捷旅假期

本文以捷旅假期为例,介绍如何通过 函数计算、云消息队列 RocketMQ 版 及对象存储等云服务,处理瞬时并发消息等问题。客户介绍 深圳市捷旅国际旅行社有限公司(简称“深捷旅”),自2001年成立以来专注于酒店行业的客房分销业务以及酒店...

使用限制

限制项 描述 限制值 创建项目的数量 单个账号最多可以通过平台部署的实例或者项目数量 10000 单项目能够接入的设备数量 创建的项目可以连接的设备数量,超过设备数,需要扩容 根据购买的规格来管控 单项目能够支撑的设备上下行消息并发数 ...

视频型企业版实例

限制 说明 云端消息并发 100 TPS 上下行消息的并发量上限。云端视频播放带宽 10 Mbps 视频播放峰值带宽。超过该限制的额外视频播放请求会失败。云端存储服务 1 TB 视频或图片存储上限。存储达到上限时,会覆盖历史时间最久的视频或图片。...

在线教育视频直播

通过对MQTT、WebSocket等协议的全面支持,连接端和云之间的双向通信,实现C2C、C2B、B2C等业务场景之间的消息通信,可支撑千万级设备与消息并发,真正做到万物互联。更多关于 云消息队列 MQTT 版 的介绍,参见 微消息队列MQTT版产品详情页...

消息堆积和延迟问题

想要避免和解决消息堆积问题,必须合理的控制消费耗时和消息并发度,其中消费耗时的优先级高于消费并发度,必须先保证消费耗时的合理性,再考虑消费并发度问题。消费耗时 影响消费耗时的消费逻辑主要分为CPU内存计算和外部I/O操作,通常...

消息队列 RocketMQ 客户端流控设计

针对消息订阅者的消费延时流控 针对消息订阅者的消费延时流控的基本原理是,每次消费时在客户端增加一个延时来控制消费速度,此时理论上消费并发最快速度为:MaxRate=1/ConsumInterval*ConcurrentThreadNumber 如果消息并发消费线程...

数据转发到消息服务(MNS)

同时,消息服务在处理大量消息并发时,有削峰填谷的作用,保证服务端不会因为突然的并发压力导致服务不可用。物联网平台与消息服务的结合,可以实现设备端与服务端之间高性能的消息闭环传输。使用限制 物联网平台实例及所在地域支持将数据...

捷旅假期

本文以捷旅假期为例,介绍如何通过 函数计算、云消息队列 RocketMQ 版 及对象存储等云服务,处理瞬时并发消息等问题。客户介绍 深圳市捷旅国际旅行社有限公司(简称“深捷旅”),自2001年成立以来专注于酒店行业的客房分销业务以及酒店...

负载均衡SLB产品家族介绍

NLB 面向海量终端连接、高并发消息服务、音视频传输等业务场景针对性地推出了TCPSSL卸载、新建连接限速、全端口监听等高级特性,在物联网MQTTS加密卸载等场景为用户提供多种辅助手段,是适合IoT业务的新一代负载均衡。更多信息,请参见 ...

顺序消息

如果发送方有多个生产者或者有多个线程并发发送消息,则此时只能以到达 云消息队列 RocketMQ 版 服务端的时序作为消息顺序的依据,和业务侧的发送顺序未必一致。顺序消息常见问题 同一条消息是否可以既是顺序消息,又是定时消息和事务消息...

队列(MessageQueue)

需要增加队列实现顺序消息性能扩展 在 云消息队列 RocketMQ 版 服务端4.x版本中,顺序消息的顺序性在队列内生效的,因此顺序消息并发度会在一定程度上受队列数量的影响,因此建议仅在系统性能瓶颈时再增加队列。非顺序消息消费的负载均衡...

发送消息(多线程)

如果发送方有多个生产者或者有多个线程并发发送消息,则此时只能以到达 云消息队列 RocketMQ 版 服务端的时序作为消息顺序的依据,和业务侧的发送顺序未必一致。在多线程之间共享Producer的示例代码如下。import ...

主题别名

否则,因为云端分布式的特点,可能导致并发消息丢失。每个设备支持的主题别名数量最多为20,消息上行或下行的数量最多为20。使用场景 下图以温度传感器为示例,介绍主题别名的原理及使用流程。示例中消息A和消息B的Payload是一样的,消息...

收发顺序消息

