• 关于

    消息队列文档

    的搜索结果

问题

短信消息API的MNS队列消费模式是否支持多个队列同时监听

roger9876 2019-12-01 19:32:19 1038 浏览量 回答数 1

问题

阿里云IOT套件从入门到精通-初级篇之设备上云端并发布消息到服务端

晟哥带你飞 2019-12-01 21:29:24 15681 浏览量 回答数 7

问题

消息服务的队列如何使用?

轩墨 2019-12-01 22:08:37 1080 浏览量 回答数 0

阿里云爆款特惠专场,精选爆款产品低至0.95折!

爆款ECS云服务器8.1元/月起,云数据库低至1.5折,限时抢购!

问题

消息队列 RocketMQ 全新开放 HTTP 协议,以及 7 种多语言客户端支持 文档在哪?

小攻云攻略 2019-12-19 10:27:38 41 浏览量 回答数 2

问题

微消息队列MQTT的SSL连接是否支持双向认证?

游客3porx62jcoafi 2020-02-17 10:49:17 53 浏览量 回答数 1

问题

消息服务的错误码有哪些?

轩墨 2019-12-01 22:10:37 1218 浏览量 回答数 0

问题

.NET 如何通过消息的Message ID进行消息单笔定向消费

渲染的天空 2019-12-01 19:26:10 1087 浏览量 回答数 0

问题

canal 怎么接入 阿里云的 消息队列MQ

bogerj 2019-12-01 19:31:16 850 浏览量 回答数 2

回答

Re用阿里云消息队列的同学们注意了! 消息队列   是 按 每个 topic  每天收费的 技术人员只看  文档 说  可以创建多个 topic     就用api 的方式 创建了  600 多个 topic 妈呀  一天扣我    600 * 2 = 1200 多元     凌晨发现 删除了  600 来个  topic    上午 10点 删除后 还收费    600*2  =1200   多元   总共  花了  3000 多元  很心疼 有一种   花了钱卖了一件没有什么用服务,有点被坑的强烈感觉!    建议大家用消息队列的时    注意看下计费文档

快递哥 2019-12-02 01:11:14 0 浏览量 回答数 0

问题

消息队列服务MQS使用分享

wiwi 2019-12-01 21:08:46 12995 浏览量 回答数 4

问题

消息服务如何查看日志LogService?

轩墨 2019-12-01 22:08:22 1250 浏览量 回答数 0

问题

如何使用python sdk中的sample代码?

轩墨 2019-12-01 22:08:52 1164 浏览量 回答数 0

回答

消息队列 AMQP 版接口调用是向消息队列 AMQP 版 API 的服务端地址发送 HTTP GET 请求,并按照接口说明在请求中加入相应请求参数,调用后系统会返回处理结果。请求及返回结果都使用 UTF-8 字符集进行编码。 请求结构 消息队列 AMQP 版的 API 是 RPC 风格,您可以通过发送 HTTP GET 请求调用消息队列 AMQP 版API。 其请求结构如下: http://Endpoint/?Action=xx&Parameters 其中: Endpoint: 消息队列 AMQP 版 API 的服务接入地址为 amqp-open.aliyuncs.com。 Action:要执行的操作,如调用 ListInstances 查询已创建的消息队列 AMQP 版实例。 Version:要使用的 API 版本,消息队列 AMQP 版的 API 版本是 2019-12-12。 Parameters:请求参数,每个参数之间用“&”分隔。 请求参数由公共请求参数和 API 自定义参数组成。公共参数中包含 API 版本号、身份验证等信息,详情请参见公共参数。 下面是一个调用 ListInstances 接口查询已创建的消息队列 AMQP 版实例的示例。 说明 为了便于您查看,本文档中的示例都做了格式化处理。 https://amqp-open.aliyuncs.com/?Action=ListInstances &Format=JSON &Version=2020-12-12 &Signature=xtC1HBet6MjHTQVZLo%2Fbm4dlJ0s%3D &SignatureMethod=HMAC-SHA1 &SignatureNonce=e7b1f31150be45594905ce6d28561286 &SignatureVersion=1.0 &AccessKeyId=key-test &TimeStamp=2020-02-10T08%3A43%3A05Z …

