1. 预备知识 1.1 消息传递 首先我们知道消费者是从队列中获取消息的，那么消息是如何到达队列的？ 当我们发送一条消息时，首先会发给交换器（exchange），交换器根据规则（路由键：routing key）将会确定消息投递到那个队列（queue）。 需要JAVA Spring Cloud大型企业 ...
分类：
编程语言 时间：
2019-04-02 16:52:54
阅读次数：
154
为什么使用消息队列 什么业务场景，这个业务场景有个什么技术挑战，如果不用MQ可能会很麻烦，但是你现在用了MQ之后带给了你很多的好处。消息队列的常见使用场景，其实场景有很多，但是比较核心的有3个：解耦、异步、削峰。 解耦： A系统发送个数据到BCD三个系统，接口调用发送，那如果E系统也要这个数据呢？那 ...
分类：
其他好文 时间：
2019-02-19 15:04:33
阅读次数：
172
消费者接收指定路由关键字的消息，这时就要用到直连类型交换器 通过直连交换器，生产者发送不同路由关键字的信息，消费者端通过绑定自己感兴趣的路由关键字来接收消息。 生产者 消费者1 消费者2 依次运行消费者1和2，生产者 可以看到消费者1接收到了路由关键字为keys1和keys2的消息，消费者2则是ke ...
分类：
其他好文 时间：
2019-02-17 00:35:32
阅读次数：
178
topic类型的交换器允许在RabbitMQ中使用模糊匹配来绑定自己感兴趣的信息 通过匹配交换器，我们可以配置更灵活的消息系统 匹配交换器的匹配符 *（星号）表示一个单词 #（井号）表示零个或者多个单词 这次的例子中，我们使用三个段式的路由关键字，有三个单词和两个点组成。 第一个词是速度，第二个词是 ...
分类：
其他好文 时间：
2019-02-17 00:23:16
阅读次数：
190
将同一个队列的消息发送给多个消费者的模式就是“发布/订阅”, 这种模式的基础是将消息广播到所有的接收器上。 实际上，RabbitMQ中消息传递模型的核心思想是： 生产者不直接发送消息到队列。 实际的运行环境中，生产者是不知道消息会发送到哪个队列上， 她只会将消息发送到一个交换器， 交换器也像一个生产 ...
分类：
其他好文 时间：
2019-02-17 00:20:43
阅读次数：
289
AMQP中消息的路由过程和Java开发者熟悉的JMS存在一些差别，AMQP中增加了Exchange和Binding的角色，生产者把消息发布到Exchange上，Binding决定发布到Exchange上的消息应该发送到那个队列上，消息最终到达队列并被消费者接收。 Exchange（交换器）类型 Ex ...
分类：
其他好文 时间：
2019-02-04 14:04:26
阅读次数：
238
生产者发送消息 1、生产者连接到 RabbitMQ Broker，建立一个连接（Connection），开启一个信道（Channel） 2、生产者声明一个交换器，并设置相关属性，比如交换机类型、是否持久化等 3、生产者声明一个队列并设置相关属性，比如是否排他、是否持久化、是否自动删除等 4、生产者通 ...
分类：
其他好文 时间：
2019-01-27 19:18:54
阅读次数：
180
public class TestController : ApiController { private static string EXCHANGE_NAME = "exchangeTest"; //交换器（路由器），负责消息的路由到相应队列 private static string QUEU... ...
分类：
其他好文 时间：
2019-01-16 11:40:56
阅读次数：
248
先说下这个参数的作用: 绑定好之后就可以测试这个参数了,使用我们指定的交换器和key! 程序启动之后会自动创建,这里如果需要捕获匹配失败的消息需要添加一个监听器 测试:当参数设置为true时,写个错误的key: 由于key不对,匹配队列失败,参数为true,所以消息会返回给生产者: 如果写上正确ke ...
分类：
编程语言 时间：
2019-01-12 12:15:25
阅读次数：
258
目录交换器、队列、绑定的声明关于消息序列化同一个队列多消费类型注解将消息和消息头注入消费者方法关于消费者确认关于发送者确认模式消费消息、死信队列和RetryTemplateRPC模式的消息（不常用）关于消费模型关于RabbitMq客户端的线程模型在公司里一直在用RabbitMQ，由于api已经封装的很简单，关于RabbitMQ本身还有封装的实现没有了解，最近在看RabbitMQ实战这本书，结合网上
分类：
编程语言 时间：
2018-12-16 19:29:20
阅读次数：
241
