上面列举了该结构体部分重要成员，其中sock表示mosquitto服务器程序与该客户端连接通信所用的socket描述符；address表示该客户端的IP地址；id是该客户端登陆mosquitto程序时所提供的ID值，该值与其他的客户端不能重复；成员username和password用于记录客户端登陆时所提供的用户名和密码；keepalive是该客户端需在此时间内向mosquitto服务器程序发送一条ping/pong消息。参数last_msg_in和last_msg_out用于记录上次收发消息的时间；参数struct mosquitto_client_msg*msgs用于暂时存储发往该context的消息。
2） struct mosquitto_db
结构体struct mosquitto_db是mosquitto对所有内部数据的统一管理结构，可以认为是其内部的一个内存数据库。它保存了所有的客户端，所有客户端的订阅关系等等，其定义形式为：
struct mosquitto_db{
dbid_tlast_db_id;
struct_mosquitto_subhier subs;
struct mosquitto**contexts;
struct_clientid_index_hash *clientid_index_hash;
intcontext_count;
structmosquitto_msg_store *msg_store;
intmsg_store_count;
structmqtt3_config *config;
intsubscription_count;
……
};
上述结构体声明中，结构体成员struct _mosquitto_subhier subs保存了订阅树的总树根，mosquitto中对所有的topic都在该订阅树中维护，客户端的订阅关系也在该订阅树中维护；结构体成员struct mosquitto **contexts可理解为一个用于存放所有客户端变量（类型为struct mosquitto）地址的数组，mosquitto程序中，所有的客户端都在此数组中保存；成员int context_count用于保存数组contexts的大小，该值也是当前mosquitto程序中维持的所有客户端的数目；成员结构体struct
_clientid_index_hash*clientid_index_hash用于保存一个hash表，该hash表可通过客户端的ID快速找到该客户端在数组contexts中的索引；结构体成员struct mqtt3_config*config用于保存mosquitto的所有配置信息；
3）struct_mosquitto_subhier
数据结构struct _mosquitto_subhier是用于保存订阅树的节点（包括叶子节点和中间节点），mosquitto中对订阅树采用孩子-兄弟链表法的方式进行存储，该存储方式主要借助与数据结构struct _mosquitto_subhier来完成，该数据结构的定义为：
struct _mosquitto_subhier {
struct_mosquitto_subhier *children;
struct_mosquitto_subhier *next;
struct_mosquitto_subleaf *subs;
char*topic;
structmosquitto_msg_store *retained;
};
成员说明：
children ：该成员指针指向同结构的第一个孩子节点；
next：该成员指针指向该节点的下一个兄弟节点；
subs：该成员指向订阅列表；
topic：该节点对应的topic片段；
4） struct _mosquitto_subleaf
在mosquitto程序中，对某一topic的所有订阅者被组织成一个订阅列表，该订阅列表是一个双向链表，链表的每个节点都保存有一个订阅者，该链表的节点即是：struct _mosquitto_subleaf，定义形式为：
struct _mosquitto_subleaf {
struct_mosquitto_subleaf *prev;
struct_mosquitto_subleaf *next;
structmosquitto *context;
int qos;
};
其中成员struct mosquitto *context表示一个订阅客户端，prev和next表示其前一个节点和后一个节点。
5）structmqtt3_config
结构体struct mqtt3_config用于保存mosquitto的所有配置信息，mosquitto程序在启动时将初始化该结构体并从配置文件中读取配置信息保存于该结构体变量内。
三、 Mosquito的核心功能分析
3.1、订阅树
Mosquitto通过订阅树的方式来管理所有的topic以及客户端的订阅关系，它首先将所有的topic按照/分割并组织成一棵树结构，从根节点到树中的每个节点即组成该节点所对应的一个topic，每个topic都保存一个订阅列表，该订阅列表中保存了所有订阅当前topic的客户端信息。例如有如下订阅关系：
客户端a1,a2,a3订阅了topic：A1/B1/C1
客户端b1,b2订阅了topic：A2/B2/C2
客户端c1,c2订阅了topic：A1/B1/C3
客户端d1订阅了topic：A2/B3
则在mosquitto程序中需要先将topic按照/进行分割，然后将分割后的topic片段组织成订阅树，上述订阅树的示意图为图3-1：
图3-1 订阅树示意图
Mosquitto程序在实现中根据topic消息的性质将订阅树分为两颗子树：业务子树和系统子树；mosquitto程序中将topic分为两种类型来处理：系统topic和业务topic，前者主要用于发布和维护mosquitto内部的系统消息，后者的topic是用户订阅的业务topic，做这种区分的原因是因为这两种的类型的topic性质和实现方式上有许多差别，这种差别主要体现在以下4点：
1）生存周期不同，系统topic无论是否有用户订阅都会存在与订阅树中，而业务topic必须有客户端订阅才能存在（除非其消息字段retain设置为1）；
2）创建方式不同，系统topic在消息发布时进行创建，业务topic即可以在订阅时创建也可以在消息发布时创建（此时需要该消息retain字段设置为1）；
3）消息保存方式不同，凡是发布到系统topic的消息都会被保存下来，业务消息将直接挂到订阅列表的各context的消息队列中，如果没有连接订阅或未设置其retain字段，消息将不会被保存下来；
消息的retain字段是否被设置在函数mqtt3_handle_publish进行检查，在该函数中有如下代码：
retain = (header & 0x01);
该代码可获取消息头部的第一个bit位，在mqtt3.1协议中，该为用于表示消息的类型是否为retain。
订阅树在程序中的采用孩子—兄弟链表法来表示。其主要涉及的数据结构是：
struct _mosquitto_subhier
struct _mosquitto_subleaf
3.1.1、订阅树的搭建
1、创建订阅树
mosquitto程序启动时将创建订阅树，该过程将创建三个节点：订阅树总根节点、业务子树根节点和系统子树根节点，这两个子树根节点作为订阅树总根节点的两个子节点，其中订阅树总根节点和业务子树的根节点中topic成员的值为空字符串，而系统子树根节点中保存的值为“$SYS”，如图3-2所示。
图3-2 订阅树的创建
订阅树的创建主要在文件database.c中mqtt3_db_open函数里实现。订阅树中节点的数据结构为struct _mosquitto_subhier，订阅树采用“孩子—兄弟”链表法保存。
2、搭建订阅树
在订阅树中，系统子树与业务子树的搭建过程不一样，系统子树是在系统消息发布时创建，而业务子树创建过程即可以在消息发布时创建也可以在客户端订阅时才创建。
1)系统子树搭建过程
Mosquitto中，系统子树在发布系统消息时，自动检测topic片段是否存在，如果不存在则在系统topic上创建节点以搭建订阅树。例如，mosquitto程序启动时，将首先向系统topic：$SYS/broker/version发送一条版本消息“mosquittoversion 1.2”，此时订阅树的系统子树只有一个根节点，如图3.2所示，其搭建过程如下：
(1)将topic按照”/”分成topic片段，系统Topic：$SYS/broker/version将被分割为$SYS、broker、version三部分。
(2)根据第一个topic片段“$SYS”遍历订阅树的子节点找到系统子树的根节点。
(3)根据topic下一个片段“broker”查找系统子树；此时系统子树中不存在topic片段“broker”的节点，则为订阅树产生一个节点，其数据结构为：struct_mosquitto_subhier。此时订阅树由图3-2变为图3-3所示：
图3-3添加broker节点之后的订阅树
上述过程在函数mqtt3_db_messages_queue中调用函数_sub_add来完成。
(4)依此处理topic剩下的片段，在系统子树中添加topic片段“version”，该过程通过递归调用函数_sub_add来完成。添加完“version”片段之后的订阅树如图3-4所示。