保持可爱mmm 2020-03-28 20:35:05 0 浏览量 回答数 0

问题

关于MNS队列获取短信回执

游客uhfftlayck2im 2020-09-09 13:38:07 3 浏览量 回答数 0

回答

设备重复收到消息,如何去重? 由于QoS=1的机制是保证最少收到一次消息,所以可能会出现重复收到消息的情况,但重复消息的消息ID是相同的。设备端可以根据消息ID去重。物联网平台也会尽量减少QoS=1时的消息重复发送。 #物联网平台是否会保存消息? 消息一发送到Topic后,物联网平台就会立即将消息转发给订阅了该Topic的设备。 QoS=0时,物联网平台不保存消息。 QoS=1时,消息会保存7天。 服务器端如何获取设备消息? 服务器端可通过以下两种方式获取设备消息。 服务端订阅:使用物联网平台的服务端订阅功能,订阅一个或多个消息类型。物联网平台根据您设置的订阅,将产品下所有设备的该类型消息流转至您的服务器。支持以下两种方式的服务端订阅。 参见AMQP服务端订阅及相关文档,设置使用AMQP SDK接收物联网平台流转的设备消息。参见MNS服务端订阅,设置使用MNS SDK接收物联网平台流转到MNS队列的设备消息。 云产品流转:使用规则引擎的云产品流转功能,通过数据流转规则将指定设备数据流转到消息服务(MNS)的主题或消息队列(RocketMQ)的队列中。服务器通过MNS或RocketMQ SDK接收消息。具体设置操作,请参见云产品流转概述。 配置了MNS服务端订阅。但在控制台上发送消息,MNS的队列中并没有收到该消息,为什么? 在控制台发送的消息和调用云端API发送的消息均属于服务端发送的消息,不会流转到MNS队列,只有设备发出的消息(设备上报的消息、设备上下线的状态通知等)才会流转到MNS队列里。 如何判断MNS服务端收到的消息是来自哪个Topic? 发送到MNS队列中的消息格式:{ “messageid”:”12345”, “messagetype”:”status/upload”, “topic”:”null/topic”, “payload”: {data}, “timestamp”: 1469564576}中有Topic字段。您可根据Topic字段来判断。

剑曼红尘 2020-03-05 09:57:14 0 浏览量 回答数 0

回答

