时间戳

首页 > 解决方案 > 嵌套JS“socket.io-redis”：“6.0.1”

redis - 嵌套JS“socket.io-redis”：“6.0.1”

问题描述

根据文档 TypeScript // npm i -D @types/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;
  }
}

在我使用 dispatch 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)

我的网关

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

}

帮助请解决问题

标签： redisnestjs

解决方案

socket.io-redis^6 使用 Nest 尚不支持的 socket.io 版本 3。这里有一个未解决的问题，它已准备好用于 Nest v8

推荐阅读