保持websocket长时间连接永不断开-Toy模板网

这篇具有很好参考价值的文章主要介绍了保持websocket长时间连接永不断开。希望对大家有所帮助。如果存在错误或未考虑完全的地方，请大家不吝赐教，您也可以点击"举报违法"按钮提交疑问。

1、定期发送心跳包（ping/pong）
客户端和服务器端都需要定期发送ping消息,并相应得到pong消息,以确保连接仍然正常。如果超过一定时间没收到pong,需要主动关闭连接。
JS客户端代码：

//定期发送ping
setInterval(() => {
	websocket.send('ping');
}, 30000);

Python客户端代码：

#定时发送ping
def heartbeat() :
    while True:
        ws.send("ping")
        time.sleep(30) #30s一次
#开启定时任务
threading.Thread(target=heartbeat).start()

java服务器端代码

@ServerEndpoint("/websocket")
public class WebSocketServer {
  private Session session;
  
  @OnMessage
  public void onMessage(String message, Session session) {
    this.session = session;
    if (message.equals("ping")) {
      try {
        session.getBasicRemote().sendPong(null);  // 回复pong
      } catch (IOException e) {
        e.printStackTrace();
      }
    } else {
      // 处理其他消息
    }
  } 
}

2、捕获关闭连接事件并重连websocket
JS客户端代码：

//连接关闭的回调方法
websocket.onclose = function() {
	setMessageInnerHTML("WebSocket连接关闭");
	setTimeout(() => {
    	webSocket = new WebSocket('ws://url');  // 重新连接
  	}, 5000);  // 5秒后重连
}

Python客户端代码：

def on_close(ws):
    timer = threading.Timer(5, connect)
    timer.start()
ws.on_close = on_close
def connect():
    ws.connect("ws://url")

3、实现断线重连
JS客户端：

setInterval(() => {
  if (!navigator.onLine) {  // 网络断开
    setTimeout(() => {    
      webSocket = new WebSocket('ws://url');  // 网络恢复,重连   
    }, 5000);
  }  
}, 1000);

Python客户端：文章来源地址https://www.toymoban.com/news/detail-601776.html

def get_network_info(): 
    return networkx.is_connected()
def reconnect():
    timer = threading.Timer(5, connect)
    timer.start()
def check_network():
    while True:
        if not get_network_info():
            reconnect()
        time.sleep(10)
threading.Thread(target=check_network).start()