开发者社区> 云原生> 云消息队列

云消息队列

关注

涵盖 RocketMQ、Kafka、RabbitMQ、MQTT、轻量消息队列(原MNS) 的消息队列产品体系,全系列产品 Serverless 化。RocketMQ 中文社区:https://rocketmq-learning.com/

0
今日
3759
内容
16
活动
2392
关注
|
消息中间件 网络协议 Java
|

使用阿里云消息队列

9679 1
|
消息中间件 安全 Ubuntu
|

Posix消息队列

1664 0
|
消息中间件
|

消息队列入门(一)关于消息队列

消息是指在两个独立的系统间传递的数据,这两个系统可以是两台计算机,也可以是两个进程。 消息可以非常简单,可以是简单的字符串,也可以是保存了数据持久化的各种类型的文档集合。 队列是在消息的传输过程中的通道,是保存消息的容器,根据不同的情形,可以有先进先出,优先级队列等区别 。

2924 0
|
消息中间件 缓存 Linux
|

消息队列接口API(posix 接口和 system v接口)

消息队列 posix API 消息队列(也叫做报文队列)能够克服早期unix通信机制的一些缺点。信号这种通信方式更像\"即时\"的通信方式,它要求接受信号的进程在某个时间范围内对信号做出反应,因此该信号最多在接受信号进程的生命周期内才有意义,信号所传递的信息是接近于随进程持续的概念(process-persistent);管道及有名管道则是典型的随进程持续IPC,并且,只能传送无格式的字节流无疑会给应用程序开发带来不便,另外,它的缓冲区大小也受到限制消息队列就是一个消息的链表。

2029 0
|
消息中间件 Java 开发工具
|

消息队列 MQ使用问题之如何使用DefaultMQPushConsumer来消费消息

消息队列(MQ)是一种用于异步通信和解耦的应用程序间消息传递的服务,广泛应用于分布式系统中。针对不同的MQ产品,如阿里云的RocketMQ、RabbitMQ等,它们在实现上述场景时可能会有不同的特性和优势,比如RocketMQ强调高吞吐量、低延迟和高可用性,适合大规模分布式系统;而RabbitMQ则以其灵活的路由规则和丰富的协议支持受到青睐。下面是一些常见的消息队列MQ产品的使用场景合集,这些场景涵盖了多种行业和业务需求。

706 0
|
消息中间件 存储 负载均衡
|

消息队列 MQ使用问题之如何在grpc客户端中设置负载均衡器

消息队列(MQ)是一种用于异步通信和解耦的应用程序间消息传递的服务,广泛应用于分布式系统中。针对不同的MQ产品,如阿里云的RocketMQ、RabbitMQ等,它们在实现上述场景时可能会有不同的特性和优势,比如RocketMQ强调高吞吐量、低延迟和高可用性,适合大规模分布式系统;而RabbitMQ则以其灵活的路由规则和丰富的协议支持受到青睐。下面是一些常见的消息队列MQ产品的使用场景合集,这些场景涵盖了多种行业和业务需求。

491 0
|
消息中间件 运维 Go
|

消息队列 MQ使用问题之如何配置生产环境

消息队列(MQ)是一种用于异步通信和解耦的应用程序间消息传递的服务,广泛应用于分布式系统中。针对不同的MQ产品,如阿里云的RocketMQ、RabbitMQ等,它们在实现上述场景时可能会有不同的特性和优势,比如RocketMQ强调高吞吐量、低延迟和高可用性,适合大规模分布式系统;而RabbitMQ则以其灵活的路由规则和丰富的协议支持受到青睐。下面是一些常见的消息队列MQ产品的使用场景合集,这些场景涵盖了多种行业和业务需求。

381 0
|
消息中间件 Java 调度
|

消息队列 MQ使用问题之消费者自动掉线是什么导致的

消息队列(MQ)是一种用于异步通信和解耦的应用程序间消息传递的服务,广泛应用于分布式系统中。针对不同的MQ产品,如阿里云的RocketMQ、RabbitMQ等,它们在实现上述场景时可能会有不同的特性和优势,比如RocketMQ强调高吞吐量、低延迟和高可用性,适合大规模分布式系统;而RabbitMQ则以其灵活的路由规则和丰富的协议支持受到青睐。下面是一些常见的消息队列MQ产品的使用场景合集,这些场景涵盖了多种行业和业务需求。

