大规模多人同时聊天室服务器的SDK构架
构思了很久，现在基本的结构基本上确定下来了
采用UDP，消息队列的模式
采用多个类的方式来实现，但是还不时完全的面向对象设计，其中最关的多态性，类的继承都没有用到，因为感觉技术还没有到家，暂时利用几个类进行简单的包装，打算下次的类QQ中完全实现面向对象的设计的优点---多态性，也就是使用虚函数来实现！
这个服务器的基本流程是这样的，采用双线程来处理
服务器流程图如果下
接受到消息然后然后广播给所有的用户
定义一个结构体保存客户端的IP地址和端口
采用UDP通信
转发所有消息并显示于其它的客户端中
客户端下线或断开连接发送消息给服务器端，服务器删除其客户端的节点
定义一下数据包结构
struct ReceMessageData //接受数据包的结构
{
int iMessageType;
char szNickName[11];
char szRecvBuffer[512];
};
struct SendMessageData//发送数据包的结构
{
int iMessageType;
char szRecvBuffer[512];
}；
iMessageType==0表示下线删除其Socket节点，
iMessageType==1表示上线 在SOCKET库中追加新SOCKET
iMessageType==2 表示修改昵称，根据其SOCKET修改昵称
iMessageType==3的时候刷新在线列表，返回昵称给该客户端
iMessageType==4表示群发消息 遍历整个链表
保存在线用户的数据结构
#ifndef ONLINE_CHAIN_
#define ONLINE_CHAIN_
#include<Windows.h>
class SocketOnlineNode
{
//public:
friend class COnlineSocketChain;//设置为友员
private:
SocketOnlineNode* m_Next;//指向下一个节点
char m_szNickName[11];//客户端的昵称
char m_szIP[20];//IP地址
int m_iPort;//端口号
};
class COnlineSocketChain
{
public:
COnlineSocketChain();
~COnlineSocketChain();
int GetNodeNum();//返回节点的个数
char* GetIp(int);//取得第i个节点的SOCKET
int GetPort(int);//取得当前节点的端口
BOOL ModifyNickName(char*,char*,int);//根据IP和端口来修改用户昵称
BOOL AddSocket(char*,char*,int);//用户登陆时保存其昵称，IP和端口
char* FindAllNickName(char*,int);//根据ip和端口返回其昵称
BOOL DeleteSocket(char*,int);//根据ip和端口
private:
SocketOnlineNode* m_FirstNode;//指向第一个节点的指针
};
#endif //ONLINE_CHAIN_
为了实现大规模并行处理能力
在这里要定义一个消息队列的类
这个类的主要功能是保存接收到的消息，然后让线程函数来处理来从这个类取出消息并进行处理
#ifndef MESSAGE_CHAIN_
#define MESSAGE_CHAIN_
class QueueNode
{
friend class MessageChain;
private:
int m_iMessageType;//消息类型
char m_szRecvBuffer[512];//消息内容
char m_szIP[20];//ip地址
int m_Port;//端口
QueueNode* m_Next;//指向下一个结点
};
class MessageChain
{
public:
MessageChain();
~ MessageChain();
CheckMessage();//检查消息队列中是否有消息没有返回FALSE 反之返回TRUE
AddMessage(QueueNode);//添加消息
GetMessage(QueueNode);//取出消息
private:
QueueNode* m_front;//头结点
QueueNode* m_rear;//尾结点
};
#endif // MESSAGE_CHAIN_
SOCKET的初始化类
#ifndef BASE_SOCKET_
#define BASE_SOCKET_
#include<Windows.h>
struct ReceMessageData //接受数据包的结构
{
int iMessageType;//消息类型
char szNickName[11];//客户端的昵称
char szRecvBuffer[512]; //接收消息内容
};
class BaseSocket
{
public:
BaseSocket();//构造函数
~BaseSocket();//析构函数
DWORD InitSocketVersion();//协议协商
BOOL GetLocalIP();//取得本主机IP
BOOL InitSocket(); //创建并绑定socket
BOOL RecvMessage();//接受消息的操作 FALSE代表没有消息,TURE代表有消息
ReceMessageData* GetRecvBuffer();//取得接受到的内容
private:
SOCKET m_ServSocket;//服务器socket
char m_szLocalIp[20];//保存主机IP;
int m_iServPort;//服务器的端口
ReceMessageData* RecvBuffer;//定义接受的数据结构
}
#endif //BASE_SOCKET_
本来还想写一个多线程处理的类，能力有限，下次写改进的时候写了吧
下面就正式CODING了