全平台开源即时通讯IM聊天框架MobileIMSDK的服务端开发指南，支持鸿蒙NEXT

 1 <dependencies>
 2    
 3   <!-- 依赖的开源JSON库Gson -->
 4   <dependency>
 5     <groupId>com.google.code.gson</groupId>
 6     <artifactId>gson</artifactId>
 7     <version>2.8.9</version>
 8   </dependency>
 9  
10   <!-- 依赖的log4j日志框架的实用组合 -->
11   <dependency>
12     <groupId>org.apache.logging.log4j</groupId>
13     <artifactId>log4j-api</artifactId>
14     <version>2.23.1</version>
15   </dependency>
16   <dependency>
17     <groupId>org.apache.logging.log4j</groupId>
18     <artifactId>log4j-core</artifactId>
19     <version>2.23.1</version>
20   </dependency>
21   <dependency>
22     <groupId>org.apache.logging.log4j</groupId>
23     <artifactId>log4j-slf4j-impl</artifactId>
24     <version>2.23.1</version>
25   </dependency>
26  
27   <!-- 依赖的RabbitMQ中间件的java客户端库，用于与MobileIMSDK-Web产品进行消息互通时 -->
28   <dependency>
29     <groupId>com.rabbitmq</groupId>
30     <artifactId>amqp-client</artifactId>
31     <version>5.20.0</version>
32   </dependency>
33  
34   <!-- 依赖的netty库 -->
35   <dependency>
36     <groupId>io.netty</groupId>
37     <artifactId>netty-all</artifactId>
38     <version>4.1.67.Final</version>
39   </dependency>
40  
41   <!-- MobileIMSDK的核心库（此jar没有上传到mave中央库，请注意本地引用路径哦） -->
42   <dependency>
43     <groupId>com.x52im</groupId>
44     <artifactId>mobileimsdk-server</artifactId>
45     <version>6.5</version>
46     <scope>system</scope>
47     <systemPath>${project.basedir}/src/main/webapp/WEB-INF/lib/MobileIMSDKServer.jar</systemPath>
48   </dependency>
49  
50 </dependencies>

/**
 * 与客服端的所有数据交互事件在此ServerEventListener子类中实现即可。
 * 
 * @author Jack Jiang
 * @version 1.0
 * @since 3.1
 */
public class ServerEventListenerImpl implements ServerEventListener
{
    private static Logger logger = LoggerFactory.getLogger(ServerEventListenerImpl.class);  
    
    /**
     * 用户身份验证回调方法定义（即验证客户端连接的合法性，合法就允许正常能信，否则断开）.
     * <p>
     * 服务端的应用层可在本方法中实现用户登陆验证。
     * <br>
     * 注意：本回调在一种特殊情况下——即用户实际未退出登陆但再次发起来登陆包时，本回调是不会被调用的！
     * <p>
     * 根据MobileIMSDK的算法实现，本方法中用户验证通过（即方法返回值=0时）后
     * ，将立即调用回调方法 {@link #onUserLoginSucess(int, String, IoSession)}。
     * 否则会将验证结果（本方法返回值错误码通过客户端的 ChatBaseEvent.onLoginResponse(int userId, int errorCode)
     * 方法进行回调）通知客户端）。
     * 
     * @param userId 传递过来的准一id，保证唯一就可以通信，可能是登陆用户名、也可能是任意不重复的id等，具体意义由业务层决定
     * @param token 用于身份鉴别和合法性检查的token，它可能是登陆密码，也可能是通过前置单点登陆接口拿到的token等，具体意义由业务层决定
     * @param extra 额外信息字符串。本字段目前为保留字段，供上层应用自行放置需要的内容
     * @param session 此客户端连接对应的 netty “会话”
     * @return 0 表示登陆验证通过，否则可以返回用户自已定义的错误码，错误码值应为：>=1025的整数
     */
    @Override
    public int onUserLoginVerify(String userId, String token, String extra, Channel session)
    {
        logger.debug("【DEBUG_回调通知】正在调用回调方法：OnVerifyUserCallBack...(extra="+extra+")");
        return 0;
    }