792 0
|
消息中间件 Arthas 监控
|

消息队列 MQ产品使用合集之每次重置reconsumeTimes就无法达到死信阈值,重试次数是否就要应用方控制

消息队列(MQ)是一种用于异步通信和解耦的应用程序间消息传递的服务,广泛应用于分布式系统中。针对不同的MQ产品,如阿里云的RocketMQ、RabbitMQ等,它们在实现上述场景时可能会有不同的特性和优势,比如RocketMQ强调高吞吐量、低延迟和高可用性,适合大规模分布式系统;而RabbitMQ则以其灵活的路由规则和丰富的协议支持受到青睐。下面是一些常见的消息队列MQ产品的使用场景合集,这些场景涵盖了多种行业和业务需求。

222 0
|
消息中间件 数据安全/隐私保护 RocketMQ
|

消息队列 MQ产品使用合集之如何自定义时间间隔

消息队列(MQ)是一种用于异步通信和解耦的应用程序间消息传递的服务,广泛应用于分布式系统中。针对不同的MQ产品,如阿里云的RocketMQ、RabbitMQ等,它们在实现上述场景时可能会有不同的特性和优势,比如RocketMQ强调高吞吐量、低延迟和高可用性,适合大规模分布式系统;而RabbitMQ则以其灵活的路由规则和丰富的协议支持受到青睐。下面是一些常见的消息队列MQ产品的使用场景合集,这些场景涵盖了多种行业和业务需求。

409 1
|
消息中间件 设计模式 网络安全
|

消息队列 MQ操作报错合集之broker启用controller配置时,遇到报错,是什么导致的

在使用消息队列MQ时,可能会遇到各种报错情况。以下是一些常见的错误场景、可能的原因以及解决建议的汇总:1.连接错误、2.消息发送失败、3.消息消费报错、4.消息重试与死信处理、5.资源与权限问题、6.配置错误、7.系统资源限制、8.版本兼容性问题。

375 1
|
消息中间件 RocketMQ
|

消息队列 MQ操作报错合集之无法自动创建topic,该怎么办

在使用消息队列MQ时,可能会遇到各种报错情况。以下是一些常见的错误场景、可能的原因以及解决建议的汇总:1.连接错误、2.消息发送失败、3.消息消费报错、4.消息重试与死信处理、5.资源与权限问题、6.配置错误、7.系统资源限制、8.版本兼容性问题。

656 0
|
消息中间件 监控 应用服务中间件
|

消息队列 MQ操作报错合集之重启Broker后,积压数出现为负数是什么导致的

在使用消息队列MQ时,可能会遇到各种报错情况。以下是一些常见的错误场景、可能的原因以及解决建议的汇总:1.连接错误、2.消息发送失败、3.消息消费报错、4.消息重试与死信处理、5.资源与权限问题、6.配置错误、7.系统资源限制、8.版本兼容性问题。

450 1
|
消息中间件 Apache C语言
|

消息队列 MQ产品使用合集之在Cluster部署模式下,使用dashboard无法查询到消费组信息,一般是什么导致的

阿里云消息队列MQ(Message Queue)是一种高可用、高性能的消息中间件服务,它允许您在分布式应用的不同组件之间异步传递消息,从而实现系统解耦、流量削峰填谷以及提高系统的可扩展性和灵活性。以下是使用阿里云消息队列MQ产品的关键点和最佳实践合集。

340 0
|
消息中间件 网络安全 网络虚拟化
|

消息队列 MQ操作报错合集之如何实现公网访问内网RocketMQ集群

在使用消息队列MQ时,可能会遇到各种报错情况。以下是一些常见的错误场景、可能的原因以及解决建议的汇总:1.连接错误、2.消息发送失败、3.消息消费报错、4.消息重试与死信处理、5.资源与权限问题、6.配置错误、7.系统资源限制、8.版本兼容性问题。

465 0
|
消息中间件 监控 Java
|

消息队列 MQ产品使用合集之vipchannel的作用有哪些

