您现在的位置是:首页 > 文章详情

🎉 Socket.D v2.4.11(新增 python 实现)

日期:2024-04-24点击:233

Socket.D 协议?

Socket.D 是一个网络应用协议。在微服务、移动应用、物联网等场景,可替代 http、websocket 等。协议详情参考《官网介绍》

  • 支持: tcp, udp, ws, kcp 传输。

  • 目前:java,kotlin,javascript,node.js,python 语言环境可用。go,rust,c/c++,.net 正在开发中。

for Java 更新

  • 调整 本端会话关闭时,也触发本端的 onClose 事件
  • 优化 ws 连接控制,避免非法恶意空连
  • 优化 socketd-transport-java-kcp 服务端停止处理(添加延时,确保指令发送完成)
  • 优化 socketd-transport-java-tcp 在某些操作系统下空跑可能 cpu 过高的问题

for JavaScript/Node.js 更新

  • 调整 本端会话关闭时,也触发本端的 onClose 事件
  • 优化 ws 连接控制,避免非法恶意空连

for Python 首次发布

Helloworld 演示

  • Server
 async def main(): server = await (SocketD.create_server("sd:ws") .listen(EventListener() .do_on_open(lambda s: #会话打开时 log.info(s.session_id()) ).do_on_message(lambda s, m: #收到任意消息时(方便做统一的日志打印) log.info(m.data_as_string()) ).do_on("/demo", lambda s, m: #收到"/demo"事件的消息时。如果是请求或订阅?则进行签复 (m.is_request() or m.is_subscribe()) and s.reply_end(m, StringEntity("And you too.")) )).start()) 
  • Client
 async def main(): #打开客户端会话,并监听(用 url 形式打开) session = await (SocketD.create_client("sd🇼🇸//127.0.0.1:8602/?token=1b0VsGusEkddgr3d") .open()) entity = StringEntity("Hello wrold!").meta_put("sender","noear") #发送 session.send("/demo", entity) #发送并请求(且,等待一个答复。否则超时异常) session.send_and_request("/demo", entity).then_reply(lambda reply: #打印 log.info(reply.data_as_string()) ).then_error(lambda error: log.error(error) ) #发送并订阅(且,接收零个或多个答复流) session.send_and_subscribe("/demo", entity).then_reply(lambda reply: #打印 log.info(reply.data_as_string()) or (reply.is_end() and log.info("the end!")) )
原文链接:https://www.oschina.net/news/289224/socketd-2-4-11-released
关注公众号

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。

持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

转载内容版权归作者及来源网站所有,本站原创内容转载请注明来源。

文章评论

共有0条评论来说两句吧...

文章二维码

扫描即可查看该文章

点击排行

推荐阅读

最新文章