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

云消息队列

关注

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

0
今日
3759
内容
16
活动
2392
关注
|
消息中间件 Java Kafka
|

使用Java编写代码安装Kafka及启动Zookeeper和Kafka

如何使用Java编写代码安装Kafka及启动Zookeeper和Kafka?其中包括安装前准备、修改配置文件、创建日志目录和数据目录等步骤,请提供详细实现过程。

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

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

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

1044 1
|
消息中间件 存储 中间件
|

一键体验RocketMQ六大环境活动操作手册

中间件产品门槛高?短时间无法深入了解?免费试用+30秒一键体验,低代码,无部署环境,带你了解“历经万亿级数据洪峰考验”的云消息队列RocketMQ。

2365 3
|
消息中间件 监控 API
|

基于个人使用消息队列MQ产品的心得体会

随着互联网技术的不断发展,消息队列MQ(Message Queue)产品已经成为了现代软件架构中非常重要的一部分。这种技术可以通过异步处理来提高系统性能和可靠性,并且它还能够实现不同应用程序之间的解耦。在最近的几个月里,我尝试了使用一些流行的MQ产品进行开发,从而得出了一些有关其优点和缺点的心得体会。

400 2
|
消息中间件 存储 监控
|

MQ的作用及如何解决消息队列的丢失、重复和积压问题

引入 MQ 消息中间件最直接的目的是:做系统解耦合流量控制,追其根源还是为了解决互联网系统的高可用和高性能问题。 系统解耦:用 MQ 消息队列,可以隔离系统上下游环境变化带来的不稳定因素,比如京豆服务的系统需求无论如何变化,交易服务不用做任何改变,即使当京豆服务出现故障,主交易流程也可以将京豆服务降级,实现交易服务和京豆服务的解耦,做到了系统的高可用。

391 0
|
消息中间件 运维 Cloud Native
|

RocketMQ 5.0 API 与 SDK 的演进

RocketMQ 5.0 SDK 采用了全新的 API,使用 gRPC 作为通信层的实现,并在可观测性上做了很大幅度的提升。

654 0
|
消息中间件
|

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

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

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

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

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

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

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

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

537 0
|
消息中间件 监控
|

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

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

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

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

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

281 0
|
消息中间件 监控 Cloud Native
|

数百万台车联网设备同时在线 0 故障,中瑞集团的云原生探索之路

在保持对业界趋势调度关注的同时,始终选用最适合自身的技术,这可能是中瑞能在车联网领域引领行业的重要原因之一,正如中瑞CTO所说“阿里云云原生产品体系带给我们的,不是单纯的IT工具,而是整个团队战斗力的提升”。

387 0
|
消息中间件 存储 RocketMQ
|

消息队列RocketMQ

消息队列RocketMQ

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

常用消息队列 Kafka、RabbitMQ、RocketMQ、ActiveMQ 综合对比(18个方面)

常用消息队列 Kafka、RabbitMQ、RocketMQ、ActiveMQ 综合对比(18个方面)

651 0
|
消息中间件 网络协议 NoSQL
|

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

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

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

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

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

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

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

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

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

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

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

2987 1
|
消息中间件 Java 微服务
|

消息队列面试解析系列(六)- 异步编程妙用(下)

消息队列面试解析系列(六)- 异步编程妙用

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

IoT设备消息洪峰怎么扛? 阿里云AIoT消息队列深度解读

阿里云AIoT作为物联网领域的引领者和创新者,在消息队列领域不断深耕与沉淀,为了让物联网从业者更进一步了解IoT场景队列,阿里云技术专家吕建文,整理了一份IoT队列的干货知识,与大家一同探讨一个适合于物联网系统的消息队列。

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

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

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

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

什么是消息队列Rocket MQ| 《Rocket MQ 使用排查指南》第一章

本章介绍 什么是消息队列Rocket MQ

8687 0
|
消息中间件 网络协议 数据可视化
|

Apache RocketMQ 消息队列部署与可视化界面安装

Apache RocketMQ是一个分布式、队列模型的消息中间件,具有低延迟、高性能和高可靠、万亿级容量和灵活的可扩展性。核心组件由四部分组成:Name Servers,Brokers,Producer 和 Consumer;它们中的每一个都可以水平扩展,而没有单一的故障节点。

