c 消息服务器-c 消息服务器文档介绍内容-阿里云

产品架构

集群级别的高可用，是云消息队列 RocketMQ 版跟其他的消息服务器的主要区别，消息生产者发送一条消息到消息服务器，消息服务器会随机的选择一个消费者，只要这个消费者消费成功就认为是成功了。重要文中所提及的云消息队列 RocketMQ 版...

签名鉴权模式

签名计算方式按照鉴权概述的描述，如果选择签名校验模式，MQTT客户端实际连接MQTT消息服务器时，connect 报文中的Username和Password需要按照本文约定的规范设置，具体设置和计算方法如下：Username 由鉴权模式名称、AccessKeyId和...

签名鉴权模式

签名计算方式按照鉴权概述的描述，如果选择签名校验模式，MQTT客户端实际连接MQTT消息服务器时，connect 报文中的Username和Password需要按照本文约定的规范设置，具体设置和计算方法如下。Username 由鉴权模式名称、AccessKey ID和...

普通消息

普通消息是指云消息队列 RocketMQ 版中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。说明您在调用SDK收发消息时需注意，云消息队列 RocketMQ 版提供的四种消息类型所对应的Topic不能混用，例如，您创建的普通消息...

定时和延时消息

概念介绍定时消息：Producer将消息发送到云消息队列 RocketMQ 版服务端，但并不期望立马投递这条消息，而是推迟到在当前时间点之后的某一个时间投递到Consumer进行消费，该消息即定时消息。延时消息：Producer将消息发送到云消息队列 ...

概述

本文主要介绍如何使用开源社区发布的rocketmq-client-cpp二进制包进行部署和连接阿里云云消息队列 RocketMQ 版的过程。...使用C++ SDK收发消息 C++ SDK支持收发以下消息：收发普通消息收发顺序消息收发事务消息收发定时和延时消息

顺序消息

顺序消息可以保证消息的消费顺序和发送的顺序一致，即先发送的先消费，后发送的后消费，常用于金融证券、电商业务等对消息指令顺序有严格要求的场景。本文介绍云消息队列 RocketMQ 版顺序消息的概念、适用场景、实现原理以及使用过程中的...

事务消息

半事务消息：暂不能投递的消息，生产者已经成功地将消息发送到了云消息队列 RocketMQ 版服务端，但是云消息队列 RocketMQ 版服务端未收到生产者对该消息的二次确认，此时该消息被标记成“暂不能投递”状态，处于该种状态下的消息即半...

OnsMessageGetByMsgId-通过MsgId查询消息

1E0578FE110F18B4AAC235C0C8460BA2 StoreHost string 存储该消息的服务器实例。11.220.*.*:10911 Topic string 消息的 Topic。test-mq_topic PropertyList object[]消息属性列表。Value string 消息属性的值。TagA Name string 消息属性。...

一机一密概述

计算方式按照鉴权概述的描述，如果选择一机一密鉴权模式，MQTT客户端实际连接MQTT消息服务器时，connect 报文中的Username和Password需要按照本文约定的规范设置，具体设置和计算方法如下：Username 由鉴权模式名称、DeviceAccessKeyId...

产品架构

本文介绍云消息队列 Kafka 版的系统架构和发布/订阅模型。云消息队列 Kafka 版系统架构如云消息队列 Kafka 版的系统架构所示，一个云消息队列 Kafka 版集群包括Producer、Kafka Broker、Group、ZooKeeper。图 1.云消息队列 Kafka ...

Token鉴权概述

MQTT客户端按照规范将Token作为参数设置，连接MQTT服务器，服务端验证通过后客户端即可正常收发消息。客户端正常收发消息。如果服务端判断Token失效，即会触发鉴权失败，断开连接，客户端应该重新发起申请Token的请求。客户端行为约束必须...

Token鉴权概述

MQTT客户端按照规范将Token作为参数设置，连接MQTT服务器，服务端验证通过后客户端即可正常收发消息。客户端正常收发消息。如果服务端判断Token失效，即会触发鉴权失败，断开连接，客户端应该重新发起申请Token的请求。客户端行为约束客户...

自定义鉴权模式

MQTT服务器云消息队列 MQTT 版权限认证和消息收发服务器，用来处理应用服务器发起的鉴权相关的请求以及消息收发业务。使用说明无论使用何种鉴权模式，本质上可以归结为身份认证和资源权限两个基本功能。身份认证，即客户端的身份标识，...

