class commfailure : public std::runtime_error { public: explicit commfailure(const char* message); int errnum() const; private: int errnum_; }; class transceiver { public: transceiver(); transceiver(const transceiver& rhs); transceiver& operator= (const transceiver& ); ~transceiver(); void send(const char* buf, long len); long recv(char* buf, long len); bool peek(); void close(); const char* peer() const; int port() const; private: friend class connector; friend class acceptor; transceiver(socket_t s, const sockaddr_in& a); }; class connector { public: connector(); transceiver connect(const char* addr, int port); private: connector(const connector& rhs); connector& operator= (const connector& rhs); struct LibInitializer { LibInitializer(); ~LibInitializer(); }; static const LibInitializer theLibInitializer; }; class acceptor { public: acceptor(); ~acceptor(); void listen(int port, int backlog = 100); transceiver accept(); private: acceptor(const acceptor& rhs); acceptor& operator= (const acceptor& rhs); struct LibInitializer { LibInitializer(); ~LibInitializer(); }; static const LibInitializer theLibInitializer; }; 为了简单,我将三个类中的private部分都去掉了。 注意设计中的细节:
1。connector/acceptor都没有拷贝和赋值能力。 2。transceiver应该是一个基于引用计数的实现,因为使用者不需显式调用transceiver::close()。 3。因为windows下使用socket需要初始化,所以让他们自动初始化。 扩展的方向。 1。因为connector/acceptor/transceiver是一个概念,所以该模式适合于所有的通讯方式:tcp/udp,pipe,x.25,共享内存等。这是协议上的扩展 2。基于扩展1的框架,向异步通讯模式的转变。 写在最后的话:本文地址:http://com.8s8s.com/it/it25063.htm