求助 rabbitmq 一直无法连接 Centos8

kspade

WEB网页 15672 端口访问正常 也可以登录!

安装了 webman的插件 stomp 不行,配置文件如下,admin 是我添加的用户 权限一切正常没问题

return [
    'default' => [
        'host'    => 'stomp://127.0.0.1:5672',
        'options' => [
            'vhost'    => '/',
            'login'    => 'admin',
            'passcode' => 'admin',
            'debug'    => true,
        ]
    ]
];

以下是rabbitmq的运行日志!无限循环这3条日志

2022-05-22 02:28:40.189589+08:00 [info] <0.615.0> accepting AMQP connection <0.615.0> (127.0.0.1:54238 -> 127.0.0.1:5672)
2022-05-22 02:28:40.189690+08:00 [error] <0.615.0> closing AMQP connection <0.615.0> (127.0.0.1:54238 -> 127.0.0.1:5672):
2022-05-22 02:28:40.189690+08:00 [error] <0.615.0> {bad_header,<<"CONNECT\n">>}

以下是宝塔终端 面板上的运行日志

求大佬帮助,
安装的是rpm:erlang-25.0-1.el8.x86_64 rabbitmq-server-3.10.2-1.el8.noarch

1236 3 0
3个回答

鲁达

老铁,你rabbitmq的stomp通道没开,开了之后端口写61613就OK了

  • chaz6chez 2022-05-22

    可以试试workerman/rabbitmq,stomp协议一般不推荐做消息队列

  • chaz6chez 2022-05-22

    如果只是发布订阅的话,stomp也可以

  • kspade 2022-05-22

    webman 不就是推荐stomp 做队列吗?插件市场也是rabbitmq/stomp 的AMQP 模式做队列

  • chaz6chez 2022-05-22

    stomp是stomp协议,workerman官方有个rabbitmq包,是amqp协议

  • kspade 2022-05-22

    那个不完整,没法 ack消费 ,没有延迟,没有重试机制a

kspade

请教一下 61613 没问题了 stomp 也启动了,但是投递消息时显示:Stomp client: not_found
我使用的是:https://www.workerman.net/doc/webman/queue/stomp.html
下面的那个:pro 就是带延迟队列那个

composer require teamones/stomp-queue

调试模式日志:

-> Try to connect to stomp://127.0.0.1:61613
-- Tcp connection established
-> Send CONNECT package, header[host:/ login:guest passcode:guest heart-beat:0,0] body[]
<- Recv CONNECTED package, header[server:RabbitMQ/3.10.2 session:session-_EjrH-426MEm2GtqGgmGSQ heart-beat:0,0 version:1.0] body[]
-> Send SEND package, header[x-delay:10000 destination:/exchange/default.exchange/default.examples content-length:40 content-type:text/plain] body[{"to":"tom@gmail.com","content":"hello"}]
<- Recv HEARTBEAT package, header[] body[]
<- Recv ERROR package, header[message:not_found content-type:text/plain version:1.0,1.1,1.2 content-length:55] body[NOT_FOUND - no exchange 'default.exchange' in vhost '/']
-- Error: not_found
Stomp client: not_found
<- Recv HEARTBEAT package, header[] body[]
-- Connection closed
-- Reconnect after 2 seconds
-- Tcp connection established
  • damao 2022-05-23

    报错里的关键信息,no exchange 'default.exchange' in vhost '/' ,没有 default.exchange 这交换机,网上找下资料看下rabbitmq怎么设置交换机

nitron

MQ其实还是推荐MQTT或者AMQP协议,STOMP这种比较适合pub/sub,比如WebSocket

  • damao 2022-05-23

    stomp 是专门为消息中间件设计的,用作MQ没问题

年代过于久远,无法发表回答
×
🔝