新零售电子价签解决方案（MQTT）

MQTT服务器云消息队列 MQTT 版提供的MQTT协议交互的服务端节点，用于接收消息并转发消息。MQTT客户端用于和MQTT服务器交互的节点，本方案中特指发送或接收价格变更消息的智能AP。P2P消息云消息队列 MQTT 版在标准的MQTT协议基础上提供...

OnsMessageDetail-查询消息详细信息

1E0578FE110F18B4AAC235C05F2*StoreHost string 存储该消息的服务器实例。11.220.*.*:10911 Topic string 消息所属的 Topic。test-mq_topic PropertyList object[]消息属性列表。Value string 消息属性的取值。MSG_REGION Name string 消息...

消息加密传输

本文介绍如何进一步提高您与 消息服务MNS 服务之间的网络链路上的安全性。背景信息 消息服务MNS 提供在公网HTTPS上进行消息加密传输的服务。对于包含敏感信息的消息，进一步提高您与阿里云服务之间的网络链路上的安全性，目前有以下两种...

OnsMessageGetByKey-根据Message Key查询消息

1E0578FE110F18B4AAC235C05F2*StoreHost string 存储该消息的服务器实例。11.193.*.*:10911 Topic string 消息的 Topic。test-mq_topic PropertyList object[]消息属性列表。Value string 消息属性的取值。TagA Name string 消息属性。取值...

名词解释

MQTT服务器云消息队列 MQTT 版提供的MQTT协议交互的服务端节点，用于完成与MQTT客户端和云消息队列 RocketMQ 版各自的消息收发。MQTT客户端用于和MQTT服务器交互的移动端节点，全称为云消息队列 MQTT 版客户端。P2P消息云消息队列 ...

云消息队列 Kafka 版何时删除旧消息？

当往Kafka Topic中写入数据提示磁盘空间已满或 Queue full 时，为避免因磁盘容量不足而导致机器宕机，进而影响服务可用性，云消息队列 Kafka 版会根据磁盘使用率的多少，执行不同的消息清理策略。清理策略磁盘使用率每天凌晨4:00集中删除...

OnsMessagePageQueryByTopic-查询Topic内所有消息

1E0578FE110F18B4AAC235C05F2*StoreHost string 存储该消息的服务器实例。11.193.*.*:10911 Topic string 消息的 Topic。test-mq_topic PropertyList object[]消息属性列表。Value string 消息属性的取值。TagA Name string 消息属性。取值...

查询Group ID内所有死信消息

1E0578FE110F18B4AAC235C05F2*StoreHost string 存储该消息的服务器实例。11.193.*.*:10911 Topic string 消息的 Topic。test-mq_topic PropertyList object[]消息属性列表。Value string 消息属性的取值。TagA Name string 消息属性。取值...

收发事务消息

当步骤1半事务消息发送完成，但本地事务返回状态为 TransactionStatus.Unknow 时，亦或是应用退出导致本地事务未提交任何状态时，从Broker的角度看，这条半状态的消息的状态是未知的，因此Broker会定期向消息发送方即消息生产者集群中的...

音视频通信解决方案（MQTT）

MQTT服务器云消息队列 MQTT 版提供的MQTT协议交互的服务端节点，用于完成与MQTT客户端和云消息队列 RocketMQ 版各自的消息收发。MQTT客户端用于和MQTT服务器交互的移动端节点，本方案中特指发送或接收音视频通话请求的音视频移动端...

收发事务消息

本文提供使用TCP协议下的社区版Java SDK收发事务消息的示例代码供您参考。交互流程事务消息交互流程如下图所示。更多信息，请参见事务消息。前提条件您已完成以下操作：下载4.5.2或以上版本的社区版 Java SDK。准备工作。获取阿里云访问...

直播互动解决方案

MQTT服务器云消息队列 MQTT 版提供的MQTT协议交互的服务端节点，用于完成与MQTT客户端和云消息队列 RocketMQ 版各自的消息收发。MQTT客户端用于和MQTT服务器交互的移动端节点，全称为云消息队列 MQTT 版客户端。父级Topic（Parent ...

迁移数据上云

bin/kafka-consumer-groups.sh-new-consumer-describe-bootstrap-server自建集群接入点-group test-consumer-group 往自建集群中发送消息，在云消息队列 Kafka 版控制台中查看Topic的分区状态，确认当前服务器上消息总量是否正确。...

