概念 Kafka 是一个快速、可扩展和高可用的基于发布 订阅模式（pub sub model）的消息系统，用作消息中间件，在系统之间传递消息。其核心概念有： Topic（话题） Producer（生产者） Consumer（消费者） Broker（经纪人） 在 Kafka 中，所有的消息都由 Top ...
分类：
其他好文 时间：
2019-08-11 12:44:35
阅读次数：
108
RabbitMQ死信队列 场景说明 代码实现 简单的Util 生产者 消费者 场景说明 场景: 当队列的消息未正常被消费时,如何解决? 消息被拒绝并且不再重新投递 消息超过有效期 队列超载 方案: 未被消费的消息,可通过"死信队列"重新被消费 死信队列含义,发生以上情况时,该队列上的消息,可通过配置 ...
分类：
其他好文 时间：
2019-08-10 19:40:46
阅读次数：
128
生产者-消费者模式是一个经典的多线程设计模式，它为多线程间的协作提供了良好的解决方案。这个模式中，通常有两类线程，即若干个生产者线程和若干个消费者线程。生产者线程负责提交用户请求，消费者线程则负责具体处理生产者提交的任务。生产者和消费者之间通过共享内存缓存区进行通信，这样就避免了生产者和消费者直接通 ...
分类：
编程语言 时间：
2019-08-10 18:58:43
阅读次数：
101
|--需求说明 |--实现方式 嗯 这个可以视作一个经典的消费者和生产者的问题，详细见代码注释 |--代码内容 1 /** 2 * @auther:：9527 3 * @Description: 消费者 4 * @program: 多线程 5 * @create: 2019-08-10 10:45 ...
分类：
编程语言 时间：
2019-08-10 14:12:41
阅读次数：
95
今天只看看原理，下一节看项目怎么集成mq进行解决分布式事物。 1、什么情况下会使用到分布式事物？ 举例说明：现有一个支付系统，因为项目使用的是微服务框架，有订单模块和支付模块两个模块。生产者进行订单的下单操作购买100元，这时候订单表数据应该是新增一条，然后支付模块的个人账户资金应该是加100元。同 ...
分类：
其他好文 时间：
2019-08-10 10:10:56
阅读次数：
90
springboot 整合 ActiveMQ pom 坐标 yml 文件 消息生产者 使用 springboot 测试类实现 ObjectMessage 被发送的对象必须实现序列化。如果嵌套，都要实现序列化。Customer 对象有个成员是 LinkMan 对象，则 Customer 和 LinkM ...
分类：
编程语言 时间：
2019-08-09 19:32:53
阅读次数：
93
1.用户不断输入两个数，计算调和平均数，直到其中一个数为0。 2.要求用户输入最多10个高尔夫成绩，并将其存储在一个数组中。程序允许用户提早结束输入，并在一行上显示所有成绩，然后报告平均成绩。使用3个数组处理函数分别进行输入、显示和计算平均成绩。 3.定义一个box结构，存储生产者，长高宽和体积的信 ...
分类：
编程语言 时间：
2019-08-08 21:46:12
阅读次数：
150
BlockingQueue BlockingQueue、解决了多线程中，如何高效安全“传输”数据的问题。程序员无需关心什么时候阻塞线程，什么时候唤醒线程，该唤醒哪个线程。 方法介绍 BlockingQueue是Queue的子类 void put(E e) 插入指定元素，当BlockingQueue为 ...
分类：
编程语言 时间：
2019-08-08 18:53:58
阅读次数：
93
maxwell主要提供了下列功能 支持 SELECT * FROM table 的方式进行全量数据初始化 支持在主库发生failover后，自动回复binlog位置（GTID） 可以对数据进行分区，解决数据倾斜问题，发送到kafka的数据支持database，table，column等级别的数据分区 ...
分类：
数据库 时间：
2019-08-06 20:01:54
阅读次数：
438
