咸阳建设网站,网站禁止右键,十大创意网站,织梦如何仿手机网站源码canal 是阿里巴巴开源的一款基于数据库增量日志解析,提供增量数据订阅消费,目前主要支持了MySQL(也支持mariaDB)。我开发的这个CanalSync项目 https://github.com/yuzd/CanalSync 觉得不错帮忙给个star谢谢是基于canal-server之上的数据库同步消费中间件#… canal 是阿里巴巴开源的一款基于数据库增量日志解析,提供增量数据订阅消费,目前主要支持了MySQL(也支持mariaDB)。我开发的这个CanalSync项目 https://github.com/yuzd/CanalSync 觉得不错帮忙给个star谢谢是基于canal-server之上的数据库同步消费中间件用于可快速搭建消费canal-server的项目。 目前我已实现并开源了如下数据消费传输到redis组件数据消费传输到rabbitmq组件数据消费传输到mysql数据库组件Nuget1. 接收canal-server的消息中间件Install-Package Canal.Server2. 解析canal-server消息转出可执行sql的中间件Install-Package Canal.SqlParse如何使用如果你需要写一个数据消费传输到XXXMQ用不到反解析成sql的话只需要引用 Canal.Server中间件。 如果你需要写一个数据消费传输到XXXdb得用到反解析sql中间件需要同时引用Canal.Server 和 Canal.SqlParse 这2个中间件。Canal.Server 如何使用引用 Canal.Server 并appsettings.json 配置canal-server的参数.如下图参数说明 创建一个 消费类 必须要 实现 INotificationHandler 接口例如叫TestHandler在startUp 使用并注册 该消费类 services.AddCanalService(produce produce.RegisterSingletonTestHandler());Canal.SqlParse 如何使用目前只实现了解析mysql的逻辑未来会加入sqlserver的解析逻辑!! services.AddMysqlParseService(connectionString);在类的构造方法可注入如上图代表将canal-server的数据直接在另外的mysql库里面执行等于2个mysql数据进行互相同步。欧洲与中国的2个mysql库 使用上述方法进行同步的测试结果 同步速度在100~200qps 原文地址https://www.cnblogs.com/yudongdong/p/11032062.html.NET社区新闻深度好文欢迎访问公众号文章汇总 http://www.csharpkit.com
