我正在使用网关来发出事件。
出于明确的原因,我创建了创建服务与此网关之间链接的文件。
例如,在网关中:
@SubscribeMessage('createRoom')
async createRoom(client: Socket, channel: newChannelDto) {
this.chatService.createRoom(client, channel)
}在聊天服务中:
async createRoom(client: Socket, channel: newChannelDto)
{
await this.channelService.createChannel(channel.chanName, client.data.user, channel.password, channel.private)
client.join(channel.chanName)
for (let [allUsers, socket] of this.gateway.activeUsers.entries())
this.gateway._server.to(socket.id).emit('rooms', " get rooms ", await this.channelService.getChannelsForUser(allUsers));
}其中:
。
@WebSocketServer()
public _server : Server网关中包含的服务器。
我通过@UseFilters(新的MyCustomExceptionsFilter())在网关的顶部创建了一个WS/HTTP/Query失败异常过滤器。
在我将函数移到“子”文件之前,我的过滤器能够捕获所有的东西,但是由于我将它们从网关移开,它不再工作;我仍然能够手动捕获它们,但它们不再被发送到前面。
在我的终端中输出的例子,我曾经能够捕获/发送作为用户友好的错误:
api | Error: this is still thrown if caught manually
api | at /api/src/websocket/chat.service.ts:67:28
api | at processTicksAndRejections (node:internal/process/task_queues:95:5)
api | at ChatService.createRoom (/api/src/websocket/chat.service.ts:66:3)发布于 2022-07-26 16:03:10
如果网关调用中没有await,承诺就不会像Nest所看到的那样,正确地处理请求的生命周期,因此,当错误发生时,Nest负责的异常区域之外。将await添加到this.chatService.createRoom(client, channel)中,从那以后一切都应该是好的。
https://stackoverflow.com/questions/73126394
复制相似问题