spingboot集成okhttp实现websocket客户端实例

com.squareup.okhttp3okhttp4.2.2

package com.wlf.ws;import com.alibaba.fastjson.JSONObject;
import com.wlf.entity.WSResponse;
import lombok.extern.slf4j.Slf4j;
import okhttp3.Response;
import okhttp3.WebSocket;
import okhttp3.WebSocketListener;
import okio.ByteString;import java.io.IOException;&＃64;Slf4j
public class SubTitleWS extends WebSocketListener {/*** websocket连接建立后来到这个方法** &＃64;param webSocket* &＃64;param response*/&＃64;Overridepublic void onOpen(WebSocket webSocket, Response response) {super.onOpen(webSocket, response);// 打印连接建立后的响应try {log.info(response.body().string());} catch (IOException e) {log.error("call onOpen failed, error :{}", e.getMessage());}}&＃64;Overridepublic void onMessage(WebSocket webSocket, String text) {super.onMessage(webSocket, text);log.info("receive&＃61;>" &＃43; text);//处理返回数据WSResponse response &＃61; (WSResponse) JSONObject.parse(text);if (response !&＃61; null) {if (!"200".equals(response.getCode())) {log.error("code&＃61;> :{}, error&＃61;> :{}", response.getCode(), response.getMessage());return;}}}&＃64;Overridepublic void onMessage(WebSocket webSocket, ByteString bytes) {super.onMessage(webSocket, bytes);}&＃64;Overridepublic void onClosing(WebSocket webSocket, int code, String reason) {super.onClosing(webSocket, code, reason);log.info("socket closing.");}&＃64;Overridepublic void onClosed(WebSocket webSocket, int code, String reason) {super.onClosed(webSocket, code, reason);log.info("socket closed.");}&＃64;Overridepublic void onFailure(WebSocket webSocket, Throwable t, Response response) {super.onFailure(webSocket, t, response);if (response &＃61;&＃61; null) {log.error("onFailure, response is null.");return;}try {log.error("onFailure, code: {}, errmsg: {}", response.code(), response.body().string());} catch (IOException e) {log.warn("onFailure failed, error: {}", e.getMessage());}}
}

package com.wlf.service;import com.wlf.utils.MD5Util;
import com.wlf.ws.SubTitleWS;
import lombok.extern.slf4j.Slf4j;
import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.WebSocket;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;import java.security.NoSuchAlgorithmException;&＃64;Slf4j
&＃64;Service
public class LiveMixService {// websocket客户端对象final OkHttpClient webSocketClient &＃61; new OkHttpClient.Builder().build();// websocket请求url&＃64;Value("${subTitleUrl}")private String subTitleUrl;&＃64;Value("${secret}")private String secret;/*** 发起字幕合成*/public void liveMix(String liveId) throws NoSuchAlgorithmException {sendRequest(liveId);}/*** 发送websocket建立连接请求** &＃64;param liveId*/private void sendRequest(String liveId) throws NoSuchAlgorithmException {String seed &＃61; subTitleUrl &＃43; "?liveId&＃61;" &＃43; liveId &＃43; "&＃43;" &＃43; secret;String md5 &＃61; MD5Util.md5Sum(seed);String url &＃61; subTitleUrl &＃43; "?liveId&＃61;" &＃43; liveId &＃43; "&md5&＃61;" &＃43; md5;log.info("websocket url: {}", url);// 构造请求对象Request request &＃61; new Request.Builder().url(url).build();// 调用websocket服务端WebSocket webSocket &＃61; webSocketClient.newWebSocket(request, new SubTitleWS());}
}

2020-04-29 18:14:11 [http-nio-8089-exec-1] INFO com.wlf.service.LiveMixService - websocket url: ws://100.100.10.110:8800/ws/subtitleConnect?liveId&＃61;1234&md5&＃61;6021b9576f99c883949fb0901a099218
2020-04-29 18:15:12 [OkHttp http://100.100.10.110:8800/...] INFO com.wlf.ws.SubTitleWS -
2020-04-29 18:15:12 [OkHttp http://100.100.10.110:8800/...] INFO com.wlf.ws.SubTitleWS - receive&＃61;>{"code":"200","message":"success"}
2020-04-29 18:15:12 [OkHttp http://100.100.10.110:8800/...] ERROR com.wlf.ws.SubTitleWS - onFailure, response is null.