首页 / RABBITMQ / canal 整合RabbitMQ

canal 整合RabbitMQ

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了canal 整合RabbitMQ，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含1473字，纯文字阅读大概需要3分钟。

内容图文

环境如下:

canal: 1.15-alpha-1

mysql  5.6.49

rabbitmq 3.7.14

Erlang 21.3

 

canal 安装和启动 见上篇文章 canal快速安装启动

 

但是这个拿到的数据,不知道怎么处理 看看如果丢到mq,我从mq取到的数据格式 

{
    "data":[
        {
            "id":"23",
            "name":"sdfs",
            "age":"10",
            "sex":"1",
            "created_at":"2010-09-09 11:11:11",
            "updated_at":"2020-08-14 23:57:34"
        }
    ],
    "database":"test",
    "es":1597420654000,
    "id":1,
    "isDdl":false,
    "mysqlType":{
        "id":"int(11)",
        "name":"varchar(255)",
        "age":"int(11)",
        "sex":"int(255)",
        "created_at":"timestamp",
        "updated_at":"timestamp"
    },
    "old":[
        {
            "name":"er",
            "updated_at":"2020-07-25 09:27:35"
        }
    ],
    "pkNames":[
        "id"
    ],
    "sql":"",
    "sqlType":{
        "id":4,
        "name":12,
        "age":4,
        "sex":4,
        "created_at":93,
        "updated_at":93
    },
    "table":"user",
    "ts":1597422036430,
    "type":"UPDATE"
}

 

这个就很好用了,直接拿data字段进行更新就行了

type 会有  UPDATE  DELETE INSERT 

canal 官方文档 说是队列只支持 kafka 和 rocketmq 

但是现在的版本已经支持 rabbitmq了  

  

vim conf/canal.properties

canal.mq.servers = 192.168.33.60
canal.mq.vhost=/
canal.mq.exchange=exchange_user_sync
canal.mq.username=admin
canal.mq.password=admin


canal.serverMode = rabbitmq

 

vim conf/example/instance.properties

canal.instance.master.address=192.168.33.60:3306  改为我的数据库ip


# username/password  默认就是这样的,按照官方的例子授权 都可以不用改了,如果自己授权其他用户改动
canal.instance.dbUsername=canal
canal.instance.dbPassword=canal
canal.instance.connectionCharset = UTF-8
# enable druid Decrypt database password
canal.instance.enableDruid=false


canal.mq.topic=example    mq路由  到时候 交换机和队列绑定要设置route为 example

 

 

技术分享图片

 

原文：https://www.cnblogs.com/brady-wang/p/13507210.html

内容总结

以上是互联网集市为您收集整理的canal 整合RabbitMQ全部内容，希望文章能够帮你解决canal 整合RabbitMQ所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/1277753.html

来源：【匿名】