remote.cpp

UDP点对点通讯客户端和服务端

// remote.cpp : Defines the entry point for the console application.
//

#include "stdafx.h"
#include "remote.h"
#include "process.h"

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

/////////////////////////////////////////////////////////////////////////////
// The one and only application object

CWinApp theApp;

using namespace std;


unsigned int __stdcall ConnThread(void* param);

int _tmain(int argc, TCHAR* argv[], TCHAR* envp[])
{
	int nRetCode = 0;

	// initialize MFC and print and error on failure
	if (!AfxWinInit(::GetModuleHandle(NULL), NULL, ::GetCommandLine(), 0))
	{
		// TODO: change error code to suit your needs
		cerr << _T("Fatal Error: MFC initialization failed") << endl;
		nRetCode = 1;
	}
	else
	{
		// TODO: code your application's behavior here.
		CString strHello;
		strHello.LoadString(IDS_HELLO);
		cout << (LPCTSTR)strHello << endl;
	}
	
	WSADATA wsa;
	if(!AfxSocketInit(&wsa))
	{
		cout<<_T("socket init failed")<<endl;
	}
	_beginthreadex(NULL,0,ConnThread,NULL,0,NULL);
	while(getchar()!='e')
	{
		Sleep(5000);
	}
	return nRetCode;
}

unsigned int __stdcall ConnThread(void* param)
{
/*	SOCKET sock;
	sock=socket(AF_INET,SOCK_DGRAM,0);
	SOCKADDR_IN sin,saServ;
	int nSize=0;
	sin.sin_family=AF_INET;
	sin.sin_port=htons(10002);
	sin.sin_addr.s_addr=htonl(INADDR_ANY);
	bind(sock,(SOCKADDR FAR*)&sin,sizeof(sin));

	saServ.sin_family=AF_INET;       
	saServ.sin_addr.s_addr=inet_addr("127.0.0.1");
	saServ.sin_port=htons(10002);
    nSize=sizeof(SOCKADDR_IN);
	char szBuf[10]={0};
	while(1)
	{
		sendto(sock,"abcdefghij",10,0,(SOCKADDR*)&saServ,sizeof(SOCKADDR_IN));
		recvfrom(sock,szBuf,10,0,(SOCKADDR*)&saServ,&nSize);
		printf("%s",szBuf);
		memset(szBuf,0,10);
		Sleep(5000);
	}*/
/*	CSocket sockConn;
	sockConn.Create(0,SOCK_DGRAM,NULL);
	UINT nPort;
	CString strAddr;
	sockConn.GetSockName(strAddr,nPort);
	char szBuf[8]={0};
	strcpy(szBuf,"connect");
	while(TRUE)
	{
		sockConn.SendTo(szBuf,8,10002,"127.0.0.1",0);
		sockConn.ReceiveFrom(szBuf,8,strAddr,nPort);
		Sleep(10000);
	}
*/

	CUdpSocket sock;
	sock.Create(0,SOCK_DGRAM);
	sock.GetSockName(sock.strAddr,sock.nPort);
	char szBuf[8]={0};
	strcpy(szBuf,"connect");
	while(1)
	{
		sock.SendTo(szBuf,8,10002,"127.0.0.1",0);
		Sleep(10000);
	}
	return 0;
}

unsigned int __stdcall ExecThread(void* param)
{
	return 0;
}