CNC 客户机的API设计

类CNCClient客户机用来实现“发布—订阅”和“组播”功能，主要接口（公有函数）如下：

class CNCClient

{ public:

BOOL Connect(…); // 连接服务器

BOOL Disconnect(); // 与服务器断开连接

BOOL PublishData(…); // 向服务器发布数据

BOOL QueryData(…); // 向服务器查询数据

BOOL SubscribeData(…); // 向服务器订阅数据

GROUPIP QueryGroupIP(…); // 向服务器查询组播地址

DWORD MulticastMessage(…); // 发送组播消息

virtual void MessageResponse(…);// 响应组播消息

…

};

一、客户程序的“发布”协议

客户机向服务器发布的每个数据报均含有数据类型、工作组名称、数据名称、生命期和数据长度的信息。数据结构见 DataPublish ：

struct DataPublish

{

BYTE iDataType; // 2 个字节数据类型，宏定义为DATA_PUBLISH

char strGroupName[16]; // 16个字节的工作组名字

char strDataName[16]; // 16个字节的数据名字

DWORD dwLifeTime; // 4 个字节的数据生命期，以秒为单位

DWORD dwLength; // 4 个字节的数据内容的长度

char *pchContent; // 数据内容

};

2字节 16字节 16字节 4字节 4字节

data type group name data name life time length content

二、客户程序的“订阅”协议

客户机向服务器订阅数据分两步实现：

（1）先调用函数QueryData向服务器发送一个 DataQuery格式的报文，用于查询要订阅的数据是否存在。

struct DataQuery

{

BYTE iDataType; // 2 个字节数据类型，宏定义为DATA_QUERY

char strGroupName[16]; // 16个字节的工作组名字

char strDataName[16]; // 16个字节的数据名字

};

（2）服务器接收到查询时，按照 DataQuery结构中的strGroupName和strDataName进行搜索。如果该数据不存在，Server向Client发送一个FALSE标志。如果该数据存在，服务器先向客户机发送一个TRUE标志，之后立即再向客户机发送该数据（DataPublish格式）。

如果客户机得到TRUE标志的查询结果，就调用函数SubscribeData来接收服务器发送过来的数据。

三、客户程序的“组播”协议

客户机先调用函数QueryGroupIP向服务器发送一个GroupAddress格式的报文，用于查询组播地址。服务器返回相应的十进制点分式的IP地址。

struct GroupAddress

{

BYTE iDataType; // 2 个字节数据类型，宏定义为GROUP_ADDRESS

char strGroupName[16]; // 16个字节的工作组名字

};

客户机调用函数MulticastMessage向指定的组（根据组播地址）播放消息。组播的数据报结构 DataMulticast定义如下：

struct DataMulticast

{

DWORD dwContentType; //　组播的数据报类型，由用户定义

char *pchContent; //　组播的数据报内容，由用户定义

};

如果客户机接收到组播的消息，将自动调用函数MessageResponse来响应该消息。MessageResponse是虚函数，它将根据dwContentType信息决定如何处理到来的组播消息，具体功能由用户定义。