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
从服务器抓取请求
创建交换
使用路由 key 在交换上发布
创建队列cl
打印出消息(此文件收到消息时发生错误。)
文件2
队列监听
从交易所获取消息
处理消息
发布到队列cl
最佳答案
您在直接使用 amqp
模块时遇到问题吗?如果是这样,他们在 github 上的问题选项卡可能是报告问题的最佳位置。
如果您愿意,也可以尝试使用我的 servicebus
模块:https://github.com/mateodelnorte/servicebus 。 npm install servicebus
将为您获取它。
关于javascript - 中型数据发布有效,而大数据发布抛出错误? (Node.js 和 RabbitMQ),我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/17113513/