echoworker.cpp

异步网络通讯例程

// EchoWorker.cpp: implementation of the CEchoWorker class.
//
//////////////////////////////////////////////////////////////////////

#include "stdafx.h"
#include "SyncServer.h"
#include "EchoWorker.h"

#ifdef _DEBUG
#undef THIS_FILE
static char THIS_FILE[]=__FILE__;
#define new DEBUG_NEW
#endif

//////////////////////////////////////////////////////////////////////
// Construction/Destruction
//////////////////////////////////////////////////////////////////////

CEchoWorker::CEchoWorker(SOCKET s, const char* szClientAddr, unsigned short nClientPort, BOOL bCloseWait)
: CSyncSocketWorker<CEchoWorker>(s, szClientAddr, nClientPort, bCloseWait)
{
}

CEchoWorker::~CEchoWorker()
{
}

void CEchoWorker::ProcessData()
{
 	const int nBufferSize = 4096;
	
	char* pBuffer = new char[nBufferSize];
	if(!pBuffer)
		return;


	CFile file;
	file.Open(TEXT("yourfile.dat"), CFile::modeRead);
	
	/*
	int nRead;
	while(nRead = Read(pBuffer, nBufferSize))
	{
		if(IsShutingdown())
			break;
		else
			Write(pBuffer, nRead);
	}
	*/

	while(!IsShutingdown() && IsConnected())
	{
		int nRead = file.Read(pBuffer, nBufferSize);
		if(nRead == 0)
			break;
		
		Write(pBuffer, nRead, FALSE);
	}

	SendRightNow();
	
	while(!IsSendBufferEmpty() && IsConnected())
		Sleep(500);
	
	delete [] pBuffer;
}