- 综合排序
- 最热优先
- 最新优先
- 来自专栏飞鸟的专栏
消息队列的异步处理
异步处理是一种常见的编程模式，用于处理需要较长时间完成的操作，如网络请求、文件读写或复杂的计算任务。在异步处理中，操作被提交到消息队列中，然后程序可以继续执行其他任务，而不必等待操作完成。 消息队列是一种中间件，用于在不同的组件或系统之间传递消息。它提供了一种可靠的机制来存储和传递消息，并确保消息的顺序性和可靠性。在异步处理中，消息队列充当了一个缓冲区，用于存储待处理的任务。 异步处理的一般工作流程：发送消息：将需要异步处理的任务或请求封装成消息，并发送到消息队列。消息包含了任务的相关信息和参数。处理消息：消息队列接收到消息后，将其存储在队列中，等待后续的处理。 为了提高网站的性能和响应速度，我们可以将这些后台处理任务放入消息队列中进行异步处理。发送消息： 用户提交订单后，网站将订单信息封装成一个消息，并发送到订单处理队列。 通过使用消息队列进行异步处理，网站可以更快地响应用户的请求，提高系统的并发性和可伸缩性，并减少服务器的负载。
2.7K20编辑于 2023-05-16 - 来自专栏码农编程进阶笔记
Redis应用-异步消息队列与延时队列
异步消息队列 说道消息队列，你肯定会想到Kafka、Rabbitmq等消息中间件，这些专业的消息中间件提供了很多功能特性，当然他的部署使用维护都是比较麻烦的。 如果你对消息队列没那么高要求，想要轻量级的，使用Redis就没错啦。 Redis通过list数据结构来实现消息队列.主要使用到如下命令： lpush和rpush入队列 lpop和rpop出队列 blpop和brpop阻塞式出队列 ? 所以我们使用sleep来解决，当没有消息的时候阻塞一段时间。但其实这样还会带来另一个问题，就是sleep会导致消息的处理延迟增加。这个问题我们可以通过blpop/brpop 来阻塞读取队列。 blpop/brpop在队列没有数据的时候，会立即进入休眠状态，一旦数据到来，则立刻醒过来。消息的延迟几乎为零。用blpop/brpop替代前面的lpop/rpop，就完美解决了上面的问题。
1K10发布于 2021-07-20 - 来自专栏全栈程序员必看
Redis应用-异步消息队列与延时队列
异步消息队列 说道消息队列，你肯定会想到Kafka、Rabbitmq等消息中间件，这些专业的消息中间件提供了很多功能特性，当然他的部署使用维护都是比较麻烦的。 如果你对消息队列没那么高要求，想要轻量级的，使用Redis就没错啦。 Redis通过list数据结构来实现消息队列.主要使用到如下命令： lpush和rpush入队列 lpop和rpop出队列 blpop和brpop阻塞式出队列 废话补不多说上代码： 所以我们使用sleep来解决，当没有消息的时候阻塞一段时间。但其实这样还会带来另一个问题，就是sleep会导致消息的处理延迟增加。这个问题我们可以通过blpop/brpop 来阻塞读取队列。 blpop/brpop在队列没有数据的时候，会立即进入休眠状态，一旦数据到来，则立刻醒过来。消息的延迟几乎为零。用blpop/brpop替代前面的lpop/rpop，就完美解决了上面的问题。
95220编辑于 2022-07-19 - 来自专栏玖叁叁
Redis 应用实践-消息队列-异步处理
Redis作为消息队列的应用场景之一是异步处理。例如，当一个Web应用程序需要处理大量的请求时，可以将请求推入消息队列，然后异步地处理请求，以避免Web应用程序的延迟。 request: # 处理请求 print('processing request:', request) else: # 队列为空
54930编辑于 2023-04-15 - 来自专栏木左侃技术人生
基于spring event实现消息异步延时队列
这不也是发个消息，然后监听者收到后进行逻辑处理。但是看了下直接发的话不做任何处理会是同步方式进行处理，而我其实需要得是异步，那就再加个注解@async。这样就达到了异步处理。 二、开搞 最终整体代码结构如下 最开始确实可以达到异步处理，但是在测试的时候发现，日志打印的时候，发送消息的日志还没打印，接收消息得日志都打印出来了，如下图。 因为消息处理本身是在线程池里处理的，有个任务队列，自己再搞一个多少有点别扭。还有一种是在监听的方法里线程sleep，这种感觉也不行。我总共开两个线程，那任务堆积不是很严重，影响处理效率。 既然@async本身就是交给了线程池处理，而我使用的是ThreadPoolTaskExecutor，这个线程池不支持延时队列，解决办法就只能是sleep，于是乎我换成了有延时队列的线程池ScheduledThreadPoolExecutor 刚要高兴，定睛一看，怎么那个tlog追踪异步不一样啊，重新试了下，还真是不一样，重启后发现是第一次创建线程的时候传入的，后续不会改了。
1K10编辑于 2024-03-26 - 来自专栏JavaEdge
消息队列面试解析系列之异步编程模式
异步模式设计可显著减少线程等待，在高吞吐量场景中，极大提升系统整体性能，降低时延。因此，像MQ这种需要超高吞吐量和超低时延中间件系统，其核心流程大量采用异步。 异步的本质是为了不占用过多的线程对象。 异步实现相比同步实现，先要定义如下回调方法： OnDebit()：扣减账户accountFrom完成后调用 OnAllDone()：转入to账户完成后调用 异步实现的语义： 异步从from账户扣减钱数， 然后调用OnDebit 在OnDebit中，异步将减去的钱数加到to账户，然后执行OnAllDone 在OnAllDone中调用OnComplete 异步的时序流程和同步实现完全一样，只是线程模型由同步调用改为异步和回调 CompletableFuture几乎涵盖异步程序所需的大部分功能，易写出优雅且易维护的异步代码。 异步实现中，回调方法 OnComplete()在执行OnAllDone()回调方法的那个线程，可通过一个异步线程池控制回调方法的线程数，如Spring中的async就是通过结合线程池来实现异步。
97240编辑于 2025-11-04 - 来自专栏学院君的专栏
基于 Redis 消息队列实现文件上传的异步存储
实战入门篇做个收尾了，不过想起来 Laravel 进阶组件部分还剩下文件存储、邮件和通知这几个功能没有介绍，不如索性一并介绍下，因为它们并不是和 Redis 风马牛不相及，我们可以将这些耗时操作通过消息队列异步处理来提升页面响应速度 不过在 Laravel 中，我们可以基于消息队列完成文件存储的异步处理：编写一个处理文件上传的任务类，当有文件上传时，将该文件的存储操作通过任务类推送到消息队列，最后通过队列处理器进程异步处理存储和其他后续操作 所以，我们可以把 Laravel 消息队列看做 PHP 不支持并发/异步编程的一种补充实现，通过消息队列来模拟多进程和异步编程实现，对于一些非常耗时的操作，甚至还可以将其分解成多个子任务，然后通过启动多个处理器进程来提升队列消费速度 接下来，学院君就来给大家演示下如何通过消息队列实现文件存储的异步处理，我们将以发布文章支持上传封面图片为例进行演示。 好了，关于文件上传和异步存储处理学院君就简单介绍到这里，下篇教程，我们来给大家演示如何通过 Redis 消息队列优化邮件和通知发送。
4.4K20发布于 2021-01-22 - 来自专栏学院君的专栏
基于 Redis 消息队列实现邮件通知的异步发送
由于发送邮件、短信之类的操作通常涉及到第三方服务的调用，所以也是个响应时间不确定的耗时操作，如果放到处理用户请求进程中同步处理，需要等待很长时间才能获取响应结果，为了提升用户体验，可以让这些操作通过消息队列异步处理 此外，和队列任务类和事件监听器类一样，我们为通知类实现了 ShouldQueue 接口，表示会将邮件通知发送操作推送到消息队列异步处理，并且通过 queue 属性设置了队列名称为 notifications ，反而是对系统资源的浪费，因为真正需要异步处理的只有邮件通知发送而已，我们不需要把简单的、能够快速处理的操作放到消息队列，因为这涉及到与 Redis 的交互、网络传输、序列化操作，这些都是需要消耗系统资源和网络传输时间的 ，如果比同步操作本身性能还要差，就没必要使用消息队列了。 至此，我们就完成了通过消息队列异步处理邮件通知的功能演示，当然了，你还以发送短信通知、数据库通知（站内通知）、广播通知等更多通信类型，详情请参考 Laravel 通知文档。
3.8K20发布于 2021-01-22 - 来自专栏决胜机器学习
消息队列（一） MySQL实现消息队列
消息队列（一）MySQL实现消息队列 （原创内容，转载请注明来源，谢谢） 一、概述 消息队列（MessageQueue，通常简称MQ）是一种进程间通信或同一进程的不同线程间的通信方式，是分布式应用间交换信息的一种技术 通过消息队列，应用程序可独立地执行，它们不需要知道彼此的位置、或在继续执行前不需要等待接收程序接收此消息。 消息队列有多种实现方式，可以用关系型数据库（如Mysql）、Nosql（如redis）、现有框架（如rabbitMQ）等。 Mysql处理消息队列的场景：主要是在数据处理量大、耗时久、处理流程繁杂、处理内容多、需要持久化（入库）、业务处理要求相对不实时的场景，如发邮件、发短信、订单后续处理、操作数据记录日志等。 因此，此场景就非常适合于用Mysql解决此消息队列。
16.6K41发布于 2018-03-07 - 来自专栏曾令武的专栏
消息队列及常见消息队列介绍
消息队列主要解决了应用耦合、异步处理、流量削锋等问题。 二、消息队列使用场景 消息队列在实际应用中包括如下四个场景： 应用耦合：多应用间通过消息队列对同一消息进行处理，避免调用接口失败导致整个过程失败； 异步处理：多应用对消息队列中同一消息进行处理，应用间并发处理消息 )负责对消息进行处理； 下面详细介绍上述四个场景以及消息队列如何在上述四个场景中使用： 2.1 异步处理 具体场景：用户为了使用某个应用，进行注册，系统需要发送注册邮件并验证短信。 主要特性： 服从 JMS 规范：JMS 规范提供了良好的标准和保证，包括：同步或异步的消息分发，一次和仅一次的消息分发，消息接收和订阅等等。 https://www.zhihu.com/question/34243607/answer/127666030 浅谈异步消息队列模型 http://www.cnblogs.com/sunkeydev
53.2K2714发布于 2017-09-29 - 来自专栏IT技术精选文摘
微信后台异步消息队列的优化升级实践分享
1、引言 MQ 异步消息队列是微信后台自研的重要组件，广泛应用在各种业务场景中，为业务提供解耦、缓冲、异步化等能力。 本文分享了该组件2.0版本的功能特点及优化实践，希望能为类似业务（比如移动端IM系统等）的消息队列设计提供一定的参考。 2、背景介绍 微信后台给件 MQ 1.0 发布之初，基本满足了一般业务场景的异步化需求，实现了单机下高性能的任务持久化和消费调度。 MQ 1.0 的基本框架如下图所示： ? 上图是群消息投递业务的简化流程示意。随着微信群消息体量的高速膨胀，其带来的成本压力越来越大，业务同学提出了批量并行化的优化方式。 相比常规的同步处理模型，它提供了一种轻量的逻辑异步化模型。一个冗长的逻辑可以切分为很多小的功能块进行串联和复用，每一级之间都有 MQ 去充当缓冲和调度。
1.6K31发布于 2018-06-22 - 来自专栏云服务器购买
消息队列-腾讯云消息队列 CKafka
腾讯云消息队列 CKafka，分布式、高吞吐量、高可扩展性的消息服务，100%兼容开源 Apache Kafka 0.9 0.10 腾讯云消息队列 CKafka点击查看详情 消息队列 CKafka 简介 消息队列 CKafka（Cloud Kafka）是一个分布式、高吞吐量、高可扩展性的消息系统，100%兼容开源 Kafka API（0.9、0.10版本）。 CKafka 基于发布/订阅模式，通过消息解耦，使生产者和消费者异步交互，无需彼此等待。CKafka 具有数据压缩、同时支持离线和实时数据处理等优点，适用于日志压缩收集、监控数据聚合等场景。 高可靠 消息队列 CKafka 集群性能强劲，生产性超越开源方案；此外，消息队列 CKafka 分布式的部署，集群稳定性也有很好的保障。 应用场景 日志分析系统 消息队列 CKafka 结合大数据套件 EMR，构建完整的日志分析系统。
7.7K60发布于 2019-08-06 - 来自专栏java思维导图
消息队列探秘 – RabbitMQ 消息队列介绍
AMQP 的出现其实也是应了广大人民群众的需求，虽然在同步消息通讯的世界里有很多公开标准（如 COBAR的 IIOP ，或者是 SOAP 等），但是在异步消息处理中却不是这样，只有大企业有一些商业实现（ Broker： 简单来说就是消息队列服务器实体。 Exchange： 消息交换机，它指定消息按什么规则，路由到哪个队列。 Queue： 消息队列载体，每个消息都会被投入到一个或多个队列。 producer： 消息生产者，就是投递消息的程序。 consumer： 消息消费者，就是接受消息的程序。 Queue Queue（队列）是RabbitMQ的内部对象，用于存储消息，用下图表示。 queue ? RPC MQ本身是基于异步的消息处理，前面的示例中所有的生产者（P）将消息发送到RabbitMQ后不会知道消费者（C）处理成功或者失败（甚至连有没有消费者来处理这条消息都不知道）。
4.8K20发布于 2019-11-05 - 来自专栏互联网技术栈
消息队列探秘-RabbitMQ消息队列介绍
AMQP 的出现其实也是应了广大人民群众的需求，虽然在同步消息通讯的世界里有很多公开标准（如 COBAR的 IIOP ，或者是 SOAP 等），但是在异步消息处理中却不是这样，只有大企业有一些商业实现（ ---- Broker： 简单来说就是消息队列服务器实体。 Exchange： 消息交换机，它指定消息按什么规则，路由到哪个队列。 Queue： 消息队列载体，每个消息都会被投入到一个或多个队列。 producer： 消息生产者，就是投递消息的程序。 consumer： 消息消费者，就是接受消息的程序。 Queue Queue（队列）是RabbitMQ的内部对象，用于存储消息，用下图表示。 queue ? RPC MQ本身是基于异步的消息处理，前面的示例中所有的生产者（P）将消息发送到RabbitMQ后不会知道消费者（C）处理成功或者失败（甚至连有没有消费者来处理这条消息都不知道）。
4.3K30发布于 2018-12-12 - 来自专栏Goboy
异步消息队列设计与实现 · 构建高效解耦的平台消息通信机制
为了应对这些挑战，越来越多的系统选择引入消息队列作为核心组件，以解耦各个业务模块，同时提供异步、可靠的通信机制。今天我们通过实践分析。 为了应对高并发的访问需求，系统需要保证以下几个特性：异步处理与解耦：每个模块独立处理自己的业务逻辑，而不直接依赖其他模块的实现。 消息队列的原理与优先级机制消息队列的基本原理消息队列（Message Queue, MQ）是异步通信的一种实现方式。它通过将发送方的消息存储到队列中，接收方从队列中消费消息来实现系统之间的松耦合。 消息队列提供了以下几个重要特性：解耦：发送方和接收方不直接依赖，消息通过队列进行传递。异步处理：生产者将消息发送到队列后，无需等待消费者处理完成，可以继续进行其他操作。 此时，我们通过优先级队列来保证支付确认消息的优先处理，而库存更新消息则可在稍后的时间被处理。消息优先级与业务解耦通过优先级队列和消息队列的结合，系统中的各个模块可以更加灵活地处理消息。
1.2K20编辑于 2025-01-20 - 来自专栏后端知识体系
异步消息通知—异步改造
# 异步消息通知—异步改造 异步消息通知，解耦业务中需要发送消息的场景，非中间件框架方式使用方法 # 背景 消息通知是项目中遇到的常见场景，通常而言消息通知会涉及到数据库操作，且面临着通知用户多，消息处理需要时间的问题 ，未使用消息队列 保存用户后异步发送通知，使用消息队列 package com.test.message.service; import com.test.message.domain.dto.UserDTO 此时引入消息队列就显得十分有必要，其异步、解耦、削峰的特性广为人知，这里不再阐述消息队列中可能遇到的问题和优点。 (采用循环监听即可)，异步多线程的取出队列内的数据，并发送消息。 发送消息实体到内存队列的时间 # 总结 异步化改造是应用中场景的方法，本文从简单的异步方法出发，提供了线程池+事务管理+消息队列联合运用的整体方法，测试结果发现相对比串行和单纯使用异步调用的方法，加入消息队列的方案具有更快的调用速度
4.3K21编辑于 2022-07-14 - 来自专栏后端知识体系
异步消息通知—异步改造
# 异步消息通知—异步改造 异步消息通知，解耦业务中需要发送消息的场景，非中间件框架方式使用方法 # 背景 消息通知是项目中遇到的常见场景，通常而言消息通知会涉及到数据库操作，且面临着通知用户多，消息处理需要时间的问题 ，未使用消息队列 保存用户后异步发送通知，使用消息队列 package com.test.message.service; import com.test.message.domain.dto.UserDTO 此时引入消息队列就显得十分有必要，其异步、解耦、削峰的特性广为人知，这里不再阐述消息队列中可能遇到的问题和优点。 (采用循环监听即可)，异步多线程的取出队列内的数据，并发送消息。 发送消息实体到内存队列的时间 # 总结 异步化改造是应用中场景的方法，本文从简单的异步方法出发，提供了线程池+事务管理+消息队列联合运用的整体方法，测试结果发现相对比串行和单纯使用异步调用的方法，加入消息队列的方案具有更快的调用速度
3.5K30编辑于 2023-02-14 消息队列
这种模式下，发送和接收是异步的，发送者无需等待；二者的生命周期未必相同；发送消息的时候接收者不一定运行，接收消息的时候发送者也不一定运行；一对多通信：对于一个消息可以有多个接收者。 为了能够完成消息的可靠传输，一般情况下，使用队列的方式进行消息管理，也就是说，能常在进行数据传输时，将数据按照用户定义的大小，拆分成若干消息放入消息队列，按照同步或异步的通信方式发送或者接收消息。 消息队列是在多个不同的应用之间实现相互通信的一种异步传输模式，相互通信的应用可以分布于同一台机器上，也可以分布于相连的网络空间中的任一位置。 消息队列实在多个不同的应用之间实现相互通信的一种异步传输模式，相互通信的应用可以分布于同一台及其上，也可以分布于相连的网络空间中的任一位置。 采用消息队列技术的好处是：由于是异步通信，无论是发送方还是接受方都不用等待对方返回成功信息，就可以执行余下的代码，因而大大的提高了事务处理的能力。
40910编辑于 2025-08-29消息队列
什么是消息队列？消息队列是一种异步通信（Asynchronous Communication）的服务或组件。 它充当了消息的中介：发送方（生产者，Producer）将消息发送到队列中，接收方（消费者，Consumer）从队列中获取并处理消息。 核心特点是解耦：生产者和消费者不需要知道彼此的存在，它们只与消息队列交互。消息队列是解决高并发问题的关键技术之一。2.解决了什么问题？ 生产者只需要将消息发送到 MQ，而不需要关心谁来消费，从而降低了服务间的依赖性。异步（Asynchrony）：问题：某些操作耗时长，同步等待会阻塞主流程，影响用户体验。 在需要解耦、异步、削峰三大特性同时发挥作用的场景下，消息队列没有完美的平替技术。 MQ（如 Kafka, RabbitMQ, RocketMQ）是最佳选择。
48810编辑于 2025-11-11- 来自专栏晨曦破晓の家
消息队列
啥是消息队列 一般来说，消息队列是一种异步的服务间通信方式，是分布式系统中重要的组件，主要解决应用耦合，异步消息，流量削锋等问题，实现高性能，高可用，可伸缩和最终一致性架构。 通过使用消息队列，我们可以异步处理请求，从而缓解系统的压力。 消息队列有哪些 Kafka RocketMQ RabbitMQ pulsar activeMQ verneMQ 一个大型的分布式系统，通常都会异步化，走消息总线。 消息队列作为最主要的基础组件，在整个体系架构中，有着及其重要的作用。异步通常意味着编程模型的改变，时效性会降低。 kafka是目前最常用的消息队列，尤其是在大数据方面，有着极高的吞吐量。 而rocketmq和rabbitmq，都是电信级别的消息队列，在业务上用的比较多。相比较而言，ActiveMQ使用的最少，属于较老一代的消息框架。
4.7K30发布于 2020-09-11
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号