allprojects {
		repositories {
			...
			maven { url 'https://jitpack.io' }
		}
	}

dependencies {
	       implementation 'com.github.CWTakiku:NettyIM:latest'
	}

    //添加网络权限
    <uses-permission android:name="android.permission.ACCESS_NETWORK_STATE" />
    <uses-permission android:name="android.permission.INTERNET" />

    //所以default都可以替换成开发者的实现，只要实现相应接口即可
       imClient=new IMClient.Builder()
                .setCodec(new DefaultCodec()) //默认的编解码，如果是私有协议开发者可以使用自己的protobuf编解码
                .setShakeHands(new DefaultMessageShakeHandsHandler(getDefaultHands())) //设置握手认证，可选
                .setHeartBeatMsg(getDefaultHeart()) //设置心跳需为解码器所支持的对象,可选
                .setAckConsumer(new DefaultAckConsumer()) //设置消息确认包的消费者，这个将影响发送的消息是否发送超时
                .setConnectTimeout(10, TimeUnit.SECONDS) //设置连接超时
                .setResendCount(3)//设置发送失败重试次数
                .setConnectionRetryEnabled(true)//是否连接重试
                .setSendTimeout(6,TimeUnit.SECONDS)//设置发送超时
                .setHeartIntervalBackground(30,TimeUnit.SECONDS)//后台心跳间隔
                .registerMessageHandler(new DefaultMessageReceiveHandler(onMessageArriveListener)) //消息接收处理器
                .registerMessageHandler(new DefaultReplyReceiveHandler(onReplyListener)) //消息状态接收处理器
                .registerMessageHandler(new DefaultHeartbeatRespHandler()) //心跳接收处器
                .setEventListener(new DefaultEventListener("user id1")) //事件监听，可选
                .addAddress(new Address("192.168.69.32",8766,Address.Type.SOCKS))
                .addAddress(new Address("www.baidu.com",8766,Address.Type.SOCKS))
                .setProtocol(IMProtocol.PRIVATE)//协议类型
                .setMaxFrameLength(65535)//最大帧长
                .setMsgTriggerReconnectEnabled(true)//设置是否消息触发重连（默认true)
                .setConnectRetryInterval(500,TimeUnit.MILLISECONDS)//设置连接重试间隔时间
                .setOpenLog(true)   //打开SDK内部日志
                .build();

       IMClient.Builder()
                .addAddress(new Address("ws://192.168.69.32:8804/ws",8804,Address.Type.WS))//websocket地址
                 .addAddress(new Address("wss://test.domain:8804/wss",8804,Address.Type.WS))//wss协议地址
                .addWsHeader("user","userId1") //ws头
                .setProtocol(IMProtocol.WEB_SOCKET);//设置为webscoket协议

imClient.startConnect();//建立连接

imClient.disConnect();//主动断开连接，不会自动重连

  Request request=new Request.Builder(). //创建一个消息发送request           
              setNeedACK(true).//需要ACK
              setSendRetry(true). //能发送重试
              setBody(getMsgPack(appMessage.buildProto())). //body为解码所支持的对象
              build();

 imClient.newCall(request).enqueue(callback);//发送消息，消息在子线程回调

Disposable disposable=   imClient.newCall(request).enqueue(callback).subscribe(consumer); //发送消息，会订阅特定的消息处理

 imClient.setBackground(background);//设置前后台切换，将会自动切换不同的心跳间隔
 imClient.isConnected();//判断是否连接中
 ...