模拟服务器

开发平台：

C/C++

IClient.h：源码内容

							#ifndef ICLIENT_H
#define ICLIENT_H
//应该使用线程的方法,Startup启动线程等待信号,不同的IO模型使用不同的信号通知这些线程,处理的时候
//根据处理器数目的不同启动不同数目的线程和缓冲区,处理异常情况
#include "zport.h"
#include "xbuffer.h"
#include "Cipher.h"
enum enumServerConnectInfo {
	enumServerConnectCreate = 0x100,
	enumServerConnectClose
};
typedef void (*CALLBACK_CLIENT_EVENT )(void *lpParam, const unsigned long &ulnEventType);
class IClient;
class IClientThread : public ZThread {
	IClient *parent;
public:
	IClientThread(IClient *the_parent) : ZThread() {
		parent = the_parent;
	}
	int action();
};
extern ZPerf g_sendPerf;
extern ZPerf g_recvPerf;
class IClient {
protected:
	IClientThread *thread;
public:
	ZPerf sendPerf;
	ZPerf recvPerf;
	bool bConnected;
	bool bStop;
	unsigned int m_uServerKey;
	unsigned int m_uClientKey;
//	int read_index;
//	int write_index;
	CALLBACK_CLIENT_EVENT call_back;
	void *call_back_param;
	int nSocket;
	ZBuffer *buffer;
	IClient(int max_send = 640 * 1024, int max_receive = 640 * 1024);
	~IClient();
	int Startup();						//启动一个线程发送
	int Cleanup();
	int Shutdown();
	void Release() {
	}
	bool ConnectTo(const char * const &pAddressToConnectServer, unsigned short usPortToConnectServer);
	void RegisterMsgFilter(void * lpParam, CALLBACK_CLIENT_EVENT pfnEventNotify);
	bool SendPackToServer( const void * const pData, const unsigned long datalength);
	void *GetPackFromServer(unsigned int &datalength );
	void startPerf() {
		buffer->startPerf(&g_recvPerf, &g_sendPerf);
	}
	void stopPerf() {
		buffer->stopPerf();
	}
};
#endif

						