分布式系统如何保证数据一致性

场景：系统被分为两大服务，用户服务模块（A）、订单系统服务（B）。下单后给用户返积分。两个系统分管各自的数据库。

方案一：该方案属于最终一致性类型。主要分两个点——消息发送端保证消息能够成功的发出去、消息接受端保证接受到消息后能顺利的处理消息。操作思路：1、消息发送端：在本地服务建立一个记录发送消息的表。在用户下单的同时在表中插入一条记录标识为待发送的消息。将消息发送到消息队列，并将表中的状态修改为已经发送。2：消息接收端：在本地服务中建立一张消息处理日志表。接收到消息后，判断是否已经在消息处理日志表中存在，如果不存在处理消息。给用户添加积分同时在消息处理日志表中插入一条记录，删除消息队列中的此条消息。

伪代码：

<?php
//消息发送者
begin transaction:$res1 =  insert into order set order_id='1',user_id=2,status = '0';$res2 = insert into message set message_id=order_id,message_content=order;
if($res1 && $res2){commit;$res = $sendMessage($order);if($res == true){update message set status = 1;}
}else roll back;

<?php
//消息接收者
$message = getMessage();
begin transaction:$res = update user set jifen=jifen + 100 where id=user_id;$res2 = insert into message_log set message=message,id=message_id;
if($res && $res2){commit;deleteMessage($message_id);
}else{roll back;
}

同时分别开两个后台脚本去定时扫描消息记录表，如果有待发送的消息立即处理！

http://www.cnblogs.com/soundcode/p/5590710.html

分布式系统如何保证数据一致性相关推荐

mysql数据迁移数据一致性检教6_如何在数据库迁移中保证数据一致性？
原标题:如何在数据库迁移中保证数据一致性? 作者 | 王斌译者 | 平川策划 | 万佳在分布式系统中,保持数据一致非常困难,而且很容易出错.在本文中,我们将探索一种在迁移期间保持数据一致性的方法 ...
php并发扣款,PHP 并发扣款，保证数据一致性（悲观锁）
业务场景分析用户购买商品的逻辑中,需要对用户钱包的余额进行查询和扣款异常:如果同一用户并发执行多个业务进行"查询+扣款"的业务中有一定概率出现数据不一致 Tips:如果没有做限 ...
redis主从复制如何保证数据一致性_面试官：Redis 主从复制时网络开小差了怎么整？...
上周因为实在太忙就认认真真写了一篇水文,吹了一下自己过去的经历,反响竟然超出了我的预期,并且后台还有读者留言表示想看续集的.哈哈,果然大家还是对水文更有热情. 这期我们继续回到之前的 Redis 话题 ...
MySQL 在高并发下的订单撮合系统使用共享锁与排他锁保证数据一致性
原文:MySQL 在高并发下的订单撮合系统使用共享锁与排他锁保证数据一致性作者:林冠宏 / 指尖下的幽灵掘金:https://juejin.im/user/587f0dfe128fe1 ...
RabbitMQ实现多系统间的分布式事务，保证数据一致性
点击关注公众号,实用技术文章及时了解一.实验环境 Lunix系统:Centos7.5 安装软件:rabbitmq 开发工具:IDEA 二.实验目的 Rabbitmq实现多系统间的分布式事务,保证数据 ...
mha数据备份_MySQL备份与恢复之保证数据一致性(5)
在上一篇文章中我们提到热拷贝(MySQL备份与恢复之热拷贝),热拷贝也就是在MySQL或者其他数据库服务在运行的情况下使用mysqlhotcopy命令进行备份.这篇文章我们讲解怎样保证数据一致性.现在 ...
redis主从保证数据一致性
redis主从保证数据一致性前言在redis中为了保证redis的高可用,一般会搭建一种集群模式就是主从模式. 主从模式可以保证redis的高可用,那么redis是怎么保证主从服务器的数据一致性的 ...
elasticsearch 如何保证数据一致性？
<<ElasticSearch 集群是如何保证数据的一致性和实时性?>> <<Elasticsearch 如何保证数据不丢失?>> <<el ...
Java怎么保证数据一致性_连续调用多个外部系统写接口保证数据一致性的思路...
概述某些场景下,我们将业务数据落地之前,是需要先调用外部系统的多个写接口,当这些写接口都操作成功了,我们才将业务数据落地到自己本地的数据库里面.比如说: public void updateProd ...
RabbitMQ实现分布式事务，保证数据一致性
一.实验环境 Lunix系统:Centos7.5 安装软件:rabbitmq 开发工具:IDEA 二.实验目的 Rabbitmq实现多系统间的分布式事务,保证数据一致性三.实验方案 rabbitmq ...

分布式系统如何保证数据一致性

分布式系统如何保证数据一致性相关推荐

最新文章

热门文章