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

云消息队列

关注

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

0
今日
3759
内容
16
活动
2389
关注
|
存储 消息中间件 负载均衡
|

深入理解RocketMQ广播消费

这篇文章我们聊聊广播消费,因为广播消费在某些场景下真的有奇效。笔者会从基础概念、实现机制、实战案例、注意事项四个方面一一展开,希望能帮助到大家。

2294 1
|
消息中间件 存储 传感器
|

嵌入式环形队列、消息队列的实现原理

嵌入式环形队列、消息队列的实现原理

1353 0
|
消息中间件 NoSQL Java
|

【Redis】浅尝Redis Stream做消息队列

SpringBoot整合Redis5.0新特性Redis Stream

1838 0
|
消息中间件 Java C++
|

开源项目推荐:多进程和多线程的高性能消息队列(无锁队列),lock-free queue

开源项目推荐:多进程和多线程的高性能消息队列(无锁队列),lock-free queue

1914 0
|
消息中间件 人工智能 监控
|

RocketMQ体验测评

【8月更文挑战第15天】RocketMQ体验测评

320 1
|
消息中间件 网络协议 物联网
|

消息队列 MQ产品使用合集之如何让消费者不从最开始进行消费,而是从最后一条消息开始消费

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

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

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

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

448 0
|
域名解析 消息中间件 Kubernetes
|

