你在学习Golang相关的知识吗？本文《使用Python将二进制数据发送到Active MQ》，主要介绍的内容就涉及到，如果你想提升自己的开发能力，就不要错过这篇文章，大家要知道编程理论基础和实战操作都是不可或缺的哦！
问题内容我正在尝试将简单的字符串消息写入 activemq 队列：
def write_to_amq(message, host_name, port, queue):
conn = blockingconnection(f'{host_name}:{port}')
sender = conn.create_sender(queue)
sender.send(message(body='message'))
conn.close()
消息很好地到达队列，但当我在 activemq web ui 上查看它时，其中似乎有一些二进制数据。它将内容报告为 spessesw�message。我期望内容只是 message
[其他数据点]
我还在使用 pack.ag/amqp 包编写的单独 go 程序中看到了这一点。
func (s *amqpSender) SendResult(data string) error {
session, err := s.client.NewSession()
if err != nil {
return fmt.Errorf("failure creating AMQP session: %s", err)
}
ctx := context.Background()
sender, err := session.NewSender(
amqp.LinkTargetAddress(s.workQueueName),
)
if err != nil {
return fmt.Errorf("failure creating sender link: %s", err)
}
ctx, cancel := context.WithTimeout(ctx, s.timeout)
defer func() {
cancel()
sender.Close(ctx)
}()
err = sender.Send(ctx, amqp.NewMessage([]byte(data)))
if err != nil {
return fmt.Errorf("failure sending message: %s", err)
}
return nil
}当我向 activemq 发送不同的消息时，我会得到类似的行为，在 activemq 消息详细信息中看到 su�vmy message。这可能只是网络用户界面异常吗？
解决方案
这不是网络异常，如果您在 openwire 协议下收到消息，您将看到与在网页上看到的相同的内容。看来 activemq 对消息有效负载内的属性进行了编码，因此开头有那些奇怪的字符。我的假设是 activemq 对您在正文开头的网页右上角看到的这些属性进行编码：
此外，如果您要使用 openwire 或 stomp 等基于文本的协议发送消息，您将不会在正文开头看到任何属性或奇怪的字节。
此问题有 3 种可能的解决方案：
如果您想继续使用 activemq
- 正如 here 所说，您可以添加
<transportConnectors>
<transportConnector name="amqp" uri="amqp://localhost:5672?transport.transformer=jms"/>
</transportConnectors>在 activemq 配置中，amqp 消息将转换为 jms textmessage。但是，如果您使用的是 aws 的托管 activemq 服务 amazon mq，则此配置当前不可用。因此，请开具一张票，以便他们优先处理此问题。
- 使用基于文本的协议而不是 amqp，例如 openwire 或 stomp
如果您不介意使用其他代理，则使用 activemq
- 考虑切换到 rabbitmq，其中 amqp 是一等公民。
我知道这个问题已经存在一年多了，但我希望这仍然有帮助！
终于介绍完啦！小伙伴们，这篇关于《使用Python将二进制数据发送到Active MQ》的介绍应该让你收获多多了吧！欢迎大家收藏或分享给更多需要学习的朋友吧~编程网公众号也会发布Golang相关知识，快来关注吧！
