用户每次抢完红包，要查看自己抢红包记录，此时需要查询数据库表 money_log ,如果每次都查询 money_log 就会占用大量数据库资源。此时我们应该将数据存储到缓存中，每次查询直接从缓存获取即可。 但现在面临的问题是如果用户抢到了不同的红包，缓存没法及时更新，因此我们需要实现抢红包数据库数据和Redis缓存中的数据同步。

 缓存一致性解决方案

用户每次操作数据库的时候，使用Canal监听数据库指定表的增量变化，在Java程序中消费Canal监听到的增量变化，并在Java程序中实现对Redis缓存或者Nginx缓存的更新。

用户查询的时候，先通过Lua查询Nginx的缓存，如果Nginx缓存没有数据，则查询Redis缓存，Redis缓存如果也没有数据，可以去数据库查询。

Canal介绍

基础知识：

java利用canal监听数据库 https://blog.csdn.net/ZGL_cyy/article/details/116563680

大数据同步工具Canal https://blog.csdn.net/ZGL_cyy/article/details/114799026

Canal主要用途是基于 MySQL 数据库增量日志解析，并能提供增量数据订阅和消费，应用场景十分丰富。

github地址：https://github.com/alibaba/canal

版本下载地址：https://github.com/alibaba/canal/releases

文档地址：https://github.com/alibaba/canal/wiki/Docker-QuickStart

.1 Canal应用场景

1.电商场景下商品实时更新同步到至Elasticsearch、solr等搜索引擎； 2.价格、库存发生变更实时同步到redis； 3.数据库异地备份、数据同步； 4.代替使用轮询数据库方式来监控数据库变更，有效改善轮询耗费数据库资源。

.2 MySQL主从复制原理

MySQL master 将数据变更写入二进制日志( binary log , 其中记录叫做二进制日志事件 binary log events ， 可以通过 show binlog events 进行查看) 2. MySQL slave 将 master 的 binary log events 拷贝到它的中继日 志( relay log ) 3. MySQL slave 重放 relay log 中事件，将数据变更反映它自己的数据

.3 Canal工作原理

1.canal 模拟 MySQL slave 的交互协议，伪装自己为 MySQL slave ，向 MySQL master 发送dump 协议 2. MySQL master 收到 dump 请求，开始推送 binary log 给 slave (即 canal ) 3.canal 解析 binary log 对象(原始为 byte 流)

.4 Canal配置

1)开启MySQL的bin-log 开启MySQL的binlog日志功能：

cd /etc/mysql/mysql.conf.d
在mysqld.cnf最下面添加如下配置
# 开启 binlog
log-bin=/var/lib/mysql/mysql-bin
# 选择 ROW 模式
binlog-format=ROW
# 配置 MySQL replaction 需要定义，不要和 canal 的 slaveId 重复
server-id=12345

2)Canal安装 这里采用容器安装 docker run -p 11111:11111 --name canal -d docker.io/canal/canal-server 配置CanalServer

修改 /home/admin/canal-server/conf/canal.properties ,将它的id属性修改成和mysql数据库中server-id不同的 值，如下图：

修改 /home/admin/canal-server/conf/example/instance.properties ,配置要监听的数据库服务地址和监听数 据变化的数据库以及表，修改如下：

指定监听数据库表的配置如下 canal.instance.filter.regex ：

mysql 数据解析关注的表，Perl正则表达式. 多个正则之间以逗号(,)分隔，转义符需要双斜杠(\) 常见例子：

• 所有表：.* or .\…
• canal schema下所有表： canal\…*
• canal下的以canal打头的表：canal\.canal.*
• canal schema下的一张表：canal.test1
• 多个规则组合使用：canal\…*,mysql.test1,mysql.test2 (逗号分隔)
• 注意：此过滤条件只针对row模式的数据有效(ps. mixed/statement因为不解析sql，所以无法准确提取tableName进行过滤)

重启canal: docker restart canal 不要忘了MySQL创建账号并授权：

create user canal@'%' IDENTIFIED by 'canal';
GRANT SELECT, REPLICATION SLAVE, REPLICATION CLIENT,SUPER ON *.* TO 'canal'@'%';
FLUSH PRIVILEGES;

同步更新Redis缓存

修改 com.oldlu.service.impl.MoneyLogServiceImpl ，添加方法 list(String username) ，代码如下：

创建类 com.oldlu.canal.MoneyLogSync ，实现消费Canal中监听到的增量数据，代码如下：

@CanalTable(value = "money_log")
@Component
public class MoneyLogSync implements EntryHandler<MoneyLog> {
@Autowired
private MoneyLogService moneyLogService;
@Autowired
private RedisTemplate redisTemplate;
/***
* 数据增加变更
* @param moneyLog
*/
@Override
public void insert(MoneyLog moneyLog) {
//查询用户的抢红包列表
List<MoneyLog> moneyLogs = moneyLogService.list(moneyLog.getUsername());
//将数据存入到Redis
redisTemplate.boundHashOps("UserMoneyLog").put(moneyLog.getUsername(),moneyLogs);
}
}

application.yml中配置Canal的地址：

#Canal配置
canal:
server: 192.168.211.141:11111
destination: example

关于微服务中如何消费Canal监听到的数据，参考参考地址： https://github.com/NormanGyllenhaal/canal-client 我们可以测试实现抢单，抢单后，数据会自动同步到Redis缓存中。