热门标签 | HotTags
当前位置:  开发笔记 > 编程语言 > 正文

连接升级期间间歇性长时间延迟

摘要我们正在使用socket.ioJS客户端从运行python-socketio

摘要

我们正在使用socket.io JS客户端从运行python-socketio的后端接收常规服务状态更新。大多数情况下,它运行良好,但我们间歇性地看到一种情况,即连接升级过程中约有30秒的延迟,在此期间未收到任何消息。最终,连接被关闭(尽管该过程看起来有些混乱)并发生了重新连接,此后,一切再次正常。我试图弄清楚为什么会出现这种延迟。

我们可以通过单元测试相当轻松地重现此内容,该单元测试可以反复导航到相关页面并再次离开,从而强制重新创建套接字并每次都重新建立连接。经过几次迭代,我们可靠地遇到了这个问题。

我正在使用socket.io v2.3.0(尽管在2.2.0中也是如此)。

代码

客户代码的简化版本:

function admin_vm() {
const self = this;
self.socket = io.connect({
path: window.config.project_url + 'status/system/socket.io'
});
self.socket.on('connect',function() {
console.log('Socket connected,joining admin room');
self.socket.emit('join','admin');
});
self.socket.on('update',function (update) {
update = JSON.parse(update);
const u = update;
console.log(
'Update for system status left server [' + u.timestamp +
'] arrived here [' + new Date().toString() + '] update count [' + update_count++ + ']'
);
// Apply the update to the UI here...
});
}

日志

登录socket.io调试后,我们看到以下内容:

