1、什么是MQ？ MQ全称为Message Queue, 顾名思义，即消息队列，它是一种应用程序对应用程序的通信方法。MQ是消费-生产者模型的一个典型的代表，生产者不断的往消息队列中不断写入消息，消费者则可以读取或者订阅队列中的消息，生产者和消费者不需要知道对方是谁，一个负责发消息，一个负责收消息， ...
分类：
其他好文 时间：
2019-08-03 11:20:22
阅读次数：
87
一、什么是Exchange 首先我们要了解到，RabbitMQ 是 AMQP（高级消息队列协议）的标准实现： 从 AMQP 协议可以看出，Queue、Exchange 和 Binding 构成了 AMQP 协议的核心 Producer：消息生产者，即投递消息的程序。 Broker：消息队列服务器实体 ...
分类：
其他好文 时间：
2019-07-14 21:23:31
阅读次数：
405
主题+客户端发布订阅的对象是主题（Topic）向主题发布消息的客户端应用程序称为生产者（Producer），生产者可以持续不断地向多个主题发送消息订阅这些主题消息的客户端应用程序称为消费者（Consumer），消费者能够同时订阅多个主题的消息生产者和消费者统称为客户端服务端Kafka的服务端由被称为Broker的服务进程构成，一个Kafka集群由多个Broker组成Broker负责接收和处理客户端
分类：
编程语言 时间：
2019-07-01 21:41:06
阅读次数：
169
return listener 用于处理一些不可路由的消息。 我们的消息生产者，通过指定一个exchange和routingkey，把消息送达到某一个队列中，然后我们的消费者监听队列，进行消费处理操作。 但是在某种情况下，如果我们在发送消息的时候，当前的exchange不存在或者制定的路由key路由 ...
分类：
其他好文 时间：
2019-06-29 19:33:35
阅读次数：
220
上篇文章我们简单的介绍了stream的使用，发现使用还是蛮方便的，但是在上个案例中，如果有多个消息接收者，那么消息生产者发送的消息会被多个消费者都接收到，这种情况在某些实际场景下是有很大问题的，比如在如下场景中，订单系统我们做集群部署，都会从RabbitMQ中获取订单信息，那 ...
分类：
编程语言 时间：
2019-06-28 21:09:39
阅读次数：
127
1. Kafka 总体架构 基于 Kafka-ZooKeeper 的分布式消息队列系统总体架构如下： 如上图所示，一个典型的 Kafka 体系架构包括若干 Producer（消息生产者），若干 broker（作为 Kafka 节点的服务器），若干 Consumer（Group），以及一个 ZooKe ...
分类：
其他好文 时间：
2019-06-28 14:49:18
阅读次数：
106
模型结构 JMS编程模型由以下几个组成： ConnectionFactory：连接工厂（创建连接） Connection：连接（创建会话） Session：会话（创建目的地、生产者、消费者、消息） Destination：目的地（消息发送目标） MessageProducer：消息生产者（发送消息） ...
分类：
其他好文 时间：
2019-06-25 00:07:15
阅读次数：
115
从 AMQP 协议可以看出，Queue、Exchange 和 Binding 构成了 AMQP 协议的核心 Producer：消息生产者，即投递消息的程序。 Broker：消息队列服务器实体。 Exchange：消息交换机，它指定消息按什么规则，路由到哪个队列。 Binding：绑定，它的作用就是把 ...
分类：
其他好文 时间：
2019-06-16 00:23:36
阅读次数：
98
事故背景： 我们公司与合作方公司有个消息同步的需求，合作方是消息生产者，我们是消息消费者，他们通过kafka给我们推送消息，我们实时接收，然后进行后续业务处理。昨天上午，发现他们推送过来的广场门店信息我们都没有消费，导致我们系统和他们系统数据不一致，从而导致无法提单，无法出报表（报表有误）等各种问题 ...
分类：
其他好文 时间：
2019-06-12 10:53:36
阅读次数：
143