    /**
     * 用户登录验证成功后的回调方法定义（在业务上可理解为该用户的上线通知）.
     * <p>
     * 服务端的应用层通常可在本方法中实现用户上线通知等。
     * <br>
     * 注意：本回调在一种特殊情况下——即用户实际未退出登陆但再次发起来登陆包时，回调也是一定会被调用。
     * 
     * @param userId 传递过来的准一id，保证唯一就可以通信，可能是登陆用户名、也可能是任意不重复的id等，具体意义由业务层决定
     * @param extra 额外信息字符串。本字段目前为保留字段，供上层应用自行放置需要的内容。为了丰富应用层处理的手段，在本回调中也把此字段传进来了
     * @param session 此客户端连接对应的 netty “会话”
     */
    @Override
    public void onUserLoginSucess(String userId, String extra, Channel session)
    {
        logger.debug("【IM_回调通知onUserLoginSucess】用户："+userId+" 上线了！");
    }

    /**
     * 用户退出登录回调方法定义（可理解为下线通知回调）。
     * <p>
     * 服务端的应用层通常可在本方法中实现用户下线通知等。
     * 
     * @param userId 下线的用户user_id
     * @param session 此客户端连接对应的 netty “会话”
     * @param beKickoutCode 被踢原因编码，本参数当为-1时表示本次logout事件不是源自“被踢”，否则被踢原因编码请见 {@link PKickoutInfo}类中的常量定义
     * @see {@link OnlineProcessor#setBeKickoutCodeForChannel(Channel, int)}
     */
    @Override
    public void onUserLogout(String userId, Channel session, int beKickoutCode)
    {
        logger.debug("【DEBUG_回调通知onUserLogout】用户："+userId+" 离线了（beKickoutCode="+beKickoutCode+"）！");
    }
    
    /**
     * 收到客户端发送给“服务端”的数据回调通知（即：消息路径为“C2S”的消息）前的处理逻辑。
     * <p>
     * <b>本方法的默认实现</b>：<font color="green">当开发者不需要本方法进行额外逻辑处理时，请直接返回true即可！</font>
     * <p>
     * <b>本方法的典型用途</b>：开发者可在本方法中实现如：用户聊天内容的鉴黄、过滤、篡改等等，把内容审读权限交给开发者，就看怎么用了。
     * 
     * @param p 消息/指令的完整协议包对象
     * @param session 消息发送者的“会话”引用（也就是客户端的网络连接对象）
     * @return true表示经过本方法后将正常进入 {@link #onTransferMessage4C2S(Protocal, Channel)}继续正常逻辑  ，false表示该条指令将不会继续处理（直接被丢弃）
     * @see #onTransferMessage4C2S(Protocal, Channel)
     * @since 6.2
     */
    @Override
    public boolean onTransferMessage4C2CBefore(Protocal p, Channel session)
    {
        return true;
    }
    
    /**
     * 收到客户端发送给“其它客户端”的数据回调通知（即：消息路径为“C2C”的消息）前的处理逻辑。
     * <p>
     * <b>本方法的默认实现</b>：<font color="green">当开发者不需要本方法进行额外逻辑处理时，请直接返回true即可！</font>
     * <p>
     * <b>本方法的典型用途</b>：开发者可在本方法中实现如：用户聊天内容的鉴黄、过滤、篡改等等，把内容审读权限交给开发者，就看怎么用了。
     * 
     * @param p 消息/指令的完整协议包对象
     * @param session 消息发送者的“会话”引用（也就是客户端的网络连接对象）
     * @return true表示经过本方法后将正常进入 {@link #onTransferMessage4C2C(Protocal)}继续正常逻辑  ，false表示该条指令将不会继续处理（直接被丢弃）
     * @see #onTransferMessage4C2C(Protocal)
     * @since 6.2
     */
    @Override
    public boolean onTransferMessage4C2SBefore(Protocal p, Channel session)
    {
        return true;
    }

