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

云消息队列

关注

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

0
今日
3759
内容
16
活动
2392
关注
|
存储 消息中间件 测试技术
|

滴滴出行千亿级消息队列炼成记!

本文整理自滴滴出行消息队列负责人 江海挺 在Apache RocketMQ开发者沙龙北京站的分享。通过本文,您将了解到滴滴出行: 1. 在消息队列技术选型方面的思考; 2. 为什么选择 RocketMQ 作为出行业务的消息队列解决方案; 3. 如何构建自己的消息队列服务; 4. 在 RocketMQ 上的扩展改造实践; 5. 在 RocketMQ 上的实践经验。

1823 0
|
消息中间件 缓存 测试技术
|

消息队列在测试开发中的应用思路

前言: 在面向企业级的运用中,各种中间件被广泛运用,对于多并发的应用,为了解决服务器处理性能的差异问题,普遍使用消息队列作为非实时性(或实时性)请求的转发与控制,一般可用来支持分布式请求系统、事务最终一致性,高吞吐系统,请求缓存池等架构方案。

1681 0
|
消息中间件
|

RabbitMQ消息队列(2):工作队列之消息分发机制

oldriver老司机技术手册 分享 RabbitMQ消息队列(2):工作队列之消息分发机制

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

消息队列软件产品大比拼

导读:本文是从《Message Queue Shootout!》这篇文章翻译而来,译文来自外刊IT评论《消息队列软件产品大比拼》。 内容如下: 我花了一周的时间评估比较了一下各种消息队列产品,非常的有趣。

1518 0
|
消息中间件 NoSQL Java
|

spring mvc redis消息队列

通常情况下,为了提高系统开发的灵活性和可维护度,我们会采用消息队列队系统进行解耦。下面是一个采用spring redis实现的消息队列实例,但此实例会由于网络延迟和阻塞等情况导致消息处理的延时,因而不能确保消息处理的顺序,所以使用时需要注意。

1244 0
|
消息中间件 Linux 机器学习/深度学习
|

POSIX 消息队列

POSIX消息队列与System V消息队列的主要区别:1.对POSIX队列的读总数返回最高优先级到最早消息,对SV队列到读则可以返回任意指定优先级的消息2.当往一个空队列放置一个消息时,POSIX允许产生一个信号或启动一个线程,System V不提供此机制消息的属性:1.

1098 0
|
消息中间件 Python API
|

beanstalkd 消息队列的第一手资料

1135 0
|
消息中间件 JSON Java
|

spring整合消息队列rabbitmq

ps:本文只是简单一个整合介绍,属于抛砖引玉,具体实现还需大家深入研究哈..   1.首先是生产者配置 ? 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 ...

955 0
|
消息中间件
|

消息队列资源包

1664 0
|
消息中间件 安全 大数据
|

消息队列一览

谈谈互联网后端基础设施  http://www.rowkey.me/blog/2016/08/27/server-basic-tech-stack/   service之间的调用方式可以分为同步调用以及异步调用。

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

存储用es,消息队列用redis

自动化确实方便,做微服务再合适不过了,单一jar包部署和管理都非常方便。只要系统架构设计合理,大型项目也能用。最近做的项目,统计中心和推荐系统,collector、calculator、recommendor都是用springboot写,加上nginx负载均衡,轻松实现横向扩展。

1188 0
|
消息中间件 Java API
|

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

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

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

【云原生 | 27】Docker部署运行开源消息队列实现RabbitMQ

AMQP架构中有两个主要组件:Exchange和Queue,两者都在服务端,又称Broker,由RabbitMQ实现的。客户端通常有Producer和Consumer两种类型

619 0
|
消息中间件 SQL canal
|

融合数据库生态:利用 EventBridge 构建 CDC 应用

近期,EventBridge 事件流已经支持了基于阿里云 DTS服务的 CDC 能力。本文将从 CDC、CDC 在 EventBridge 上的应用以及若干最佳实践场景等方面,为大家介绍如何利用 EventBridge 轻松构建 CDC 应用。

680 0
|
消息中间件 Java Kafka
|

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

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

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

秒懂消息队列MQ,万字总结带你全面了解消息队列MQ

消息队列是大型分布式系统不可缺少的中间件,也是高并发系统的基石中间件,所以掌握好消息队列MQ就变得极其重要。接下来我就将从零开始介绍什么是消息队列?消息队列的应用场景?如何进行选型?如何在Spring Boot项目中整合集成消息队列。

26276 10
|
消息中间件 网络协议 开发工具
|

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

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

1017 2
|
消息中间件 Java API
|

阿里云微服务消息队列Token C# 设备端示例Demo

微消息队列 MQTT 版的客户端收发消息时,服务端会根据 MQTT 客户端设置的 Username 和 Password 参数来进行鉴权。目前支持ak,sk通过签名方式认证,也支持通过Token方式进行认证。本文主要介绍基于:Token 使用NET SDK进行设备端连接认证。

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

消息队列系列4 - 原理初探之RocketMQ

RocketMQ是一个纯Java、分布式、队列模型的开源消息中间件,前身是MetaQ,是阿里参考Kafka特点研发的一个队列模型的消息中间件,后开源给apache基金会成为了apache的顶级开源项目,具有高性能、高可靠、高实时、分布式特点。

993 0
|
消息中间件 传感器 网络协议
|

物联网通信消息队列客户端-MQTT简介

物联网通信消息队列客户端-MQTT简介

2011 0
|
消息中间件 Kafka Linux
|

linux如何安装KafKa

linux如何安装KafKa

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

两个实验让我彻底弄懂了「订阅关系一致」

