怎么在Android中利用WebSocket实现即时通讯
本篇文章为大家展示了怎么在Android中利用WebSocket实现即时通讯，内容简明扼要并且容易理解，绝对能使你眼前一亮，通过这篇文章的详细介绍希望你能有所收获。
WebSocket
WebSocket协议就不细讲了，感兴趣的可以具体查阅资料，简而言之，它就是一个可以建立长连接的全双工(full-duplex)通信协议，允许服务器端主动发送信息给客户端。
Java-WebSocket框架
对于使用websocket协议，Android端已经有些成熟的框架了，在经过对比之后，我选择了Java-WebSocket这个开源框架，目前已经有五千以上star，并且还在更新维护中，所以本文将介绍如何利用此开源库实现一个稳定的即时通讯功能。
1、与websocket建立长连接
2、与websocket进行即时通讯
3、Service和Activity之间通讯和UI更新
4、弹出消息通知（包括锁屏通知）
5、心跳检测和重连（保证websocket连接稳定性）
6、服务（Service）保活
一、引入Java-WebSocket
1、build.gradle中加入
implementation"org.java-websocket:Java-WebSocket:1.4.0"
2、加入网络请求权限
<uses-permissionandroid:name="android.permission.INTERNET"/>
3、新建客户端类
新建一个客户端类并继承WebSocketClient，需要实现它的四个抽象方法和构造函数，如下：
publicclassJWebSocketClientextendsWebSocketClient{
publicJWebSocketClient(URIserverUri){
super(serverUri,newDraft_6455());
}
@Override
publicvoidonOpen(ServerHandshakehandshakedata){
Log.e("JWebSocketClient","onOpen()");
}
@Override
publicvoidonMessage(Stringmessage){
Log.e("JWebSocketClient","onMessage()");
}
@Override
publicvoidonClose(intcode,Stringreason,booleanremote){
Log.e("JWebSocketClient","onClose()");
}
@Override
publicvoidonError(Exceptionex){
Log.e("JWebSocketClient","onError()");
}
}其中onOpen()方法在websocket连接开启时调用，onMessage()方法在接收到消息时调用，onClose()方法在连接断开时调用，onError()方法在连接出错时调用。构造方法中的new Draft_6455()代表使用的协议版本，这里可以不写或者写成这样即可。
4、建立websocket连接
建立连接只需要初始化此客户端再调用连接方法，需要注意的是WebSocketClient对象是不能重复使用的，所以不能重复初始化，其他地方只能调用当前这个Client。
URIuri=URI.create("ws://*******");
JWebSocketClientclient=newJWebSocketClient(uri){
@Override
publicvoidonMessage(Stringmessage){
//message就是接收到的消息
Log.e("JWebSClientService",message);
}
};为了方便对接收到的消息进行处理，可以在这重写onMessage()方法。初始化客户端时需要传入websocket地址（测试地址：ws://echo.websocket.org），websocket协议地址大致是这样的
ws:// ip地址 : 端口号
连接时可以使用connect()方法或connectBlocking()方法，建议使用connectBlocking()方法，connectBlocking多出一个等待操作，会先连接再发送。
try{
client.connectBlocking();
}catch(InterruptedExceptione){
e.printStackTrace();
}运行之后可以看到客户端的onOpen()方法得到了执行，表示已经和websocket建立了连接
5、发送消息
发送消息只需要调用send()方法，如下
if(client!=null&&client.isOpen()){
client.send("你好");
}6、关闭socket连接
关闭连接调用close()方法，最后为了避免重复实例化WebSocketClient对象，关闭时一定要将对象置空。
/**
*断开连接
*/
privatevoidcloseConnect(){
try{
if(null!=client){
client.close();
}
}catch(Exceptione){
e.printStackTrace();
}finally{
client=null;
}
}二、后台运行
一般来说即时通讯功能都希望像QQ微信这些App一样能在后台保持运行，当然App保活这个问题本身就是个伪命题，我们只能尽可能保活，所以首先就是建一个Service，将websocket的逻辑放入服务中运行并尽可能保活，让websocket保持连接。
1、新建Service
新建一个Service，在启动Service时实例化WebSocketClient对象并建立连接，将上面的代码搬到服务里即可。
2、Service和Activity之间通讯
由于消息是在Service中接收，从Activity中发送，需要获取到Service中的WebSocketClient对象，所以需要进行服务和活动之间的通讯，这就需要用到Service中的onBind()方法了。
首先新建一个Binder类,让它继承自Binder，并在内部提供相应方法，然后在onBind()方法中返回这个类的实例。
publicclassJWebSocketClientServiceextendsService{
privateURIuri;
publicJWebSocketClientclient;
privateJWebSocketClientBindermBinder=newJWebSocketClientBinder();
//用于Activity和service通讯
classJWebSocketClientBinderextendsBinder{
publicJWebSocketClientServicegetService(){
returnJWebSocketClientService.this;
}
}
@Override
publicIBinderonBind(Intentintent){
returnmBinder;
}
}接下来就需要对应的Activity绑定Service，并获取Service的东西，代码如下
publicclassMainActivityextendsAppCompatActivity{
privateJWebSocketClientclient;
privateJWebSocketClientService.JWebSocketClientBinderbinder;
privateJWebSocketClientServicejWebSClientService;
privateServiceConnectionserviceConnection=newServiceConnection(){
@Override
publicvoidonServiceConnected(ComponentNamecomponentName,IBinderiBinder){
//服务与活动成功绑定
Log.e("MainActivity","服务与活动成功绑定");
binder=(JWebSocketClientService.JWebSocketClientBinder)iBinder;
jWebSClientService=binder.getService();
client=jWebSClientService.client;
}
@Override
publicvoidonServiceDisconnected(ComponentNamecomponentName){
//服务与活动断开
Log.e("MainActivity","服务与活动成功断开");
}
};
@Override
protectedvoidonCreate(BundlesavedInstanceState){
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
bindService();
}
/**
*绑定服务
*/
privatevoidbindService(){
IntentbindIntent=newIntent(MainActivity.this,JWebSocketClientService.class);
bindService(bindIntent,serviceConnection,BIND_AUTO_CREATE);
}
}这里首先创建了一个ServiceConnection匿名类，在里面重写onServiceConnected()和onServiceDisconnected()方法，这两个方法会在活动与服务成功绑定以及连接断开时调用。在onServiceConnected()首先得到JWebSocketClientBinder的实例，有了这个实例便可调用服务的任何public方法，这里调用getService()方法得到Service实例，得到了Service实例也就得到了WebSocketClient对象，也就可以在活动中发送消息了。
三、从Service中更新Activity的UI
当Service中接收到消息时需要更新Activity中的界面，方法有很多，这里我们利用广播来实现，在对应Activity中定义广播接收者，Service中收到消息发出广播即可。
publicclassMainActivityextendsAppCompatActivity{
...
privateclassChatMessageReceiverextendsBroadcastReceiver{
@Override
publicvoidonReceive(Contextcontext,Intentintent){
Stringmessage=intent.getStringExtra("message");
}
}
/**
*动态注册广播
*/
privatevoiddoRegisterReceiver(){
chatMessageReceiver=newChatMessageReceiver();
IntentFilterfilter=newIntentFilter("com.xch.servicecallback.content");
registerReceiver(chatMessageReceiver,filter);
}
...
}上面的代码很简单，首先创建一个内部类并继承自BroadcastReceiver，也就是代码中的广播接收器ChatMessageReceiver，然后动态注册这个广播接收器。当Service中接收到消息时发出广播，就能在ChatMessageReceiver里接收广播了。
发送广播：
client=newJWebSocketClient(uri){
@Override
publicvoidonMessage(Stringmessage){
Intentintent=newIntent();
intent.setAction("com.xch.servicecallback.content");
intent.putExtra("message",message);
sendBroadcast(intent);
}
};获取广播传过来的消息后即可更新UI，具体布局就不细说，比较简单，看下我的源码就知道了，demo地址我会放到文章末尾。
四、消息通知
消息通知直接使用Notification，只是当锁屏时需要先点亮屏幕，代码如下
/**
*检查锁屏状态，如果锁屏先点亮屏幕
*
*@paramcontent
*/
privatevoidcheckLockAndShowNotification(Stringcontent){
//管理锁屏的一个服务
KeyguardManagerkm=(KeyguardManager)getSystemService(Context.KEYGUARD_SERVICE);
if(km.inKeyguardRestrictedInputMode()){//锁屏
//获取电源管理器对象
PowerManagerpm=(PowerManager)this.getSystemService(Context.POWER_SERVICE);
if(!pm.isScreenOn()){
@SuppressLint("InvalidWakeLockTag")PowerManager.WakeLockwl=pm.newWakeLock(PowerManager.ACQUIRE_CAUSES_WAKEUP|
PowerManager.SCREEN_BRIGHT_WAKE_LOCK,"bright");
wl.acquire();//点亮屏幕
wl.release();//任务结束后释放
}
sendNotification(content);
}else{
sendNotification(content);
}
}
/**
*发送通知
*
*@paramcontent
*/
privatevoidsendNotification(Stringcontent){
Intentintent=newIntent();
intent.setClass(this,MainActivity.class);
PendingIntentpendingIntent=PendingIntent.getActivity(this,0,intent,PendingIntent.FLAG_UPDATE_CURRENT);
NotificationManagernotifyManager=(NotificationManager)getSystemService(Context.NOTIFICATION_SERVICE);
Notificationnotification=newNotificationCompat.Builder(this)
.setAutoCancel(true)
//设置该通知优先级
.setPriority(Notification.PRIORITY_MAX)
.setSmallIcon(R.mipmap.ic_launcher)
.setContentTitle("昵称")
.setContentText(content)
.setVisibility(VISIBILITY_PUBLIC)
.setWhen(System.currentTimeMillis())
//向通知添加声音、闪灯和振动效果
.setDefaults(Notification.DEFAULT_VIBRATE|Notification.DEFAULT_ALL|Notification.DEFAULT_SOUND)
.setContentIntent(pendingIntent)
.build();
notifyManager.notify(1,notification);//id要保证唯一
}如果未收到通知可能是设置里通知没开，进入设置打开即可，如果锁屏时无法弹出通知，可能是未开启锁屏通知权限，也需进入设置开启。为了保险起见我们可以判断通知是否开启，未开启引导用户开启，代码如下：
最后加
/**
*检测是否开启通知
*
*@paramcontext
*/
privatevoidcheckNotification(finalContextcontext){
if(!isNotificationEnabled(context)){
newAlertDialog.Builder(context).setTitle("温馨提示")
.setMessage("你还未开启系统通知，将影响消息的接收，要去开启吗？")
.setPositiveButton("确定",newDialogInterface.OnClickListener(){
@Override
publicvoidonClick(DialogInterfacedialog,intwhich){
setNotification(context);
}
}).setNegativeButton("取消",newDialogInterface.OnClickListener(){
@Override
publicvoidonClick(DialogInterfacedialog,intwhich){
}
}).show();
}
}
/**
*如果没有开启通知，跳转至设置界面
*
*@paramcontext
*/
privatevoidsetNotification(Contextcontext){
IntentlocalIntent=newIntent();
//直接跳转到应用通知设置的代码：
if(android.os.Build.VERSION.SDK_INT>=Build.VERSION_CODES.LOLLIPOP){
localIntent.setAction("android.settings.APP_NOTIFICATION_SETTINGS");
localIntent.putExtra("app_package",context.getPackageName());
localIntent.putExtra("app_uid",context.getApplicationInfo().uid);
}elseif(android.os.Build.VERSION.SDK_INT==Build.VERSION_CODES.KITKAT){
localIntent.setAction(Settings.ACTION_APPLICATION_DETAILS_SETTINGS);
localIntent.addCategory(Intent.CATEGORY_DEFAULT);
localIntent.setData(Uri.parse("package:"+context.getPackageName()));
}else{
//4.4以下没有从app跳转到应用通知设置页面的Action，可考虑跳转到应用详情页面
localIntent.addFlags(Intent.FLAG_ACTIVITY_NEW_TASK);
if(Build.VERSION.SDK_INT>=9){
localIntent.setAction("android.settings.APPLICATION_DETAILS_SETTINGS");
localIntent.setData(Uri.fromParts("package",context.getPackageName(),null));
}elseif(Build.VERSION.SDK_INT<=8){
localIntent.setAction(Intent.ACTION_VIEW);
localIntent.setClassName("com.android.settings","com.android.setting.InstalledAppDetails");
localIntent.putExtra("com.android.settings.ApplicationPkgName",context.getPackageName());
}
}
context.startActivity(localIntent);
}
/**
*获取通知权限,检测是否开启了系统通知
*
*@paramcontext
*/
@TargetApi(Build.VERSION_CODES.KITKAT)
privatebooleanisNotificationEnabled(Contextcontext){
StringCHECK_OP_NO_THROW="checkOpNoThrow";
StringOP_POST_NOTIFICATION="OP_POST_NOTIFICATION";
AppOpsManagermAppOps=(AppOpsManager)context.getSystemService(Context.APP_OPS_SERVICE);
ApplicationInfoappInfo=context.getApplicationInfo();
Stringpkg=context.getApplicationContext().getPackageName();
intuid=appInfo.uid;
ClassappOpsClass=null;
try{
appOpsClass=Class.forName(AppOpsManager.class.getName());
MethodcheckOpNoThrowMethod=appOpsClass.getMethod(CHECK_OP_NO_THROW,Integer.TYPE,Integer.TYPE,
String.class);
FieldopPostNotificationValue=appOpsClass.getDeclaredField(OP_POST_NOTIFICATION);
intvalue=(Integer)opPostNotificationValue.get(Integer.class);
return((Integer)checkOpNoThrowMethod.invoke(mAppOps,value,uid,pkg)==AppOpsManager.MODE_ALLOWED);
}catch(Exceptione){
e.printStackTrace();
}
returnfalse;
}入相关的权限
<!--解锁屏幕需要的权限--> <uses-permissionandroid:name="android.permission.DISABLE_KEYGUARD"/> <!--申请电源锁需要的权限--> <uses-permissionandroid:name="android.permission.WAKE_LOCK"/> <!--震动权限--> <uses-permissionandroid:name="android.permission.VIBRATE"/>
五、心跳检测和重连
由于很多不确定因素会导致websocket连接断开，例如网络断开，所以需要保证websocket的连接稳定性，这就需要加入心跳检测和重连。
心跳检测其实就是个定时器，每个一段时间检测一次，如果连接断开则重连，Java-WebSocket框架在目前最新版本中有两个重连的方法，分别是reconnect()和reconnectBlocking()，这里同样使用后者。
privatestaticfinallongHEART_BEAT_RATE=10*1000;//每隔10秒进行一次对长连接的心跳检测
privateHandlermHandler=newHandler();
privateRunnableheartBeatRunnable=newRunnable(){
@Override
publicvoidrun(){
if(client!=null){
if(client.isClosed()){
reconnectWs();
}
}else{
//如果client已为空，重新初始化websocket
initSocketClient();
}
//定时对长连接进行心跳检测
mHandler.postDelayed(this,HEART_BEAT_RATE);
}
};
/**
*开启重连
*/
privatevoidreconnectWs(){
mHandler.removeCallbacks(heartBeatRunnable);
newThread(){
@Override
publicvoidrun(){
try{
//重连
client.reconnectBlocking();
}catch(InterruptedExceptione){
e.printStackTrace();
}
}
}.start();
}然后在服务启动时开启心跳检测
mHandler.postDelayed(heartBeatRunnable,HEART_BEAT_RATE);//开启心跳检测
我们打印一下日志，如图所示
六、服务(Service)保活
如果某些业务场景需要App保活，例如利用这个websocket来做推送，那就需要我们的App后台服务不被kill掉，当然如果和手机厂商没有合作，要保证服务一直不被杀死，这可能是所有Android开发者比较头疼的一个事，这里我们只能尽可能的来保证Service的存活。
1、提高服务优先级（前台服务）
前台服务的优先级比较高，它会在状态栏显示类似于通知的效果，可以尽量避免在内存不足时被系统回收，前台服务比较简单就不细说了。有时候我们希望可以使用前台服务但是又不希望在状态栏有显示，那就可以利用灰色保活的办法，如下
privatefinalstaticintGRAY_SERVICE_ID=1001;
//灰色保活手段
publicstaticclassGrayInnerServiceextendsService{
@Override
publicintonStartCommand(Intentintent,intflags,intstartId){
startForeground(GRAY_SERVICE_ID,newNotification());
stopForeground(true);
stopSelf();
returnsuper.onStartCommand(intent,flags,startId);
}
@Override
publicIBinderonBind(Intentintent){
returnnull;
}
}
//设置service为前台服务，提高优先级
if(Build.VERSION.SDK_INT<18){
//Android4.3以下，隐藏Notification上的图标
startForeground(GRAY_SERVICE_ID,newNotification());
}elseif(Build.VERSION.SDK_INT>18&&Build.VERSION.SDK_INT<25){
//Android4.3-Android7.0，隐藏Notification上的图标
IntentinnerIntent=newIntent(this,GrayInnerService.class);
startService(innerIntent);
startForeground(GRAY_SERVICE_ID,newNotification());
}else{
//暂无解决方法
startForeground(GRAY_SERVICE_ID,newNotification());
}AndroidManifest.xml中注册这个服务
<serviceandroid:name=".im.JWebSocketClientService$GrayInnerService" android:enabled="true" android:exported="false" android:process=":gray"/>
这里其实就是开启前台服务并隐藏了notification，也就是再启动一个service并共用一个通知栏，然后stop这个service使得通知栏消失。但是7.0以上版本会在状态栏显示“正在运行”的通知，目前暂时没有什么好的解决办法。
2、修改Service的onStartCommand 方法返回值
@Override
publicintonStartCommand(Intentintent,intflags,intstartId){
...
returnSTART_STICKY;
}onStartCommand()返回一个整型值，用来描述系统在杀掉服务后是否要继续启动服务，START_STICKY表示如果Service进程被kill掉，系统会尝试重新创建Service。
3、锁屏唤醒
PowerManager.WakeLockwakeLock;//锁屏唤醒
privatevoidacquireWakeLock()
{
if(null==wakeLock)
{
PowerManagerpm=(PowerManager)this.getSystemService(Context.POWER_SERVICE);
wakeLock=pm.newWakeLock(PowerManager.PARTIAL_WAKE_LOCK|PowerManager.ON_AFTER_RELEASE,"PostLocationService");
if(null!=wakeLock)
{
wakeLock.acquire();
}
}
}获取电源锁，保持该服务在屏幕熄灭时仍然获取CPU时，让其保持运行。
上述内容就是怎么在Android中利用WebSocket实现即时通讯，你们学到知识或技能了吗？如果还想学到更多技能或者丰富自己的知识储备，欢迎关注恰卡编程网行业资讯频道。