阿里云消息队列MQ(Message Queue)是一种高可用、高性能的消息中间件服务,它允许您在分布式应用的不同组件之间异步传递消息,从而实现系统解耦、流量削峰填谷以及提高系统的可扩展性和灵活性。以下是使用阿里云消息队列MQ产品的关键点和最佳实践合集。

255 0
|
缓存 NoSQL 安全
|

玩转Redis!非常强大的Redisson分布式集合,少写60%代码

Redisson是Java的Redis客户端,提供实时数据平台服务,简化了分布式环境下的数据管理。它包含RList、RSet、RMap等分布式集合,支持ConcurrentMap和Set接口,确保线程安全和数据一致性。例如,RMap实现了本地缓存和监听器功能,允许数据监听和本地加速读取。此外,还提供了RSet的排序和去重功能,以及RQueue和RBlockingQueue等队列实现,支持阻塞操作。通过Redisson,开发者能轻松处理分布式系统的数据同步和操作。

1208 1
|
消息中间件 网络安全 数据安全/隐私保护
|

MQ产品使用合集之在MQTT中,出现了 NO HEART 错误如何解决

消息队列(MQ)是一种用于异步通信和解耦的应用程序间消息传递的服务,广泛应用于分布式系统中。针对不同的MQ产品,如阿里云的RocketMQ、RabbitMQ等,它们在实现上述场景时可能会有不同的特性和优势,比如RocketMQ强调高吞吐量、低延迟和高可用性,适合大规模分布式系统;而RabbitMQ则以其灵活的路由规则和丰富的协议支持受到青睐。下面是一些常见的消息队列MQ产品的使用场景合集,这些场景涵盖了多种行业和业务需求。

572 2
|
消息中间件 存储 数据库
|

深度剖析 RocketMQ 5.0,流数据库:如何实现一体化流处理?

本文将从概念和宏观角度理解什么是流处理。 RocketMQ 5.0,学习 RocketMQ 提供的轻量流处理引擎 RStreams,了解其特性和原理。学习 RocketMQ 的流数据库 RSQLDB,通过流存储和流计算的深度结合,看它如何进一步降低流处理使用门槛。

79509 0
|
消息中间件 Cloud Native 物联网
|

深度剖析 RocketMQ 5.0,消息基础:RocketMQ 在业务消息场景的基础优势是什么?

本文主要介绍业务消息的应用解耦场景,具体解耦什么? RocketMQ 在业务消息场景的基础特性。业界那么多消息队列能实现应用解耦,RocketMQ 在基础特性上有哪些增强?

126007 2
|
消息中间件 编解码 网络协议
|

聊聊 RocketMQ 网络通讯模块

RocketMQ 的网络通讯模块负责生产者、消费者与 Broker 之间的网络通信。 笔者学习 RocketMQ 也是从通讯模块源码开始的,并且从源码里汲取了很多营养。

37642 3
|
消息中间件 弹性计算 Java
|

Rocketmq-spring入门与实践

本场景带您体验如何在 Spring 生态中优雅地使用 Apache RocketMQ,感受最受欢迎业务开发框架与最受欢迎消息平台结合的魅力。

727 0
|
消息中间件 存储 自然语言处理
|

RocketMQ 5.0: 存储计算分离新思路

Apache RocketMQ 自 2012 年开源以来,因其架构简单,业务功能丰富,具备极强的可扩展性等特点被广泛采用。RocketMQ 在阿里巴巴集团内部有着数千台的集群规模,每天十万亿消息的规模。在阿里云上,RocketMQ 的商业化产品也以弹性云服务的形式为全球数万个用户提供企业级的消息解决方案,被广泛应用于互联网、大数据、移动互联网、物联网等领域的业务场景,成为了业务开发的首选消息中间件。 尽管消息中间件 RocketMQ 在阿里巴巴和开源社区已经走过了十多个年头,但在云原生浩浩荡荡的浪潮下(《云原生时代消息中间件的演进路线》),我们对 RocketMQ 的架构有了一些新的思考。

475 0
|
消息中间件 Cloud Native 安全
|

云钉一体:EventBridge 联合钉钉连接器打通云钉生态

今天,EventBridge 联合钉钉连接器,打通了钉钉生态和阿里云生态,钉钉的生态伙伴可以通过通道的能力驱动阿里云上海量的计算力。

