0
点赞
收藏
分享

微信扫一扫

RabbitMQ高级特性(二):RabbitMQ事务(概述)


RabbitMQ高级特性(二):RabbitMQ事务(概述)

RabbitMQ支持事务(transaction),RabbitMQ中与事务机制有关的方法有三个:txSelect(), txCommit()以及txRollback()。

(1)txSelect用于将当前channel设置成transaction模式,通过调用tx.select方法开启事务模式。

(2)txCommit用于提交事务。当开启了事务模式后,只有当一个消息被所有的镜像队列保存完毕后,RabbitMQ才会调用tx.commit-ok返回给客户端。

(3)txRollback用于回滚事务,在通过txSelect开启事务之后,我们便可以发布消息给broker代理服务器了,如果txCommit提交成功了,则消息一定到达了broker了,如果在txCommit执行之前broker异常崩溃或者由于其他原因抛出异常,这个时候我们便可以捕获异常通过txRollback回滚事务了。

关键代码:

channel.txSelect(); // 将当前channel设置成事务模式

/**
* ConfirmConfig.exchangeName(交换机名称)
* ConfirmConfig.routingKey(路由键)
* message (消息内容)
*/
channel.basicPublish(ConfirmConfig.exchangeName, ConfirmConfig.routingKey, MessageProperties.PERSISTENT_TEXT_PLAIN, message));
channel.txCommit(); // 提交事务
channel.txRollback(); // 回滚事务

注: 事务确实能够解决producer与broker之间消息确认的问题,只有消息成功被broker接受,事务提交才能成功,否则我们便可以在捕获异常进行事务回滚操作同时进行消息重发。

事务机制的缺点 :
使用事务机制的话会降低RabbitMQ的性能。
会导致生产者和RabbitMq之间产生同步(等待确认),这也违背了我们使用RabbitMq的初衷,所以一般很少采用


举报

相关推荐

0 条评论