博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
java分布式事务处理--最终事务一致性
阅读量:6008 次
发布时间:2019-06-20

本文共 2646 字,大约阅读时间需要 8 分钟。

hot3.png

在大型系统架构时我们会进行分库设计,比如用户库、订单库。如果采用了dubbo会产生服务,如果目前有两个服务,用户服务和订单服务。

实际业务中,用户下单支付成功后,并改变用户的状态或增加用户的积分。这样过程中就会产生事务问题。这里我们采用最终事务一致性。

    大致实现思路,把分布式事务切割成小事务,用消息队列消除分布式事务。实现方式如下:

订单功能的小事务如下:

首先:订单服务。

jmsTemplate.setSessionTransacted(true);		transactionTemplate.execute(new TransactionCallback
() { @Override public String doInTransaction(TransactionStatus status) { // TODO Auto-generated method stub Connection connection = null; Session session = null; try { String orderId = System.currentTimeMillis() + ""; String sql = "insert into order (order_id,user_id) values (?,?)"; jdbcTemplate.update(sql, new Object[] { orderId, userId }); connection = jmsTemplate.getConnectionFactory().createConnection(); session = connection.createSession(true, Session.CLIENT_ACKNOWLEDGE); Destination destination = session.createQueue("transactionQueue"); MessageProducer producer = session.createProducer(destination); producer.setDeliveryMode(DeliveryMode.PERSISTENT); String text = "orderid"; MapMessage message = session.createMapMessage();//Message(text); message.setString("order_id", orderId); message.setString("user_id", userId); message.setString("status", "1"); producer.send(message); session.commit(); } catch (Exception ex) { // TODO: handle exception status.setRollbackOnly(); try { session.rollback(); } catch (JMSException e) { // TODO Auto-generated catch block e.printStackTrace(); } ex.printStackTrace(); } finally { try { session.close(); } catch (JMSException e) { // TODO Auto-generated catch block e.printStackTrace(); } } return null; } });

 

用户服务监听消息队列

public void handlerMessage(final MapMessage mapMessage, final Session session) throws JMSException	{		getTransactionTemplate().execute(new TransactionCallback
() { @Override public String doInTransaction(TransactionStatus status) { int result = 0; try { //String status, String user_id, String order_id updateUserLevel(mapMessage.getString("status"), mapMessage.getString("user_id"), mapMessage.getString("order_id")); } catch (Exception e) { try { session.rollback(); } catch (JMSException ex) { logger.error("JMS事务回滚异常", ex); ex.printStackTrace(); } status.setRollbackOnly(); } return String.valueOf(result); } }); }

消息队列配置

 

消息队列重试次数10次,如果一次失败,可以多试几次。

如果消息队列最终失败,则监听失败信息,采用事务补偿机制,删除之前增加的订单或其他处理。

转载于:https://my.oschina.net/rock912/blog/717826

你可能感兴趣的文章
从设计者的角度看 React
查看>>
CSS居中总结大全
查看>>
Elasticsearch 参考指南(安装X-Pack)
查看>>
[LintCode] 604. Design Compressed String Iterator
查看>>
微信小程序黑客马拉松即将开始,来做最酷的 Mini Program Creators!
查看>>
JavaScript基础---函数
查看>>
前端每日实战:120# 视频演示如何用纯 CSS 创作锡纸撕开的文字效果
查看>>
Laravel实用小功能
查看>>
matplotlib绑定到PyQt5(有菜单)
查看>>
利用Powershell和ceye.io实现Windows账户密码回传
查看>>
Windows 8.1 今年 1 月市场份额超 Vista
查看>>
《设计团队协作权威指南》—第1章1.5节总结
查看>>
Chair:支付宝前端团队推出的Node.js Web框架
查看>>
《Total Commander:万能文件管理器》——第3.8节.后续更新
查看>>
BSD vi/vim 命令大全(下)[转]
查看>>
css3中变形与动画(一)
查看>>
[XMove-自主设计的体感解决方案] 系统综述
查看>>
【LINUX学习】磁盘分割之建立primary和logical 分区
查看>>
【YUM】第三方yum源rpmforge
查看>>
IOS(CGGeometry)几何类方法总结
查看>>