1
Unhandled connection error: FRAME_ERROR - type 1, 
first 16 octets = <<0,60,0,20,0,0,16,99,108,111,117,100,82,111,117,116>>: {invalid_frame_end_marker,82}

我创建了一个使用路由键直接发布到队列 1 的交换器。队列 1 然后在对该消息执行工作后发布到具有路由密钥 cl 的同一交换到队列。这是它引发错误的地方。

文件 1
来自服务器的抓取请求
Create Exchange
Publish on exchange 使用路由密钥
Create queue cl
打印出消息(此文件收到消息时发生错误。)

文件 2

队列监听

从交换中获取消息

处理消息

发布到队列 cl

4

1 回答 1

-1

amqp直接使用模块有问题吗?如果是这样,他们在 github 上的问题选项卡可能是报告问题的最佳地点。

如果您愿意,也可以尝试使用我的servicebus模块:https ://github.com/mateodelnorte/servicebus 。npm install servicebus会给你的。

于 2013-06-15T17:19:47.793 回答