使用Adonis.js的Socket.io

Question

我使用的是Adonis4.1.0，而Adonis-websocket只适用于v3。谁能告诉我在Adonis4.1.0中使用socket.io的变通方法？

Answer 1

很显然，他们不久前就在做这件事，它是基于socket.io的，但由于内存泄漏等一些问题，他们决定直接使用websockets，请查看以下讨论：

https://github.com/adonisjs/discussion/issues/51

https://forum.adonisjs.com/t/integrating-socket-io-with-adonis-4/519

您是否尝试过在不依赖Adonis的情况下使用socket.io？，例如：

var app = require('express')();
var http = require('http').Server(app);
var io = require('socket.io')(http);

app.get('/', function(req, res){
  res.sendFile(__dirname + '/index.html');
});

io.on('connection', function(socket){
  console.log('a user connected');
});

http.listen(3000, function(){
  console.log('listening on *:3000');
});

但是你现在应该能够用Adonis做到这一点，根据：https://github.com/adonisjs/adonis-websocket-protocol

示例：

const filereader = require('simple-filereader')
const msgpack = require('msgpack-lite')
const packets = require('@adonisjs/websocket-packets')

const client = new WebSocket('ws://localhost:3000/adonis-ws')

client.onopen = function () {
  // TCP connection created
}

client.onerror = function () {
  // TCP connection error
}

client.onmessage = function (message) {
  filereader(message, function (error, payload) {
    const packet = msgpack.decode(payload)
    handlePacket(packet)
  })
}

function handlePacket (packet) {
  if (packets.isOpenPacket(packet)) {
    console.log('Server ack connection. Make channel subscriptions now')
  }

  if (packets.isJoinAck(packet)) {
    console.log('subscription created for %s', packet.d.topic)
  }
}

使用WS：https://github.com/websockets/ws#broadcast-example查看广播示例

Answer 2

创建start/socket.js文件，并在其中粘贴以下代码。

const Server = use('Server')
const io = use('socket.io')(Server.getInstance())

io.on('connection', function (socket) {
console.log(socket.id)
})

来自维克本人在这个论坛上：https://forum.adonisjs.com/t/integrating-socket-io-with-adonis-4/519

Answer 3

在start/socket.js中创建独立的socket io配置文件

const io = require('socket.io')();
io.listen(3000);
io.on('connection', function (socket) {
  console.log(socket.id)
})

要启动socket io服务器，可以按如下方式配置server.js

new Ignitor(require('@adonisjs/fold'))
  .appRoot(__dirname)
  .preLoad('start/socket') //path of socket.js
  .fireHttpServer()
  .catch(console.error)

现在，当您启动服务器时，它将与socket io一起启动。