socket.io学习教程之基本应用（二）
前言
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)
})
})
总结
以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作能带来一定的帮助，如果有疑问大家可以留言交流，谢谢大家对脚本之家的支持。
相关文章
nodejs Assert中equal(),strictEqual(),deepEqual(),strictDeepEq
这篇文章主要介绍了node项目中遇到使用断言测试程序，看了下nodejs的api之后，对nodejs中assert断言的几个方法做个简单的记录,需要的朋友可以参考下2017-09-09
NodeJS与HTML5相结合实现拖拽多个文件上传到服务器的实现方法
这篇文章主要介绍了NodeJS与HTML5相结合实现拖拽多个文件上传到服务器的实现方法的相关资料,非常不错，具有参考借鉴价值，需要的朋友可以参考下2016-07-07
这篇文章主要介绍了如何从头实现一个node.js的koa框架，koa.js是最流行的node.js后端框架之一，有很多网站都使用koa进行开发，同时社区也涌现出了一大批基于koa封装的企业级框架。,需要的朋友可以参考下2019-06-06
node.js中express模块创建服务器和http模块客户端发请求
今天小编就为大家分享一篇关于node.js中express模块创建服务器和http模块客户端发请求，小编觉得内容挺不错的，现在分享给大家，具有很好的参考价值，需要的朋友一起跟随小编来看看吧2019-03-03
这篇文章主要为大家详细介绍了nodejs读取图片返回给浏览器显示，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2019-07-07
本文给大家介绍的是node.js的初体验，从最简单的内容开始，慢慢的深入分析node.js。并附上一则很不错的文章《7天学会nodeJS》更加详细的向我们展示了node.js的学习步骤。2015-03-03
上传图片、Excel等，毕竟几M的大小可以很快就上传到服务器。 针对于上传视频等大文件几百M或者几G的大小，就需要等待比较长的时间。这就产生了对应的解决方法，对于大文件上传时的暂停、断网、网络较差的情况下， 使用切片+断点续传就能够很好的应对上述的情况2021-06-06
这篇文章主要介绍了关于npm install过程失败的几种处理方式，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2023-06-06
Egret Framework是一款使用TypeScript语言构建的开源免费的移动游戏框架。Egret Framework的核心定位是开放，高效，优雅。通过它，你可以快速地创建HTML5类型的移动游戏，也可以将游戏项目编译输出成为目标移动平台的原生游戏应用。2014-09-09
本文主要介绍了Node.js中readline模块实现终端输入，文中通过示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2022-02-02
最新评论