package main import ( "encoding/json" paho "github.com/eclipse/paho.mqtt.golang" ) func main() { o := paho.NewClientOptions() o.SetClientID("mqttx_82fac77f") o.AddBroker("mqtt://broker.emqx.io:1833") // o.SetUsername("mqtt") // o.SetPassword("123456") c := paho.NewClient(o) c.Publish("testtopic/PLC325454756", byte('0'), false, json.Encoder("{"key1":2,"Speed1":40,"Speed2":50,"YV1":0,"YV2":1}")) }