From fc263810bfac2072d0143f0aa1fdea84e07398f5 Mon Sep 17 00:00:00 2001
From: unknown <zhongchao@zdauto.com>
Date: Mon, 26 Oct 2020 12:00:51 +0800
Subject: [PATCH] add websocket

---
 .idea/gradle.xml                              |   1 +
 .idea/misc.xml                                |   2 +-
 app/build.gradle                              |   2 +
 .../com/mogo/launcher/MogoApplication.java    |   1 +
 config.gradle                                 |   1 +
 foudations/mogo-base-websocket-sdk/.gitignore |   1 +
 .../mogo-base-websocket-sdk/build.gradle      |  47 +++++
 .../consumer-rules.pro                        |   0
 .../mogo-base-websocket-sdk/gradle.properties |   3 +
 .../proguard-rules.pro                        |  21 ++
 .../ExampleInstrumentedTest.java              |  26 +++
 .../src/main/AndroidManifest.xml              |   5 +
 .../websocket/IMogoWebSocketInitCallBack.java |   6 +
 .../base/websocket/WebSocketConstant.java     |  27 +++
 .../mogo/base/websocket/WebSocketData.java    |  36 ++++
 .../websocket/WebSocketHandlerThread.java     |  39 ++++
 .../mogo/base/websocket/WebSocketManager.java | 179 ++++++++++++++++++
 .../websocket/WebSocketShakeHandsData.java    |  55 ++++++
 .../ExampleUnitTest.java                      |  17 ++
 gradle.properties                             |   1 +
 .../com/mogo/service/IMogoServiceApis.java    |   6 +
 .../com/mogo/service/MogoServicePaths.java    |   6 +
 .../IMogoOnWebSocketMessageListener.java      |  13 ++
 .../connection/IMogoWebSocketManager.java     |  38 ++++
 .../service/connection/WebSocketMsgType.java  |  24 +++
 .../mogo/service/impl/MogoServiceApis.java    |   6 +
 .../impl/connection/MogoWebSocketManager.java |  63 ++++++
 settings.gradle                               |   1 +
 28 files changed, 626 insertions(+), 1 deletion(-)
 create mode 100644 foudations/mogo-base-websocket-sdk/.gitignore
 create mode 100644 foudations/mogo-base-websocket-sdk/build.gradle
 create mode 100644 foudations/mogo-base-websocket-sdk/consumer-rules.pro
 create mode 100644 foudations/mogo-base-websocket-sdk/gradle.properties
 create mode 100644 foudations/mogo-base-websocket-sdk/proguard-rules.pro
 create mode 100644 foudations/mogo-base-websocket-sdk/src/androidTest/java/com/mogo/mogo_base_websocket_sdk/ExampleInstrumentedTest.java
 create mode 100644 foudations/mogo-base-websocket-sdk/src/main/AndroidManifest.xml
 create mode 100644 foudations/mogo-base-websocket-sdk/src/main/java/com/mogo/base/websocket/IMogoWebSocketInitCallBack.java
 create mode 100644 foudations/mogo-base-websocket-sdk/src/main/java/com/mogo/base/websocket/WebSocketConstant.java
 create mode 100644 foudations/mogo-base-websocket-sdk/src/main/java/com/mogo/base/websocket/WebSocketData.java
 create mode 100644 foudations/mogo-base-websocket-sdk/src/main/java/com/mogo/base/websocket/WebSocketHandlerThread.java
 create mode 100644 foudations/mogo-base-websocket-sdk/src/main/java/com/mogo/base/websocket/WebSocketManager.java
 create mode 100644 foudations/mogo-base-websocket-sdk/src/main/java/com/mogo/base/websocket/WebSocketShakeHandsData.java
 create mode 100644 foudations/mogo-base-websocket-sdk/src/test/java/com/mogo/mogo_base_websocket_sdk/ExampleUnitTest.java
 create mode 100644 services/mogo-service-api/src/main/java/com/mogo/service/connection/IMogoOnWebSocketMessageListener.java
 create mode 100644 services/mogo-service-api/src/main/java/com/mogo/service/connection/IMogoWebSocketManager.java
 create mode 100644 services/mogo-service-api/src/main/java/com/mogo/service/connection/WebSocketMsgType.java
 create mode 100644 services/mogo-service/src/main/java/com/mogo/service/impl/connection/MogoWebSocketManager.java

diff --git a/.idea/gradle.xml b/.idea/gradle.xml
index 17ccda5417..c9845e981c 100644
--- a/.idea/gradle.xml
+++ b/.idea/gradle.xml
@@ -16,6 +16,7 @@
             <option value="$PROJECT_DIR$/foudations" />
             <option value="$PROJECT_DIR$/foudations/mogo-base-services-apk" />
             <option value="$PROJECT_DIR$/foudations/mogo-base-services-sdk" />
+            <option value="$PROJECT_DIR$/foudations/mogo-base-websocket-sdk" />
             <option value="$PROJECT_DIR$/foudations/mogo-commons" />
             <option value="$PROJECT_DIR$/foudations/mogo-utils" />
             <option value="$PROJECT_DIR$/libraries" />
