在 Mainflux 中接收来自 Nats 的消息

问题描述

我试图在 Mainflux 平台中接收来自 Nats 的消息。我已使用 golang 成功接收到来自主流频道的消息，但该消息似乎格式错误。这里有json结构吗？为什么我只收到来自 nats 的消息

当我打印为字符串时的错误信息示例："$86903597-b75e-4a4d-bbfd-17a304714b86→$23f59960-7a32-4f0b-8e56-d21220c4f860"♦"{urn:dev:[urow]" :10e2073a01080063","v":23.1,"u":"Cel" }]0ՔԹ��▬" 这是我从 nats 接收消息的代码

if _,err := ec.QueueSubscribe(job,"worker",func(m *nats.Msg) {
                ec.Flush()
                //wg.Done()
                fmt.Println("Dât",string(m.Data))
                result <- string(m.Data)
            }); err != nil {
                log.Fatal(err)
            }

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）

go nats.io