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

云消息队列

关注

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

0
今日
3759
内容
16
活动
2389
关注
|
消息中间件 开发者 存储
|

消息队列(一)——消息的简单发送与接收

    背景           开发者经常遇到需要异步执行操作的情况(即过程不等到操作完成就开始)。消息队列提供一个中心位置或池,您可以在其中放置或从中提取数据,从而满足了这一要求。

1521 0
|
消息中间件 NoSQL Redis
|

Redis消息队列

Redis的消息队列使用简单,没有什么配置,比ActiveMQ要轻量级太多,当然功能也比较简单,如果只需要简单的订阅以及发布,可以考虑使用它。 订阅操作 命令为:subscribe [channel] [channel] ..,如【代码1】所示,即成功订阅频道[redis.blog]。 发布操作 命令为publish [channel] [message],如【代码2

2374 0
|
消息中间件 测试技术 Windows
|

WCF 消息队列通信

MSMQ, microsoft Message Queue,微软消息队列。通过它,应用程序开发人员可以通过发送和接收消息,来与应用程序进行快速可靠的通信。   在WCF中,提供了MSMQ通信绑定:NetMsmqBinding和MsmqIntegrationBinding 这里做个简单的演示。

793 0
|
10月前
|
消息中间件 Cloud Native 大数据
|

ApsaraMQ x Confluent 云原生 Kafka 线上沙龙

云消息队列 Kafka 版是基于 Apache Kafka 构建的全托管服务,依托于阿里云强大的基础设施,对 Apache Kafka 进行了深度重构,通过存算分离架构、高弹性扩展、云服务深度集成等优化,致力于打造更经济、更稳定、更弹性的云原生 Kafka 产品,助力企业在数字化与智能化转型中,实现业务的稳定增长与创新突破。同时,阿里云作为全球消息流领域领导者 Confluent 在中国大陆地区唯一的合作商,推出云消息队列 Confluent 版,为企业提供集成消息流式处理与大数据系统的一站式解决方案。

270 0
|
消息中间件 网络协议 RocketMQ
|

RocketMQ Controller 模式 始终更新成本机ip

ontrollerAddr=192.168.24.241:8878 但是日志输出Update controller leader address to 127.0.0.1:8878。导致访问失败

301 3
|
消息中间件 存储 弹性计算
|

云消息队列 RabbitMQ 版实践解决方案评测

随着企业业务的增长,对消息队列的需求日益提升。阿里云的云消息队列 RabbitMQ 版通过架构优化,解决了消息积压、内存泄漏等问题,并支持弹性伸缩和按量计费,大幅降低资源和运维成本。本文从使用者角度详细评测这一解决方案,涵盖实践原理、部署体验、实际优势及应用场景。

420 3
|
消息中间件 存储 负载均衡
|

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

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

432 0
|
消息中间件 JavaScript Linux
|

消息队列 MQ操作报错合集之客户端在启动时遇到了连接错误,是什么原因

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

908 0
|
消息中间件 存储 中间件
|

云原生异步问题之消息队列中的异步如何解决

云原生异步问题之消息队列中的异步如何解决

141 3
|
消息中间件 Java RocketMQ
|

消息队列 MQ产品使用合集之当SpringBoot应用因网络不通而启动失败时,该如何解决

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

851 0
|
消息中间件 Serverless 网络性能优化
|

消息队列 MQ产品使用合集之客户端和服务器之间的保活心跳检测间隔是怎么设置的

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

383 0
|
消息中间件 小程序 JavaScript
|

消息队列 MQ产品使用合集之如何限制部分客户端连接

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

183 0
|
消息中间件 Apache RocketMQ
|

消息队列 MQ操作报错合集之设置了controller后,有一主一从,但只显示一个,该怎么解决

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

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

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

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

109417 287
|
消息中间件 Cloud Native 物联网
|

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

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

125959 2
|
消息中间件 Kafka Python
|

python如何使用kafka

python如何使用kafka

731 0
|
消息中间件 SQL 弹性计算
|

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

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

986 1
|
消息中间件 存储 监控
|

【实测】django的超轻量级消息队列:django-task-mq 使用教程

【实测】django的超轻量级消息队列:django-task-mq 使用教程

904 0
|
消息中间件 分布式计算 运维
|

阿里云消息队列 Kafka 生态集成的实践与探索

阿里云消息队列 Kafka 生态集成的实践与探索

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