发送顺序消息 重要 云消息队列 RocketMQ 版 服务端判定消息产生的顺序性是参照单一生产者、单一线程并发消息发送的时序。如果发送方有多个生产者或者有多个线程并发发送消息,则此时只能以到达 云消息队列 RocketMQ 版 服务端的时序作为...

收发顺序消息

发送顺序消息 重要 云消息队列 RocketMQ 版 服务端判定消息产生的顺序性是参照单一生产者、单一线程并发消息发送的时序。如果发送方有多个生产者或者有多个线程并发发送消息,则此时只能以到达 云消息队列 RocketMQ 版 服务端的时序作为...

收发顺序消息

发送顺序消息 重要 云消息队列 RocketMQ 版 服务端判定消息产生的顺序性是参照单一生产者、单一线程并发消息发送的时序。如果发送方有多个生产者或者有多个线程并发发送消息,则此时只能以到达 云消息队列 RocketMQ 版 服务端的时序作为...

收发顺序消息

发送顺序消息 重要 云消息队列 RocketMQ 版 服务端判定消息产生的顺序性是参照单一生产者、单一线程并发消息发送的时序。如果发送方有多个生产者或者有多个线程并发发送消息,则此时只能以到达 云消息队列 RocketMQ 版 服务端的时序作为...

收发顺序消息

发送顺序消息 重要 云消息队列 RocketMQ 版 服务端判定消息产生的顺序性是参照单一生产者、单一线程并发消息发送的时序。如果发送方有多个生产者或者有多个线程并发发送消息,则此时只能以到达 云消息队列 RocketMQ 版 服务端的时序作为...

收发顺序消息

发送顺序消息 重要 云消息队列 RocketMQ 版 服务端判定消息产生的顺序性是参照单一生产者、单一线程并发消息发送的时序。如果发送方有多个生产者或者有多个线程并发发送消息,则此时只能以到达 云消息队列 RocketMQ 版 服务端的时序作为...

收发顺序消息

发送顺序消息 重要 云消息队列 RocketMQ 版 服务端判定消息产生的顺序性是参照单一生产者、单一线程并发消息发送的时序。如果发送方有多个生产者或者有多个线程并发发送消息,则此时只能以到达 云消息队列 RocketMQ 版 服务端的时序作为...

收发顺序消息

发送顺序消息 重要 云消息队列 RocketMQ 版 服务端判定消息产生的顺序性是参照单一生产者、单一线程并发消息发送的时序。如果发送方有多个生产者或者有多个线程并发发送消息,则此时只能以到达 云消息队列 RocketMQ 版 服务端的时序作为...

收发顺序消息

发送顺序消息 重要 云消息队列 RocketMQ 版 服务端判定消息产生的顺序性是参照单一生产者、单一线程并发消息发送的时序。如果发送方有多个生产者或者有多个线程并发发送消息,则此时只能以到达 云消息队列 RocketMQ 版 服务端的时序作为...

收发顺序消息

发送顺序消息 重要 云消息队列 RocketMQ 版 服务端判定消息产生的顺序性是参照单一生产者、单一线程并发消息发送的时序。如果发送方有多个生产者或者有多个线程并发发送消息,则此时只能以到达 云消息队列 RocketMQ 版 服务端的时序作为...

收发顺序消息

发送顺序消息 重要 云消息队列 RocketMQ 版 服务端判定消息产生的顺序性是参照单一生产者、单一线程并发消息发送的时序。如果发送方有多个生产者或者有多个线程并发发送消息,则此时只能以到达 云消息队列 RocketMQ 版 服务端的时序作为...

收发事务消息

