socket.io学习教程之基本应用(二)

发布时间 - 2026-01-11 00:54:19    点击率:

前言

Socket.IO支持及时、双向与基于事件的交流。它可以在每个平台、每个浏览器和每个设备上工作,可靠性和速度同样稳定。

  • 实时分析:将数据推送到客户端,这些客户端会被表示为实时计数器,图表或日志客户。
  • 实时通信和聊天:只需几行代码便可写成一个Socket.IO的”Hello,World”聊天应用。
  • 二进制流传输:从1.0版本开始,Socket.IO支持任何形式的二进制文件传输,例如:图片,视频,音频等。
  • 文档合并:允许多个用户同时编辑一个文档,并且能够看到每个用户做出的修改。

服务端与客户端连接

socket.io同时提供了服务端和客户端的API

服务端socket.io必须绑定一个http.Server实例

绑定http.Server

1、隐式绑定

通过实例化时传入端口或实例化后调用listen或attach函数进行隐式绑定。socket.io内部实例化并监听http.Server

实例化时传入端口

let io = require('socket.io')(3000)

直接通过listen或attach函数绑定。listen与attach同义

let io = require('socket.io') 
io.listen(3000) // io.attach(3000) 

2、显示绑定

可以手动指定http.Server

实例化时绑定

let server = require('http').Server(); 
let io = require('socket.io')(server)

server.listen(3000) 

通过listen或attach绑定

let server = require('http').Server(); 
let io = require('socket.io')()

io.listen(server) // io.attach(server)

server.listen(3000) 

可以绑定express或koa等http框架

express

let app = require('express') 
let server = require('http').Server(app) 
let io = require('socket.io')(server)

app.listen(3000) 

koa

let app = require('koa')() 
let server = require('http').Server(app.callback())

let io = require('socket.io')(server)

app.listen(3000) 

监听连接状态

当服务器端与客户端连接成功时,服务端会监听到connection和connect事件(connection与connect同义), 客户端会监听到connect事件, 断开连接时服务端的对应到客户端的socket与客户端均会均会监听到disconnect事件

服务端代码

let server = require('http').Server() 
let io = require('socket.io')(server)

server.listen(3000); 
io.on('connection', socket => { 
 console.log('connect')
 socket.on('disconnect', () => {
 console.log('disconnect')
 })
 socket.disconnect()
})

运行后打印

connect 
disconnect 

客户端代码

let socket = io('http://localhost:3000') 
socket.on('connect', () => { 
 console.log('connect')
})
socket.on('disconnect', () => { 
 console.log('disconnect')
})

运行后打印

connect 
disconnect 

传输数据

服务器与客户端的socket是一个关联的EventEmitter对象,客户端socket派发的事件可以通以被服务端的socket接收,服务器端socket派发的事件也可以被客户端接受。基于这种机制,可以实现双向交流。

现在模拟这样一种情况:客户端不停发送随机数,当随机数大于0.95时,服务端延时1s后向客户端发送警告以及警告次数

服务端代码

let server = require('http').Server() 
let io = require('socket.io')(server)

server.listen(3000); 
io.on('connection', socket => { 
 socket.on('random', value => {
 console.log(value)
 if (value > 0.95) {
  if (typeof socket.warning === 'undefined') socket.warning = 0
  setTimeout(() => {
  socket.emit('warn', ++socket.warning)
  }, 1000)
 }
 })
})

socket对象可以用来存储状态信息和自定义数据,如socket.warning

客户端代码

let socket = io('http://localhost:3000') 
let interval = setInterval(() => { 
 socket.emit('random', Math.random())
}, 500)
socket.on('warn', count => { 
 console.log('warning count: ' + count)
})
socket.on('disconnect', () => { 
 clearInterval(interval)
})

传输流

socket.io可以处理流

服务端代码

io.on('connection', function (socket) { 
 let stream = ss.createStream()
 ss(socket).emit('script', stream)
 fs.createReadStream(__filename).pipe(stream)
})

客户端代码

let socket = io('http://localhost:3000') 
ss(socket).on('script', stream => { 
 let buffer = '' 
 stream.on('data', data => {
 buffer += data.toString()
 })
 stream.on('end', () => {
 console.log(buffer)
 })
})

总结

以上就是这篇文章的全部内容了,希望本文的内容对大家的学习或者工作能带来一定的帮助,如果有疑问大家可以留言交流,谢谢大家对的支持。


