JavaWeb/biliob
2
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

调整日志

Browse Source
This commit is contained in:
zlzw 2024-12-10 09:51:22 +08:00
parent 6ee610f4cc
commit d2bcd5c64a
1 changed files with 6 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/main/java/com/yutou/biliapi/net/WebSocketServer.java
View File

@ -23,6 +23,7 @@ import com.yutou.common.okhttp.HttpCallback;
import com.yutou.common.utils.ConfigTools;
import com.yutou.common.utils.Log;
import jakarta.annotation.Resource;
import lombok.Setter;
import okhttp3.Headers;
import org.java_websocket.client.WebSocketClient;
import org.java_websocket.handshake.ServerHandshake;
@ -86,13 +87,13 @@ public class WebSocketServer {
public void stopRoom(String roomId, boolean isUser) {
LiveRoomConfig roomConfig = new LiveRoomConfig();
roomConfig.setRoomId(new String(roomId));
roomConfig.setRoomId(roomId);
if (checkRoom(roomConfig)) {
roomMap.get(roomConfig).close();
roomMap.remove(roomConfig);
}
if (isUser) {
userStopList.add(roomConfig.getRoomId().toString());
userStopList.add(roomConfig.getRoomId());
}
}
@ -120,7 +121,7 @@ public class WebSocketServer {
LiveApi api = BiliLiveNetApiManager.getInstance().getApi(roomConfig.getLoginUid());
Response<HttpBody<LiveRoomInfo>> execute = null;
try {
execute = api.getRoomInfo(roomConfig.getRoomId().toString()).execute();
execute = api.getRoomInfo(roomConfig.getRoomId()).execute();
if (execute.isSuccessful()) {
roomConfig.setRoomInfo(execute.body() != null ? execute.body().getData() : null);
}
@ -211,7 +212,7 @@ public class WebSocketServer {
@Override
public void onError(Exception e) {
Log.getDynamicLogger(logTag).info("WebSocketClientTh.onError,{}", roomConfig.getRoomId());
Log.getDynamicLogger(logTag).error("WebSocketClientTh.onError,{}", roomConfig.getRoomId());
Log.e(e);
roomMap.remove(roomConfig);
heartbeatTask.cancel();
@ -262,13 +263,10 @@ public class WebSocketServer {
}
}
@Setter
private class HeartbeatTask extends TimerTask {
WebSocketClientTh socket;
public void setSocket(WebSocketClientTh socket) {
this.socket = socket;
}
@Override
public void run() {
try {