有用户说，“Socket.D 之于 Socket，尤如 Vue 之于 Js、Mvc 之于 Http”

与其它协议的简单对比

本次更新

• 开放 FragmentSize 可配置
• 添加 Channel::onError 方法（属于内部调整）
• 添加 ChannelSupporter 接口，并简化 Channel 构造函数（属于内部调整）
• 添加 SessionWrapper 包装类（便于监视会话的支行）
• 添加 集群客户端接口及创建方式 SocketD.createClusterClient()
• 统一客户端与集群客户端接口
• 统一客户端会话与集群客户端会话接口

新的集群客户端对比示例:

//单机客户端
ClientSession sessoin = SocketD.createClient("sd:tcp://127.0.0.1:8602")
        .listen(new EventListener().on("hello", (s, m) -> {
            System.out.println(m);
        }))
        .open();
        
//集群客户端
ClientSession sessoin = SocketD.createClusterClient("sd:tcp://127.0.0.1:8602", 
                            "sd:tcp://127.0.0.1:8603", 
                            "sd:tcp://127.0.0.1:8604")
        .listen(new EventListener().on("hello", (s, m) -> {
            System.out.println(m);
        }))
        .open();

Brokeer 集群示例:

public class Demo07_Broker {
    public static void main(String[] args) throws IOException {
        //创建 broker 服务
        SocketD.createServer("sd:tcp")
                .config(c -> c.port(8602).fragmentHandler(new BrokerFragmentHandler()))
                .listen(new BrokerListener())
                .start();
        
        //创建服务并加入 broker 集群
        SocketD.createClient("sd:tcp://127.0.0.1:8602/?@=server")
                .listen(new EventListener().on("hello", (s, m) -> {
                    System.out.println("Server0: " + m);

                    if (m.isSubscribe() || m.isRequest()) {
                        s.replyEnd(m, new StringEntity("me to!" + m.dataAsString()));
                    }
                }))
                .open();
    }
}

代码仓库

• https://gitee.com/noear/socketd
• https://github.com/noear/socketd