    /**
     * 收到客户端发送给“服务端”的数据回调通知（即：消息路径为“C2S”的消息）.
     * <p>
     * MobileIMSDK在收到客户端向userId="0"(即接收目标是"服务器")的情况下通过
     * 本方法的回调通知上层。
     * <p>
     * <b>本方法的典型用途</b>：开发者通常可在本方法中实现如：添加好友请求等需要服务端进行处理的业务。
     * 
     * @param p 消息/指令的完整协议包对象
     * @param session 此客户端连接对应的 netty “会话”
     * @return true表示本方法已成功处理完成，否则表示未处理成功。此返回值目前框架中并没有特殊意义，仅作保留吧
     * @see Protocal
     * @since 4.0
     */
    @Override
    public boolean onTransferMessage4C2S(Protocal p, Channel session)
    {
        // 接收者uid
        String userId = p.getTo();
        // 发送者uid
        String from_user_id = p.getFrom();
        // 消息或指令内容
        String dataContent = p.getDataContent();
        // 消息或指令指纹码（即唯一ID）
        String fingerPrint = p.getFp();
        // 【重要】用户定义的消息或指令协议类型（开发者可据此类型来区分具体的消息或指令）
        int typeu = p.getTypeu();
                
        logger.debug("【DEBUG_回调通知】[typeu="+typeu+"]收到了客户端"+from_user_id+"发给服务端的消息：str="+dataContent);
        return true;
    }

    /**
     * 收到客户端发送给“其它客户端”的数据回调通知（即：消息路径为“C2C”的消息）.
     * <p>
     * <b>注意：</b>本方法当且仅当在数据被服务端成功实时发送（“实时”即意味着对方在线的情况下）出去后被回调调用.
     * <p>
     * <b>本方法的典型用途</b>：开发者可在本方法中可以实现用户聊天信息的收集，以便后期监控分析用户的行为等^_^。
     * 开发者可以对本方法不作任何代码实现，也不会影响整个MobileIMSDK的运行，因为本回调并非关键逻辑，只是个普通消息传输结果的回调而已。
     * <p>
     * 提示：如果开启消息QoS保证，因重传机制，本回调中的消息理论上有重复的可能，请以参数 #fingerPrint
     * 作为消息的唯一标识ID进行去重处理。
     * 
     * @param p 消息/指令的完整协议包对象
     * @see Protocal
     * @since 4.0
     */
    @Override
    public void onTransferMessage4C2C(Protocal p)
    {
        // 接收者uid
        String userId = p.getTo();
        // 发送者uid
        String from_user_id = p.getFrom();
        // 消息或指令内容
        String dataContent = p.getDataContent();
        // 消息或指令指纹码（即唯一ID）
        String fingerPrint = p.getFp();
        // 【重要】用户定义的消息或指令协议类型（开发者可据此类型来区分具体的消息或指令）
        int typeu = p.getTypeu();
                
        logger.debug("【DEBUG_回调通知】[typeu="+typeu+"]收到了客户端"+from_user_id+"发给客户端"+userId+"的消息：str="+dataContent);
    }

