首页 - 资讯 - 科技 - 教育 - 汽车 - 财经 - 健康 - 房产 - 文旅 - 娱乐 - 游戏
影视 |明星 |八卦 |攻略 |评测 |单机 |网游 |手游 |游戏 |艺术 |文化 |酒店 |旅游 |美景
当前位置： 首页> 娱乐> 影视 > 分销系统定制_中国跨境电商前三名_宣传推广的形式有哪些_在线制作网站免费

分销系统定制_中国跨境电商前三名_宣传推广的形式有哪些_在线制作网站免费

时间:2025/7/10 11:38:12来源：https://blog.csdn.net/weixin_74019079/article/details/145717498 浏览次数:0次
分销系统定制_中国跨境电商前三名_宣传推广的形式有哪些_在线制作网站免费

一、复习+面试题

二、canal

（1）是什么

2.1.1官网地址

Home · alibaba/canal Wiki · GitHub

2.1.2一句话

（2）能干嘛

  1. 数据库镜像
  2. 数据库实时备份
  3. 索引构建和实时维护（拆分异构索引、倒排索引等）
  4. 业务 cache 刷新
  5. 带业务逻辑的增量数据处理

（3）在哪下

下载地址：https://github.com/alibaba/canal/releases/tag/canal-1.1.6

三、工作原理，面试回答

（1）传统MySQL主从复制工作原理

（2）canal工作原理

四、mysql-canal-redis双写一致性Coding

（1）java案例，来源出处

https://github.com/alibaba/canal/wiki/ClientExample

（2）mysql

4.2.1查看MySQL版本

select version();

4.2.2当前的主机二进制日志

show master status;

4.2.3查看 show variables like 'log_bin';

4.2.4开启MySQL的binlog写入功能

最好提前备份

4.2.5重启MySQL

4.2.6再次查看 show variables like 'log_bin';

4.2.7授权canal链接MySQL账号

  1. MySQL默认的用户在MySQL库的user表里面
  2. 默认没有canal账户，此处新建+授权 
    
DROP USER IF EXISTS 'canal'@'%';
CREATE USER 'canal'@'%' IDENTIFIED BY 'canal';  
GRANT ALL PRIVILEGES ON *.* TO 'canal'@'%' IDENTIFIED BY 'canal';  
FLUSH PRIVILEGES;SELECT * FROM mysql.user;

（3）canal服务端

4.3.1下载

  1. 官网地址：https://github.com/alibaba/canal/releases/tag/canal-1.1.6
  2. 下载Linux版本：

4.3.2解压

解压后整体放入到/mycanal路径下

4.3.3配置

  1. 修改 /mycanal/conf/example路径下instance.properties文件
  2. instance.properties
    1. 换成自己的MySQL主机master的IP地址
    2. 换成自己的在MySQL新建的canal账户

4.3.4启动

在/mycanal/bin路径下执行 -> ./startup.sh

4.3.5查看

判断canal是否启动成功

  1. 查看server日志
  2. 查看样例 example的日志

（4）canal客户端（Java编写业务程序）

4.4.1SQL脚本

CREATE TABLE `t_user` (`id` bigint(20) NOT NULL AUTO_INCREMENT,`userName` varchar(100) NOT NULL,PRIMARY KEY (`id`)) ENGINE=InnoDB AUTO_INCREMENT=10 DEFAULT CHARSET=utf8mb4

4.4.2建module

canal_demo02

4.4.3改POM

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><groupId>com.atguigu.canal</groupId><artifactId>canal_demo02</artifactId><version>1.0-SNAPSHOT</version><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.5.14</version><relativePath/></parent><properties><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding><maven.compiler.source>1.8</maven.compiler.source><maven.compiler.target>1.8</maven.compiler.target><junit.version>4.12</junit.version><log4j.version>1.2.17</log4j.version><lombok.version>1.16.18</lombok.version><mysql.version>5.1.47</mysql.version><druid.version>1.1.16</druid.version><mapper.version>4.1.5</mapper.version><mybatis.spring.boot.version>1.3.0</mybatis.spring.boot.version></properties><dependencies><!--canal--><dependency><groupId>com.alibaba.otter</groupId><artifactId>canal.client</artifactId><version>1.1.0</version></dependency><!--SpringBoot通用依赖模块--><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-actuator</artifactId></dependency><!--swagger2--><dependency><groupId>io.springfox</groupId><artifactId>springfox-swagger2</artifactId><version>2.9.2</version></dependency><dependency><groupId>io.springfox</groupId><artifactId>springfox-swagger-ui</artifactId><version>2.9.2</version></dependency><!--SpringBoot与Redis整合依赖--><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-redis</artifactId></dependency><dependency><groupId>org.apache.commons</groupId><artifactId>commons-pool2</artifactId></dependency><!--SpringBoot与AOP--><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-aop</artifactId></dependency><dependency><groupId>org.aspectj</groupId><artifactId>aspectjweaver</artifactId></dependency><!--Mysql数据库驱动--><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><version>5.1.47</version></dependency><!--SpringBoot集成druid连接池--><dependency><groupId>com.alibaba</groupId><artifactId>druid-spring-boot-starter</artifactId><version>1.1.10</version></dependency><dependency><groupId>com.alibaba</groupId><artifactId>druid</artifactId><version>${druid.version}</version></dependency><!--mybatis和springboot整合--><dependency><groupId>org.mybatis.spring.boot</groupId><artifactId>mybatis-spring-boot-starter</artifactId><version>${mybatis.spring.boot.version}</version></dependency><!--通用基础配置junit/devtools/test/log4j/lombok/hutool--><!--hutool--><dependency><groupId>cn.hutool</groupId><artifactId>hutool-all</artifactId><version>5.2.3</version></dependency><dependency><groupId>junit</groupId><artifactId>junit</artifactId><version>${junit.version}</version></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency><dependency><groupId>log4j</groupId><artifactId>log4j</artifactId><version>${log4j.version}</version></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><version>${lombok.version}</version><optional>true</optional></dependency><!--persistence--><dependency><groupId>javax.persistence</groupId><artifactId>persistence-api</artifactId><version>1.0.2</version></dependency><!--通用Mapper--><dependency><groupId>tk.mybatis</groupId><artifactId>mapper</artifactId><version>${mapper.version}</version></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-autoconfigure</artifactId></dependency><dependency><groupId>redis.clients</groupId><artifactId>jedis</artifactId><version>3.8.0</version></dependency></dependencies><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId></plugin></plugins></build></project>