536 0
|
程序员 云计算 开发者
|

【科普】如果程序员穿越到古代当皇帝,会发生什么?

皇帝组建一个内阁团队,不仅可以提高办事效率,而且还能帮助自己分担一部分的工作。 而云计算中的EventBridge,就是一个可以分析、归类和传递奏折,并且能处理突发状况的“内阁”。

311 0
|
消息中间件 缓存 供应链
|

“消息驱动、事件驱动、流 ”基础概念解析

本文旨在帮助大家对近期消息领域的高频词“消息驱动(Message-Driven),事件驱动(Event-Driven)和流(Streaming)”有更清晰的了解和认知,其中事件驱动 EDA 作为 Gartner 预测的十大技术趋势之一, EventBridge 作为下一代消息中间件,也是目前的重点方向之一。

680 0
|
消息中间件 Cloud Native Devops
|

《云原生消息队列Apache RocketMQ》电子版地址

从虚拟化技术诞生以来,IaaS/PaaS/SaaS 概念陆续被提了出来,各种容器技术层出不穷。有了“云原生”这个概念后,我们就一直在思考传统的消息中间件需要做些什么才能加上云原生这个修饰词,而这也正是本书探讨的主题:传统的消息中间件如何持续进化为云原生的消息服务。本书一书将为你详细解答。同时解读 RocketMQ 的强大功能通过实战演练的方式,教你打造定制化 DevOps 平台!

222 0
|
消息中间件 存储 搜索推荐
|

面试题(二十二)消息队列与搜索引擎

2. 消息队列 2.1 MQ有什么用? 参考答案 消息队列有很多使用场景,比较常见的有3个:解耦、异步、削峰。 1. 解耦:传统的软件开发模式,各个模块之间相互调用,数据共享,每个模块都要时刻关注其他模块的是否更改或者是否挂掉等等,使用消息队列,可以避免模块之间直接调用,将所需共享的数据放在消息队列中,对于新增业务模块,只要对该类消息感兴趣,即可订阅该类消息,对原有系统和业务没有任何影响,降低了系统各个模块的耦合度,提高了系统的可扩展性。 2. 异步:消息队列提供了异步处理机制,在很多时候应用不想也不需要立即处理消息,允许应用把一些消息放入消息中间件中,并不立即处理它,在之后需要的时候再慢慢处

280 0
|
消息中间件 监控 Java
|

手把手系列:消息队列 MNS 实操讲|学习笔记

快速学习手把手系列:消息队列 MNS 实操讲

867 0
|
消息中间件 Cloud Native Java
|

RocketMQ-Spring 毕业两周年,为什么能成为 Spring 生态中最受欢迎的 messaging 实现?

2019 年 1 月,孵化 6 个月的 RocketMQ-Spring 作为 Apache RocketMQ 的子项目正式毕业,发布了第一个 Release 版本 2.0.1。该项目是把 RocketMQ 的客户端使用 Spring Boot 的方式进行了封装,可以让用户通过简单的 annotation 和标准的 Spring Messaging API 编写代码来进行消息的发送和消费。当时 RocketMQ 社区同学请 Spring 社区的同学对 RocketMQ-Spring 代码进行 review,引出一段罗美琪(RocketMQ)和春波特(Spring Boot)的故事。

455 0
|
消息中间件 Unix Linux
|

嵌入式Linux C进程间通信(三)——消息队列

嵌入式Linux C进程间通信(三)——消息队列

644 0
|
SQL 消息中间件 Unix
|

分布式消息队列RocketMQ工作原理与应用(七)

第 4 章 RocketMQ应用 四、事务消息 1 问题引入 这里的一个需求场景是:工行用户A向建行用户B转账 1 万元。 我们可以使用同步消息来处理该需求场景: 工行系统发送一个给B增款 1 万元的

462 0
|
消息中间件 自然语言处理 数据可视化
|

消息队列入门学习

消息队列(Message Queue,简称 MQ)。是基于队列与消息传递技术,在网络环境中为应用系统提供同步或异步、可靠的消息传输的支撑性软件系统

399 0
|
消息中间件 运维 物联网
|

微消息队列 MQTT 销售指南| 学习笔记

