rabbitmq 應(yīng)該要安裝stomp插件才能用stomp，具體百度下 rabbitmq stomp

https://www.rabbitmq.com/stomp.html
http://m.wtbis.cn/plugin/13#%E9%A1%B9%E7%9B%AE%E5%9C%B0%E5%9D%80
按照手冊(cè)stomp應(yīng)該連 61613 端口，你可能連錯(cuò)了端口了

我弄了個(gè)新的ubuntu服務(wù)器試了下，很順利就通了
1、安裝rabbitmq-server，apt-get install rabbitmq-server
2、啟用stomp，rabbitmq-plugins enable rabbitmq_stomp
3、按照手冊(cè)安裝webman/stomp，composer require webman/stomp
4、按照手冊(cè)新建控制器投遞消息

<?php
namespace app\controller;

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

class Index
{
    public function queue(Request $request)
    {
        // 隊(duì)列
        $queue = 'examples';
        // 數(shù)據(jù)（傳遞數(shù)組時(shí)需要自行序列化，比如使用json_encode，serialize等）
        $data = json_encode(['to' => 'tom@gmail.com', 'content' => 'hello']);
        // 執(zhí)行投遞
        Client::send($queue, $data);

        return response('redis queue test');
    }

}

5、按照手冊(cè)新建消費(fèi)者消費(fèi)消息

<?php
namespace app\queue\stomp;

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

class MyMailSend implements Consumer
{
    // 隊(duì)列名
    public $queue = 'examples';

    // 連接名，對(duì)應(yīng) stomp.php 里的連接`
    public $connection = 'default';

    // 值為 client 時(shí)需要調(diào)用$ack_resolver->ack()告訴服務(wù)端已經(jīng)成功消費(fèi)
    // 值為 auto   時(shí)無需調(diào)用$ack_resolver->ack()
    public $ack = 'auto';

    // 消費(fèi)
    public function consume($data, AckResolver $ack_resolver = null)
    {
        // 如果是數(shù)據(jù)是數(shù)組，需要自行反序列化
        var_export(json_decode($data, true)); // 輸出 ['to' => 'tom@gmail.com', 'content' => 'hello']
        // 告訴服務(wù)端，已經(jīng)成功消費(fèi)
        $ack_resolver->ack(); // ack為 auto時(shí)可以省略此調(diào)用
    }
}

6、啟動(dòng)workerman

7、訪問控制器http://127.0.0.1:8787/index/queue，

8、終端顯示消費(fèi)成功

以上rabbitmq除了apt-get install rabbitmq-server rabbitmq-plugins enable rabbitmq_stomp 2句命令，什么都沒設(shè)置，代碼完全照抄手冊(cè)，一次成功

stomp插件有時(shí)候會(huì)丟失消息,如圖所示,生產(chǎn)了,確沒有消費(fèi), 還有一個(gè)問題,重啟rabbitmq后,所有的消息都會(huì)丟失,沒有持久化,不知道什么原因