|
|
@@ -9,6 +9,7 @@ import (
|
|
|
"time"
|
|
|
|
|
|
mqtt "github.com/eclipse/paho.mqtt.golang"
|
|
|
+ "github.com/google/uuid"
|
|
|
"hnyfkj.com.cn/rtu/linux/baseapp"
|
|
|
)
|
|
|
|
|
|
@@ -34,6 +35,7 @@ var (
|
|
|
type MQTTCoupler struct {
|
|
|
broker, username, password string
|
|
|
client mqtt.Client
|
|
|
+ clientID string
|
|
|
|
|
|
imei string // 设备唯一标识
|
|
|
subTopic string // 订阅应答主题:/yfkj/device/rpc/imei/ack
|
|
|
@@ -58,6 +60,7 @@ func init() {
|
|
|
broker: CfgServers.MQTTSrv.Address,
|
|
|
username: CfgServers.MQTTSrv.Username,
|
|
|
password: CfgServers.MQTTSrv.Password,
|
|
|
+ clientID: uuid.New().String(),
|
|
|
cwd: "/",
|
|
|
ctx: ctx,
|
|
|
cancel: cancel,
|