MySQL和Redis是很多應用程序都要使用到的數據庫，而實時同步數據對于很多應用來說是非常重要的。MySQL是一個關系型數據庫，而Redis則是一個非關系型數據庫，兩者的使用場景有所不同。在某些情況下，我們需要在兩個數據庫之間實時同步數據。這時候，如何實現MySQL和Redis之間的實時同步數據呢？

首先，我們需要使用一個工具來實現MySQL和Redis之間的同步，這個工具就是Canal。Canal是阿里巴巴開源的基于 MySQL 數據庫增量日志解析和同步的組件，可以將增量數據解析成邏輯事件，邏輯事件包括插入(insert)、更新(update)、刪除(delete)等操作，同時提供了類似于 trigger 的 after 消費機制，讓使用者可以將事件消費到自己的應用中。

// Canal的簡單配置
canal.instance.master.address=mysql地址:3306
canal.instance.dbUsername=username
canal.instance.dbPassword=password
canal.instance.connectionCharset=UTF-8
canal.instance.filter.regex=.*\\..*
canal.instance.tsdb.enable=false

接下來，我們需要將數據從Canal中同步到Redis。這個時候，我們可以利用Redis的發布訂閱功能來實現數據的實時同步。具體來說，我們可以在Canal中設置一個after消費機制，在這里面可以通過Redis的發布訂閱功能將數據實時同步到Redis。代碼如下：

// 訂閱MySQL事件
canalConnector.subscribe();
while (true) {
Message message = canalConnector.getWithoutAck(batchSize); // 獲取指定數量的數據
long batchId = message.getId();
int size = message.getEntries().size();
if (batchId == -1 || size == 0) {
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
} else {
//將數據實時同步到Redis
for (CanalEntry.Entry entry : message.getEntries()) {
if (entry.getEntryType() == CanalEntry.EntryType.ROWDATA) {
CanalEntry.RowChange rowChange = null;
try {
rowChange = CanalEntry.RowChange.parseFrom(entry.getStoreValue());
} catch (Exception e) {
throw new RuntimeException("ERROR ## parser of eromanga-event has an error , data:" + entry.toString(), e);
}
CanalEntry.EventType eventType = rowChange.getEventType();
if (eventType == CanalEntry.EventType.DELETE) {
// 刪除操作
//實時同步到Redis
redisTemplate.delete(key);
} else if (eventType == CanalEntry.EventType.INSERT) {
// 插入操作
//實時同步到Redis
redisTemplate.opsForValue().set(key, value);
} else {
// 更新操作
//實時同步到Redis
redisTemplate.opsForValue().set(key, value);
}
}
}
}
canalConnector.ack(batchId); // 提交確認
}

通過上面的代碼，我們可以實現MySQL和Redis之間的實時數據同步，這對于需要保證數據一致性的應用來說非常有用。