client.cpp

俄罗斯方块,带背景音乐,带扩展窗口,操作同qq游戏的疯狂俄罗斯

// Client.cpp: implementation of the CClient class.
//
//////////////////////////////////////////////////////////////////////

#include "stdafx.h"
#include "TE.h"
#include "Client.h"

#include "TEDLG.h"

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

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

CClient::CClient()
{
	m_hUSocket =NULL;
	m_hTSocket =NULL;

}

CClient::~CClient()
{

}


//连接服务器
BOOL CClient::UDPConnectServer(HWND hwnd,UINT port,CString strserver) 
{
	m_hWnd=hwnd;
	m_uPort=port;
	m_strServer=strserver;
	if(m_hUSocket != NULL)
	{
		//如果原来打开这套接字先关闭
		closesocket(m_hUSocket);
		m_hUSocket = NULL;
	}
	if(m_hUSocket == NULL)
	{
		//创建新的流套接字
		m_hUSocket = socket(AF_INET, SOCK_DGRAM,0);
		ASSERT(m_hUSocket != NULL);
		UDPClientInit();
	}

	//准备服务器的信息，这里需要指定服务器的地址
	m_addr.sin_family = AF_INET;
	m_addr.sin_addr.S_un.S_addr = inet_addr(m_strServer.GetBuffer(0));
	m_addr.sin_port = htons(m_uPort);   //改变端口号的数据格式
	
	//这里主动连接服务器，该过程将等待一定时间
	int ret = 0;
	int error = 0;
	ret = connect(m_hUSocket, (LPSOCKADDR)&m_addr, sizeof(m_addr));
	if(ret == SOCKET_ERROR)
	{//连接失败
		if(GetLastError()!=WSAEWOULDBLOCK)
		{
			AfxMessageBox(_T("请确认服务器确实已经打开并工作在同样的端口！"));
			return FALSE;
		}
	}
	return TRUE;
}



BOOL CClient::TCPInitAndConnet(HWND hwnd,UINT port,CString strserver)
{
	m_hWnd=hwnd;
	m_tPort=port;
	m_strServer=strserver;
	if(m_hTSocket != NULL)
	{
		//如果原来打开这套接字先关闭
		closesocket(m_hTSocket);
		m_hTSocket = NULL;
	}
	if(m_hTSocket == NULL)
	{
		//创建新的流套接字
		m_hTSocket = socket(AF_INET, SOCK_STREAM,0);
		ASSERT(m_hTSocket != NULL);
		TCPClientInit();
	}

	//准备服务器的信息，这里需要指定服务器的地址
	m_addr.sin_family = AF_INET;
	m_addr.sin_addr.S_un.S_addr = inet_addr(m_strServer.GetBuffer(0));
	m_addr.sin_port = htons(m_tPort);   //改变端口号的数据格式
	
	//这里主动连接服务器，该过程将等待一定时间
	int ret = 0;
	int error = 0;
	ret = connect(m_hTSocket, (LPSOCKADDR)&m_addr, sizeof(m_addr));
	if(ret == SOCKET_ERROR)
	{//连接失败
		if(GetLastError()!=WSAEWOULDBLOCK)
		{
			AfxMessageBox(_T("请确认服务器确实已经打开并工作在同样的端口！"));
			return FALSE;
		}
	}
	return TRUE;
}


void CClient::TCPClientInit()
{
	if(WSAAsyncSelect(m_hTSocket,m_hWnd,CLI_MESSAGE,FD_READ|FD_WRITE|FD_CLOSE|FD_CONNECT)>0)
	{
		AfxMessageBox("Error in select");
	}
}

void CClient::UDPClientInit()
{
	if(WSAAsyncSelect(m_hUSocket,m_hWnd,UDP_C_SOCK,FD_READ|FD_WRITE|FD_CLOSE|FD_CONNECT)>0)
	{
		AfxMessageBox("Error in select");
	}
}