什么是消息队列 消息队列，即MQ，Message Queue。 消息队列是典型的：生产者、消费者模型。生产者不断向消息队列中生产消息，消费者不断的从队列中获取消息。因为消息的生产和消费都是异步的，而且只关心消息的发送和接收，没有业务逻辑的侵入，这样就实现了生产者和消费者的解耦。 结合前面所说的问题： ...
分类：
其他好文 时间：
2019-07-13 20:05:30
阅读次数：
134
消息队列是典型的 生产者 消费者模型 ,生产者只管发送消息,消费者只管监听队列取出消息,没有业务逻辑的侵入,实现了生产者和消费者的 解耦 ,这篇博客主要从如下几个方面整理相关RabbitMQ的知识点 1. 消息中间件在项目中的使用场景 2. RabbitMQ常见的 五种消息模型 3. 如何 避免消息 ...
分类：
其他好文 时间：
2019-07-08 13:46:46
阅读次数：
60
事故背景： 我们公司与合作方公司有个消息同步的需求，合作方是消息生产者，我们是消息消费者，他们通过kafka给我们推送消息，我们实时接收，然后进行后续业务处理。昨天上午，发现他们推送过来的广场门店信息我们都没有消费，导致我们系统和他们系统数据不一致，从而导致无法提单，无法出报表（报表有误）等各种问题 ...
分类：
其他好文 时间：
2019-06-12 10:53:36
阅读次数：
143
在 Kafka 中，生产者写入消息、消费者读取消息的操作都是与 leader 副本进行交互的，从 而实现的是一种主写主读的生产消费模型。数据库、Redis 等都具备主写主读的功能，与此同时还支持主写从读的功能，主写从读也就是读写分离，为了与主写主读对应，这里就以主写从读来称呼。Kafka 并不支持主 ...
分类：
其他好文 时间：
2019-05-30 10:19:14
阅读次数：
89
一、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
本篇将介绍RabbitMq的一个简单使用例子，分别介绍生产者如何发送消息，消费者如何接收和处理消息 关于RabbitMQ的知识背景的文章非常多。我对它的总结是，解决高并发请求的瓶颈，将应用程序真正处理请求的担子推送给一个处理消息的中心，以减轻应用程序本身处理请求的压力。 这个处理中心也即Rabbit ...
分类：
其他好文 时间：
2019-05-11 18:22:23
阅读次数：
142
首先Kafka是一个分布式消息队列中间件，Apache顶级项目，https://kafka.apache.org/ 高性能、持久化、多副本备份、横向扩展。 生产者Producer往队列里发送消息，消费者Consumer从队列里消费消息，然后进行业务逻辑。应用场景主要有：解耦、削峰（缓冲）、异步处理、 ...
分类：
其他好文 时间：
2019-05-04 16:16:53
阅读次数：
217
1，消息队列解决什么问题 异步处理 应用解耦 流量消峰(高并发、 秒杀) 日志处理...... 2，virtual host 相当于mysql数据库的db，一般以/开头 授权 3，使用java开发rabbitMQ (1) 简单队列 p:消息生产者 红色：消息队列 c：消息消费者 3个对象，生产者、消 ...
分类：
其他好文 时间：
2019-04-27 09:27:38
阅读次数：
144
pom 消费者代码: 由于注释内容都写得很详细就没有单独写文字了.运行之后可以发掘管控台中消息没有了, 在正式开发中不会使用这种原生得代码去使用,会采用springboot去整合相关内容,至于以上代码为什么还要去监听队列,防止如果队列不存在,程序会存在异常,所以这样,在正式开发中 会采用手动会签得方 ...
分类：
其他好文 时间：
2019-03-24 13:52:54
阅读次数：
144
震惊了！原来这才是kafka！ 简介 kafka是一个分布式消息队列。具有高性能、持久化、多副本备份、横向扩展能力。生产者往队列里写消息，消费者从队列里取消息进行业务逻辑。一般在架构设计中起到解耦、削峰、异步处理的作用。 kafka对外使用topic的概念，生产者往topic里写消息，消费者从读消息 ...
分类：
其他好文 时间：
2019-03-10 19:15:06
阅读次数：
154