RocketMQ 集成生态再升级:轻松构建云上数据管道

本文将从业务架构和 API 使用等方面讲解如何使用 EventBridge 创建阿里云 RocketMQ 4.0、5.0 版本,开源自建版本以及消息路由的相关任务。

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

RocketMQ 的消费者类型详解与最佳实践

在 RocketMQ 5.0 中,更加强调了客户端类型的概念,尤其是消费者类型。为了满足多样的 RocketMQ 中一共有三种不同的消费者类型,分别是 PushConsumer、SimpleConsumer 和 PullConsumer。不同的消费者类型对应着不同的业务场景。

1127 0
|
消息中间件 存储 算法
|

RocketMQ 重试机制详解及最佳实践

本文主要介绍在使用 RocketMQ 时为什么需要重试与兜底机制,生产者与消费者触发重试的条件和具体行为,如何在 RocketMQ 中合理使用重试机制,帮助构建弹性,高可用系统的最佳实践。

1765 0
|
消息中间件
|

【中秋特辑】嫦娥妹妹,你别着急~

今天为大家带来一个小故事,是关于嫦娥和吴刚的爱情故事,想知道吴刚是怎样将情愫传递给嫦娥的吗?让我们一起一探究竟吧~

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

解析 RocketMQ 业务消息--“顺序消息”

本篇将继续业务消息集成的场景,从功能原理、应用案例、最佳实践以及实战等角度介绍 RocketMQ 的顺序消息功能。

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

消息队列 RabbitMQ 遇上可观测--业务链路可视化

本篇文章主要介绍阿里云消息队列 RabbitMQ 版的可观测功能。RabbitMQ 的可观测能力相对开源有了全面的加强,为业务链路保驾护航。

327 0
|
网络协议 物联网 测试技术
|

如何发起 MQTT 亿级连接和千万消息吞吐性能测试

MQTT 协议凭借简单易实现、支持 QoS、报文小等特点,占据了物联网协议的半壁江山。

743 0
|
消息中间件 Java Kafka
|

平安保险基于 SPI 机制的 RocketMQ 定制化应用

本文讲讲述平安保险为何选择 RocketMQ,以及在确定使用消息中间件后,又是如何去选择哪款消息中间件的。

333 0
|
消息中间件 监控
|

十五、.net core(.NET 6)搭建RabbitMQ消息队列生产者和消费者的简单方法

搭建RabbitMQ简单通用的直连方法 如果还没有MQ环境,可以参考上一篇的博客: https://www.cnblogs.com/weskynet/p/14877932.html

1427 0
|
消息中间件 安全 调度
|

消息队列RocketMQ应对双十一流量洪峰的“六大武器”

消息队列 RocketMQ 是如何帮助各企业交易系统扛住瞬间千万级 TPS、万亿级流量洪峰的冲击,并保持各个应用之间的消息通畅的呢?下文将为您介绍消息队列 RocketMQ 应对双十一流量洪峰的“六大武器”。

268 0
|
消息中间件 数据采集 运维
|

告别Kafka Stream,让轻量级流处理更加简单

还在花精力去选型Kafka组件去做清洗转化?来试试Kafka ETL任务功能!

433 0
|
人工智能 运维 Cloud Native
|

15年云原生实践,在关键节点我们做对了什么? | 云原生大咖说

今天,数字化成为企业的核心竞争力,千行百业都在拥抱云计算,拥抱云原生。2020 年我们认为是云原生的落地元年,那么 2021 年将是云原生加速推动企业数字创新的关键节点。阿里巴巴拥有 15 年云原生实践历程,在数字经济的背景下,企业如何通过云原生实现应用云化,充分发挥云的价值,快速激活数字创新能力?

707 0
|
消息中间件 Java 中间件
|

如何在 Spring 生态中玩转 RocketMQ?

RocketMQ 作为业务消息的首选,在消息和流处理领域被广泛应用。而微服务生态 Spring 框架也是业务开发中最受欢迎的框架,两者的完美契合使得 RocketMQ 成为 Spring Messaging 实现中最受欢迎的消息实现。本文展示了 5 种在 Spring 生态中文玩转 RocketMQ 的方式,并描述了每个项目的特点和使用场景。

417 0
|
消息中间件 关系型数据库 MySQL
|

5. 消息队列中,如何保证消息的顺序性?

5. 消息队列中,如何保证消息的顺序性?

