谢欣伦 - OpenDev原创教程 - 服务端套接字类CxServerSocket

时间:2023-09-01 22:21:03
谢欣伦 - OpenDev原创教程 - 服务端套接字类CxServerSocket

  这是一个精练的服务端套接字类,类名、函数名和变量名均采用匈牙利命名法。小写的x代表我的姓氏首字母(谢欣伦),个人习惯而已,如有雷同,纯属巧合。

CxServerSocket的使用如下(以某个叫做CSomeClass的类的相关代码为例):

一、声明服务端套接字对象实例。

CxServerSocket m_ssLocalHost;

二、设置服务端套接字事件通知方式。消息响应或回调函数,任选其一。服务端套接字事件有:接收到客户端的连接请求。

void CSomeClass::PreSubclassWindow()
{
// TODO: Add your specialized code here and/or call the base class
HWND hwnd = GetSafeHwnd();
MSG msg = {hwnd, WM_SOCKET_EVENT};
m_usRemoteHost.SetWindowMessage(&msg);
m_csRemoteHost.SetWindowMessage(&msg);
m_ssLocalHost.SetWindowMessage(&msg); if (m_btCSMode == CSM_SERVER)
ListenRemoteHost(); CStatic::PreSubclassWindow();
}

三、侦听客户端连接请求

BOOL CSomeClass::ListenRemoteHost()
{
char szIPAddr[MAX_IPV6];
if (CxSocket::GetLocalHost(szIPAddr))
return m_ssLocalHost.Listen(szIPAddr, NETPORT_NETWORK_COMM);
else
return FALSE;
}

  NETPORT_NETWORK_COMM是一个自定义的TCP端口值,只要不与公用端口冲突就行。

四、处理消息响应或函数回调。
1.消息响应

BEGIN_MESSAGE_MAP(CSomeClass, CStatic)
//{{AFX_MSG_MAP(CSomeClass)
ON_WM_DESTROY()
//}}AFX_MSG_MAP
ON_MESSAGE(WM_SOCKET_EVENT, OnSocketEvent)
END_MESSAGE_MAP() /////////////////////////////////////////////////////////////////////////////
// CSomeClass message handlers LRESULT CSomeClass::OnSocketEvent(WPARAM wParam, LPARAM lParam)
{
if (WSAGETSELECTERROR(lParam) != )
return ; int nEvent = WSAGETSELECTEVENT(lParam);
switch (nEvent)
{
  case FD_ACCEPT: OnSocketAccept(wParam); break;
  case FD_CLOSE: OnSocketClose(wParam); break;
  case FD_READ: OnSocketRead(wParam); break;
  default: break;
} return ;
} void CSomeClass::OnSocketAccept(WPARAM wParam)
{
if ((SOCKET)wParam == m_ssLocalHost.GetSocket())
{
CxClientSocket xcs;
xcs =m_ssLocalHost.Accept(); if (xcs.GetSocket() != INVALID_SOCKET)
{
char szIPAddr[MAX_IPV6];
xcs.GetRemoteHost(szIPAddr); if (strcmp(szIPAddr, m_ipapRemoteHost.szAddr) == )
m_csRemoteHost = xcs.GetSocket();
       else
{
xcs.DisConnect(); CString str;
str.Format("unknown socket %s disconnect.\n", szIPAddr);
OutputDebugString(str);
}
}
}
}

2.回调函数

LRESULT CALLBACK CSomeClass::SocketProc(HWND hwnd, UINT uMsg, WPARAM wParam, LPARAM lParam)
{
LRESULT lRet = ;
CSomeClass* pThis = (CSomeClass*)hwnd;
if (pThis != )
lRet = pThis->OnSocketEvent(wParam, lParam); return lRet;
}

  注意,在使用回调函数时应设置服务端套接字事件通知方式为回调函数,并且设法把this指针传入设置函数,方便在回调函数中调用成员函数。

MSG msg = {(HWND)this, WM_SOCKET_EVENT};
m_ssRemoteHost.SetWindowMessage(&msg, SocketProc);

五、停止侦听客户端连接请求

void CSomeClass::OnDestroy()
{
CStatic::OnDestroy(); // TODO: Add your message handler code here
TerminateWaitComm(); m_csRemoteHost.DisConnect();
m_ssLocalHost.DisListen();
m_usRemoteHost.Disbind();
}

  至于服务端如何与客户端交换数据,很简单:将服务端接受的客户端连接赋给一个客户端套接字对象实例,然后让这个客户端套接字对象实例在需要处完成数据交换就可以了(客户端套接字类CxClientSocket如何使用?请查阅往期文章)。

CxClientSocket xcs;
xcs = m_ssLocalHost.Accept();
// Save the expected socket and disconnect the unexpected socket
m_csRemoteHost = xcs.GetSocket();

  精练的代码不需要过多解释,你们懂的。To be continued...