add mqtt connect/disconnect

examples/mqtt/mqtt_connect.py

@@ -0,0 +1,10 @@
+import mqtt
+
+client = mqtt.MQTT('192.168.1.255')
+
+client.setHost('broker.emqx.io')
+client.setPort(1883)
+
+client.connect()
+
+client.disconnect()

examples/mqtt/mqtt_init.py

@@ -2,13 +2,6 @@ import mqtt
 
 client = mqtt.MQTT('192.168.1.255')
 
-client.set_host('broker.emqx.io')
-client.set_port(1883)
-ret = client.connect()
-print('client.connect:%d' % ret)
-
-ret = client.disconnect()
-print('client.disconnect:%d' % ret)
 
 
 

package/mqtt/_mqtt.pyi

@@ -6,23 +6,60 @@ class _MQTT:
 
     def __del__(self): ...
 
-    def set_port(self, port: int) -> int:
+    def setClientID(self, id:str) -> int:
-        """Set the port of the MQTTClient."""
+        pass
+        """Set the ClientID of the MQTTClient."""
 
-    def set_host(self, host_url: str) -> int:
+    def setUsername(self, name:str) -> int:
-        """Set the host_url of the MQTTClient."""
+        pass
+        """Set the Username of the MQTTClient."""
 
-    def set_client_id(self, id: str) -> int:
+    def setPassword(self, passwd:str) -> int:
-        """Set the client_id of the MQTTClient."""
+        pass
+        """Set the Password of the MQTTClient."""
 
-    def set_user_name(self, name: str) -> int:
+    def setVersion(self, version:str) -> int:
-        """Set the name of the MQTTClient."""
+        pass
+        """Set the Version of the MQTTClient."""
 
-    def set_password(self, password: str) -> int:
+    def setCa(self, ca:str) -> int:
-        """Set the password of the MQTTClient."""
+        pass
+        """Set the Ca of the MQTTClient."""
+
+    def setKeepAlive(self, time:str) -> int:
+        pass
+        """Set the KeepAlive of the MQTTClient."""
+
+    def setWill(self, qos:int, topic:str, retain:int, payload:str) -> int:
+        pass
+        """Set the Will of the MQTTClient."""
 
     def connect(self) -> int:
+        pass
         """connect to the mqtt-server."""
 
     def disconnect(self) -> int:
+        pass
         """disconnect to the mqtt-server."""
+
+    def subscribe(self, topic:str, cb:any) -> int:
+        pass
+        """subscribe to the mqtt-server."""
+
+    def unsubscribe(self, topic:str) -> int:
+        pass
+        """unsubscribe to the mqtt-server."""
+
+    def listSubscribrTopic(self) -> dict:
+        pass
+        """listSubscribrTopic """
+
+    def publish(self, topic:str , payload:str) -> int:
+        pass
+        """publish to the mqtt-server."""
+
+    def setPort(self, port: int) -> int:
+        """Set the port num of the MQTTClient."""
+
+    def setHost(self, host_url: str) -> int:
+        """Set the host_url of the MQTTClient."""

package/mqtt/_mqtt__MQTT.c

@@ -1,6 +1,12 @@
 #include "_mqtt__MQTT.h"
 #include "mqttclient.h"
 
