免费互动小程序_socket.io学习教程之根本应用(二

摘要: socket.io学习培训实例教程之基本运用(二) socket.io出示了根据恶性事件的即时双重通信,下边本文关键给大伙儿详细介绍了socket.io基本运用的有关材料,对大伙儿具备一定的参照...

socket.io学习教程之基本应用(二)       socket.io提供了基于事件的实时双向通讯,下面这篇文章主要给大家介绍了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('pre>

运行后打印

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('pre>

传输流

socket.io可以处理流

服务端代码

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

客户端代码

let socket = io('pre>

总结

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




联系我们

全国服务热线:4000-399-000 公司邮箱:343111187@qq.com

  工作日 9:00-18:00

关注我们

官网公众号

官网公众号

Copyright?2020 广州凡科互联网科技股份有限公司 版权所有 粤ICP备10235580号 客服热线 18720358503

技术支持:个人网页