如何做一个国产数据库(七) 网络传输 java做订阅客户端

如何做一个国产数据库一 如何做一个国产数据库二 如何做一个国产数据库三 如何做一个国产数据库四 如何做一个国产数据库五 如何做一个国产数据库六

server端协议定义

再次强调一下我们的protocol 应用层的协议，其中协议第一个字节的前两位如下所示 //1字节 2位 //00 发布数据 //01 订阅数据 //10 心跳数据 //11 返回数据 所以服务端在接收到头部字节结束后，可以知道客户端时订阅客户端还是发布了

	int on_headers_complete(void* param) {
		//client_t* pclient = (client_t*)param;

		printf("the header len is %d\n", pclient->recvlen);
		//printf("the id is %04x\n", getid(pclient));
		client_t* cl = (client_t*)param;
		//得到头部字节
		char head = cl->head[0];
		char type = head >> 6;
		switch (type)
		{
		case 0x00://00 发布数据
		//放入发布列表
			cout