Android：如何正确使用Gottox / socket.io-java-client库？

我有服务.我创建了一个Thread,用于在此Service中的单独线程上使用socket.io- java-client库.

我用以下方式保持线程：

@Override
public void run() {
    while (canLiveThread) {
    //  keep thread
    }
}

这种方式完全错了是吗？要解决此解决方案,我需要找到以下问题的答案：

1.我是否需要单独创建线程以在服务中使用socket.io-java-client库？或者我可以在没有线程的情况下使用这个库,只需在服务中实现socket.io-java-client库？

2.如果需要创建线程来使用这个库,那么如何在后台服务中以正确的方式管理线程以不耗尽电池？

如果有人有任何解决方案,请回答这个问题……

提前致谢！

解决方法

实际上,我不知道我是否正确使用socket-io-client,但我试着完全清楚.
据我所知,socket-io-client已经在使用后台线程来连接,发送,接收事件.

第一种方式

我认为这不是你想要的,但我尽可能地展示了这个变种.
所以,首先,我创建了一个SocketClient,如下所示：

public class SocketClient implements IOCallback {

    private SocketIO socket;
    private Context context; // for some cases (i.e. broadcasting via LocalbroadcastManager).

    public SocketClient(Context context) {
       this.context = context;
    }

    public synchronized void connect() {
        if (socket == null || !socket.isConnected()) {
            Properties properties = new Properties();
            // setting your properties...
            try {
                socket = new SocketIO("http://your.address",properties);
                socket.connect(this);
            } catch (MalformedURLException e) {
                Log.e("SocketClientException",e.getMessage());
            }
        }
    }

    @Override
    public void ondisconnect() {

    }

    @Override
    public void onConnect() {

    }

    @Override
    public void onMessage(String data,IOAckNowledge ack) {

    }

    @Override
    public void onMessage(JsonElement json,IOAckNowledge ack) {

    }

    @Override
    public void on(String event,IOAckNowledge ack,JsonElement... args) {
        LocalbroadcastManager.getInstance(context).sendbroadcast(new Intent("action_on"));
    }

    @Override
    public void onError(SocketIOException socketIOException) {

    }

}

然后我创建了一个包含SocketClient的Singleton：

public class API {

    private static API instance;
    private SocketClient client;

    private API() {
    }

    public static API getInstance() {
        if (instance == null) {
            instance = new API();
        }
        return instance;
    }

    public void init(Context context) {
        client = new SocketClient(context);
    }

    public SocketClient getSocketIO() {
        return client;
    }
}

然后在Service类onCreate()方法中,我只是调用我的单例：

@Override
public void onCreate() {
    super.onCreate();
    Log.i("SocketService","onCreate");
    API.getInstance().init(getApplicationContext());
    API.getSocketIO().connect();
}

之后,只要一个服务,套接字就会处于活动状态,这样我们就可以通过我们的单例从应用程序的任何地方接收,发送套接字命令.我们可以通过LocalbroadcastManager从SocketClient中的onMessage方法发送接收到的数据.

第二种方式

让我们尝试实现一个SocketService：

public class SocketService extends Service implements IOCallback {
    private SocketIO socket;

    private synchronized void connect() {
        if (socket == null || !socket.isConnected()) {
            Properties properties = new Properties();
            // setting your properties...
            try {
                socket = new SocketIO("http://your.address",e.getMessage());
            }
        }
    }

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

    @Override
    public void ondisconnect() {

    }

    @Override
    public void onConnect() {

    }

    @Override
    public void onMessage(String data,JsonElement... args) {
         LocalbroadcastManager.getInstance(this).sendbroadcast(new Intent("action_on"));
    }

    @Override
    public void onError(SocketIOException socketIOException) {

    }
}

就这样.您可以从您的活动中启动服务,并通过广播或消息处理程序进行通信.我从来没有尝试过第二种方式,但我认为它应该像魅力一样.

结论

这些方法中没有一个使用单独的后台线程,并且它对我有用,我有三个基于第一种方式的应用程序,并且所有这些应用程序都在后台工作而没有任何支持.希望答案对SocketIO使用中的所有有趣内容都有帮助:)