这篇文章,笔者想聊聊 RocketMQ 最佳实践之一:**保证订阅关系一致**。 订阅关系一致指的是同一个消费者 Group ID 下所有 Consumer 实例所订阅的 Topic 、Tag 必须完全一致。 如果订阅关系不一致,消息消费的逻辑就会混乱,甚至导致消息丢失。

1600 1
|
消息中间件 存储 负载均衡
|

消息队列是干什么的?底层原理是什么?

消息队列是干什么的?底层原理是什么?

1872 0
|
消息中间件 运维 Java
|

RocketMQ的常规运维实践应用

RocketMQ的常规运维实践应用

1008 1
|
消息中间件 SQL Java
|

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

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

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

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

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

922 0
|
消息中间件 微服务
|

MQTT X连接阿里云微服务消息队列MQTT

MQTT X 是 EMQ 开源的一款优雅的跨平台 MQTT 5.0 桌面客户端,它支持 macOS, Linux, Windows。MQTT X 的 UI 采用了聊天界面形式,简化了页面操作逻辑,用户可以快速创建连接,允许保存多个客户端,方便用户快速测试 MQTT/MQTTS 连接,及 MQTT 消息的订阅和发布。本文演示如何使用该工具快速连接阿里云微服务消息队列MQTT,并进行消息的发布和订阅测试。

5200 0
|
消息中间件 NoSQL 物联网
|

Redis Stream——作为消息队列的典型应用场景

Redis Stream Redis最新的大版本5.0已经RC1了,其中最重要的Feature莫过于Redis Stream了,关于Redis Stream的基本使用介绍和设计理念可以看我之前的一篇文章(Redis Stream简介)。

37211 151
|
消息中间件 存储 监控
|

消息队列原理和选型:Kafka、RocketMQ 、RabbitMQ 和 ActiveMQ

常用的消息队列主要这 4 种,分别为 Kafka、RabbitMQ、RocketMQ 和 ActiveMQ,主要介绍前三,不BB,上思维导图!

4209 0
|
12月前
|
消息中间件 人工智能 运维
|

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

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

724 102
|
消息中间件 物联网 API
|

消息队列 MQ使用问题之如何在物联网项目中搭配使用 MQTT、AMQP 与 RabbitMQ

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

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

EventBridge 与 FC 一站式深度集成解析

本篇文章通过对 EventBridge 与 FC 一站式深度集成解析和集成场景的介绍,旨在帮助大家更好的了解面对丰富的事件时,如何使用 EventBridge 与 FC 的一站式集成方案,快速基于事件驱动(EDA)架构建云上业务系统。

707 0
|
消息中间件 Java 物联网
|

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

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

2389 0
|
消息中间件 存储 Cloud Native
|

深度剖析 RocketMQ 5.0,架构解析:云原生架构如何支撑多元化场景?

了解 RocketMQ 5.0 的核心概念和架构概览;然后我们会从集群角度出发,从宏观视角学习 RocketMQ 的管控链路、数据链路、客户端和服务端如何交互;学习 RocketMQ 如何实现数据的存储,数据的高可用,如何利用云原生存储进一步提升竞争力。

143514 3
|
消息中间件 存储 安全
|

探索FreeRTOS的功能:线程,消息队列,邮箱,信号量,互斥量,任务通知,延时,虚拟定时器

探索FreeRTOS的功能:线程,消息队列,邮箱,信号量,互斥量,任务通知,延时,虚拟定时器

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

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

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

1198 4
|
消息中间件 NoSQL Java
|

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

SpringBoot整合Redis5.0新特性Redis Stream

1895 0
|
12月前
|
消息中间件 存储 Kafka
|

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

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

693 5
|
存储 消息中间件 NoSQL
|

Redisson源码(二)延迟队列RDelayedQueue的使用及原理分析

Redisson源码(二)延迟队列RDelayedQueue的使用及原理分析

2711 3
|
消息中间件 设计模式 中间件
|

消息队列-Redis-RabbitMQ-Kafka

本文先围绕生产消费者设计模式中最重要的消息队列进行阐述,后期文章在涉及具体的队列,生产者,消费者!

21777 4
|
消息中间件 存储 监控
|

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

第 4 章 RocketMQ应用 七、消息发送重试机制 1 说明 Producer对发送失败的消息进行重新发送的机制,称为消息发送重试机制,也称为消息重投机制。 对于消息重投,需要注意以下几点: 生产

498 0
|
消息中间件 监控 大数据
|

RabbitMQ:什么是消息队列MQ?为什么使用消息队列MQ?入门MQ先学哪种?(一)

MQ(Message Queue):消息队列,如今在各类业务场景中已经被广泛使用,特别在并发量日益增涨的业务和微服务架构中,消息队列能够帮助我们解决很多传统方式所不能解决的问题。 所以今天,我们就开始学习消息队列啦

692 0
|
消息中间件 Cloud Native 大数据
|

云原生 Kafka 问卷调研启动,你的声音很重要!参与赢精美礼品!

Apache Kafka 作为高吞吐的分布式消息系统,支持实时数据采集、传输、存储及处理,广泛应用于日志收集、监控数据聚合、流式数据处理、在线和离线分析等场景,是大数据生态的核心组件。然而,随着云计算的快速发展,传统 Kafka 架构在云环境中的局限性日益凸显。

430 21
|
消息中间件 存储 Java
|

消息队列 MQ使用问题之如何将RocketMQ中某个集群的topic迁移到另一个集群

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

794 0
|
消息中间件 Kubernetes Java
|

MQ产品使用合集之RocketMQ发消息失败了,proxy报connect to null failed如何解决

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

2958 2
|
域名解析 消息中间件 Kubernetes
|

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

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

831 0
|
消息中间件 安全 物联网
|

【IOT】如何创建和使用FreeRTOS消息队列

消息队列

588 0
我要发布