我打算使用 AMQP 来允许分布式机器集合异步向中心位置报告。这个想法是将消息放入队列并允许中央日志记录实体以解耦的方式处理队列;“过程”只是在数据库表中创建或更新一行。
我预料到的一个问题是网络抖动在消息排队过程中的影响——如果由于两条消息发出的时间小于网络抖动而update
意外到达 an 前面会发生什么?insert
阅读 AMQP 规范,似乎我可以对insert
s 应用更高的优先级,以便它们跳过队列并首先得到处理。但大概这仅适用于要跳过的代理处实际存在队列的情况。有没有办法在代理处施加缓冲或延迟以吸收这种抖动并允许在消息传递给消费者之前制定优先级?
或者我是否必须按照 ActiveMQ 的建议走重新排序器的路线?