当前位置：首页 > news >正文

网站建设商业计划书范文抖音seo优化排名

news 2025/9/12 19:07:54

网站建设商业计划书范文,抖音seo优化排名,北京物流网站建设,app 软件开发目录双写一致性Redis与Mysql双写一致性canal配置流程代码案例双写一致性理解缓存操作细分缓存一致性多种更新策略挂牌报错,凌晨升级先更新数据库,在更新缓存先删除缓存,在更新数据库先更新数据库,在删除缓存延迟双删策略总结双写一致性 Redis与Mysql双写一致性 canal 主要是…

- 双写一致性
- - Redis与Mysql双写一致性
  - - canal
    - - 配置流程
      - 代码案例
    - 双写一致性理解
    - - 缓存操作细分
    - 缓存一致性多种更新策略
    - - 挂牌报错,凌晨升级
      - 先更新数据库,在更新缓存
      - 先删除缓存,在更新数据库
      - 先更新数据库,在删除缓存
      - 延迟双删策略
  - 总结

双写一致性

Redis与Mysql双写一致性

canal

主要是用于MySQL数据库增量日志数据的订阅,消费和解析(由阿里开源的Java项目),canal是通过伪装成MySQL的slave节点来转储master节点的binlog日志的一个中间件,他拿到日志内容以后,就可以把日志的相关数据变更重放到任何地方,可以是其他的MySQL,也可以是消息队列,redis甚至是文件中.

配置流程

开启MySQL的binlog写入功能(需要重启MySQL,阿里云的好像默认就开启了)
授权canal连接MySQL的账号,其实就是新建一个canal专用的账号便于区分(权限可以稍微高一些)
去官网下载并解压canal到自己的目录下,修改instance.properties配置文件
换成自己mysql主机所在的ip地址
换成自己刚才给MySQL新建的用户及其密码
启动canel并查看server和instance实例的日志来确保启动运行成功

代码案例

import com.alibaba.otter.canal.client.CanalConnector;
import com.alibaba.otter.canal.client.CanalConnectors;
import com.alibaba.otter.canal.protocol.CanalEntry;
import com.alibaba.otter.canal.protocol.Message;
import com.google.protobuf.InvalidProtocolBufferException;import java.net.InetSocketAddress;
import java.util.List;
import java.util.concurrent.TimeUnit;public class RedisCanalClientExample {public static final int _60SECONDS = 60;public static void main(String[] args) {CanalConnector connector = CanalConnectors.newSingleConnector(new InetSocketAddress("127.0.0.1", 1111), "example", "", "");int batchSize = 1000;int emptyCount = 0;System.out.println("---------程序启动,开始监听MySQL的变化: ");try {connector.connect();//这个就是你要订阅的变化的那个库表connector.subscribe("db_test.t_user");connector.rollback();int totalEmptyCount = 10 * _60SECONDS;while (emptyCount < totalEmptyCount) {//获取指定数量的数据Message message = connector.getWithoutAck(batchSize);long batchId = message.getId();int size = message.getEntries().size();if (batchId == -1 || size == 0) {emptyCount++;try {TimeUnit.SECONDS.sleep(1);} catch (InterruptedException e) {e.printStackTrace();}} else {emptyCount = 0;printEntry(message.getEntries());System.out.println();}//提交确认connector.ack(batchId);//处理失败,回滚数据//connector.rollback(batchId);}System.out.println("empty too many times,exit");} finally {connector.disconnect();}}private static void printEntry(List<CanalEntry.Entry> entries) {for (CanalEntry.Entry entry : entries) {if (entry.getEntryType() == CanalEntry.EntryType.TRANSACTIONBEGIN || entry.getEntryType() == CanalEntry.EntryType.TRANSACTIONEND) {continue;}CanalEntry.RowChange rowChange = null;try {rowChange = CanalEntry.RowChange.parseFrom(entry.getStoreValue());} catch (InvalidProtocolBufferException e) {throw new RuntimeException(e);}CanalEntry.EventType eventType = rowChange.getEventType();System.out.printf("==========binlog[%s:%s],name[%s,%s],eventType : %s%n",entry.getHeader().getLogfileName(), entry.getHeader().getLogfileOffset(),entry.getHeader().getSchemaName(), entry.getHeader().getTableName(), eventType);for (CanalEntry.RowData rowData : rowChange.getRowDatasList()) {if (eventType == CanalEntry.EventType.INSERT) {redisInsert(rowData.getAfterColumnsList());} else if (eventType == CanalEntry.EventType.UPDATE) {redisUpdate(rowData.getAfterColumnsList());} else {redisDelete(rowData.getAfterColumnsList());}}}}private static void redisInsert(List<CanalEntry.Column> columns) {//实现省略,往redis插入数据}private static void redisUpdate(List<CanalEntry.Column> columns) {//实现省略,往redis修改数据}private static void redisDelete(List<CanalEntry.Column> columns) {//实现省略,往redis删除数据}
}