main.cpp

通讯中间件

#include "main.h"

int g_Count1;
int g_Count2;
int g_Count3;

int main(int argc, char **argv)
{
	g_Count1 = 0;
	g_Count2 = 0;
	g_Count3 = 0;
	
	int ret, n1, n2, n3, suc1, suc2, suc3;
	
	//TAbc abc;
	
	TComm comm;
	TPacket packet;
	
	comm.SetModuleID(20);
	comm.AddServer(7890);
	comm.AddTrustIP("10.10.0.159");
	comm.AddTrustIP("10.10.1.28");
	comm.AddTrustIP("10.10.1.55");

	time_t time1, now;
	time1 = 0;
	
	n1 = 0;
	n2 = 0;
	n3 = 0;
	suc1 = 0;
	suc2 = 0;
	suc3 = 0;
	while (1)
	{
		usleep(2000000);

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

			printf("80----Send=%d, success=%d, recv=%d\n", n1, suc1, g_Count1);
			printf("50----Send=%d, success=%d, recv=%d\n", n2, suc2, g_Count2);
			printf("90----Send=%d, success=%d, recv=%d\n", n3, suc3, g_Count3);
			fflush(stdout);	
		}
		
		if (n1 < 10000)
		{
			if (comm.ExistID(80) == COMM_ERR_NONE)
			{
				n1++;
				memset(&packet, 0, sizeof(packet));
				packet.m_ModuleID = 80;
				_snprintf(packet.m_BodyBuf, sizeof(packet.m_BodyBuf) - 1, "Send to client, 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: SERVER->CLIENT 80: %s\n", packet.m_BodyBuf);
					
					fflush(stdout);	
				}
				else
				{
					suc1++;
				}
			}
		}

		if (n2 < 10000)
		{
			if (comm.ExistID(50) == COMM_ERR_NONE)
			{
				n2++;
				memset(&packet, 0, sizeof(packet));
				packet.m_ModuleID = 50;
				_snprintf(packet.m_BodyBuf, sizeof(packet.m_BodyBuf) - 1, "Send to client, count=%d", n2);
				packet.m_BodyLen = (100 + n2)%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: SERVER->CLIENT 50: %s\n", packet.m_BodyBuf);
					
					fflush(stdout);	
				}
				else
				{
					suc2++;
				}
			}
		}

		if (n3 < 10000)
		{
			if (comm.ExistID(90) == COMM_ERR_NONE)
			{
				n3++;
				memset(&packet, 0, sizeof(packet));
				packet.m_ModuleID = 90;
				_snprintf(packet.m_BodyBuf, sizeof(packet.m_BodyBuf) - 1, "Send to client, count=%d", n3);
				packet.m_BodyLen = (100 + n3)%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: SERVER->CLIENT 90: %s\n", packet.m_BodyBuf);
					
					fflush(stdout);	
				}
				else
				{
					suc3++;
				}
			}
		}
	}
	
	return 0;
}