- 综合排序
- 最热优先
- 最新优先
- 来自专栏userlyz学习记录
消息中间件
消息中间件 RabbitMq ActiveMQ RocketMQ kafka 安装RabbitMQ (33条消息) RabbitMQ安装教程（超详细）_凡尘-追梦者的博客-CSDN博客 为什么要使用消息队列 为什么使用消息队列？ ："+msg); } } 测试 direct模式 路由模式 生产者将消息发送到direct交换器，在绑定队列和交换器的时候有一个路由key，生产者发送的消息会指定一个路由key，那么消息只会发送到相应 也就是让消费者有选择性的接收消息。 路由模式，是以路由规则为导向，引导消息存入符合规则的队列中。再由队列的消费者进行消费的。 ("发消息喽03"); mqSender.send04("发消息喽04"); } 发现再不同时发送的时候，两个接受队列都可以接收到消息04; 但是为什么在同一个方法中，两个接受队列不能同时接受消息
76530编辑于 2023-10-18 - 来自专栏二进制文集
消息中间件
消息中间件的应用场景 主流 MQ 框架及对比 说明 Kafka 优点 Kafka 缺点 RocketMQ Pulsar 发展趋势 各公司发展 Kafka Kafka 是什么？ [2021-01-24-092401.png] 消息中间件的应用场景 异步解耦 削峰填谷 顺序收发 分布式事务一致性 腾讯应用案例： [2021-01-24-093404.png] 主流 MQ 框架及对比 开源的消息引擎系统（消息队列/消息中间件） 分布式流处理平台 发布/订阅模型 削峰填谷 Kafka 术语 Topic：发布订阅的主题 Producer：向Topic发布消息的客户端 Consumer：消费者 为了保证最终一致，消息系统和业务程序需要保证： 消息发送的一致性：消息发送时，一阶段事务和消息发送必须同时成功或失败 消息存储不丢失：消息发送成功后，到消息被成功消费前，消息服务器（broker）必须存储好消息 ，保证发生故障时，消息不丢失 消费者不丢失消息：处理失败不丢弃，重试直到成功为止 消息发送的一致性如何保证？
1.4K41发布于 2021-01-26 - 来自专栏匠心独运的博客
消息中间件—RocketMQ消息发送
因此，本篇主要从一条消息发送为切入点，详细阐述在RocketMQ这款分布式消息队列中发送一条普通消息的大致流程和细节。 在阅读本篇之前希望读者能够先仔细读下关于RocketMQ分布式消息队列Remoting通信模块的两篇文章： （1）消息中间件—RocketMQ的RPC通信（一） （2）消息中间件—RocketMQ的 （2）Broker（Master）：RocketMQ消息代理服务器主节点，起到串联Producer的消息发送和Consumer的消息消费，和将消息的落盘存储的作用； （3）Broker（Slave）： RocketMQ消息代理服务器备份节点，主要是通过同步/异步的方式将主节点的消息同步过来进行备份，为RocketMQ集群的高可用性提供保障； （4）Producer（消息生产者）：在这里为普通消息的生产者 从上面一节中可以看出，消息生产者发送消息的demo代码还是较为简单的，核心就几行代码，但在深入研读RocketMQ的Client模块后，发现其发送消息的核心流程还是有一些复杂的。
3.1K30发布于 2018-09-05 - 来自专栏Pixel Fandom
消息中间件 Kafka
简介 消息中间件利用高效可靠的消息传递机制进行平台无关的数据交流，并基于数据通信来进行分布式系统的集成。通过提供消息传递和消息排队模型，它可以在分布式环境下扩展进程间的通信。 常用消息中间件对比 特性 ActiveMQ RabbitMQ RocketMQ Kafka 开发语言 java erlang java scala 单机吞吐量 万级 万级 10万级 10万级 时效性 ms 选择建议 消息中间件 建议 Kafka 追求高吞吐量，适合产生大量数据的互联网服务的数据收集业务 RocketMQ 可靠性要求很高的金融互联网领域,稳定性高，经历了多次阿里双11考验 RabbitMQ Kafka Kafka 是一个分布式流媒体平台，类似于消息队列或企业消息传递系统。 Kafka 将消息分门别类，每一类的消息称之为一个主题（Topic） -- consumer：订阅消息并处理发布的消息的对象称之为主题消费者（consumers） -- broker：已发布的消息保存在一组服务器中
1.3K40编辑于 2023-03-04 - 来自专栏IT技术订阅
消息中间件-RabbitMQ
，由Erlang（专门针对于大数据高并发的语言）语言开发，可复用的企业消息系统，是当前最主流的消息中间件之一，具有可靠性、灵活的路由、消息集群简单、队列高可用、多种协议的支持、管理界面、跟踪机制以及插件机制 2.什么是消息和队列 1.消息 就是数据，增删改查的数据。 例如在员工管理系统中增删改查的数据 2.队列 指的是一端进数据一端出数据，例如C#中(Queue数据结构） 3.什么是消息队列 1.消息队列指：一端进消息，一端出消息 2.RabbitMQ就是实现了消息队列概念的一个组件 .集群 3.消息消费端 1.消费者宕机，导致消息丢失 2.执行业务逻辑失败，但是消息已经被消费 当生产者写入消息到RabbitMQ后，消费服务接收消息期间，服务器宕机,导致消息丢失了，这个时候我们就应该使用 生产者发送高并发消息，消费者来不及处理，导致消息堆积，如何解决消息堆积问题？
87810编辑于 2022-06-23 - 来自专栏用户8506532的专栏
消息中间件RabbitMQ
消息中间件RabbitMQ 1.什么是消息中间件 MQ全称为Message Queue，消息队列是应用程序和应用程序之间的通信方法。 为什么使用MQ？ 但是因为消息积压，在高峰期过后的一段时间内，消费消息的速度还是会维持在1000QPS，直到消费完积压的消息,这就叫做**“填谷”** 3. 3.2 JMS JMS 即Java消息服务（JavaMessage Service）应用程序接口，是一个Java平台中关于面向消息中间件（MOM）的API，用于在两个应用程序之间，或分布式系统中发送消息 JMS 规定了两种消息模式； AMQP的消息模式更加丰富 4.多种消息中间件 常见的消息队列有如下： ActiveMQ：基于 JMS ZeroMQ：基于 C 语言开发 RabbitMQ：基于 AMQP Message Queue 高级消息队列协议）协议实现的消息队列，它是一种应用程序之间的通信方法，消息队列在分布式系统开发中应用非常广泛。
75720编辑于 2021-12-06 - 来自专栏转行程序员
扫盲消息队列 | 消息中间件 | Kafka
大型分布式系统建设中，消息队列主要解决应用耦合、异步消息、流量削锋等问题。实现高性能、高可用、可伸缩和最终一致性架构。是大型分布式系统不可缺少的中间件。 消息发布者只管把消息发布到 MQ 中而不用管谁来取，消息使用者只管从 MQ 中取消息而不管是谁发布的。这样发布者和使用者都不用知道对方的存在。 [2]拥有权限的进程可以向消息队列中写入或读取消息。 IBM MQ：它是一个消息传递中间件，可以简化和加速跨多个平台的不同应用程序和业务数据的集成。它提供了经过验证的企业级消息传递功能，能够熟练而安全地移动信息。 消息队列有什么优点和缺点？ 那为什么Kafka的吞吐量远高于其他同类中间件？ 比较重要的关键字吗？比如Producer，Consumer，Partition，Broker，你都是怎么理解的？
2.2K11发布于 2020-04-26 - 来自专栏Cyylog技术
RabbitMQ消息中间件
RabbitMQ 消息中间件 1、消息中间件 1、简介 消息中间件也可以称消息队列，是指用高效可靠的消息传递机制进行与平台无关的数据交流，并基于数据通信来进行分布式系统的集成。 通过提供消息传递和消息队列模型，可以在分布式环境下扩展进程的通信。 当下主流的消息中间件有RabbitMQ、Kafka、ActiveMQ、RocketMQ等。 2、作用 1、消息中间件主要作用 解耦 冗余(存储) 扩展性 削峰 可恢复性 顺序保证 缓冲 异步通信 2、消息中间件的两种模式 1、P2P模式 P2P模式包含三个角色：消息队列（Queue）、发送者( ,是应用层协议的一个开放标准,为面向消息的中间件设计。 基于此协议的客户端与消息中间件可传递消息，并不受客户端/中间件不同产品，不同的开发语言等条件的限制。 4、什么和是消息队列 MQ 全称为Message Queue, 消息队列。
1.3K30发布于 2020-08-19 - 来自专栏软件工程
消息中间件RabbitMQ
它是应用层协议的一个开放标准，为面向消息的中间件设计，基于此协议的客户端与消息中间件可传递消息，并不受产品、开发语言等条件的限制。 Producer： 消息生产者，如图A、B、C，数据的发送方。 消息生产者连接RabbitMQ服务器然后将消息投递到Exchange。 Consumer：消息消费者，如图1、2、3，数据的接收方。 消息消费者订阅队列，RabbitMQ将Queue中的消息发送到消息消费者。 消息消费者就是通过订阅队列来获取消息的，RabbitMQ中的消息都只能存储在Queue中 生产者生产消息并最终投递到Queue中消费者可以从Queue中获取消息并消费。 VirtualHost：权限控制的基本单位 一个VirtualHost里面有若干Exchange和MessageQueue，以及指定被哪些user使用 我来一句话总结下我理解消息中间件 类似于厨师做完菜只管把菜送给服务员就可以忙自己的事了
57320编辑于 2022-05-13 - 来自专栏方法论
消息中间件简介
通过提供消息传递和消息排队模型,它可以在分布式环境下扩展进程间的通信。 消息队列中间件,也可以称为消息队列或者消息中间件。 图1-1 应用通过消息中间件进行通讯 消息中间件将消息路由给应用程序B,这样消息就可存在于完全不同的计算机上。 消息中间件负责处理网络通信,如果网络连接不可用,消息中间件会存储消息,直到连接变得可用,再将消息转发给应用程序B.灵活性的另一方面体现在,当应用程序A发送其消息时,应用程序B甚至可以处于不运行状态,消息中间件将保留这份消息 消息中间件的作用 消息中间件凭借其独到的特性,在不同的应用场景下可以展现不同的作用。总的来说,消息中间件的作用可以概括如下。 解耦:在项目启动之初来预测将来会碰到什么需求是极其困难的。 消息中间件降低了进程闻的耦合度,所以即使一个处理消息的进程挂掉,加入消息中间件中的消息仍然可以在系统恢复后进行处理。
1.4K30发布于 2020-04-14 - 来自专栏Chasays
消息中间件-MQ
中间件是什么 中间件是计算机软件，它为操作系统以外的软件应用程序提供服务。它可以被描述为“软件粘合剂”。 中间件使软件开发人员更容易实现通信和输入/输出，因此他们可以专注于应用程序的特定用途。 在这种更具体的意义上，中间件可以描述为客户机-服务器中的破折号(“-”) ，或者对等网络中的对等网络。中间件包括 web 服务器、应用服务器、内容管理系统以及支持应用程序开发和交付的类似工具。 数据库访问服务通常被描述为中间件。其中一些是特定于语言的实现，并支持异构特性和其他相关的通信特性。面向数据库中间件的例子包括 ODBC、 JDBC 和事务处理监视器。 消息中间件 MQ 消息队列已经逐渐成为企业IT系统内部通信的核心手段。它具有低耦合、可靠投递、广播、流量控制、最终一致性等一系列功能，成为异步RPC的主要手段之一。 当今市面上有很多主流的消息中间件，如老牌的ActiveMQ、RabbitMQ，炙手可热的Kafka，阿里巴巴自主开发RocketMQ等。
1.3K20编辑于 2021-12-06 - 来自专栏匠心独运的博客
消息中间件—RocketMQ消息消费（一）
在阅读本篇之前希望读者能够先仔细阅读下关于RocketMQ分布式消息队列的前几篇文章： （1）消息中间件—RocketMQ的RPC通信（一） （2）消息中间件—RocketMQ的RPC通信（二） （3）消息中间件—RocketMQ消息发送 一、如何选择消息消费的方式—Pull or Push？ 1.1 MQ中Pull和Push的两种消费方式 对于任何一款消息中间件而言，消费者客户端一般有两种方式从消息中间件获取消息并消费： （1）Push方式：由消息中间件（MQ消息服务器代理）主动地将消息推送给消费者 概括起来地说就是“慢消费问题”)，而MQ不断地向消费者Push消息，消费者端的缓冲区可能会溢出，导致异常； （2）Pull方式：由消费者客户端主动向消息中间件（MQ消息服务器代理）拉取消息；采用Pull 方式，如何设置Pull消息的频率需要重点去考虑，举个例子来说，可能1分钟内连续来了1000条消息，然后2小时内没有新消息产生（概括起来说就是“消息延迟与忙等待”）。
2.2K30发布于 2018-09-05 - 来自专栏Java架构师必看
消息中间件选型
消息中间件选型 常用的 MQ组件有 Kafka、RabbitMQ、RocketMQ、ActiveMQ、ZeroMQ、MetaMQ。 并发能力很强，性能及其好，延迟极低，管理界面丰富 MQ功能比较完备，扩展性强 成熟的产品，在很多公司得到应用，有很多成熟的文档，支持各种协议 一、中间件选型 ---- Kafka Kafka 是 LinkedIn 号称大数据的杀手锏，谈到大数据领域内的消息传输，则绕不开Kafka，这款为大数据而生的消息中间件，以其百万级TPS（单机写入TPS约在百万条/秒**）**的吞吐量名声大噪，迅速成为大数据领域的宠儿，在数据采集 RocketMQ RocketMQ是阿里开源的消息中间件，它是纯 Java开发，具有高吞吐量、高可用性、适合大规模分布式系统应用的特点。 在同步发送场景中，三个消息中间件的表现区分明显： Kafka Kafka 的吞吐量高达17.3w/s，是高吞吐量消息中间件的行业老大。这主要取决于它的队列模式保证了写磁盘的过程是线性IO。
2.3K20发布于 2021-04-25 - 来自专栏匠心独运的博客
消息中间件—RocketMQ消息消费（三）（消息消费重试）
这里先回顾往期RocketMQ技术分享的篇幅： （1）消息中间件—RocketMQ的RPC通信（一） （2）消息中间件—RocketMQ的RPC通信（二） （3）消息中间件—RocketMQ消息发送 （4）消息中间件—RocketMQ消息消费（一） （5）消息中间件—RocketMQ消息消费（二）（push模式实现） 一、其他MQ中间件消费端可靠性的保障 在业务开发中，大家一定都遇到过业务工程因为各类异常 （可能是业务工程本身的异常、JVM内存异常或者系统所在的虚拟机宕机等），而导致MQ中间件发送过来的业务消息消费失败而无法再次消费该消息的情况。 目前，很多MQ消息中间件都有相应的机制和方法来保证Consumer端消费消息的可靠性。下面先来看看RabbitMQ和Kafka这两款MQ消息中间件是如何来保证消费者端消息处理的可靠性的呢？ 二、RocketMQ消费失败后的消费重试机制 对比了另外两款MQ中间件后，接下来进入正题，主要来说说RocketMQ在消费失败后的是如何来保证消息消费的可靠性？
4.4K40发布于 2018-09-05 - 来自专栏服务端思维
消息中间件选型分析
一、前言 消息队列中间件（简称消息中间件）是指利用高效可靠的消息传递机制进行与平台无关的数据交流，并基于数据通信来进行分布式系统的集成。 从某种意义上来讲，如果一个消息中间件不具备消息堆积的能力，那么就不能把它看做是一个合格的消息中间件。消息堆积分内存式堆积和磁盘式堆积。 消息中间件具备消息堆积的能力，消息堆积越大也就意味着端到端的时延也就越长，与此同时延时队列也是某些消息中间件的一大特色。那么为什么还要关注消息中间件的时延问题呢？ ---- 四、消息中间件选型误区探讨 在进行消息中间件选型之前可以先问自己一个问题：是否真的需要一个消息中间件？在搞清楚这个问题之后，还可以继续问自己一个问题：是否需要自己维护一套消息中间件？ ---- 五、总结 消息中间件大道至简：一发一存一消费，没有最好的消息中间件，只有最合适的消息中间件。人过留名，雁过留声，路过记得点个赞。
1.9K42发布于 2019-07-10 - 来自专栏JAVA乐园
消息中间件哪些事
一、消息中间件的产生的背景 1.在网络通讯中，Http请求默认采用同步请求方式，基于请求与响应模式 2.在客户端与服务器进行通讯时，客户端调用服务端接口后，必须等待服务端完成处理后返回结果给客户端才能继续执行 二、什么是消息中间件 消息队列中间件是分布式系统中重要的组件，主要解决应用解耦，异步消息，流量削锋等问题，实现高性能，高可用，可伸缩和最终一致性架构。 目前使用较多的消息队列有ActiveMQ，RabbitMQ，ZeroMQ，Kafka，MetaMQ，RocketMQ 实现方式:面向消息的中间件(MessageOrlented MiddlewareMOM 三、JMS介绍 1、什么是JMS JMS是java的消息服务器，JMS的客户端之间可以通过JMS服务进行异步的消息传输,是一个Java平台中面向消息中间件的API 角色划分 1.提供者：实现JMS 规范的消息中间件服务器 (存放消息容器) 2.客户端：发送或接收消息的应用程序 3.生产者/发布者：创建并发送消息的客户端（向消息容器存放消息） 4.消费者/订阅者：接收并处理消息的客户端
1.3K20发布于 2020-06-29 - 来自专栏田守枝的技术博客
消息中间件选型分析
消息中间件选型分析 ——从Kafka与RabbitMQ的对比来看全局 有很多网友留言：公司要做消息中间件选型，该如何选？你觉得哪个比较好？ 一、前言 消息队列中间件（简称消息中间件）是指利用高效可靠的消息传递机制进行与平台无关的数据交流，并基于数据通信来进行分布式系统的集成。 消息中间件具备消息堆积的能力，消息堆积越大也就意味着端到端的时延也就越长，与此同时延时队列也是某些消息中间件的一大特色。那么为什么还要关注消息中间件的时延问题呢？ ---- 四、消息中间件选型误区探讨 在进行消息中间件选型之前可以先问自己一个问题：是否真的需要一个消息中间件？在搞清楚这个问题之后，还可以继续问自己一个问题：是否需要自己维护一套消息中间件？ ---- 五、总结 消息中间件大道至简：一发一存一消费，没有最好的消息中间件，只有最合适的消息中间件。人过留名，雁过留声，路过记得点个赞。
1.3K10发布于 2019-05-21 - 来自专栏码猿技术专栏
消息中间件之Rabbitmq
RabbitMQ【消息中间件】 1.1. 介绍 1.2. 安装 1.3. 消息确认（SpringBoot整合） 1.6.1. confirm模式 1.6.1.1. 发送消息的确认 1.6.1.2. 消费消息的确认 1.7. 参考文章 RabbitMQ【消息中间件】 介绍 RabbitMQ是实现AMQP（高级消息队列协议）的消息中间件的一种，最初起源于金融系统，用于在分布式系统中存储转发消息，在易用性、扩展性、高可用性等方面表现不俗 AMQP，即Advanced Message Queuing Protocol，高级消息队列协议，是应用层协议的一个开放标准，为面向消息的中间件设计。 消息中间件主要用于组件之间的解耦，消息的发送者无需知道消息使用者的存在，反之亦然。AMQP的主要特征是面向消息、队列、路由（包括点对点和发布/订阅）、可靠性、安全。
1.1K30发布于 2019-12-31 - 来自专栏分布式系统进阶
消息中间件的 Style
前情提要 现如今，消息中间件已经在很多公司的业务中被广泛使用：业务解耦，消峰填谷，对接大数据，流式计算等等各种玩法层出不穷。 伴随着消息中间件的使用，你一定还听过 "消息队列"，“pub-sub”这些名词，我们今天就来聊一下这些消息中间件提供给业务的可使用的 "Style"。 概述 不管如何使用消息中间件，其实都可以归结到两个步骤：消息的产生和消费。 消息中间件作为一种消息的暂存（当前也可以持久存储）系统，解耦消息的上下游，通过自身提供的高吞吐量，稳定可靠性，分布式可扩展性等一系列特性保证消息被业务合理正确处理。 发布者push消息到消息中间件里的某个topic上，各个订阅者都会收到这个topic上的完整的消息，即每个订阅者都能看到一样的完整的topic视图，并且收到的消息的顺序和消息被push到消息中间件时的顺序是一致的
67040发布于 2020-02-18 - 来自专栏MessageQueue
消息中间件架构讨论
前言 接上一篇的《业务方对消息中间件的需求》，在可用性和可靠性的基础上，讨论各种架构的优缺点，最后给出自己关于消息中间件的架构思考。 Kafka 首先还是来看Kafka的系统架构（做消息中间件逃不开要去了解Kafka）。 ? 可靠性 在消息中间件中，可靠性主要就是写入的消息一定会被消费到，条消息不会丢失。 在分布式环境中消息不丢失有两点： 消息在成功写入一个节点后，消息会做持久化 消息会被备份到其他物理节点 只要做到上面两点就可以保证除所有节点都发生永久性故障的情况下数据不会丢失。 当然，消息丢失不一定指消息真的从磁盘上被销毁或者没被存储下来，如果消息被存储下来了，但是没办法被消费，对客户端来说也是消息丢失。
80620发布于 2018-07-24
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号