node.js Google PubSub订阅者没有收到一些消息

Question

对调试的任何帮助都将非常感谢。

这是我的堆栈：

• node.js
• socket.io
• express.js
• passport.js
• MongoDb
• react.js

流程：

• Anna在聊天中发送一条消息（这条消息写入数据库并发布到PubSubtopic“messages”）
• Node.js express应用程序运行订阅，然后根据消息内容发送给其他应该接收消息的人。
• 在本例中，与安娜在同一频道的鲍勃将接收消息。

const pubSubClient = require('./client');

const errorHandler = function(error) {
    console.error(`ERROR: ${error}`);
    throw error;
};

module.exports = listenForMessages =(subscriptionName="messageReceiver",io) => {
    const subscription = pubSubClient.subscription(subscriptionName);

    // Listen for new messages until timeout is hit
    subscription.on("message", (message) => {
        console.log(`Received message ${message.id}:`);
        const parsedMessage = JSON.parse(message.data)
        parsedMessage._id = message.id
        console.log(parsedMessage)

        if (parsedMessage.to === "admin") {
            io.to(`admin:${parsedMessage.from}`).emit("NewMessage", parsedMessage);
        } else {
            io.to(`${parsedMessage.to}`).emit("NewMessage", parsedMessage);
        }
        message.ack();
    });

    subscription.on('error', errorHandler);
}

...
const listenForMessages = require("./message_processing/listen");
listenForMessages("messageReceiver", io);

下面的控制台输出是通过在本地运行应用程序生成的，使用两个浏览器（其中一个匿名）互相聊天。可以看到，监听器实际上只接收到最后一条消息（并打印出来）。有趣的是，由于调用的异步性质，接收到的消息的打印输出是在消息发送的日志之前完成的（也就是说，延迟在这里肯定不是一个问题）。

[0] went into deserialize user
[0] Message 875007020424601 published.
[0] went into deserialize user
[0] Message 875006704834317 published.
[0] went into deserialize user
[0] Message 875006583857400 published.
[0] went into deserialize user
[0] Message 875006520104287 published.
[0] went into deserialize user
[0] Message 875006699141463 published.
[0] went into deserialize user
[0] Received message 875006881073134:
[0] {
[0]   from: '5e949f73aeed81beefaf6daa',
[0]   to: 'admin',
[0]   content: 'i6',
[0]   seenByUser: true,
[0]   type: 'message',
[0]   createdByUser: true,
[0]   createdAt: '2020-04-20T07:44:54.280Z',
[0]   _id: '875006881073134'
[0] }
[0] Message 875006881073134 published.

在其他一些情况下，以前的消息工作，然后监听器似乎停止。

Answer 1

null