    /**
     * 服务端在进行消息发送时，当对方在线但实时发送失败、以及其它各种问题导致消息并没能正常发出时
     * ，将无条件走本回调通知。
     * 
     * <p>
     * <b>注意：</b>本方法当且仅当在数据被服务端<u>在线发送</u>失败后被回调调用.
     * 
     * <p>
     * <b>举个例子：以下是一段典型的服务端消息/指令发送代码：</b>
     * <pre style="border: 1px solid #eaeaea;background-color: #fff6ea;border-radius: 6px;">
     * // 消息接收者的id（这个id由你自已定义，对于MobileIMSDK来说只要保证唯一性即可）
     * String destinationUserId = "400069";
     * 
     * // 这是要发送的消息（"你好"是消息内容、“0”是消息发送者）
     * final Protocal p = ProtocalFactory.createCommonData("你好", "0", destinationUserId, true, null, -1);
     *     
     * // 对方在线的情况下，才需要实时发送，否则走离线处理逻辑
     * if(OnlineProcessor.isOnline(destinationUserId)) {
     *     // netty是异步通知数据发送结果的
     *     MBObserver＜Object＞ resultObserver = new MBObserver＜Object＞(){
     *         public void update(boolean sucess, Object extraObj) {
     *             if(sucess){
     *                 // 你的消息/指令实时发送成功，不需要额外处理了
     *             }
     *             else{
     *                 //【1】TODO: 你的消息/指令实时发送失败，在这里实现离线消息处理逻辑！
     *             }
     *         }
     *     };
     *         
     *     //【2】开始实时消息/指令的发送
     *     LocalSendHelper.sendData(p, resultObserver);
     * }
     * else{
     *     //【3】TODO: 你的离线消息处理逻辑！
     * }
     * <br>
     * <font color="#0000ff">如上代码所示：“【1】【3】”代码处，开发者可以自行明确地进行离线逻辑处理，“【2】”处如
     * 果实时发送时出现任何问题，将会走本回调方法进行通知，框架正是通过此回调进一步确保消息可靠性保证的。</font>
     * </pre>
     * <p>
     * 
     * <p>
     * <b>本方法的典型用途</b>：<br>
     * 开发者可在本方法中实现离线消息的持久化存储（反正进到本回调通知的消息，就是应该被离线存储起来的）。
     * 
     * <p>
     * <b>此方法存的意义何在？</b><br>
     * 发生此种情况的场景可能是：对方确实不在线（那么此方法里就可以作为离线消息处理了）、或者在发送时判断对方是在线的
     * 但服务端在发送时却没有成功（这种情况就可能是通信错误或对方非正常通出但尚未到达会话超时时限）。<br><u>应用层在
     * 此方法里实现离线消息的处理即可！</u>
     * 
     * @param p 消息/指令的完整协议包对象
     * @return true表示应用层已经处理了离线消息（如果该消息有QoS机制，则服务端将代为发送一条伪应答包
     * （伪应答仅意味着不是接收方的实时应答，而只是存储到离线DB中，但在发送方看来也算是被对方收到，只是延
     * 迟收到而已（离线消息嘛））），否则表示应用层没有处理（如果此消息有QoS机制，则发送方在QoS重传机制超时
     * 后报出消息发送失败的提示）
     * @see Protocal
     * @see #onTransferMessage4C2C(Protocal)
     * @since 4.0
     */
    @Override
    public boolean onTransferMessage_RealTimeSendFaild(Protocal p)
    {
        // 接收者uid
        String userId = p.getTo();
        // 发送者uid
        String from_user_id = p.getFrom();
        // 消息或指令内容
        String dataContent = p.getDataContent();
        // 消息或指令指纹码（即唯一ID）
        String fingerPrint = p.getFp();
        // 【重要】用户定义的消息或指令协议类型（开发者可据此类型来区分具体的消息或指令）
        int typeu = p.getTypeu();

        logger.debug("【DEBUG_回调通知】[typeu="+typeu+"]客户端"+from_user_id+"发给客户端"+userId+"的消息：str="+dataContent
                +"，因实时发送没有成功，需要上层应用作离线处理哦，否则此消息将被丢弃.");
        return false;
    }


    /**
     * <b>注意：</b><font color="red">本回调仅用于与Web的互通模式下，默认情况下本方法可什么也不做，无任何影响。如你对此回调有疑问可跟Jack Jiang进行技术讨论！</font>
     * {@inheritDoc}
     * 
     * @since 6.2
     */
    @Override
    public void onTransferMessage4C2C_AfterBridge(Protocal p)
    {    
        // 默认本方法可
    }
}

/**
 * MobileIMSDK的服务端QoS消息送达保证机制的事件监听器实现类。
 * <p>
 * <b>当前QoS机制支持全部的C2C、C2S、S2C共3种消息交互场景下的消息送达质量保证：<</b>>
 * <ur>
 * <li>1) Client to Server(C2S)：即由某客户端主动发起，消息最终接收者是服务端，此模式下：重发由C保证、ACK应答由S发回；</li>
 * <li>2) Server to Client(S2C)：即由服务端主动发起，消息最终接收者是某客户端，此模式下：重发由S保证、ACK应答由C发回；</li>
 * <li>2) Client to Client(C2C)：即由客户端主动发起，消息最终接收者是另一客户端。此模式对于QoS机制来说，相当于C2S+S2C两程路径。</li>
 * </ul>
 * <p>
 * TCP理论上能从底层保证数据的可靠性，但应用层的代码和场景中存在网络本身和网络之外的各种不可靠性，
 * MobileIMSDK中的QoS送达保证机制，将加强TCP的可靠性，确保消息，无法从哪一个层面和维度，都会给
 * 开发者提供两种结果：要么明确被送达（即收到ACK应答包，见 {@link #messagesBeReceived(String)}）
 * 、要行明确未被送达（见 {@link #messagesLost(ArrayList)}）。从理论上，保证消息的百分百送达率。
 * 
 * @author Jack Jiang
 * @version 1.0
 * @since 3.1
 * @see net.x52im.mobileimsdk.server.qos.QoS4SendDaemonS2C
 * @see net.x52im.mobileimsdk.server.qos.QoS4ReciveDaemonC2S
 * @see MessageQoSEventListenerS2C
 */