3009 0
|
消息中间件 网络协议 物联网
|

微服务消息队列(MQTT For IoT)Android Demo使用介绍

目前阿里云官方对于微消息队列 MQTT提供了很多语言的参考示例,但是在实际的使用中发现很多用户在使用Android Sample的时候总是会遇到问题,无法正常调试使用。本文主要介绍Android Sample的使用。

609 0
|
消息中间件 存储 设计模式
|

数据库必知词汇:消息队列MQ

消息是在两台计算机间传送的数据单位。消息可以非常简单,例如只包含文本字符串;也可以更复杂,可能包含嵌入对象。消息被发送到队列中。消息队列(Message Queue, MQ)是在消息的传输过程中保存消息的容器。消息队列管理器在将消息从它的源中继到它的目标时充当中间人。

1723 0
|
消息中间件 存储 网络协议
|

nsq 优秀的消息队列

简介 NSQ是Go语言编写的,开源的分布式消息队列中间件,其设计的目的是用来大规模地处理每天数以十亿计级别的消息。NSQ 具有分布式和去中心化拓扑结构,该结构具有无单点故障、故障容错、高可用性以及能够保证消息的可靠传递的特征,是一个成熟的、已在大规模生成环境下应用的产品。

6069 1
|
消息中间件 NoSQL Java
|

企业级 SpringBoot 教程-在springboot中用redis实现消息队列

准备阶段 java 1.8 maven 3.0 idea 环境依赖 创建一个新的springboot工程,在其pom文件,加入spring-boot-starter-data-redis依赖: <dependency> <groupId>org.

4306 0
|
消息中间件 NoSQL Kafka
|

主流的消息队列MQ比较,详解MQ的4类应用场景

消息队列已经逐渐成为企业IT系统内部通信的核心手段。它具有低耦合、可靠投递、广播、流量控制、最终一致性等一系列功能,成为异步RPC的主要手段之一。

2980 0
|
消息中间件 监控 安全
|

阿里云即将直播发布消息队列Kafka:全面融合开源生态

在全面兼容Apache Kafka生态的基础上,消息队列Kafka彻底解决Apache Kafka稳定性不足的长期痛点,并且支持消息无缝迁移到云上。

5636 0
|
消息中间件 Java Kafka
|

后端必备——数据通信知识(RPC、消息队列)一站式总结

RPC(Remote Procedure Call)—远程过程调用 ,它是一种通过网络从远程计算机程序上请求服务,而不需要了解底层网络技术的协议。RPC协议假定某些传输协议的存在,如TCP或UDP,为通信程序之间携带信息数据。

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

消息队列ActiveMQ的使用详解

通过上一篇文章 **《消息队列深入解析》**,我们已经消息队列是什么、使用消息队列的好处以及常见消息队列的简单介绍。 这一篇文章,主要带大家详细了解一下消息队列ActiveMQ的使用。 学习消息队列ActiveMQ的使用之前,我们先来搞清**JMS**。

4494 0
|
消息中间件 NoSQL Redis
|

利用Redis 实现消息队列

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

消息队列设计精要

1902 0
|
消息中间件 缓存 监控
|

Aliware-MQ消息队列技术架构与最佳实践

在阿里云生态日,阿里巴巴中间件产品专家不铭分享了《Aliware-MQ消息队列》。他从功能特性、技术架构、最佳实践、案例分析四个方面进行了分享。在分享中,他主要介绍了Aliware-MQ的线性扩展技术、存储模型、负载均衡、数据流、刷盘策略、高可靠/高可用方案进行了介绍,并通过案例进行了具体实践分享。

12907 0
|
消息中间件 编解码
|

消息队列MQ新增3把武器

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

使用阿里云消息队列

9679 1
|
消息中间件
|

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

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

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

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

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

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

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

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

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

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

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

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

消息队列 MQ产品使用合集之启动Namesrv节点时,遇到报错,该如何解决

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

779 0
|
消息中间件 物联网 Kafka
|

消息队列 MQ产品使用合集之QoS 1与QoS 2的主要区别有哪些

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

618 1
|
消息中间件 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
|
消息中间件 Java 测试技术
|

消息队列 MQ操作报错合集之设置了setKeepAliveInterval(1)但仍然出现客户端未连接,该怎么解决

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

280 2
我要发布