Socket.io与Adonis.js的结合

Question

我正在使用Adonis 4.1.0，但是Adonis-websocket只适用于v3。有人能告诉我如何在Adonis 4.1.0中使用socket.io吗？

- Tijan Manandhar

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');
});

根据https://github.com/adonisjs/adonis-websocket-protocol的说明，您现在应该能够使用Adonis实现此操作。

例如：

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

- Taki

---

是的，我尝试按照Socket.io框架进行操作。但我遇到的问题是，当数据库中插入记录时，我无法发出消息，我认为这在Sails.js或Adonis 3.2版本中是默认设置的。 - Tijan Manandhar

非常感谢您的回复。虽然Adonis JS框架非常流畅，但社区规模很小。 - Tijan Manandhar

不客气 :)，我不知道你是怎么尝试做的，但你应该在插入数据库函数的回调中执行 Broadcast，就像我之前提到的一样，你可以使用 ws 和 adonis 进行广播，以下是如何发送广播消息的示例链接：https://github.com/websockets/ws#broadcast-example ，希望这会有所帮助。 - Taki

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)
})

在这个论坛上，来自 Virk 自己的话：https://forum.adonisjs.com/t/integrating-socket-io-with-adonis-4/519

- Tiago Mendes

---

你真是个救星，因为论坛已经不再可用，这个信息也无处可寻了。 - Owehbeh

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。

- Vishnu Bhadoriya