饶子涵 2022-07-19 19:14 采纳率: 33.3%
浏览 45
已结题

vue封装websock后 重连心跳怎么写

请问怎么添加websocket的心跳 重连机制?
这是已经封装好的websocket

var websock = null;
var limitConnect = 3;  // 断线重连次数
var timeConnect = 0;
var global_callback = null;
var serverPort = "80"; // webSocket连接端口
var wsuri = "ws://baidu.com";

function createWebSocket(callback) {

    if (websock == null || typeof websock !== WebSocket) {
        initWebSocket(callback);
    }
}

function initWebSocket(callback) {
    global_callback = callback;
    // 初始化websocket
    websock = new WebSocket(wsuri);
    websock.onmessage = function (e) {
        websocketonmessage(e);
    };
    websock.onclose = function (e) {
        websocketclose(e);
    };
    websock.onopen = function () {
        websocketOpen();
    };

    // 连接发生错误的回调方法
    websock.onerror = function () {
        console.log("WebSocket连接发生错误");
        //createWebSocket();啊,发现这样写会创建多个连接,加延时也不行
    };
}

// 实际调用的方法
function sendSock(agentData) {

    if (websock.readyState === websock.OPEN) {
        // 若是ws开启状态
        websocketsend(agentData);
    } else if (websock.readyState === websock.CONNECTING) {
        // 若是 正在开启状态,则等待1s后重新调用
        setTimeout(function () {
            sendSock(agentData);
        }, 1000);
    } else {
        // 若未开启 ,则等待1s后重新调用
        setTimeout(function () {
            sendSock(agentData);
        }, 1000);
    }
}

function closeSock() {
    websock.close();
}

// 数据接收
function websocketonmessage(msg) {
    // console.log("收到数据:"+JSON.parse(e.data));
    // console.log("收到数据:"+msg);

    // global_callback(JSON.parse(msg.data));

    // 收到信息为Blob类型时
    let result = null;
    // debugger
    if (msg.data instanceof Blob) {
        const reader = new FileReader();
        reader.readAsText(msg.data, "UTF-8");
        reader.onload = (e) => {
            result = JSON.parse(reader.result);
            //console.log("websocket收到", result);
            global_callback(result);
        };
    } else {
        result = JSON.parse(msg.data);
        //console.log("websocket收到", result);
        global_callback(result);
    }
}

// 数据发送
function websocketsend(agentData) {
    console.log("发送数据:" + agentData);
    websock.send(agentData);

}

// 关闭
function websocketclose(e) {
    reconnect(wsuri);
    console.log("connection closed (" + e.code + ")");
}
// 重连
function reconnect(service) {
    // lockReconnect加锁,防止onclose、onerror两次重连
    if (limitConnect > 0) {
        limitConnect--;
        timeConnect++;
        console.log("第" + timeConnect + "次重连");
        // 进行重连
        setTimeout(function () {
            createWebSocket();
        }, 2000);

    } else {
        console.log("TCP连接已超时");
    }
}
// 心跳 * 回应
setInterval(function () {
    var websocket = new WebSocket(wsServer);
    websocket.send('');

}, 1000 * 100)


function websocketOpen(e) {
    console.log("连接打开");
}

export { sendSock, createWebSocket, closeSock };

  • 写回答

1条回答 默认 最新

  • “mint” 2022-07-20 10:51
    关注
    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论 编辑记录

报告相同问题?

问题事件

  • 系统已结题 7月28日
  • 已采纳回答 7月20日
  • 创建了问题 7月19日

悬赏问题

  • ¥15 电脑开机过商标后就直接这样,求解各位
  • ¥15 mysql , 用自己创建的本地主机和用户名 登录不上
  • ¥15 关于#web项目#的问题,请各位专家解答!
  • ¥15 vmtools环境不正常
  • ¥15 请问如何在Ubuntu系统中安装使用microsoft R open?
  • ¥15 jupyter notebook
  • ¥30 informer时间序列预测
  • ¥20 SSR引物多态性分析
  • ¥15 大漠插件在Win11易语言注册调用和免注册灵异事件,VS上注册调用完全没问题
  • ¥15 Addressable缓存机制做热更新的问题