HPsock http服务器 内存上涨问题

美丽星空

哪位大佬能帮忙看看源码...
用的是 hpsock的中文支持库,
进行了,10万次的请求,内存会上涨到100MB左右

  

窗口程序集名	保 留	保 留	备 注
窗口程序集_启动窗口
变量名	类 型	数组	备 注
http	HTTP服务端
多线程	线程池组件
通讯句柄	整数型
a	整数型
b	整数型
许可	整数型

子程序名	返回值类型	公开	备 注
__启动窗口_创建完毕

许可 ＝ 创建进入许可证 ()
通讯句柄 ＝ http.创建监听环境 (假)
http.设置回调事件 (&请求头完成通知, &请求体报文通知, &完成解析通知, &解析错误通知, &开始解析, &请求行解析完成, &请求头通知, , , , , , , &监听回调事件, &客户进入回调事件, &握手成功回调事件, , , &客户关闭回调事件, &服务关闭回调事件)
http.启动 (通讯句柄, “0.0.0.0”, 12345)
多线程.启动线程池 (8, 16, 0, )

子程序名	返回值类型	公开	备 注
监听回调事件	整数型		1创建监听自动回调
参数名	类 型	参考	可空	数组	备 注
监听句柄	整数型
套接字监听句柄	整数型

调试输出 (“监听回调事件”)
返回 ( #事件通知_成功 )

子程序名	返回值类型	公开	备 注
客户进入回调事件	整数型		2给客户端连接创建一个附加数据的内存空间
参数名	类 型	参考	可空	数组	备 注
监听句柄	整数型
连接ID	整数型
客户套接字句柄	整数型				TCP:客户套接字句柄 UDP:地址结构指针

变量名	类 型	静态	数组	备 注
端口	整数型
pExtra	整数型
远程地址	文本型
pBuffer	数据指针操作

' http.取地址信息_远程 (监听句柄, 连接ID, 远程地址, 端口)
' 客户端连接创建一个附加数据的内存空间
pBuffer.new (, )
http.置附加数据 (监听句柄, 连接ID, pBuffer.GetThis ())
pBuffer.Free ()
返回 ( #事件通知_成功 )

子程序名	返回值类型	公开	备 注
握手成功回调事件	整数型		3
参数名	类 型	参考	可空	数组	备 注
监听句柄	整数型
连接ID	整数型

' 调试输出 (“握手成功回调事件”)
返回 ( #事件通知_成功 )

子程序名	返回值类型	公开	备 注
开始解析	整数型		4
参数名	类 型	参考	可空	数组	备 注
pSender	整数型
dwConnID	整数型

' LogMsg (“ > [” ＋ GetSenderName (pSender) ＋ “,#” ＋ 到文本 (dwConnID) ＋ “,OnMessageBegin]”)
' 调试输出 (“开始解析”)
返回 ( #事件通知_成功 )

子程序名	返回值类型	公开	备 注
请求行解析完成	整数型		5
参数名	类 型	参考	可空	数组	备 注
pSender	整数型
dwConnID	整数型
lpszMethod	文本型
lpszUrl	文本型

' LogMsg (“ > [” ＋ GetSenderName (pSender) ＋ “,#” ＋ 到文本 (dwConnID) ＋ “,OnMessageBegin] ->[” ＋ lpszMethod ＋ “/” ＋ 到文本 (http.取请求行URL域掩码 (pSender, dwConnID)) ＋ “]:” ＋ lpszUrl)
' 调试输出 (“请求行解析完成”)
返回 ( #事件通知_成功 )

子程序名	返回值类型	公开	备 注
解析错误通知	整数型
参数名	类 型	参考	可空	数组	备 注
pSender	整数型
dwConnID	整数型
iErrorCode	整数型
lpszErrorDesc	整数型

' LogMsg (“ > [” ＋ GetSenderName (pSender) ＋ “,#” ＋ 到文本 (dwConnID) ＋ “,OnParseError]”)
' 调试输出 (“解析错误通知”)
b ＝ b ＋ 1
标签2.标题 ＝ 到文本 (b)
返回 ( #事件通知_成功 )

子程序名	返回值类型	公开	备 注
请求头通知	整数型		6 运行了 8 次
参数名	类 型	参考	可空	数组	备 注
pSender	整数型
dwConnID	整数型
lpszName	文本型
lpszValue	文本型

' LogMsg (“ > [” ＋ GetSenderName (pSender) ＋ “,#” ＋ 到文本 (dwConnID) ＋ “,OnHeader] ->” ＋ lpszName ＋ “:” ＋ lpszValue)
' 调试输出 (“请求头通知”)
返回 ( #事件通知_成功 )

子程序名	返回值类型	公开	备 注
请求头完成通知	整数型		7
参数名	类 型	参考	可空	数组	备 注
pSender	整数型
dwConnID	整数型

' GetHeaderSummary (pSender, dwConnID, 真, 真)
' 调试输出 (“请求头完成通知”)
返回 ( #事件通知_成功 )

子程序名	返回值类型	公开	备 注
请求体报文通知	整数型		8重要,这里是获取数据如果为空,不允许下面代码
参数名	类 型	参考	可空	数组	备 注
pSender	整数型
dwConnID	整数型
pData	整数型
iLength	整数型

变量名	类 型	静态	数组	备 注
pE	整数型
pBuffer	数据指针操作

' 调试输出 (“请求体报文通知”)
如果真 (http.取附加数据 (pSender, dwConnID, pE))
' 调试输出 (“请求体报文通知获得真”)
如果真 (pE ≠ 0)
pBuffer.Attach (pE)
pBuffer.Cat_Ptr (pData, iLength)  ' 数据累加


' 调试输出 (“请求体报文通知获得假”)
返回 ( #事件通知_成功 )

子程序名	返回值类型	公开	备 注
完成解析通知	整数型		9调用多任务
参数名	类 型	参考	可空	数组	备 注
pSender	整数型
dwConnID	整数型

变量名	类 型	静态	数组	备 注
px	整数型

' 调试输出 (“完成解析通知”)
px ＝ 多线程.创建任务对象 (&任务处理, pSender, dwConnID, , , , , )
多线程.提交Socket任务 (px, )
返回 ( #事件通知_成功 )

子程序名	返回值类型	公开	备 注
任务处理
参数名	类 型	参考	可空	数组	备 注
rwzz	整数型

变量名	类 型	静态	数组	备 注
任务	线程池任务			转换
数据指针	整数型
pBuffer	数据指针操作
bin	字节集
发起对象	整数型
连接id	整数型

' 调试输出 (“这是多线程处理”)
任务.Attach (rwzz)
发起对象 ＝ 任务.GetSender ()
连接id ＝ 任务.GetConnID ()
http.取附加数据 (发起对象, 连接id, 数据指针)
pBuffer.Attach (数据指针)
bin ＝ 指针到字节集 (pBuffer.Ptr (), pBuffer.Size ())
pBuffer.Free ()
http.回复请求 (通讯句柄, 连接id, #HTTP状态_200, , , bin)
http.断开连接 (通讯句柄, 连接id, )
进入许可区 (许可)
a ＝ a ＋ 1
标签1.标题 ＝ 到文本 (a)
进入许可区 (许可)

子程序名	返回值类型	公开	备 注
客户关闭回调事件	整数型		10
参数名	类 型	参考	可空	数组	备 注
监听句柄	整数型
连接ID	整数型
操作类型	整数型
错误码	整数型

' 调试输出 (“客户关闭回调事件”)
返回 ( #事件通知_成功 )

子程序名	返回值类型	公开	备 注
服务关闭回调事件	整数型		服务关闭才触发
参数名	类 型	参考	可空	数组	备 注
监听句柄	整数型

' 调试输出 (“服务关闭回调事件”)
返回 ( #事件通知_成功 )

子程序名	返回值类型	公开	备 注
__启动窗口_将被销毁

http.停止 (通讯句柄)
http.销毁监听环境 (通讯句柄, 假)

i支持库列表	支持库注释
HPSocket_E	(未知支持库)
EThread	多线程支持库
spec	特殊功能支持库

.版本 2<br /> .支持库 HPSocket_E<br /> .支持库 EThread<br /> .支持库 spec<br /> <br /> .程序集 窗口程序集_启动窗口<br /> .程序集变量 http, HTTP服务端<br /> .程序集变量 多线程, 线程池组件<br /> .程序集变量 通讯句柄, 整数型<br /> .程序集变量 a, 整数型<br /> .程序集变量 b, 整数型<br /> .程序集变量 许可, 整数型<br /> <br /> .子程序 __启动窗口_创建完毕<br /> <br /> 许可 ＝ 创建进入许可证 ()<br /> 通讯句柄 ＝ http.创建监听环境 (假)<br /> http.设置回调事件 (&请求头完成通知, &请求体报文通知, &完成解析通知, &解析错误通知, &开始解析, &请求行解析完成, &请求头通知, , , , , , , &监听回调事件, &客户进入回调事件, &握手成功回调事件, , , &客户关闭回调事件, &服务关闭回调事件)<br /> <br /> http.启动 (通讯句柄, “0.0.0.0”, 12345)<br /> 多线程.启动线程池 (8, 16, 0, )<br /> <br /> <br /> .子程序 监听回调事件, 整数型, , 1创建监听自动回调<br /> .参数 监听句柄, 整数型<br /> .参数 套接字监听句柄, 整数型<br /> <br /> 调试输出 (“监听回调事件”)<br /> 返回 (#事件通知_成功)<br /> <br /> .子程序 客户进入回调事件, 整数型, , 2给客户端连接创建一个附加数据的内存空间<br /> .参数 监听句柄, 整数型<br /> .参数 连接ID, 整数型<br /> .参数 客户套接字句柄, 整数型, , TCP:客户套接字句柄 UDP:地址结构指针<br /> .局部变量 端口, 整数型<br /> .局部变量 pExtra, 整数型<br /> .局部变量 远程地址, 文本型<br /> .局部变量 pBuffer, 数据指针操作<br /> <br /> <br /> ' http.取地址信息_远程 (监听句柄, 连接ID, 远程地址, 端口)<br /> <br /> ' 客户端连接创建一个附加数据的内存空间<br /> pBuffer.new (, )<br /> http.置附加数据 (监听句柄, 连接ID, pBuffer.GetThis ())<br /> pBuffer.Free ()<br /> <br /> 返回 (#事件通知_成功)<br /> <br /> .子程序 握手成功回调事件, 整数型, , 3<br /> .参数 监听句柄, 整数型<br /> .参数 连接ID, 整数型<br /> <br /> ' 调试输出 (“握手成功回调事件”)<br /> 返回 (#事件通知_成功)<br /> <br /> .子程序 开始解析, 整数型, , 4<br /> .参数 pSender, 整数型<br /> .参数 dwConnID, 整数型<br /> <br /> ' LogMsg (“ > [” ＋ GetSenderName (pSender) ＋ “,#” ＋ 到文本 (dwConnID) ＋ “,OnMessageBegin]”)<br /> ' 调试输出 (“开始解析”)<br /> 返回 (#事件通知_成功)<br /> <br /> .子程序 请求行解析完成, 整数型, , 5<br /> .参数 pSender, 整数型<br /> .参数 dwConnID, 整数型<br /> .参数 lpszMethod, 文本型<br /> .参数 lpszUrl, 文本型<br /> <br /> ' LogMsg (“ > [” ＋ GetSenderName (pSender) ＋ “,#” ＋ 到文本 (dwConnID) ＋ “,OnMessageBegin] ->[” ＋ lpszMethod ＋ “/” ＋ 到文本 (http.取请求行URL域掩码 (pSender, dwConnID)) ＋ “]:” ＋ lpszUrl)<br /> ' 调试输出 (“请求行解析完成”)<br /> 返回 (#事件通知_成功)<br /> <br /> .子程序 解析错误通知, 整数型<br /> .参数 pSender, 整数型<br /> .参数 dwConnID, 整数型<br /> .参数 iErrorCode, 整数型<br /> .参数 lpszErrorDesc, 整数型<br /> <br /> ' LogMsg (“ > [” ＋ GetSenderName (pSender) ＋ “,#” ＋ 到文本 (dwConnID) ＋ “,OnParseError]”)<br /> ' 调试输出 (“解析错误通知”)<br /> b ＝ b ＋ 1<br /> 标签2.标题 ＝ 到文本 (b)<br /> <br /> 返回 (#事件通知_成功)<br /> <br /> .子程序 请求头通知, 整数型, , 6 运行了 8 次<br /> .参数 pSender, 整数型<br /> .参数 dwConnID, 整数型<br /> .参数 lpszName, 文本型<br /> .参数 lpszValue, 文本型<br /> <br /> ' LogMsg (“ > [” ＋ GetSenderName (pSender) ＋ “,#” ＋ 到文本 (dwConnID) ＋ “,OnHeader] ->” ＋ lpszName ＋ “:” ＋ lpszValue)<br /> ' 调试输出 (“请求头通知”)<br /> 返回 (#事件通知_成功)<br /> <br /> .子程序 请求头完成通知, 整数型, , 7<br /> .参数 pSender, 整数型<br /> .参数 dwConnID, 整数型<br /> <br /> ' GetHeaderSummary (pSender, dwConnID, 真, 真)<br /> ' 调试输出 (“请求头完成通知”)<br /> 返回 (#事件通知_成功)<br /> <br /> .子程序 请求体报文通知, 整数型, , 8重要,这里是获取数据如果为空,不允许下面代码<br /> .参数 pSender, 整数型<br /> .参数 dwConnID, 整数型<br /> .参数 pData, 整数型<br /> .参数 iLength, 整数型<br /> .局部变量 pE, 整数型<br /> .局部变量 pBuffer, 数据指针操作<br /> <br /> ' 调试输出 (“请求体报文通知”)<br /> <br /> .如果真 (http.取附加数据 (pSender, dwConnID, pE))<br />     ' 调试输出 (“请求体报文通知获得真”)<br />     .如果真 (pE ≠ 0)<br />         pBuffer.Attach (pE)<br />         pBuffer.Cat_Ptr (pData, iLength)  ' 数据累加<br /> <br /> <br />     .如果真结束<br /> <br /> <br /> .如果真结束<br /> <br /> ' 调试输出 (“请求体报文通知获得假”)<br /> 返回 (#事件通知_成功)<br /> <br /> .子程序 完成解析通知, 整数型, , 9调用多任务<br /> .参数 pSender, 整数型<br /> .参数 dwConnID, 整数型<br /> .局部变量 px, 整数型<br /> <br /> ' 调试输出 (“完成解析通知”)<br /> px ＝ 多线程.创建任务对象 (&任务处理, pSender, dwConnID, , , , , )<br /> 多线程.提交Socket任务 (px, )<br /> <br /> 返回 (#事件通知_成功)<br /> <br /> .子程序 任务处理<br /> .参数 rwzz, 整数型<br /> .局部变量 任务, 线程池任务, , , 转换<br /> .局部变量 数据指针, 整数型<br /> .局部变量 pBuffer, 数据指针操作<br /> .局部变量 bin, 字节集<br /> .局部变量 发起对象, 整数型<br /> .局部变量 连接id, 整数型<br /> <br /> ' 调试输出 (“这是多线程处理”)<br /> 任务.Attach (rwzz)<br /> <br /> 发起对象 ＝ 任务.GetSender ()<br /> 连接id ＝ 任务.GetConnID ()<br /> <br /> http.取附加数据 (发起对象, 连接id, 数据指针)<br /> <br /> pBuffer.Attach (数据指针)<br /> bin ＝ 指针到字节集 (pBuffer.Ptr (), pBuffer.Size ())<br /> pBuffer.Free ()<br /> <br /> http.回复请求 (通讯句柄, 连接id, #HTTP状态_200, , , bin)<br /> http.断开连接 (通讯句柄, 连接id, )<br /> <br /> <br /> 进入许可区 (许可)<br /> a ＝ a ＋ 1<br /> 标签1.标题 ＝ 到文本 (a)<br /> 进入许可区 (许可)<br /> <br /> <br /> .子程序 客户关闭回调事件, 整数型, , 10<br /> .参数 监听句柄, 整数型<br /> .参数 连接ID, 整数型<br /> .参数 操作类型, 整数型<br /> .参数 错误码, 整数型<br /> <br /> ' 调试输出 (“客户关闭回调事件”)<br /> 返回 (#事件通知_成功)<br /> <br /> .子程序 服务关闭回调事件, 整数型, , 服务关闭才触发<br /> .参数 监听句柄, 整数型<br /> <br /> ' 调试输出 (“服务关闭回调事件”)<br /> 返回 (#事件通知_成功)<br /> <br /> .子程序 __启动窗口_将被销毁<br /> <br /> http.停止 (通讯句柄)<br /> http.销毁监听环境 (通讯句柄, 假)

影知

任务处理 这个子程序，在有可能出现问题的地方 提前加 返回()，保证每次都完整结束线程

美丽星空

影知 发表于 2021-8-20 16:28
任务处理 这个子程序，在有可能出现问题的地方 提前加 返回()，保证每次都完整结束线程 ...

试了一下 还是一样  转换线程池任务  的没有释放的  不知道是不是这个问题

影知

美丽星空 发表于 2021-8-20 16:58
试了一下 还是一样  转换线程池任务  的没有释放的  不知道是不是这个问题 ...

一个个试试吧，易语言没有像JAVA一样的自动处理机制。。

美丽星空

影知 发表于 2021-8-20 16:59
一个个试试吧，易语言没有像JAVA一样的自动处理机制。。

找到问题了  ,,,是断开连接引起的,,,删除命令后正常了...