implementation "org.java-websocket:Java-WebSocket:1.4.0" 

<uses-permission android:name="android.permission.INTERNET" />

public class JWebSocketClient extends WebSocketClient {
 public JWebSocketClient(URI serverUri) {
  super(serverUri, new Draft_6455());
 }
 @Override
 public void onOpen(ServerHandshake handshakedata) {
  Log.e("JWebSocketClient", "onOpen()");
 }
 @Override
 public void onMessage(String message) {
  Log.e("JWebSocketClient", "onMessage()");
 }
 @Override
 public void onClose(int code, String reason, boolean remote) {
  Log.e("JWebSocketClient", "onClose()");
 }
 @Override
 public void onError(Exception ex) {
  Log.e("JWebSocketClient", "onError()");
 }
}

URI uri = URI.create("ws://*******");
JWebSocketClient client = new JWebSocketClient(uri) {
 @Override
 public void onMessage(String message) {
  //message就是接收到的消息
  Log.e("JWebSClientService", message);
 }
};

try {
 client.connectBlocking();
} catch (InterruptedException e) {
 e.printStackTrace();
}

if (client != null && client.isOpen()) {
 client.send("你好");
}

/**
 * 斷開(kāi)連接
 */
private void closeConnect() {
 try {
  if (null != client) {
   client.close();
  }
 } catch (Exception e) {
  e.printStackTrace();
 } finally {
  client = null;
 }
}

public class JWebSocketClientService extends Service {
 private URI uri;
 public JWebSocketClient client;
 private JWebSocketClientBinder mBinder = new JWebSocketClientBinder();

 //用于Activity和service通訊
 class JWebSocketClientBinder extends Binder {
  public JWebSocketClientService getService() {
   return JWebSocketClientService.this;
  }
 }
 @Override
 public IBinder onBind(Intent intent) {
  return mBinder;
 }
}

public class MainActivity extends AppCompatActivity {
 private JWebSocketClient client;
 private JWebSocketClientService.JWebSocketClientBinder binder;
 private JWebSocketClientService jWebSClientService;
 private ServiceConnection serviceConnection = new ServiceConnection() {
  @Override
  public void onServiceConnected(ComponentName componentName, IBinder iBinder) {
   //服務(wù)與活動(dòng)成功綁定
   Log.e("MainActivity", "服務(wù)與活動(dòng)成功綁定");
   binder = (JWebSocketClientService.JWebSocketClientBinder) iBinder;
   jWebSClientService = binder.getService();
   client = jWebSClientService.client;
  }
  @Override
  public void onServiceDisconnected(ComponentName componentName) {
   //服務(wù)與活動(dòng)斷開(kāi)
   Log.e("MainActivity", "服務(wù)與活動(dòng)成功斷開(kāi)");
  }
 };
 @Override
 protected void onCreate(Bundle savedInstanceState) {
  super.onCreate(savedInstanceState);
  setContentView(R.layout.activity_main);
  bindService();
 }
 /**
  * 綁定服務(wù)
  */
 private void bindService() {
  Intent bindIntent = new Intent(MainActivity.this, JWebSocketClientService.class);
  bindService(bindIntent, serviceConnection, BIND_AUTO_CREATE);
 }
}

public class MainActivity extends AppCompatActivity {
 ...
 private class ChatMessageReceiver extends BroadcastReceiver{
  @Override
  public void onReceive(Context context, Intent intent) {
    String message=intent.getStringExtra("message");
  }
 }
 /**
  * 動(dòng)態(tài)注冊(cè)廣播
  */
 private void doRegisterReceiver() {
  chatMessageReceiver = new ChatMessageReceiver();
  IntentFilter filter = new IntentFilter("com.xch.servicecallback.content");
  registerReceiver(chatMessageReceiver, filter);
 }
 ...
}

client = new JWebSocketClient(uri) {
  @Override
  public void onMessage(String message) {
   Intent intent = new Intent();
   intent.setAction("com.xch.servicecallback.content");
   intent.putExtra("message", message);
   sendBroadcast(intent);
  }
};

 /**
 * 檢查鎖屏狀態(tài)，如果鎖屏先點(diǎn)亮屏幕
 *
 * @param content
 */
 private void checkLockAndShowNotification(String content) {
  //管理鎖屏的一個(gè)服務(wù)
  KeyguardManager km = (KeyguardManager) getSystemService(Context.KEYGUARD_SERVICE);
  if (km.inKeyguardRestrictedInputMode()) {//鎖屏
   //獲取電源管理器對(duì)象
   PowerManager pm = (PowerManager) this.getSystemService(Context.POWER_SERVICE);
   if (!pm.isScreenOn()) {
    @SuppressLint("InvalidWakeLockTag") PowerManager.WakeLock wl = pm.newWakeLock(PowerManager.ACQUIRE_CAUSES_WAKEUP |
      PowerManager.SCREEN_BRIGHT_WAKE_LOCK, "bright");
    wl.acquire(); //點(diǎn)亮屏幕
    wl.release(); //任務(wù)結(jié)束后釋放
   }
   sendNotification(content);
  } else {
   sendNotification(content);
  }
 }
 /**
 * 發(fā)送通知
 *
 * @param content
 */
 private void sendNotification(String content) {
  Intent intent = new Intent();
  intent.setClass(this, MainActivity.class);
  PendingIntent pendingIntent = PendingIntent.getActivity(this, 0, intent, PendingIntent.FLAG_UPDATE_CURRENT);
  NotificationManager notifyManager = (NotificationManager) getSystemService(Context.NOTIFICATION_SERVICE);
  Notification notification = new NotificationCompat.Builder(this)
    .setAutoCancel(true)
    // 設(shè)置該通知優(yōu)先級(jí)
    .setPriority(Notification.PRIORITY_MAX)
    .setSmallIcon(R.mipmap.ic_launcher)
    .setContentTitle("昵稱(chēng)")
    .setContentText(content)
    .setVisibility(VISIBILITY_PUBLIC)
    .setWhen(System.currentTimeMillis())
    // 向通知添加聲音、閃燈和振動(dòng)效果
    .setDefaults(Notification.DEFAULT_VIBRATE | Notification.DEFAULT_ALL | Notification.DEFAULT_SOUND)
    .setContentIntent(pendingIntent)
    .build();
  notifyManager.notify(1, notification);//id要保證唯一
 }