AccessDenied The OwnerId that your Access Key Idassociated to is forbidden for this operation. 403 检查AccessKeyId和AccessKeySecret等配置是否正确 InvalidAccessKeyId The AccessKey Id you provided is not exist. 403 检查AccessKeyId是否正确 InternalError Interal error. 500 系统错误,请联系MNS技术支持 InvalidAuthorizationHeader The Authorization header format is invalid. 400 签名格式不正确,请参见请求签名机制 InvalidDateHeader The Date header format is invalid. 400 Date字段不合法,请参见公共参数 InvalidArgument The XML you provided did not validate against our published schema, cause by Element① Element. 400 XML结构不正确,请参见对应API文档 InvalidArgument The value of Element②should between Low③ and High④ seconds/bytes. 400 参数值非法,请根据提示调整 InvalidDegist The Content-MD5 you specified is invalid. 400 请求Header中Content-MD5不正确 InvalidRequestURL Http request URL format invalid. 400 请求的URL不正确,请参见对应API文档 InvalidQueryString Http request URL contains invalid querystring item “Element⑤”. 400 请求的URL不正确,请参见对应API文档 MalformedXML The XML you provided was not well-formed. 400 XML结构异常,请参见对应API文档 MissingAuthorizationHeader Authorization header is required. 400 请求Header缺少字段,请参见公共参数 MissingDateHeader Date header is required. 400 请求Header缺少字段,请参见公共参数 MissingReceiptHandle ReceiptHandle is required. 400 请求缺少参数,请参见对应API文档 MissingVisibilityTimeout VisibilityTimeout is required. 400 请求缺少参数,请参见对应API文档 MessageNotExist Message not exist. 404 队列中没有可见消息 QueueAlreadyExist The queue you want to create is already exist. 409 同名队列已存在,且请求属性与原有队列属性不同 InvalidQueueName The queue name you provided is invalid. QueueName should start with alpha and contain only alpha, digit or - . 400 队列名称不合法,请参见对应API文档 QueueNameLengthError Queue name length should between 1 and 255. 400 队列名称不合法,请参见对应API文档 QueueNotExist The queue name you provided is not exist. 404 队列不存在,请先创建队列 ReceiptHandleError The receipt handle you provide is not valid. 400 请求参数不合法,请参见对应API文档 SignatureDoesNotMatch The request signature we calculated does not match the signature you provided. Check your key and signing method. 403 请求签名异常,请参见请求签名机制 TimeExpired The http request you sent is expired. 408 请求时间与MNS服务器时间相差超过15分钟,建议检查本地时间 QpsLimitExceeded The qps limit of the queue is exceeded ⑥ 400 队列每秒的请求次数超过QPS限制,如果需要提高QPS限制,请联系MNS技术支持 TopicAlreadyExist The topic you want to create already exists. 409 同名主题已存在,且请求属性与原有主题属性不同 TopicNameInvalid The topic name you provided is invalid. TopicName should start with alpha or digit and contain only alpha, digit or -. 400 主题名称不合法,请参见对应API文档 TopicNameLengthError Topic name length is out of range, should be between 1 and 255. 400 主题名称不合法,请参见对应API文档 TopicNotExist The Topic you provided does not exist. 404 主题不存在,请先创建主题 SubscriptionNameInvalid The subscription name you provided is invalid. SubscriptionName should start with alpha or digit and contain only alpha, digit or -. 400 订阅名称不合法,请参见对应API文档 SubscriptionNameLengthError Subscription name length is out of range, should be between 1 and 255. 400 订阅名称不合法,请参见对应API文档 SubscriptionNotExist The subscription you provided does not exist. 404 订阅不存在,请先创建订阅 SubscriptionAlreadyExist The subscription you want to create already exists. 409 同名订阅已经存在,且请求属性与原有订阅属性不同 EndpointInvalid The format of endpoint you provided is invalid. 400 Endpoint参数不合法,请参见Endpoint InvalidArgument The length of message should not be larger than MaximumMessageSize. 400 消息体过长,请参见对应API文档 说明 ①②表示在请求内容的XML元素名称 ③表示在MNS中某个参数的下限值 ④表示在MNS中某个参数的上限值 ⑤表示在URL请求中QueryString的元素 ⑥当前MNS单个queue的QPS上限是5k

保持可爱mmm 2020-03-29 00:02:09 0 浏览量 回答数 0

回答

服务器端可通过以下两种方式获取设备消息。 服务端订阅:使用物联网平台的服务端订阅功能,订阅一个或多个消息类型。物联网平台根据您设置的订阅,将产品下所有设备的该类型消息流转至您的服务器。支持以下两种方式的服务端订阅。 参见AMQP服务端订阅及相关文档,设置使用AMQP SDK接收物联网平台流转的设备消息。 参见MNS服务端订阅,设置使用MNS SDK接收物联网平台流转到MNS队列的设备消息。 云产品流转:使用规则引擎的云产品流转功能,通过数据流转规则将指定设备数据流转到消息服务(MNS)的主题或消息队列(RocketMQ)的队列中。服务器通过MNS或RocketMQ SDK接收消息。具体设置操作,请参见云产品流转概述。

保持可爱mmm 2020-04-06 03:18:40 0 浏览量 回答数 0

回答

