diff --git a/mbtk/test/libmbtk_mqtt/Makefile b/mbtk/test/libmbtk_mqtt/Makefile
new file mode 100755
index 0000000..4802389
--- /dev/null
+++ b/mbtk/test/libmbtk_mqtt/Makefile
@@ -0,0 +1,34 @@
+ROOT = $(shell pwd)/../../..
+include $(ROOT)/mbtk/Make.defines
+
+INC_DIR +=
+
+LIB_DIR +=
+
+LIBS += -lmbtk_lib -lmbtk_net -lmbtk_mqtt -lmbtk_http
+
+CFLAGS += 
+
+DEFINE +=
+
+LOCAL_SRC_FILES = $(wildcard *.c) $(wildcard *.cpp)
+
+$(info LOCAL_SRC_FILES = $(LOCAL_SRC_FILES))
+
+OBJS = $(patsubst %.c,%.o,$(patsubst %.cpp,%.o,$(LOCAL_SRC_FILES)))
+BINS = $(patsubst %.o,%,$(OBJS))
+
+all: $(BINS)
+
+$(BINS):$(OBJS)
+	@echo "  BIN     $@"
+	$(CC) $(CFLAGS) $(LIB_DIR) $(LIBS) $@.o -o $(OUT_DIR)/bin/$@
+
+%.o:%.c
+	$(CC) $(CFLAGS) $(INC_DIR) $(DEFINE) -c $< -o $@
+
+%.o:%.cpp
+	$(CC) $(CFLAGS) $(INC_DIR) $(DEFINE) -c $< -o $@
+
+clean:
+	rm -f $(OBJS)
diff --git a/mbtk/test/libmbtk_mqtt/mbtk_mqtt_aliyun_test.c b/mbtk/test/libmbtk_mqtt/mbtk_mqtt_aliyun_test.c
new file mode 100755
index 0000000..923b123
--- /dev/null
+++ b/mbtk/test/libmbtk_mqtt/mbtk_mqtt_aliyun_test.c
@@ -0,0 +1,190 @@
+#include <stdio.h>
+#include "mbtk_mqtt.h"
+#include "pthread.h"
+#include "string.h"
+#include "unistd.h"
+#include "sys/stat.h"
+#include "sys/types.h"
+#include "sys/socket.h"
+#include "netinet/in.h"
+#include "arpa/inet.h"
+#include "fcntl.h"
+#include "mbtk_sock2.h"
+/*
+typedef struct {
+    char clientId[255];
+    char deviceToken[255];
+} regnwl_info_t;
+*/
+
+int aliyun_xiyinyimi_connect(mbtk_mqtt_device_session_t *device, regnwl_info_t *regn);
+
+struct opts_struct opts = {
+    (char *)"iot-dev", 0, (char *)"\n", QOS0, "admin", "password", (char *)"localhost", 1883, 0
+};//初始化结构体
+
+iot_device_info_t gateway = {
+    .iotstatus = IOT_STATUS_LOGIN,
+    .model = {"2022"},
+    .company = {"/my"}
+};//初始化主题
+
+static Cloud_MQTT_t *miot_mqtt;
+
+void set_mqtt_t(Cloud_MQTT_t *piot_mqtt)
+{
+    miot_mqtt = piot_mqtt;
+}
+Cloud_MQTT_t * get_mqtt_t()
+{
+    return miot_mqtt;
+}
+
+void mqtt_data_rx_cb(void *pbuf, int len) 
+{
+
+    printf("data = %s\n", (unsigned char *)pbuf);	//打印接收到的数据
+}
+
+
+void MQTTMessageArrived_Cb(MessageData* md)
+{
+    MQTTMessage *message = md->message; 
+
+    Cloud_MQTT_t *piot_mqtt = get_mqtt_t();
+
+    if (NULL != piot_mqtt->DataArrived_Cb) {
+        piot_mqtt->DataArrived_Cb((void *)message->payload, message->payloadlen);//异步消息体
+    }
+}
+
+
+void *mqtt_thread(void *arg)
+{
+    while (gateway.iotstatus != IOT_STATUS_DROP){
+        printf("gateway.iotstatus is %d\n",gateway.iotstatus);
+        iot_yield(arg,&gateway);									//维持服务器稳定，断开重连
+    }
+    printf("gateway.iotstatus is IOT_STATUS_DROP");
+//    mqtt_device_disconnect(arg);
+    pthread_exit(NULL);
+    return NULL;
+}
+
+
+
+//int mbtk_aliyun_mqtt_register_init(mbtk_mqtt_device_session_t *mbtk_mqtt_device )
+int main(int argc, char *argv[])
+{
+
+    printf("aliyun mqtt start2\n");
+    int ret, len; 
+    char will_msg[256] = {"hello world"};						//初始化遗嘱数据
+    static int i = 0;
+
+    mbtk_mqtt_device_session_t mbtk_mqtt_device = {0};
+    memcpy(mbtk_mqtt_device.device_name, argv[1] , strlen(argv[1]));
+    memcpy(mbtk_mqtt_device.product_key, "a14Vv4QUPeP" , strlen("a14Vv4QUPeP"));
+    memcpy(mbtk_mqtt_device.product_secret, "GiBigxEaluyAPnD4" , strlen( "GiBigxEaluyAPnD4"));
+    mbtk_mqtt_device.host = 0;
+    mbtk_mqtt_device.port = 1883;
+
+
+    Cloud_MQTT_t *Iot_mqtt;
+    Iot_mqtt = (Cloud_MQTT_t *)malloc(sizeof(Cloud_MQTT_t));
+    memset(Iot_mqtt,0x0,sizeof(Cloud_MQTT_t));
+
+    //一型一密免预注册mqtt
+    mbtk_aliyun_mqtt_one_type_one_secret_unregin_set_info_init(Iot_mqtt, &mbtk_mqtt_device,60*1000,4,mqtt_data_rx_cb);
+
+    mqtt_will_msg_set(Iot_mqtt, will_msg, strlen(will_msg));	//设置遗嘱
+    set_mqtt_t(Iot_mqtt);   
+    ret = mbtk_aliyun_mqtt_one_type_one_secret_unregin_device_connect(Iot_mqtt);						//初始化并连接mqtt服务器
+
+    printf("connect success\n");
+    int rc = mbtk_MQTTSubscribe(&Iot_mqtt->Client, Iot_mqtt->sub_topic, opts.qos, MQTTMessageArrived_Cb);
+    if (rc) {
+        printf("mqtt subscribe fail \n");
+        char clientId[255] = {0};
+        char deviceToken[255] = {0};
+        if(! mbtk_aliyun_mqtt_one_type_one_secret_unregin_get_regin_info(clientId, deviceToken) )
+        {
+            regnwl_info_t regn_info = {0};
+            memcpy(regn_info.clientId,clientId , strlen(clientId));
+            memcpy(regn_info.deviceToken, deviceToken , strlen(deviceToken));
+            printf("example\n");
+            printf("%s\n, %s\n", clientId, deviceToken);
+            aliyun_xiyinyimi_connect(&mbtk_mqtt_device, &regn_info);
+        }
+    }
+
+    return 0;
+}
+
+int aliyun_xiyinyimi_connect(mbtk_mqtt_device_session_t *device, regnwl_info_t *regn)
+{
+
+    int ret, len; 
+    char will_msg[256] = {"hello world"};						//初始化遗嘱数据
+    static int retry_count = 0;
+    pthread_t thread_ID;      //定义线程id
+    static int i = 0;
+
+    Cloud_MQTT_t *Iot_mqtt;
+    Iot_mqtt = (Cloud_MQTT_t *)malloc(sizeof(Cloud_MQTT_t));
+    memset(Iot_mqtt,0x0,sizeof(Cloud_MQTT_t));
+    
+
+    iot_aliyun_mqtt_one_type_one_secret_unregin_connect_init(Iot_mqtt,device, regn->clientId, regn->deviceToken, 30,3,"aaa","aaa",mqtt_data_rx_cb);	
+
+//    iot_mqtt_init(Iot_mqtt,host,port, client, user, pass,30,3,"aaa","aaa",mqtt_data_rx_cb);	
+
+    mqtt_will_msg_set(Iot_mqtt, will_msg, strlen(will_msg));	//设置遗嘱
+
+    set_mqtt_t(Iot_mqtt);    
+    ret = mqtt_device_connect(Iot_mqtt);						//初始化并连接mqtt服务器
+    
+
+    while (ret < 0 && retry_count <= 5) {
+        printf("ret = %d\r\n", ret);
+        retry_count ++ ;
+        printf("retry_count = %d\n",retry_count);
+        sleep(3);
+        ret = mqtt_device_connect(Iot_mqtt);
+    }
+    if(ret < 0 && retry_count > 5)
+    {
+        printf("reconnect times more than 5 exit\n");
+        return NULL;
+    }
+    retry_count = 0;
+
+    printf("connect success\n");
+    int rc = mbtk_MQTTSubscribe(&Iot_mqtt->Client, Iot_mqtt->sub_topic, opts.qos, MQTTMessageArrived_Cb);
+    if (rc) {
+        printf("mqtt subscribe fail \n");
+        ret = -105;
+        return 0;
+    }
+    gateway.iotstatus = IOT_STATUS_CONNECT;
+    
+    pthread_create(&thread_ID, NULL, &mqtt_thread, (void *)Iot_mqtt);	//创建一个线程执行mqtt客户端
+    pthread_detach(thread_ID);	//设置线程结束收尸
+
+    while (1)
+    {
+        mbtk_MQTTPublish("my yes", 6, 0,&Iot_mqtt->Client,Iot_mqtt->pub_topic,2,0);//循环发布"my yes"
+        sleep(3);						//睡眠3s
+        i++;
+        if (i > 5)
+        {
+            mbtk_MQTTUnsubscribe(&Iot_mqtt->Client,Iot_mqtt->sub_topic);
+            break;
+        }
+    }
+    return 0;
+}
+
+
+
+
diff --git a/mbtk/test/libmbtk_mqtt/mbtk_mqtt_test.c b/mbtk/test/libmbtk_mqtt/mbtk_mqtt_test.c
new file mode 100755
index 0000000..5d99258
--- /dev/null
+++ b/mbtk/test/libmbtk_mqtt/mbtk_mqtt_test.c
@@ -0,0 +1,127 @@
+#include <stdio.h>
+#include "mbtk_mqtt.h"
+#include "pthread.h"
+#include "string.h"
+#include "unistd.h"
+#include "sys/stat.h"
+#include "sys/types.h"
+#include "sys/socket.h"
+#include "netinet/in.h"
+#include "arpa/inet.h"
+#include "fcntl.h"
+#include "mbtk_sock2.h"
+
+
+struct opts_struct opts = {
+    (char *)"iot-dev", 0, (char *)"\n", QOS0, "admin", "password", (char *)"localhost", 1883, 0
+};//初始化结构体
+
+iot_device_info_t gateway = {
+    .iotstatus = IOT_STATUS_LOGIN,
+    .model = {"2022"},
+    .company = {"/my"}
+};//初始化主题
+
+static Cloud_MQTT_t *miot_mqtt;
+
+void set_mqtt_t(Cloud_MQTT_t *piot_mqtt)
+{
+    miot_mqtt = piot_mqtt;
+}
+Cloud_MQTT_t * get_mqtt_t()
+{
+    return miot_mqtt;
+}
+
+void mqtt_data_rx_cb(void *pbuf, int len)
+{
+
+    printf("data = %s\n", (unsigned char *)pbuf);	//打印接收到的数据
+}
+
+
+void MQTTMessageArrived_Cb(MessageData* md)
+{
+    MQTTMessage *message = md->message;
+
+    Cloud_MQTT_t *piot_mqtt = get_mqtt_t();
+
+    if (NULL != piot_mqtt->DataArrived_Cb) {
+        piot_mqtt->DataArrived_Cb((void *)message->payload, message->payloadlen);//异步消息体
+    }
+}
+
+void *mqtt_thread(void *arg)
+{
+    while (gateway.iotstatus != IOT_STATUS_DROP){
+        printf("gateway.iotstatus is %d\n",gateway.iotstatus);
+        iot_yield(arg,&gateway);									//维持服务器稳定，断开重连
+    }
+    printf("gateway.iotstatus is IOT_STATUS_DROP");
+//    mqtt_device_disconnect(arg);
+    pthread_exit(NULL);
+    return NULL;
+}
+
+int main(int argc, char *argv[])
+{
+    if(argc >6 || argc < 4)
+    {
+        printf("input error.\n example:./mqtt_test 192.168.1.1 8080 clientid username password\n");
+        return 0;
+    }
+    int ret, len;
+    char will_msg[256] = {"hello world"};						//初始化遗嘱数据
+    static int retry_count = 0;
+    pthread_t thread_ID;      //定义线程id
+    static int i = 0;
+
+    Cloud_MQTT_t *Iot_mqtt;
+    Iot_mqtt = (Cloud_MQTT_t *)malloc(sizeof(Cloud_MQTT_t));
+    memset(Iot_mqtt,0x0,sizeof(Cloud_MQTT_t));
+
+    iot_mqtt_init(Iot_mqtt,argv[1],atoi(argv[2]),argv[3],argv[4],argv[5],30,3,"aaa","aaa",mqtt_data_rx_cb);									//初始化
+    mqtt_will_msg_set(Iot_mqtt, will_msg, strlen(will_msg));	//设置遗嘱
+    set_mqtt_t(Iot_mqtt);
+    ret = mqtt_device_connect(Iot_mqtt);						//初始化并连接mqtt服务器
+
+
+    while (ret < 0 && retry_count <= 5) {
+        printf("ret = %d\r\n", ret);
+        retry_count ++ ;
+        printf("retry_count = %d\n",retry_count);
+        sleep(3);
+        ret = mqtt_device_connect(Iot_mqtt);
+    }
+    if(ret < 0 && retry_count > 5)
+    {
+        printf("reconnect times more than 5 exit\n");
+        return NULL;
+    }
+    retry_count = 0;
+
+    printf("connect success\n");
+    int rc = mbtk_MQTTSubscribe(&Iot_mqtt->Client, Iot_mqtt->sub_topic, opts.qos, MQTTMessageArrived_Cb);
+    if (rc) {
+        printf("mqtt subscribe fail \n");
+        ret = -105;
+        return 0;
+    }
+    gateway.iotstatus = IOT_STATUS_CONNECT;
+
+    pthread_create(&thread_ID, NULL, &mqtt_thread, (void *)Iot_mqtt);	//创建一个线程执行mqtt客户端
+    pthread_detach(thread_ID);	//设置线程结束收尸
+
+    while (1)
+    {
+        mbtk_MQTTPublish("my yes", 6, 0,&Iot_mqtt->Client,Iot_mqtt->pub_topic,2,0);//循环发布"my yes"
+        sleep(3);						//睡眠3s
+        i++;
+        if (i > 5)
+        {
+            mbtk_MQTTUnsubscribe(&Iot_mqtt->Client,Iot_mqtt->sub_topic);
+            break;
+        }
+    }
+    return 0;
+}