阿里云消息订阅-阿里云消息订阅文档介绍内容-阿里云

什么是服务端订阅

说明如果您有多个服务器消费同一个产品的订阅消息，消息会随机转发至某个服务器。服务端订阅与规则引擎数据流转的使用场景和能力对比，请参见数据流转方案对比。使用AMQP服务端订阅消息 AMQP（Advanced Message Queuing Protocol）即高级...

什么是云消息队列 MQTT 版

消费者：也称为消息订阅者，负责从Topic接收并消费消息。消息：生产者向Topic发送并最终传送给消费者的数据。规则：云消息队列 MQTT 版与其他阿里云产品实现数据互通的资源。消息收发模型云消息队列 MQTT 版主要包含以下两种消息收发...

收发事务消息

本文提供使用TCP协议下的Java SDK收发事务消息的示例代码。云消息队列 RocketMQ 版提供类似XA或Open XA的分布式事务功能，通过云消息队列 RocketMQ 版事务...订阅事务消息事务消息的订阅与普通消息订阅一致，更多信息，请参见 订阅消息。

设置资源包预警

本文介绍如何设置资源包余量预警阈值并订阅通知消息。设置资源包余量预警设置资源包余量预警后，则当资源包剩余一定额度时，会通过短信、邮箱或站内信方式向账号联系人推送通知。登录全站加速控制台。单击顶部菜单栏的费用，进入阿里云...

概述

消费者：也称为消息订阅者，负责从 Topic 接收并消费消息。消息：生产者向 Topic 发送并最终传送给消费者的数据和（可选）属性的组合。消息属性：生产者可以为消息定义的属性，包含 Message Key 和 Tag。Group：一类生产者或消费者，这类...

收发事务消息

本文提供使用 TCP 协议下的 Java SDK 收发事务消息的示例代码供您参考。消息队列提供类似 X/Open XA 的分布式事务功能，通过消息队列事务消息，能达到分布式事务的...订阅事务消息事务消息的订阅与普通消息订阅一致，详情请参见 订阅消息。

认证与连接

