🎉 Socket.D v2.4.11（新增 python 实现）

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!"))
    )