main.cpp

通讯中间件

#include "comm.h"

int g_Count;

int main(int argc, char **argv)
{
	g_Count = 0;

	TLogFile log;
	TPacket packet;

	TComm comm;
	time_t time1, now;


	comm.SetModuleID(90);
	//comm.AddServer(2655);
	comm.AddClient("10.10.0.188", 7890);

	time1 = 0;

	int n1, n2, ret;
	n1 = 0;
	n2 = 0;
	while (1) 
	{
		//Sleep(1);

		now = time(NULL);
		if ((now - time1) >= 5)
		{
			time1 = now;

			printf("send=%d, success=%d, recv=%d\n", n1, n2, g_Count);
			fflush(stdout);
		}

		if (n1 < 100000)
		{
			if (comm.ExistID(20) == COMM_ERR_NONE)
			{
				n1++;

				memset(&packet, 0, sizeof(packet));
				packet.m_ModuleID = 20;
				_snprintf(packet.m_BodyBuf, sizeof(packet.m_BodyBuf) - 1, "Send to server, count=%d", n1);
				packet.m_BodyLen = (100 + n1)%COMM_BODY_SIZE;
				if (packet.m_BodyLen < 100)
				{
					packet.m_BodyLen = 100;
				}
				else if (packet.m_BodyLen > COMM_BODY_SIZE)
				{
					packet.m_BodyLen = COMM_BODY_SIZE;
				}
			
				ret = comm.SendMessage(&packet);
				if (ret != 0)
				{
					printf("FAIL: CLIENT->SENVER: %s\n", packet.m_BodyBuf);
					
					fflush(stdout);	
				}
				else
				{
					n2++;
				}
			}
		}
	}

	return 0;
}