socket.io之二: 基本应用

栏目: 后端 · 发布时间: 6年前

内容简介:socket.io之二: 基本应用

socket.io提供了基于事件的实时双向通讯

服务端与客户端连接

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

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

绑定http.Server

  1. 隐式绑定

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

  • 实例化时传入端口
let io = require('socket.io')(3000)
  • 直接通过 listenattach 函数绑定。 listenattach 同义
let io = require('socket.io')  
io.listen(3000) // io.attach(3000)
  1. 显示绑定

可以手动指定http.Server

  • 实例化时绑定
let server = require('http').Server();  
let io = require('socket.io')(server)

server.listen(3000)
  • 通过 listenattach 绑定
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)

监听连接状态

当服务器端与客户端连接成功时,服务端会监听到 connectionconnect 事件(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之二: 基本应用》,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对 码农网 的支持!

查看所有标签

猜你喜欢:

本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们

深入浅出Ajax

深入浅出Ajax

(美)Brett McLaughlin / 东南大学出版社 / 2006-5 / 98.00元

本书将教会您如何在很短的时间内掌握使用JavaScript代码来向服务器提交异步请求?同时,您可以学习如何使用诸如动态HTML、XML、JSON、DOM等技术来解决开发过程中遇到的许多问题。让你从那些繁琐而笨拙的网站开发技术中彻底解放出来!本书将是一本指导您进行异步开发的经典参考书籍。   作为一名网站设计人员,您也许时常因为遇到以下情况而烦恼:用户只是移动了鼠标就要从服务器重载数据......一起来看看 《深入浅出Ajax》 这本书的介绍吧!

HTML 压缩/解压工具
HTML 压缩/解压工具

在线压缩/解压 HTML 代码

在线进制转换器
在线进制转换器

各进制数互转换器

HEX HSV 转换工具
HEX HSV 转换工具

HEX HSV 互换工具