diff --git a/.idea/misc.xml b/.idea/misc.xml
index 47f1a4e1d4..2db9aab721 100644
--- a/.idea/misc.xml
+++ b/.idea/misc.xml
@@ -4,7 +4,7 @@
     <asm skipDebug="false" skipFrames="false" skipCode="false" expandFrames="false" />
     <groovy codeStyle="LEGACY" />
   </component>
-  <component name="ProjectRootManager" version="2" languageLevel="JDK_1_8" project-jdk-name="1.8" project-jdk-type="JavaSDK">
+  <component name="ProjectRootManager" version="2" languageLevel="JDK_1_8" project-jdk-name="JDK" project-jdk-type="JavaSDK">
     <output url="file://$PROJECT_DIR$/build/classes" />
   </component>
   <component name="SuppressionsComponent">
diff --git a/app/build.gradle b/app/build.gradle
index 66fe428f2e..bb1d862a4d 100644
--- a/app/build.gradle
+++ b/app/build.gradle
@@ -356,6 +356,7 @@ dependencies {
     if (Boolean.valueOf(RELEASE)) {
         implementation rootProject.ext.dependencies.mogocommons
         implementation rootProject.ext.dependencies.modulecommon
+        implementation rootProject.ext.dependencies.mogobasewebsocketsdk
         implementation rootProject.ext.dependencies.modulesearch
         implementation rootProject.ext.dependencies.mogomoduleguide
         implementation rootProject.ext.dependencies.mogomoduleauth
@@ -373,6 +374,7 @@ dependencies {
         implementation rootProject.ext.dependencies.guideshow
     } else {
         implementation project(':foudations:mogo-commons')
+        implementation project(':foudations:mogo-base-websocket-sdk')
         implementation project(':modules:mogo-module-common')
         implementation project(':modules:mogo-module-search')
         implementation project(':modules:mogo-module-authorize')
diff --git a/app/src/main/java/com/mogo/launcher/MogoApplication.java b/app/src/main/java/com/mogo/launcher/MogoApplication.java
index 04f44e9a90..2c503b5345 100644
--- a/app/src/main/java/com/mogo/launcher/MogoApplication.java
+++ b/app/src/main/java/com/mogo/launcher/MogoApplication.java
@@ -189,6 +189,7 @@ public class MogoApplication extends AbsMogoApplication {
 
     private void prepareSocketAndLocationServices( IMogoServiceApis apis ) {
         apis.getSocketManagerApi( getApplicationContext() ).init( getApplicationContext(), DebugConfig.getSocketAppId() );
+        apis.getWebSocketManagerApi( getApplicationContext() ).init( getApplicationContext(), DebugConfig.getSocketAppId() );
         apis.getLocationInfoApi().start();
         apis.getMapServiceApi().getSingletonLocationClient( getApplicationContext() ).addLocationListener( location -> {
             apis.getLocationInfoApi().provideLocation( location );
diff --git a/config.gradle b/config.gradle
index 19335a59b4..cd5b71d3aa 100644
--- a/config.gradle
+++ b/config.gradle
@@ -174,6 +174,7 @@ targetSdkVersion               : 22,
             // 基础服务实现
             mogobaseservicesdk         : "com.mogo.base:services-sdk:${MOGO_BASE_SERVICES_SDK_VERSION}",
             mogobaseserviceapk         : "com.mogo.base:services-apk:${MOGO_BASE_SERVICES_APK_VERSION}",
+            mogobasewebsocketsdk         : "com.mogo.base:websocket-sdk:${MOGO_BASE_WEBSOCKET_SDK_VERSION}",
             // loglib
             mogologlib                 : "com.mogo.module:module-loglib:${LOGLIB_VERSION}",
             // monitor
diff --git a/foudations/mogo-base-websocket-sdk/.gitignore b/foudations/mogo-base-websocket-sdk/.gitignore
new file mode 100644
index 0000000000..42afabfd2a
--- /dev/null
+++ b/foudations/mogo-base-websocket-sdk/.gitignore
@@ -0,0 +1 @@
+/build
\ No newline at end of file
diff --git a/foudations/mogo-base-websocket-sdk/build.gradle b/foudations/mogo-base-websocket-sdk/build.gradle
new file mode 100644
index 0000000000..b5a25227ab
--- /dev/null
+++ b/foudations/mogo-base-websocket-sdk/build.gradle
@@ -0,0 +1,47 @@
+apply plugin: 'com.android.library'
+
+android {
+    compileSdkVersion rootProject.ext.android.compileSdkVersion
+
+    defaultConfig {
+        minSdkVersion rootProject.ext.android.minSdkVersion
+        targetSdkVersion rootProject.ext.android.targetSdkVersion
+        versionCode Integer.valueOf(VERSION_CODE)
+        versionName getValueFromRootProperties("${project.name.replace("-", "_").toUpperCase()}_VERSION")
+
+        testInstrumentationRunner "androidx.test.runner.AndroidJUnitRunner"
+        consumerProguardFiles "consumer-rules.pro"
+    }
+
+    buildTypes {
+        release {
+            minifyEnabled false
+            proguardFiles getDefaultProguardFile('proguard-android-optimize.txt'), 'proguard-rules.pro'
+        }
+    }
+
+    compileOptions {
+        sourceCompatibility JavaVersion.VERSION_1_8
+        targetCompatibility JavaVersion.VERSION_1_8
+    }
+}
+
+dependencies {
+    implementation fileTree(dir: "libs", include: ["*.jar"])
+    implementation rootProject.ext.dependencies.arouter
+
+    implementation "com.mogo.module.carchatting:module-carchatt-socket:1.1.1"
+
+    if (Boolean.valueOf(RELEASE)) {
+        implementation rootProject.ext.dependencies.mogoutils
+        implementation rootProject.ext.dependencies.mogocommons
+        implementation rootProject.ext.dependencies.mogoserviceapi
+    } else {
+        implementation project(":foudations:mogo-utils")
+        implementation project(":foudations:mogo-commons")
+        implementation project(":services:mogo-service-api")
+    }
+
+}
+
+apply from: new File(rootProject.rootDir, "gradle/upload.gradle").toString()
\ No newline at end of file
diff --git a/foudations/mogo-base-websocket-sdk/consumer-rules.pro b/foudations/mogo-base-websocket-sdk/consumer-rules.pro
new file mode 100644
index 0000000000..e69de29bb2
diff --git a/foudations/mogo-base-websocket-sdk/gradle.properties b/foudations/mogo-base-websocket-sdk/gradle.properties
new file mode 100644
index 0000000000..8c04f6273a
--- /dev/null
+++ b/foudations/mogo-base-websocket-sdk/gradle.properties
@@ -0,0 +1,3 @@
+GROUP=com.mogo.base
+POM_ARTIFACT_ID=websocket-sdk
+VERSION_CODE=1
\ No newline at end of file
diff --git a/foudations/mogo-base-websocket-sdk/proguard-rules.pro b/foudations/mogo-base-websocket-sdk/proguard-rules.pro
new file mode 100644
index 0000000000..481bb43481
--- /dev/null
+++ b/foudations/mogo-base-websocket-sdk/proguard-rules.pro
@@ -0,0 +1,21 @@
+# Add project specific ProGuard rules here.
+# You can control the set of applied configuration files using the
+# proguardFiles setting in build.gradle.
+#
+# For more details, see
+#   http://developer.android.com/guide/developing/tools/proguard.html
+
+# If your project uses WebView with JS, uncomment the following
+# and specify the fully qualified class name to the JavaScript interface
+# class:
+#-keepclassmembers class fqcn.of.javascript.interface.for.webview {
+#   public *;
+#}
+
+# Uncomment this to preserve the line number information for
+# debugging stack traces.
+#-keepattributes SourceFile,LineNumberTable
+
+# If you keep the line number information, uncomment this to
+# hide the original source file name.
+#-renamesourcefileattribute SourceFile
\ No newline at end of file
diff --git a/foudations/mogo-base-websocket-sdk/src/androidTest/java/com/mogo/mogo_base_websocket_sdk/ExampleInstrumentedTest.java b/foudations/mogo-base-websocket-sdk/src/androidTest/java/com/mogo/mogo_base_websocket_sdk/ExampleInstrumentedTest.java
new file mode 100644
index 0000000000..ab623f49dd
--- /dev/null
+++ b/foudations/mogo-base-websocket-sdk/src/androidTest/java/com/mogo/mogo_base_websocket_sdk/ExampleInstrumentedTest.java
@@ -0,0 +1,26 @@
+package com.mogo.mogo_base_websocket_sdk;
+
+import android.content.Context;
+
+import androidx.test.platform.app.InstrumentationRegistry;
+import androidx.test.ext.junit.runners.AndroidJUnit4;
+
+import org.junit.Test;
+import org.junit.runner.RunWith;
+
+import static org.junit.Assert.*;
+
+/**
+ * Instrumented test, which will execute on an Android device.
+ *
+ * @see <a href="http://d.android.com/tools/testing">Testing documentation</a>
+ */
+@RunWith(AndroidJUnit4.class)
+public class ExampleInstrumentedTest {
+    @Test
+    public void useAppContext() {
+        // Context of the app under test.
+        Context appContext = InstrumentationRegistry.getInstrumentation().getTargetContext();
+        assertEquals("com.mogo.mogo_base_websocket_sdk.test", appContext.getPackageName());
+    }
+}
\ No newline at end of file
diff --git a/foudations/mogo-base-websocket-sdk/src/main/AndroidManifest.xml b/foudations/mogo-base-websocket-sdk/src/main/AndroidManifest.xml
new file mode 100644
index 0000000000..164c03d1ce
--- /dev/null
+++ b/foudations/mogo-base-websocket-sdk/src/main/AndroidManifest.xml
@@ -0,0 +1,5 @@
+<manifest xmlns:android="http://schemas.android.com/apk/res/android"
+    package="com.mogo.base.websocket">
+
+    /
+</manifest>
\ No newline at end of file
diff --git a/foudations/mogo-base-websocket-sdk/src/main/java/com/mogo/base/websocket/IMogoWebSocketInitCallBack.java b/foudations/mogo-base-websocket-sdk/src/main/java/com/mogo/base/websocket/IMogoWebSocketInitCallBack.java
new file mode 100644
index 0000000000..6ed99a8d0f
--- /dev/null
+++ b/foudations/mogo-base-websocket-sdk/src/main/java/com/mogo/base/websocket/IMogoWebSocketInitCallBack.java
@@ -0,0 +1,6 @@
+package com.mogo.base.websocket;
+
+public interface IMogoWebSocketInitCallBack {
+
+    void init();
+}
diff --git a/foudations/mogo-base-websocket-sdk/src/main/java/com/mogo/base/websocket/WebSocketConstant.java b/foudations/mogo-base-websocket-sdk/src/main/java/com/mogo/base/websocket/WebSocketConstant.java
new file mode 100644
index 0000000000..8812ee6e76
--- /dev/null
+++ b/foudations/mogo-base-websocket-sdk/src/main/java/com/mogo/base/websocket/WebSocketConstant.java
@@ -0,0 +1,27 @@
+package com.mogo.base.websocket;
+
+
+import com.mogo.commons.debug.DebugConfig;
+
+public class WebSocketConstant {
+
+    private static final String HOST_DEV = "";
+    private static final String HOST_QA = "";
+    private static final String HOST_DEMO = "";
+    private static final String HOST_RELEASE = "";
+
+    public static String getSocketServer(){
+        switch (DebugConfig.getNetMode()){
+            case DebugConfig.NET_MODE_DEV:
+                return HOST_DEV;
+            case DebugConfig.NET_MODE_QA:
+                return HOST_QA;
+            case DebugConfig.NET_MODE_DEMO:
+                return HOST_DEMO;
+            case DebugConfig.NET_MODE_RELEASE:
+            default:
+                return HOST_RELEASE;
+
+        }
+    }
+}
diff --git a/foudations/mogo-base-websocket-sdk/src/main/java/com/mogo/base/websocket/WebSocketData.java b/foudations/mogo-base-websocket-sdk/src/main/java/com/mogo/base/websocket/WebSocketData.java
new file mode 100644
index 0000000000..d72eb438cb
--- /dev/null
+++ b/foudations/mogo-base-websocket-sdk/src/main/java/com/mogo/base/websocket/WebSocketData.java
@@ -0,0 +1,36 @@
+package com.mogo.base.websocket;
+
+import java.io.Serializable;
+
+public class WebSocketData<T> implements Serializable {
+
+    private long seq;
+
+    private int msgType;
+
+    private T t;
+
+    public long getSeq() {
+        return seq;
+    }
+
+    public void setSeq(long seq) {
+        this.seq = seq;
+    }
+
+    public int getMsgType() {
+        return msgType;
+    }
+
+    public void setMsgType(int msgType) {
+        this.msgType = msgType;
+    }
+
+    public T getT() {
+        return t;
+    }
+
+    public void setT(T t) {
+        this.t = t;
+    }
+}
diff --git a/foudations/mogo-base-websocket-sdk/src/main/java/com/mogo/base/websocket/WebSocketHandlerThread.java b/foudations/mogo-base-websocket-sdk/src/main/java/com/mogo/base/websocket/WebSocketHandlerThread.java
new file mode 100644
index 0000000000..e26eb49929
--- /dev/null
+++ b/foudations/mogo-base-websocket-sdk/src/main/java/com/mogo/base/websocket/WebSocketHandlerThread.java
@@ -0,0 +1,39 @@
+package com.mogo.base.websocket;
+
+import android.os.Handler;
+import android.os.HandlerThread;
+import android.os.Message;
+
+import com.mogo.utils.logger.Logger;
+import com.mogo.websocket.SocketClient;
+
+public class WebSocketHandlerThread extends HandlerThread {
+
+    private Handler mHandler;
+    private String tag;
+
+    private static final int MSG_SEND = 1;
+
+    public WebSocketHandlerThread(String name) {
+        super(name);
+        tag = name;
+        mHandler = new Handler(this.getLooper()) {
+            @Override
+            public void handleMessage(Message msg) {
+                super.handleMessage(msg);
+                if (msg.what == MSG_SEND) {
+                    Logger.d(tag, "WebSocketHandlerThread handleMessage = %d", msg.obj.toString());
+                    SocketClient.getInstance().getClientProxy().sendMessage(msg.obj.toString());
+                }
+            }
+        };
+    }
+
+    public void sendMsg(String msg) {
+        Message message = new Message();
+        message.what = MSG_SEND;
+        message.obj = msg;
+        mHandler.sendMessage(message);
+    }
+
+}
diff --git a/foudations/mogo-base-websocket-sdk/src/main/java/com/mogo/base/websocket/WebSocketManager.java b/foudations/mogo-base-websocket-sdk/src/main/java/com/mogo/base/websocket/WebSocketManager.java
new file mode 100644
index 0000000000..948b9d5208
--- /dev/null
+++ b/foudations/mogo-base-websocket-sdk/src/main/java/com/mogo/base/websocket/WebSocketManager.java
@@ -0,0 +1,179 @@
+package com.mogo.base.websocket;
+
+import android.content.Context;
+
+import androidx.annotation.Keep;
+
+import com.google.gson.Gson;
+import com.mogo.commons.network.Utils;
+import com.mogo.service.connection.IMogoMsgAckListener;
+import com.mogo.service.connection.IMogoOnWebSocketMessageListener;
+import com.mogo.service.connection.IMogoWebSocketManager;
+import com.mogo.utils.logger.Logger;
+import com.mogo.utils.network.utils.GsonUtil;
+import com.mogo.websocket.ISocketMsgCallBack;
+import com.mogo.websocket.ISocketMsgSetting;
+import com.mogo.websocket.SocketClient;
+
+import java.util.ArrayList;
+import java.util.Iterator;
+import java.util.List;
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
+
+import static com.mogo.service.connection.WebSocketMsgType.MSG_TYPE_SERVER;
+
+@Keep
+public class WebSocketManager implements IMogoWebSocketManager, ISocketMsgSetting, ISocketMsgCallBack {
+
+    private static final String TAG = "WebSocketManager-sdk";
+
+    private static volatile WebSocketManager sInstance;
+    private WebSocketHandlerThread handlerThread;
+
+    public WebSocketManager(Context context) {
+        handlerThread = new WebSocketHandlerThread(TAG);
+        handlerThread.start();
+    }
+
+    @Keep
+    public static WebSocketManager getInstance(Context context) {
+        if (sInstance == null) {
+            synchronized (WebSocketManager.class) {
+                if (sInstance == null) {
+                    sInstance = new WebSocketManager(context);
+                }
+            }
+        }
+        return sInstance;
+    }
+
+    /**
+     * 管理消息分发
+     * <p>
+     * key - msgType
+     */
+    private Map<Integer, List<IMogoOnWebSocketMessageListener>> mListeners = new ConcurrentHashMap<>();
+
+    /**
+     * 管理消息回执
+     * <p>
+     * key - msgId
+     */
+    private Map<Long, IMogoMsgAckListener> mAckListeners = new ConcurrentHashMap<>();
+
+    @Override
+    public void init(Context context, String appId) {
+        SocketClient.getInstance().getClientProxy().initSocketServer(WebSocketConstant.getSocketServer());
+        SocketClient.getInstance().getClientProxy().getMessageSettings(this);
+        SocketClient.getInstance().getClientProxy().addISocketMsgCallBack(this);
+        SocketClient.getInstance().getClientProxy().startConnect();
+    }
+
+    @Override
+    public void registerOnWebSocketMessageListener(IMogoOnWebSocketMessageListener listener) {
+        if (listener.getType() == null) {
+            Logger.w(TAG, "websocket registerListener msgType is not exist");
+            return;
+        }
+        int msgType = listener.getType().getMsgType();
+        if (mListeners.containsKey(msgType)) {
+            Logger.w(TAG, "websocket msgType %d is exist.", msgType);
+        }
+        if (!mListeners.containsKey(msgType)) {
+            mListeners.put(msgType, new ArrayList<>());
+        }
+        mListeners.get(msgType).add(listener);
+        Logger.d(TAG, "websocket add listener success");
+    }
+
+    @Override
+    public void unregisterOnWebSocketMessageListener(IMogoOnWebSocketMessageListener listener) {
+        if (listener == null) {
+            return;
+        }
+        if (listener.getType() == null) {
+            Logger.w(TAG, "websocket unregisterListener msgType is not exist");
+            return;
+        }
+        int msgType = listener.getType().getMsgType();
+        if (!mListeners.containsKey(msgType)) {
+            return;
+        }
+        List<IMogoOnWebSocketMessageListener> listeners = mListeners.get(msgType);
+        if (listeners != null && listeners.contains(listener)) {
+            listeners.remove(listener);
+            Logger.d(TAG, "websocket remove listener success");
+        }
+    }
+
+    @Override
+    public void sendMsg(Object body, IMogoOnWebSocketMessageListener listener) {
+        Logger.d(TAG, "websocket sendMsg body = %d , listener = %d ", body, listener);
+        if (handlerThread != null) {
+            WebSocketData webSocketData = new WebSocketData();
+            webSocketData.setSeq(System.currentTimeMillis());
+            webSocketData.setMsgType(listener.getType().getMsgType());
+            webSocketData.setT(body);
+            handlerThread.sendMsg(new Gson().toJson(webSocketData));
+        }
+    }
+
+    @Override
+    public void init(Context context) {
+
+    }
+
+    @Override
+    public void onConnectOpen() {
+        Logger.d(TAG, "websocket onConnectOpen");
+    }
+
+    @Override
+    public void handleMessage(String message) {
+        Logger.d(TAG, "websocket received msg = %d ", message);
+        WebSocketData webSocketData = GsonUtil.objectFromJson(message, WebSocketData.class);
+        int msgType = webSocketData.getMsgType();
+        Logger.d(TAG, "websocket received msg type = %d", msgType);
+        //服务端下发数据返回，上传数据回执默认不返回
+        if (msgType == MSG_TYPE_SERVER.getMsgType()) {
+            List<IMogoOnWebSocketMessageListener> listeners = mListeners.get(msgType);
+            if (listeners != null && !listeners.isEmpty()) {
+                Iterator<IMogoOnWebSocketMessageListener> iterator = listeners.iterator();
+                while (iterator.hasNext()) {
+                    IMogoOnWebSocketMessageListener listener = iterator.next();
+                    if (listener != null) {
+                        Logger.d(TAG, "received msgId = %s, content = %s", webSocketData.getSeq(), webSocketData.getT().toString());
+                        listener.onMsgReceived(webSocketData.getT());
+                    }
+                }
+            }
+        }
+    }
+
+    @Override
+    public void onConnectClose() {
+        Logger.d(TAG, "websocket ready to reconnect");
+        SocketClient.getInstance().getClientProxy().reConnect();
+    }
+
+    @Override
+    public void handleError(Exception e) {
+        Logger.e(TAG, "websocket handleError : %d", e.getMessage());
+    }
+
+    @Override
+    public String getHandShakeMsg() {
+        WebSocketShakeHandsData webSocketShakeHandData = new WebSocketShakeHandsData(
+                System.currentTimeMillis(),
+                Utils.getSn(),
+                true
+        );
+        return GsonUtil.jsonFromObject(webSocketShakeHandData);
+    }
+
+    @Override
+    public String getHeartBeatMsg() {
+        return null;
+    }
+}
diff --git a/foudations/mogo-base-websocket-sdk/src/main/java/com/mogo/base/websocket/WebSocketShakeHandsData.java b/foudations/mogo-base-websocket-sdk/src/main/java/com/mogo/base/websocket/WebSocketShakeHandsData.java
new file mode 100644
index 0000000000..9ac94d62ae
--- /dev/null
+++ b/foudations/mogo-base-websocket-sdk/src/main/java/com/mogo/base/websocket/WebSocketShakeHandsData.java
@@ -0,0 +1,55 @@
+package com.mogo.base.websocket;
+
+import java.io.Serializable;
+
+public class WebSocketShakeHandsData implements Serializable {
+
+    public WebSocketShakeHandsData(){
+
+    }
+
+    public WebSocketShakeHandsData(long seq, String sn, boolean bind) {
+        this.seq = seq;
+        this.sn = sn;
+        this.bind = bind;
+    }
+
+    /**
+     * 请求序列号
+     */
+    private long seq;
+
+    /**
+     * 车机sn
+     */
+    private String sn;
+
+    /**
+     * 是否申请通道绑定
+     */
+    private boolean bind;
+
+    public long getSeq() {
+        return seq;
+    }
+
+    public void setSeq(long seq) {
+        this.seq = seq;
+    }
+
+    public String getSn() {
+        return sn;
+    }
+
+    public void setSn(String sn) {
+        this.sn = sn;
+    }
+
+    public boolean isBind() {
+        return bind;
+    }
+
+    public void setBind(boolean bind) {
+        this.bind = bind;
+    }
+}
diff --git a/foudations/mogo-base-websocket-sdk/src/test/java/com/mogo/mogo_base_websocket_sdk/ExampleUnitTest.java b/foudations/mogo-base-websocket-sdk/src/test/java/com/mogo/mogo_base_websocket_sdk/ExampleUnitTest.java
new file mode 100644
index 0000000000..36ec8a5bae
--- /dev/null
+++ b/foudations/mogo-base-websocket-sdk/src/test/java/com/mogo/mogo_base_websocket_sdk/ExampleUnitTest.java
@@ -0,0 +1,17 @@
+package com.mogo.mogo_base_websocket_sdk;
+
+import org.junit.Test;
+
+import static org.junit.Assert.*;
+
+/**
+ * Example local unit test, which will execute on the development machine (host).
+ *
+ * @see <a href="http://d.android.com/tools/testing">Testing documentation</a>
+ */
+public class ExampleUnitTest {
+    @Test
+    public void addition_isCorrect() {
+        assertEquals(4, 2 + 2);
+    }
+}
\ No newline at end of file
diff --git a/gradle.properties b/gradle.properties
index 98d245ce8e..20a7a16067 100644
--- a/gradle.properties
+++ b/gradle.properties
@@ -60,6 +60,7 @@ MOGO_MODULE_V2X_VERSION=2.0.0
 # 基础服务实现：passport、socket、location
 MOGO_BASE_SERVICES_APK_VERSION = 2.0.0
 MOGO_BASE_SERVICES_SDK_VERSION = 2.0.0
+MOGO_BASE_WEBSOCKET_SDK_VERSION = 1.0.0
 ## 工程外部模块
 # 探路
 MOGO_MODULE_TANLU_VERSION=2.0.0
diff --git a/services/mogo-service-api/src/main/java/com/mogo/service/IMogoServiceApis.java b/services/mogo-service-api/src/main/java/com/mogo/service/IMogoServiceApis.java
index f6e0f9ee03..b33adead45 100644
--- a/services/mogo-service-api/src/main/java/com/mogo/service/IMogoServiceApis.java
+++ b/services/mogo-service-api/src/main/java/com/mogo/service/IMogoServiceApis.java
@@ -8,6 +8,7 @@ import com.mogo.service.analytics.IMogoAnalytics;
 import com.mogo.service.auth.IMogoAuthManager;
 import com.mogo.service.cardmanager.IMogoCardManager;
 import com.mogo.service.connection.IMogoSocketManager;
+import com.mogo.service.connection.IMogoWebSocketManager;
 import com.mogo.service.datamanager.IMogoDataManager;
 import com.mogo.service.entrance.IMogoEntranceButtonController;
 import com.mogo.service.eventpanel.IEventPanelProvider;
@@ -69,6 +70,11 @@ public interface IMogoServiceApis extends IProvider {
      */
     IMogoSocketManager getSocketManagerApi( Context context );
 
+    /**
+     * 获取WebSocket操作api
+     */
+    IMogoWebSocketManager getWebSocketManagerApi( Context context );
+
     /**
      * 大而全的数据管理接口
      *
diff --git a/services/mogo-service-api/src/main/java/com/mogo/service/MogoServicePaths.java b/services/mogo-service-api/src/main/java/com/mogo/service/MogoServicePaths.java
index 8184350abf..90110ecd81 100644
--- a/services/mogo-service-api/src/main/java/com/mogo/service/MogoServicePaths.java
+++ b/services/mogo-service-api/src/main/java/com/mogo/service/MogoServicePaths.java
@@ -51,6 +51,12 @@ public class MogoServicePaths {
     @Deprecated
     public static final String PATH_SOCKET_MANAGER = "/socket/manager";
 
+    /**
+     * WebSocket 长链
+     */
+    @Deprecated
+    public static final String PATH_WEB_SOCKET_MANAGER = "/websocket/manager";
+
     /**
      * 状态管理接口
      */
diff --git a/services/mogo-service-api/src/main/java/com/mogo/service/connection/IMogoOnWebSocketMessageListener.java b/services/mogo-service-api/src/main/java/com/mogo/service/connection/IMogoOnWebSocketMessageListener.java
new file mode 100644
index 0000000000..fb3bcb0769
--- /dev/null
+++ b/services/mogo-service-api/src/main/java/com/mogo/service/connection/IMogoOnWebSocketMessageListener.java
@@ -0,0 +1,13 @@
+package com.mogo.service.connection;
+
+/**
+ * 消息回调
+ */
+public interface IMogoOnWebSocketMessageListener< T > {
+
+    WebSocketMsgType getType();
+
+    void onMsgReceived(T obj);
+
+    void onError(String errorMsg);
+}
diff --git a/services/mogo-service-api/src/main/java/com/mogo/service/connection/IMogoWebSocketManager.java b/services/mogo-service-api/src/main/java/com/mogo/service/connection/IMogoWebSocketManager.java
new file mode 100644
index 0000000000..1409b2b2c3
--- /dev/null
+++ b/services/mogo-service-api/src/main/java/com/mogo/service/connection/IMogoWebSocketManager.java
@@ -0,0 +1,38 @@
+package com.mogo.service.connection;
+
+import android.content.Context;
+
+import com.alibaba.android.arouter.facade.template.IProvider;
+
+public interface IMogoWebSocketManager<T> extends IProvider {
+
+    /**
+     * 初始化，各模块不用关心
+     *
+     * @param context 上下文
+     * @param appId   一般为包名，不参与通道的建立，一般用于发消息
+     */
+    void init( Context context, String appId );
+
+    /**
+     * 注册消息监听
+     *
+     * @param listener 回调
+     */
+    void registerOnWebSocketMessageListener(IMogoOnWebSocketMessageListener listener );
+
+    /**
+     * 注销消息监听
+     *
+     */
+    void unregisterOnWebSocketMessageListener(IMogoOnWebSocketMessageListener listener );
+
+    /**
+     * 发送消息
+     *
+     * @param body     消息体
+     * @param listener 回执监听
+     */
+    void sendMsg( T body, IMogoOnWebSocketMessageListener listener );
+
+}
diff --git a/services/mogo-service-api/src/main/java/com/mogo/service/connection/WebSocketMsgType.java b/services/mogo-service-api/src/main/java/com/mogo/service/connection/WebSocketMsgType.java
new file mode 100644
index 0000000000..5718ac44bc
--- /dev/null
+++ b/services/mogo-service-api/src/main/java/com/mogo/service/connection/WebSocketMsgType.java
@@ -0,0 +1,24 @@
+package com.mogo.service.connection;
+
+public enum WebSocketMsgType {
+
+    MSG_TYPE_SELF(0,"自车数据"),
+    MSG_TYPE_ADAS(1,"ADAS数据"),
+    MSG_TYPE_SERVER(2,"服务端下发车辆信息");
+
+    private int msgType;
+    private String msg;
+
+    WebSocketMsgType(int msgType, String msg) {
+        this.msgType = msgType;
+        this.msg = msg;
+    }
+
+    public int getMsgType() {
+        return msgType;
+    }
+
+    public void setMsgType(int msgType) {
+        this.msgType = msgType;
+    }
+}
diff --git a/services/mogo-service/src/main/java/com/mogo/service/impl/MogoServiceApis.java b/services/mogo-service/src/main/java/com/mogo/service/impl/MogoServiceApis.java
index 36f61a534f..a1b5529e3a 100644
--- a/services/mogo-service/src/main/java/com/mogo/service/impl/MogoServiceApis.java
+++ b/services/mogo-service/src/main/java/com/mogo/service/impl/MogoServiceApis.java
@@ -12,6 +12,7 @@ import com.mogo.service.analytics.IMogoAnalytics;
 import com.mogo.service.auth.IMogoAuthManager;
 import com.mogo.service.cardmanager.IMogoCardManager;
 import com.mogo.service.connection.IMogoSocketManager;
+import com.mogo.service.connection.IMogoWebSocketManager;
 import com.mogo.service.datamanager.IMogoDataManager;
 import com.mogo.service.entrance.IMogoEntranceButtonController;
 import com.mogo.service.eventpanel.IEventPanelProvider;
@@ -72,6 +73,11 @@ public class MogoServiceApis implements IMogoServiceApis {
         return getApiInstance( IMogoSocketManager.class, MogoServicePaths.PATH_SOCKET_MANAGER );
     }
 
+    @Override
+    public IMogoWebSocketManager getWebSocketManagerApi(Context context) {
+        return getApiInstance( IMogoWebSocketManager.class, MogoServicePaths.PATH_WEB_SOCKET_MANAGER );
+    }
+
     @Override
     public IMogoFragmentManager getFragmentManagerApi() {
         return SingletonsHolder.get( IMogoFragmentManager.class );
diff --git a/services/mogo-service/src/main/java/com/mogo/service/impl/connection/MogoWebSocketManager.java b/services/mogo-service/src/main/java/com/mogo/service/impl/connection/MogoWebSocketManager.java
new file mode 100644
index 0000000000..7073fcad5e
--- /dev/null
+++ b/services/mogo-service/src/main/java/com/mogo/service/impl/connection/MogoWebSocketManager.java
@@ -0,0 +1,63 @@
+package com.mogo.service.impl.connection;
+
+import android.content.Context;
+
+import com.alibaba.android.arouter.facade.annotation.Route;
+import com.mogo.service.connection.IMogoOnWebSocketMessageListener;
+import com.mogo.service.connection.IMogoWebSocketManager;
+import com.mogo.utils.logger.Logger;
+
+import java.lang.reflect.Method;
+
+import static com.mogo.service.MogoServicePaths.PATH_WEB_SOCKET_MANAGER;
+
+@Route(path = PATH_WEB_SOCKET_MANAGER)
+public class MogoWebSocketManager implements IMogoWebSocketManager {
+
+    private static final String TAG = "MogoWebSocketManager";
+    private IMogoWebSocketManager mDelegate;
+
+    @Override
+    public void init(Context context, String appId) {
+        if (mDelegate != null) {
+            mDelegate.init(context, appId);
+        }
+    }
+
+    @Override
+    public void registerOnWebSocketMessageListener(int msgType, IMogoOnWebSocketMessageListener listener) {
+        if (mDelegate != null) {
+            mDelegate.registerOnWebSocketMessageListener(msgType, listener);
+        }
+    }
+
+    @Override
+    public void unregisterOnWebSocketMessageListener(int msgType, IMogoOnWebSocketMessageListener listener) {
+        if (mDelegate != null) {
+            mDelegate.unregisterOnWebSocketMessageListener(msgType, listener);
+        }
+    }
+
+    @Override
+    public void sendMsg(Object body, IMogoOnWebSocketMessageListener listener) {
+        if (mDelegate != null) {
+            mDelegate.sendMsg(body, listener);
+        }
+    }
+
+    @Override
+    public void init(Context context) {
+        try {
+            Class<?> clazz = Class.forName("com.mogo.base.websocket.WebSocketManager");
+            Method getInstanceMethod = clazz.getMethod("getInstance", Context.class);
+            getInstanceMethod.setAccessible(true);
+            mDelegate = (IMogoWebSocketManager) getInstanceMethod.invoke(null, context);
+        } catch (Exception e) {
+            Logger.e(TAG, e, "error.");
+        }
+
+        if (mDelegate != null) {
+            mDelegate.init(context);
+        }
+    }
+}
diff --git a/settings.gradle b/settings.gradle
index 2521b83254..a72b2bd046 100644
--- a/settings.gradle
+++ b/settings.gradle
@@ -1,3 +1,4 @@
+include ':foudations:mogo-base-websocket-sdk'
 include ':tts:tts-base'
 include ':tts:tts-di'
 include ':tts:tts-zhi'