安卓socket 心跳和信鸽自定义提示音

/**
*        连接socket 和心跳
*/
public class SocketService extends Service {
    private static addNewOrderInterface mInterface;

    private SocketBinder socketBinder = new SocketBinder();

    public static WebSocketClient client;
     public static String address = "ws://192.168.0.120:8080/websocket/";
   

    private static int count = 0;
    // 发送心跳包
    private static Handler timeHandler = new Handler();
    private static Handler mHandler = new Handler();
    private static Runnable heartBeatRunnable = new Runnable() {
        @Override
        public void run() {
            mHandler.postDelayed(this, 15 * 1000);
            sendMsg("@heart");
//            socketBinder.sendMsg("@heart");

        }
    };
    private static Runnable timeRunnable = new Runnable() {
        @Override
        public void run() {
            timeHandler.postDelayed(this, 1000);
            count++;
            if (count >= 30) {
                //socket 连接断开
                try {
                    closeConnect();
                    L.e(SharedUtils.getInstance().getToken() + "连接socket的token");
                    initSocketClient(SharedUtils.getInstance().getToken());
                } catch (URISyntaxException e) {
                    e.printStackTrace();
                }
                connect();
            }
        }
    };


    public static String message;

    static String tokenMsg;

    @Override
    public void onCreate() {
        super.onCreate();

        try {
            L.e(SharedUtils.getInstance().getToken() + "连接socket的token");
            initSocketClient(SharedUtils.getInstance().getToken());
        } catch (URISyntaxException e) {
            e.printStackTrace();
        }

    }

    @Override
    public int onStartCommand(Intent intent, int flags, int startId) {
        L.e("执行了onStartCommand()");
//        String orderNo = intent.getStringExtra("orderNo");
//        if (orderNo != null)
//            getOrder(orderNo);
//        if (client.isClosed())
        connect();
        return super.onStartCommand(intent, flags, startId);
    }


    @Override
    public void onDestroy() {
        super.onDestroy();
        L.e("执行了onDestory()");
    }


    @Nullable
    @Override
    public IBinder onBind(Intent intent) {
        return socketBinder;
    }

    @Override
    public boolean onUnbind(Intent intent) {
        L.e("绑定服务");
        return super.onUnbind(intent);
    }

    @Override
    public void unbindService(ServiceConnection conn) {
//        closeConnect();
        L.e("解绑服务");
        super.unbindService(conn);
    }


    public static void receiverMessage(String msg) {

        if (mInterface != null) {
            if (msg.indexOf("heart") != -1) {

            } else {
                mInterface.addNewData(msg);
            }
        }
    }

    public static class SocketBinder extends Binder {

        public void service_connect_Activity() {
            mHandler.post(heartBeatRunnable);
            timeHandler.post(timeRunnable);
            L.e("Service关联了Activity,并在Activity执行了Service的方法");

        }


        public void addNewOrderInterface(addNewOrderInterface anInterface) {
            mInterface = anInterface;
        }


    }

    //断开连接
    public static void closeConnect() {
        try {
            client.close();
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            client = null;
        }

        L.e("断开 socket");

    }

    /**
     * 发送消息
     */
    public static void sendMsg(String msg) {

        if (!SharedUtils.getInstance().getLogin()) {
            return;
        }

        L.e("socket发送给服务端的消息- - >" + msg);
        if (client == null)
            return;
        try {
            client.send(msg);
        } catch (WebsocketNotConnectedException e) {
            if (tokenMsg == null) {

                L.e("socket----->WebsocketNotConnectedException异常");
                e.printStackTrace();
                closeConnect();
                try {
                    initSocketClient(SharedUtils.getInstance().getToken());
                } catch (URISyntaxException ee) {
                    ee.printStackTrace();
                }
                connect();
            }
        }
    }


    public static void initSocketClient(String token) throws URISyntaxException {

        if (client == null) {
            client = new WebSocketClient(new URI(address + token)) {

                @Override
                public void onOpen(ServerHandshake serverHandshake) {
                    //连接成功
                    L.e("socket连接成功");
                    count = 0;
                }

                @Override
                public void onMessage(String s) {
                    L.e("服务端发的消息:" + s);
                    if (s.equals("token验证失败！")) {
                        tokenMsg = s;
                        SharedUtils.getInstance().setLogin(false);
                        //token 过期 或者 验证失败  停止心跳相关
                        mHandler.removeCallbacks(heartBeatRunnable);
                        timeHandler.removeCallbacks(timeRunnable);

                        return;
                    } else {
                        tokenMsg = null;
                    }
                    if (s.indexOf("heart") != -1) {
                        count = 0;
                    }


                    message = s;
//                    if (s.length() > 10)
                    receiverMessage(s);
                    if (s.length() > 5) {
//                    disposeData(s);
//                        newOrder.addNewData(s);
//                        OrderReceiveFragment.getInstance().addNewData(s);
                    }
                }

                @Override
                public void onClose(int i, String s, boolean remote) {
                    //连接断开，remote判定是客户端断开还是服务端断开
                    L.e("Connection closed by " + (remote ? "remote peer---断开？？" : "us") + ", info=" + s);
                    //
                }

                @Override
                public void onError(Exception e) {
                    L.e("error:" + e);
                }
            };
        }
    }

    //连接
    public synchronized static void connect() {

        new Thread() {
            @Override
            public void run() {
                if (client != null) {
                    try {
                        client.connect();
                    } catch (IllegalStateException e) {
                        L.e(e.toString());
                    }
                }
                L.e("socket连接");
            }
        }.start();

    }


}