3 threads: initsocketthread, readthread, heartbeatthread

钟易宏
1 parent 03b4127d
Showing 1 changed file with 98 additions and 53 deletions
gimiCinema/src/main/java/com/qnbar/smc/service/SocketService1.java
--- a/gimiCinema/src/main/java/com/qnbar/smc/service/SocketService1.java
View file @7d11457
+++ b/gimiCinema/src/main/java/com/qnbar/smc/service/SocketService1.java
View file @7d11457
@@ -43,6 +43,7 @@ import java.util.concurrent.atomic.AtomicBoolean;
 public class SocketService1 extends BaseService {
     private static final String TAG = "BackService1";
     private static final long HEART_BEAT_RATE = 2 * 1000;
+    private final long READ_THREAD_DEFAULT_SLEEP_MTIME = 1000;
     //    public static final int USER_OPEN_DOOR_AND_GET_MOVIE = 1703;
     /*
@@ -97,10 +98,11 @@ public class SocketService1 extends BaseService {
     //    public String testRoomSn = "R170413034374";
     public String testRoomSn = "c";
-    private ReadThread mReadThread;
-    private Gson gson;
+//    private ReadThread mReadThread;
+    private Gson gson = new Gson();
-    private WeakReference<Socket> mSocket;
+//    private WeakReference<Socket> mSocket;
+    private Socket socket = null;
     StringBuilder readingMsg = new StringBuilder();
     // For heart Beat
@@ -109,16 +111,19 @@ public class SocketService1 extends BaseService {
     AtomicBoolean sendRegister = new AtomicBoolean(false);
     private Runnable heartBeatRunnable = new Runnable() {
+        private static final String TAG = "HeartBeatThread";
         @Override
         public void run() {
             Log.d(TAG, "heart beat");
             mHandler.postDelayed(this, HEART_BEAT_RATE);
-            boolean isSuccess = sendMsg(new Gson().toJson(new SocketSendMsg().contractHeartBeatMsg(testRoomSn)) + END_SYMBOL);//就发送一个HEART_BEAT_STRING过去 如果发送失败，就重新初始化一个socket
+            //就发送一个HEART_BEAT_STRING过去 如果发送失败，就重新初始化一个socket
+            boolean isSuccess = sendMsg(new Gson().toJson(
+                    new SocketSendMsg().contractHeartBeatMsg(testRoomSn)) + END_SYMBOL);
             if (!isSuccess) {
                 LogUtils.d(TAG, "heart beat error restart");
-                clearConnect();
-                new InitSocketThread().start();
+//                clearConnect();
+//                new InitSocketThread().start();
             }
         }
     };
@@ -138,7 +143,7 @@ public class SocketService1 extends BaseService {
         }
     };
-    private Context context;
+    private Context context = this;
     @Override
     public IBinder onBind(Intent arg0) {
@@ -148,8 +153,8 @@ public class SocketService1 extends BaseService {
     @Override
     public void onCreate() {
         super.onCreate();
-        gson = new Gson();
-        context = this;
+//        gson = new Gson();
+//        context = this;
         LogUtils.d(TAG, "onCreate");
     }
@@ -193,13 +198,19 @@ public class SocketService1 extends BaseService {
             return super.onStartCommand(intent, flags, startId);
         }
+//        LogUtils.d(TAG, "socket service onCreate");
         new InitSocketThread().start();
-        LogUtils.d(TAG, "socket service onCreate");
+        new ReadThread().start();
+        mHandler.post(heartBeatRunnable);
+
         return START_STICKY;
     }
     ///begin socket operation
     private synchronized void initSocket() throws IOException {//初始化Socket
+        if (socket != null && socket.isConnected()) {
+            return;
+        }
         LogUtils.d(TAG, "serverHost:serverPort:" + serverHost + ":" + serverPort);
         mHandler.post(new Runnable() {
             @Override
@@ -207,21 +218,18 @@ public class SocketService1 extends BaseService {
                 CToast.makeText(context, "开始连接服务器", 10 * 1000).show();
             }
         });
-        Socket so = new Socket(serverHost, serverPort);
-        mSocket = new WeakReference<>(so);
+        socket = new Socket(serverHost, serverPort);
         readingMsg.setLength(0);
-        mReadThread = new ReadThread();
-        mReadThread.start();
     }
     private synchronized boolean sendMsg(String msg) {
-        if (null == mSocket || null == mSocket.get()) {
+        if (socket == null || !socket.isConnected()) {
             return false;
         }
         if (!msg.contains("20025")) {
             LogUtils.d(TAG, "send msg:" + msg);
         }
-        Socket soc = mSocket.get();
+        Socket soc = socket;
         try {
             if (!soc.isClosed() && !soc.isOutputShutdown()) {
                 OutputStream os = soc.getOutputStream();
@@ -233,32 +241,28 @@ public class SocketService1 extends BaseService {
         } catch (IOException e) {
             LogUtils.d(TAG, "error" + e.getMessage());
             e.printStackTrace();
+            releaseLastSocket();
             return false;
         }
         return true;
     }
-
     private synchronized void releaseLastSocket() {
         try {
-            if (null != mSocket) {
-                Socket sk = mSocket.get();
-                if (!sk.isClosed()) {
-                    sk.close();
-                }
+            if (null != socket) {
+                socket.close();
             }
         } catch (IOException e) {
             LogUtils.d(TAG, "error" + e.getMessage());
             e.printStackTrace();
         } finally {
+            socket = null;
             readingMsg.setLength(0);
-            mSocket = null;
         }
     }
     private synchronized boolean recvMsg(StringBuilder msg) {
-        Socket socket = mSocket.get();
-        if (null == socket) {
+        if (null == socket || !socket.isConnected()) {
             return false;
         }
         try {
@@ -281,8 +285,10 @@ public class SocketService1 extends BaseService {
             }
         } catch (IOException e) {
             e.printStackTrace();
+            releaseLastSocket();
             return false;
         }
+
         return false;
     }
@@ -294,6 +300,8 @@ public class SocketService1 extends BaseService {
     ///end socket operation
     class InitSocketThread extends Thread {
+        private static final String TAG = "HeartBeatThread";
+
         @Override
         public void run() {
             super.run();
@@ -315,37 +323,64 @@ public class SocketService1 extends BaseService {
     // Thread to read content from Socket
     class ReadThread extends Thread {
+        private final String TAG = "ReadThread";
+        private long sleepTime = 0;
         @Override
         public void run() {
-            super.run();
-            if (!sendRegister.get()) {
-                LogUtils.d(TAG, "send register mes");
-                SocketSendMsg ssm = new SocketSendMsg().contractRegisterMsg(testRoomSn);
-                String msg = gson.toJson(ssm) + END_SYMBOL;
-                if (!sendMsg(msg)) {
-                    clearConnect();
-                    return;
-                }
-                LogUtils.d(TAG, "" + msg);
-                sendRegister.set(true);
-            }
-            LogUtils.d(TAG, "send register mes end");
             StringBuilder message = new StringBuilder();
-            while (recvMsg(message)) {
-                LogUtils.d(TAG, "recv msg:" + message);
+
+            LogUtils.d(TAG, "begin");
+
+            while (!isInterrupted()) {
                 try {
-                    SocketResponse socketResponse = gson.fromJson(message.toString(),
-                            SocketResponse.class);
+                    if (!sendRegister.get()) {
+                        LogUtils.d(TAG, "send register mes");
+                        SocketSendMsg ssm = new SocketSendMsg().contractRegisterMsg(testRoomSn);
+                        String msg = gson.toJson(ssm) + END_SYMBOL;
+                        if (!sendMsg(msg)) {
+                            Thread.sleep(READ_THREAD_DEFAULT_SLEEP_MTIME);
+                            continue;
+                        }
+                        LogUtils.d(TAG, "" + msg);
+                        sendRegister.set(true);
+                    } else {
+                        LogUtils.d(TAG, "already register");
+                    }
+                } catch (InterruptedException e) {
+                    continue;
+                }
+
+                LogUtils.d(TAG, "begin to recv msg");
+
+                sleepTime = READ_THREAD_DEFAULT_SLEEP_MTIME;
+recvMsgTag:
+                while (recvMsg(message)) {
+                    sleepTime = sleepTime;
+
+                    LogUtils.d(TAG, "recv msg:" + message);
+                    SocketResponse socketResponse;
+                    try {
+                        socketResponse = gson.fromJson(message.toString(),
+                                SocketResponse.class);
+                    } catch (JsonSyntaxException e) {
+                        LogUtils.e(TAG, "invalid msg:", message + e.getMessage());
+                        e.printStackTrace();
+                        clearConnect();
+                        break recvMsgTag;
+                    }
+
                     switch (socketResponse.getCode()) {
                         case SUCCESS_MESSAGE:
                             Log.d(TAG, "SUCCESS_MESSAGE");
                             break;
+
                         case VERIFY_SUCCESS:
                             LogUtils.d(TAG, "VERIFY_SUCCESS");
                             mHandler.post(heartBeatRunnable);
                             LogUtils.d(TAG, "verify success start heart beat");
                             break;
+
                         case HEART_BEAT_SUCCESS:
                             //每成功5次心跳判定是否启动main activity
                             if (++mainChargeCount == 5) {
@@ -358,20 +393,23 @@ public class SocketService1 extends BaseService {
                             boolean serviceLaunched = ActivityCollector.getActivity(MainActivity.class) != null;
                             Log.d(TAG, "HEART_BEAT_SUCCESS,MainActivity Launched:" + serviceLaunched);
                             break;
+
                         case HEART_BEAT_ERROR_SYMBOL:
                         case ROOM_SN_CONNECTED:
                             String msg1 = socketResponse.getCode() == HEART_BEAT_ERROR_SYMBOL ? "HEART_BEAT_ERROR_SYMBOL" : "ROOM_SN_CONNECTED";
                             LogUtils.d(TAG, msg1);
-                            clearConnect();
+//                            clearConnect();
                             LogUtils.d(TAG, msg1 + " before:" + +System.currentTimeMillis());
-                            try {
-                                Thread.sleep(10 * 1000);
-                            } catch (InterruptedException e) {
-                                e.printStackTrace();
-                            }
+//                                try {
+//                                    Thread.sleep(10 * 1000);
+//                                } catch (InterruptedException e) {
+//                                    e.printStackTrace();
+//                                }
+                            sleepTime = 10 * 1000;
                             LogUtils.d(TAG, msg1 + "  after:" + System.currentTimeMillis());
-                            new InitSocketThread().start();
+//                            new InitSocketThread().start();
                             break;
+
                         case RETURN_VERIFY_CODE:
                             LogUtils.d(TAG, "RETURN_VERIFY_CODE");
                             if (!TextUtils.isEmpty(socketResponse.getData().getVerify())) {
@@ -381,6 +419,7 @@ public class SocketService1 extends BaseService {
                                 sendMsg(msg);
                             }
                             break;
+
                         case CONTAIN_MESSAGE:
                             LogUtils.d(TAG, "CONTAIN_MESSAGE");
                             if (socketResponse.getData() != null) {
@@ -438,15 +477,21 @@ public class SocketService1 extends BaseService {
                                 }
                             }
                             break;
+
                         default:
                             LogUtils.d(TAG, "default msg:" + socketResponse.toString());
                     }
-                } catch (JsonSyntaxException e) {
-                    LogUtils.d(TAG, "error" + message + e.getMessage());
-                    e.printStackTrace();
+                    LogUtils.d(TAG, "recv msg:" + message);
+                }
+
+                try {
+                    Thread.sleep(sleepTime);
+                } catch (InterruptedException e) {
+                    continue;
                 }
-                LogUtils.d(TAG, "recv msg:" + message);
             }
+
+            LogUtils.d(TAG, "end");
         }
     }