在发送消息前,必须调用start方法来启动Producer,只需调用一次即可,启动之后可以多线程并发发送消息。pProducer.start();Message msg=new Message(/Message Topic factoryInfo.getPublishTopics(),/Message Tag"TagA",/Message Body ...

收发普通消息

static void Main(string[]args){/在当前线程循环消费消息,建议多开个几个线程并发消费消息。while(true){ try {/长轮询消费消息。长轮询表示如果Topic没有消息,则请求会在服务端挂起3s,3s内如果有消息可以消费则立即返回客户端。List...

收发普通消息

}/在当前线程循环消费消息,建议多开个几个线程并发消费消息。do { List<Message>messages=null;try {/长轮询消费消息。长轮询表示如果Topic没有消息,则请求会在服务端挂起3s,3s内如果有消息可以消费则立即返回客户端。messages=consumer....

收发顺序消息

static void Main(string[]args){/在当前线程循环消费消息,建议多开个几个线程并发消费消息。while(true){ try {/长轮询顺序消费消息,拉取到的消息可能是多个分区的(对于分区顺序消息),一个分区内的消息一定是顺序的。对于分区顺序消息...

收发定时消息和延时消息

static void Main(string[]args){/在当前线程循环消费消息,建议多开个几个线程并发消费消息。while(true){ try {/长轮询消费消息。长轮询表示如果Topic没有消息,则请求会在服务端挂起3s,3s内如果有消息可以消费则立即返回客户端。List...

收发定时消息和延时消息

}/在当前线程循环消费消息,建议多开个几个线程并发消费消息。do { List<Message>messages=null;try {/长轮询消费消息。长轮询表示如果Topic没有消息,则请求会在服务端挂起3s,3s内如果有消息可以消费则立即返回客户端。messages=consumer....

收发普通消息

} } } } public function run(){/在当前线程循环消费消息,建议多开个几个线程并发消费消息。while(True){ try {/长轮询消费消息。若Topic内没有消息,请求会在服务端挂起一段时间(长轮询时间),期间如果有消息可以消费则立即返回客户端...

收发定时消息和延时消息

} } } } public function run(){/在当前线程循环消费消息,建议多开个几个线程并发消费消息。while(True){ try {/长轮询消费消息。若Topic内没有消息,请求会在服务端挂起一段时间(长轮询时间),期间如果有消息可以消费则立即返回客户端...

收发事务消息

static void Main(string[]args){/在当前线程循环消费消息,建议多开个几个线程并发消费消息。while(true){ try {/长轮询消费消息。长轮询表示如果Topic没有消息,则请求会在服务端挂起3s,3s内如果有消息可以消费则立即返回客户端。List...

收发事务消息

}/在当前线程循环消费消息,建议多开个几个线程并发消费消息。do { List<Message>messages=null;try {/长轮询消费消息。长轮询表示如果Topic没有消息,则请求会在服务端挂起3s,3s内如果有消息可以消费则立即返回客户端。messages=consumer....

收发事务消息

} } } } public function run(){/在当前线程循环消费消息,建议多开个几个线程并发消费消息。while(True){ try {/长轮询消费消息。若Topic内没有消息,请求会在服务端挂起一段时间(长轮询时间),期间如果有消息可以消费则立即返回客户端...

示例代码

以方便您在无法正常收到消息情况下,可通过消息队列RocketMQ版控制台查询消息并补发。注意:不设置也不会影响消息正常收发。msg.setKey("ORDERID_100");deliver time,单位:ms。指定一个时刻,在这个时刻之后消息才能被消费,这个例子表示...

调用HTTP协议的SDK收发普通消息

前提条件 创建资源 说明 本文以普通消息为例进行说明,因此您创建的普通消息的Topic不能用来收发其他类型的消息,包括定时、延时、顺序和事务消息。换言之,切勿混用不同消息类型的Topic。创建AccessKey 下载并安装HTTP协议的SDK 云消息...

什么是云消息队列 MQTT 版

高性能 支撑千万级设备在线连接,消息百万级并发,万亿级流转,毫秒级推送;分布式架构设计,无单点瓶颈,各组件间均可无限水平扩展。安全可靠 支持设备级权限控制,支持临时Token服务以及TLS 1.2版本的安全传输协议,确保用户数据安全可靠...

定时/延时消息

消息队列 RocketMQ 版 的定时消息具有高并发和水平扩展的能力。功能原理 什么是定时消息 定时消息是 云消息队列 RocketMQ 版 提供的一种高级消息类型,消息被发送至服务端后,在指定时间后才能被消费者消费。通过设置一定的定时时间可以...

产品优势

架构上难以支持万级的消息规模,消息上下行并发会给系统带来巨大的冲击。无法做到削峰填谷,影响高峰时正常业务运行。安全性 等保2.0版(三级等保),提供多重防护,保障设备数据安全。接入层使用高防IP防止DDoS攻击。设备认证保障设备安全...
共有200条 < 1 2 3 4 ... 200 >
跳转至: GO
产品推荐
云服务器 安全管家服务 安全中心
这些文档可能帮助您
消息服务 云消息队列 Kafka 版 云原生数据仓库AnalyticDB MySQL版 云消息队列 RocketMQ 版 视频直播 弹性公网IP
新人特惠 爆款特惠 最新活动 免费试用