处理收不到广播

lmw

2023-06-21 bd6a8872438a35d47821c5d5da7fe149e5fed3ab

 rxnetty/src/main/java/cn/sinata/rxnetty/NettyClient.java

@@ -4,8 +4,14 @@
import android.content.Context;
import android.content.Intent;
import android.os.Build;
import android.os.Handler;
import android.widget.Toast;

import java.util.ArrayList;

import cn.sinata.rxnetty.Cache.CacheUtil;

import static android.os.Looper.getMainLooper;

/**
 * 使用的是rxjava1。而不是rxjava2。所以尽量不要在主项目中使用rxjava1相关类。以免交叉。不好维护修改。
@@ -19,6 +25,7 @@
    private OnSendListener sendListener;
    private OnConnectListener connectListener;
    private OnCheckListener onCheckListener;
    private OnCheckListenerNull onCheckListenerNull;

    public void init(Context context,String server,int port) {
        init(context,server,port,false);
@@ -29,6 +36,10 @@
        Config.SOCKET_SERVER = server;
        Config.SOCKET_PORT = port;
        Config.isStartForeground= isStartForeground;
    }

    public Context getmContext() {
        return mContext;
    }

    public OnConnectListener getConnectListener() {
@@ -90,6 +101,9 @@
    void setOnCheckListener(OnCheckListener listener) {
        this.onCheckListener = listener;
    }
    void setOnCheckNullListener(OnCheckListenerNull listener){
        this.onCheckListenerNull = listener;
    }

    /**
     * 发送消息给服务器
@@ -109,6 +123,12 @@
            onCheckListener.doCheck();
        }
    }
    public void checkNettyStateNull() {
        if (onCheckListenerNull != null) {
            onCheckListenerNull.doCheck();
        }
    }


    public void startService() {
        if (mContext == null) {