我有一个服务。我在这个服务中创建了一个Thread，并将socket.io-java-client库用在这个线程中。
我的处理方式如下：
@Override
public void run() {
while (canLiveThread) {
// keep thread
}
}
这种方式完全是错误的，对吗？为了修复这个问题，我需要找到以下问题的答案:
1. 我需要创建一个单独的线程来使用socket.io-java-client库吗？或者我可以在Service中直接使用这个库而不需要线程？
2. 如果需要创建线程来使用该库，那么如何以正确的方式管理线程，以避免在后台Service中耗尽电池电量？
如果有人有任何解决方案，请回答这个问题...
谢谢！
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：
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) {
}
}
这就是全部内容。您可以从活动启动服务并通过广播或消息处理程序进行通信。我从未尝试过第二种方式，但我认为它应该像魅力一样工作。
结论
这些方法中没有一个单独使用后台线程，并且对我而言很有效，我有三个基于第一种方式的应用程序，所有这些应用程序都在后台运行，不需要任何支持。希望这个答案对所有对SocketIO使用感兴趣的人有所帮助 :)
SocketIO socket = new SocketIO(url, properties) 时，该线程就会启动，所以我认为我们不需要再创建一个单独的线程来启动 ConnectThread。我认为这是多余的。链接：https://github.com/Gottox/socket.io-java-client/blob/master/src/io/socket/IOConnection.java#L184 - romtsn