有没有办法用 RabbitMQ 提供 "N messages before yours" 计数器来确定特定消息之前的消息数?
Is there a way to determine the number of messages before a specific message with RabbitMQ to provide "N messages before yours" counter?
我想向用户(消息发布者)反馈他们的消息何时会被处理(而不是在它们完成时)。
理论上我可以收到所有消息,统计并重新安排它们。这将是愚蠢的,因为在新消息将在新消息(最初的最后一条)消息之后重新安排之前,由于所有消息,新到达的消息将被立即处理。
有没有办法用 RabbitMQ 确定特定消息之前的消息数?
虽然 rabbitmq 提供了一个HTTP API,returns 当前在队列。
您必须在客户端(如计数器或其他东西)最好在发布者端维护此统计信息。但是请确保只发布一次消息以避免重复计数或以这种方式实现您的计数器(为每条消息保留一个唯一标识符)以避免多次计算同一消息(如果允许重新发布)。
之前有人问过类似的问题:
RabbitMQ - Get total count of messages enqueued
我想向用户(消息发布者)反馈他们的消息何时会被处理(而不是在它们完成时)。
理论上我可以收到所有消息,统计并重新安排它们。这将是愚蠢的,因为在新消息将在新消息(最初的最后一条)消息之后重新安排之前,由于所有消息,新到达的消息将被立即处理。
有没有办法用 RabbitMQ 确定特定消息之前的消息数?
虽然 rabbitmq 提供了一个HTTP API,returns 当前在队列。
您必须在客户端(如计数器或其他东西)最好在发布者端维护此统计信息。但是请确保只发布一次消息以避免重复计数或以这种方式实现您的计数器(为每条消息保留一个唯一标识符)以避免多次计算同一消息(如果允许重新发布)。
之前有人问过类似的问题:
RabbitMQ - Get total count of messages enqueued