带有 Adonis.js 的 Socket.io答案

【问题标题】：Socket.io with Adonis.js带有 Adonis.js 的 Socket.io
【发布时间】：2018-08-27 15:35:54
【问题描述】：

我使用的是 Adonis 4.1.0，而 Adonis-websocket 仅适用于 v3。谁能告诉我在 Adonis 4.1.0 中使用 socket.io 的解决方法？

【问题讨论】：

【解决方案1】：

显然他们不久前一直在研究这个，它基于socket.io，但由于一些问题，如内存泄漏等，他们决定直接使用websockets，查看这些讨论：
@ 987654321@
https://forum.adonisjs.com/t/integrating-socket-io-with-adonis-4/519

您是否尝试过使用 socket.io 而不依赖 Adonis ？ , 类似的东西：

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

【讨论】：

是的，我尝试按照 Socket.io 框架进行操作。但是我遇到的问题是，当我认为在 Sails.js 或 Adonis 3.2 版本中默认设置的数据库中插入记录时，我无法发出消息
非常感谢您的回复。 adonis js 的社区很小，虽然框架很流畅。
不客气:)，我不知道你是怎么做的，但你应该在插入数据库的函数的回调中做一个Broadcast，因为我上面提到，您可以使用ws 和adonis，这些是有关如何broadcast 发送消息的示例：github.com/websockets/ws#broadcast-example，希望对您有所帮助。

【解决方案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

【讨论】：

你是一个救命稻草，因为论坛不再可用，而且再也找不到了。

【解决方案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)

现在，当您启动服务器时，它将与套接字 io 一起启动

【讨论】：