websocket api

Websocket-Client

得到它

websocket-api需要Java 11或 +运行。

使用Maven Central存储库（仅稳定版本）：

    < dependency >
        < groupId >org.zhongweixian</ groupId >
        < artifactId >websocket-api</ artifactId >
        < version >2.1.6</ version >
    </ dependency >

启动服务器

 WebSocketServer webSocketServer = new WebSocketServer ( 8190 , 60 , "ws" , new ConnectionListener () {
            @ Override
            public void connect ( Channel channel ) throws Exception {
                logger . info ( "channel {} is connect" , channel . id ());
            }

            @ Override
            public void onClose ( Channel channel , int closeCode , String reason ) {

            }

            @ Override
            public void onError ( Throwable throwable ) {

            }

            @ Override
            public void onFail ( int status , String reason ) {
                logger . info ( "status:{} , reason:{}" , status , reason );
            }

            @ Override
            public void onMessage ( Channel channel , String text ) throws Exception {
                logger . info ( "channel {} , receive message:{}" , channel . id (), text );
            }

            @ Override
            public void onMessage ( Channel channel , ByteBuf byteBuf ) throws Exception {
                logger . info ( "" );
            }
        });
        webSocketServer . start ();

Websocket客户端（不重连）

        /**
         * 启动ws客户端
         */
        WebSocketClient client = new WebSocketClient ( "ws://192.168.181.178:8190/ws" );


        for ( int i = 0 ; i < 1000 ; i ++) {
            client . connection ( new ConnectionListener () {
                @ Override
                public void onClose ( Channel channel , int closeCode , String reason ) {
                    logger . warn ( "channelId:{} , closeCode:{} , reason:{}" , channel . id (), closeCode , reason );
                }

                @ Override
                public void onError ( Throwable throwable ) {
                    logger . warn ( "onError:{}" , throwable . getMessage ());
                }

                @ Override
                public void onFail ( int status , String reason ) {

                }

                @ Override
                public void onMessage ( Channel channel , String text ) throws Exception {
                    logger . info ( "client:{} onMessage:{}" , channel . id (), text );
                }

                @ Override
                public void onMessage ( Channel channel , ByteBuf byteBuf ) throws Exception {
                    logger . info ( "client:{} onMessage:{}" , channel . id (), byteBuf . toString ( Charset . defaultCharset ()));
                }

                @ Override
                public void connect ( Channel channel ) throws Exception {
                    logger . info ( "client:{} connect" , channel . id ());
                }
            });
            Thread . sleep ( 10 );
        }

Websocket客户端（支持重连）

    public static void main ( String [] args ) {
        try {
            String login = "{ " cmd " : " connect " , " agentId " : " 1000 " , " sip " : " " , " companyId " :129, " businessIds " :[831,823], " operatorType " :1}" ;
            WsClient client = new WsClient ( "ws://192.168.183.145:8190/ws" , login , new ConnectionListener () {
                @ Override
                public void onClose ( Channel channel , int closeCode , String reason ) {

                }

                @ Override
                public void onError ( Throwable throwable ) {

                }

                @ Override
                public void onFail ( int status , String reason ) {

                }

                @ Override
                public void onMessage ( Channel channel , String text ) throws Exception {
                    System . out . println ( text );
                }

                @ Override
                public void onMessage ( Channel channel , ByteBuf byteBuf ) throws Exception {

                }

                @ Override
                public void connect ( Channel channel ) throws Exception {
                    System . out . println ( "连接成功 " );
                }
            });
            new Thread ( client ). start ();

            System . out . println ( " start ok" );
        } catch ( Exception e ) {
            e . printStackTrace ();
        }

    }