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

云消息队列

关注

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

0
今日
3748
内容
16
活动
2384
关注
|
消息中间件 API C++
|

细说UI线程和Windows消息队列

在 Windows应用程序中,窗体是由一种称为“ UI线程( User Interface Thread)”的特殊类型的线程创建的。        首先, UI线程是一种“线程”,所以它具有一个线程应该具有的所有特征,比如有一个线程函数和一个线程 ID。

1346 0
|
消息中间件 C语言
|

POSIX和SYSTEM的消息队列应该注意的问题

首先看看POSIX的代码: 1.posix_mq_server.c #include #include #include #include #define MQ_FILE "/mq_test"#define BUF_LEN 128 int main(){     mqd_t mqd;  ...

1187 0
|
消息中间件 Linux
|

Linux IPC实践(7) --Posix消息队列

1. 创建/获取一个消息队列 #include /* For O_* constants */ #include /* For mode constan...

1078 0
|
消息中间件 开发工具 Windows
|

深入浅出Win32多线程设计之MFC的多线程-线程与消息队列(经典)

1、创建和终止线程   在MFC程序中创建一个线程,宜调用AfxBeginThread函数。该函数因参数不同而具有两种重载版本,分别对应工作者线程和用户接口(UI)线程。   工作者线程 CWinThread *AfxBeginThread( AFX_THREADPROC pfnThreadP...

1435 0
|
消息中间件 API C++
|

细说UI线程和Windows消息队列(经典)

在Windows应用程序中,窗体是由一种称为“UI线程(User Interface Thread)”的特殊类型的线程创建的。   首先,UI线程是一种“线程”,所以它具有一个线程应该具有的所有特征,比如有一个线程函数和一个线程ID。

1276 0
|
消息中间件 Windows
|

Windows消息队列

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

2167 0
|
消息中间件 Android开发
|

Handler详解系列(二)——主线程向自身消息队列发消息

MainActivity如下:package cc.c; import android.os.Bundle; import android.os.

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

POSIX 消息队列

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

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

艾伟_转载:消息队列(Message Queue)简介及其使用

消息队列(Message Queue)简介及其使用 利用 MSMQ(Microsoft Message Queue),应用程序开发人员可以通过发送和接收消息方便地与应用程序进行快速可靠的通信。消息处理为您提供了有保障的消息传递和执行许多业务处理的可靠的防故障方法。

1284 0
|
消息中间件 Python API
|

beanstalkd 消息队列的第一手资料

1046 0
x3d
|
消息中间件 PHP 数据库
|

【转】持久化消息队列之MEMCACHEQ

G MEMCACHEQ AS MESSAGE QUEUE PHP,消息队列,MEMCACHEQ 使用消息队列(MESSAGE QUEUE)可以把某些耗时的工作推后,然后在后台慢慢地去执行,这样就不会让你的用户等待太久。

1243 0
|
消息中间件
|

进程间通信:消息队列

http://blog.csdn.net/ljianhui/article/details/10287879   #include #include #include int msgget(key_t key, int flag);int msgsnd(int msqid, const void *...

892 0
|
消息中间件 Linux 开发工具
|

Linux进程间通信之消息队列

  马上过年了,心里万般滋味。。。    一,消息队列 1,概念:“消息队列”是在消息的传输过程中保存消息的容器   2,消息队列就是一个消息的链表。可以把消息看作一个记录,具有特定的格式以及特定的优先级。

2251 0
|
消息中间件 Linux Windows
|

Linux IPC实践(5) --System V消息队列(2)

消息发送/接收API msgsnd函数 int msgsnd(int msqid, const void *msgp, size_t msgsz, int msgflg); 参数    ms...

891 0
|
消息中间件
|

消息队列七

使用.net客户端连接到Kafka 这里推荐使用一个开源.net客户端:https://github.com/Jroland/kafka-net Producer 1 var options = new KafkaOptions(new Uri("http://SERVER1:90...

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

消息队列一览

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

1038 0
|
消息中间件 Windows SQL
|

SSIS常用的包—消息队列任务

  通过消息队列任务可以从Microsoft Message Queuing (MSMQ)中接收或向它发送消息。消息的格式可以是字符串,文件或者变量。消息队列任务的优点是你可以在package正在运行的时候相互通信。

1293 0
|
消息中间件
|

消息队列

928 0
|
消息中间件
|

消息队列一

为什么要用Message Queue 解耦 在项目启动之初来预测将来项目会碰到什么需求,是极其困难的。消息队列在处理过程中间插入了一个隐含的、基于数据的接口层,两边的处理过程都要实现这一接口。这允许你独立的扩展或修改两边的处理过程,只要确保它们遵守同样的接口约束 冗余 有时在处理数据的时候处理过程会失败。

785 0
|
消息中间件 Java Spring
|

消息队列AMQP Spring Boot发送延时消息

消息队列AMQP Spring Boot发送延时消息

1007 0
|
消息中间件 算法
|

剖析nsq消息队列(四) 消息的负载处理

剖析nsq消息队列-目录 实际应用中,一部分服务集群可能会同时订阅同一个topic,并且处于同一个channel下。当nsqd有消息需要发送给订阅客户端去处理时,发给哪个客户端是需要考虑的,也就是我要说的消息的负载。

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

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

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

24877 10
|
消息中间件 传感器 网络协议
|

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

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

1249 0
|
消息中间件 存储 监控
|

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

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

3304 0
|
消息中间件 Kubernetes Java
|

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

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

2296 2
|
消息中间件 存储 Kafka
|

在Windows系统上安装消息队列kafka

在Windows系统上安装消息队列kafka

2043 0
|
消息中间件 存储 安全
|

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

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

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

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

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

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

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

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

142929 3
|
消息中间件 存储 缓存
|

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

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

1861 0
|
消息中间件 Java RocketMQ
|

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

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

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

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

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

7753 0
|
消息中间件 SQL 存储
|

阿里云物联网平台设备数据转发到消息队列RocketMQ全链路测试

本文从物联网平台的产品及设备的创建开始,逐步介绍整个链路的完整实现。

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

深入理解RocketMQ广播消费

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

2103 1
|
域名解析 消息中间件 Kubernetes
|

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

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

496 0
|
消息中间件 运维 监控
|

使用钉钉机器人监控DataWorks/消息队列Kakfa/实时计算Flink任务

我们写的数仓任务、Flink任务提交任务缺少对任务运行情况监控报警,这里可以使用钉钉自带的机器人实现钉钉群任务告警功能

1393 0
|
消息中间件 负载均衡 网络协议
|

多维度对比5款主流分布式MQ消息队列

从17个维度综合对比Kafka、RabbitMQ、ZeroMQ、RocketMQ、ActiveMQ这5款当前最主流的MQ消息中间件产品,希望能为您的下一次产品的架构设计和MQ消息中间件选型提供参考依据。

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

如何设计一个消息队列?

**如果让你来设计一个 MQ,该如何下手?需要考虑哪些问题?又有哪些技术挑战?** 对于 MQ 来说,不管是 RocketMQ、Kafka 还是其他消息队列,**它们的本质都是:一发一存一消费。**下面我们以这个本质作为根,一起由浅入深地聊聊 MQ。

2076 2
|
消息中间件 物联网 Kafka
|

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

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

491 1
|
消息中间件 API
|

HarmonyOS系统内核中消息队列的实现

大家好,今天主要来聊一聊,如何使用HarmonyOS开发实现消息队列。

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

什么是消息队列?

笔记

313 0
|
消息中间件 Java API
|

消息队列 MQ产品使用合集之遇到"No topic route info in name server for the topic"错误,该如何处理

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

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

如何在 Spring 生态中玩转 RocketMQ?

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

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

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

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

765 1
|
消息中间件 微服务
|

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

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

4702 0
|
消息中间件 SQL 容灾
|

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

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

109303 287
|
消息中间件 监控 Kafka
|

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

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

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

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

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

2118 0
我要发布