认证与连接

// connectAIoT 连接并订阅
func connectAIoT(t *testing.T) (client *comm.Client, err error) {
	connParam := &comm.MqttConnParam{
		IP:           "127.0.0.1",              //mqtt IP地址
		Port:         30394,                    //mqtt 端口
		ProductId:    "xx",                     //物模型产品id
		DeviceId:     "xx",                     //物模型设备id
		ClientId:     "xx",                     //连接mqtt  clientId
		DeviceSecret: "xx",                     //物模型设备id
		SignMethod:   comm.SIGN_METHOD_HMACMD5, //连接mqtt加密方式。hmacmd5/hmacsha256/hmacsha1 三种方式。
		ExtraData:    nil,                      //连接扩展参数。 可自行根据需要定义。后续可在需要的时候获取。
	}
	callback := NewReceiveDataHandle() //收到消息后的回调method
	client, err = comm.NewMqttClient(connParam, callback)
	if err != nil {
		t.Errorf("ConnectAIoT. NewMqttClient fail., err:%s", err.Error())
		return
	}

	//连接并订阅
	err = client.ConnAndSubscribe()
	if err != nil {
		if err == comm.ErrClientIsQuit {
			t.Logf("ConnectAIoT. client is quit. ")
			return
		}
		t.Errorf("conn. ConnAndSubscribe fail.  err:%s", err.Error())

		return
	}

	return
}