Android:如何用正确的方式使用Gottox/socket.io-java-client库？

Question

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

我用以下方式来维持线：

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

这条路完全错了，是吗？要解决这个问题，我需要找到以下问题的答案：

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

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

如果有人有解决办法，请回答这个问题.

提前谢谢！

Answer 1

实际上，我不知道我如何正确地使用socket-io-client，但我尝试完全清楚。据我所知，socket-io-client已经在使用后台线程连接、发送、接收事件。

FIRST WAY

我认为这不是你想要的，但我尽可能地展示这个变体。首先，我创建了一个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) {

    }

}

然后我创建了一个Singleton，它保存了我们的SocketClient

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();
}

此后，套接字将与Service一样有效，因此我们将能够从应用程序中的任何地方通过我们的单例在后台接收、发送套接字命令。我们可以通过LocalBroadcastManager将接收到的数据从on、onMessage方法发送到SocketClient中。

第二道

让我们尝试实现一个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", properties);
                socket.connect(this);
            } catch (MalformedURLException e) {
                Log.e("SocketClientException", e.getMessage());
            }
        }
    }

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

    @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(this).sendBroadcast(new Intent("action_on"));
    }

    @Override
    public void onError(SocketIOException socketIOException) {

    }
}

就这样。您可以通过您的活动进行startService，并通过广播或消息处理程序进行通信。我从来没有试过第二种方法，但我认为它应该像一种魅力。

结论

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