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

云消息队列

关注

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

0
今日
3748
内容
16
活动
2381
关注
|
消息中间件 存储 缓存
|

消息队列之推还是拉,RocketMQ 和 Kafka 是如何做的?(上)

消息队列之推还是拉,RocketMQ 和 Kafka 是如何做的?(上)

1685 0
|
消息中间件 开发工具 RocketMQ
|

消息队列 MQ使用问题之一直连接master失败,是什么原因

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

269 1
|
消息中间件 Java 调度
|

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

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

581 0
|
消息中间件 RocketMQ
|

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

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

527 0
|
缓存 NoSQL 安全
|

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

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

820 1
|
消息中间件 SQL 弹性计算
|

RocketMQ中使用Java客户端发送消息和消费的应用

本教程将总结使用java客户端消息发送和消费各种场景, 并Demo演示

760 1
|
消息中间件 存储 缓存
|

RocketMQ 监控告警:生产环境如何快速通过监控预警发现堆积、收发失败等问题?

本文主要向大家介绍如何利用 RocketMQ 可观测体系中的指标监控,对生产环境中典型场景:消息堆积、消息收发失败等场景配置合理的监控预警,快速发现问题,定位问题。

1867 0
|
消息中间件 网络协议 Java
|

使用阿里云消息队列

9454 1
|
消息中间件 NoSQL Java
|

Redis笔记(七)Java实现Redis消息队列

这里我使用Redis的发布、订阅功能实现简单的消息队列,基本的命令有publish、subscribe等。 在Jedis中,有对应的java方法,但是只能发布字符串消息。为了传输对象,需要将对象进行序列化,并封装成字符串进行处理。

9197 0
|
消息中间件 网络协议 开发工具
|

MQ产品使用合集之rocketmq5.x只有tcp接入点吗,python sdk需要http接入点,请问怎么使用

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

453 2
|
消息中间件 Java RocketMQ
|

MQ产品使用合集之在同一个 Java 进程内建立三个消费对象并设置三个消费者组订阅同一主题和标签的情况下,是否会发生其中一个消费者组无法接收到消息的现象

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

234 1
|
消息中间件 Java RocketMQ
|

使用 rocketmq-spring-boot-starter 来配置、发送和消费 RocketMQ 消息

本文将 rocktmq-spring-boot 的设计实现做一个简单的介绍,读者可以通过本文了解将 RocketMQ Client 端集成为 spring-boot-starter 框架的开发细节,然后通过一个简单的示例来一步一步的讲解如何使用这个 spring-boot-starter 工具包来配置,发送和消费 RocketMQ 消息。

2522 0
|
消息中间件 PHP 数据库
|

PHP使用topthink/think-queue消息队列实例

PHP使用topthink/think-queue消息队列实例

491 0

【vue】项目使用mqtt消息队列实现推送

简介 近年来随着 Web 前端的快速发展,浏览器新特性层出不穷,越来越多的应用可以在浏览器端或通过浏览器渲染引擎实现,Web 应用的即时通信方式 WebSocket 得到了广泛的应用。 WebSocket 是一种在单个 TCP 连接上进行全双工通讯的协议。

8462 7
|
3月前
|
消息中间件 Apache 双11
|

Apache RocketMQ + “太乙” = 开源贡献新体验

Apache RocketMQ 是 Apache 顶级项目,源于阿里巴巴,历经多年双十一考验。RocketMQ 联合“太乙”平台启动开源竞赛,提供贡献价值评价与奖金激励(最高 5000 元),助力开发者成为社区核心成员。竞赛包含详尽教程与自动搭建环境,促进技术生态繁荣,推动分布式消息处理技术发展。欢迎加入,共创开源未来!

121 1
|
5月前
|
消息中间件 存储 Kafka
|

10倍降本、10倍无损弹性!Kafka Serverless 基础版与专业版重磅发布!

云消息队列 Kafka 版基于 Apache Kafka 构建,提供高吞吐量与高可扩展性的分布式消息队列服务,广泛应用于日志收集、监控数据聚合、流式数据处理及在离线分析等场景,是 AI 与大数据时代企业数据处理体系的核心组件。

278 5
|
消息中间件 Dubbo Java
|

如何应对RocketMQ消息堆积

很多同学都在使用 RocketMQ 时,经常会遇到消息堆积的问题。这篇文章,我们聊聊消息堆积的概念,以及如何应对消息堆积。

1791 1
|
消息中间件 SQL Java
|

Spring-cloud-stream-binder-rocketmq入门与实践

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

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

消息队列之 MetaQ 和 Kafka 区别和优势详解

本篇文章介绍MetaQ和Kafka这两个消息队列的区别和优势。

7394 0
|
消息中间件 网络协议 Java
|

阿里云微服务消息队列(MQTT For IoT)使用Demo

微消息队列 MQTT 版是阿里云推出的一款面向移动互联网以及物联网领域的轻量级消息中间件。如果说传统的消息队列中间件一般应用于微服务之间,那么适用于物联网的微消息队列 MQTT 版则实现了端与云之间的消息传递和真正意义上的万物互联。本文结合最新推出的V3版本实例介绍产品的具体使用流程。