服务器端可通过以下两种方式获取设备消息。 服务端订阅:使用物联网平台的服务端订阅功能,订阅一个或多个消息类型。物联网平台根据您设置的订阅,将产品下所有设备的该类型消息流转至您的服务器。支持以下两种方式的服务端订阅。 参见AMQP服务端订阅及相关文档,设置使用AMQP SDK接收物联网平台流转的设备消息。 参见MNS服务端订阅,设置使用MNS SDK接收物联网平台流转到MNS队列的设备消息。 云产品流转:使用规则引擎的云产品流转功能,通过数据流转规则将指定设备数据流转到消息服务(MNS)的主题或消息队列(RocketMQ)的队列中。服务器通过MNS或RocketMQ SDK接收消息。具体设置操作,请参见云产品流转概述。

保持可爱mmm 2020-03-27 16:42:06 0 浏览量 回答数 0

问题

消息服务是干什么的?

轩墨 2019-12-01 22:06:43 970 浏览量 回答数 0

回答

word文档中特定的数据进行更新,,建立定时任务或者消息队列,用Java操作Word文档的库Apache POI

消失er 2019-12-02 01:43:59 0 浏览量 回答数 0

回答

“如果消息队列服务不可用的情况下将无法提交消息”。 个人觉得这个问题不大,mqs保证的是99.9%服务可用性,Always Writable。当然公网的网络环境不稳定是有的。缓存数据在客户端来做是不是会更好? ------------------------- 2  json格式这个可以有。3 我第一看文档也没弄明白QueueOwnerId。。。是在创建队列后,才搞明白的。这个是文档的问题,没说明白,要改进的地方4 mqs目前对放消息数是没有限制的。5 PollingWaitseconds 是指,当queue没有消息时,针对该queue receive message请求最长等待时间。超过这个时间后,返回MsgNotExsits。如果在这个时间范围内,有了消息,就直接返回消息。                     ------------------------- 6  “希望能够对于消息设置MessageRetentionPeriod,这样更为灵活,而且,有些情况下持久消息还是很有用的。”        灵活和方便管理需要平衡。            mqs本身消息是有持久化。但mqs本身不是存储服务,其实可以选择本地存储或是oss。 ------------------------- 7 “对于MessageSize,64K感觉有点小,我遇到过一个企业应用里的消息大小是50M的xml文本”。。。50M的消息,这个确实有点大。建议存oss,然后把它的地址发到消息    。 ------------------------- 8  跨区域的消息队列是不能共享的 请问这个是什么意思,你希望怎么共享?9 之前你是使用的什么队列,习惯性的建了个test.q1 ?

boboan 2019-12-02 00:52:23 0 浏览量 回答数 0

问题

MNS Csharp SDK队列如何使用?

轩墨 2019-12-01 22:09:05 1219 浏览量 回答数 0

问题

【阿里云产品公测】MQS使用体会和建议

dongcc 2019-12-01 21:13:38 14959 浏览量 回答数 4

问题

消息服务的Queue如何操作?

轩墨 2019-12-01 22:10:37 1289 浏览量 回答数 0

问题

对Handler的理解:报错

kun坤 2020-06-08 11:03:22 4 浏览量 回答数 1

问题

MNS Python SDK如何下载?

轩墨 2019-12-01 22:08:49 1293 浏览量 回答数 0

回答

