在上一篇《ActiveMQ入门系列二：入门代码实例（点对点模式）》中提到了ActiveMQ中的两种模式：点对点模式（PTP）和发布/订阅模式（Pub & Sub），详细介绍了点对点模式并用代码实例进行说明，今天就介绍下发布/订阅模式。 一、理论基础 发布/订阅模式的工作示意图： 消息生产者将消息（发 ...
分类：
其他好文 时间：
2019-06-08 14:43:02
阅读次数：
98
一、MQ消息发送 1、发送端MQ-client(消息生产者：Producer)将消息发送给MQ-server； 2、MQ-server将消息落地； 3、MQ-server回ACK给MQ-client（Producer）； 4、MQ-server将消息发送给消息接受端MQ-client(消息消费者：C ...
分类：
其他好文 时间：
2019-05-23 22:44:49
阅读次数：
134
概览 - kafka解决的问题- 主题 - 分区 - 消息- 生产者- broker - broker集群- 消费者 - 消费者组群 - 生产者分区和消费者群组- 消息可靠性- 消息系统 - 队列和广播 - 消息保序- 存储系统- 流处理- 整合- 应用场景- api分类kafka解决的问题 生产者 ...
分类：
其他好文 时间：
2019-05-16 15:16:21
阅读次数：
152
1，消息队列解决什么问题 异步处理 应用解耦 流量消峰(高并发、 秒杀) 日志处理...... 2，virtual host 相当于mysql数据库的db，一般以/开头 授权 3，使用java开发rabbitMQ (1) 简单队列 p:消息生产者 红色：消息队列 c：消息消费者 3个对象，生产者、消 ...
分类：
其他好文 时间：
2019-04-27 09:27:38
阅读次数：
144
rabbit引入交换机概念。 交换机与生产者绑定。 队列与消费者绑定。 队列又与交换机绑定。 扇形交换机是 fanout类型的。 类似于其他消息中间件的 topic。一对多（生产者推送消息到指定交换机，一个或多个绑定了此交换机的消费者的队列都可以收到此交换机的消息） 生产者： 消费者： ...
分类：
其他好文 时间：
2019-04-06 09:47:06
阅读次数：
120
直连交换机类型为：direct。加入了路由键routingKey的概念。 就是说 生产者投递消息给指定交换机的指定路由键。 只有绑定了此交换机指定路由键的消息队列才可以收到消息。 生产者： 消费者： ...
分类：
其他好文 时间：
2019-04-06 09:34:04
阅读次数：
92
工作队列比简单队列在消费者这边多了一个方法。 channel.basicQos(1);公平队列消费(参数设置为1，表示消费者消费完一条才会去接受再次发来的消息) 生产者： 消费者1： 消费者2： ...
分类：
其他好文 时间：
2019-04-06 09:17:43
阅读次数：
107
JMS（java message service）常用的消息模式有两种：点对点(PTP)和订阅发布(Pub/Sub） Clients A 和 B是消息生产者，以两种不同的目的地向Clients C, D, 和E 发送消息：在clients A, C, 和 D之间的消息是点对点模式，使用这种模式，客户 ...
分类：
其他好文 时间：
2019-03-22 16:42:29
阅读次数：
149
消费者接收指定路由关键字的消息，这时就要用到直连类型交换器 通过直连交换器，生产者发送不同路由关键字的信息，消费者端通过绑定自己感兴趣的路由关键字来接收消息。 生产者 消费者1 消费者2 依次运行消费者1和2，生产者 可以看到消费者1接收到了路由关键字为keys1和keys2的消息，消费者2则是ke ...
分类：
其他好文 时间：
2019-02-17 00:35:32
阅读次数：
178
生产者发送消息 1、生产者连接到 RabbitMQ Broker，建立一个连接（Connection），开启一个信道（Channel） 2、生产者声明一个交换器，并设置相关属性，比如交换机类型、是否持久化等 3、生产者声明一个队列并设置相关属性，比如是否排他、是否持久化、是否自动删除等 4、生产者通 ...
分类：
其他好文 时间：
2019-01-27 19:18:54
阅读次数：
180
