我有一个服务来消耗来自RabbitMQ队列的消息(通过主题交换发送到队列).假设该服务理论上可以失败并失去其状态,那么备份所有消息以进行灾难恢复的可能性就会派上用场.
想到的第一个想法是为主题交换添加另一个绑定,以便消息也被发布到另一个队列,并创建一个自定义服务来备份将侦听该队列的消息.但这听起来很像车轮的潜在改造.使用RabbitMQ(插件/现有服务/等)有更简单的方法吗?
最佳答案 发现可以使用
firehose和
tracing plugin的组合.
我有一个服务来消耗来自RabbitMQ队列的消息(通过主题交换发送到队列).假设该服务理论上可以失败并失去其状态,那么备份所有消息以进行灾难恢复的可能性就会派上用场.
想到的第一个想法是为主题交换添加另一个绑定,以便消息也被发布到另一个队列,并创建一个自定义服务来备份将侦听该队列的消息.但这听起来很像车轮的潜在改造.使用RabbitMQ(插件/现有服务/等)有更简单的方法吗?
最佳答案 发现可以使用
firehose和
tracing plugin的组合.