- 综合排序
- 最热优先
- 最新优先
- 来自专栏决胜机器学习
消息队列（一） MySQL实现消息队列
消息队列（一）MySQL实现消息队列 （原创内容，转载请注明来源，谢谢） 一、概述 消息队列（MessageQueue，通常简称MQ）是一种进程间通信或同一进程的不同线程间的通信方式，是分布式应用间交换信息的一种技术 通过消息队列，应用程序可独立地执行，它们不需要知道彼此的位置、或在继续执行前不需要等待接收程序接收此消息。 消息队列有多种实现方式，可以用关系型数据库（如Mysql）、Nosql（如redis）、现有框架（如rabbitMQ）等。 Mysql处理消息队列的场景：主要是在数据处理量大、耗时久、处理流程繁杂、处理内容多、需要持久化（入库）、业务处理要求相对不实时的场景，如发邮件、发短信、订单后续处理、操作数据记录日志等。 因此，此场景就非常适合于用Mysql解决此消息队列。
16.6K41发布于 2018-03-07 - 来自专栏曾令武的专栏
消息队列及常见消息队列介绍
； 队列高可用：队列可以在集群中的机器上进行镜像，以确保在硬件问题下还保证消息安全； 多种协议的支持：支持多种消息队列协议； 服务器端用Erlang语言编写，支持只要是你能想到的所有编程语言； 管理界面 : RabbitMQ有一个易用的用户界面，使得用户可以监控和管理消息Broker的许多方面； 跟踪机制：如果消息异常，RabbitMQ提供消息跟踪机制，使用者可以找出发生了什么； 插件机制：提供了许多插件 所以，它并不需要专门的管理员，因为它提供了简单又使用的管理特性。 缺点： 支持的客户端语言不多，目前是java及c++，其中c++不成熟； RocketMQ社区关注度及成熟度也不及前两者； 没有web管理界面，提供了一个CLI(命令行界面)管理工具带来查询、管理和诊断各种问题 ； 支持批量操作； 消费者采用Pull方式获取消息, 消息有序, 通过控制能够保证所有消息被消费且仅被消费一次; 有优秀的第三方Kafka Web管理界面Kafka-Manager； 在日志领域比较成熟
53.2K2714发布于 2017-09-29 - 来自专栏云服务器购买
消息队列-腾讯云消息队列 CKafka
腾讯云消息队列 CKafka，分布式、高吞吐量、高可扩展性的消息服务，100%兼容开源 Apache Kafka 0.9 0.10 腾讯云消息队列 CKafka点击查看详情 消息队列 CKafka 简介 消息队列 CKafka（Cloud Kafka）是一个分布式、高吞吐量、高可扩展性的消息系统，100%兼容开源 Kafka API（0.9、0.10版本）。 高可靠 消息队列 CKafka 集群性能强劲，生产性超越开源方案；此外，消息队列 CKafka 分布式的部署，集群稳定性也有很好的保障。 业务安全 不同租户间网络隔离，实例的网络访问在账户间天然隔离；支持管理流的 CAM 鉴权及数据流的 SASL 权限控制，严格控制访问权限。 统一运维监控 提供腾讯云平台整套的运维服务，包括租户隔离、权限控制、消息堆积查询、消费者详情查看等多维度监控告警等运维服务。
7.7K60发布于 2019-08-06 - 来自专栏java思维导图
消息队列探秘 – RabbitMQ 消息队列介绍
Broker： 简单来说就是消息队列服务器实体。 Exchange： 消息交换机，它指定消息按什么规则，路由到哪个队列。 Queue： 消息队列载体，每个消息都会被投入到一个或多个队列。 Routing Key： 路由关键字，exchange根据这个关键字进行消息投递。 vhost： 虚拟主机，一个broker里可以开设多个vhost，用作不同用户的权限分离。 producer： 消息生产者，就是投递消息的程序。 consumer： 消息消费者，就是接受消息的程序。 Queue Queue（队列）是RabbitMQ的内部对象，用于存储消息，用下图表示。 queue ? 但依然解决不了小概率丢失事件的发生（比如RabbitMQ服务器已经接收到生产者的消息，但还没来得及持久化该消息时RabbitMQ服务器就断电了），如果我们需要对这种小概率事件也要管理起来，那么我们要用到事务
4.8K20发布于 2019-11-05 - 来自专栏互联网技术栈
消息队列探秘-RabbitMQ消息队列介绍
---- Broker： 简单来说就是消息队列服务器实体。 Exchange： 消息交换机，它指定消息按什么规则，路由到哪个队列。 Queue： 消息队列载体，每个消息都会被投入到一个或多个队列。 Routing Key： 路由关键字，exchange根据这个关键字进行消息投递。 vhost： 虚拟主机，一个broker里可以开设多个vhost，用作不同用户的权限分离。 producer： 消息生产者，就是投递消息的程序。 consumer： 消息消费者，就是接受消息的程序。 Queue Queue（队列）是RabbitMQ的内部对象，用于存储消息，用下图表示。 queue ? 但依然解决不了小概率丢失事件的发生（比如RabbitMQ服务器已经接收到生产者的消息，但还没来得及持久化该消息时RabbitMQ服务器就断电了），如果我们需要对这种小概率事件也要管理起来，那么我们要用到事务
4.3K30发布于 2018-12-12 消息队列
为了能够完成消息的可靠传输，一般情况下，使用队列的方式进行消息管理，也就是说，能常在进行数据传输时，将数据按照用户定义的大小，拆分成若干消息放入消息队列，按照同步或异步的通信方式发送或者接收消息。 专用队列只能由知道队列的完整路径名或标签的应用程序访问。 3)“管理队列”包含确认在给定“消息队列”网络中发送的消息回执的消息。制定希望MessageQueue组件使用的管理队列。 3)“专用系统队列”是一系列存储系统治性消息处理操作所需的管理和通知消息的专用队列。 消息中间件在以后的开发中，将会向传输的消息大小和容量不受限制的方向发展。 q QMgrName -q是指创建缺省的队列管理器 删除队列管理器 dltmqm QmgrName 启动队列管理器 strmqm QmgrName QmgrName 如果队列是默认队列管理器中的队列，可以不带其队列管理器的名字 从队列中取出消息 amqsget QName QmgrName 如果队列是默认队列管理器中的队列
40810编辑于 2025-08-29消息队列
什么是消息队列？消息队列是一种异步通信（Asynchronous Communication）的服务或组件。 它充当了消息的中介：发送方（生产者，Producer）将消息发送到队列中，接收方（消费者，Consumer）从队列中获取并处理消息。 核心特点是解耦：生产者和消费者不需要知道彼此的存在，它们只与消息队列交互。消息队列是解决高并发问题的关键技术之一。2.解决了什么问题？ 消息队列主要解决了分布式系统中的三大核心问题：解耦（Decoupling）：问题：系统间存在强依赖关系。解决：将消息的发送和接收分离开。 2.Broker 真正的 “消息存储 & 转发节点”：存储生产者发送的消息，给消费者提供消息读取；管理 Topic（消息主题）、Queue（消息队列）等元数据。
48010编辑于 2025-11-11- 来自专栏晨曦破晓の家
消息队列
啥是消息队列 一般来说，消息队列是一种异步的服务间通信方式，是分布式系统中重要的组件，主要解决应用耦合，异步消息，流量削锋等问题，实现高性能，高可用，可伸缩和最终一致性架构。 通过使用消息队列，我们可以异步处理请求，从而缓解系统的压力。 消息队列有哪些 Kafka RocketMQ RabbitMQ pulsar activeMQ verneMQ 一个大型的分布式系统，通常都会异步化，走消息总线。 消息队列作为最主要的基础组件，在整个体系架构中，有着及其重要的作用。异步通常意味着编程模型的改变，时效性会降低。 kafka是目前最常用的消息队列，尤其是在大数据方面，有着极高的吞吐量。 而rocketmq和rabbitmq，都是电信级别的消息队列，在业务上用的比较多。相比较而言，ActiveMQ使用的最少，属于较老一代的消息框架。
4.7K30发布于 2020-09-11 消息队列
消息队列 前言： 说实话，最近还是比较忙的，手上素材倒是一大把，但是大多只是初步整理了。但是博客这种东西还是要写的，果然后面还是要放低一下排版要求（扩展性的一些东西也少提一些）。 简介： 消息队列这个东西，其实网上的资料还是很多的。我就简单说一些自己的认识与源代码哈。 演变： 我是很喜欢了解技术演进的，因为演进的过程展现了前辈们的智慧。 最早的程序串行执行就不说了。 当然了，在本篇中，只简单谈一下异步通信的主流实现-消息队列。 选择： 选择方面，我就不多说了，目前只用过RabbitMq,RocketMq,Kafka。 网上有关消息队列选择的文章很多，很细致，我就不赘述了。 代码实现： 这里贴出来的都是实际生产代码（如果内部版本也算的话，嘿嘿），所以如果有一些不是很熟悉的类，请查看import，是否是项目自身的类。 virtual-host: "/" connection-timeout: 15000 小结： 这里不得不赞一下Spring，它通过提供RabbitMq地封装API-ampq，极大地简化了消息队列的代码
26110编辑于 2025-08-26消息队列
二、使用场景异步处理发送者将消息发送给消息队列之后，不需要同步等待消息接收者处理完毕，而是立即返回进行其它操作。消息接收者从消息队列中订阅消息之后异步处理。 例如在注册流程中通常需要发送验证邮件来确保注册用户身份的合法性，可以使用消息队列使发送验证邮件的操作异步处理，用户在填写完注册信息之后就可以完成注册，而将发送验证邮件这一消息发送到消息队列中。 可以将请求发送到消息队列中，服务器按照其处理能力从消息队列中订阅消息进行处理。 通过使用消息队列，一个模块只需要向消息队列中发送消息，其它模块可以选择性地从消息队列中订阅消息从而完成调用。三、可靠性发送端的可靠性发送端完成操作后一定能将消息成功发送到消息队列中。 事务提交成功后，将消息表中的消息转移到消息队列中，若转移消息成功则删除消息表中的数据，否则继续重传。接收端的可靠性接收端能够从消息队列成功消费一次消息。
1.2K30编辑于 2024-05-15- 来自专栏全栈程序员必看
消息队列
消息队列 一、消息模型 点对点 消息生产者向消息队列中发送了一个消息之后，只能被一个消费者消费一次。 发布/订阅 消息生产者向频道发送一个消息之后，多个消费者可以从该频道订阅到这条消息并消费。 二、使用场景 异步处理 发送者将消息发送给消息队列之后，不需要同步等待消息接收者处理完毕，而是立即返回进行其它操作。消息接收者从消息队列中订阅消息之后异步处理。 可以将请求发送到消息队列中，服务器按照其处理能力从消息队列中订阅消息进行处理。 通过使用消息队列，一个模块只需要向消息队列中发送消息，其它模块可以选择性地从消息队列中订阅消息从而完成调用。 三、可靠性 发送端的可靠性 发送端完成操作后一定能将消息成功发送到消息队列中。 事务提交成功后，将消息表中的消息转移到消息队列中，若转移消息成功则删除消息表中的数据，否则继续重传。 接收端的可靠性 接收端能够从消息队列成功消费一次消息。
4.2K20发布于 2021-04-07 - 来自专栏Owen's World
消息队列
为什么使用消息队列 其实就是问问你消息队列都有哪些使用场景，然后你项目里具体是什么场景，说说你在这个场景里用消息队列是什么？ 先说一下消息队列常见的使用场景吧，其实场景有很多，但是比较核心的有 3 个：解耦、异步、削峰。 解耦 看这么个场景。A 系统发送数据到 BCD 三个系统，通过接口调用发送。 所以说，只要高峰期一过，A 系统就会快速将积压的消息给解决掉。 消息队列有什么优缺点 优点上面已经说了，就是在特殊场景下有其对应的好处，解耦、异步、削峰。 如何保证消息队列的高可用，可以点击这里查看。 系统复杂度提高 硬生生加个 MQ 进来，你怎么保证消息没有重复消费？怎么处理消息丢失的情况？怎么保证消息传递的顺序性？ 所以消息队列实际是一种非常复杂的架构，你引入它有很多好处，但是也得针对它带来的坏处做各种额外的技术方案和架构来规避掉，做好之后，你会发现，妈呀，系统复杂度提升了一个数量级，也许是复杂了 10 倍。
3.1K40编辑于 2021-12-08 - 来自专栏springBoot3.0
消息队列
关于消息队列 ???? 文章简介：Kafka ???? 创作目的：消息队列 ☀️ 今日天气：天气很好 ???? 每日一言：“所行皆坦途 所求皆如愿。” ---- kafka常用于构建TB级别的异步消息系统 首先谈到对于框架的含义 : Java 框架由一系列可重用的预编写代码组成，它们起着模板的作用，开发人员可以根据需要通过填充自定义代码来创建应用。 Java 框架中可以包含预定义类（例如对象类别）和函数，用于处理、输入和管理硬件设备，以及与系统软件进行交互。 在我们不使用Kafka的情况下，我们也能通过Java自带的API：BlockingQueue解决阻塞队列、实现消息系统或解决类似的问题、 ! ArrayBlockingQueue基于数组实现的阻塞队列，创建队列时需指定容量大小，是有界队列。
3.8K20编辑于 2023-03-06 - 来自专栏技术换美食换不换
消息队列
实时性要求不高，比较耗时的任务，可以考虑消息队列，如激活邮件，图像处理。 应用场景 应用耦合：多应用对于同一消息处理 异步处理：应用建并发处理消息 流量削锋 消息驱动系统：log 消息通讯：订阅同一主题，实现点对点通信 成熟MQ特点 RabbitMQ: 不支持消息批量处理，多 client无序，不支持事务 Kafka：只支持pull，不支持push，不支持事务 RockerMQ：最高单机吞吐量，但ali只有java客户端 ZeroMQ：“史上最快消息队列” 功能队列 优先级队列 延迟队列：30分钟未付款 死信队列：回退队列，充实队列
3.6K20发布于 2018-08-28 - 来自专栏芋道源码1024
【消息队列 MQ 专栏】消息队列之 ActiveMQ
ActiveMQ 实现了 JMS 1.1 并提供了很多附加的特性，比如 JMX 管理、主从管理、消息组通信、消息优先级、延迟接收消息、虚拟接收者、消息持久化、消息队列监控等等。 消息传送模型 点对点模型（Point to Point）使用队列（Queue）作为消息通信载体，满足生产者与消费者模式，一条消息只能被一个消费者使用，未被消费的消息在队列中保留直到被消费或超时。 Queue，队列，点对点模式下特定生产者向特定队列发送消息，消费者订阅特定队列接收消息并进行业务逻辑处理。 ; } } } 队列消息监听器在收到消息时校验是否是文本消息类型，是的话则打印出内容。 接收到文本消息 队列监听器监听到了一条消息，两个主题监听器分别监听到了两条消息。
7.7K10发布于 2018-07-31 - 来自专栏芋道源码1024
【消息队列 MQ 专栏】消息队列之 Kafka
即使在非常廉价的商用机器上也能做到单机支持每秒 100K 条消息的传输。 2. 消息持久化 将消息持久化到磁盘，因此可用于批量消费，例如 ETL 以及实时应用程序。 分布式 支持 Server 间的消息分区及分布式消费，同时保证每个 partition 内的消息顺序传输。 Partition Topic 物理上的分组，一个 Topic 可以分为多个 Partition ，每个 Partition 是一个有序的队列。 Partition 中的每条消息都会被分配一个有序的 id（offset） 4. Producer 消息和数据的生产者，可以理解为往 Kafka 发消息的客户端 5. Consumer 消息和数据的消费者，可以理解为从 Kafka 取消息的客户端 6.
4.8K00发布于 2018-07-31 - 来自专栏芋道源码1024
【消息队列 MQ 专栏】消息队列之 RocketMQ
它还存储与消息相关的元数据，包括用户组、消费进度偏移量、队列信息等。 消息队列 消息队列（Message Queue），主题被划分为一个或多个子主题，即消息队列。 一个 Topic 下可以设置多个消息队列，发送消息时执行该消息的 Topic ，RocketMQ 会轮询该 Topic 下的所有队列将消息发出去。下图 Broker 内部消息情况： ? 顺序消费表示消息消费的顺序同生产者为每个消息队列发送的顺序一致，所以如果正在处理全局顺序是强制性的场景，需要确保使用的主题只有一个消息队列。 目前在 Spring 框架中集成 RocketMQ 有三种方式，一是将消息生产者和消费者定义成 bean 对象交由 Spring 容器管理，二是使用 RocketMQ 社区的外部项目 rocketmq-jms
7.6K00发布于 2018-07-31 - 来自专栏乐行僧的博客
进程通信（二）消息队列（System V 消息队列）
一、System V 消息队列简介 消息队列：消息队列的本质是由Linux内核创建用于存放消息的链表，并且其功能是用来存放消息的，所以又称之为消息队列。 在Linux的不同进程中，包括有血缘的进程和无血缘的进程，都可以通过Linux消息队列API所得到的消息队列唯一标识符对消息队列进行操作。 二、分析消息队列的数据结构 Linux为了维护消息队列，为消息队列创建了数据结构，接下来我们来分析一下消息队列的结构以及消息队列节点的结构。 消息队列的结构: struct msqid_ds { struct ipc_perm msg_perm; //消息队列的读写权限和所有者 struct msg *msg_first; //指向消息队列链表中的第一个节点 ; //读写权限 unsigned short seq; //序列号，保证消息队列ID不会被 }; 由上边的几个关于消息队列的结构体，我们可以大致画出消息队列的样子：
3.3K20编辑于 2022-02-24 - 来自专栏月梦·剑心的技术专栏
认识消息队列
消息队列简介 消息队列，英文名：Message Queue，经常缩写为MQ。从字面上来理解，消息队列是一种用来存储消息的队列。可以简单理解消息队列就是将需要传输的数据存放在队列中。 消息队列–用于存放消息的组件 程序员可以将消息放入到队列中，也可以从消息队列中获取消息 很多消息队列不是一个永久性的存储，是作为临时存储存在的（设定一个期限：设置消息在MQ中保存10天） 本质是个队列， 但这个队列需要支持高吞吐、高并发、并且高可用 消息队列中间件 消息队列中间件就是用来存储消息的软件(组件)。 ，会导致另一个也不好工作，这时候引入消息队列，一个组件只需要把消息放在MQ中，另一个组件取消息即可。 流量消峰 在服务器和数据库之间放一个消息队列，用消息队列的大吞吐量，快速处理用户请求。
70620编辑于 2023-08-31 - 来自专栏CNCF
Kubernetes消息队列
用于容器的无缝管理；它提供了高可伸缩性并增强了通信/消息传递。它还允许在构建微服务时添加许多应用程序。这意味着随着项目的扩展，企业可以轻松地做出很多改变。 为了解决微服务体系结构和Kubernetes中的问题，必须部署消息队列系统进行有效管理。消息传递队列系统重新构建堆栈并部署单个通信焦点以实现更好的通信。这确保每个服务都用自己的语言与消息队列代理通信。 然后，消息队列系统将消息传递给等待它的服务。 构建管理良好的消息传递解决方案 如果消息传递系统不是Kubernetes原生的，那么它就不可能有效。 要使混合云有效、透明、无缝连接和交互，消息队列必须部署在Kubernetes中。 用例 消息队列支持多样化的消息传递模式；它确保了灵活性，并可以创建广泛的用例。 它通过采用死信队列机制来实现这一点，死信队列机制接受未处理的消息并以预定义的方式处理它。在一个多阶段的流水线系统中，每个服务被认为是一个单独的阶段，消息在序列中的所有阶段之间传递。
2.2K10发布于 2020-02-20
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号