本文详细分析了RocketMQ事务消息实现原理中的事务状态回查实现，RocketMQ会默认一分钟的频率处理消息状态为Prepare的消息，通过调用消息生产者的事务状态查询接口得知消息的事务状态，从而决定提交或回滚消息。
分类：
其他好文 时间：
2019-01-08 17:19:10
阅读次数：
185
一 为什么使用MQ： 二 那么MQ是什么： 三 队列、生产者、消费者 ① 队列是RabbitMQ内部对象，用于存储消息，生产者生产的消息投进队列中，消费者可以从中取消息消费。 ② 多个消费者可以同时订阅一个队列，这个时候队列中的消息会被均分给多个消费者消费，而不是每个消费者都可以拿到所有的消息。 ③ ...
分类：
其他好文 时间：
2018-09-12 01:08:47
阅读次数：
172
1.消息发送 1.异步发送 消息生产者使用持久（persistent）传递模式发送消息的时候，Producer.send() 方法会被阻塞，直到 broker 发送一个确认消息给生产者，这个确认消息暗示生产者 broker已经成功地将它发送的消息路由到目标目的并把消息保存到二级存储中。这个过程通常称 ...
分类：
其他好文 时间：
2018-09-08 16:52:10
阅读次数：
167
1 RabbitMQ知识点 1.1 整体架构图 消息生产者将消息投递到exchange中，exchange会以某种路由机制将生产者投递的消息路由到queue中，消息消费者再从queue中获取消息进行消费。 1.2 核心概念 1.2.1 server 又称Broker，接收客户端的连接，实现AMQP实 ...
分类：
编程语言 时间：
2018-08-31 00:33:33
阅读次数：
313
什么是MQ？ MQ全程Message Queue，消息队列（MQ）是一种应用程序对应用程序的通信方法。MQ是消费者-生产者模型的典型代表。一端往消息队列中不断写消息而另一端则可以读取队列中的消息。 RabbmitMQ相关组成： producer：消息生产者，生产消息并投递到队列之中。 cusumer ...
分类：
其他好文 时间：
2018-08-24 18:08:49
阅读次数：
540
Kafka整体结构图 Producer ：消息生产者，就是向 kafka broker 发消息的客户端。 Consumer ：消息消费者，向 kafka broker 取消息的客户端 Topic ：每条发布到Kafka集群的消息都有一个类别，这个类别被称为Topic。 Consumer Group ...
分类：
其他好文 时间：
2018-08-10 23:12:32
阅读次数：
224
Kafka架构组成：由producer（消息生产者）、consumer（消息消费者）、borker(kafka集群的server，负责处理消息读、写请求，存储消息，在kafka cluster这一层这里，其实里面是有很多个broker)、topic（消息队列/分类相当于队列，里面有生产者和消费者模型 ...
分类：
其他好文 时间：
2018-07-22 14:03:53
阅读次数：
245
引入依赖： 配置文件： 邮件服务： 模板文件： spring boot启动类： email rest 接口： 通过请求 /test/send 接口，通过调用邮件消息生产者，将想要发送的邮件信息缓存在activeMq的email.queue队列中， 由邮件消息消费者调用邮件服务类发送邮件 邮件消息生产 ...
分类：
编程语言 时间：
2018-06-22 15:26:42
阅读次数：
643
一、概述什么是MQ？MQ全称为MessageQueue,消息队列（MQ）是一种应用程序对应用程序的通信方法。MQ是消费-生产者模型的一个典型的代表，一端往消息队列中不断写入消息，而另一端则可以读取队列中的消息1、队列、生产者、消费者队列是RabbitMQ的内部对象，用于存储消息。生产者（下图中的P）生产消息并投递到队列中，消费者（下图中的C）可以从队列中获取消息并消费。多个消费者可以订阅同一个队列
分类：
其他好文 时间：
2018-05-24 20:44:58
阅读次数：
204
一，前言 如果我们一个生产者，对应多个消费者，rabbitmq 会发生什么呢 二，消息分发轮询 前提条件：1个生产者 > 多个消费者，且no_ack=True （启动三次生产者） ①初始化状态：3个消费者都在等待生产者发消息 ②生产者发第1条消息：只有第1个消费者受到消息，第2个和第3个消费者没有收 ...
分类：
其他好文 时间：
2018-05-24 20:40:51
阅读次数：
219