云存储网关利用MQTT服务实现统一管控

MQTT服务器云消息队列 MQTT 版提供的MQTT协议交互的服务端节点，用于接收消息并转发消息。MQTT客户端用于和MQTT服务器交互的节点，本方案中特指CSG实例侧的客户端。RDS 阿里云推出的一种稳定可靠、可弹性伸缩的在线数据库服务。SLS 阿里...

如何处理不活跃的Topic

当前服务器上消息总量（TotalCount）消息最后更新时间（LastTimeStamp）一般情况下，如果消息总量为0，说明Topic不活跃。一般情况下，如果消息最后更新时间是很久之前的有效时间戳，说明Topic不活跃。说明如果消息最后更新时间为0或者负值...

OnsDLQMessageGetById-根据Message ID查询死信消息

0BC16699165C03B925DB8A404E2D*StoreHost string 存储该消息的服务器实例。11.220.*.*:10911 Topic string 消息的 Topic。test-mq_topic PropertyList object[]消息属性列表。Value string 消息属性的取值。TagA Name string 消息属性。...

准备环境

在使用C#SDK收发消息前，您需按照本文提供的内容来准备环境。环境要求安装.NET。更多信息，请参见安装.NET 。安装Visual Studio 2015或以上版本，更多信息，请参见安装Visual Studio。安装完成后，您可以执行 dotnet-version 命令查看....

如何配置客户端参数？

达到设置的数值时，就会触发一次网络请求，然后Producer客户端把消息批量发往服务器。如果 batch.size 设置过小，有可能影响发送性能和稳定性。建议保持默认值16384。单位：字节。linger.ms 每条消息在缓存中的最长时间。若超过这个时间，...

消息存储和清理机制

背景信息参考云消息队列 RocketMQ 版中队列的定义，消息按照达到服务器的先后顺序被存储到队列中，理论上每个队列都支持无限存储。但是在实际部署场景中，服务端节点的物理存储空间有限，消息无法做到永久存储。因此，在实际使用中...

发布者最佳实践

本文介绍云消息队列 Kafka 版发布者的最佳实践，帮助您降低发送消息的错误率。本文最佳实践基于Java客户端。对于其他语言的客户端，其基本概念与思想是相通的，但实现细节可能存在差异。发送消息发送消息的示例代码如下：Future...

请求签名机制

如果请求时间和 消息服务MNS 服务器时间相差超过15分钟，消息服务MNS 会判定此请求不合法，返回错误码400。更多错误信息及错误码，请参见错误响应格式。CanonicalizedMNSHeaders：HTTP中的 x-mns-开头的字段组合。该字段在签名验证前需要...

接口和参数说明

云消息队列 RocketMQ 版提供Java SDK实现消息发送与订阅，订阅方可通过Push或Pull的方式从云消息队列 RocketMQ 版获取消息。本文介绍消息发送和订阅的接口和参数说明。背景信息云消息队列 RocketMQ 版支持以下两种消息获取方式：Push...

订阅关系一致

正确示例代码一 C1、C2、C3的订阅关系一致，即C1、C2、C3订阅消息的代码必须完全一致，代码示例如下：Properties properties=new Properties();properties.put(PropertyKeyConst.GROUP_ID,"GID_test_1");Consumer consumer=ONSFactory....

部署高可用架构应用集群

本示例中将创建两台轻量应用服务器作为应用服务器（本文中简称服务器A 和服务器B），创建一台轻量应用服务器作为数据库服务器（本文中简称 服务器C）。轻量应用负载均衡：默认采用HTTP协议（目前不支持HTTPS协议），监听80端口，且转发...

创建资源

您可创建不同的Topic来发送不同类型的消息，例如用Topic A发送普通消息，Topic B发送事务消息，Topic C发送定时和延时消息。在实例所在页面的左侧导航栏，单击 Topic 管理。在 Topic 管理页面，单击创建 Topic。在创建 Topic 面板，输入...

创建资源

您可创建不同的Topic来发送不同类型的消息，例如用Topic A发送普通消息，Topic B发送事务消息，Topic C发送定时和延时消息。在实例所在页面的左侧导航栏，单击 Topic 管理。在 Topic 管理页面，单击创建 Topic。在创建 Topic 面板，输入...

c 消息服务器

新品推荐