我们可以使用 AMQP Go 消费者将从 JMS 发布者发布的事件映射到结构吗？

有志者，事竟成！如果你在学习Golang，那么本文《我们可以使用 AMQP Go 消费者将从 JMS 发布者发布的事件映射到结构吗？》，就很适合你！文章讲解的知识点主要包括，若是你对本文感兴趣，或者是想搞懂其中某个知识点，就请你继续往下看吧~

我有一个发布者，它使用 jms 通过 amqp 将数据发布到主题。它使用名为 wso2 消息代理的消息代理。

在默认的 java 实现中，接收到的消息被映射到 javax.jms.mapmessage 对象，并从带有键值对的映射中提取值。

我想从 go 客户端订阅主题以检索消息。我可以使用 https://github.com/streadway/amqp 库连接到消息代理，并使用 amqp.delivery 类型检索所需的消息，其正文为字节数组。但是当我尝试将其解组/解码为结构/映射时，出现错误 invalid character '\x00'looking for opening of value。

这是从java端收到的消息，

body:
{event_type=key_manager_configuration, name=newkm, action=update, type=okta, tenantdomain=carbon.super, value=eyjjbgfpbv9tyxbwaw5ncyi6w10simf1dghvcml6zv9lbmrwb2ludci6imh0dhbzoi8vzgv2lti3mzewndkub2t0ys5jb20vb2f1dggyl2rlzmf1bhqvdjevyxv0ag9yaxpliiwiyxbps2v5ijoimdbrakd2afotvthxnvptq1dwrvy5qy0znve2qzfjdxhotetvmdhidjjyiiwiz3jhbnrfdhlwzxmiolsiyxv0ag9yaxphdglvbl9jb2rliiwiaw1wbgljaxqilcjyzwzyzxnox3rva2vuiiwicgfzc3dvcmqilcjjbgllbnrfy3jlzgvudglhbhmixswizw5hymxlx29hdxrox2fwcf9jcmvhdglvbii6dhj1zswiaw50cm9zcgvjdglvbl9lbmrwb2ludci6imh0dhbzoi8vzgv2lti3mzewndkub2t0ys5jb20vb2f1dggyl2rlzmf1bhqvdjevaw50cm9zcgvjdcisimnlcnrpzmljyxrlx3zhbhvlijoiahr0chm6ly9kzxytmjczmta0os5va3rhlmnvbs9vyxv0adivzgvmyxvsdc92ms9rzxlziiwizw5hymxlx3rva2vux2dlbmvyyxrpb24ionrydwusimnsawvudf9pzci6ijbvytfjedr5aji4uvjzmuhinwq2iiwiaxnzdwvyijoiahr0chm6ly9kzxytmjczmta0os5va3rhlmnvbs9vyxv0adivzgvmyxvsdcisimvuywjszv9tyxbfb2f1dghfy29uc3vtzxjfyxbwcyi6dhj1zswizw5hymxlx3rva2vux2hhc2giomzhbhnllcjzzwxmx3zhbglkyxrlx2p3dci6zmfsc2usinjldm9rzv9lbmrwb2ludci6imh0dhbzoi8vzgv2lti3mzewndkub2t0ys5jb20vb2f1dggyl2rlzmf1bhqvdjevcmv2b2tliiwid2vsbf9rbm93bl9lbmrwb2ludci6imh0dhbzoi8vzgv2lti3mzewndkub2t0ys5jb20vb2f1dggyl2rlzmf1bhqvlndlbgwta25vd24vb2f1dggtyxv0ag9yaxphdglvbi1zzxj2zxiilcjzy29wzxnfy2xhaw0ioijzy3ailcjlbmfibgvfdg9rzw5fzw5jcnlwdglvbii6zmfsc2usimnsawvudf9yzwdpc3ryyxrpb25fzw5kcg9pbnqioijodhrwczovl2rldi0ynzmxmdq5lm9rdgeuy29tl29hdxromi92ms9jbgllbnrziiwidg9rzw5fzm9ybwf0x3n0cmluzyi6ilt7xcjpzfwiojesxcjlbmfibgvcijp0cnvllfwidhlwzvwiolwislduxcisxcj2ywx1zvwiontcimjvzhlcijp7fx19xsisimnvbnn1bwvyx2tlev9jbgfpbsi6imnpzcisimnsawvudf9zzwnyzxqioijaclzfnnatcs0zsy01bzdldfficmtwum9mmmi1udzyeu1rctzxclnsiiwiy2vydglmawnhdgvfdhlwzsi6ikpxs1milcj0b2tlbl9lbmrwb2ludci6imh0dhbzoi8vzgv2lti3mzewndkub2t0ys5jb20vb2f1dggyl2rlzmf1bhqvdjevdg9rzw4ifq==, enabled=false}
jms correlation id: null
jms timestamp: 1607418910052
jms expiration: 0
jms priority: 4
jms delivery mode: 2
jms reply to: null
jms redelivered: false
jms destination: topic://amq.topic/keymanager/?routingkey='keymanager'&exclusive='true'&autodelete='true'
jms type: null
jms messageid: id:d0ef4dac-9844-3e66-9a4e-a8f2448d360d
jms content-type: amqp/map
amq message number: 6
properties:
    jms_qpid_desttype = 2

