2023-12-25 09:30:22 +08:00
|
|
|
|
![HP-Socket](Doc/HP-Socket%20Logo.png "HP-Socket")
|
2020-05-08 18:06:50 +08:00
|
|
|
|
---
|
|
|
|
|
*高性能跨平台网络通信框架*
|
|
|
|
|
## 描述
|
|
|
|
|
- ***Server*** 基于IOCP / EPOLL通信模型,并结合缓存池、私有堆等技术实现高效内存管理,支持超大规模、高并发通信场景。
|
|
|
|
|
- ***Agent*** Agent组件实质上是Multi-Client组件,与Server组件采用相同的技术架构。一个Agent组件对象可同时建立和高效处理大规模Socket连接。
|
|
|
|
|
- ***Client*** 基于Event Select / POLL通信模型,每个组件对象创建一个通信线程并管理一个Socket连接,适用于小规模客户端场景。
|
|
|
|
|
## 文档
|
|
|
|
|
- HP-Socket开发指南
|
2023-12-25 09:30:22 +08:00
|
|
|
|
[[pdf]](Doc/HP-Socket%20Development%20Guide.pdf)
|
2020-05-08 18:06:50 +08:00
|
|
|
|
- HP-Socket基础组件类图
|
2023-12-25 09:30:22 +08:00
|
|
|
|
[[uml]](Doc/HP-Socket%20Class%20Diagram.uml)
|
2020-05-08 18:06:50 +08:00
|
|
|
|
- HP-Socket基础组件类图
|
2023-12-25 09:30:22 +08:00
|
|
|
|
[[jpg]](Doc/HP-Socket%20Class%20Diagram.jpg)
|
2020-05-08 18:06:50 +08:00
|
|
|
|
- HP-Socket SSL组件类图组件
|
2023-12-25 09:30:22 +08:00
|
|
|
|
[[jpg]](Doc/HP-Socket%20SSL%20Class%20Diagram.jpg)
|
2020-05-08 18:06:50 +08:00
|
|
|
|
- HP-Socket HTTP组件类图
|
2023-12-25 09:30:22 +08:00
|
|
|
|
[[jpg]](Doc/HP-Socket%20HTTP%20Class%20Diagram.jpg)
|
2020-05-08 18:06:50 +08:00
|
|
|
|
## 工作流程
|
|
|
|
|
1. 创建监听器
|
|
|
|
|
2. 创建通信组件(同时绑定监听器)
|
|
|
|
|
3. 启动通信组件
|
|
|
|
|
4. 连接到目标主机(*Agent*组件)
|
|
|
|
|
5. 处理通信事件(*OnConnect/OnReceive/OnClose*等)
|
|
|
|
|
6. 停止通信组件(可选:在第7步销毁通信组件时会自动停止组件)
|
|
|
|
|
7. 销毁通信组件
|
|
|
|
|
8. 销毁监听器
|
|
|
|
|
|
2023-12-25 09:30:22 +08:00
|
|
|
|
![Agent工作流程](Doc/HP-Socket-Agent-Demo.jpg "Agent工作流程")
|
2020-05-08 18:06:50 +08:00
|
|
|
|
## 示例
|
|
|
|
|
- ***C++示例***
|
|
|
|
|
|
|
|
|
|
``` C++
|
|
|
|
|
#include <hpsocket/HPSocket.h>
|
|
|
|
|
|
|
|
|
|
/* Listener Class */
|
|
|
|
|
class CListenerImpl : public CTcpPullServerListener
|
|
|
|
|
{
|
|
|
|
|
|
|
|
|
|
public:
|
|
|
|
|
// 5. process network events
|
|
|
|
|
virtual EnHandleResult OnPrepareListen(ITcpServer* pSender, SOCKET soListen);
|
|
|
|
|
virtual EnHandleResult OnAccept(ITcpServer* pSender, CONNID dwConnID, UINT_PTR soClient);
|
|
|
|
|
virtual EnHandleResult OnHandShake(ITcpServer* pSender, CONNID dwConnID);
|
|
|
|
|
virtual EnHandleResult OnReceive(ITcpServer* pSender, CONNID dwConnID, int iLength);
|
|
|
|
|
virtual EnHandleResult OnSend(ITcpServer* pSender, CONNID dwConnID, const BYTE* pData, int iLength);
|
|
|
|
|
virtual EnHandleResult OnClose(ITcpServer* pSender, CONNID dwConnID, EnSocketOperation enOperation, int iErrorCode);
|
|
|
|
|
virtual EnHandleResult OnShutdown(ITcpServer* pSender);
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
int main(int argc, char* const argv[])
|
|
|
|
|
{
|
|
|
|
|
// 1. Create listener object
|
|
|
|
|
CListenerImpl s_listener;
|
|
|
|
|
// 2. Create component object (and binding with listener object)
|
|
|
|
|
CTcpPullServerPtr s_pserver(&s_listener);
|
|
|
|
|
|
|
|
|
|
// 3. Start component object
|
|
|
|
|
if(!s_pserver->Start("0.0.0.0", 5555))
|
|
|
|
|
exit(1);
|
|
|
|
|
|
|
|
|
|
/* wait for exit */
|
|
|
|
|
// ... ...
|
|
|
|
|
|
|
|
|
|
// 6. (optional) Stop component object
|
|
|
|
|
s_pserver->Stop();
|
|
|
|
|
|
|
|
|
|
return 0;
|
|
|
|
|
|
|
|
|
|
// 7. Destroy component object automatically
|
|
|
|
|
// 8. Destroy listener object automatically
|
|
|
|
|
}
|
|
|
|
|
```
|
|
|
|
|
|
|
|
|
|
- ***C示例***
|
|
|
|
|
|
|
|
|
|
``` C
|
|
|
|
|
#include <hpsocket/HPSocket4C.h>
|
|
|
|
|
|
|
|
|
|
// 5. process network events
|
|
|
|
|
EnHandleResult __HP_CALL OnConnect(HP_Agent pSender, HP_CONNID dwConnID);
|
|
|
|
|
EnHandleResult __HP_CALL OnReceive(HP_Agent pSender, HP_CONNID dwConnID, int iLength);
|
|
|
|
|
EnHandleResult __HP_CALL OnSend(HP_Agent pSender, HP_CONNID dwConnID, const BYTE* pData, int iLength);
|
|
|
|
|
EnHandleResult __HP_CALL OnClose(HP_Agent pSender, HP_CONNID dwConnID, En_HP_SocketOperation enOperation, int iErrorCode);
|
|
|
|
|
EnHandleResult __HP_CALL OnShutdown(HP_Agent pSender);
|
|
|
|
|
|
|
|
|
|
int main(int argc, char* const argv[])
|
|
|
|
|
{
|
|
|
|
|
HP_TcpPullAgentListener s_listener;
|
|
|
|
|
HP_TcpPullAgent s_agent;
|
|
|
|
|
|
|
|
|
|
// 1. Create listener object
|
2020-11-21 17:11:39 +08:00
|
|
|
|
s_listener = ::Create_HP_TcpPullAgentListener();
|
2020-05-08 18:06:50 +08:00
|
|
|
|
// 2. Create component object (and binding with listener object)
|
2020-11-21 17:11:39 +08:00
|
|
|
|
s_agent = ::Create_HP_TcpPullAgent(s_listener);
|
2020-05-08 18:06:50 +08:00
|
|
|
|
|
|
|
|
|
/* Set listener callbacks */
|
|
|
|
|
::HP_Set_FN_Agent_OnConnect(s_listener, OnConnect);
|
|
|
|
|
::HP_Set_FN_Agent_OnSend(s_listener, OnSend);
|
|
|
|
|
::HP_Set_FN_Agent_OnPullReceive(s_listener, OnReceive);
|
|
|
|
|
::HP_Set_FN_Agent_OnClose(s_listener, OnClose);
|
|
|
|
|
::HP_Set_FN_Agent_OnShutdown(s_listener, OnShutdown);
|
|
|
|
|
|
|
|
|
|
// 3. Start component object
|
2021-03-17 23:10:11 +08:00
|
|
|
|
if(!::HP_Agent_Start(s_agent, "0.0.0.0", TRUE))
|
2020-05-08 18:06:50 +08:00
|
|
|
|
exit(1);
|
|
|
|
|
|
|
|
|
|
// 4. Connect to dest host
|
2021-03-13 00:15:19 +08:00
|
|
|
|
::HP_Agent_Connect(s_agent, REMOTE_HOST_1, REMOTE_PORT_1, nullptr);
|
|
|
|
|
::HP_Agent_Connect(s_agent, REMOTE_HOST_2, REMOTE_PORT_2, nullptr);
|
|
|
|
|
::HP_Agent_Connect(s_agent, REMOTE_HOST_3, REMOTE_PORT_3, nullptr);
|
2020-05-08 18:06:50 +08:00
|
|
|
|
|
|
|
|
|
/* wait for exit */
|
|
|
|
|
// ... ...
|
|
|
|
|
|
|
|
|
|
// 6. (optional) Stop component object
|
|
|
|
|
::HP_Agent_Stop(s_agent);
|
|
|
|
|
|
|
|
|
|
// 7. Destroy component object
|
|
|
|
|
::Destroy_HP_TcpPullAgent(s_agent);
|
|
|
|
|
// 8. Destroy listener object
|
|
|
|
|
::Destroy_HP_TcpPullAgentListener(s_listener);
|
|
|
|
|
|
|
|
|
|
return 0;
|
|
|
|
|
}
|
|
|
|
|
```
|
|
|
|
|
|
|
|
|
|
## 组件列表
|
|
|
|
|
- ***基础组件***
|
|
|
|
|
|
2023-12-25 09:30:22 +08:00
|
|
|
|
![Basic Component](Doc/Basic%20Component%20-%20mini.jpg "基础组件")
|
2020-05-08 18:06:50 +08:00
|
|
|
|
|
|
|
|
|
- ***SSL组件***
|
|
|
|
|
|
2023-12-25 09:30:22 +08:00
|
|
|
|
![SSL Component](Doc/SSL%20Component%20-%20mini.jpg "SSL 组件")
|
2020-05-08 18:06:50 +08:00
|
|
|
|
|
|
|
|
|
- ***HTTP组件***
|
|
|
|
|
|
2024-08-06 00:15:28 +08:00
|
|
|
|
![HTTP Component](Doc/HTTP%20Component%20-%20mini.jpg "HTTP 组件")
|
2020-05-08 18:06:50 +08:00
|
|
|
|
|
|
|
|
|
## 引用项目
|
|
|
|
|
|
2021-01-15 15:36:09 +08:00
|
|
|
|
- *[mimalloc](https://github.com/microsoft/mimalloc)*
|
2020-05-08 18:06:50 +08:00
|
|
|
|
- *[jemalloc](https://github.com/jemalloc/jemalloc)*
|
|
|
|
|
- *[openssl](https://github.com/openssl/openssl)*
|
2021-01-15 15:36:09 +08:00
|
|
|
|
- *[llhttp](https://github.com/nodejs/llhttp)*
|
2020-05-08 18:06:50 +08:00
|
|
|
|
- *[zlib](https://github.com/madler/zlib)*
|
2020-11-21 17:11:39 +08:00
|
|
|
|
- *[brotli](https://github.com/google/brotli)*
|
2020-05-08 18:06:50 +08:00
|
|
|
|
- *[kcp](https://github.com/skywind3000/kcp)*
|
|
|
|
|
|
2021-08-12 21:50:04 +08:00
|
|
|
|
## 扩展项目
|
2020-05-08 18:06:50 +08:00
|
|
|
|
|
|
|
|
|
- *[HP-Socket for MacOS](https://gitee.com/xin_chong/HP-Socket-for-macOS)*
|
|
|
|
|
- *[HP-Socket for .Net](https://gitee.com/int2e/HPSocket.Net)*
|
|
|
|
|
|
2020-11-21 17:11:39 +08:00
|
|
|
|
## 技术交流
|
|
|
|
|
|
2022-11-28 01:05:15 +08:00
|
|
|
|
- *[怪兽乐园①群](https://jq.qq.com/?_wv=1027&k=3UAbrhTG)*
|
|
|
|
|
- *[怪兽乐园②群](https://jq.qq.com/?_wv=1027&k=uYBpc6bG)*
|