互操作性Azure Service Bus消息队列消息

Question

我有一个Java App和一个NodeJS App，它们都使用一个Azure Service Bus消息队列。

我看到与客户产生一些奇怪的影响，如下所示。

JAVA MESSAGE PRODUCER（每个Azure JMS教程使用QPID库）：

 TextMessage message = sendSession.createTextMessage();
        message.setText("Test AMQP message from JMS");
        long randomMessageID = randomGenerator.nextLong() >>>1;
        message.setJMSMessageID("ID:" + randomMessageID);
        sender.send(message);
        System.out.println("Sent message with JMSMessageID = " + message.getJMSMessageID());

输出：发送的邮件的JMSMessageID = ID：2414932965987073843

NODEJS消息消费者：

serviceBus.receiveQueueMessage(queue, {timeoutIntervalInS: timeOut, isReceiveAndDelete: true}, function(err, message) {
if(message !==null)console.log(util.inspect(message, {showHidden: false, depth: null}));
});

输出：

{ body: '@\u0006string\b3http://schemas.microsoft.com/2003/10/Serialization/�\u001aTest AMQP message from JMS',
brokerProperties:
{ DeliveryCount: 1,
EnqueuedSequenceNumber: 5000004,
EnqueuedTimeUtc: 'Wed, 04 Nov 2015 21:28:21 GMT',
MessageId: '2414932965987073843',
PartitionKey: '89',
SequenceNumber: 59672695067659070,
State: 'Active',
TimeToLive: 1209600,
To: 'moequeue' },
contentType: 'application/xml; charset=utf-8' }

如果将其与通过serviceBus.sendQueueMessage（）插入队列中的消息进行比较，则属性如下所示：

{ body: 'test message',
brokerProperties:
{ DeliveryCount: 1,
EnqueuedSequenceNumber: 0,
EnqueuedTimeUtc: 'Wed, 04 Nov 2015 21:44:03 GMT',
MessageId: 'bc0a3d4f-15ba-434f-9fb0-1a3789885f8c',
PartitionKey: '734',
SequenceNumber: 37436171906517256,
State: 'Active',
TimeToLive: 1209600 },
contentType: 'text/plain',
customProperties:
{ message_number: 0,
sent_date: Wed Nov 04 2015 21:44:03 GMT+0000 (UTC) } }

因此内容类型从一开始就不同-为什么？-然后第一个消息有效内容的主体中的奇怪垃圾来自 何处 ： @ \ u0006string \
b3http：//schemas.microsoft.com/2003/10/Serialization/。\ u001a

这是序列化的结果吗？如何缓解这种情况？

在此处也找到代码：http :
//pastebin.com/T9RTFRBk

Answer 1

Azure服务总线支持两种不同的协议：AMQP和HTTP。使用qpid库的Java /
JMS将AMQP协议用于ServiceBus。但是，NodeJS通过HTTP协议包装了ServiceBus REST API。

有关Service Bus中AMQP支持的详细信息，请参阅https://azure.microsoft.com/zh-
cn/documentation/articles/service-bus-amqp-
overview/。

对于ServiceBus的REST API，请参阅https://msdn.microsoft.com/en-
us/library/azure/hh780717.aspx。

AMQP是二进制的应用程序层协议，旨在有效地支持各种消息传递应用程序和通信模式。-
来自WikiPedia

但是HTTP是文本协议。

消息格式如下，请参阅Message Formataritifact 的部分：http: //docs.oasis-open.org/amqp/core/v1.0/os/amqp-core-
messaging-v1.0-os.html ＃section-message-format。而且AMQP规范可以参考html" target="_blank">http://docs.oasis-open.org/amqp/core/v1.0/os/amqp-core-
overview-v1.0-os.html。

                                                     Bare Message
                                                            |
                                      .---------------------+--------------------.
                                      |                                          |
 +--------+-------------+-------------+------------+--------------+--------------+--------+
 | header | delivery-   | message-    | properties | application- | application- | footer |
 |        | annotations | annotations |            | properties   | data         |        |
 +--------+-------------+-------------+------------+--------------+--------------+--------+
 |                                                                                        |
 '-------------------------------------------+--------------------------------------------'
                                             |
                                      Annotated Message

因此，以Java发送或以NodeJS发送的消息被序列化为不同的结果。

\uXXXXAMQP正文内容中格式化的内容是Unicode Charater。

Unicode字符\u0006是Acknowledge控制字符，请参阅https://en.wikipedia.org/wiki/Acknowledge_character来了解。

Unicode字符\u001a是替代控制字符，请参阅https://en.wikipedia.org/wiki/Substitute_character。

它们限制了消息头中元数据的开始和结束。