这是从go端接收到的字节数组转换后的字符串，

\x00\x00\a\x0f\x00\x00\x00\a\nevent_type\x98\x00\x00\x00\x19key_manager_configuration\x04name\x98\x00\x00\x00\x05newkm\x06action\x98\x00\x00\x00\x06update\x04type\x98\x00\x00\x00\x04okta\ftenantdomain\x98\x00\x00\x00\fcarbon.super\x05value\x98\x00\x00\x06\x80eyjjbgfpbv9tyxbwaw5ncyi6w10simf1dghvcml6zv9lbmrwb2ludci6imh0dhbzoi8vzgv2lti3mzewndkub2t0ys5jb20vb2f1dggyl2rlzmf1bhqvdjevyxv0ag9yaxpliiwiyxbps2v5ijoimdbrakd2afotvthxnvptq1dwrvy5qy0znve2qzfjdxhotetvmdhidjjyiiwiz3jhbnrfdhlwzxmiolsiyxv0ag9yaxphdglvbl9jb2rliiwiaw1wbgljaxqilcjyzwzyzxnox3rva2vuiiwicgfzc3dvcmqilcjjbgllbnrfy3jlzgvudglhbhmixswizw5hymxlx29hdxrox2fwcf9jcmvhdglvbii6dhj1zswiaw50cm9zcgvjdglvbl9lbmrwb2ludci6imh0dhbzoi8vzgv2lti3mzewndkub2t0ys5jb20vb2f1dggyl2rlzmf1bhqvdjevaw50cm9zcgvjdcisimnlcnrpzmljyxrlx3zhbhvlijoiahr0chm6ly9kzxytmjczmta0os5va3rhlmnvbs9vyxv0adivzgvmyxvsdc92ms9rzxlziiwizw5hymxlx3rva2vux2dlbmvyyxrpb24ionrydwusimnsawvudf9pzci6ijbvytfjedr5aji4uvjzmuhinwq2iiwiaxnzdwvyijoiahr0chm6ly9kzxytmjczmta0os5va3rhlmnvbs9vyxv0adivzgvmyxvsdcisimvuywjszv9tyxbfb2f1dghfy29uc3vtzxjfyxbwcyi6dhj1zswizw5hymxlx3rva2vux2hhc2giomzhbhnllcjzzwxmx3zhbglkyxrlx2p3dci6zmfsc2usinjldm9rzv9lbmrwb2ludci6imh0dhbzoi8vzgv2lti3mzewndkub2t0ys5jb20vb2f1dggyl2rlzmf1bhqvdjevcmv2b2tliiwid2vsbf9rbm93bl9lbmrwb2ludci6imh0dhbzoi8vzgv2lti3mzewndkub2t0ys5jb20vb2f1dggyl2rlzmf1bhqvlndlbgwta25vd24vb2f1dggtyxv0ag9yaxphdglvbi1zzxj2zxiilcjzy29wzxnfy2xhaw0ioijzy3ailcjlbmfibgvfdg9rzw5fzw5jcnlwdglvbii6zmfsc2usimnsawvudf9yzwdpc3ryyxrpb25fzw5kcg9pbnqioijodhrwczovl2rldi0ynzmxmdq5lm9rdgeuy29tl29hdxromi92ms9jbgllbnrziiwidg9rzw5fzm9ybwf0x3n0cmluzyi6ilt7xcjpzfwiojesxcjlbmfibgvcijp0cnvllfwidhlwzvwiolwislduxcisxcj2ywx1zvwiontcimjvzhlcijp7fx19xsisimnvbnn1bwvyx2tlev9jbgfpbsi6imnpzcisimnsawvudf9zzwnyzxqioijaclzfnnatcs0zsy01bzdldfficmtwum9mmmi1udzyeu1rctzxclnsiiwiy2vydglmawnhdgvfdhlwzsi6ikpxs1milcj0b2tlbl9lbmrwb2ludci6imh0dhbzoi8vzgv2lti3mzewndkub2t0ys5jb20vb2f1dggyl2rlzmf1bhqvdjevdg9rzw4ifq==\aenabled\b\x00

如果有人可以指导我找到一种解决方法，使该消息可用，那将是一个很大的帮助。

这是用于解组消息的代码片段

func handle(deliveries <-chan amqp.Delivery, done chan error) {
    for d := range deliveries {
        var bar map[string]string
        err := json.Unmarshal(d.Body, &bar)
        if err != nil {
            log.Println(err)
        }
        log.Println(bar)
        d.Ack(false)
    }
    log.Printf("handle: deliveries channel closed")
    done <- nil
}

解决方案

不要依赖代理或协议特定的转换。您应该发送与协议无关的数据（例如 JSON、protobuf、XML 等），然后在客户端中进行转换。

如果您依赖经纪人提供此类功能，那么您将受到其摆布，这意味着如果您更换经纪人，情况可能会发生变化。这不利于应用程序的可移植性，并最终威胁应用程序的稳定性。

终于介绍完啦！小伙伴们，这篇关于《我们可以使用 AMQP Go 消费者将从 JMS 发布者发布的事件映射到结构吗？》的介绍应该让你收获多多了吧！欢迎大家收藏或分享给更多需要学习的朋友吧~golang学习网公众号也会发布Golang相关知识，快来关注吧！