12:58:46.117 admin.js 113:12 "admin.js document ready - creating vm"
12:58:46.117 admin.js 32:12 "Creating admin socket"
12:58:46.119 socket.io.js 391:131 "socket.io-client:url parse %s +0ms" "https://..."
12:58:46.121 socket.io.js 391:131 "socket.io-client new io instance for %s +0ms" "https://..."
12:58:46.122 socket.io.js 391:131 "socket.io-client:manager readyState %s +0ms" "closed"
12:58:46.123 socket.io.js 391:131 "socket.io-client:manager opening %s +1ms" "https://..."
12:58:46.124 socket.io.js 391:131 "engine.io-client:socket creating transport \"%s\" +0ms" "polling"
12:58:46.125 socket.io.js 391:131 "engine.io-client:polling polling +0ms"
12:58:46.126 socket.io.js 391:131 "engine.io-client:polling-xhr xhr poll +0ms"
12:58:46.127 socket.io.js 391:131 "engine.io-client:polling-xhr xhr open %s: %s +1ms" "GET" "https://.../.../socket.io/?EIO=3&transport=polling&t=MxglP_k"
12:58:46.128 socket.io.js 391:131 "engine.io-client:polling-xhr xhr data %s +2ms" null
12:58:46.131 socket.io.js 391:131 "engine.io-client:socket setting transport %s +7ms" "polling"
12:58:46.132 socket.io.js 391:131 "socket.io-client:manager connect attempt will timeout after %d +9ms" 20000
12:58:46.133 socket.io.js 391:131 "socket.io-client:manager readyState %s +2ms" "opening"
12:58:46.164 socket.io.js 391:131 "engine.io-client:polling polling got data %s +39ms" ArrayBuffer(119)
12:58:46.166 socket.io.js 391:131 "engine.io-client:socket socket receive: type \"%s\",data \"%s\" +34ms" "open" "{\"sid\":\"6294b24868144273b4a9bceaf0e439f9\",\"upgrades\":[\"websocket\"],\"pingTimeout\":60000,\"pingInterval\":25000}"
12:58:46.167 socket.io.js 391:131 "engine.io-client:socket socket open +2ms"
12:58:46.168 socket.io.js 391:131 "socket.io-client:manager open +34ms"
12:58:46.169 socket.io.js 391:131 "socket.io-client:manager cleanup +1ms"
12:58:46.170 socket.io.js 391:131 "socket.io-client:socket transport is open - connecting +0ms"
12:58:46.171 socket.io.js 391:131 "engine.io-client:socket starting upgrade probes +4ms"
12:58:46.172 socket.io.js 391:131 "engine.io-client:socket probing transport \"%s\" +1ms" "websocket"
12:58:46.173 socket.io.js 391:131 "engine.io-client:socket creating transport \"%s\" +1ms" "websocket"
12:58:46.177 socket.io.js 391:131 "engine.io-client:socket socket receive: type \"%s\",data \"%s\" +4ms" "message" "0"
12:58:46.178 admin.js 46:16 "Socket connected,joining admin room"
12:58:46.179 socket.io.js 391:131 "socket.io-client:manager writing packet {\"type\":2,\"data\":[\"join\",\"admin\"],\"options\":{\"compress\":true},\"nsp\":\"/\"} +9ms"
12:58:46.180 socket.io.js 1646:132 "socket.io-parser encoding packet {\"type\":2,\"nsp\":\"/\"} +0ms"
12:58:46.181 socket.io.js 1646:132 "socket.io-parser encoded {\"type\":2,\"nsp\":\"/\"} as %s +0ms" "2[\"join\",\"admin\"]"
12:58:46.181 socket.io.js 391:131 "engine.io-client:socket flushing %d packets in socket +3ms" 1
12:58:46.182 socket.io.js 391:131 "engine.io-client:polling-xhr xhr open %s: %s +52ms" "POST" "https://.../.../socket.io/?EIO=3&transport=polling&t=MxglQ0a&sid=6294b24868144273b4a9bceaf0e439f9"
12:58:46.183 socket.io.js 391:131 "engine.io-client:polling-xhr xhr data %s +1ms" "18:42[\"join\",\"admin\"]"
12:58:46.183 socket.io.js 391:131 "engine.io-client:polling polling +19ms"
12:58:46.183 socket.io.js 391:131 "engine.io-client:polling-xhr xhr poll +1ms"
12:58:46.184 socket.io.js 391:131 "engine.io-client:polling-xhr xhr open %s: %s +0ms" "GET" "https://.../.../socket.io/?EIO=3&transport=polling&t=MxglQ0c&sid=6294b24868144273b4a9bceaf0e439f9"
12:58:46.184 socket.io.js 391:131 "engine.io-client:polling-xhr xhr data %s +1ms" null
12:58:46.193 socket.io.js 391:131 "engine.io-client:socket probe transport \"%s\" opened +13ms" "websocket"
12:58:46.211 socket.io.js 391:131 "engine.io-client:polling polling got data %s +28ms" ArrayBuffer(4)
12:58:46.212 socket.io.js 391:131 "engine.io-client:socket socket receive: type \"%s\",data \"%s\" +19ms" "noop" undefined
12:58:46.212 socket.io.js 391:131 "engine.io-client:polling polling +1ms"
12:58:46.213 socket.io.js 391:131 "engine.io-client:polling-xhr xhr poll +29ms"
12:58:46.213 socket.io.js 391:131 "engine.io-client:polling-xhr xhr open %s: %s +0ms" "GET" "https://.../.../socket.io/?EIO=3&transport=polling&t=MxglQ14&sid=6294b24868144273b4a9bceaf0e439f9"
12:58:46.214 socket.io.js 391:131 "engine.io-client:polling-xhr xhr data %s +1ms" null
12:58:46.220 socket.io.js 391:131 "engine.io-client:socket probe transport \"%s\" pong +7ms" "websocket"
12:58:46.220 socket.io.js 391:131 "engine.io-client:socket pausing current transport \"%s\" +1ms" "polling"
12:58:46.220 socket.io.js 391:131 "engine.io-client:polling we are currently polling - waiting to pause +8ms"
12:59:11.356 socket.io.js 391:131 "engine.io-client:socket writing ping packet - expecting pong within %sms +25s" 60000
12:59:17.224 socket.io.js 391:131 "engine.io-client:polling polling got data %s +31s" ArrayBuffer(0)
12:59:17.224 socket.io.js 391:131 "engine.io-client:polling pre-pause polling complete +2ms"
12:59:17.224 socket.io.js 391:131 "engine.io-client:polling paused +1ms"
12:59:17.224 socket.io.js 391:131 "engine.io-client:socket changing transport and sending upgrade packet +6s"
12:59:17.224 socket.io.js 391:131 "engine.io-client:socket setting transport %s +1ms" "websocket"
12:59:17.224 socket.io.js 391:131 "engine.io-client:socket clearing existing transport %s +0ms" "polling"
12:59:17.224 socket.io.js 391:131 "engine.io-client:polling ignoring poll - transport state \"%s\" +4ms" "paused"
12:59:17.224 socket.io.js 391:131 "engine.io-client:socket flushing %d packets in socket +3ms" 1
12:59:17.225 admin.js 79:16 "Update for system status left server [December 9th 2019,12:58:46 pm] arrived here [December 9th 2019,12:59:17 pm] update count [0]"
12:59:17.225 admin.js 97:20 "First update received"

