Actually, 我不知道我使用
socket-io-client
的方式是否正确,但我尽量清楚明白。
据我所知,
socket-io-client
已经在使用后台线程进行连接、发送和接收事件。
第一种方式
我认为这不是你想要的,但我展示这个变体作为可能的选择。
首先,我创建了一个类似这样的
SocketClient
:
public class SocketClient implements IOCallback {
private SocketIO socket;
private Context context;
public SocketClient(Context context) {
this.context = context;
}
public synchronized void connect() {
if (socket == null || !socket.isConnected()) {
Properties properties = new 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();
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
使用感兴趣的人有所帮助 :)