4.4.4写YML

server.port=5555# ========================alibaba.druid=====================
spring.datasource.type=com.alibaba.druid.pool.DruidDataSource
spring.datasource.driver-class-name=com.mysql.jdbc.Driver
spring.datasource.url=jdbc:mysql://localhost:3306/bigdata?useUnicode=true&characterEncoding=utf-8&useSSL=false
spring.datasource.username=root
spring.datasource.password=123456
spring.datasource.druid.test-while-idle=false

4.4.5主启动

package com.atguigu.canal;import com.alibaba.druid.spring.boot.autoconfigure.DruidDataSourceAutoConfigure;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;@SpringBootApplication
public class CanalDemo02App
{//本例不要启动CanalDemo02App实例
}

4.4.6业务类

（1）RedisUtils
package com.atguigu.canal.util;import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;public class RedisUtils
{public static final String  REDIS_IP_ADDR = "192.168.111.185";public static final String  REDIS_pwd = "111111";public static JedisPool jedisPool;static {JedisPoolConfig jedisPoolConfig=new JedisPoolConfig();jedisPoolConfig.setMaxTotal(20);jedisPoolConfig.setMaxIdle(10);jedisPool=new JedisPool(jedisPoolConfig,REDIS_IP_ADDR,6379,10000,REDIS_pwd);}public static Jedis getJedis() throws Exception {if(null!=jedisPool){return jedisPool.getResource();}throw new Exception("Jedispool is not ok");}}
（2）RedisCanalClientExample
package com.atguigu.canal.biz;import com.alibaba.fastjson.JSONObject;
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.atguigu.canal.util.RedisUtils;
import redis.clients.jedis.Jedis;
import java.net.InetSocketAddress;
import java.util.List;
import java.util.UUID;
import java.util.concurrent.TimeUnit;public class RedisCanalClientExample
{public static final Integer _60SECONDS = 60;public static final String  REDIS_IP_ADDR = "192.168.111.185";private static void redisInsert(List<Column> columns){JSONObject jsonObject = new JSONObject();for (Column column : columns){System.out.println(column.getName() + " : " + column.getValue() + "    update=" + column.getUpdated());jsonObject.put(column.getName(),column.getValue());}if(columns.size() > 0){try(Jedis jedis = RedisUtils.getJedis()){jedis.set(columns.get(0).getValue(),jsonObject.toJSONString());}catch (Exception e){e.printStackTrace();}}}private static void redisDelete(List<Column> columns){JSONObject jsonObject = new JSONObject();for (Column column : columns){jsonObject.put(column.getName(),column.getValue());}if(columns.size() > 0){try(Jedis jedis = RedisUtils.getJedis()){jedis.del(columns.get(0).getValue());}catch (Exception e){e.printStackTrace();}}}private static void redisUpdate(List<Column> columns){JSONObject jsonObject = new JSONObject();for (Column column : columns){System.out.println(column.getName() + " : " + column.getValue() + "    update=" + column.getUpdated());jsonObject.put(column.getName(),column.getValue());}if(columns.size() > 0){try(Jedis jedis = RedisUtils.getJedis()){jedis.set(columns.get(0).getValue(),jsonObject.toJSONString());System.out.println("---------update after: "+jedis.get(columns.get(0).getValue()));}catch (Exception e){e.printStackTrace();}}}public static void printEntry(List<Entry> entrys) {for (Entry entry : entrys) {if (entry.getEntryType() == EntryType.TRANSACTIONBEGIN || entry.getEntryType() == EntryType.TRANSACTIONEND) {continue;}RowChange rowChage = null;try {//获取变更的row数据rowChage = RowChange.parseFrom(entry.getStoreValue());} catch (Exception e) {throw new RuntimeException("ERROR ## parser of eromanga-event has an error,data:" + entry.toString(),e);}//获取变动类型EventType eventType = rowChage.getEventType();System.out.println(String.format("================&gt; binlog[%s:%s] , name[%s,%s] , eventType : %s",entry.getHeader().getLogfileName(), entry.getHeader().getLogfileOffset(),entry.getHeader().getSchemaName(), entry.getHeader().getTableName(), eventType));for (RowData rowData : rowChage.getRowDatasList()) {if (eventType == EventType.INSERT) {redisInsert(rowData.getAfterColumnsList());} else if (eventType == EventType.DELETE) {redisDelete(rowData.getBeforeColumnsList());} else {//EventType.UPDATEredisUpdate(rowData.getAfterColumnsList());}}}}public static void main(String[] args){System.out.println("---------O(∩_∩)O哈哈~ initCanal() main方法-----------");//=================================// 创建链接canal服务端CanalConnector connector = CanalConnectors.newSingleConnector(new InetSocketAddress(REDIS_IP_ADDR,11111), "example", "", "");int batchSize = 1000;//空闲空转计数器int emptyCount = 0;System.out.println("---------------------canal init OK，开始监听mysql变化------");try {connector.connect();//connector.subscribe(".*\\..*");connector.subscribe("bigdata.t_user");connector.rollback();int totalEmptyCount = 10 * _60SECONDS;while (emptyCount < totalEmptyCount) {System.out.println("我是canal，每秒一次正在监听:"+ UUID.randomUUID().toString());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());}connector.ack(batchId); // 提交确认// connector.rollback(batchId); // 处理失败, 回滚数据}System.out.println("已经监听了"+totalEmptyCount+"秒，无任何消息，请重启重试......");} finally {connector.disconnect();}}
}
（3）题外话
  1. java程序下 connector.subscribe配置的过滤正则
  2. 关闭资源代码简写：
（4）总结
  1. 原理和步骤1、步骤2：
  2. 步骤3是开发 Canal 客户端，用于接收 Canal 解析后的 binlog 数据，并根据数据内容更新 Redis，代码见上
  3.  数据同步处理：
关键字：分销系统定制_中国跨境电商前三名_宣传推广的形式有哪些_在线制作网站免费

版权声明:

本网仅为发布的内容提供存储空间，不对发表、转载的内容提供任何形式的保证。凡本网注明“来源：XXX网络”的作品，均转载自其它媒体，著作权归作者所有，商业转载请联系作者获得授权，非商业转载请注明出处。

我们尊重并感谢每一位作者，均已注明文章来源和作者。如因作品内容、版权或其它问题，请及时与我们联系，联系邮箱：809451989@qq.com，投稿邮箱：809451989@qq.com

责任编辑：
>> 相关文章
>> 热门图片
html电影网站源码_网站建设哪里好_网站收录查询站长工具_搜索网站大全排名
html电影网站源码_网站建设哪里好_网站收录查询站长工具_搜索网站大全排名
线上运营公司_宁波网站建设是哪家便宜_seo推广工具_竞价推广网络推广运营
线上运营公司_宁波网站建设是哪家便宜_seo推广工具_竞价推广网络推广运营
网页qq登陆网站_秦皇岛在哪里属于哪个省_广丰网站seo_农产品营销方案
网页qq登陆网站_秦皇岛在哪里属于哪个省_广丰网站seo_农产品营销方案
公司部门解散怎么赔偿员工_工商企业网_口碑营销的概念_软文营销什么意思
公司部门解散怎么赔偿员工_工商企业网_口碑营销的概念_软文营销什么意思
廊坊百度优化_免费空间申请网站_百度知道网页版_seo快速排名案例
廊坊百度优化_免费空间申请网站_百度知道网页版_seo快速排名案例
小程序商城多少钱_网站代码免费复制_seo是什么及作用_网站优化价格
小程序商城多少钱_网站代码免费复制_seo是什么及作用_网站优化价格
上海人才信息网_如何做百度搜索推广_seo关键词优化技术_安卓嗅探app视频真实地址
上海人才信息网_如何做百度搜索推广_seo关键词优化技术_安卓嗅探app视频真实地址
免费手机网站制作方法_资源网站推荐_营销神器_百度云搜索引擎入口
免费手机网站制作方法_资源网站推荐_营销神器_百度云搜索引擎入口
>> 热门搜索
评论排行
图片新闻
更多>>
seo北京公司_廊坊seo优化公司_网站优化靠谱seo_seo软文推广工具
南宁经典网站建设_网站设计制作开发公司_无排名优化_整站优化方案
分销系统定制_中国跨境电商前三名_宣传推广的形式有哪些_在线制作网站免费
h5海报免费制作软件_花园休闲平台设计_百度拍照搜索_大泽山seo快速排名
点击排行

邮箱：809451989@qq.com 网站地图
未经过本站允许,请勿将本站内容传播或复制