4

我正在为 NodeJS 寻找一个稳定的 AMQP 1.0 客户端，以便我可以使用来自 Azure 事件中心的事件。

我曾尝试使用https://github.com/noodlefrenzy/node-amqp10，但它在某些有效负载上偶尔会出现malformed payload: Unknown code prefix: 0x30和malformed payload: Unable to decode bytes from message body: 005375b00002810c5b7b226576656e7474797065223（...）之类的消息。

我将不胜感激人们可以为 NodeJS 中稳定的 AMQP 1.0 客户端提供的任何方向。我很惊讶到目前为止我还没有找到一个，因为否则 Azure 似乎无法支持整个开发人员群。

4

2 回答 2

6

我是https://github.com/noodlefrenzy/node-amqp10的（共同）作者。您看到的错误是由于大消息被拆分为多个传输帧 - 这是我们以前没有遇到过的，所以没有实现。我们刚刚在 v2.1.0 中添加了对此的支持，所以请再次查看我们的库。

我的合著者在生产中使用它来对抗 QPID 并且已经使用了几个月，我们都积极支持它，因为我们有时间，所以如果有任何不稳定或缺失的功能，我们会尽力解决它们。通常它们只是我们不需要（令人难以置信的大）规范的功能或误解了（令人难以置信的分散的）规范细节的问题。

于 2015-11-05T16:31:14.987 回答
1

您还可以使用 Azure 事件中心的官方 JavaScript SDK，@azure/event-hubs，它在内部使用rhea

于 2020-12-08T02:35:15.520 回答