//初始化消息中心
        //socket连接模块集成的是netty框架
        MessageCenter.create(context)
                .setSocketCheckIntervalTime(10 * 1000)      //设置socket自检定时器时间，默认为10秒
                .host("192.168.0.1").port(8088)             //设置socket连接参数，不需要使用socket也可以不设置
                .socketInterceptor(new MySocketInterceptor());//绑定socket拦截器，不需要使用socket也可以不设置

        //连接socket，如果已经连上socket，会自动先断开再连接；不需要使用socket也可以不调用
        MessageCenter.connectSocket();
        //断开socket连接；不需要使用socket也可以不调用
        MessageCenter.disConnectSocket();

        //发送应用内消息
        Msg insideMsg = Msg.ini("insideTag", new Object());//"insideTag"是订阅消息的标识，new Object()是携带的数据包，可以是任意类型
        insideMsg.destination(Msg.APP_INSIDE);//APP_INSIDE为默认值，可以不用设置，如需发送到服务器则使用APP_OUTSIDE
        MessageCenter.sendMessage(insideMsg);

        //发送到应用外的消息
        Msg outSideMsg = Msg.ini("outsideTag", new Object());
        outSideMsg.destination(Msg.APP_OUTSIDE);
        MessageCenter.sendMessage(outSideMsg);

        //Listener方式创建订阅者
        MessageHandler insideMessageHandler = new MessageHandler("insideTag",
                //收到消息订阅
                new MHanderReceiveListener() {
                    @Override
                    public void receivedMsg(Msg message) {}
                },
                //发送消息订阅，可监听发送状态，主要用于处理发送socket消息回执，不是必须实现的方法
                new MHanderSendListener() {
                    @Override
                    public void sendMsgReturn(Msg message, int sendState) {}
                });
        //Listener方式注册订阅者
        MessageCenter.registMessageHandler(insideMessageHandler);
        //Listener方式注销订阅者。如不再使用一定要记得注销
        MessageCenter.unRegistMessageHandler(insideMessageHandler);

        //注解方式注册订阅者
        MessageCenter.registMessageHandler(this);
        //注解方式注销订阅者。如不再使用一定要记得注销
        MessageCenter.unRegistMessageHandler(this,"outsideTag");

 /**
     * 注解方式绑定订阅者
     * 发送socket消息监听
     * @param obj 发送的数据包 , 不一定是Object，视你发送的消息类型而定，如果发送的数据包为null，这儿可以不要这个参数
     * @param sendState 发送状态
     */
   @MHanderSendTag("outsideTag")
    void sendOutside(Object obj, int sendState){
        //MHanderSendListener.ACTIVE 发送中
        //MHanderSendListener.SUCCESS 发送成功
        //MHanderSendListener.FAIL 发送失败
    }

    /**
     * 注解方式绑定订阅者
     * 接受socket消息监听 收到的数据包 , 不一定是Object，视你收到的消息类型而定，如果收到的数据包为null，这儿可以不要这个参数
     * @param obj
     */
    @MHanderReceiveTag("outsideTag")
    void receiveOutside(Object obj){

    }

/**
     * socket拦截器
     * 可以在这里做数据拆装、重连机制
     */
    public class MySocketInterceptor implements SocketInterceptor {

        /**
         * 这里会收到服务器发来的且已处理成String字符串，你可以根据自己的需求进行包装
         * ReceiveMsg有tag和obj可供你的订阅者使用
         * @param msg 收到的数据包
         * @return
         */
        @Override
        public List<ReceiveMsg> receiveServerMsg(String msg) {
            return null;
        }

        /**
         * 这里用于包装心跳包，你可以根据自己的需求包装成需要的字符串样式
         * @return
         */
        @Override
        public String heartbeat() {
            return null;
        }
        /**
         * socket的连接状态监听
         * @param connetState  CONNECTING：连接中 INTERRUPT：已断开 SUCCESS：连接成功 CANCEL：已取消（主动调用MessageCenter.disConnectSocket()会调用）
         * @param exception 如已断开会返回错误信息
         */
        @Override
        public void connectState(ConnetState connetState, Exception exception) {

        }
    }