网关与太阳集团平台 之间的通讯体例通俗都是客户指定的，就那末几种（阿里云、华为云、腾讯云、亚马逊AWS平台）。通俗都请求网关与太阳集团平台 之间处于长毗连的状况，如许云真个各类指令便能够随时发送到网关。
与太阳集团平台 之间的 MQTT 毗连
今朝的几大物联网太阳集团平台 ，都供给了差别的接入体例。对网关来讲，操纵最多的便是 MQTT 接入。
咱们晓得，MQTT 只是一个和谈罢了，差别的编程说话中都有完成，在 C 说话中也有好几个完成。
在网关外部，运转着一个背景 deamon： MQTT Broker，实在便是 mosquitto 这个可履行法式，它充任着动静总线的功效。这里请大师注重：由于这个动静总线是运转在嵌入式体系的外部，接入总线的客户端便是须要彼此通讯的那些历程。这些历程的数目是无限的，即便是一个比拟庞杂的体系，最多十几个历程也就差未几了。是以，mosquitto 这个完成是完全能够支持体系负载的。
那末，若是在云端安排一个 MQTT Broker，实际上是能够间接操纵 mosquitto 这个完成来作为动静总线的，可是你要评价接入的客户端（也便是网关）在一个甚么样的数目级，斟酌到并发的题目，必然要做压力测试。
对背景开辟，我的经历未几，不敢（也不能）多言，误导大师就罪过了。不过，对通俗的进修和测试来讲，在云端间接安排 mosquitto 作为动静总线，是不题目标。
Proc＿Bridge 历程：外部和外部动静总线之间的桥接器
下面这张图，申了然 Proc＿Bridge 历程在这个模子中的感化：
从太阳集团平台
动静总线领受到的动静，须要转发到外部的动静总线；从外部动静总线领受到的动静，须要转发到太阳集团平台
的动静总线；
若是用 mosquitto 来完成，应当若何来完成呢？
1． mosquitto 的 API 接口
mosquitto 这个完成是基于回调函数的机制来运转的，比方：
／／ 毗连胜利时的回调函数void my＿connect＿callback（struct mosquitto ＊mosq， void ＊obj， int rc）｛ ／／ ．．．｝
／／ 毗连失利时的回调函数void my＿disconnect＿callback（struct mosquitto ＊mosq， void ＊obj， int result）｛ ／／ ．．．｝
／／ 领受到动静时的回调函数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 ＂， rc）； sleep（1）； mosquitto＿reconnect（g＿mosq）； ｝ ｝ mosquitto＿destroy（g＿mosq）； mosquitto＿lib＿cleanup（）； return 0；｝
以上代码便是一个 mosquitto 客户真个最简代码了，操纵回调函数的机制，让法式的开辟很是简略。
mosquitto 把底层的细节题目都赞助咱们处置了，只要咱们注册的函数被挪用了，就申明产生了咱们感乐趣的事务。
如许的回调机制在各类开源软件中操纵的比拟多，比方：glib 里的按时器、libevent通讯处置、libmodbus 里的数据处置、linux 内核中的驱动开辟和按时器，都是这个套路，一通百通！
在网关中的每一个历程，只须要增加下面这局部代码，便能够挂载到动静总线上，从而能够与别的历程停止收发数据了。
2． 操纵 UserData 指针，完成多个 MQTT 毗连
下面的实例仅仅是毗连到一个动静总线上，对一个通俗的历程来讲，到达了通讯的目标。
可是对 Proc＿Bridge 历程来讲，还不到达目标，由于这个历程处于桥接的地位，须要同时毗连到长途和本地这两个动静总线上。那末应当若何完成呢？
看一下 mosquitto＿new 这个函数的署名：
＊ obj － A user pointer that will be passed as an argument to any ＊ callbacks that are specified．最初一个参数的感化是：能够设置一个用户本身的数据（作为指针传入），那末mosquitto 在回调咱们的注册的任何一个函数时，都会把这个指针传入。
是以，咱们能够操纵这个参数来辨别这个毗连是长途毗连？仍是本地毗连。libmosq＿EXPORT struct mosquitto ＊mosquitto＿new（const char ＊id， bool clean＿session， void ＊obj）；
以是，咱们能够界说一个布局体变量，把一个 MQTT 毗连的一切信息都记实在这里，而后注册给 mosquitto。当 mosquitto 回调函数时，把这个布局体变量的指针回传给咱们，如许就拿到了这个毗连的一切数据，在某种水平下去讲，这也是一种面向工具的思惟。
／／ 历来表现一个 MQTT 毗连的布局体typedef struct｛ char ＊id； char ＊name； char ＊pw； char ＊host； int port； pthread＿t tHandle； struct mosquitto ＊mosq； int mqtt＿num；｝MQData；
完全的代码已放到网盘里了，为了让你先从道理上看大白，我把关头几个处所的代码贴在这里：
／／ 分派布局体变量MQData userData ＝ （MQData ＊）malloc（sizeof（MQData））；
／／ 设置属于这里毗连的参数： id， name 等等
／／ 建立 mosquitto 工具时，传入 userData。struct mosquitto ＊mosq ＝ mosquitto＿new（userData－＞id， true， userData）；
／／ 在回调函数中，把 obj 指针前转成 MQData 指针static void messageCB（struct mosquitto ＊mosq， void ＊obj， const struct mosquitto＿message ＊message）｛ MQData ＊userData ＝ （MQData ＊）obj； ／／ 此时便能够按照 userData 指针中的内容分辩出这是哪个链接了｝
别的一个题目：不晓得你是不是注重到示例中的 mosquitto＿loop（） 这个函数？这个函数须要放在 while 死轮回中不停的挪用，才能动身 mosuiqtto 外部的事务。（实在在 mosuiqtto 中，还供给了另外一个简化的函数 mosquitto＿loop＿forever）。
也便是说：在每一个毗连中，须要延续的触发 mosquitto 底层的事务，才能让动静体系顺遂的收发。是以，在示例代码中，操纵两个线程别离毗连到太阳集团平台 的总线和外部的总线。