基于C 的纯面向对象的通用高性能大并发TCP-SERVERCLIENT开发框架实践系列之基础篇.docVIP

基于C++纯面向对象的通用高性能大并发TCP-SERVERCLIENT开发框架实践系列之基础篇 PAGE 基于C++的纯面向对象的通用高性能大并发TCP-SERVER/CLIENT开发框架实践系列之基础篇yijian 2008-12-21 technologier@126.com前言本篇主要介绍Servant和Client都会使用到的公共基础，主要包括两大部分：一是对线程相关的封装；另是对Socket相关的封装。这些基础类间的关系比较简单，但是和Server/Client框架息息相关。线程相关类图CShared功能CShared实现了引用计数器，引用计数采用原子锁。所有需要使用到引用计数的类都可以从它派生出来。定义Class CShared{public:CShared(); // 初始化m_refcount为0int IncRef(); // 对m_refcount增一int DecRef(); // 对m_refcount减一int GetRef(); // 返回m_refcount的值private: int m_refcount; // 引用计数器变量};CThread功能将线程封装成一个类，所要创建一个线程时，只需要从它继承，并实现Run方法即可。定义class CThread: public CShared{private: virtual void run() = 0; // 线程执行体，子类必须实现这个方法public: virtual bool BeforeRun() { return true; } // 线程启动之前，可用来做一些初始化 virtual void AfterRun(int errcode) { } // 线程启动之后，如果errcode为0表示启动成功，否则表示一个出错代码，可使用strerror(errcode)得到具体的出错信息public:bool start(); // 启动线程void stop() { m_stop = true; } // 非强制性地停止线程protected:bool IsStop() const { return m_stop; } // 判断是否要退出线程Private: pthread_t m_thread // 线程句柄 bool m_stop; // 是否停止标识};CThreadPool功能提供一个通用的线程池功能。定义template class CThreadClassclass CThreadPool{public:typedef std::listCThreadClass* TThreadList;public:bool create(uint32_t size); // 创建和启动线程，线程个数由size指定void destroy(); // 停止和销毁所有线程private:TThreadList m_lstThread;};CMutex功能不可递归的锁。定义class CMutex{protected:CMutex(bool rec):m_rec(rec) {}public:CMutex():m_rec(false); // 初始化mutex~CMutex(); // 释放mutexbool lock(); // 加锁，出错代码由errno保存bool unlock(); // 解锁，出错代码由errno保存private:bool m_rec; // 是否可递归标识，如果为true则可递归，否则不可以递归pthread_mutex_t m_mtx; // mutex句柄};CRecMutex功能可递归的锁。定义class CRecMutex: public CMutex{public:CRecMutex():CMutex(true) {}};CMutexGuard功能智能锁，在构造中加锁，在析构中自动解锁。定义template class CMutexClassclass CMutexGuard{friend class CCondition;public CMutexGuard(CMutexClass mutex):m_mutex(mutex) { mutex.lock(); }~CMutexGuard() { m_mutex.unlock(); }private:CMutexClass m_mutex;};CCondition功能Posix条件的封装。定义class CCondition{public:CCondition(); // 初始化m_cond~CCondition(); // 释放m_condbool TimedWait(uint32_t milliSeconds); // 以毫秒方