golang 如何实现mqtt的p2p消息收发？

连接

package mqtt

import ( "crypto/tls" "crypto/x509" "fmt" mqtt "github.com/eclipse/paho.mqtt.golang" "io/ioutil" "log" "src/goProject1/base_64" "src/goProject1/config" "strconv" "time" )

var ( broker string port int AccessKey_ID string AccessKey_Secret string InstanceId string client mqtt.Client groupId string

clientId string

connectHandler mqtt.OnConnectHandler = func(client mqtt.Client) { fmt.Println("Connected") } connectLostHandler mqtt.ConnectionLostHandler = func(client mqtt.Client, err error) { fmt.Printf("Connect lost: %v", err) } // 默认处理接收的消息 messagePubHandler mqtt.MessageHandler = func(client mqtt.Client, msg mqtt.Message) { fmt.Printf("Received message: %s from topic: %s\n", msg.Payload(), msg.Topic()) }