物联网网关开发：基于MQTT消息总线的设计过程(下)

复制// 连接成功时的物联网网回调函数  void my_connect_callback(struct mosquitto *mosq, void *obj, int rc)  {      // ... }  // 连接失败时的服务器托管回调函数  void my_disconnect_callback(struct mosquitto *mosq, void *obj, int result)  {      // ... }  // 接收到消息时的IT技术网回调函数  void my_message_callback(struct mosquitto *mosq, void *obj, const struct mosquitto_message *message)  {    // .. }  int main()  {      // 其他代码      // ...      // 创建一个 mosquitto 对象      struct mosquitto g_mosq = mosquitto_new("client_name", true, NULL);      // 注册回调函数      mosquitto_connect_callback_set(g_mosq, my_connect_callback);      mosquitto_disconnect_callback_set(g_mosq, my_disconnect_callback);      mosquitto_message_callback_set(g_mosq, my_message_callback);      // 这里还有其他的网站模板回调函数设置      // 开始连接到消息总线      mosquitto_connect(g_mosq, "127.0.0.1", 1883, 60);      while(1)      {        int rc = mosquitto_loop(g_mosq, -1, 1);        if (rc) {          printf("mqtt_portal: mosquitto_loop rc = %d n", rc);          sleep(1);          mosquitto_reconnect(g_mosq);        }      }      mosquitto_destroy(g_mosq);      mosquitto_lib_cleanup();      return 0;  }  1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.17.18.19.20.21.22.23.24.25.26.27.28.29.30.31.32.33.34.35.36.37.38.39.40.41.42.43.44.45.46.47.48.