消费者接收指定路由关键字的消息，这时就要用到直连类型交换器 通过直连交换器，生产者发送不同路由关键字的信息，消费者端通过绑定自己感兴趣的路由关键字来接收消息。 生产者 消费者1 消费者2 依次运行消费者1和2，生产者 可以看到消费者1接收到了路由关键字为keys1和keys2的消息，消费者2则是ke ...
分类：
其他好文 时间：
2019-02-17 00:35:32
阅读次数：
178
我们以官方提供的教程1做个简单梳理：该教程展示了Producer如何向一个消息队列(message queue)发送一个消息(message)，消息消费者(Consumer)收到该消息后消费该消息。
分类：
其他好文 时间：
2019-01-16 13:14:19
阅读次数：
160
1.mq解决的问题 + 系统异步处理 + 应用解耦 + 流量削峰 + 日志处理 + 消息通信 2.消息中间件的2中模型 2.1 Point to Point(P2P) / 点对点 / 类比：送快递 特点: + 一个消费生产者必须有一个消息消费者。一对一的关系 + 一个消息发送到queue中，如果mq ...
分类：
其他好文 时间：
2018-12-02 01:20:48
阅读次数：
189
Kafka简介kafka是一个高吞吐量的分布式消息队列，具有高性能、持久化、多副本备份、横向扩展能力，通常用于大数据及流处理平台。消息队列里都有生产者/消费者的概念，生产者往队列里写消息，而消费者则是从队列里获取消息。一般在架构设计中起到解耦、削峰、异步处理的作用。kafka对外使用topic的概念，生产者往topic里写消息，消费者则从topic里读消息。为了做到水平扩展，一个topic实际是由
分类：
其他好文 时间：
2018-10-25 19:45:36
阅读次数：
190
1.消费者代码 2. 消费者代码 3. pom依赖 ...
分类：
其他好文 时间：
2018-10-14 19:16:14
阅读次数：
247
一：消费者确认 消费者确认或者说消费者应答指的是RabbitMQ需要确认消息到底有没有被收到 - 自动应答 在订阅消息的时候可以指定应答模式,当自动应答等于true的时候，表示当消费者一收到消息就表示消费者收到了消息，消费者收到了消息就会立即从队列中删除。 生产者 消费者 运行结果： 运行生产者可以 ...
分类：
其他好文 时间：
2018-09-04 11:36:38
阅读次数：
202
1 RabbitMQ知识点 1.1 整体架构图 消息生产者将消息投递到exchange中，exchange会以某种路由机制将生产者投递的消息路由到queue中，消息消费者再从queue中获取消息进行消费。 1.2 核心概念 1.2.1 server 又称Broker，接收客户端的连接，实现AMQP实 ...
分类：
编程语言 时间：
2018-08-31 00:33:33
阅读次数：
313
Kafka整体结构图 Producer ：消息生产者，就是向 kafka broker 发消息的客户端。 Consumer ：消息消费者，向 kafka broker 取消息的客户端 Topic ：每条发布到Kafka集群的消息都有一个类别，这个类别被称为Topic。 Consumer Group ...
分类：
其他好文 时间：
2018-08-10 23:12:32
阅读次数：
224
RabbitMQ是一个消息服务器，可以接收和转发消息。 RabbitMQ是一个消息代理 - 一个消息系统的媒介。它可以为你的应用提供一个通用的消息发送和接收平台，并且保证消息在传输过程中的安全。 生产者（producer）发送一条消息，消费者(consumer)接收消息并打印。 Queue 队列 P ...
分类：
其他好文 时间：
2018-08-03 16:28:35
阅读次数：
149
Kafka架构组成：由producer（消息生产者）、consumer（消息消费者）、borker(kafka集群的server，负责处理消息读、写请求，存储消息，在kafka cluster这一层这里，其实里面是有很多个broker)、topic（消息队列/分类相当于队列，里面有生产者和消费者模型 ...
分类：
其他好文 时间：
2018-07-22 14:03:53
阅读次数：
245
