编写P2P程序的可靠UDP详细使用源码

jian1210

UDPP可靠UDP传输，非常适合编写P2P应用
udpp0.13与接口例程.zip (73.97 KB, 下载次数: 72)

2022-3-28 02:35 上传

点击文件名下载附件
下载积分: 精币 -2 枚

BUG反馈、对UDP可靠传输算法、P2P通信感兴趣的朋友可以一起探讨，

  

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

窗口.标题 ＝ 窗口.标题 ＋ “ - SDK: ” ＋ UGetVersion ()
' 可以创建监听IPV4或者IPV6的套接字
集_ipv4套接字 ＝ UCreate ( #AF_INET, “0.0.0.0”, 8815)
' 集_ipv6套接字 ＝ UCreate (#AF_INET6, “::1”, 8815)
' 设置回调接口
USetCallback (到整数 (&回调子程序))

子程序名	返回值类型	公开	备 注
回调子程序	整数型		回调子程序参数结构不能改变
参数名	类 型	参考	可空	数组	备 注
参_事件类型	整数型
参_套接字	整数型
参_连接序号	整数型
参_数据指针	整数型
参_数据长度	整数型

变量名	类 型	静态	数组	备 注
局_addr	文本型
局_port	整数型
局_接收数据指针	整数型

' 注意：连接断开和连接失败事件下必须调用 UGetConnectINFO ，否则会出现内存泄露
判断 (参_事件类型 ＝ #回调事件_建立连接 )
集_连接句柄 ＝ 参_连接序号
局_addr ＝ UGetConnectINFO (参_套接字, 参_连接序号, 参_事件类型, 局_port)
调试输出 (“新连接建立”, 参_套接字, 参_连接序号, 局_addr, 局_port)
如果真 (参_数据长度 ＞ 0)
局_接收数据指针 ＝ 申请内存 (参_数据长度, 假)
UGetDATA (局_接收数据指针, 参_数据指针, 参_数据长度, 1)
欲发送数据.加入文本 (“连接携带数据：” ＋ 到文本 (_读字节集 (局_接收数据指针, 参_数据长度)) ＋ #换行符 )
释放内存 (局_接收数据指针)
返回 (0)
判断 (参_事件类型 ＝ #回调事件_连接断开 )
局_addr ＝ UGetConnectINFO (参_套接字, 参_连接序号, 参_事件类型, 局_port)
调试输出 (“有连接断开”, 参_套接字, 参_连接序号, 局_addr, 局_port)
返回 (0)
判断 (参_事件类型 ＝ #回调事件_连接失败 )
局_addr ＝ UGetConnectINFO (参_套接字, 参_连接序号, 参_事件类型, 局_port)
调试输出 (“连接失败”, 参_套接字, 参_连接序号, 局_addr, 局_port)
返回 (0)
判断 (参_事件类型 ＝ #回调事件_数据到达 )
局_接收数据指针 ＝ 申请内存 (参_数据长度, 假)
UGetDATA (局_接收数据指针, 参_数据指针, 参_数据长度, 0)
调试输出 (到文本 (_读字节集 (局_接收数据指针, 参_数据长度)))
欲发送数据.加入文本 (“DATA到达回调长度：” ＋ 到文本 (参_数据长度) ＋ #换行符 )
释放内存 (局_接收数据指针)
返回 (0)
判断 (参_事件类型 ＝ #回调事件_发送成功 )
' 异步操作下，需要在回调里释放自己申请的内存
释放内存 (参_数据指针)
调试输出 (参_套接字, 参_连接序号, 参_数据指针, “发送成功”)
返回 (0)
判断 (参_事件类型 ＝ #回调事件_发送失败 )
' 异步操作下，需要在回调里释放自己申请的内存
释放内存 (参_数据指针)
调试输出 (参_套接字, 参_连接序号, 参_数据指针, “发送失败”)
返回 (0)


返回 (0)

子程序名	返回值类型	公开	备 注
_按钮_连接_被单击

变量名	类 型	静态	数组	备 注
局_携带数据	文本型
局_数据指针	整数型
携带数据	文本型

' 写法1
局_携带数据 ＝ 连接携带内容.内容
' 阻塞，等待连接返回，成功返回连接序列，失败返回0
集_连接句柄 ＝ UConnect (集_ipv4套接字, 连接IP.内容, 到整数 (连接端口.内容), 0, 0, _取文本变量地址 (局_携带数据), 取文本长度 (局_携带数据), 1)
连接句柄.内容 ＝ 到文本 (集_连接句柄)
返回 ()
' 或者自己申请内存存放携带数据
局_携带数据 ＝ 连接携带内容.内容
局_数据指针 ＝ 申请内存 (取文本长度 (局_携带数据), 假)
Memcpy (局_数据指针, 指针_取文本变量地址 (携带数据), 取文本长度 (携带数据))
' 非阻塞，直接返回0，并在回调里反馈连接结果
UConnect (集_ipv4套接字, 连接IP.内容, 到整数 (连接端口.内容), 0, 0, 局_数据指针, 取文本长度 (局_携带数据), 0)
释放内存 (局_数据指针)

子程序名	返回值类型	公开	备 注
_按钮_断开连接_被单击

' 断开已经建立的连接
UDisconnect (集_ipv4套接字, 集_连接句柄)

子程序名	返回值类型	公开	备 注
_按钮_发送数据_被单击

变量名	类 型	静态	数组	备 注
局_数据	文本型
局_反馈	逻辑型
局_数据指针	整数型

局_数据 ＝ 取重复文本 (50, “1234567890qwertyuiop”)
局_数据指针 ＝ 申请内存 (取文本长度 (局_数据), 真)
Memcpy (局_数据指针, 指针_取文本变量地址 (局_数据), 取文本长度 (局_数据))
' 异步非阻塞写法
' 非阻塞，直接返回真，并在回调里反馈发送结果
USend (集_ipv4套接字, 集_连接句柄, 局_数据指针, 取文本长度 (局_数据), 0, 0)
返回 ()
' 阻塞写法
' 阻塞，发送成功返回真，失败返回假
USend (集_ipv4套接字, 集_连接句柄, 局_数据指针, 取文本长度 (局_数据), 0, 1)
释放内存 (局_数据指针)
返回 ()

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

UDestory (集_ipv4套接字)

i支持库列表	支持库注释
spec	特殊功能支持库

.版本 2<br /> .支持库 spec<br /> <br /> .子程序 _窗口_创建完毕<br /> <br /> 窗口.标题 ＝ 窗口.标题 ＋ “ - SDK: ” ＋ UGetVersion ()<br /> ' 可以创建监听IPV4或者IPV6的套接字<br /> 集_ipv4套接字 ＝ UCreate (#AF_INET, “0.0.0.0”, 8815)<br /> ' 集_ipv6套接字 ＝ UCreate (#AF_INET6, “::1”, 8815)<br /> <br /> ' 设置回调接口<br /> USetCallback (到整数 (&回调子程序))<br /> <br /> .子程序 回调子程序, 整数型, , 回调子程序参数结构不能改变<br /> .参数 参_事件类型, 整数型<br /> .参数 参_套接字, 整数型<br /> .参数 参_连接序号, 整数型<br /> .参数 参_数据指针, 整数型<br /> .参数 参_数据长度, 整数型<br /> .局部变量 局_addr, 文本型<br /> .局部变量 局_port, 整数型<br /> .局部变量 局_接收数据指针, 整数型<br /> <br /> ' 注意：连接断开和连接失败事件下必须调用 UGetConnectINFO ，否则会出现内存泄露<br /> .判断开始 (参_事件类型 ＝ #回调事件_建立连接)<br />     集_连接句柄 ＝ 参_连接序号<br />     局_addr ＝ UGetConnectINFO (参_套接字, 参_连接序号, 参_事件类型, 局_port)<br />     调试输出 (“新连接建立”, 参_套接字, 参_连接序号, 局_addr, 局_port)<br />     .如果真 (参_数据长度 ＞ 0)<br />         局_接收数据指针 ＝ 申请内存 (参_数据长度, 假)<br />         UGetDATA (局_接收数据指针, 参_数据指针, 参_数据长度, 1)<br />         欲发送数据.加入文本 (“连接携带数据：” ＋ 到文本 (_读字节集 (局_接收数据指针, 参_数据长度)) ＋ #换行符)<br />         释放内存 (局_接收数据指针)<br />     .如果真结束<br />     返回 (0)<br /> .判断 (参_事件类型 ＝ #回调事件_连接断开)<br />     局_addr ＝ UGetConnectINFO (参_套接字, 参_连接序号, 参_事件类型, 局_port)<br />     调试输出 (“有连接断开”, 参_套接字, 参_连接序号, 局_addr, 局_port)<br />     返回 (0)<br /> .判断 (参_事件类型 ＝ #回调事件_连接失败)<br />     局_addr ＝ UGetConnectINFO (参_套接字, 参_连接序号, 参_事件类型, 局_port)<br />     调试输出 (“连接失败”, 参_套接字, 参_连接序号, 局_addr, 局_port)<br />     返回 (0)<br /> .判断 (参_事件类型 ＝ #回调事件_数据到达)<br />     局_接收数据指针 ＝ 申请内存 (参_数据长度, 假)<br />     UGetDATA (局_接收数据指针, 参_数据指针, 参_数据长度, 0)<br />     调试输出 (到文本 (_读字节集 (局_接收数据指针, 参_数据长度)))<br />     欲发送数据.加入文本 (“DATA到达回调长度：” ＋ 到文本 (参_数据长度) ＋ #换行符)<br />     释放内存 (局_接收数据指针)<br />     返回 (0)<br /> .判断 (参_事件类型 ＝ #回调事件_发送成功)<br />     ' 异步操作下，需要在回调里释放自己申请的内存<br />     释放内存 (参_数据指针)<br />     调试输出 (参_套接字, 参_连接序号, 参_数据指针, “发送成功”)<br />     返回 (0)<br /> .判断 (参_事件类型 ＝ #回调事件_发送失败)<br />     ' 异步操作下，需要在回调里释放自己申请的内存<br />     释放内存 (参_数据指针)<br />     调试输出 (参_套接字, 参_连接序号, 参_数据指针, “发送失败”)<br />     返回 (0)<br /> .默认<br /> <br /> .判断结束<br /> 返回 (0)<br /> <br /> .子程序 _按钮_连接_被单击<br /> .局部变量 局_携带数据, 文本型<br /> .局部变量 局_数据指针, 整数型<br /> .局部变量 携带数据, 文本型<br /> <br /> ' 写法1<br /> 局_携带数据 ＝ 连接携带内容.内容<br /> ' 阻塞，等待连接返回，成功返回连接序列，失败返回0<br /> 集_连接句柄 ＝ UConnect (集_ipv4套接字, 连接IP.内容, 到整数 (连接端口.内容), 0, 0, _取文本变量地址 (局_携带数据), 取文本长度 (局_携带数据), 1)<br /> 连接句柄.内容 ＝ 到文本 (集_连接句柄)<br /> 返回 ()<br /> <br /> <br /> ' 或者自己申请内存存放携带数据<br /> 局_携带数据 ＝ 连接携带内容.内容<br /> 局_数据指针 ＝ 申请内存 (取文本长度 (局_携带数据), 假)<br /> Memcpy (局_数据指针, 指针_取文本变量地址 (携带数据), 取文本长度 (携带数据))<br /> ' 非阻塞，直接返回0，并在回调里反馈连接结果<br /> UConnect (集_ipv4套接字, 连接IP.内容, 到整数 (连接端口.内容), 0, 0, 局_数据指针, 取文本长度 (局_携带数据), 0)<br /> 释放内存 (局_数据指针)<br /> <br /> .子程序 _按钮_断开连接_被单击<br /> <br /> ' 断开已经建立的连接<br /> UDisconnect (集_ipv4套接字, 集_连接句柄)<br /> <br /> .子程序 _按钮_发送数据_被单击<br /> .局部变量 局_数据, 文本型<br /> .局部变量 局_反馈, 逻辑型<br /> .局部变量 局_数据指针, 整数型<br /> <br /> 局_数据 ＝ 取重复文本 (50, “1234567890qwertyuiop”)<br /> 局_数据指针 ＝ 申请内存 (取文本长度 (局_数据), 真)<br /> Memcpy (局_数据指针, 指针_取文本变量地址 (局_数据), 取文本长度 (局_数据))<br /> <br /> ' 异步非阻塞写法<br /> ' 非阻塞，直接返回真，并在回调里反馈发送结果<br /> USend (集_ipv4套接字, 集_连接句柄, 局_数据指针, 取文本长度 (局_数据), 0, 0)<br /> 返回 ()<br /> <br /> ' 阻塞写法<br /> ' 阻塞，发送成功返回真，失败返回假<br /> USend (集_ipv4套接字, 集_连接句柄, 局_数据指针, 取文本长度 (局_数据), 0, 1)<br /> 释放内存 (局_数据指针)<br /> 返回 ()<br /> <br /> <br /> .子程序 _窗口_将被销毁<br /> <br /> UDestory (集_ipv4套接字)

hao15312

6666666666666666666666666666

帅清

7777777777777777777

plsplspls

学习学习

uulive

可靠UDP

uulive

学习学习

yiwei125

真是太麻烦了 你应该写一个模块 内存加载dll   然后功能可以直接和网络数据报一样  那样就能直接替代了

alanwoo

支持开源~！感谢分享

xtavoxing

学习学习....

凉忆亦凉心

瞅瞅看