mysql广播_监听Mysql数据库变更并广播到ws.z.12zan.net

项目地址:yuanfenxi/yuanlicastgithub.com

go-mysql-elasticsearch是一个golang包，可以以一个MysqlServer的salve的身份，监听mysql的数据变更，并将变更导入到elasticsearch。

我看到这个包的想法是，是否可以稍做修改，当mysql数据库有变更时，将变更广播到消息队列中去,增强及时性。关于我们的这个简单的消息队列，或者叫广播，可以参见:

。

昨天睡前喝了点小酒，拿着elasticsearch的代码就开始动刀了，我把访问elasticsearch的那一部分删掉，改成提交数据到http://ws.z.12zan.net 到凌晨1点的时候已经基本完成了。

用法和go-mysql-elasticsearch基本一致，启动是: ./bin/yuancast -config=./etc/river.toml

配置文件

配置文件也在./etc/river.toml里。

配置里几个关键项如下:

* _bulk_size = 1

这个请修改成1，这样每次有数据变更就提交。不然就失去项目存在的意义了。yfx_gateway = "https://ws.z.12zan.net/dbcast/some_channel_as_you_wish"

每个不同的URL地址就是一个不同的频道。这里可以随便填，请确保你填写的和别人的是不一样的频道地址。yfx_secret = hellloafsdfefss9843ru93f

广播的时候，对数据进行一下加密，用的是这个密钥。

客户端

客户端解密的代码需要根据自己的应用场景来写了。

我提供了一个nodejs的示例，在 jsClientExample 目录下:

npm install

node ./test.js

mysql广播_监听Mysql数据库变更并广播到ws.z.12zan.net相关推荐

监听mysql表内容变化使用canal,canal 监听同步指定数据库，所有表
canal 监听同步指定数据库,所有表 canal 监听同步指定数据库,所有表因为工作需求,需要用到数据库同步,又从网上找了一些发现都有些问题,所以自己弄好之后写一篇总结,及配置步骤吧先将 MyS ...
spring boot+kafka+canal实现监听MySQL数据库
spring boot+kafka+canal实现监听MySQL数据库一.zookeeper安装 kafka依赖于zookeeper,安装kafka前先安装zookeeper 下载地址:Apache ...
Java监听mysql的binlog详解(mysql-binlog-connector)
Java监听mysql的binlog详解(mysql-binlog-connector) 1. 需求概述 2. 技术选型 3. 方案设计 3.环境准备 3.1 查看是否开启binlog 3.2 mys ...
Canal监听mysql的binlog日志实现数据同步
Canal监听mysql的binlog日志实现数据同步 1. canal概述 1.1 canal简介 1.2 技术选型 1.3 原理分析 1.3.1 MySQL主备复制原理 1.3.2 canal原理 ...
springboot整合canal，监听MySQL binlog日志，实现增量同步
有两个数据库,并不是主从关系,但是需要同步某张表,可以通过binlog日志,进行同步,前提是这两个数据库的要同步的表,表名和字段名需要一致. 当前项目连接的数据库(需要同步的数据库):base_pro ...
Canal监听MySQL
Canal监听MySQL 1.Mysql数据库开启binlog模式注意:Mysql容器,此处Mysql版本为5.7 #进入容器 docker exec -it mysql /bin/bash #进入 ...
判断frame是否已创建_大白菜的ROS笔记（8）（创建TF广播和监听，内容很多，细节满满）...
创建TF广播和监听 #include <ros/ros.h> #include <tf/transform_broadcaster.h> #include <turtle ...
【Android 电量优化】电量优化 ( 充电状态获取 | 主动获取充电状态 | 广播接受者监听充电状态 | 被动获取充电状态 | 注册空广播接受者获取历史广播 )
文章目录一.获取充电状态二.被动获取充电状态三.主动获取充电状态参考 Google 官方文档 : 优化电池续航时间一.获取充电状态在应用中执行某些操作 , 如软件云端备份 , 从服务器端获 ...
【RK3399Pro学习笔记】十四、ROS中tf坐标系广播与监听的编程实现
目录创建功能包如何实现一个tf广播器创建tf广播器代码(C++) 如何实现一个tf监听器创建tf监听器代码(C++) 配置编译规则编译并运行 python 编写程序 turtle_tf_br ...

mysql广播_监听Mysql数据库变更并广播到ws.z.12zan.net

mysql广播_监听Mysql数据库变更并广播到ws.z.12zan.net相关推荐

最新文章

热门文章