前言
之前我们在使 RESTful 访问服务端时，一般都是客户端请求服务端应答的方式，这种通讯方式，对于需要持续获取数据的情形都是采用轮询的方式，但是这种方式对两边的性能消耗很大，特别是服务端的压力很大。现在当我们使用WebSocket时，这类问题迎刃而解了。服务端可以根据需要向客户端实时推送消息。
WebSocket的协议很简单，客户端的onMessage事件可以很方便的接收消息。我们可以收到后传递给前端的Activity处理更新UI.
现代手机为了省电，屏幕在很短的时候就关闭了，但有时候我们不希望屏幕一灭，应用也跟着睡着了，手机息屏后，我们仍然希望用户能通过语音给用户传递信息。就像你切换屏幕了，高德能继续给你语音导航一样。这种情况单独使用Activity是无能为力的，Android系统设计为只要屏幕一灭，任何Activity的UI活动都会睡眠。不过，息屏后，后台的WebSocket客户端是能够继续接受消息的，但是没办法传到前端的活动了。这时候我们需要引入Android的Service来处理。
在讲解正文之前我们先回顾一下WebSocket的基本使用。
WebSocket与回调接口
在之前的文章中我们介绍了WebSocket的基本使用。就是利用OkHttp3的WebSocket相关功能搭建自己的调用程序框架。这里为了适应Service的使用，我们对WebSocket程序稍微加以改造一下。
首先我们将静态方法改造为实例方法，并使用单例模式。
其次，我们引入一个回调接口，这个很关键。
WebSocketListenerCallback
public interface WebSocketListenerCallback {
void onDataReceived(String action, String data);
void onFailure(String text);
}
它包含2个方法，
onDataReceived 处理收到消息后怎么办
onFailure 处理通讯失败
我们的WebSocket程序设计为可以设定多个Callback, 在onMessage 收到消息后，逐个执行每个Callback的onDataReceived方法。整个WebSocket程序的代码如下。使用前需要引入Okhttp3库。
import androidx.annotation.NonNull;
import androidx.annotation.Nullable;
import com.bob.app.C;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.TimeUnit;
import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.Response;
import okhttp3.WebSocket;
import okhttp3.WebSocketListener;
public class WSClient {
private static WSClient instance;
private WebSocket socket;
private final List<WebSocketListenerCallback> callbacks = new ArrayList<>();
private final OkHttpClient client;
private WSClient() {
OkHttpClient.Builder cb = new OkHttpClient.Builder();
cb.readTimeout(C.SOCKET_TIMEOUT, TimeUnit.SECONDS);
cb.connectTimeout(C.SOCKET_TIMEOUT, TimeUnit.SECONDS);
cb.writeTimeout(C.SOCKET_TIMEOUT, TimeUnit.SECONDS);
client = cb.build();
}
public static synchronized WSClient getInstance() {
if (instance == null) {
instance = new WSClient();
}
return instance;
}
public synchronized void init() {
Request request = new Request.Builder().url(C.serverUrl).build();
WSListener listener = new WSListener();
socket = client.newWebSocket(request, listener);
}
public void addCallback(WebSocketListenerCallback callback) {
if (!callbacks.contains(callback)) {
callbacks.add(callback);
}
}
public void removeCallback(WebSocketListenerCallback callback) {
callbacks.remove(callback);
}
public synchronized void send(String action, Object data) {
long txNo = System.currentTimeMillis();
String message = action + "$$" + txNo + "$$" + U.toJSONString(data);
if (socket != null) {
socket.send(message);
}
}
public void disconnect(int code, String reason) {
if (socket != null) {
socket.close(code, reason);
socket = null;
}
}
private class WSListener extends WebSocketListener {
@Override
public void onMessage(@NonNull WebSocket webSocket, @NonNull String text) {
for (WebSocketListenerCallback callback : callbacks) {
String[] str = text.split("\$\$");
String action = str[0];//操作指令，
String message = str.length > 2 ? str[2] : "";//信息正文
callback.onDataReceived(action, message);
}
}
@Override
public void onFailure(@NonNull WebSocket webSocket, @NonNull Throwable t, @Nullable Response response) {
for (WebSocketListenerCallback callback : callbacks) {
callback.onFailure("Error: " + t.getMessage());//错误信息传出去
}
}
}
}
C是一个常数类,里面有些常数，比如SOCKET_TIMEOUT = 5;
Service接收推送消息
关于Service的基本使用，网上有很多资料。我们这里通过实际的场景应用来消化理解。
我们现在的应用场景就是：收到后台消息后，通过Service传递给前端应用，然后语音播报。
首先自己的Service继承基类，并且需要实现回调方法WebSocketListenerCallback
在初始化WebSocket的时候我们就把Callback传进去。并初始化。
整个Service的完整代码如下:
import android.app.Notification;
import android.app.NotificationChannel;
import android.app.NotificationManager;
import android.app.Service;
import android.content.Intent;
import android.os.IBinder;
import androidx.annotation.Nullable;
import androidx.core.app.NotificationCompat;
import androidx.localbroadcastmanager.content.LocalBroadcastManager;
import com.bob.app.common.WSClient;
import com.bob.app.common.WebSocketListenerCallback;
public class ActiveDataService extends Service implements WebSocketListenerCallback {
@Override
public void onCreate() {
super.onCreate();
WSClient wsClient = WSClient.getInstance();//获取实例
wsClient.addCallback(this);//传入Callback
wsClient.init();//执行初始化
}
public void onDataReceived(String action, String str) {
if (A.ACTIVE_DATA.equals(action)) {//如果指令是推送新消息
Intent intent = new Intent(BC.BROADCAST_ACTIVE_DATA);//收到最新实时消息
intent.putExtra("data", str);
LocalBroadcastManager.getInstance(this).sendBroadcast(intent);
}
}
public void onFailure(String str) {
Intent intent = new Intent(BC.BROADCAST_SERVER_OFFLINE);//服务端访问异常
LocalBroadcastManager.getInstance(this).sendBroadcast(intent);
}
@Override
public int onStartCommand(Intent intent, int flags, int startId) {
startForeground(1, createNotification());
return START_STICKY;
}
private Notification createNotification() {
NotificationChannel channel = new NotificationChannel("channel", "Service", NotificationManager.IMPORTANCE_LOW);
NotificationManager manager = getSystemService(NotificationManager.class);
if (manager != null) {
manager.createNotificationChannel(channel);
}
NotificationCompat.Builder builder = new NotificationCompat.Builder(this, "channel")
.setContentTitle(getString(R.string.app_name))
.setContentText(getString(R.string.fetching_data))
.setSmallIcon(android.R.drawable.ic_notification_overlay)
.setAutoCancel(true)
.setOngoing(false)
.setPriority(NotificationCompat.PRIORITY_DEFAULT); // Make sure the priority is LOW
return builder.build();
}
@Nullable
@Override
public IBinder onBind(Intent intent) {
return null;
}
@Override
public void onDestroy() {
super.onDestroy();
}
}
其中BC.BROADCAST_ACTIVE_DATA和BC.BROADCAST_SERVER_OFFLINE是2个常数字符串，可以自己取名字。
在Android里面，由于Activity和Service的生命周期并不相同，Service息屏后还能活动，因此Service并不能直接引用Activity也不能直接与Activity交互，只能通过广播间接交互。意思就是Service发送广播，Activity可以订阅后处理。上面的代码展示了怎样发送广播。
createNotification是一个常规方法，创建一个通知信息栏。这个会让用户知道一个后台服务在干嘛。有的手机会显示比如华为等，有的手机也默认不显示，比如Oppo等
Activity接收Service广播信息
Service发送的广播，Activity可以通过订阅的方式来使用。
具体的订阅方法如下：
private final BroadcastReceiver receiver1 = new BroadcastReceiver() {
@Override
public void onReceive(Context context, Intent intent) {
String data = intent.getStringExtra("data");
finishGetActiveData(data);//接收到最新数据，传递到处理方法
}
};
private final BroadcastReceiver receiver2 = new BroadcastReceiver() {
@Override
public void onReceive(Context context, Intent intent) {
showLogin();//接收到网络异常，退回到登录界面
}
};
先声明BroadcastReceiver, receiver的目的就是声明收到数据后怎么办。在onReceive方法里接收数据，然后传递到实现方法里面。这里我们声明了2个receiver，一个是收到正常的最新信息后怎么办。另一个是收到网络错误信息后怎么办。
然后在onCreate方法里注册receiver
Intent serviceIntent = new Intent(this, ActiveDataService.class);
ContextCompat.startForegroundService(this, serviceIntent);
LocalBroadcastManager.getInstance(this).registerReceiver(receiver1, new IntentFilter(BC.BROADCAST_ACTIVE_DATA));
LocalBroadcastManager.getInstance(this).registerReceiver(receiver2, new IntentFilter(BC.BROADCAST_SERVER_OFFLINE));
注意其中的 IntentFilter的用法，一般一个receiver只过滤接收一种消息。
这样我们就完成把消息传送给Activity这个数据链路了。
然后我们可以在finishGetActiveData方法里面干该干的事情了，比如调用TTS语音播报啥的。
看到这里，有的小伙伴可能会问，这个Callback我能不能在Activity里将WebSocket初始化，然后传入Callback呢，答案是可以的，可以将Activity实现WebSocketListenerCallback后传入WebSocket,也是一样的效果，还更简单，不用广播。不过前面我们讲过，这种直接使用Activity初始化WebSocket的程序只能在亮屏时功能正常，息屏了程序就跟着睡眠了。
另外，需要强调的一点时，要实现息屏后服务正常，需要手机在设置里关闭省电功能，并且允许应用后台活动。否则写了也白搭。只有用户才有最终决定权。
总结
要想息屏后，部分手机功能正常接收后台推送消息并传递给Activity处理，需要做如下处理：
- WebSocket引入回调接口并在onMesssge中调用。
- 创建一个Service实现回调接口，在回调方法中发送广播
- Activity中声明接收广播的receiver，并实现处理receiver收到的的数据。