+////////////////////////////////////////////////////////////////////
+// 函 数 名：_mqtt__MQTT___init__
+// 功能说明：对象初始化
+// 输入参数：
+// 返 回 值：无
+///////////////////////////////////////////////////////////////////
 void _mqtt__MQTT___init__(PikaObj* self,
                           char* ip,
                           int port,
@@ -11,163 +17,81 @@ void _mqtt__MQTT___init__(PikaObj* self,
                           char* ca,
                           int keepalive) {
     mqtt_client_t* _client = mqtt_lease();
-    obj_setPtr(self, "_client", _client);
+    //obj_setPtr(self, "_client", _client);
     /* port to str, and cache to object */
     char port_str[10] = {0};
+
+    if(strlen(ip) > 0)
+    {
+        obj_setStr(self, "host_str", ip);
+        mqtt_set_host(_client, obj_getStr(self,"host_str"));
+    }
+
     __platform_sprintf(port_str, "%d", port);
     obj_setStr(self, "port", port_str);
-    mqtt_set_port(_client, port_str);
+    mqtt_set_port(_client, obj_getStr(self,"port"));
 
-    if(strlen(ca) > 0)
-        mqtt_set_ca(_client, ca);
-    if(strlen(ip) > 0)
-        mqtt_set_host(_client, ip);
     if(strlen(clinetID) > 0)
-        mqtt_set_client_id(_client, clinetID);
+    {
+        obj_setStr(self, "id_str", clinetID);
+        mqtt_set_client_id(_client, obj_getStr(self,"id_str"));
+    }
+
     if(strlen(username) > 0)
-        mqtt_set_user_name(_client, username);
+    {
+        obj_setStr(self, "username_str", username);
+        mqtt_set_user_name(_client, obj_getStr(self,"username_str"));
+    }
+
     if(strlen(password) > 0)
-        mqtt_set_password(_client, password);
+    {
+        obj_setStr(self, "password_str", password);
+        mqtt_set_password(_client, obj_getStr(self,"password_str"));
+    }
         
+    if(strlen(ca) > 0)
+    {
+        obj_setStr(self, "ca_str", ca);
+        mqtt_set_ca(_client, obj_getStr(self,"ca_str"));
+    }
+
     mqtt_set_clean_session(_client, 1);
+
+    obj_setPtr(self, "_client", _client);//这里要再保存一次mqtt结构体的内容到python环境
+    __platform_printf("Mqtt_Lib buildtime:%s-%s\r\n",__DATE__,__TIME__);
 }
 
+////////////////////////////////////////////////////////////////////
+// 函 数 名：_mqtt__MQTT___del__
+// 功能说明：释放对象资源
+// 输入参数：
+// 返 回 值：无
+///////////////////////////////////////////////////////////////////
 void _mqtt__MQTT___del__(PikaObj* self) {
     mqtt_client_t* _client = obj_getPtr(self, "_client");
     if (NULL != _client) {
+        //mqtt_release(_client);
         mqtt_release_free(_client);
     }
 }
 
-////////////////////////////////////////////////////////////////////
-// 函 数 名：_mqtt__MQTT_set_client_id
-// 功能说明：设置mqtt客户端的id
-// 输入参数：id 字符串格式
-// 返 回 值：0=成功；非0=错误码
-///////////////////////////////////////////////////////////////////
-int _mqtt__MQTT_set_client_id(PikaObj *self, char* id) {
-    mqtt_client_t* _client = obj_getPtr(self, "_client");
-    
-    if(id == NULL) {
-        __platform_printf("input id error\r\n");
-        return -1;
-    }
-    if(strlen(id) <= 0) {
-        __platform_printf("input id data error\r\n");
-        return -2;
-    }
-
-    mqtt_set_client_id(_client, id);
-    return 0;
-}
-
-////////////////////////////////////////////////////////////////////
-// 函 数 名：_mqtt__MQTT_set_host
-// 功能说明：设置mqtt客户端，连接主机的ip或者url
-// 输入参数：字符串格式
-// 返 回 值：0=成功；非0=错误码
-///////////////////////////////////////////////////////////////////
-int _mqtt__MQTT_set_host(PikaObj *self, char* host_url) {
-    mqtt_client_t* _client = obj_getPtr(self, "_client");
-    
-    if(host_url == NULL) {
-        __platform_printf("input host_url error\r\n");
-        return -1;
-    }
-    if(strlen(host_url) <= 0) {
-        __platform_printf("input host_url data error\r\n");
-        return -2;
-    }
-
-    mqtt_set_host(_client, host_url);
-    return 0;
-}
-
-////////////////////////////////////////////////////////////////////
-// 函 数 名：_mqtt__MQTT_set_password
-// 功能说明：设置mqtt客户端的 密码
-// 输入参数：字符串格式
-// 返 回 值：0=成功；非0=错误码
-///////////////////////////////////////////////////////////////////
-int _mqtt__MQTT_set_password(PikaObj *self, char* password){
-    mqtt_client_t* _client = obj_getPtr(self, "_client");
-
-    if(password == NULL) {
-        __platform_printf("input password error\r\n");
-        return -1;
-    }
-    if(strlen(password) <= 0) {
-        __platform_printf("input password data error\r\n");
-        return -2;
-    }
-
-    mqtt_set_password(_client, password);
-    return 0;
-}
-
-////////////////////////////////////////////////////////////////////
-// 函 数 名：_mqtt__MQTT_set_port
-// 功能说明：设置mqtt客户端，连接主机的端口号
-// 输入参数：字符串格式
-// 返 回 值：0=成功；非0=错误码
-///////////////////////////////////////////////////////////////////
-int _mqtt__MQTT_set_port(PikaObj *self, int port){
-    char port_str[10] = {0};
-    mqtt_client_t* _client = obj_getPtr(self, "_client");
-
-    __platform_sprintf(port_str, "%d", port);
-    obj_setStr(self, "port", port_str);
-    
-    if(port_str == NULL) {
-        __platform_printf("input port error\r\n");
-        return -1;
-    }
-    if(strlen(port_str) <= 0) {
-        __platform_printf("input port data error\r\n");
-        return -2;
-    }
-
-    mqtt_set_port(_client, port_str);
-    return 0;
-}
-
-////////////////////////////////////////////////////////////////////
-// 函 数 名：_mqtt__MQTT_set_user_name
-// 功能说明：设置mqtt客户端的用户名
-// 输入参数：字符串格式
-// 返 回 值：0=成功；非0=错误码
-///////////////////////////////////////////////////////////////////
-int _mqtt__MQTT_set_user_name(PikaObj *self, char* name){
-    mqtt_client_t* _client = obj_getPtr(self, "_client");
-
-    if(name == NULL) {
-        __platform_printf("input name error\r\n");
-        return -1;
-    }
-    if(strlen(name) <= 0) {
-        __platform_printf("input name data error\r\n");
-        return -2;
-    }
-
-    mqtt_set_user_name(_client, name);
-    return 0;
-}
-
 ////////////////////////////////////////////////////////////////////
 // 函 数 名：_mqtt__MQTT_connect
 // 功能说明：连接mqtt的服务端
 // 输入参数：无
 // 返 回 值：0=成功；非0=错误码
 ///////////////////////////////////////////////////////////////////
-int _mqtt__MQTT_connect(PikaObj *self){
+int _mqtt__MQTT_connect(PikaObj *self) {
     int ret;
 
     mqtt_client_t* _client = obj_getPtr(self, "_client");
 
     ret = mqtt_connect(_client);
     if(ret != 0)
-        __platform_printf("mqtt connect error :%d\r\n",ret);
+        __platform_printf("mqtt connect ERROR! :%d\r\n",ret);
 
+    if(ret == 0)
+        __platform_printf("mqtt connect OK\r\n");
     return ret;
 }
 
@@ -184,7 +108,217 @@ int _mqtt__MQTT_disconnect(PikaObj *self) {
 
     ret = mqtt_disconnect(_client);
     if(ret != 0)
-        __platform_printf("mqtt disconnect error :%d\r\n",ret);
+        __platform_printf("mqtt disconnect ERROR! :%d\r\n",ret);
 
+    if(ret == 0)
+        __platform_printf("mqtt disconnect Done\r\n");
     return ret;
+}
+
+////////////////////////////////////////////////////////////////////
+// 函 数 名：_mqtt__MQTT_listSubscribrTopic
+// 功能说明：罗列出当前订阅的主题
+// 输入参数：无
+// 返 回 值：对象指针
+///////////////////////////////////////////////////////////////////
+PikaObj* _mqtt__MQTT_listSubscribrTopic(PikaObj *self) {
+
+    return NULL;
+}
+
+////////////////////////////////////////////////////////////////////
+// 函 数 名：_mqtt__MQTT_publish
+// 功能说明：发布主题消息
+// 输入参数：主题名称，有效数据
+// 返 回 值：0=成功；非0=错误码
+///////////////////////////////////////////////////////////////////
+int _mqtt__MQTT_publish(PikaObj *self, char* topic, char* payload) {
+
+    return 0;
+}
+
+////////////////////////////////////////////////////////////////////
+// 函 数 名：_mqtt__MQTT_setCa
+// 功能说明：设置ca值
+// 输入参数：ca值
+// 返 回 值：0=成功；非0=错误码
+///////////////////////////////////////////////////////////////////
+int _mqtt__MQTT_setCa(PikaObj *self, char* ca) {
+    return 0;
+}
+
+////////////////////////////////////////////////////////////////////
+// 函 数 名：_mqtt__MQTT_setClientID
+// 功能说明：设置mqtt客户端的id
+// 输入参数：id 字符串格式
+// 返 回 值：0=成功；非0=错误码
+///////////////////////////////////////////////////////////////////
+int _mqtt__MQTT_setClientID(PikaObj *self, char* id) {
+    mqtt_client_t* _client = obj_getPtr(self, "_client");
+    
+    if(id == NULL) {
+        __platform_printf("input id error\r\n");
+        return -1;
+    }
+    if(strlen(id) <= 0) {
+        __platform_printf("input id data error\r\n");
+        return -2;
+    }
+
+    mqtt_set_client_id(_client, id);
+    __platform_printf("MQTT_setClientID:%s\r\n",id);
+    obj_setPtr(self, "_client", _client);//这里要再保存一次mqtt结构体的内容到python环境
+    return 0;
+}
+
+////////////////////////////////////////////////////////////////////
+// 函 数 名：_mqtt__MQTT_setHost
+// 功能说明：设置mqtt客户端，连接主机的ip或者url
+// 输入参数：字符串格式
+// 返 回 值：0=成功；非0=错误码
+///////////////////////////////////////////////////////////////////
+int _mqtt__MQTT_setHost(PikaObj *self, char* host_url) {
+    mqtt_client_t* _client = obj_getPtr(self, "_client");
+    
+    if(host_url == NULL) {
+        __platform_printf("input host_url error\r\n");
+        return -1;
+    }
+    if(strlen(host_url) <= 0) {
+        __platform_printf("input host_url data error\r\n");
+        return -2;
+    }
+
+    obj_setStr(self, "host_str", host_url);//python 环境创建一个全局变量存放 host
+    mqtt_set_host(_client, obj_getStr(self,"host_str"));//从python环境中取出 host的指针 赋值给结构体
+    __platform_printf("MQTT_setHost :%s\r\n",host_url);
+
+    return 0;
+}
+
+////////////////////////////////////////////////////////////////////
+// 函 数 名：_mqtt__MQTT_setKeepAlive
+// 功能说明：设置mqtt客户端的 心跳包发送间隔
+// 输入参数：字符串格式
+// 返 回 值：0=成功；非0=错误码
+///////////////////////////////////////////////////////////////////
+int _mqtt__MQTT_setKeepAlive(PikaObj *self, char* time) {
+
+    return 0;
+}
+
+////////////////////////////////////////////////////////////////////
+// 函 数 名：_mqtt__MQTT_setPassword
+// 功能说明：设置mqtt客户端的 密码
+// 输入参数：字符串格式
+// 返 回 值：0=成功；非0=错误码
+///////////////////////////////////////////////////////////////////
+int _mqtt__MQTT_setPassword(PikaObj *self, char* passwd) {
+    mqtt_client_t* _client = obj_getPtr(self, "_client");
+
+    if(passwd == NULL) {
+        __platform_printf("input passwd error\r\n");
+        return -1;
+    }
+    if(strlen(passwd) <= 0) {
+        __platform_printf("input passwd data error\r\n");
+        return -2;
+    }
+
+    mqtt_set_password(_client, passwd);
+    __platform_printf("MQTT_setPassword:%s\r\n",passwd);
+    //obj_setPtr(self, "_client", _client);//这里要再保存一次mqtt结构体的内容到python环境
+    return 0;
+}
+
+////////////////////////////////////////////////////////////////////
+// 函 数 名：_mqtt__MQTT_setPort
+// 功能说明：设置mqtt客户端，连接主机的端口号
+// 输入参数：字符串格式
+// 返 回 值：0=成功；非0=错误码
+///////////////////////////////////////////////////////////////////
+int _mqtt__MQTT_setPort(PikaObj *self, int port) {
+    char port_str[10] = {0};
+    mqtt_client_t* _client = obj_getPtr(self, "_client");
+
+    if(port <= 0) {
+        __platform_printf("input port error\r\n");
+        return -1;
+    }
+
+    __platform_sprintf(port_str, "%d", port);
+    obj_setStr(self, "port", port_str);
+    
+    mqtt_set_port(_client, obj_getStr(self,"port"));
+    __platform_printf("MQTT_setPort :%s\r\n",port_str);
+    
+    return 0;
+}
+
+////////////////////////////////////////////////////////////////////
+// 函 数 名：_mqtt__MQTT_setUsername
+// 功能说明：设置mqtt客户端的用户名
+// 输入参数：字符串格式
+// 返 回 值：0=成功；非0=错误码
+///////////////////////////////////////////////////////////////////
+int _mqtt__MQTT_setUsername(PikaObj *self, char* name) {
+    mqtt_client_t* _client = obj_getPtr(self, "_client");
+
+    if(name == NULL) {
+        __platform_printf("input name error\r\n");
+        return -1;
+    }
+    if(strlen(name) <= 0) {
+        __platform_printf("input name data error\r\n");
+        return -2;
+    }
+
+    mqtt_set_user_name(_client, name);
+    __platform_printf("MQTT_setUsername:%s\r\n",name);
+    //obj_setPtr(self, "_client", _client);//这里要再保存一次mqtt结构体的内容到python环境
+    return 0;
+}
+
+////////////////////////////////////////////////////////////////////
+// 函 数 名：_mqtt__MQTT_setVersion
+// 功能说明：设置mqtt 协议版本
+// 输入参数：字符串格式
+// 返 回 值：0=成功；非0=错误码
+///////////////////////////////////////////////////////////////////
+int _mqtt__MQTT_setVersion(PikaObj *self, char* version) {
+
+    return 0;
+}
+
+////////////////////////////////////////////////////////////////////
+// 函 数 名：_mqtt__MQTT_setWill
+// 功能说明：
+// 输入参数：
+// 返 回 值：0=成功；非0=错误码
+///////////////////////////////////////////////////////////////////
+int _mqtt__MQTT_setWill(PikaObj *self, int qos, char* topic, int retain, char* payload) {
+
+    return 0;
+}
+
+////////////////////////////////////////////////////////////////////
+// 函 数 名：_mqtt__MQTT_subscribe
+// 功能说明：设置mqtt 订阅主题
+// 输入参数：
+// 返 回 值：0=成功；非0=错误码
+///////////////////////////////////////////////////////////////////
+int _mqtt__MQTT_subscribe(PikaObj *self, char* topic, Arg* cb) {
+
+    return 0;
+}
+
+////////////////////////////////////////////////////////////////////
+// 函 数 名：_mqtt__MQTT_unsubscribe
+// 功能说明：取消mqtt 订阅主题
+// 输入参数：
+// 返 回 值：0=成功；非0=错误码
+///////////////////////////////////////////////////////////////////
+int _mqtt__MQTT_unsubscribe(PikaObj *self, char* topic) {
+
+    return 0;
 }

port/linux/.vscode/launch.json

@@ -11,7 +11,7 @@
             "program": "${workspaceFolder}/build/test/pikascript_test",
             // "program": "${workspaceFolder}/build/boot/demo06-pikamain/pikascript_demo06-pikamain",
             "args": [
-                "--gtest_filter=mqtt.init"
+            //    "--gtest_filter=mqtt.init"
             ],
             "stopAtEntry": false,
             "cwd": "${workspaceFolder}",

port/linux/package/pikascript/_mqtt.pyi

@@ -6,23 +6,60 @@ class _MQTT:
 
     def __del__(self): ...
 
-    def set_port(self, port: int) -> int:
+    def setClientID(self, id:str) -> int:
-        """Set the port of the MQTTClient."""
+        pass
+        """Set the ClientID of the MQTTClient."""
 
-    def set_host(self, host_url: str) -> int:
+    def setUsername(self, name:str) -> int:
-        """Set the host_url of the MQTTClient."""
+        pass
+        """Set the Username of the MQTTClient."""
 
-    def set_client_id(self, id: str) -> int:
+    def setPassword(self, passwd:str) -> int:
-        """Set the client_id of the MQTTClient."""
+        pass
+        """Set the Password of the MQTTClient."""
 
-    def set_user_name(self, name: str) -> int:
+    def setVersion(self, version:str) -> int:
-        """Set the name of the MQTTClient."""
+        pass
+        """Set the Version of the MQTTClient."""
 
-    def set_password(self, password: str) -> int:
+    def setCa(self, ca:str) -> int:
-        """Set the password of the MQTTClient."""
+        pass
+        """Set the Ca of the MQTTClient."""
+
+    def setKeepAlive(self, time:str) -> int:
+        pass
+        """Set the KeepAlive of the MQTTClient."""
+
+    def setWill(self, qos:int, topic:str, retain:int, payload:str) -> int:
+        pass
+        """Set the Will of the MQTTClient."""
 
     def connect(self) -> int:
+        pass
         """connect to the mqtt-server."""
 
     def disconnect(self) -> int:
+        pass
         """disconnect to the mqtt-server."""
+
+    def subscribe(self, topic:str, cb:any) -> int:
+        pass
+        """subscribe to the mqtt-server."""
+
+    def unsubscribe(self, topic:str) -> int:
+        pass
+        """unsubscribe to the mqtt-server."""
+
+    def listSubscribrTopic(self) -> dict:
+        pass
+        """listSubscribrTopic """
+
+    def publish(self, topic:str , payload:str) -> int:
+        pass
+        """publish to the mqtt-server."""
+
+    def setPort(self, port: int) -> int:
+        """Set the port num of the MQTTClient."""
+
+    def setHost(self, host_url: str) -> int:
+        """Set the host_url of the MQTTClient."""

port/linux/package/pikascript/pikascript-lib/mqtt/_mqtt__MQTT.c

@@ -1,6 +1,12 @@
 #include "_mqtt__MQTT.h"
 #include "mqttclient.h"
 
+////////////////////////////////////////////////////////////////////
+// 函 数 名：_mqtt__MQTT___init__
+// 功能说明：对象初始化
+// 输入参数：
+// 返 回 值：无
+///////////////////////////////////////////////////////////////////
 void _mqtt__MQTT___init__(PikaObj* self,
                           char* ip,
                           int port,
@@ -11,163 +17,81 @@ void _mqtt__MQTT___init__(PikaObj* self,
                           char* ca,
                           int keepalive) {
     mqtt_client_t* _client = mqtt_lease();
-    obj_setPtr(self, "_client", _client);
+    //obj_setPtr(self, "_client", _client);
     /* port to str, and cache to object */
     char port_str[10] = {0};
+
+    if(strlen(ip) > 0)
+    {
+        obj_setStr(self, "host_str", ip);
+        mqtt_set_host(_client, obj_getStr(self,"host_str"));
+    }
+
     __platform_sprintf(port_str, "%d", port);
     obj_setStr(self, "port", port_str);
-    mqtt_set_port(_client, port_str);
+    mqtt_set_port(_client, obj_getStr(self,"port"));
 
-    if(strlen(ca) > 0)
-        mqtt_set_ca(_client, ca);
-    if(strlen(ip) > 0)
-        mqtt_set_host(_client, ip);
     if(strlen(clinetID) > 0)
-        mqtt_set_client_id(_client, clinetID);
+    {
+        obj_setStr(self, "id_str", clinetID);
+        mqtt_set_client_id(_client, obj_getStr(self,"id_str"));
+    }
+
     if(strlen(username) > 0)
-        mqtt_set_user_name(_client, username);
+    {
+        obj_setStr(self, "username_str", username);
+        mqtt_set_user_name(_client, obj_getStr(self,"username_str"));
+    }
+
     if(strlen(password) > 0)
-        mqtt_set_password(_client, password);
+    {
+        obj_setStr(self, "password_str", password);
+        mqtt_set_password(_client, obj_getStr(self,"password_str"));
+    }
         
+    if(strlen(ca) > 0)
+    {
+        obj_setStr(self, "ca_str", ca);
+        mqtt_set_ca(_client, obj_getStr(self,"ca_str"));
+    }
+
     mqtt_set_clean_session(_client, 1);
+
+    obj_setPtr(self, "_client", _client);//这里要再保存一次mqtt结构体的内容到python环境
+    __platform_printf("Mqtt_Lib buildtime:%s-%s\r\n",__DATE__,__TIME__);
 }
 
+////////////////////////////////////////////////////////////////////
+// 函 数 名：_mqtt__MQTT___del__
+// 功能说明：释放对象资源
+// 输入参数：
+// 返 回 值：无
+///////////////////////////////////////////////////////////////////
 void _mqtt__MQTT___del__(PikaObj* self) {
     mqtt_client_t* _client = obj_getPtr(self, "_client");
     if (NULL != _client) {
+        //mqtt_release(_client);
         mqtt_release_free(_client);
     }
 }
 
-////////////////////////////////////////////////////////////////////
-// 函 数 名：_mqtt__MQTT_set_client_id
-// 功能说明：设置mqtt客户端的id
-// 输入参数：id 字符串格式
-// 返 回 值：0=成功；非0=错误码
-///////////////////////////////////////////////////////////////////
-int _mqtt__MQTT_set_client_id(PikaObj *self, char* id) {
-    mqtt_client_t* _client = obj_getPtr(self, "_client");
-    
-    if(id == NULL) {
-        __platform_printf("input id error\r\n");
-        return -1;
-    }
-    if(strlen(id) <= 0) {
-        __platform_printf("input id data error\r\n");
-        return -2;
-    }
-
-    mqtt_set_client_id(_client, id);
-    return 0;
-}
-
-////////////////////////////////////////////////////////////////////
-// 函 数 名：_mqtt__MQTT_set_host
-// 功能说明：设置mqtt客户端，连接主机的ip或者url
-// 输入参数：字符串格式
-// 返 回 值：0=成功；非0=错误码
-///////////////////////////////////////////////////////////////////
-int _mqtt__MQTT_set_host(PikaObj *self, char* host_url) {
-    mqtt_client_t* _client = obj_getPtr(self, "_client");
-    
-    if(host_url == NULL) {
-        __platform_printf("input host_url error\r\n");
-        return -1;
-    }
-    if(strlen(host_url) <= 0) {
-        __platform_printf("input host_url data error\r\n");
-        return -2;
-    }
-
-    mqtt_set_host(_client, host_url);
-    return 0;
-}
-
-////////////////////////////////////////////////////////////////////
-// 函 数 名：_mqtt__MQTT_set_password
-// 功能说明：设置mqtt客户端的 密码
-// 输入参数：字符串格式
-// 返 回 值：0=成功；非0=错误码
-///////////////////////////////////////////////////////////////////
-int _mqtt__MQTT_set_password(PikaObj *self, char* password){
-    mqtt_client_t* _client = obj_getPtr(self, "_client");
-
-    if(password == NULL) {
-        __platform_printf("input password error\r\n");
-        return -1;
-    }
-    if(strlen(password) <= 0) {
-        __platform_printf("input password data error\r\n");
-        return -2;
-    }
-
-    mqtt_set_password(_client, password);
-    return 0;
-}
-
-////////////////////////////////////////////////////////////////////
-// 函 数 名：_mqtt__MQTT_set_port
-// 功能说明：设置mqtt客户端，连接主机的端口号
-// 输入参数：字符串格式
-// 返 回 值：0=成功；非0=错误码
-///////////////////////////////////////////////////////////////////
-int _mqtt__MQTT_set_port(PikaObj *self, int port){
-    char port_str[10] = {0};
-    mqtt_client_t* _client = obj_getPtr(self, "_client");
-
-    __platform_sprintf(port_str, "%d", port);
-    obj_setStr(self, "port", port_str);
-    
-    if(port_str == NULL) {
-        __platform_printf("input port error\r\n");
-        return -1;
-    }
-    if(strlen(port_str) <= 0) {
-        __platform_printf("input port data error\r\n");
-        return -2;
-    }
-
-    mqtt_set_port(_client, port_str);
-    return 0;
-}
-
-////////////////////////////////////////////////////////////////////
-// 函 数 名：_mqtt__MQTT_set_user_name
-// 功能说明：设置mqtt客户端的用户名
-// 输入参数：字符串格式
-// 返 回 值：0=成功；非0=错误码
-///////////////////////////////////////////////////////////////////
-int _mqtt__MQTT_set_user_name(PikaObj *self, char* name){
-    mqtt_client_t* _client = obj_getPtr(self, "_client");
-
-    if(name == NULL) {
-        __platform_printf("input name error\r\n");
-        return -1;
-    }
-    if(strlen(name) <= 0) {
-        __platform_printf("input name data error\r\n");
-        return -2;
-    }
-
-    mqtt_set_user_name(_client, name);
-    return 0;
-}
-
 ////////////////////////////////////////////////////////////////////
 // 函 数 名：_mqtt__MQTT_connect
 // 功能说明：连接mqtt的服务端
 // 输入参数：无
 // 返 回 值：0=成功；非0=错误码
 ///////////////////////////////////////////////////////////////////
-int _mqtt__MQTT_connect(PikaObj *self){
+int _mqtt__MQTT_connect(PikaObj *self) {
     int ret;
 
     mqtt_client_t* _client = obj_getPtr(self, "_client");
 
     ret = mqtt_connect(_client);
     if(ret != 0)
-        __platform_printf("mqtt connect error :%d\r\n",ret);
+        __platform_printf("mqtt connect ERROR! :%d\r\n",ret);
 
+    if(ret == 0)
+        __platform_printf("mqtt connect OK\r\n");
     return ret;
 }
 
@@ -184,7 +108,217 @@ int _mqtt__MQTT_disconnect(PikaObj *self) {
 
     ret = mqtt_disconnect(_client);
     if(ret != 0)
-        __platform_printf("mqtt disconnect error :%d\r\n",ret);
+        __platform_printf("mqtt disconnect ERROR! :%d\r\n",ret);
 
+    if(ret == 0)
+        __platform_printf("mqtt disconnect Done\r\n");
     return ret;
+}
+
+////////////////////////////////////////////////////////////////////
+// 函 数 名：_mqtt__MQTT_listSubscribrTopic
+// 功能说明：罗列出当前订阅的主题
+// 输入参数：无
+// 返 回 值：对象指针
+///////////////////////////////////////////////////////////////////
+PikaObj* _mqtt__MQTT_listSubscribrTopic(PikaObj *self) {
+
+    return NULL;
+}
+
+////////////////////////////////////////////////////////////////////
+// 函 数 名：_mqtt__MQTT_publish
+// 功能说明：发布主题消息
+// 输入参数：主题名称，有效数据
+// 返 回 值：0=成功；非0=错误码
+///////////////////////////////////////////////////////////////////
+int _mqtt__MQTT_publish(PikaObj *self, char* topic, char* payload) {
+
+    return 0;
+}
+
+////////////////////////////////////////////////////////////////////
+// 函 数 名：_mqtt__MQTT_setCa
+// 功能说明：设置ca值
+// 输入参数：ca值
+// 返 回 值：0=成功；非0=错误码
+///////////////////////////////////////////////////////////////////
+int _mqtt__MQTT_setCa(PikaObj *self, char* ca) {
+    return 0;
+}
+
+////////////////////////////////////////////////////////////////////
+// 函 数 名：_mqtt__MQTT_setClientID
+// 功能说明：设置mqtt客户端的id
+// 输入参数：id 字符串格式
+// 返 回 值：0=成功；非0=错误码
+///////////////////////////////////////////////////////////////////
+int _mqtt__MQTT_setClientID(PikaObj *self, char* id) {
+    mqtt_client_t* _client = obj_getPtr(self, "_client");
+    
+    if(id == NULL) {
+        __platform_printf("input id error\r\n");
+        return -1;
+    }
+    if(strlen(id) <= 0) {
+        __platform_printf("input id data error\r\n");
+        return -2;
+    }
+
+    mqtt_set_client_id(_client, id);
+    __platform_printf("MQTT_setClientID:%s\r\n",id);
+    obj_setPtr(self, "_client", _client);//这里要再保存一次mqtt结构体的内容到python环境
+    return 0;
+}
+
+////////////////////////////////////////////////////////////////////
+// 函 数 名：_mqtt__MQTT_setHost
+// 功能说明：设置mqtt客户端，连接主机的ip或者url
+// 输入参数：字符串格式
+// 返 回 值：0=成功；非0=错误码
+///////////////////////////////////////////////////////////////////
+int _mqtt__MQTT_setHost(PikaObj *self, char* host_url) {
+    mqtt_client_t* _client = obj_getPtr(self, "_client");
+    
+    if(host_url == NULL) {
+        __platform_printf("input host_url error\r\n");
+        return -1;
+    }
+    if(strlen(host_url) <= 0) {
+        __platform_printf("input host_url data error\r\n");
+        return -2;
+    }
+
+    obj_setStr(self, "host_str", host_url);//python 环境创建一个全局变量存放 host
+    mqtt_set_host(_client, obj_getStr(self,"host_str"));//从python环境中取出 host的指针 赋值给结构体
+    __platform_printf("MQTT_setHost :%s\r\n",host_url);
+
+    return 0;
+}
+
+////////////////////////////////////////////////////////////////////
+// 函 数 名：_mqtt__MQTT_setKeepAlive
+// 功能说明：设置mqtt客户端的 心跳包发送间隔
+// 输入参数：字符串格式
+// 返 回 值：0=成功；非0=错误码
+///////////////////////////////////////////////////////////////////
+int _mqtt__MQTT_setKeepAlive(PikaObj *self, char* time) {
+
+    return 0;
+}
+
+////////////////////////////////////////////////////////////////////
+// 函 数 名：_mqtt__MQTT_setPassword
+// 功能说明：设置mqtt客户端的 密码
+// 输入参数：字符串格式
+// 返 回 值：0=成功；非0=错误码
+///////////////////////////////////////////////////////////////////
+int _mqtt__MQTT_setPassword(PikaObj *self, char* passwd) {
+    mqtt_client_t* _client = obj_getPtr(self, "_client");
+
+    if(passwd == NULL) {
+        __platform_printf("input passwd error\r\n");
+        return -1;
+    }
+    if(strlen(passwd) <= 0) {
+        __platform_printf("input passwd data error\r\n");
+        return -2;
+    }
+
+    mqtt_set_password(_client, passwd);
+    __platform_printf("MQTT_setPassword:%s\r\n",passwd);
+    //obj_setPtr(self, "_client", _client);//这里要再保存一次mqtt结构体的内容到python环境
+    return 0;
+}
+
+////////////////////////////////////////////////////////////////////
+// 函 数 名：_mqtt__MQTT_setPort
+// 功能说明：设置mqtt客户端，连接主机的端口号
+// 输入参数：字符串格式
+// 返 回 值：0=成功；非0=错误码
+///////////////////////////////////////////////////////////////////
+int _mqtt__MQTT_setPort(PikaObj *self, int port) {
+    char port_str[10] = {0};
+    mqtt_client_t* _client = obj_getPtr(self, "_client");
+
+    if(port <= 0) {
+        __platform_printf("input port error\r\n");
+        return -1;
+    }
+
+    __platform_sprintf(port_str, "%d", port);
+    obj_setStr(self, "port", port_str);
+    
+    mqtt_set_port(_client, obj_getStr(self,"port"));
+    __platform_printf("MQTT_setPort :%s\r\n",port_str);
+    
+    return 0;
+}
+
+////////////////////////////////////////////////////////////////////
+// 函 数 名：_mqtt__MQTT_setUsername
+// 功能说明：设置mqtt客户端的用户名
+// 输入参数：字符串格式
+// 返 回 值：0=成功；非0=错误码
+///////////////////////////////////////////////////////////////////
+int _mqtt__MQTT_setUsername(PikaObj *self, char* name) {
+    mqtt_client_t* _client = obj_getPtr(self, "_client");
+
+    if(name == NULL) {
+        __platform_printf("input name error\r\n");
+        return -1;
+    }
+    if(strlen(name) <= 0) {
+        __platform_printf("input name data error\r\n");
+        return -2;
+    }
+
+    mqtt_set_user_name(_client, name);
+    __platform_printf("MQTT_setUsername:%s\r\n",name);
+    //obj_setPtr(self, "_client", _client);//这里要再保存一次mqtt结构体的内容到python环境
+    return 0;
+}
+
+////////////////////////////////////////////////////////////////////
+// 函 数 名：_mqtt__MQTT_setVersion
+// 功能说明：设置mqtt 协议版本
+// 输入参数：字符串格式
+// 返 回 值：0=成功；非0=错误码
+///////////////////////////////////////////////////////////////////
+int _mqtt__MQTT_setVersion(PikaObj *self, char* version) {
+
+    return 0;
+}
+
+////////////////////////////////////////////////////////////////////
+// 函 数 名：_mqtt__MQTT_setWill
+// 功能说明：
+// 输入参数：
+// 返 回 值：0=成功；非0=错误码
+///////////////////////////////////////////////////////////////////
+int _mqtt__MQTT_setWill(PikaObj *self, int qos, char* topic, int retain, char* payload) {
+
+    return 0;
+}
+
+////////////////////////////////////////////////////////////////////
+// 函 数 名：_mqtt__MQTT_subscribe
+// 功能说明：设置mqtt 订阅主题
+// 输入参数：
+// 返 回 值：0=成功；非0=错误码
+///////////////////////////////////////////////////////////////////
+int _mqtt__MQTT_subscribe(PikaObj *self, char* topic, Arg* cb) {
+
+    return 0;
+}
+
+////////////////////////////////////////////////////////////////////
+// 函 数 名：_mqtt__MQTT_unsubscribe
+// 功能说明：取消mqtt 订阅主题
+// 输入参数：
+// 返 回 值：0=成功；非0=错误码
+///////////////////////////////////////////////////////////////////
+int _mqtt__MQTT_unsubscribe(PikaObj *self, char* topic) {
+
+    return 0;
 }

test/mqtt-test.cpp

@@ -94,4 +94,13 @@ TEST(mqtt, init) {
     obj_deinit(pikaMain);
     EXPECT_EQ(pikaMemNow(), 0);
 }
+
+TEST(mqtt, connect) {
+    PikaObj* pikaMain = newRootObj("pikaMain", New_PikaMain);
+    extern unsigned char pikaModules_py_a[];
+    obj_linkLibrary(pikaMain, pikaModules_py_a);
+    pikaVM_runSingleFile(pikaMain, "test/python/mqtt/mqtt_connect.py");
+    obj_deinit(pikaMain);
+    EXPECT_EQ(pikaMemNow(), 0);
+}
 #endif

test/python/mqtt/mqtt_connect.py

@@ -0,0 +1,10 @@
+import mqtt
+
+client = mqtt.MQTT('192.168.1.255')
+
+client.setHost('broker.emqx.io')
+client.setPort(1883)
+
+client.connect()
+
+client.disconnect()

test/python/mqtt/mqtt_init.py

@@ -2,13 +2,6 @@ import mqtt
 
 client = mqtt.MQTT('192.168.1.255')
 
-client.set_host('broker.emqx.io')
-client.set_port(1883)
-ret = client.connect()
-print('client.connect:%d' % ret)
-
-ret = client.disconnect()
-print('client.disconnect:%d' % ret)