/**
 * 檢測(cè)是否開(kāi)啟通知
 *
 * @param context
 */
 private void checkNotification(final Context context) {
  if (!isNotificationEnabled(context)) {
   new AlertDialog.Builder(context).setTitle("溫馨提示")
     .setMessage("你還未開(kāi)啟系統(tǒng)通知，將影響消息的接收，要去開(kāi)啟嗎？")
     .setPositiveButton("確定", new DialogInterface.OnClickListener() {
      @Override
      public void onClick(DialogInterface dialog, int which) {
       setNotification(context);
      }
     }).setNegativeButton("取消", new DialogInterface.OnClickListener() {
    @Override
    public void onClick(DialogInterface dialog, int which) {
    }
   }).show();
  }
 }
 /**
 * 如果沒(méi)有開(kāi)啟通知，跳轉(zhuǎn)至設(shè)置界面
 *
 * @param context
 */
 private void setNotification(Context context) {
  Intent localIntent = new Intent();
  //直接跳轉(zhuǎn)到應(yīng)用通知設(shè)置的代碼：
  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);
  } else if (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以下沒(méi)有從app跳轉(zhuǎn)到應(yīng)用通知設(shè)置頁(yè)面的Action，可考慮跳轉(zhuǎn)到應(yīng)用詳情頁(yè)面
   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));
   } else if (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);
 }
 /**
 * 獲取通知權(quán)限,檢測(cè)是否開(kāi)啟了系統(tǒng)通知
 *
 * @param context
 */
 @TargetApi(Build.VERSION_CODES.KITKAT)
 private boolean isNotificationEnabled(Context context) {
  String CHECK_OP_NO_THROW = "checkOpNoThrow";
  String OP_POST_NOTIFICATION = "OP_POST_NOTIFICATION";
  AppOpsManager mAppOps = (AppOpsManager) context.getSystemService(Context.APP_OPS_SERVICE);
  ApplicationInfo appInfo = context.getApplicationInfo();
  String pkg = context.getApplicationContext().getPackageName();
  int uid = appInfo.uid;
  Class appOpsClass = null;
  try {
   appOpsClass = Class.forName(AppOpsManager.class.getName());
   Method checkOpNoThrowMethod = appOpsClass.getMethod(CHECK_OP_NO_THROW, Integer.TYPE, Integer.TYPE,
     String.class);
   Field opPostNotificationValue = appOpsClass.getDeclaredField(OP_POST_NOTIFICATION);
   int value = (Integer) opPostNotificationValue.get(Integer.class);
   return ((Integer) checkOpNoThrowMethod.invoke(mAppOps, value, uid, pkg) == AppOpsManager.MODE_ALLOWED);
  } catch (Exception e) {
   e.printStackTrace();
  }
  return false;
 }

<!-- 解鎖屏幕需要的權(quán)限 -->
 <uses-permission android:name="android.permission.DISABLE_KEYGUARD" />
 <!-- 申請(qǐng)電源鎖需要的權(quán)限 -->
 <uses-permission android:name="android.permission.WAKE_LOCK" />
 <!--震動(dòng)權(quán)限-->
 <uses-permission android:name="android.permission.VIBRATE" />

private static final long HEART_BEAT_RATE = 10 * 1000;//每隔10秒進(jìn)行一次對(duì)長(zhǎng)連接的心跳檢測(cè)
 private Handler mHandler = new Handler();
 private Runnable heartBeatRunnable = new Runnable() {
  @Override
  public void run() {
   if (client != null) {
    if (client.isClosed()) {
     reconnectWs();
    }
   } else {
    //如果client已為空，重新初始化websocket
    initSocketClient();
   }
   //定時(shí)對(duì)長(zhǎng)連接進(jìn)行心跳檢測(cè)
   mHandler.postDelayed(this, HEART_BEAT_RATE);
  }
 };
 /**
 * 開(kāi)啟重連
 */
 private void reconnectWs() {
  mHandler.removeCallbacks(heartBeatRunnable);
  new Thread() {
   @Override
   public void run() {
    try {
     //重連
     client.reconnectBlocking();
    } catch (InterruptedException e) {
     e.printStackTrace();
    }
   }
  }.start();
 }

mHandler.postDelayed(heartBeatRunnable, HEART_BEAT_RATE);//開(kāi)啟心跳檢測(cè)