nestJS "socket.io-redis"："6.0.1“

Question

根据文档 TypeScript // npm i -D @type/redis

import { Server } from 'socket.io';
import { createAdapter } from 'socket.io-redis';
import { RedisClient } from 'redis';

const io = new Server(8080);
const pubClient = new RedisClient({ host: 'localhost', port: 6379 });
const subClient = pubClient.duplicate();

io.adapter(createAdapter({ pubClient, subClient }));

我创建了redis适配器

import { IoAdapter } from '@nestjs/platform-socket.io';
import { createAdapter } from 'socket.io-redis';
import { RedisClient } from 'redis';

export class RedisIoAdapter extends IoAdapter {
  createIOServer(port: number, options?: any): any {
    const server = super.createIOServer(port, options);
    const pubClient = new RedisClient({ host: 'localhost', port: 6379 });
    const subClient = pubClient.duplicate();
    server.adapter(createAdapter({ pubClient, subClient }));
    return server;
  }
}

在我使用分派this.appGateway.server.emit('test'，‘hello’)之后；

TypeError: callback is not a function
    at Encoder.encode (/home/test/node_modules/socket.io-parser/index.js:135:5)
    at RedisAdapter.broadcast (/home/test/node_modules/socket.io-redis/node_modules/socket.io-adapter/dist/index.js:102:45)
    at RedisAdapter.broadcast (/home/test/node_modules/socket.io-redis/dist/index.js:267:15)
    at Namespace.emit (/home/test/node_modules/socket.io/lib/namespace.js:234:16)
    at Server.<computed> [as emit] (/home/test/node_modules/socket.io/lib/index.js:505:29)

my gateWay

import { OnGatewayConnection,  WebSocketGateway, WebSocketServer } from '@nestjs/websockets';
import { Logger } from '@nestjs/common';

@WebSocketGateway()
export class AppGateway implements OnGatewayConnection {
  private readonly logger = new Logger(AppGateway.name);

  @WebSocketServer()
  server;
  
  handleConnection(client): any {
    this.logger.log('new user connected...');
    client.emit('connection', 'Succesfuly connected');
  }

}

帮助--请解决问题

Answer 1

socket.io-redis ^6使用Nest尚未支持的socket.io版本3。关于它有一个悬而未决的问题，这里，它已经为Nest v8做好了准备