Producer定义了Start、Shutdown、SendSync、SendAsync、SendOneWay方法；NewProducer方法通过producer.NewDefaultProducer创建Producer

简介 canal，阿里开源工具，主要用途是基于 MySQL 数据库增量日志解析，提供增量数据订阅和消费 应用场景 数据库实时备份 业务cache刷新 索引构建和实时维护，例：将商品数据推送到es中构建倒排索引 带业务逻辑的增量数据处理，例：增量数据推送到第三方平台 官网 [链接] 原理 MySQL master将数据写入binlog canal 向mas…

3.找一个目录作为rocketmq的工作目录比如D:rocketmq-home新建三个文件夹conf: 配置文件logs: 日志文件store: broker持久化目录在idea中找到distribution目录把conf目录下面的logback_namesrv.xmllogback_broker.xmlbroker.conf文件拷贝到D:rocketmq-homeconf目录

broker 每隔 30s 会向 namesrv 注册自身的信息。namesrv 每隔 10s 检查 120s 内 无响应的 broker, 并进行剔除。