822 0
|
消息中间件 缓存 容灾
|

22. 为什么需要消息队列?使用消息队列有什么好处?

22. 为什么需要消息队列?使用消息队列有什么好处?

318 0
|
消息中间件 JavaScript 前端开发
|

js的EventLoop事件循环机制调用栈、微任务、消息队列执行顺序优先级

js的EventLoop事件循环机制调用栈、微任务、消息队列执行顺序优先级

106 0
|
消息中间件 JavaScript 前端开发
|

js的EventLoop事件循环机制调用栈、微任务、消息队列执行顺序优先级

js的EventLoop事件循环机制调用栈、微任务、消息队列执行顺序优先级

166 0
|
消息中间件 JavaScript 前端开发
|

js的EventLoop事件循环机制调用栈、微任务、消息队列执行顺序优先级

js的EventLoop事件循环机制调用栈、微任务、消息队列执行顺序优先级

183 0
|
消息中间件 存储 数据可视化
|

[原创]SpringBoot整合RocketMQ消息队列

[原创]SpringBoot整合RocketMQ消息队列

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

消息队列系列1 - 如何选型

消息队列目前主要2种模式,分别为“点对点模式”和“发布/订阅模式”。

530 0
|
消息中间件 Java
|

消息队列---RabbitMQ深入研究(含Springboot+RabbitMQ整合)(三)

消息队列---RabbitMQ深入研究(含Springboot+RabbitMQ整合)

243 0
|
消息中间件
|

消息队列---RabbitMQ深入研究(含Springboot+RabbitMQ整合)(二)

消息队列---RabbitMQ深入研究(含Springboot+RabbitMQ整合)

231 0
|
消息中间件 安全 JavaScript
|

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

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

491 0
|
消息中间件 SQL 开发框架
|

AspNetCore结合Redis实践消息队列

这是年中首发在博客园上的文章,个人觉得是AspNetCore结合Redis做的一次比较优秀的消息队列重构,其中对于点对点/发布-订阅的思路应该也是面试必考题。

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

Redis消息队列发展历程

Redis是目前最受欢迎的kv类数据库,当然它的功能越来越多,早已不限定在kv场景,消息队列就是Redis中一个重要的功能。Redis从2010年发布1.0版本就具备一个消息队列的雏形,随着10多年的迭代,其消息队列的功能也越来越完善,作为一个全内存的消息队列,适合应用与要求高吞吐、低延时的场景。本文将来盘一下Redis消息队列功能的发展历程,历史版本有哪些不足,后续版本是如何来解决这些问题的。

1502 2
|
消息中间件 Android开发
|

【Android 异步操作】HandlerThread 示例 ( 初始化并执行 | 获取Looper | 获取 Handler | 获取消息队列 | 设置空闲队列 | 代码示例 )

【Android 异步操作】HandlerThread 示例 ( 初始化并执行 | 获取Looper | 获取 Handler | 获取消息队列 | 设置空闲队列 | 代码示例 )

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

一个最简单的消息队列,带你理解 RabbitMQ!

RabbitMQ 简述

409 0
|
消息中间件 存储 算法
|

消息队列面试解析系列(七)- 数据压缩(上)

消息队列面试解析系列(七)- 数据压缩

265 0
|
消息中间件 Java Kafka
|

该如何选择消息队列?

在高并发业务场景下,消息队列在流量削峰、解耦上有不可替代的作用。当前使用较多的消息队列有 RabbitMQ、RocketMQ、ActiveMQ、Kafka、ZeroMQ、Pulsar 等。 消息队列这么多,到底该选择哪款消息队列呢? 选择消息队列的基本标准 虽然这些消息队列在功能和特性方面各有优劣,但我们在选择的时候要有一个基本标准。

2191 0
|
消息中间件 Go 网络协议
|

剖析nsq消息队列(一) 简介及去中心化实现原理

分布式消息队列nsq,简单易用,去中心化的设计使nsq更健壮,nsq充分利用了go语言的goroutine和channel来实现的消息处理,代码量也不大,读不了多久就没了。后期的文章我会把nsq的源码分析给大家看。

1809 0
|
消息中间件 数据库
|

消息队列事务型消息原理浅析

在分布式系统架构中,尤其是金融级业务应用的解决方案设计中,消息队列提供 “事务型消息” 特性是必不可少的,“数据一致性” 是金融级分布式架构的基本要求。

1016 0
我要发布