# socket.io  # 应用场景  # socket.io教程  # nodejs  # socket.io学习教程之基础介绍(一)  # node.js中的Socket.IO使用实例  # node.js中Socket.IO的进阶使用技巧  # 基于socket.io和node.js搭建即时通信系统  # node.js中的socket.io入门实例  # 使用Angular和Nodejs、socket.io搭建聊天室及多人聊天室  # node中socket.io的事件使用详解  # node.js中使用socket.io的方法  # node.js中的socket.io的广播消息  # socket.io学习教程之深入学习篇(三)  # 客户端  # 绑定  # 服务端  # 随机数  # 是一个  # 文档  # 隐式  # 多个  # 只需  # 便可  # 自定义  # 它可以  # 可以实现  # 这篇文章  # 谢谢大家  # 可以用来  # 后向  # 应到  # 几行  # 在每个 


相关栏目: 【 网站优化151355 】 【 网络推广146373 】 【 网络技术251813 】 【 AI营销90571


相关推荐: 微信小程序 canvas开发实例及注意事项  如何用已有域名快速搭建网站?  Laravel如何实现邮箱地址验证功能_Laravel邮件验证流程与配置  详解一款开源免费的.NET文档操作组件DocX(.NET组件介绍之一)  Laravel如何使用.env文件管理环境变量?(最佳实践)  详解jQuery中基本的动画方法  千问怎样用提示词获取健康建议_千问健康类提示词注意事项【指南】  WordPress 子目录安装中正确处理脚本路径的完整指南  Laravel用户认证怎么做_Laravel Breeze脚手架快速实现登录注册功能  Laravel如何生成API文档?(Swagger/OpenAPI教程)  HTML5空格和margin有啥区别_空格与外边距的使用场景【说明】  如何在VPS电脑上快速搭建网站?  详解jQuery停止动画——stop()方法的使用  Laravel如何使用Sanctum进行API认证?(SPA实战)  Laravel怎么实现搜索高亮功能_Laravel结合Scout与Algolia全文检索【实战】  如何快速重置建站主机并恢复默认配置?  在线制作视频的网站有哪些,电脑如何制作视频短片?  Laravel如何实现API版本控制_Laravel版本化API设计方案  简单实现Android验证码  标题:Vue + Vuex + JWT 身份认证的正确实践与常见误区解析  东莞专业网站制作公司有哪些,东莞招聘网站哪个好?  极客网站有哪些,DoNews、36氪、爱范儿、虎嗅、雷锋网、极客公园这些互联网媒体网站有什么差异?  Laravel Facade的原理是什么_深入理解Laravel门面及其工作机制  微博html5版本怎么弄发语音微博_语音录制入口及时长限制操作【教程】  如何在阿里云虚拟主机上快速搭建个人网站?  高防网站服务器:DDoS防御与BGP线路的AI智能防护方案  如何确保西部建站助手FTP传输的安全性?  Laravel如何为API编写文档_Laravel API文档生成与维护方法  iOS中将个别页面强制横屏其他页面竖屏  ChatGPT回答中断怎么办 引导AI继续输出完整内容的方法  Laravel Eloquent关联是什么_Laravel模型一对一与一对多关系精讲  如何在服务器上三步完成建站并提升流量?  Android中Textview和图片同行显示(文字超出用省略号,图片自动靠右边)  UC浏览器如何切换小说阅读源_UC浏览器阅读源切换【方法】  Laravel项目结构怎么组织_大型Laravel应用的最佳目录结构实践  个人摄影网站制作流程,摄影爱好者都去什么网站?  Laravel怎么进行数据库事务处理_Laravel DB Facade事务操作确保数据一致性  Win11怎么开启自动HDR画质_Windows11显示设置HDR选项  Edge浏览器怎么启用睡眠标签页_节省电脑内存占用优化技巧  Laravel如何配置任务调度?(Cron Job示例)  Laravel怎么发送邮件_Laravel Mail类SMTP配置教程  如何做网站制作流程,*游戏网站怎么搭建?  今日头条AI怎样推荐抢票工具_今日头条AI抢票工具推荐算法与筛选【技巧】  Laravel如何配置和使用队列处理异步任务_Laravel队列驱动与任务分发实例  三星、SK海力士获美批准:可向中国出口芯片制造设备  Android中AutoCompleteTextView自动提示  rsync同步时出现rsync: failed to set times on “xxxx”: Operation not permitted  微信小程序 scroll-view组件实现列表页实例代码  什么是JavaScript解构赋值_解构赋值有哪些实用技巧  如何用PHP快速搭建CMS系统?