4174 0
|
消息中间件 NoSQL 中间件
|

消息队列在线迁移实战 | 最佳实践

如何让MQ的在线迁移同时满足多个重要的需求呢?

7612 0
|
消息中间件 NoSQL Kafka
|

ActiveMQ消息队列

7462 0
|
5月前
|
消息中间件 人工智能 运维
|

乐言科技:云原生加速电商行业赋能,云消息队列助力降本 37%

乐言科技依托云原生架构及阿里云云原生产品体系,实现基础设施与业务解耦以及弹性调度,在提升业务稳定性的同时,显著增加研发效能并降低运维成本,加速电商客户定制化需求交付,推动云计算与 AI 技术在电商领域的深度融合。

365 102
|
消息中间件 Java 开发工具
|

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

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

549 0
|
消息中间件 网络性能优化 开发工具
|

消息队列 MQ使用问题之如何确保消息的唯一性

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

298 0
|
消息中间件 测试技术 RocketMQ
|

消息队列 MQ产品使用合集之在异步发送消息函数sendMessage()中出现了错误,错误代码为-3,该如何解决

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

661 1
|
消息中间件 存储 开发工具
|

消息队列 MQ产品使用合集之C++如何使用Paho MQTT库进行连接、发布和订阅消息

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

630 0
|
消息中间件 存储 Apache
|

MQ产品使用合集之有RocketMQ arm架构的镜像吗

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

514 1
|
消息中间件 SQL 容灾
|

深度剖析 RocketMQ 5.0,消息进阶:如何支撑复杂业务消息场景?

本文主要学习 RocketMQ 的一致性特性,一致性对于交易、金融都是刚需。从大规模复杂业务出发,学习 RocketMQ 的 SQL 订阅、定时消息等特性。再从高可用的角度来看,这里更多的是大型公司对于高阶可用性的要求,如同城容灾、异地多活等。

109163 287
|
消息中间件 运维 Prometheus
|

RocketMQ运维自我实践

这一节不会讲解知识点,会提出一些常见的运维问题,读者需要自行翻找答案。有问题可以群里咨询

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

一篇搞定:消息队列概念、kafka入门、Kafka Golang客户端库

一篇搞定:消息队列概念、kafka入门、Kafka Golang客户端库

1165 0
|
消息中间件 Java Kafka
|

Kafka技术专题之「问题分析篇」消息队列服务端出现内存溢出OOM以及相关实战分析系列

Kafka技术专题之「问题分析篇」消息队列服务端出现内存溢出OOM以及相关实战分析系列

728 0
|
SQL 消息中间件 Unix
|

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

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

339 0
|
消息中间件 存储 XML
|

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

第 2 章 RocketMQ的安装与启动 一、基本概念 1 消息(Message) 消息是指,消息系统所传输信息的物理载体,生产和消费数据的最小单位,每条消息必须属于一个主题。 2 主题(Topic)

650 0
|
消息中间件 NoSQL Shell
|

ThinkPHP5-消息队列

在这个例子当中,我们是手动指定的 $jobHandlerClassName ,更合理的做法是先定义好消息名称与消费者类名的映射关系,然后由某个可以获取该映射关系的类来推送这个消息。这样,生产者只需要知道消息的名称,而无需指定哪个消费者类来处理。

555 0
|
消息中间件 存储 调度
|

RT-Thread记录(七、IPC机制之邮箱、消息队列)

讲完了线程同步的机制,我们要开始线程通讯的学习,线程通讯中的邮箱消息队列也属于 RT-Thread 的IPC机制

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

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

rocketmq 你真的了解么?

580 2
|
消息中间件 存储 编解码
|

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

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

2776 1
|
消息中间件 物联网 存储
|

一图看懂 IoT物联网企业实例和 消息队列MQ的不同

IoT物联网企业实例和消息队列MQ,数据库DB等云产品关系

1440 1
|
消息中间件 存储 NoSQL
|

laravel的消息队列剖析

2304 0
|
消息中间件 C语言 RocketMQ
|

消息队列 MQ操作报错合集之出现"Connection reset by peer"的错误,该如何处理

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

526 0
|
消息中间件 网络协议 JavaScript
|

消息队列 MQ产品使用合集之报错提示是"the internal error!",是什么原因导致的”

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

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

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

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

219 0
|
消息中间件 C# RocketMQ
|

MQ产品使用合集之设置rocketmq的timerMaxDelaySec时间出现报错如何解决

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

706 4
|
消息中间件 存储 NoSQL
|

Redis 竟然能用 List 实现消息队列

今天,码哥结合消息队列的特点一步步带大家分析使用 Redis 的 List 作为消息队列的实现原理,并分享如何把 SpringBoot 与 Redission 整合运用到项目中。

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

RocketMQ消息队列的最佳实践(上)

RocketMQ消息队列的最佳实践

317 0
|
消息中间件 存储 Java
|

基于RabbitMQ消息队列的分布式事务解决方案(上)

基于RabbitMQ消息队列的分布式事务解决方案(上)

423 0
|
消息中间件 Java API
|

阿里云微服务消息队列Token C# Code Sample

文本主要演示使用C# SDK调用 ApplyToken 创建临时访问 Token。

1130 0
我要发布