www.pudn.com > fanccMSNr.src.rar > MessageDispatcher.h


#pragma once 
#include  
#include  
 
#include "messenger/MessageDispatcher.hpp" 
#include "messenger/MessageListener.hpp" 
 
using namespace poral; 
 
/** 
* MessageDispatcher인터페이스를 CAsyncSocket을 통해 구현한 메시지 
* 전송 클래스. 
*/ 
class CMessageDispatcher : public CAsyncSocket,  
							public MessageDispatcher // interface 
{ 
public: 
	CMessageDispatcher(); 
	virtual ~CMessageDispatcher(); 
 
	// MessageDispatcher 인터페이스 
	virtual void connect(const string &address, unsigned long port); 
	virtual void close() { 
		Close(); 
	} 
	virtual int listen(int preferredPort); 
	virtual void getAddress(string &address); 
 
	virtual void sendMessage(Message &message); 
	virtual bool sendBytes(const unsigned char *bytes, size_t length); 
	virtual void addMessageListener(MessageListener &messageListener); 
	virtual void removeMessageListener(MessageListener &messageListener); 
	virtual MessageDispatcher *newInstance(); 
 
	virtual void OnConnect(int nErrorCode); 
protected: 
	/** 메시지가 통보될 리스너 */ 
	list listeners; 
	/** OnReceive에서 메시지를 조립하는 데 쓸 buffer */ 
	string buffer; 
	/** 서버로 소켓을 열 때 리스닝할 소켓 */ 
	CAsyncSocket *serverSocket; 
public: 
	virtual void OnClose(int nErrorCode); 
	/** 
	* 소켓으로부터 바이트가 도착했을 때 호출된다. 
	* 받아낸 바이트를 모아서 메시지를 구성하고 MessageListener를 호출한다. 
	*/ 
	virtual void OnReceive(int nErrorCode); 
	virtual void OnSend(int nErrorCode); 
};