快速学习微消息队列 MQTT 销售指南

575 0
|
消息中间件 物联网 Linux
|

消息队列中消息的格式|学习笔记

快速学习消息队列中消息的格式

594 0
|
消息中间件 物联网 Shell
|

消息队列的创建及打开|学习笔记

快速学习消息队列的创建及打开

366 0
|
消息中间件 Kafka
|

关于MQ的几件小事(二)如何保证消息队列的高可用

介绍如何保证消息队列的高可用

319 0
|
消息中间件 NoSQL 关系型数据库
|

redis 实现消息队列及常用命令(三)|学习笔记

快速学习 redis 实现消息队列及常用命令(三)

584 0
|
消息中间件 存储 监控
|

4.图灵学院-----阿里/京东/滴滴/美团整理----高频MQ消息队列篇

4.图灵学院-----阿里/京东/滴滴/美团整理----高频MQ消息队列篇

405 0
|
消息中间件 存储 缓存
|

RocketMq消息队列系列(一)简介与特性

rocketmq 你真的了解么?

915 2
|
消息中间件 存储 Java
|

消息队列:从选型到原理,一文带你全部掌握(一)

消息队列中间件重要吗?面试必问问题之一,你说重不重要。我有时会问同事,为啥你用RabbitMQ,不用Kafka,或者RocketMQ呢,他给我的回答“因为公司用的就是这个,大家都这么用”,如果你去面试,直接就被Pass,今天这篇文章,告诉你如何回答。 这篇文章纯理论,主要整理网络资料,肝了我整整一个月!文章依然延续上几篇的风格,很长,长到我只整理排版,手都整麻了。全文2.5万字,建议先收藏,后续面试、或者技术选型,再拿出来喵喵,不BB,上思维导图!

775 0
|
消息中间件 Kafka 数据库
|

消息队列之事务消息,RocketMQ 和 Kafka 是如何做的?(上)

消息队列之事务消息,RocketMQ 和 Kafka 是如何做的?(上)

657 0
|
消息中间件 存储 运维
|

消息队列面试连环问:如何保证消息不丢失?处理重复消息?消息有序性?消息堆积处理?(上)

消息队列面试连环问:如何保证消息不丢失?处理重复消息?消息有序性?消息堆积处理?(上)

589 0
|
消息中间件 前端开发 安全
|

小家Spring】从Spring中的(ApplicationEvent)事件驱动机制出发,聊聊【观察者模式】【监听者模式】【发布订阅模式】【消息队列MQ】【EventSourcing】...(上)

小家Spring】从Spring中的(ApplicationEvent)事件驱动机制出发,聊聊【观察者模式】【监听者模式】【发布订阅模式】【消息队列MQ】【EventSourcing】...(上)

1298 0
|
消息中间件 存储 编解码
|

Kratos微服务框架下的消息队列应用

Kratos微服务框架下的消息队列应用,包括了:Kafka、Rabbitmq、mqtt、redis,nats,websocket等。

2986 1
|
消息中间件 存储 数据库
|

Rabbit MQ消息队列原理(2)

Rabbit MQ消息队列原理(2)

246 0
|
消息中间件 存储 缓存
|

Rabbit MQ消息队列原理(1)

Rabbit MQ消息队列原理(1)

468 0
|
消息中间件 Java Linux
|

【Android 异步操作】Handler 机制 ( MessageQueue 消息队列的阻塞机制 | Java 层机制 | native 层阻塞机制 | native 层解除阻塞机制 )(一)

【Android 异步操作】Handler 机制 ( MessageQueue 消息队列的阻塞机制 | Java 层机制 | native 层阻塞机制 | native 层解除阻塞机制 )(一)

811 0
|
消息中间件 存储 负载均衡
|

17 个方面,综合对比 Kafka、RabbitMQ、RocketMQ、ActiveMQ 四个分布式消息队列

本文将从,Kafka、RabbitMQ、ZeroMQ、RocketMQ、ActiveMQ 17 个方面综合对比作为消息队列使用时的差异。

1332 0
|
消息中间件
|

ucosii中消息队列、消息邮箱、信号量的区别

ucosii中消息队列、消息邮箱、信号量的区别

650 0
我要发布