MQ全称为Message Queue, 消息队列（MQ）是应用程序“对”应用程序的通信方法。MQ：生产者者往消息队列中写消息，消费可以读取队列中的消息。 MQ的好处有很多： 好处一：解耦 在项目启动之初来预测将来项目会碰到什么需求，是极其困难的。消息系统在处理过程中间插入了一个隐含的、基于数据的接口 ...
分类：
其他好文 时间：
2020-01-02 22:52:30
阅读次数：
147
概要 消息队列的概念,原理和场景 解耦案例: 队列处理订单系统和配送系统 流量削峰案例: Redis的List类型实现秒杀 RabbitMQ: 更专业的消息系统实现方案 一.消息队列 消息队列概念 队列结构中间件 消息放入后,不需要立即处理 由订阅者/消费者按顺序处理 核心结构 业务系统--入队-- ...
分类：
Web程序 时间：
2019-12-23 13:30:06
阅读次数：
97
9.1 Kafka 基础知识 9.1.1 消息系统 点对点消息系统：生产者发送一条消息到queue，一个queue可以有很多消费者，但是一个消息只能被一个消费者接受，当没有消费者可用时，这个消息会被保存直到有 一个可用的消费者，所以Queue实现了一个可靠的负载均衡。 发布订阅消息系统：发布者发送到 ...
分类：
其他好文 时间：
2019-12-21 22:55:47
阅读次数：
90
nats的消息传递模型 @[toc] What is NATS nats是一个go语言开发的开源的、轻量、高性能的原生消息系统。nats消息由主题处理，不依赖于网络位置。它提供了应用程序或服务与底层物理网络之间的抽象层。数据被编码并作为消息，由发布者发送。消息由一个或多个订阅者接收、解码和处理。 N ...
分类：
其他好文 时间：
2019-12-16 00:05:38
阅读次数：
148
一、Kafka简介 Kafka是一种高吞吐量的分布式发布订阅消息系统，用户通过Kafka系统可以发布大量的消息，同时也能实时订阅消费消息。Kafka可以同时满足在线实时处理和批量离线处理。 在公司的大数据生态系统中，可以把Kafka作为数据交换枢纽，不同类型的分布式系统（关系数据库、NoSQL数据库 ...
分类：
其他好文 时间：
2019-12-12 13:28:15
阅读次数：
155
前言Kafka是最初由Linkedin公司开发，是一个分布式、支持分区的（partition）、多副本的（replica），基于zookeeper协调的分布式消息系统，它的最大的特性就是可以实时的处理大量数据以满足各种需求场景：比如基于hadoop的批处理系统、低延迟的实时系统、storm/Spark流式处理引擎，web/nginx日志、访问日志，消息服务等等，用scala语言编写，Linkedi
分类：
其他好文 时间：
2019-12-09 18:50:02
阅读次数：
101
在很多互联网应用系统中，请求处理异步化是提升系统性能一种常用的手段，而基于消息系统的异步处理由于具备高可靠性、高吞吐量的特点，因而在并发请求量比较高的互联网系统中被广泛应用。与此同时，这种方案也带来了调用链路处理上的问题，因为大部分应用请求都会要求同步响应实时处理结果，而由于请求的处理过程已经通过消息异步解耦，所以整个调用链路就变成了异步链路，此时请求链路的发起者如何同步拿到响应结果，就需要进行额外的系统设计考虑。
分类：
其他好文 时间：
2019-12-04 18:41:32
阅读次数：
116
分布式开放消息系统(RocketMQ)的原理与实践 RocketMQ基础：https://github.com/apache/rocketmq/tree/rocketmq-all-4.5.1/docs/cn 分布式消息系统作为实现分布式系统可扩展、可伸缩性的关键组件，需要具有高吞吐量、高可用等特点。 ...
分类：
其他好文 时间：
2019-12-02 17:13:07
阅读次数：
131
点对点（Point-to-Point）。在点对点的消息系统中，消息分发给一个单独的使用者。点对点消息往往与队列（javax.jms.Queue）相关联。 有两种消费形式,我们此次只介绍listener模式(代码冗长,后期的util需自己封装) 实时监听,消费者监听生产者的生产状态 定时刷新 reci ...
分类：
其他好文 时间：
2019-11-27 16:22:02
阅读次数：
85
一、kafka介绍及原理kafka是由Apache软件基金会发布的一个开源流处理平台，由Scala和Java编写。它是一种高吞吐量的分布式发布的订阅消息系统，它可以处理消费者规模的网站中的所有动作流数据。这种动作（网页浏览，搜索和其他用户的行动）是在现代网络上的许多社会功能的一个关键因素。这些数据通常是由于吞吐量的要求而通过处理日志和日志聚合来解决。对于像Hadoop一样的日志数据和离线分析系统，
分类：
其他好文 时间：
2019-11-26 09:35:53
阅读次数：
66
