前置条件，build.gradle引入依赖：

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

封装websocket类：

public class WsHelper {private static Option option = new Option();public JWebSocketClient client;public Boolean ping_status = false;private ActivityWsCallback callback;private String TAG = "WS";public void setCallback(ActivityWsCallback callback) {this.callback = callback;}/*** 初始化websocket连接*/public void initSocketClient() {URI uri = URI.create(option.WSUri);Logger.e("开始ws连接");client = new JWebSocketClient(uri) {@Overridepublic void onMessage(String message) {handleMessage(message);}@Overridepublic void onOpen(ServerHandshake handshakedata) {Log.e(TAG, "websocket连接成功");msgData sn = new msgData();sn.setSn(getDeviceSN());msg obj = new msg();obj.setCommand("init");obj.setData(sn);String str = JSON.toJSONString(obj);sendMsg(str);heartBeatRunnable.run();}@Overridepublic void onError(Exception ex) {super.onError(ex);Log.e(TAG,"websocket连接错误：" + ex);ping_status = false;}@Overridepublic void onClose(int code, String reason, boolean remote) {super.onClose(code, reason, remote);Log.e("ws", "websocket断开连接：·code:" + code + "·reason:" + reason + "·remote:" + remote);ping_status = false;}};connect();}//消息发送public void sendMsg(String msg) {if (null != client && client.isOpen()) {client.send(msg);} else {ping_status = false;}}/*** 连接websocket*/private void connect() {if (client.isOpen()) {return;}client.connect();}//心跳检测private static final long HEART_BEAT_RATE = 5 * 1000;private Handler mHandler = new Handler();//心跳检测private Runnable heartBeatRunnable = new Runnable() {@Overridepublic void run() {mHandler.removeCallbacks(heartBeatRunnable);if (client != null) {if (client.isClosed()) {Log.e(TAG, "关闭状态");reconnectWs();//心跳机制发现断开开启重连} else {//发送消息msgData sn = new msgData();sn.setSn(getDeviceSN());msg obj = new msg();obj.setData(sn);if (client.isOpen()) {obj.setCommand("ping");sendMsg(JSON.toJSONString(obj));} else {Log.e(TAG, "异常");ping_status = false;reconnectWs();//心跳机制发现断开开启重连}}} else {Log.e("", "没有初始化");//如果client已为空，重新初始化连接initSocketClient();}mHandler.postDelayed(heartBeatRunnable, HEART_BEAT_RATE);}};//开启重连private void reconnectWs() {Log.e("", "正在重连");initSocketClient();}public static String getDeviceSN() {String serialNumber = android.os.Build.SERIAL;return serialNumber;}public class msg {private String command;private msgData data;public msgData getData() {return data;}public String getCommand() {return command;}public void setCommand(String command) {this.command = command;}public void setData(msgData data) {this.data = data;}}public class msgData {private String sn;private String data;public void setData(String data) {this.sn = data;}public String getSn() {return sn;}public void setSn(String sn) {this.sn = sn;}}/*** 处理收到的消息* @param message 收到的消息*/private void handleMessage(String message) {// 调用回调接口的方法，将消息传递给调用方if (callback != null) {callback.onMessageReceived(message);}}}

定义回调接口 ：

public interface ActivityWsCallback {void onMessageReceived(String message);
}

使用：

public class YourActivity implements ActivityWsCallback {private WsHelper wsHelper;@Overrideprotected void onCreate(Bundle savedInstanceState) {super.onCreate(savedInstanceState);// 初始化 WsHelperwsHelper = new WsHelper();wsHelper.initSocketClient();// 设置回调wsHelper.setCallback(this);}// 实现回调接口的方法，处理收到的消息@Overridepublic void onMessageReceived(String message) {// 在这里处理收到的消息Log.d(TAG, "Received message: " + message);}
}