使用Python将二进制数据发送到Active MQ

你在学习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相关知识，快来关注吧！