public class MessageQoSEventS2CListnerImpl implements MessageQoSEventListenerS2C
{
    private static Logger logger = LoggerFactory.getLogger(MessageQoSEventS2CListnerImpl.class);  
    
    /**
     * 消息未送达的回调事件通知.
     * 
     * @param lostMessages 由MobileIMSDK QoS算法判定出来的未送达消息列表（此列表
     * 中的Protocal对象是原对象的clone（即原对象的深拷贝），请放心使用哦），应用层
     * 可通过指纹特征码找到原消息并可以UI上将其标记为”发送失败“以便即时告之用户
     */
    @Override
    public void messagesLost(ArrayList<Protocal> lostMessages)
    {
        logger.debug("【DEBUG_QoS_S2C事件】收到系统的未实时送达事件通知，当前共有"
                        +lostMessages.size()+"个包QoS保证机制结束，判定为【无法实时送达】！");
    }

    /**
     * 消息已被对方收到的回调事件通知.
     * <p>
     * <b>目前，判定消息被对方收到是有两种可能：</b><br>
     * 1) 对方确实是在线并且实时收到了；<br>
     * 2) 对方不在线或者服务端转发过程中出错了，由服务端进行离线存储成功后的反馈
     * （此种情况严格来讲不能算是“已被收到”，但对于应用层来说，离线存储了的消息
     * 原则上就是已送达了的消息：因为用户下次登陆时肯定能通过HTTP协议取到）。
     * 
     * @param theFingerPrint 已被收到的消息的指纹特征码（唯一ID），应用层可据此ID
     * 来找到原先已发生的消息并可在UI是将其标记为”已送达“或”已读“以便提升用户体验
     */
    @Override
    public void messagesBeReceived(String theFingerPrint)
    {
        if(theFingerPrint != null)
        {
            logger.debug("【DEBUG_QoS_S2C事件】收到对方已收到消息事件的通知，fp="+theFingerPrint);
        }
    }
}

/**
 * IM服务的启动主类。
 * <p>
 * <b>友情提示：</b>其实MobileIMSDK的服务端并非只能以main的主类方式独立启动，你完全可以把它放到诸如java的Web工程里作为子模块运行，不会有任何问题！
 * 
 * @author Jack Jiang
 * @version 1.0*/
public class ServerLauncherImpl extends ServerLauncher
{
    private static Logger logger = LoggerFactory.getLogger(ServerLauncherImpl.class);  
    
    /**
     * 静态类方法：进行一些全局配置设置。
     */
    static
    {
        // 设置MobileIMSDK服务端的UDP网络监听端口
        GatewayUDP.PORT       = 7901;
        // 设置MobileIMSDK服务端的TCP网络监听端口
        GatewayTCP.PORT       = 8901;
        // 设置MobileIMSDK服务端的WebSocket网络监听端口
        GatewayWebsocket.PORT = 3000;
        
        // 设置MobileIMSDK服务端仅支持UDP协议
//        ServerLauncher.supportedGateways = Gateway.SOCKET_TYPE_UDP;
        // 设置MobileIMSDK服务端仅支持TCP协议
//        ServerLauncher.supportedGateways = Gateway.SOCKET_TYPE_TCP;
        // 设置MobileIMSDK服务端仅支持WebSocket协议
//        ServerLauncher.supportedGateways = Gateway.SOCKET_TYPE_WEBSOCKET;
        // 设置MobileIMSDK服务端同时支持UDP、TCP、WebSocket三种协议
        ServerLauncher.supportedGateways = Gateway.SOCKET_TYPE_UDP | Gateway.SOCKET_TYPE_TCP | Gateway.SOCKET_TYPE_WEBSOCKET;
        
        // 开/关Demog日志的输出
        QoS4SendDaemonS2C.getInstance().setDebugable(true);
        QoS4ReciveDaemonC2S.getInstance().setDebugable(true);
        
        // 与客户端协商一致的心跳频率模式设置
//        ServerToolKits.setSenseModeUDP(SenseModeUDP.MODE_15S);
        ServerToolKits.setSenseModeTCP(SenseModeTCP.MODE_5S);
        ServerToolKits.setSenseModeWebsocket(SenseModeWebsocket.MODE_5S);
//        ServerToolKits.setSenseModeWebsocket(SenseModeWebsocket.MODE_30S);

        // 关闭与Web端的消息互通桥接器（其实SDK中默认就是false）
        ServerLauncher.bridgeEnabled = false;
        // TODO 跨服桥接器MQ的URI（本参数只在ServerLauncher.bridgeEnabled为true时有意义）
//        BridgeProcessor.IMMQ_URI = "amqp://js:19844713@192.168.0.190";
        
        // 设置最大TCP帧内容长度（不设置则默认最大是 6 * 1024字节）
//        GatewayTCP.TCP_FRAME_MAX_BODY_LENGTH = 60 * 1024;
        
        SslContext sslContext = createSslContext();
        // 开启TCP协议的SSL/TLS加密传输（请确保客户端也已开发SSL）
//        GatewayTCP.sslContext = sslContext;
        // 开启WebSocket协议的SSL/TLS加密传输（请确保SSL证书是正规CA签发，否则浏览器是不允许的）
//        GatewayWebsocket.sslContext = sslContext;
    }
    