登录物联网控制台,创建产品和设备。 左侧菜单栏选择设备管理 > 产品,单击创建产品,创建产品。本示例中,创建了名称为MQ_test的产品,且节点类型选择为设备。 在产品详情页面,自定义Topic类,用于设备上报数据。本示例中,定义的Topic类:/{YourProductKey}/${YourDeviceName}/user/data。 选择设备管理 > 设备 > 添加设备,创建设备。本示例中,创建了一个名称为MQdevice的设备。 在消息队列RocketMQ控制台,创建Topic和消费者。 登录消息队列RocketMQ控制台。 创建一个实例。 创建Topic。消息类型选择普通消息。 物联网设备消息 创建Group ID。 物联网设备消息 创建消息消费者。在服务器SDK中运行如下示例代码,然后,在RocketMQ控制台查看消费者状态,消费者是否处于在线状态,订阅关系是否一致。 import com.aliyun.openservices.ons.api.Action; import com.aliyun.openservices.ons.api.ConsumeContext; import com.aliyun.openservices.ons.api.Consumer; import com.aliyun.openservices.ons.api.Message; import com.aliyun.openservices.ons.api.MessageListener; import com.aliyun.openservices.ons.api.ONSFactory; import com.aliyun.openservices.ons.api.PropertyKeyConst; import java.util.Properties; public class ConsumerTest { public static void main(String[] args) { Properties properties = new Properties(); // 您在控制台创建的 Group ID properties.put(PropertyKeyConst.GROUP_ID, "XXX"); // AccessKey 阿里云身份验证,在阿里云服务器管理控制台创建 properties.put(PropertyKeyConst.AccessKey, "${AccessKey}"); // SecretKey 阿里云身份验证,在阿里云服务器管理控制台创建 properties.put(PropertyKeyConst.SecretKey, "${SecretKey}"); // 设置 TCP 接入域名,到控制台的实例基本信息中查看 properties.put(PropertyKeyConst.NAMESRV_ADDR, "XXX"); // 集群订阅方式 (默认) // properties.put(PropertyKeyConst.MessageModel, PropertyValueConst.CLUSTERING); // 广播订阅方式 // properties.put(PropertyKeyConst.MessageModel, PropertyValueConst.BROADCASTING); Consumer consumer = ONSFactory.createConsumer(properties); consumer.subscribe("iot_to_mq", "*", new MessageListener() { //订阅多个 Tag public Action consume(Message message, ConsumeContext context) { System.out.println("Receive: " + message); return Action.CommitMessage; } }); consumer.start(); System.out.println("Consumer Started"); } } 说明 如何创建AccessKey和SecretKey,请参见创建AccessKey。 RocketMQ详细操作指导,请参考消息队列RocketMQ文档 在物联网平台控制台,设置数据流转规则,将设备上报的数据转发至消息队列(RocketMQ)。 单击规则引擎 > 创建规则,创建一条数据流转规则。数据格式选择为JSON。 设置数据处理SQL。 物联网设备消息 设置数据转发目的地。 物联网设备消息 启动规则。 规则启动后,物联网平台会将规则SQL中定义的设备上报消息转发至消息队列(RocketMQ)的Topic中。 使用Java SDK模拟设备,上报消息。 下载Java SDK Demo。 输入MQdevice的设备证书信息,包括ProductKey、DeviceName和DeviceSecret。 修改MQTT Topic为设备上报数据的Topic。本示例中,使用的Topic是/{YourProductKey}/${YourDeviceName}/user/data。 启动设备。 在物联网平台控制台监控运维 > 日志服务中,查看该设备的日志信息,发现设备数据成功转发至RocketMQ。 物联网设备消息 在RocketMQ控制台查看消息。 在本地运行订阅消息队列RocketMQ资源的代码。 物联网设备消息 在消息队列RocketMQ控制台,消息查询页面,按Topic或者Message ID查询消息,验证消息是否成功流转至消息队列RocketMQ中。 RocketMQ接收到的消息类型: {"deviceName()":"MQdevice"}

保持可爱mmm 2020-04-06 02:52:02 0 浏览量 回答数 0

问题

MNS PHP SDK的队列如何使用?

轩墨 2019-12-01 22:09:12 1138 浏览量 回答数 0

问题

PHP AMQP的问题:报错

kun坤 2020-06-09 23:15:35 0 浏览量 回答数 1

问题

消息队列提供32位C++SDK吗?

我的大大王 2019-12-01 20:05:32 1369 浏览量 回答数 0
阿里云大学 云服务器ECS com域名 网站域名whois查询 开发者平台 小程序定制 小程序开发 国内短信套餐包 开发者技术与产品 云数据库 图像识别 开发者问答 阿里云建站 阿里云备案 云市场 万网 阿里云帮助文档 免费套餐 开发者工具 企业信息查询 小程序开发制作 视频内容分析 企业网站制作 视频集锦 代理记账服务 企业建站模板