源码网商城,靠谱的源码在线交易网站 我的订单 购物车 帮助

源码网商城

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

  • 时间:2020-08-20 11:07 编辑: 来源: 阅读:
  • 扫一扫,手机访问
摘要:socket.io学习教程之基本应用(二)
[b]前言[/b] Socket.IO支持及时、双向与基于事件的交流。它可以在每个平台、每个浏览器和每个设备上工作,可靠性和速度同样稳定。 [list] [*]实时分析:将数据推送到客户端,这些客户端会被表示为实时计数器,图表或日志客户。[/*] [*]实时通信和聊天:只需几行代码便可写成一个Socket.IO的”Hello,World”聊天应用。[/*] [*]二进制流传输:从1.0版本开始,Socket.IO支持任何形式的二进制文件传输,例如:图片,视频,音频等。[/*] [*]文档合并:允许多个用户同时编辑一个文档,并且能够看到每个用户做出的修改。[/*] [/list] [b]服务端与客户端连接[/b] socket.io同时提供了服务端和客户端的API 服务端socket.io必须绑定一个http.Server实例 [b]绑定http.Server[/b] 1、隐式绑定 通过实例化时传入端口或实例化后调用listen或attach函数进行隐式绑定。socket.io内部实例化并监听[code]http.Server[/code] 实例化时传入端口
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) 
[b]监听连接状态[/b] 当服务器端与客户端连接成功时,服务端会监听到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 
[b]传输数据[/b] 服务器与客户端的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对象可以用来存储状态信息和自定义数据,如[code]socket.warning[/code] 客户端代码
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)
})
[b]传输流[/b] 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)
 })
})
[b]总结[/b] 以上就是这篇文章的全部内容了,希望本文的内容对大家的学习或者工作能带来一定的帮助,如果有疑问大家可以留言交流,谢谢大家对编程素材网的支持。
  • 全部评论(0)
联系客服
客服电话:
400-000-3129
微信版

扫一扫进微信版
返回顶部