如何降低节点的速度/rabbitmq-message/request



我有一个模拟的实时应用程序。我向rabbitmq.发送了一个csv文件。rabbitmq会发回队列。在我的客户端应用程序中,ag grid无法跟上收到消息的速度。我正在使用websocket。我想知道如何控制这些消息的速度,无论是在rabbitmq、node-js、服务器还是客户端的websocket中?我想控制每个响应的速度,例如每秒钟、每分钟发送/接收每个响应。提前感谢

解决方案是控制队列的流量。使用预取来指示每次要使用多少队列,并添加一个设置的时间来指示的频率

通道预取(1(;channel.cosume(队列消息=>{if(msg!==null({if(msg({setTimeout(((=>{console.log(msg.content.toString(((;sendQueuesToWebSocket(msg.content.toString(((;channel.ack(消息(;},50(}}其他{console.log("Consumer cancelled by server"(;}},{noAck:false,})

最新更新