Android10 嵌入Websocket客户端

1. 依赖包引用，在build.gradle里加入这个依赖

注意：如果引用版本过低的话，没有断线重连的功能，我目前用的是这个版本

    implementation "org.java-websocket:Java-WebSocket:1.5.1"

2. 新建一个工具类 WebSocketUtil

这里是把ws做成的单例模式，方便在不同的地方调用

public class WebSocketUtil {
    public static WebSocketClient webSocketClient = null;
    public static Context s_context;
    private static TaskListener listener;

    public static WebSocketClient inistance(Context context){
        if(webSocketClient == null){
            init();
        }

        s_context = context;
        return webSocketClient;
    }

    public static void addListener(TaskListener taskListener){
        listener = taskListener;
    }

    private static void init(){
        URI serverURI = URI.create(Constants.WebSocket_URL);

        webSocketClient = new WebSocketClient(serverURI) {
            @Override
            public void onOpen(ServerHandshake handshakedata) {
                App.log( "WebSocket已连接=============================");
            }

            @Override
            public void onMessage(String message) {
                App.log( "收到服务器消息：" + message);
            }

            @Override
            public void onClose(int code, String reason, boolean remote) {
                App.log( "WebSocket已关闭");
            }

            @Override
            public void onError(Exception ex) {
                App.log( "服务器状态：" + ex.toString());
            }
        };
    }

    // 这个是我自己业务逻辑去验证链接合法性的
    private static void auth(String client_id){
        String deviceKey = App.getSharedPreferences().getString(Sp.DeviceKey, "");

        RequestUtil.AuthClient(deviceKey, client_id, new BaseListener() {
            @Override
            public void suc(Object suc) {
                Util.showLargeLog(TAG, suc + "", 4000);
            }

            @Override
            public void err(Object err) {
                App.log( "err: " + err);
            }
        });
    }
}

3. 在入口类中初始化Websocket，同时用Timer来监听

每10秒检查一次当前ws的连接状态，如果不是连接中的话判定为断开，同时发起重连

    @Override
    public void onCreate() {
        super.onCreate();
        application = this;
        context = getApplicationContext();
        
        // 初始化Websocket
        WebSocketUtil.inistance(context).connect();

        // 写一个Timer，来保证ws保持连接
        keepWebSocketConnect();
    }

    public void keepWebSocketConnect(){
        if (timer == null) {
            timer = new Timer();
        }
        timer.schedule(new TimerTask() {
            @Override
            public void run() {
                if( ! WebSocketUtil.inistance(context).getReadyState().equals(ReadyState.OPEN)){
                    App.log( "守护进程判定ws已关闭，尝试重连");
                    WebSocketUtil.inistance(context).reconnect();
                }
            }
        }, 0, 10 * 1000);
    }

4. 写一个监听类，用来监听ws服务端传来的消息，并且随意映射到当前的Activity

public interface TaskListener {
    String SYSTEM_UPDATE = "SYSTEM_UPDATE";
    String SYSTEM_REBOOT = "SYSTEM_REBOOT";
    String MEET_REFRESH = "MEET_REFRESH";
    String DEBUG = "debug";

    void task_message(String TaskName, String param);
}

5. 在你想要接收ws通信的页面Activity里，加入这个监听器，并重写监听方法即可。

这里的Taskname之类的参数是你和服务端那边统一约定就行，没有什么限制

public class MainActivity extends AppCompatActivity implements TaskListener {

    @Override
    public void task_message(String TaskName, String param) {
        App.log("接收到TASK指令，TaskName:" + TaskName + ", param:" + param);

        // 这里的Taskname和服务端那边约定好类型就可以了，没有什么限制的，然后匹配到对应的操作
        switch (TaskName) {
            case TaskListener.SYSTEM_UPDATE:
                SystemHelper.wakeUpAndUnlock(this);
                runOnUiThread(() -> SystemHelper.update(MainActivity.this, param));
                break;
            case TaskListener.SYSTEM_REBOOT:
                SystemHelper.wakeUpAndUnlock(this);
                SpeechHelper.speech(this, "系统即将重启");
                break;
            case TaskListener.MEET_REFRESH:
                SystemHelper.wakeUpAndUnlock(this);
                SpeechHelper.speech(this, "收到下发资料");
                break;
            case TaskListener.DEBUG:
                SystemHelper.wakeUpAndUnlock(this);
                SpeechHelper.speech(this, "收到服务器指令");
                new Thread(()
                        -> runOnUiThread(()
                        -> Toast.makeText(MainActivity.this, "交互指令：" + param, Toast.LENGTH_SHORT).show()
                )).start();
                break;
            default:
                SystemHelper.wakeUpAndUnlock(this);
                SpeechHelper.speech(this, "无效命令");
                break;
        }
    }
}