webman如何使用stomp队列插件操作rabbimq

rabbitmq 应该要安装stomp插件才能用stomp，具体百度下 rabbitmq stomp

https://www.rabbitmq.com/stomp.html
https://www.workerman.net/plugin/13#%E9%A1%B9%E7%9B%AE%E5%9C%B0%E5%9D%80
按照手册stomp应该连 61613 端口，你可能连错了端口了

我弄了个新的ubuntu服务器试了下，很顺利就通了
1、安装rabbitmq-server，apt-get install rabbitmq-server
2、启用stomp，rabbitmq-plugins enable rabbitmq_stomp
3、按照手册安装webman/stomp，composer require webman/stomp
4、按照手册新建控制器投递消息

<?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');
    }

}

5、按照手册新建消费者消费消息

<?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时可以省略此调用
    }
}

6、启动workerman

7、访问控制器http://127.0.0.1:8787/index/queue，

8、终端显示消费成功

以上rabbitmq除了apt-get install rabbitmq-server rabbitmq-plugins enable rabbitmq_stomp 2句命令，什么都没设置，代码完全照抄手册，一次成功

stomp插件有时候会丢失消息,如图所示,生产了,确没有消费, 还有一个问题,重启rabbitmq后,所有的消息都会丢失,没有持久化,不知道什么原因