server.cpp

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

// Server.cpp: implementation of the CServer class.
//
//////////////////////////////////////////////////////////////////////

#include "stdafx.h"
#include "te.h"
#include "Server.h"

#include"tedlg.h"
#ifdef _DEBUG
#undef THIS_FILE
static char THIS_FILE[]=__FILE__;
#define new DEBUG_NEW
#endif

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

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

}

CServer::~CServer()
{
	WSAAsyncSelect(m_hUSocket, m_hWnd, 0, 0);
		WSAAsyncSelect(m_hTSocket, m_hWnd, 0, 0);
}

BOOL CServer::UDPCreateSocket(HWND hwnd,UINT port)
{
	m_uPort=port;
	m_hWnd=hwnd;

	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);
		UDPServerInit();
	}
	m_addr.sin_family = AF_INET;
	m_addr.sin_addr.S_un.S_addr = INADDR_ANY;
	m_addr.sin_port = htons(m_uPort);

	int ret = 0;
	int error = 0;


	// 允许广播
	BOOL optval = TRUE;
	if ( SOCKET_ERROR == setsockopt( m_hUSocket, SOL_SOCKET, SO_BROADCAST, (char *) &optval, sizeof( BOOL ) ) )
		{
			closesocket( m_hUSocket );
			return false;
		}
		// 设定变量
		m_bBroadcast = true;


	//绑定一个套接字到本机的地址
	ret = bind(m_hUSocket, (LPSOCKADDR)&m_addr, sizeof(m_addr));

	if(ret == SOCKET_ERROR)
	{	//绑定错误
		AfxMessageBox("绑定错误");
		return FALSE;
	}

	return TRUE;
}


BOOL CServer::TCPInitAndListen(HWND hwnd,UINT port)
{
	m_tPort=port;
	m_hWnd=hwnd;

	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);
		TCPServerInit();
	}
	m_addr.sin_family = AF_INET;
	m_addr.sin_addr.S_un.S_addr = INADDR_ANY;
	m_addr.sin_port = htons(m_tPort);

	int ret = 0;
	int error = 0;
	//绑定一个套接字到本机的地址
	ret = bind(m_hTSocket, (LPSOCKADDR)&m_addr, sizeof(m_addr));

	if(ret == SOCKET_ERROR)
	{	//绑定错误
		AfxMessageBox("Binding Error");
		return FALSE;
	}
	
	//开始一个侦听过程，等待客户的连接
	ret = listen(m_hTSocket, 5);    //这里的第二个参数表示最多支持的客户连接数
	if(ret == SOCKET_ERROR)
	{	//listen失败
		AfxMessageBox("Listen Error");
		return FALSE;
	}

	return TRUE;
}

void CServer::TCPServerInit()
{
	if(WSAAsyncSelect(m_hTSocket, m_hWnd, SER_MESSAGE, FD_ACCEPT|FD_READ|FD_WRITE|FD_CLOSE)>0)
		AfxMessageBox("error select");
}

void CServer::UDPServerInit()
{
	if(WSAAsyncSelect(m_hUSocket, m_hWnd, UDP_S_SOCK, FD_ACCEPT|FD_READ|FD_WRITE|FD_CLOSE)>0)
		AfxMessageBox("error select");
}