    /**
     * 实例构造方法。
     * 
     * @throws IOException
     */
    public ServerLauncherImpl() throws IOException
    {
        super();
    }
    
    /**
     * 初始化消息处理事件监听者.
     */
    @Override
    protected void initListeners()
    {
        // ** 设置各种回调事件处理实现类
        this.setServerEventListener(new ServerEventListenerImpl());
        this.setServerMessageQoSEventListener(new MessageQoSEventS2CListnerImpl());
    }
    
    /**
     * 创建SslContext对象，用于开启SSL/TLS加密传输。
     * 
     * @return 如果成功创建则返回SslContext对象，否则返回null
     */
    private static SslContext createSslContext()
    {        
        try {
            /** 示例 1：使用证书（证书位于绝对路径）*/
//            // 证书文件
//            File certChainFile = new File("c:/certs/netty-cert2.crt");
//            // 证书文件
//            File keyFile = new File("c:/certs/netty-key2.pk8");
//            // 私钥密码（注意：Netty只支持.pk8格式，如何生成，见JackJiang文章：）
//            String keyPassword = "123456";
//            // 生成SslContext对象（为了方便理解，此处使用的是单向认证）
//            SslContext sslCtx = SslContextBuilder.forServer(certChainFile, keyFile, keyPassword).clientAuth(ClientAuth.NONE).build();
                
            /** 示例 2：使用证书（证书位于相对路径）*/
            // TODO: 注意：请使用自已的证书，Demo中带的证书为自签名证书且已绑定域名，不安全！！！
            // 证书文件
            InputStream certChainFile = ServerLauncherImpl.class.getResourceAsStream("certs/netty-cert2.crt");
            // 私钥文件（注意：Netty只支持.pk8格式，如何生成，见JackJiang文章：）
            InputStream keyFile = ServerLauncherImpl.class.getResourceAsStream("certs/netty-key2.pk8");
            // 私钥密码（注意：Netty只支持.pk8格式，如何生成，见JackJiang文章：）
            String keyPassword = "123456";
            // 生成SslContext对象（为了方便理解，此处使用的是单向认证）
            SslContext sslCtx = SslContextBuilder.forServer(certChainFile, keyFile, keyPassword).clientAuth(ClientAuth.NONE).build();
                
            /** 示例 3：使用Netty自带的自签名证书（建议该证书仅用于测试使用）*/
//            SelfSignedCertificate ssc = new SelfSignedCertificate();
//            SslContext sslCtx = SslContextBuilder.forServer(ssc.certificate(), ssc.privateKey()).build();
                
            return sslCtx;
        } catch (Exception e) {
             logger.warn("createSslContext()时出错了，原因："+e.getMessage(), e);
        }
        
        return null;
    }
    
    /**
     * Demo程序主入口函数。
     * 
     * @param args
     * @throws Exception
     */
    public static void main(String[] args) throws Exception 
    {
        // 实例化后记得startup哦，单独startup()的目的是让调用者可以延迟决定何时真正启动IM服务
        final ServerLauncherImpl sli = new ServerLauncherImpl();
        
        // 启动MobileIMSDK服务端的Demo
        sli.startup();
        
        // 加一个钩子，确保在JVM退出时释放netty的资源
        Runtime.getRuntime().addShutdownHook(new Thread() {
            @Override
            public void run() {
                sli.shutdown();
            }
        });
    }
}