完整日志(包括正常运行时的日志)是我在python-socketio:https://github.com/miguelgrinberg/python-socketio/issues/393

上提出的问题

当它在12:58:46说we are currently polling - waiting to pause时(即30秒延迟开始的地方),会发生什么情况?还等什么呢?

我目前发现的唯一解决方法是直接使用websocket传输,而不是从轮询和升级开始。一旦我这样做,它就可以正常工作,但是显然,这意味着它不能在任何不支持websocket的地方使用。





推荐阅读
  • 微信小程序实现类似微博的无限回复功能,内置云开发数据库支持
    本文详细介绍了如何利用微信小程序实现类似于微博的无限回复功能,并充分利用了微信云开发的数据库支持。文中不仅提供了关键代码片段,还包含了完整的页面代码,方便开发者按需使用。此外,HTML页面中包含了一些示例图片,开发者可以根据个人喜好进行替换。文章还将展示详细的数据库结构设计,帮助读者更好地理解和实现这一功能。 ... [详细]
  • 本文详细探讨了 jQuery 中 `ajaxSubmit` 方法的使用技巧及其应用场景。首先,介绍了如何正确引入必要的脚本文件,如 `jquery.form.js` 和 `jquery-1.8.0.min.js`。接着,通过具体示例展示了如何利用 `ajaxSubmit` 方法实现表单的异步提交,包括数据的发送、接收和处理。此外,还讨论了该方法在不同场景下的应用,如文件上传、表单验证和动态更新页面内容等,提供了丰富的代码示例和最佳实践建议。 ... [详细]
  • C++ 异步编程中获取线程执行结果的方法与技巧及其在前端开发中的应用探讨
    本文探讨了C++异步编程中获取线程执行结果的方法与技巧,并深入分析了这些技术在前端开发中的应用。通过对比不同的异步编程模型,本文详细介绍了如何高效地处理多线程任务,确保程序的稳定性和性能。同时,文章还结合实际案例,展示了这些方法在前端异步编程中的具体实现和优化策略。 ... [详细]
  • 本文介绍了如何利用Shell脚本高效地部署MHA(MySQL High Availability)高可用集群。通过详细的脚本编写和配置示例,展示了自动化部署过程中的关键步骤和注意事项。该方法不仅简化了集群的部署流程,还提高了系统的稳定性和可用性。 ... [详细]
  • 在ElasticStack日志监控系统中,Logstash编码插件自5.0版本起进行了重大改进。插件被独立拆分为gem包,每个插件可以单独进行更新和维护,无需依赖Logstash的整体升级。这不仅提高了系统的灵活性和可维护性,还简化了插件的管理和部署过程。本文将详细介绍这些编码插件的功能、配置方法,并通过实际生产环境中的应用案例,展示其在日志处理和监控中的高效性和可靠性。 ... [详细]
  • Python 伦理黑客技术:深入探讨后门攻击(第三部分)
    在《Python 伦理黑客技术:深入探讨后门攻击(第三部分)》中,作者详细分析了后门攻击中的Socket问题。由于TCP协议基于流,难以确定消息批次的结束点,这给后门攻击的实现带来了挑战。为了解决这一问题,文章提出了一系列有效的技术方案,包括使用特定的分隔符和长度前缀,以确保数据包的准确传输和解析。这些方法不仅提高了攻击的隐蔽性和可靠性,还为安全研究人员提供了宝贵的参考。 ... [详细]
  • 本文深入探讨了NoSQL数据库的四大主要类型:键值对存储、文档存储、列式存储和图数据库。NoSQL(Not Only SQL)是指一系列非关系型数据库系统,它们不依赖于固定模式的数据存储方式,能够灵活处理大规模、高并发的数据需求。键值对存储适用于简单的数据结构;文档存储支持复杂的数据对象;列式存储优化了大数据量的读写性能;而图数据库则擅长处理复杂的关系网络。每种类型的NoSQL数据库都有其独特的优势和应用场景,本文将详细分析它们的特点及应用实例。 ... [详细]
  • Web开发框架概览:Java与JavaScript技术及框架综述
    Web开发涉及服务器端和客户端的协同工作。在服务器端,Java是一种优秀的编程语言,适用于构建各种功能模块,如通过Servlet实现特定服务。客户端则主要依赖HTML进行内容展示,同时借助JavaScript增强交互性和动态效果。此外,现代Web开发还广泛使用各种框架和库,如Spring Boot、React和Vue.js,以提高开发效率和应用性能。 ... [详细]
  • 深入探索HTTP协议的学习与实践
    在初次访问某个网站时,由于本地没有缓存,服务器会返回一个200状态码的响应,并在响应头中设置Etag和Last-Modified等缓存控制字段。这些字段用于后续请求时验证资源是否已更新,从而提高页面加载速度和减少带宽消耗。本文将深入探讨HTTP缓存机制及其在实际应用中的优化策略,帮助读者更好地理解和运用HTTP协议。 ... [详细]
  • 本文探讨了使用JavaScript在不同页面间传递参数的技术方法。具体而言,从a.html页面跳转至b.html时,如何携带参数并使b.html替代当前页面显示,而非新开窗口。文中详细介绍了实现这一功能的代码及注释,帮助开发者更好地理解和应用该技术。 ... [详细]
  • 线程能否先以安全方式获取对象,再进行非安全发布? ... [详细]
  • Amoeba 通过优化 MySQL 的读写分离功能显著提升了数据库性能。作为一款基于 MySQL 协议的代理工具,Amoeba 能够高效地处理应用程序的请求,并根据预设的规则将 SQL 请求智能地分配到不同的数据库实例,从而实现负载均衡和高可用性。该方案不仅提高了系统的并发处理能力,还有效减少了主数据库的负担,确保了数据的一致性和可靠性。 ... [详细]
  • 本文详细介绍了一种利用 ESP8266 01S 模块构建 Web 服务器的成功实践方案。通过具体的代码示例和详细的步骤说明,帮助读者快速掌握该模块的使用方法。在疫情期间,作者重新审视并研究了这一未被充分利用的模块,最终成功实现了 Web 服务器的功能。本文不仅提供了完整的代码实现,还涵盖了调试过程中遇到的常见问题及其解决方法,为初学者提供了宝贵的参考。 ... [详细]
  • 本文探讨了如何利用 jQuery 的 JSONP 技术实现跨域调用外部 Web 服务。通过详细解析 JSONP 的工作原理及其在 jQuery 中的应用,本文提供了实用的代码示例和最佳实践,帮助开发者解决跨域请求中的常见问题。 ... [详细]
  • Nginx 反向代理配置与应用指南
    本文详细介绍了 Nginx 反向代理的配置与应用方法。首先,用户可以从官方下载页面(http://nginx.org/en/download.html)获取最新稳定版 Nginx,推荐使用 1.14.2 版本。下载并解压后,通过双击 `nginx.exe` 文件启动 Nginx 服务。文章进一步探讨了反向代理的基本原理及其在实际应用场景中的配置技巧,包括负载均衡、缓存管理和安全设置等,为用户提供了一套全面的实践指南。 ... [详细]
author-avatar
百厌仔小菜一碟
这个家伙很懒,什么也没留下!
PHP1.CN | 中国最专业的PHP中文社区 | DevBox开发工具箱 | json解析格式化 |PHP资讯 | PHP教程 | 数据库技术 | 服务器技术 | 前端开发技术 | PHP框架 | 开发工具 | 在线工具
Copyright © 1998 - 2020 PHP1.CN. All Rights Reserved | 京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有