HP-Socket是一个免费的开源通信库。 由于示例代码看起来很庞杂，所以简化后写了demo
服务器端：//请在调试模式中包括HPSocket4C_UD.lib
//在工程目录中包括头套HPSocket4C.h、HPTypeDef.h和SocketInterface.h
#pragmaonce
#include'HPSocket4C.h '
constlpctstrdef _ address=_ t ('0.0.0' )；
constUSHORTPORT=9700；
类服务器
{
公共：
服务器(；
~Server (；
HP_TcpPullServerm_pServer； //创建服务器
HP _ tcppullserverlistenerm _ p listener； //侦听器
私有：
//回调函数
static en _ HP _ handle result _ _ stdcallonpreparelisten (HP _ serverpsender，SOCKETsoListen )；
static en _ HP _ handle result _ _ stdcallonaccept (HP _ serverpsender，HP_CONNIDdwConnID，SOCKETsoClient )；
static en _ HP _ handle result _ _ stdcallonsend (HP _ serverpsender，HP_CONNIDdwConnID，constBYTE*pData，intiLength
static en _ HP _ handle result _ _ stdcall onreceive (HP _ serverpsender，HP_CONNIDdwConnID，intiLength )；
static en _ HP _ handle result _ _ stdcall onclose (HP _ serverpsender，HP_CONNIDdwConnID，en _ HP _ socketopetoperatione
static en _ HP _ handle result _ _ stdcallonshutdown (HP _ serverpsender )；
公共：
VOIDStartServer (；
VOIDStopServer (；
私有：
staticBOOLm_ServerStat；
(；
. CPP文件#include'stdafx.h '
#include'Server.h '
boolserver :3360 m _ serverstat=false；
服务器：服务器()
{
//创建侦听器对象
m _ p listener=:3360 create _ HP _ tcppullserverlistener (；
//创建套接字对象
m _ pserver=:3360 create _ HP _ tcppullserver (m _ p listener )；
//设置套接字侦听器的回调函数
:3360 HP _ set _ fn _ server _ onpreparelisten (m _ p listener，onpreparelisten )；
:3360 HP _ set _ fn _ server _ onaccept (m _ p listener，onaccept )；
:3360 HP _ set _ fn _ server _ onsend (m _ p listener，onsend )；
:3360 HP _ set _ fn _ server _ onpullreceive (m _ p listener，OnReceive )；
:3360 HP _ set _ fn _ server _ onclose (m _ p listener，onclose )；
:3360 HP _ set _ fn _ server _ onshutdown (m _ p listener，ons hutdown )；
}
server :至server (
{
//放弃套接字对象
: destroy _ HP _ tcppullserver (m _ pserver；
//放弃侦听器对象
: destroy _ HP _ tcppullserverlistener (m _ p listener )；
}
en _ HP _ handleresultserver :3360 onpreparelisten (HP _ serverpsender，SOCKETsoListen ) ) )。
{
setlocale(LC_all，
"chs");TCHAR szAddress[50];
int iAddressLen = sizeof(szAddress) / sizeof(TCHAR);
USHORT usPort;
::HP_Server_GetListenAddress(pSender, szAddress, &iAddressLen, &usPort);
return HR_OK;
}
En_HP_HandleResult Server::OnAccept(HP_Server pSender, HP_CONNID dwConnID, SOCKET soClient)
{
BOOL bPass = TRUE;
TCHAR szAddress[50];
int iAddressLen = sizeof(szAddress) / sizeof(TCHAR);
USHORT usPort;
::HP_Server_GetRemoteAddress(pSender, dwConnID, szAddress, &iAddressLen, &usPort);
USES_CONVERSION;
char buff[255] = {};
sprintf_s(buff,255,"地址%s:%ld", W2A(szAddress), usPort);
return HR_OK;
}
En_HP_HandleResult Server::OnSend(HP_Server pSender, HP_CONNID dwConnID, const BYTE* pData, int iLength)
{
return HR_OK;
}
En_HP_HandleResult Server::OnReceive(HP_Server pSender, HP_CONNID dwConnID, int iLength)
{
return HR_OK;
}
En_HP_HandleResult Server::OnClose(HP_Server pSender, HP_CONNID dwConnID, En_HP_SocketOperation enOperation, int iErrorCode)
{
return HR_OK;
}
En_HP_HandleResult Server::OnShutdown(HP_Server pSender)
{
return HR_OK;
}
VOID Server::StartServer()
{//启动服务器
USES_CONVERSION;
if (!::HP_Server_Start(m_pServer, DEF_ADDRESS, PORT))
{
m_ServerStat = FALSE;
printf("服务器启动出错:%d,%s", ::HP_Server_GetLastError(m_pServer), W2A(::HP_Server_GetLastErrorDesc(m_pServer)));
}
else
{
m_ServerStat = TRUE;
}
}
VOID Server::StopServer()
{//停止服务器
::HP_Server_Stop(m_pServer);
m_ServerStat = FALSE;
}
客户端：CHpClientDlg::CHpClientDlg(CWnd* pParent /*=NULL*/)
: CDialogEx(IDD_HPCLIENT_DIALOG, pParent)
{//初始化
m_hIcon = AfxGetApp()->LoadIcon(IDR_MAINFRAME);
// 创建监听器对象
m_pListener = ::Create_HP_TcpPullClientListener();
// 创建 Socket 对象
m_pClient = ::Create_HP_TcpPullClient(m_pListener);
// 设置 Socket 监听器回调函数
::HP_Set_FN_Client_OnConnect(m_pListener, OnConnect);
::HP_Set_FN_Client_OnSend(m_pListener, OnSend);
::HP_Set_FN_Client_OnPullReceive(m_pListener, OnReceive);
::HP_Set_FN_Client_OnClose(m_pListener, OnClose);
}
连接服务器：void CHpClientDlg::OnBnClickedButton2()
{
if (::HP_Client_Start(m_pClient, DEFAULT_ADDRESS, DEFAULT_PORT, true))
{
m_edShow->SetSel(-1, -1); //插入光标放于最后
m_edShow->ReplaceSel(_T("连接成功!"));
m_edShow->ScrollWindow(0, 0); //滚动到插入点
}
else
{
CString str;
str.Format(_T("%d,%s"), ::HP_Client_GetLastError(m_pClient), HP_Client_GetLastErrorDesc(m_pClient));
m_edShow->SetSel(-1, -1); //插入光标放于最后
m_edShow->ReplaceSel(str);
m_edShow->ScrollWindow(0, 0); //滚动到插入点
}
}
准备回调函数(固定写法)：En_HP_HandleResult CHpClientDlg::OnConnect(HP_Client pSender, HP_CONNID dwConnID)
{
TCHAR szAddress[50];
int iAddressLen = sizeof(szAddress) / sizeof(TCHAR);
USHORT usPort;
::HP_Client_GetLocalAddress(pSender, szAddress, &iAddressLen, &usPort);
return HR_OK;
}
En_HP_HandleResult CHpClientDlg::OnSend(HP_Client pSender, HP_CONNID dwConnID, const BYTE* pData, int iLength)
{
return HR_OK;
}
En_HP_HandleResult CHpClientDlg::OnReceive(HP_Client pSender, HP_CONNID dwConnID, int iLength)
{
byte buffer[1000]{ 0 };
En_HP_FetchResult result = ::HP_TcpPullClient_Fetch(pSender, buffer, 1000);
return HR_OK;
}
En_HP_HandleResult CHpClientDlg::OnClose(HP_Client pSender, HP_CONNID dwConnID, En_HP_SocketOperation enOperation, int iErrorCode)
{
return HR_OK;
}
发送数据：void CHpClientDlg::OnBnClickedButton1()
{//发送数据
CString strSend;
m_edSend->GetWindowText(strSend);
USES_CONVERSION;
char * p = W2A(strSend);
if (::HP_Client_Send(m_pClient, (BYTE*)p, strlen(p)+1))
{
CString strinfo;
strinfo.Format(_T("%d-%s"), ::HP_Client_GetConnectionID(m_pClient), strSend);
m_edShow->SetSel(-1, -1); //插入光标放于最后
m_edShow->ReplaceSel(_T("rn发送成功!"));
m_edShow->ScrollWindow(0, 0); //滚动到插入点
}
else
;//::LogSendFail(::HP_Client_GetConnectionID(m_pClient), ::SYS_GetLastError(), ::HP_GetSocketErrorDesc(SE_DATA_SEND));
}
关闭连接：void CHpClientDlg::OnBnClickedButton3()
{
if (::HP_Client_Stop(m_pClient))
;//记录客户端(::HP_Client_GetConnectionID(m_pClient));
else
ASSERT(FALSE);
}
另外补充两点如下:
(1)服务器端的Create_HP_TcpPullServer函数返的对象,与各事件的pSender是同一对象，很多辅助函数里会用到。如服务器端主端给客户端发数据：HP_Server_Send(pSender,dwConnID,"#",1);其中pSender就是Create_HP_TcpPullServer的返回值
(2)有的辅助函数如：SYS_SSO_NoDelay的第一个参数为SOCKET，这个参数就是OnPrepareListen事件中的第二个参数soListen