主动发送的消息，或者订阅/取消订阅消息有结果后会回调该消息*/void demo_result_callback(void*device,const aiot_device_msg_result_t*result,void*userdata){ switch(result->type){ case AIOT_DEVICE_SEND_MESSAGE_RESULT:{ printf(...

消息收发功能

支持消息发送、消息订阅以及接收终端SDK上下线事件消息。终端和终端消息收发该场景下消息的发送端和消费端都分布在移动终端环境，通过MQTT协议连接到云消息队列 MQTT 版。发送端和消费端的终端设备均通过开源的终端SDK接入云消息队列 ...

示例代码

本文为您介绍RocketMQ 5.x...示例代码函数说明消息类型发送消息示例代码 订阅消息示例代码（SimpleConsumer）普通消息 ProducerNormalMessageExample.cs SimpleConsumerExample.cs 顺序消息 ProducerFifoMessageExample.cs 定时/延时消息 ...

实例规格

Java SDK Pull方式订阅消息 支持 Java SDK Pull方式订阅消息，请参见 订阅消息。不支持消息轨迹支持消息轨迹，请参见查询消息轨迹。支持容灾高可用说明可用区由服务端部署资源控制，不支持自定义配置。服务：多可用区数据：三副本 ...

示例代码

消息类型发送消息示例代码 订阅消息示例代码（SimpleConsumer）普通消息同步发送：ExampleProducerNormalMessage.go 异步发送：AsyncExampleProducerNormalMessage.go ExampleSimpleConsumer.go 顺序消息 ExampleProducerWithFifoMessage...

收发事务消息

本文提供使用TCP协议下的C/C++ SDK收发事务消息的示例代码供您参考。云消息队列 RocketMQ 版提供类似XA或Open XA的分布式事务功能，通过云消息队列 RocketMQ...订阅事务消息事务消息的订阅与普通消息订阅一致，更多信息，请参见 订阅消息。

用户身份识别

读取：表示被授予权限的ACL用户拥有指定Topic或Group的消息订阅权限。写入 IP白名单设置允许访问资源的客户端IP地址或IP地址段，多个IP地址或地址段之间以英文分号;或者逗号（,）隔开。若不设置，则表示不对客户端IP地址进行限制。192.168...

收发事务消息

目前支持的地域包括公网、华东1（杭州）、华北2（北京）、华东2（上海）、华南1（深圳）。云消息队列 RocketMQ 版提供类似XA或Open XA的分布式事务功能，通过...订阅事务消息事务消息的订阅与普通消息订阅一致，更多信息，请参见 订阅消息。

使用国密算法接入云网关

主动发送的消息，或者订阅/取消订阅消息有结果后会回调该消息*/void demo_result_callback(void*device,const aiot_device_msg_result_t*result,void*userdata){ switch(result->type){ case AIOT_DEVICE_SEND_MESSAGE_RESULT:{ printf(...

添加订阅配置

标准协议：按照标准化的参数结构要求输出消息订阅内容，由第三方应用依照自身业务诉求自主进行信息订阅和消费，一般格式是http://，用户可在第三方地址上对监控任务按订阅模板告警。语音通知：通过语音通知实现订阅监控。短信通知：通过...

添加订阅配置

标准协议：按照标准化的参数结构要求输出消息订阅内容，由第三方应用依照自身业务诉求自主进行信息订阅和消费，一般格式是http://，用户可在第三方地址上对监控任务按订阅模板告警。语音通知：通过语音通知实现订阅监控。短信通知：通过...

JMS Pub/Sub（主账号与RAM账号）

示例代码请参见非持久订阅消息。如果订阅者创建的是持久订阅，则订阅者必须在发布者向Topic发布消息前订阅Topic，但在订阅后不必始终保持活跃状态，也能从订阅的Topic消费全部的消息。在订阅者处于非活跃状态时发布的消息会在订阅者重新...

基础术语

消息消费者 Consumer 消息消费者，也称为消息订阅者，负责接收并消费消息。Consumer 实例 Consumer instance Consumer 的一个对象实例，不同的 Consumer 实例可以运行在不同进程内或者不同机器上。一个 Consumer 实例内配置线程池消费消息...

开源MQTT迁移至云消息队列 MQTT 版

云端SDK可用于云端分布式应用部署，天然支持共享订阅，并提供消息收发、消息订阅、客户端上下线事件通知等能力，目前支持Java、Go语言的SDK。更多信息，请参见云端开发概述。云端SDK支持在云消息队列 MQTT 版服务端层面进行订阅发布，而...

CreateConsumerGroup-创建消费者分组

消费者需要通过指定消费者分组订阅相关的主题来实现消息订阅。接口说明注意阿里云提供的 OpenAPI 属于管控类 API，用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成，消息收发的核心数据链路中严禁依赖 OpenAPI 实现，否则可能...

产品架构

本文介绍云消息队列 RocketMQ 版的系统部署架构，方便您更好地理解...Consumer既可以从Master Broker订阅消息，也可以从Slave Broker订阅消息，订阅规则由Broker配置决定。更多信息云消息队列 RocketMQ 版中的概念详情，请参见基本概念。

收发顺序消息

} } 订阅顺序消息订阅顺序消息的示例代码如下。using System;using System.Text;using System.Threading;using ons;namespace demo { public class MyMsgOrderListener:MessageOrderListener { public MyMsgOrderListener(){ }~...

收发事务消息

订阅事务消息事务消息的订阅与普通消息订阅一致，如下所示。import java.util.List;import org.apache.rocketmq.acl.common.AclClientRPCHook;import org.apache.rocketmq.acl.common.SessionCredentials;import org.apache.rocketmq....

消息过滤

订阅者：订阅消息Tag。订阅的Tag和发送者设置的消息Tag一致，则消息被投递给消费端进行消费。简单过滤场景。一条消息支持设置一个Tag，仅需要对Topic中的消息进行一级分类并过滤时可以使用此方式。无。无。SQL属性过滤发送者：设置消息的...

企业铂金版计费说明

长轮询方式：若Topic中没有消息，订阅请求会一直在服务端挂起，直到有消息或等待时间（最长30秒）到达后返回响应。服务端有消息返回时，投递消息次数按照以上规则计算，即消息条数乘以对应的高级特性倍率和消息体大小倍率。服务端未返回...

权限策略

AliyunMQSubOnlyAccess 云消息队列 MQTT 版的订阅权限，被授予该权限的RAM用户具有使用阿里云账号所有资源通过SDK订阅消息的权限。AliyunMQReadOnlyAccess 云消息队列 MQTT 版的只读权限，被授予该权限的RAM用户仅有通过访问控制台或调用...

集群消费和广播消费

本文介绍 SOFAStack 消息队列的集群消费和广播消费的基本概念、适用场景以及注意事项。消息队列是基于发布/订阅模型的消息系统。...更多信息集群消费模式和广播消费模式的具体配置方法，请参见以下文档：TCP 协议 Java SDK：订阅消息

基本概念

Consumer 消息消费者，也称为消息订阅者，负责接收并消费消息。可分为两类：Push Consumer：消息由云消息队列 RocketMQ 版推送至Consumer。Pull Consumer：该类Consumer主动从云消息队列 RocketMQ 版拉取消息。目前仅TCP Java SDK支持...

收发顺序消息

} 订阅顺序消息订阅顺序消息的示例代码如下。include"ONSFactory.h"using namespace std;using namespace ons;创建消费消息的实例。pushConsumer拉取到消息后，会主动调用该实例的consumeMessage函数。class ONSCLIENT_API MyMsgListener:...

JMS Pub/Sub（RAM角色跨账号授权场景）

示例代码请参见非持久订阅消息。如果订阅者创建的是持久订阅，则订阅者必须在发布者向Topic发布消息前订阅Topic，但在订阅后不必始终保持活跃状态，也能从订阅的Topic消费全部的消息。在订阅者处于非活跃状态时发布的消息会在订阅者重新...

示例代码

示例代码消息类型发送消息示例代码 订阅消息示例代码 PushConsumer SimpleConsumer 普通消息同步发送：ProducerNormalMessageExample.java 异步发送：AsyncProducerExample.java PushConsumerExample.java 同步订阅：...

消息过滤

只订阅消息标签为“TagA”、“TagB”或“TagC”的消息。FilterExpression filterExpression=new FilterExpression("TagA|TagB|TagC",FilterExpressionType.TAG);pushConsumer.subscribe(topic,filterExpression);订阅消息，匹配Topic中的...

收发普通消息

订阅普通消息订阅普通消息的示例代码如下。const { MQClient }=require('@aliyunmq/mq-http-sdk');设置HTTP协议客户端接入点，进入消息队列RocketMQ版控制台实例详情页面的接入点区域查看。const endpoint="${HTTP_ENDPOINT}";请确保环境...

} } } } 订阅普通消息订阅普通消息的示例代码如下。using System;using System.Collections.Generic;using System.Threading;using Aliyun.MQ.Model;using Aliyun.MQ.Model.Exp;using Aliyun.MQ;namespace Aliyun.MQ.Sample { public ...

收发普通消息

print("Topic not exist,please create it.")sys.exit(1)print("Publish Message Fail.Exception:%s"%e)订阅普通消息订阅普通消息的示例代码如下。from mq_...

收发定时消息和延时消息

} } } } 订阅定时消息或延时消息订阅定时消息或延时消息的示例代码如下。using System;using System.Collections.Generic;using System.Threading;using Aliyun.MQ.Model;using Aliyun.MQ.Model.Exp;using Aliyun.MQ;namespace Aliyun.MQ....

收发定时消息和延时消息

} } 订阅定时消息或延时消息订阅定时消息或延时消息的示例代码如下。import java.util.List;import org.apache.rocketmq.acl.common.AclClientRPCHook;import org.apache.rocketmq.acl.common.SessionCredentials;import org.apache....

收发定时消息和延时消息

if e.type="TopicNotExist":print("Topic not exist,please create it.")sys.exit(1)print("Publish Message Fail.Exception:%s"%e)订阅定时消息或延时消息订阅定时消息或延时消息的示例代码如下。from mq_...

示例代码

} } 订阅普通消息 using System;using System.Threading;using System.Text;using ons;从Broker拉取消息时要执行的回调函数。public class MyMsgListener:MessageListener { public MyMsgListener(){ }~MyMsgListener(){ } public override...

阿里云消息订阅

新品推荐