其实我不知道我用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从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) {
}
}
就是这样。您可以从您的活动中启动服务并通过广播或消息处理程序进行通信。我从未尝试过第二种方式，但我认为它应该像一个魅力。
结论
这些方法中没有一个使用单独的后台线程，它对我有用，我有三个基于第一种方法的应用程序，它们都在后台工作，没有任何支持的东西。希望答案对SocketIO使用中所有有趣的人有所帮助:)