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

Question

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

我用以下方式保持线程:

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

这种方式完全错误是吗？要修复此解决方案，我需要找到以下问题的答案:

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

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

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

提前致谢!

Answer 1

实际上，我不知道我使用 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) {

    }

}

然后我创建了一个 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 从 SocketClient 中的 on、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", 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) {

    }
}

就是这样。您可以从您的 Activity 开始服务并通过广播或消息处理程序进行通信。我从未尝试过第二种方法，但我认为它应该会很有用。

结论

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