javascript - 中型数据发布有效,而大数据发布抛出错误? (Node.js 和 RabbitMQ)

标签 javascript node.js rabbitmq

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/servicebusnpm install servicebus 将为您获取它。

关于javascript - 中型数据发布有效,而大数据发布抛出错误? (Node.js 和 RabbitMQ),我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/17113513/

相关文章:

javascript - javascript 中 functionName() 和 functionName.call() 的区别

node.js - 配置 Electron/Node 以在调试中运行并附加调试器

javascript - 使用 Azure VM Javascript SDK 从 RunCommand 获取 StdOut

javascript - 使用 Slack 的 Node SDK 的 files.upload 问题

Python Celery 线程、工作线程和 vCPU

python - 使用 aioamqp 的异步 RabbitMQ 消费者

c# - RabbitMq - ConversationId 与 CorrelationId - 哪个更适合跟踪特定请求?

Javascript 数组只显示最后一个子元素

javascript - 缩放的 Canvas 元素的坐标

php - 获取表单数据并将其发送到浏览器中的新选项卡