HP-Socket 是一套通用的高性能 Windows Socket 组件,提供服务端组件(IOCP 模型)和客户端组件(Event Select 模型),广泛适用于 Windows 平台的 TCP/UDP 通信系统。HP-Socket 对通信层实现完全封装,上层应用不必关注通信层的任何细节;HP-Socket 提供基于事件通知模型的 API 接口,能非常简单高效地整合到各类应用程序中;另外,为了让大家能更方便的学习 HP-Socket,特此精心制作了功能测试示例(Test Echo)、性能测试示例(Test Echo-PFM)、PULL 模型测试示例(Test Echo-Pull) 和 UDP 测试示例(Test Echo-UDP),用户可以通过这几个测试示例入手,迅速掌握组件的设计思想和使用方法。
----------------------------------------------------------------
通用性
- 通信组件的唯一职责就是接受和发送字节流,绝对不能参与上层协议解析等工作;
- 与上层使用者解耦、互不依赖,组件与使用者通过操作接口和监听器接口进行交互,组件实现操作接口为上层提供操作方法;使用者实现监听器接口把自己注册为组件的 Listener,接收组件通知。因此,任何使用者只要实现了监听器接口都可以使用组件;另一方面,甚至可以自己重新写一个实现方式完全不同的组件实现给使用者调用,只要该组件遵从组件的操作接口,这也是 DIP 设计原则的体现。
可用性
可用性对所有通用组件都是至关重要的,如果太难用还不如自己重头写一个来得方便。因此,组件的操作接口和监听器接口设计得尽量简单易用(通俗来说就是“傻瓜化”),这两个接口的主要方法均不超过 5 个。另外,组件完全封装了所有的底层 Socket 通信,上层应用看不到任何通信细节,不必也不能干预任何通信操作,Socket 连接被抽象为 Connection ID,该参数作为连接标识提供给上层应用识别不同的连接。
高性能
作为底层的通用组件,性能问题是必须考虑的,绝对不能成为系统的瓶颈。而另一方面,从实际出发,根据客户端组件与服务端组件的性能要求采用不同的 Socket 模型。组件在设计上充分考虑了性能、现实使用情景、可用性和实现复杂性等因素,确保满足性能要求的同时又不会写得太复杂。做出以下两点设计决策:
- 客户端:在单独线程中实现 Socket 通信交互。这样可以避免与主线程或其他线程相互干扰;I/O 模型选择 Event Select 通信模型。
- 服务端:采用 Windows 平台效率最高的 IOCP 通信模型;利用缓存池技术,在通信的过程中,通常需要频繁的申请和释放内存缓冲区,建立了动态缓存池, 只有当缓存池中没有可用对象时才创建新对象,而当缓存对象过多时则会压缩缓存池;另外,组件的动态内存通过私有堆(Private Heap)机制分配,避免与 new / malloc 竞争同时又减少内存空洞。
伸缩性
可以根据实际的使用环境要求设置组件的各项性能参数(如:工作线程的数量、各种缓存池的大小、收发缓冲区的大小、Socket 监听队列的大小、Accep 派发的数目以及心跳检查的间隔等)。
(项目主页:点击这里,下载地址:点击这里)
*** v3.1.3 更新 ***
> 增加其它语言 Demo:
-----------------
- C#
- Delphi
- E 语言
> Bug Fix:
-----------------
-
修复 IP 地址判断错误 Bug
1) 客户端连接服务器时,如果服务器 IP 地址满位(12个数字:‘AAA.BBB.CCC.DDD’),IP 地址解析错误
2) 影响组件:所有 TCP/UDP 客户端组件
3) 影响版本:v3.1.2 及之前所有版本
-
修复域名或主机名的 IP 地址解析错误 Bug
1) 客户端组件通过域名或主机名连接服务器时,可能会解析到错误的 IP 地址
2) 影响组件:所有 TCP/UDP 客户端组件
3) 影响版本:v3.1.2 及之前所有版本
> 升级说明:
-----------------
- 使用 HP-Socket v3.1.2 及以前版本的应用程序可以安全升级到 HP-Socket v3.1.3
*** v3.1.2 更新 ***
> 修改 Server 组件的 OnClose() / OnError() 事件的触发规则:
-----------------
- 以前版本的 TCP/UDP Server 组件中,当关闭一个连接时可能会同时触发一个 OnClose() 事件和若干个 OnError() 事件
- 由于存在上述可能性,所以应用程序需要对 OnClose() / OnError() 的处理事件代码段进行同步
- 从 v3.1.2 开始,当多个 OnClose() / OnError() 事件同时发生时,组件只会向应用程序通知第一个事件,后续事件则忽略
- 因此,应用程序在处理 OnClose() / OnError() 事件时不必处理同步,减少了出错的可能和编写同步及检测代码的负担
-
示例代码
/* 示例代码一:*/
/*----------------------------------------------------------------------------*/
ISocketListener::EnHandleResult CServerDlg::OnClose(CONNID dwConnID)
{
// 以前版本:有可能存在并发的 OnClose()/OnError(),要把代码放在临界区中并检测返回值
CCriSecLock locallock(m_csPkgInfo); // <-- 临界区
PVOID pInfo = nullptr;
// <-- 检测返回值
if(m_Server->GetConnectionExtra(dwConnID, &pInfo) && pInfo != nullptr)
{
m_Server->SetConnectionExtra(dwConnID, nullptr);
delete pInfo;
}
}
/* 示例代码二:*/
/*----------------------------------------------------------------------------*/
ISocketListener::EnHandleResult CServerDlg::OnClose(CONNID dwConnID)
{
// v3.1.2 版本:只会接收到一个 OnClose()/OnError() 事件,能安全地移除临界区代码和检测代码
PVOID pInfo = nullptr;
m_Server->GetConnectionExtra(dwConnID, &pInfo);
ASSERT(pInfo != nullptr);
delete pInfo;
}
*** v3.1.1 更新 ***
> 增加导出纯 C 函数的动态链接库 HPSocket4C.dll:
-----------------
- 增加代码文件 HPSocket4C.h 和 HPSocket4C.cpp,用于创建 HPSocket4C.dll
- 导出纯 C 函数,让其它语言(如:C/C#/Delphi 等)能方便地使用 HPSocket
-
HPSocket4C.dll 使用方法
方法一:
------------------------------------------------------------------------------
(0) (C/C++ 程序)包含 HPSocket4C.h 头文件
(1) 调用 ::Create_HP_XxxListener() 函数创建监听器对象
(2) 调用 ::Create_HP_Xxx(pListener) 函数创建 HPSocket 对象
(3) 调用 ::HP_Set_FN_Xxx_OnYyy(pListener, ...) 函数设置监听器的回调函数
(4) 调用相关导出函数操作 HPSocket 对象
(5) ...... ......
(6) 调用 ::Destroy_HP_Xxx(pSocket) 函数销毁 HPSocket 对象
(7) 调用 ::Destroy_HP_XxxListener(pListener) 函数销毁监听器对象
方法二:
------------------------------------------------------------------------------
(1) 应用程序把需要用到的导出函数封装到特定语言的包装类中
(2) 通过包装类封装后,以面向对象的方式使用 HPSocket
-
动态链接库发行版本
(1) x86/HPSocket4C.dll - (32位/MBCS/Release)
(2) x86/HPSocket4C_D.dll - (32位/MBCS/DeBug)
(3) x86/HPSocket4C_U.dll - (32位/UNICODE/Release)
(4) x86/HPSocket4C_UD.dll - (32位/UNICODE/DeBug)
(5) x64/HPSocket4C.dll - (64位/MBCS/Release)
(6) x64/HPSocket4C_D.dll - (64位/MBCS/DeBug)
(7) x64/HPSocket4C_U.dll - (64位/UNICODE/Release)
(8) x64/HPSocket4C_UD.dll - (64位/UNICODE/DeBug)
> 全面启用 Buffer Pool 缓存机制:
-----------------
- Common/Src 增加代码文件 bufferpool.h 和 bufferpool.cpp,实现 Buffer Pool 缓存机制
- 通过 Buffer Pool 缓存机制提升内存使用效率,减少动态内存分配和释放操作,避免内存空洞
- ICTcpClient 用 CItemPool 和 TItemList 实现发送缓冲区
- CUdpClient 用 CItemPool 和 TItemList 实现发送缓冲区
- CTcpPullClient 用 CItemPool 和 TItemList 实现发送缓冲区和 PULL 缓冲区
- CTcpPullServer 用 CBufferPool 和 TBuffer 实现 PULL 缓冲区
*** v3.0.2 更新 ***
> 把 HP-Socket 编译为动态链接库:
-----------------
- 应用程序可以通过导入源代码或动态链接库方式使用 HP-Socket
- 动态链接库使用方法
方法一:
------------------------------------------------------------------------------
(0) 应用程序包含 SocketInterface.h 和 HPSocket.h 头文件
(1) 调用 HP_Create_Xxx() 函数创建 HPSocket 对象
(2) 使用完毕后调用 HP_Destroy_Xxx() 函数销毁 HPSocket 对象
方法二:
------------------------------------------------------------------------------
(0) 应用程序包含 SocketInterface.h 和 HPSocket.h 头文件
(1) 创建 CXxxWrapper 包装器,通过包装器智能指针使用 HPSocket 对象
- 动态链接库发行版本
(1) x86/HPSocket.dll - (32位/MBCS/Release)
(2) x86/HPSocket_D.dll - (32位/MBCS/DeBug)
(3) x86/HPSocket_U.dll - (32位/UNICODE/Release)
(4) x86/HPSocket_UD.dll - (32位/UNICODE/DeBug)
(5) x64/HPSocket.dll - (64位/MBCS/Release)
(6) x64/HPSocket_D.dll - (64位/MBCS/DeBug)
(7) x64/HPSocket_U.dll - (64位/UNICODE/Release)
(8) x64/HPSocket_UD.dll - (64位/UNICODE/DeBug)
*** v3.0.1 更新 ***
> 新增 UDP 通信组件:
-----------------
- 新增两个 UDP 通信组件:CUdpServer 为服务端组件,CUdpClient 为客户端组件
- 服务端组件 CUdpServer 采用 IOCP 通信模型
- 客户端组件 CUdpClient 采用 Event Select 通信模型
- UDP 通信组件的接口与原 TCP 通信组件一致,简单实用
- UDP 通信组件内置通信线路自动监测机制
- 新增 UDP 通信组件示例工程 TestEcho-UDP
> 代码重构与优化:
-----------------
- 规范所有接口、类以及代码文件的命名
- 重构和优化了大量组件代码
- 服务端组件加入读写锁机制,有效平衡处理性能与安全性
- 服务端组件的 Socket 对象缓存列表设置了锁定时间,提高访问的安全性
*** v2.2.3 更新 ***
> 连接 ID 的数据类型改为 ‘CONNID’:
-----------------
- 在SocketHelper.h 中定义 CONNID 数据类型(默认:typedef ULONG_PTR CONNID)
- 应用程序可以把 CONNID 定义为其希望的类型(如:ULONG / ULONGLONG 等)
- 为了便于移植与维护,应用程序的任何地方都应该用‘CONNID’类型引用连接 ID
> 服务端 Socket 组件支持为每个连接绑定附加数据:
-----------------
- IServerSocket 和 CIocpServer 增加方法 Get/SetConnectionExtra()
- 通过上述两个方法,应用程序可以为每个连接绑定任意附加数据并把数据获取出来
*** v2.2.2 更新 ***
> 优化心跳检测相关功能:
-----------------
- IServerSocket 和 IClientSocket 的 Get/SetKeepAliveTimes() 方法改为 Get/SetKeepAliveTime()
- CIocpServer 和 CClientSocket 的默认 KeepAliveTime 属性改为 5000
- CIocpServer 和 CClientSocket 的默认 KeepAliveInterval 属性改为 3000
*** v2.2.1 更新 ***
> PULL 模型支持:
-----------------
- ISocketListener 增加 PULL 模型数据接收通知方法 OnReceive(dwConnID, int)
- 增加 PULL Socket 接口 IPullSocket,该接口的 Fetch(dwConnID, pBuffer, iLength) 方法用于抓取通信数据
> Server:
-----------------
- 服务端 Socket 接口 ISocketServer 改名为 IServerSocket
- 增加 PULL Server Socket 监听器抽象类 CPullServerSocketListener
- 增加 PULL Server Socket 接口 IPullServerSocket
- 增加 PULL Server Socket 实现类 CIocpPullServer
> Client:
-----------------
- 客户端 Socket 接口 ISocketClient 改名为 IClientSocket
- 客户端 Socket 实现类 CSocketClient 改名为 CClientSocket
- 增加 PULL Client Socket 监听器抽象类 CPullClientSocketListener
- 增加 PULL Client Socket 接口 IPullClientSocket
- 增加 PULL Client Socket 实现类 CPullClientSocket
分享到:
相关推荐
hadoop-eclipse-plugin-3.1.3,eclipse版本为eclipse-jee-2020-03
固件V3.1.3是CP343-1的一个特定版本,它包含了对硬件功能的优化和软件错误的修复,以确保设备稳定运行和兼容最新的应用需求。 固件升级对于保持设备的最佳性能和安全性至关重要。6GK7343-1CX10-0XE0是CP343-1的型号...
3. 电子商务功能:CRMEB-DT-v3.1.3提供了完整的电商流程,包括商品发布、购物车、订单管理、支付接口集成(如支付宝、微信支付)、物流跟踪等。用户可以在平台上方便地浏览商品、下单购买,并通过多种支付方式进行...
【作品名称】:基于潘多拉board主控(RT-Thread-v3.1.3)、麦克纳姆全向轮底盘、遥控智能小车 【适用人群】:适用于希望学习不同技术领域的小白或进阶学习者。可作为毕设项目、课程设计、大作业、工程实训或初期项目...
这是后半部分,需要配合前半部分使用。 ESP32是一系列低成本,低功耗的单芯片微控制器,集成了Wi-Fi和双模蓝牙。 ESP32系列采用Tensilica Xtensa LX6微处理器,包括双核心和单核变体,内建天线开关,RF变换器,功率...
- **高性能**:ANTLR生成的解析器和词法分析器效率高,能够处理大规模的输入数据。 - **灵活性**:你可以定义复杂的语法规则,甚至可以实现上下文感知的解析。 - **错误处理**:ANTLR提供良好的错误报告和恢复机制,...
rt-thread-v3.1.3是一个高度可裁剪、高性能的实时操作系统(RTOS),专为嵌入式系统设计。该版本包含了丰富的内核功能,如任务管理、信号量、互斥锁、消息队列、内存管理等,同时提供了丰富的组件和中间件支持,如...
固件V3.1.3(6GK7343-1EX30-0XE0)是CP343-1的一个特定版本,旨在提高其性能、稳定性和安全性。 固件,或称软件固件,是嵌入在硬件设备中的程序,它控制设备的操作并提供与上层系统的接口。固件升级是保持设备最佳...
### 厂内物流调度控制系统RCS-2000 V3.1.3 对外任务接口文档_发布版 #### 协议概述 RCS-2000 V3.1.3 版本的厂内物流调度控制系统提供了一套全面的对外任务接口文档,该文档详细介绍了如何通过标准化的JSON格式接口...
Apache DolphinScheduler 是一个分布式易扩展的可视化DAG工作流任务调度开源系统。适用于企业级场景,提供了一个可视化操作任务、工作流和全生命周期数据处理过程的解决方案。 Apache DolphinScheduler 旨在解决...
在这个"apache-hadoop-3.1.3-winutils-master.zip"压缩包中,包含了在Windows环境下配置Hadoop HDFS客户端所需的组件,特别是`hadoop-winutils`和`hadoop.dll`这两个关键文件,它们对于在Windows系统上运行Hadoop...
Apache Hive(apache-hive-3.1.3-bin.tar.gz、apache-hive-3.1.3-src.tar.gz)是一种分布式容错数据仓库系统,支持大规模分析,并使用 SQL 促进读取、写入和管理驻留在分布式存储中的 PB 级数据。Hive 构建在 Apache...
该文档仓库包含了 OceanBase 的最新版本V3.1.3的全部技术文档,包括安装部署、配置管理、SQL语法、性能优化、故障排查等多个方面,旨在提供全方位的技术支持。通过这些文档,用户可以快速上手,掌握OceanBase的核心...
java-uuid-generator-3.1.3.jar 部分开源源代码用到这里面的类。
"apache-hive-3.1.3-bin.tar.gz" 是 Apache Hive 3.1.3 版本的二进制发行版,包含所有必要的文件和组件,让用户能够在本地或集群环境中安装和运行 Hive。 在这个压缩包中,`apache-hive-3.1.3-bin` 文件夹包含了...
mariadb-connector-odbc-3.1.3-win64.msi,mariadb的odbc驱动程序
根据提供的文件信息,以下是对《厂内物流调度控制系统RCS-2000 V3.1.3 对外任务接口文档》中的知识点的详细说明: 1. RCS-2000系统概述: RCS-2000是杭州海康机器人技术有限公司开发的厂内物流机器人控制系统,...
spring-webmvc-3.1.3.-sources.jar 源码
这个"spark-3.1.3-bin-without-hadoop.tgz"压缩包是Spark的3.1.3版本,不含Hadoop依赖的二进制发行版。这意味着在部署时,你需要自行配置Hadoop环境,或者在不依赖Hadoop的环境中运行Spark。 Spark的核心特性包括...
APICloud studio3是基于业界领先的代码编辑器-Vscode深度定制。无论开发者是开发Android、iOS、Web、App还是小程序, Studio3都能快速编译对应终端的代码。本资源试用windows系统。