java - 使用协议缓冲区消息发送字符串

Question

如何将字符串作为协议缓冲区消息发送？我想做以下事情：

Message message1 = "some string"
ByteString data1 = (message1).toByteString();
System.out.println(String.format("Publishing [%s] on subject [%s]", message1, subject));
streamHandler1.publish(subject, data1);

Answer 1

您可以使用协议缓冲区将对象序列化为字节数组。

然后，将字节数组作为BytesMessage的一部分发送到 Solace 设备/VMR

在Solace 网站上有一个如何发送消息的简单示例。请注意，该示例使用TextMessage，但可以轻松替换为BytesMessage。

按顺序：

1. 连接到安慰消息路由器
2. 创建生产者
3. 创建BytesMessage对象
4. 将您的协议缓冲区序列化为字节数组
5. 将字节数组附加到先前创建的BytesMessage
6. 发送消息