当前位置: 首页 > 后端技术 > Java

使用rabbitmq时,如何保证消息的可靠传递[1]

时间:2023-04-01 23:29:57 Java

使用rabbitmq发送消息时。如何保证生产端的消息投递到rabbitmq是一个需要解决的问题,即可靠的消息投递问题。rabbitmq的一种使用方式是直接给它投递消息,但它并不关心消息是否真的投递成功;另一种传递消息的方法是在传递成功或失败时触发回调函数。回调函数中的参数包括发送的消息和是否发送成功的标志。可靠投递的方式是指在一定程度上保证消息能够投递到rabbitmq。为了实现可靠的传递,我们每次都传递消息。消息体会存储在数据库中,消息当然会被传递。当投递消息的回调函数显示为成功时,说明消息确实投递成功,无需关注该消息;当消息没有投递成功时,在回调参数中得知投递失败。然后我们需要再次从数据库中取出消息并尝试再次传递。如果仍然发送失败,则重复此操作,直到发送成功。