RXJS Websockets发送＆＃x27; undefined＆＃x27;消息

Question

我使用RXJS Websockets和node.js后端使用“ WS”软件包具有Angular前端。

我遇到的问题是，没有消息从后端传输到前端 - 有一个连接，因为我可以强迫它们进行互动，并且我的角前端消息始终由后端正确接收。

问题是前端没有接收到后端消息，因此 - 这是我的后端代码...

clients = [];
wss;

webSocketServer() {
    this.wss = new WebSocket.Server({ port: 7072 });

    this.wss.on('connection', (ws) => {
        const id = methods.generateRandomId(5);
        this.clients.push({socket: ws, data: { id }});
        
        ws.on('open', () => {
            console.log(`Client ${id} has connected.`)
            this.sendWebsockMessage(`User ${id} connected...`);
        });

        ws.on('message', (msg) => {
            const message = JSON.parse(msg);         
            console.log(message);
        });
        
        ws.on('close', () => {
            console.log(`Client ${id} has disconnected.`)
        })

    })
}

sendWebsockMessage(msg) {
    this.clients.forEach(client =>{
        client.socket.send(`[{hello: hi}]`);
    });
}

问题是：

• 客户端$ {id}已连接不显示，这似乎暗示着“ open oble'例程不运行。
• 在前端，输出总是不确定的。我在该sendwebsockmessage函数中放置的内容似乎无关紧要 - 输出总是不确定的。

这是我的前端，角度代码：

ws: WebSocketSubject<any>;

webSockets(): void {
// deserializer is from this: https://github.com/ReactiveX/rxjs/issues/4166
// this solves a connection issue
this.ws = webSocket({url: `${environment.websocketUrl}`, deserializer: () => {}});

// this.sendMessage(ws, 'loginNotification', 'hello');

this.ws.subscribe(
  {
    next: (message: string) => {
      console.log(`msg: ${message}`);
  },
    error: (error) => {
      console.log(`Error in socket: ${error}`);
  },
    complete: () => {
      console.log("connection to server closed");
    }
 });
}

sendTestMessage(): void {
  this.ws.next({ msg: 'hello' });
}

所有这些代码都为我提供了msg：未定义的从下一个：订阅的部分。如果我点击“ sendTestMessage”函数，则在node.js服务器上以字符串形式收到该对象。