引言
多路复用I/O模型是UNIX/LINUX用得的最多的一种I/O模型。这种I/O模型在技术上的实现是包括select()以及FD_XXX的几个宏及常量。在单个进程中支持的客户端数量由FD_SETSIZE决定。Solaris 10和Linux 9.0默认为1024个,Windows 2000是64个。本文用代码给出该I/O模型处理多Client的一种实现。
用select开发一个通信服务器
这个服务器包括接收模块、发送模块和套接口管理模块。我们只演示与select实现有关的部分,即接收模块和套接口管理模块。下面服务器类关系图:
tcp_listen是tcp实现监听功能,tcp_comm实现tcp的发送和接收,下在我们重点在于recv和sock_list这两个类。sock_list定义如下:
class sock_list
{
public:
// 功能:将一个值插入到list的尾部
// 参数:要插入的tcp_comm对象
void insert(tcp_comm* t);
// 功能:删除一个指定的元素
// 参数:指向要删除的tcp_comm对象的指针
void remove(tcp_comm* t);
// 功能:从队列取得所有的元素
// 参数:存放指向tcp_comm对象指针的向量
void get_all(std::vector<tcp_comm*>& vec);
private:
std::list<tcp_comm*> _sock_list;
};
sock_list实现tcp_comm对象的管理。下面我们来看recv类的定义:
class recv
{
public:
// 功能: 启动通信服务
bool start();
private:
// 功能: 接收核心函数,通过多路复用支持多个客户端
// 返回值: 正常, 0; 失败,-1
int do_select();
// 初始化套接口集合
void init_readfds(const vector<tcp*>& vec, fd_set* set);
private:
sock_list* _list;
tcp_listen* _listen; // 监听套接口
};
start()是给外部调用的:创建监听套接口对象;监听;执行do_select()。init_readfds将监听套接口对象和socket_list中的通信套接口对象加入到套接口读套接口集合中。do_select()比较重要,流程:
用init_readfds初始化读套接口集合;
执行select(),返回进行到下一步;
先检测监听套接口是否有连接到来,并将新的连接加入到sock_list中;
再检测sock_list中的套接口是否有数据可接收。