client.cpp

采用完成端口的client/server DLL源码

#include "INetEngineClient.h"
#include <iostream>
//#include "string.h"
using namespace std;

enum tag{
	MSG_CHAR = 1,
};
struct pack{
	tag s_tag;
	char s_a[1000];
	char s_string[30];
};
int i=0;
pack a;


SYSTEMTIME ls_Old,ls_New;;
DWORD Time_Elapse;

bool Process( void* a_pBuffer,NET_MSG a_eMsg )
{
	if( a_eMsg == NET_MSG_RECV ){//接受消息
		pack* p=(pack*)a_pBuffer;
		if( p->s_tag == MSG_CHAR ){
			//cout<<p->s_string<<'\n';
			//cout<<" recv ok"<<'\n';
			printf("recv ok: %s\n",p->s_string);
			GetSystemTime(&ls_New);
			
			Time_Elapse=(ls_New.wMinute-ls_Old.wMinute)*60000+(ls_New.wSecond-ls_Old.wSecond)*1000+(ls_New.wMilliseconds-ls_Old.wMilliseconds);
			printf("Time Elapse: %d ms\n",Time_Elapse);
			
			GetSystemTime(&ls_Old);
			//Sleep(10);
		}
		/*if(i<10)
		{
		//	a.s_tag =MSG_CHAR;
			sprintf(a.s_string,"%d",i++);
			FOXNETSendBuf(&a,sizeof(a));
		}*/

	}
	else{//关闭消息
		cout<<"close";
	}
	return true;
}

void main()
{
	int Exit=1;

	GetSystemTime(&ls_New);
	GetSystemTime(&ls_Old);

	FOXNETCreateClient( Process );
	if(FOXNETConnect("218.98.193.36", 5554 )){
		cout<<"connect!\n";
	}
	//sprintf(a.s_string,"%d",i++);
	a.s_tag =MSG_CHAR;
	
	while(Exit)
	{
		//FOXNETSendBuf(&a,sizeof(a));
		//for(int i=1;i<10000;i++)
	//	{
			sprintf(a.s_string,"s3--%d",i);
			if(FOXNETSendBuf(&a,sizeof(a)))
			{
				Sleep(100);
				cout<<i<<' '<<" Send ok"<<'\n';
				//MessageBox(NULL,"FOXNETSendBuf","ERROR",NULL);
			}
			
		//}
		i++;
		if(i==1000)
		{
			/*char aa;
			cin>>aa;
			if(aa=='r')
			{
				Exit=1;
				i=1;
			}
			else if(aa=='e')
			{
				Exit=0;
			}*/
			Exit=0;
		}
	
	}

	FOXNETDisconnect();
}