断线重连

Author: danbai225

.idea/workspace.xml

@@ -38,6 +38,7 @@ public class CinemaSocket {
      * 房间池
      */
     public static ConcurrentHashMap<Integer, CinemaRoom> ROOM_POOL = new ConcurrentHashMap<>();
+    public static ConcurrentHashMap<String, Integer> DELETE_P00L =new ConcurrentHashMap<>();
     /**
      * 与某个客户端的连接会话，需要通过它来给客户端发送数据
      */
@@ -52,12 +53,21 @@ public class CinemaSocket {
     public void onOpen(Session session, @PathParam("username") String username) {
         this.session = session;
         this.username=username;
+        if(DELETE_P00L.containsKey(username)){
+            this.roomId=DELETE_P00L.get(username);
+        }
         //加入POOL中
         POOL.put(session.getId(),this);
+        //断线重连加房间
+        if(roomId!=0){
+            CinemaRoom room= ROOM_POOL.get(roomId);
+            if(room!=null){
+                ROOM_POOL.get(roomId).getSockets().add(session.getId());
+            }
+        }
         //在线数加1
         log.info("有新连接加入！当前在线人数为" + POOL.size());
         CinemaSocketManagement.info(session.getId());
-
     }
 
     /**
@@ -68,6 +78,7 @@ public void onClose(Session session) {
         //从POOL中删除
         CinemaSocket cinemaSocket = POOL.get(session.getId());
         if(cinemaSocket!=null){
+            DELETE_P00L.put(cinemaSocket.getUsername(),cinemaSocket.roomId);
         if(cinemaSocket.roomId!=0){
             CinemaSocketManagement.exitRoom(session.getId());
         }
@@ -101,6 +112,7 @@ public void onMessage(String message,Session session) {
                         case  "sendChat":CinemaSocketManagement.sendChat(id,jsonObject.getString("msg"));break;
                         case  "sendUrl":CinemaSocketManagement.sendUrl(id,jsonObject.getString("url"));break;
                         case  "sendTime":CinemaSocketManagement.sendTime(id,jsonObject.getDouble("time"));break;
+                        case "transfer":CinemaSocketManagement.transfer(id,jsonObject.getString("id"));break;
                         default:log.info(message);
                     }}
                 } catch (NullPointerException e) {

src/main/java/com/danbai/ys/websocket/CinemaSocket.java

@@ -214,4 +214,11 @@ public static void sendTime(String socketId,double time){
             SpringUtil.getBean(CinemaSocketAsync.class).sendRoomMsgPassAuthor(room.getId(),sendMsg.toJSONString());
         }
     }
+    public static void transfer(String socketId,String transferId){
+        CinemaSocket cinemaSocket = CinemaSocket.POOL.get(socketId);
+        CinemaRoom room = CinemaSocket.ROOM_POOL.get(cinemaSocket.getRoomId());
+        if(room.getAuthorId().equals(socketId)){
+            CinemaSocket.ROOM_POOL.get(cinemaSocket.getRoomId()).setAuthorId(transferId);
+        }
+    }
 }

src/main/java/com/danbai/ys/websocket/CinemaSocketManagement.java

@@ -128,15 +128,14 @@ <h3 id="fangjianInfo"></h3>
 <script src="https://cdn.jsdelivr.net/npm/cdnbye@latest"></script>
 <script src="https://cdn.jsdelivr.net/npm/p2p-dplayer@latest"></script>
 <script src="https://cdn.p00q.cn/ys/js/AgoraRTCSDK-3.0.1.js"></script>
-<script src="https://cdn.p00q.cn/ys/js/materialize.min.js"></script>
+<script src="https://cdn.p00q.cn/ys/js/reconnecting-websocket.min.js"></script>
 <script th:inline="javascript">
  /*<![CDATA[*/
  var username = /*[[${session.user.username}]]*/ null;
  /*]]>*/
  fangzhu = null;
  ysurl = "";
- id = null;
-
+ wsurl="wss://dbys.vip/wss/cinema/socket/"+username;
  //播放器
  const dp = new DPlayer({
   autoplay: true,
@@ -190,10 +189,9 @@ <h3 id="fangjianInfo"></h3>
   Notiflix.Loading.Init({
    clickToClose: true
   });
-
  });
 
- var ws = new WebSocket('wss://dbys.vip/wss/cinema/socket/' + username);
+ var ws = new ReconnectingWebSocket(wsurl);
  //回调、事件函数区
  ws.onopen = function (evt) {
   console.log('连接到服务器');
@@ -217,8 +215,11 @@ <h3 id="fangjianInfo"></h3>
    case "sendTime": sendTime(json.time); break;
   }
  };
- ws.onclose = function (evt) {
+ ws.onclose = function () {
   console.log('断开了连接');
+  if(fangzhu!=null){
+   console.log(123)
+  }
  };
  //加入房间
  function joinbt(e) {
@@ -357,7 +358,16 @@ <h3 id="fangjianInfo"></h3>
   $("#roomOnline").html('(' + data.online + ')');
   $(".user").remove();
   data.users.forEach(user => {
-   u = '<div class="user" uid="' + user.id + '">' + user.username + '</div>';
+   if(username==data.author&user.username!=username){
+    u='<div class="user" uid="' + user.id + '">' + user.username +'<button class="btn btn-success" type="button" onclick="transfer('+user.id+')">给他房主</button>'+'</div>';
+  }else{
+    if(user.username==data.author){
+     u = '<div class="user" uid="' + user.id + '">' + user.username + '👑</div>';
+    }else {
+     u = '<div class="user" uid="' + user.id + '">' + user.username + '</div>';
+    }
+
+  }
   $('#users').append(u);
  })
  }
@@ -373,14 +383,18 @@ <h3 id="fangjianInfo"></h3>
           }
   );
  }
+ function transfer(id){
+  ws.send(toJsonStr({type:"transfer",id:id}));
+ }
  //退出房间
  $('.exitRoom').click(function(){
+  fangzhu=null;
+  ysurl=null;
   ws.send(toJsonStr({type:"exitRoom"}))
   $("#shouye").show();
   $("#fangjian").hide();
   publish(rtc);
   dp.pause();
-  ysurl="";
  })
  //url
  function sendUrl(url) {