RabbitMQ如何对消息做持久化?

RabbitMQ如何对消息做持久化?

请先 登录 后评论

1 个回答

李奡 | 奈学教育 - 奈学教育 | 讲师
擅长:大数据

1、创建队列和发送消息时将设置durable=Ture,如果在接收到消息还没有存储时,消息也有可能丢失,就必须配置publisher confirm channel.queue_declare(queue='task_queue', durable=True)

2、返回一个ack,进程收到消息并处理完任务后,发给rabbitmq一个ack表示任务已经完成,可以删除该任务

3、镜像队列:将queue镜像到cluster中其他的节点之上。 在该实现下,如果集群中的一个节点失效了,queue能自动地切换到镜像中的另一个节点以保证服务的可用性

请先 登录 后评论