开发者社区 > 云原生 > 云消息队列 > 正文

MQTT可以用golang发送p2p消息吗?

MQTT可以用golang发送p2p消息吗?

展开
收起
真的很搞笑 2024-01-04 09:27:15 139 0
3 条回答
写回答
取消 提交回答
  • 是的,使用Go语言(Golang)可以实现MQTT协议的点对点(P2P)消息发送。MQTT协议本身支持多种消息收发模式,其中包括发布/订阅(Pub/Sub)模式和点对点(P2P)模式。在Pub/Sub模式下,消息从一个或多个发布者(Publisher)发送到多个订阅者(Subscriber),这种模式适用于一对多或多对多的消息分发场景。而P2P模式则是针对一对一的消息传输,在这种模式下,消息的发送者明确知道接收者的身份信息,直接向其发送消息,适合于需要节约订阅成本的单点对单点的消息传递。

    在Golang中实现MQTT P2P消息发送,可以使用第三方库,例如Eclipse Paho MQTT库。首先,需要通过Go的包管理工具安装这个库:

    go get github.com/eclipse/paho.mqtt.golang
    

    接下来,创建MQTT客户端并连接到MQTT服务器,在发送消息时使用特定的Topic格式来指明P2P消息的接收者。Topic的格式通常为"topic/p2p/GID_xxxx@@@DEVICEID_001",其中GID_xxxx代表群组ID,DEVICEID_001代表设备ID。例如,发送方在发送P2P消息时,会将消息发布到这样的Topic上:

    package main
    
    import (
        "fmt"
        "time"
    
        "github.com/eclipse/paho.mqtt.golang"
    )
    
    func main() {
        client := paho.NewClient(...)
        token := client.Connect()
        token.Wait()
    
        // 假设我们已经有了正确的client ID
        p2pTopic := "topic/p2p/GID_xxxx@@@DEVICEID_001"
        client.Publish(p2pTopic, 0, false, "Your P2P Message")
    
        client.Disconnect(250)
    }
    

    在这个例子中,"Your P2P Message"是想要发送的具体消息内容,0表示消息的质量服务(QoS)等级,这里使用的是QoS 0,即至少传送一次,不保证消息到达。false表示消息不是持久消息。

    接收方在接收到P2P消息后,不需要提前订阅,就可以直接收到消息。

    需要注意的是,在使用Paho MQTT库时,需要处理连接返回的token,确保连接成功后再进行消息的发布和订阅操作。此外,还需要处理连接丢失、消息发布失败等情况,通常通过设置连接选项中的回调函数来完成。

    总之,Golang结合MQTT协议和适当的库支持,可以方便地实现设备之间的P2P消息通信,这在物联网(IoT)应用中是非常实用的技术。

    2024-01-06 11:54:33
    赞同 展开评论 打赏
  • 面对过去,不要迷离;面对未来,不必彷徨;活在今天,你只要把自己完全展示给别人看。

    是的,Golang可以使用paho.mqtt.golang库来发送和接收MQTT消息。这个库提供了实现客户端与MQTT服务器连接、订阅、收发消息等功能的方法。

    除了标准MQTT协议所支持的发布/订阅(Pub/Sub)模式外,云消息队列 MQTT版还支持点对点(Point to Point,简称P2P)模式。因此,你也可以使用Golang进行点对点的MQTT消息传输。

    值得注意的是,对于MQTT broker,目前主流的实现有EMQ,mosquito,HiveMQ等,但是并没有一个很完整的Go语言实现。而Gmqtt项目则完整地实现了MQTT V3.1.1和最新的V5协议,应该是Go语言中对MQTT协议支持最完整的项目。

    2024-01-04 17:35:00
    赞同 展开评论 打赏
  • go sdk 不行 ,此回答整理自钉群“阿里云 微消息队列 MQTT产品咨询群”

    2024-01-04 11:52:22
    赞同 展开评论 打赏
问答分类:
相关产品:

涵盖 RocketMQ、Kafka、RabbitMQ、MQTT、轻量消息队列(原MNS) 的消息队列产品体系,全系产品 Serverless 化。RocketMQ 一站式学习:https://rocketmq.io/

相关产品

  • 云消息队列 MQ
  • 热门讨论

    热门文章

    相关电子书

    更多
    基于RocketMQ Prometheus Exporter 立即下载
    基于RocketMQ Connect 构建全新数据流转处理平 立即下载
    RocketMQ Client-GO 介绍 立即下载