数据库同步中间件CanalOtter前日篇（2）MySQLInnoDB架构体系!这里写图片描述(http://static.oschina.net/uploads/img/201604/24113828_GCwY.jpg)MySQL体系前端

1\.kafka介绍1.1. 主要功能根据官网的介绍，ApacheKafka®是_一个分布式流媒体平台_，它主要有3种功能：1：Itletsyoupublishandsubscribetostreamsofrecords.发布和订阅消息流，这个功能类似于消息队列，这也是kafka归类为消息队

1.ActiveMQ是什么ActiveMQ是一个消息队列应用服务器（推送服务器）。支持JMS规范。1.1JMS概述全称：JavaMessageService，即为Java消息服务，是一套java消息服务的API标准。（标准即接口）实现了JMS标准的系统，称之

activemq消息队列，分为生产者和消费者。.1创建生产者publicclassProducter{//ActiveMq的默认用户名privatestaticfinalStringUSERNAMEActiveMQConnection.DEFAULT\_USER;//ActiveMq的默认登录密码pr

java往MQ里面发消息和取消息packagetest;importjava.io.IOException;importcom.ibm.mq.MQC;importcom.ibm.mq.MQEnvironment;importcom.ibm.mq.MQException

1、默认生产者消息是持久的:会存数据库\消费者的持久：createDurableSubscriber是指消费者能收到所有它订阅时间点之后的消息，即使消费者注册后关闭，当它重启就能收到注册时间点之后所有的消息;即当此消费用户ID(AAA)在producer发送之前就已经注册，那么此id能收到producer发送的所有消息，如果是在produce

Kafka是一种分布式的基于发布/订阅的消息系统，它的高吞吐量、灵活的offset是其它消息系统所没有的。Kafka发送消息主要有三种方式：1.发送并忘记2.同步发送3.异步发送回调函数下面以单节点的方式分别用三种方法发送1w条消息测试：方式一：发送并忘记(不关心消息是否正常到达，对返回结果不做任何判断处理)发送并忘记的方式本质上也

Redis不仅可作为缓存服务器，还可用作消息队列。它的列表类型天生支持用作消息队列。\\性质：\\由于Redis的列表是使用双向链表实现的，保存了头尾节点，所以在列表头尾两边插取元素都是非常快的。所以可以直接使用Redis的List实现消息队列，只需简单的两个指令lpush和rpop或者rpush和lpop。（列表常用命令）R

为什么使用延迟消息？不同于同步消息，有些业务场景下希望可以实现延迟一定时间再消费消息。典型的场景有微信、支付宝等第三方支付回调接口，会在用户支付后3秒、5秒、30秒等等时间后向应用服务器发送回调请求，确保应用服务器可以正确收到消息。那有些朋友就会说了，把需要定时处理的数据存到数据库中用定时任务就可以实现，为什么还弄个异步消息。增加后台维护

客户端SDK版本与推送通知的关系主要体现在以下几个方面：兼容性：消息格式：不同版本的SDK可能支持不同的消息格式和协议。如果服务端发送的消息格式与客户端SDK不兼容，可能会导致消息无法正确解析或显示。特性支持：新版本的SDK可能引入了新的特性或功能，而旧版