Stomp 队列

Stomp 是简单 (流) 文本定向消息协议，它提供了一个可互操作的连接格式，允许 STOMP 客户端与任意 STOMP 消息代理（Broker）进行交互。workerman/stomp 实现了 Stomp 客户端，主要用于 RabbitMQ、Apollo、ActiveMQ 等消息队列场景。

安装

composer require webman/stomp

配置

配置文件在 config/plugin/webman/stomp 下

投递消息

<?php
namespace app\controller;

use support\Request;
use Webman\Stomp\Client;

class Index
{
    public function queue(Request $request)
    {
        // 队列
        $queue = 'examples';
        // 数据（传递数组时需要自行序列化，比如使用json_encode，serialize等）
        $data = json_encode(['to' => 'tom@gmail.com', 'content' => 'hello']);
        // 执行投递
        Client::send($queue, $data);

        return response('redis queue test');
    }

}

为了兼容其它项目，Stomp 组件没有提供自动序列化反序列化功能，如果投递的是数组数据，需要自行序列化，消费的时候自行反序列化

消费消息

新建 app/queue/stomp/MyMailSend.php (类名任意，符合 psr4 规范即可)。

<?php
namespace app\queue\stomp;

use Workerman\Stomp\AckResolver;
use Webman\Stomp\Consumer;

class MyMailSend implements Consumer
{
    // 队列名
    public $queue = 'examples';

    // 连接名，对应 stomp.php 里的连接`
    public $connection = 'default';

    // 值为 client 时需要调用$ack_resolver->ack()告诉服务端已经成功消费
    // 值为 auto   时无需调用$ack_resolver->ack()
    public $ack = 'auto';

    // 消费
    public function consume($data, AckResolver $ack_resolver = null)
    {
        // 如果是数据是数组，需要自行反序列化
        var_export(json_decode($data, true)); // 输出 ['to' => 'tom@gmail.com', 'content' => 'hello']
        // 告诉服务端，已经成功消费
        $ack_resolver->ack(); // ack为 auto时可以省略此调用
    }
}

rabbitmq 开启 stomp 协议

rabbitmq 默认没有开启 stomp 协议，需要执行以下命令开启

rabbitmq-plugins enable rabbitmq_stomp

开启后 stomp 的端口默认为 61613。