【消息队列】解决ERR 1 [topic/channel] (: no such host

【消息队列】解决ERR 1 [topic/channel] (: no such host

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

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

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

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

阿里云消息队列 RocketMQ 5.0 全新升级:消息、事件、流融合处理平台

RocketMQ5.0 的发布标志着阿里云消息从消息领域正式迈向了“消息、事件、流”场景大融合的新局面。未来阿里云消息产品的演进也将继续围绕消息、事件、流核心场景而开展。

1551 1
|
消息中间件 PHP 数据库
|

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

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

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

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

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

7997 0
|
消息中间件 Java Spring
|

精通SpringBoot——第八篇:整合RabbitMQ消息队列

springboot 整合消息队列RabbitMQ

5531 1
|
消息中间件 Python
|

python—多进程的消息队列

1525 0
|
6月前
|
消息中间件 数据可视化 RocketMQ
|

可视化生成RocketMQ配置工具

RocketMQ配置复杂?试试这款可视化工具,轻松搞定配置难题,点击体验:https://how-to-config-rocketmq.demoworld.tech/

429 6
|
消息中间件 Java 物联网
|

消息队列 MQ操作报错合集之建立连接时发生了超时错误,该如何解决

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

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

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

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

1024 4
|
消息中间件 存储 负载均衡
|

RocketMQ 客户端负载均衡机制详解及最佳实践

本文介绍 RocketMQ 负载均衡机制,主要涉及负载均衡发生的时机、客户端负载均衡对消费的影响(消息堆积/消费毛刺等)并且给出一些最佳实践的推荐。

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

深度解读 RocketMQ 存储机制

本文想从一个不一样的视角,着重于谈谈我眼中的这种存储实现是在解决哪些复杂的问题,因此我从本文最初的版本中删去了冗杂的代码细节分析,由浅入深的分析存储机制的缺陷与优化方向。

1011 1
|
消息中间件 缓存 数据库
|

Python编程:RabbitMQ消息队列

Python编程:RabbitMQ消息队列

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

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

rocketmq 你真的了解么?

879 2
|
消息中间件 大数据 Kafka
|

分布式消息队列Kafka之发布订阅消息系统

分布式消息队列Kafka之发布订阅消息系统

394 0
|
消息中间件 存储 NoSQL
|

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

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

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

打造更适合IoT场景的消息队列实践

随着接触客户越来越多,也越来越颠覆了我对“传统队列”(kafka、rocketmq、rabbitmq...)的看法。 当然本文不是说“传统队列”做得不好, 这些队列系统经过多年打磨,在高性能、海量堆积、消息可靠性等诸多方面都已经做得非常极致了,都做得非常的优秀。 但今天我觉得大家在设计方案时动不动任何一个异步、系统解耦等就来选用队列,然后线上又频繁出一些问题,这些问题的背后我们得看看到底什么场景适合、什么场景过渡使用了、有没有更好解法, 尤其今天IoT领域场景复杂,既有面向自身SAAS业务又要承担多租户PAAS平台化模式,面临更多的队列方面问题,拿来和大家讨论分享。

5466 1
|
消息中间件 缓存 数据库
|

MQ(消息队列)常见的应用场景解析

前言 提高系统性能首先考虑的是数据库的优化,之前一篇文章《数据库的使用你可能忽略了这些》中有提到过开发中,针对数据库需要注意的事项。但是数据库因为历史原因,横向扩展是一件非常复杂的工程,所有我们一般会尽量把流量都挡在数据库之前。

2637 0
|
存储 消息中间件 Kafka
|

当设计消息队列时我们关心什么

1602 0
|
消息中间件 中间件 测试技术
|

消息队列软件产品大比拼

1855 0
|
消息中间件 Java
|

消息队列的exclusive consumer功能是如何保证消息有序和防止脑裂的

一般来说,消息队列都会保证queue当中的消息的顺序。然而如果有多个consumer同时消费同一个queue,那么这时就不能保证的消息的顺序性。 有时候,消息的顺序是非常重要的,为了能顺序的消费消息,我们只能启动一个consumer来消费这个queue。

10988 7
|
消息中间件 SQL 负载均衡
|

EQueue - 一个纯C#写的分布式消息队列介绍2

4423 0
|
消息中间件 NoSQL Java
|

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

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

9498 0
|
消息中间件 Windows
|

Windows消息队列

一 Windows中有一个系统消息队列,对于每一个正在执行的Windows应用程序,系统为其建立一个“消息队列”,即应用程序队列,用来存放该程序可能 创建的各种窗口的消息。应用程序中含有一段称作“消息循环”的代码,用来从消息队列中检索这些消息并把它们分发到相应的窗口函数中。

2233 0
|
消息中间件 Web App开发
|

安装 RabbitMQ 消息队列

1、安装运行环境 yum install erlang 2、安装RabbitMQ wget http://www.rabbitmq.com/releases/rabbitmq-server/v3.

2664 0
|
消息中间件 缓存 Apache
|

消息队列 MQ使用问题之对于Grpc参数的调优,该如何操作

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

277 0
|
消息中间件 SQL Java
|

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

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

1346 0
|
消息中间件 Prometheus 运维
|

最佳实践|从Producer 到 Consumer,如何有效监控 Kafka

对于运维人而言,如何安装维护一套监控系统,或如何进行技术选型,从来不是工作重点。如何借助工具对所需的应用、组件进行监控,发现并解决问题才是重中之重。随着 Prometheus 逐渐成为云原生时代可观测标准,为了帮助更多运维人用好 Prometheus,阿里云云原生团队将定期更新 Prometheus 最佳实践系列。第一期我们讲解了《最佳实践|Spring Boot 应用如何接入 Prometheus 监控》,今天将为大家带来,消息队列产品 Kafka 的监控最佳实践。

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

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

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

514 0
|
消息中间件 监控 负载均衡
|

快手基于 RocketMQ 的在线消息系统建设实践

快手需要建设一个主要面向在线业务的消息系统作为 Kafka 的补充,低延迟、高并发、高可用、高可靠的分布式消息中间件 RocketMQ 正是我们所需的。

550 0
|
消息中间件 监控 NoSQL
|

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

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

209 0
|
消息中间件 存储 大数据
|

分布式消息队列Kafka理论(浅显易懂)

分布式消息队列Kafka理论(浅显易懂)

267 0
|
消息中间件 存储 NoSQL
|

什么是消息队列?

笔记

413 0
|
消息中间件 监控 Kafka
|

阿里云消息队列Kafka Ram账户授权问题

消息队列Kafka版的控制台和API的权限管理通过访问控制RAM(Resource Access Management)实现。RAM可以让您避免与其他用户共享阿里云云账号密钥,即AccessKey(包含AccessKey ID和AccessKey Secret),按需为其他用户分配最小权限。本文介绍如何给一个RAM子账户授予单个Kakfa实例的ReadOnly查看权限。

927 0

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

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

8760 7
|
消息中间件 C#
|

【c#】队列(Queue)和MSMQ(消息队列)的基础使用

原文:【c#】队列(Queue)和MSMQ(消息队列)的基础使用       首先我们知道队列是先进先出的机制,所以在处理并发是个不错的选择。然后就写两个队列的简单应用。 Queue 命名空间     命名空间:System.Collections,不在这里做过多的理论解释,这个东西非常的好理解。

1667 2
|
消息中间件 关系型数据库 MySQL
|

用消息队列和socket实现聊天系统

  前言:最近在学进程间通信,所以做了一个小项目练习一下。主要用消息队列和socket(UDP)实现这个系统,并数据库存储数据,对C语言操作不熟悉的可以参照我的这篇博客:https://www.cnblogs.com/liudw-0215/p/9593414.html,所有代码提交我的Github上,地址:https://github.com/ldw0215/Chat-System.git,可以自行下载,然后make一下就可以了。

2182 0
|
消息中间件 测试技术 安全
|

生产环境消息队列ActiveMQ的数据积压优化过程

针对消息队列的数据积压问题,我们主要做了三个方面的优化处理,取消同步锁、ActiveMQ参数优化、本地双队列优化,通过这三个方面的优化基本解决了队列数据积压的问题。

5208 0
|
消息中间件 NoSQL Kafka
|

ActiveMQ消息队列

7619 0
我要发布