消息队列 MQ
MQ 产品生态丰富,多个子产品线联合打造金融级高可用消息服务以及对物联网的原生支持,覆盖金融保险、(新)零售、物联网、移动互联网、传媒泛娱乐、教育、物流、能源、交通等行业。

超大消息传输

背景信息消息服务MNS的队列的消息大小最大限制是64KB,这个限制基本能够满足在正常情况下消息作为控制流信息交换通道的需求。但是,在某些特殊场景下,消息数据比较大时,就只能采用消息切片的方式。下面是不做消息切片,通过OSS来实现传递...

使用消息队列Kafka版时客户端的报错及解决方案

报错信息客户端语言类型报错原因解决方案TimeoutExceptionJava网络问题客户端鉴权(sasl.mechanisms)失败说明:该报错仅出现在消息队列Kafka版的公网实例中。确保servers配置正确。通过telnet命令排除网络问题。如果网络正常,请参考如下...

搭建IPv4专有网络

网络选择已创建的专有网络和交换机。公网IP带宽:选择不分配。安全组:选择使用默认安全组。单击确认订单并完成支付。单击管理控制台,在实例列表页面查看已创建的ECS实例。步骤三:创建EIP并将EIP绑定到ECS实例EIP是可以独立购买和持有...

阿里云试用中心,为您提供0门槛上云实践机会!

100+款试用云产品,最长免费试用12个月!拨打95187-1,咨询专业上云建议!
广告

消息幂等

在Producer客户端为每条消息设置唯一MessageID。设置唯一MessageID的示例代码如下:AMQP.BasicPropertiesprops=newAMQP.BasicProperties.Builder().messageId(UUID.randomUUID().toString()).build();channel.basicPublish("${ExchangeName...

快速使用MQTT的Java SDK收发消息(跨产品数据流入)

客户端网络对IP地址设置网络防火墙策略,产品方更新了域名解析后新IP地址被您的防火墙策略拦截。本文以公网接入点为例。微消息队列MQTT版与消息队列RocketMQ版的应用场景对比和消息属性映射关系请参见以下文档:MQTT与Rocket的应用场景对比...

【公测迁移】经典网络用户迁移

在实例列表页面,选择用于消息队列Kafka版服务的经典网络的ECS实例,然后单击更多>网络和安全组>连接专有网络。在连接专有网络对话框,选择之前创建的VPC,然后单击确定。单击前往实例安全组列表添加ClassicLink安全组规则,设置配置规则,...

设置网络白名单

创建好一个TSDB实例后,您必须为它设置网络白名单才可以让它被应用访问到。设置网络白名单可以保证实例的访问安全。设置网络白名单的具体步骤如下:登录TSDB控制台,进入实例列表页面。在单击某实例右侧操作列中的管理按钮,进入该实例的...

快速使用MQTT的Java SDK收发消息(跨产品数据流出)

客户端网络对IP地址设置网络防火墙策略,产品方更新了域名解析后新IP地址被您的防火墙策略拦截。本文以公网接入点为例。微消息队列MQTT版与消息队列RocketMQ版的应用场景对比和消息属性映射关系请参见以下文档:MQTT与Rocket的应用场景对比...

推送到邮箱

消息服务MNS支持把发布到主题的消息推送到邮箱。本文介绍如何将消息推送至邮箱。前提条件开通邮件推送设置发信域名设置发信地址注意不支持动态设置回信地址。步骤一:创建主题登录消息服务MNS控制台。在左侧导航栏,单击主题列表。在顶部...

使用路由表

专有网络选择路由表所属的专有网络。如果专有网络中含有以下ECS实例规格族中的任一实例,则不支持为该专有网络创建自定义路由表。ecs.c1、ecs.c2、ecs.c4、ecs.ce4、ecs.cm4、ecs.d1、ecs.e3、ecs.e4、ecs.ga1、ecs.gn4、ecs.gn5、ecs.i1、...

在Knative上实现Kafka消息推送

适用场景在线任务处理AI音视频消息处理监控告警数据格式转换操作流程在Knative上实现消息队列Kafka版消息推送的操作流程如下图所示。部署Kafka组件登录容器服务控制台。在左侧导航栏,单击集群。在集群列表页面,单击要部署Kafka组件的...

设置网络白名单

创建好一个时序时空数据库实例后,您必须为它设置网络白名单才可以让它被应用访问到。设置网络白名单可以保证实例的访问安全。操作步骤登录时序时空数据库控制台,进入实例列表页面。在单击某实例右侧操作列中的管理按钮,进入该实例的实例...

设置网络白名单

创建好一个TSDB实例后,您必须为它设置网络白名单才可以让它被应用访问到。设置网络白名单可以保证实例的访问安全。设置网络白名单的具体步骤如下:登录TSDB控制台,进入实例列表页面。在单击某实例右侧操作列中的管理按钮,进入该实例的...

MQTT与RocketMQ的消息结构映射

属性Key属性可值说明qoslevel0、1、2消息队列RocketMQ版发给微消息队列MQTT版消息时可以设置,如果不设置,默认为“1”;微消息队列MQTT版发给消息队列RocketMQ版的消息可以直接读取。cleansessionflagtrue、false消息队列RocketMQ版发给...

消息日志

您可以使用消息队列RabbitMQ版的日志管理功能将消息队列RabbitMQ版实例的消息操作日志推送到日志服务。当消息的发送、消费、确认出现异常时,您可以通过MessageID查询消息操作日志,从而进行异常诊断。前提条件在将消息队列RabbitMQ版实例...

MQTT 快速入门

注意事项微消息队列MQTT版需搭配后端消息存储队列一起使用,具体说明如下:微消息队列MQTT版实例是一个无状态网关类型实例,用来完成IoT移动场景客户端连接维持和消息转发,本身并不提供消息数据持久化功能,具体的消息存储和消息数据持久...

使用消息队列RocketMQ版后收到信息堆积告警

问题描述在使用消息队列RocketMQ版实例时收到消息堆积告警,登录消息队列RocketMQ版控制台后发现了下列现象:导航栏中选择Group管理,单击目标Group右侧的消费者状态,在连接信息下方发现堆积量栏的值高于预期。导航栏中选择消息轨迹,单击...

MQTT与RocketMQ的消息结构映射

本文针对使用消息队列RocketMQ版...MQTT参数RocketMQ属性Key属性可值说明QoSqoslevel0、1、2消息队列RocketMQ版发给微消息队列MQTT版消息时可以设置,如果不设置,默认为“1”;微消息队列MQTT版发给消息队列RocketMQ版的消息可以直接读取。...

轨迹查询

本文介绍如何使用微消息队列MQTT版的轨迹查询功能排查设备在线问题和消息收发问题。当设备的状态出现异常时,您可以使用设备轨迹查询功能,查询设备的连接历史;当消息的收发不符合预期时,您可以使用消息轨迹查询功能,查询消息的收发轨迹...

云数据库MongoDB版网络切换

本文档介绍了如何通过控制台和API将云数据库MongoDB版的网络类型切换至专有网络,同时保留经典网络的访问地址。经典网络的访问地址有保留时间限制,您可以根据需要指定保留期限。到期后,经典网络地址会自动被系统删除。前提条件在开始切换...

如何快速测试消息队列Kafka版服务端是否正常?

在创建并部署消息队列Kafka版实例后,您可以使用消息队列Kafka版控制台直接发送消息,快速测试服务端是否正常。前提条件您已创建并部署消息队列Kafka版实例,且实例处于服务中状态。操作流程快速测试消息队列Kafka版服务端的流程如下:创建...

添加子网路由到路由表

专有网络选择路由表所属的专有网络。如果专有网络中含有以下ECS实例规格族中的任一实例,则不支持为该专有网络创建自定义路由表。ecs.c1、ecs.c2、ecs.c4、ecs.ce4、ecs.cm4、ecs.d1、ecs.e3、ecs.e4、ecs.ga1、ecs.gn4、ecs.gn5、ecs.i1、...

搭建IPv6专有网络

本教程将指引您搭建一个具有IPv6地址块的专有网络(VPC),然后在该VPC中创建一个带有IPv6地址的ECS实例,并可以访问IPv6服务。步骤一:创建专有网络和交换机在专有网络中使用云资源,您必须要先做好网络规划。详细信息,请参见网络规划。...

MQTT快速入门

注意事项微消息队列MQTT版需搭配后端消息存储队列一起使用,具体说明如下:微消息队列MQTT版实例是一个无状态网关类型实例,用来完成IoT移动场景下的客户端连接维持和消息转发,本身并不提供消息数据持久化功能,具体的消息存储和消息数据...

消费幂等

为了防止消息重复消费导致业务处理异常,消息队列RocketMQ版的消费者在接收到消息后,有必要根据业务上的唯一Key对消息做幂等处理。本文介绍消息幂等的概念、适用场景以及处理方法。什么是消息幂等当出现消费者对某条消息重复消费的情况时...

步骤三:创建资源

前提条件您已根据网络环境购买并部署消息队列Kafka版服务:VPC接入公网+VPC接入背景信息在成功部署消息队列Kafka版服务后,您需要创建Topic和ConsumerGroup。Topic:消息队列Kafka版里对消息进行的一级归类,例如可以创建“Topic_Trade”这...

搭建与管理网络

搭建LinkWAN网络服务需要有网关和通信模组,本节介绍如何在物联网络管理平台添加网络、分享网络并通过凭证入网。背景信息网关和通信模组的获取方式有如下两种方法:移植SDK到网关与通信模组上,并且购买LinkWAN密钥安装后使用。移植教学可...

Topic管理

背景信息Topic是消息队列RocketMQ版里对消息的一级归类。消息队列RocketMQ版支持发布和订阅模型,通过Topic完成消息的发布和订阅。消息生产者将消息发送到Topic中,而消息消费者则通过订阅该Topic来获取和消费消息。注意事项Topic不能跨...

网络连接

为了实例本身的安全性,您需要先设置网络白名单才可以获取实例的VPC访问链接。具体步骤请参照设置网络白名单。白名单设置好后,在实例详情页面的基本信息区域的VPC网络地址一栏可查看实例的VPC访问链接。公网连接创建公网访问链接时序时空...

消息队列Kafka版接入阿里云Elasticsearch

随着时间的积累,消息队列Kafka版中的日志数据会越来越多。当您需要查看并分析庞杂的日志数据时,可通过阿里云Logstash将消息队列Kafka版中的日志数据导入阿里云Elasticsearch,然后通过Kibana进行可视化展示与分析。本文介绍将消息队列...

查看日志Log Service

消息服务MNS支持将日志推送到LogService,本文为您介绍日志成功推送后,如何通过日志查询特定信息。以下介绍几种常用场景的查询,您可以通过组合多个关键字来实现更加复杂的查询。注意消息服务MNS推送日志到指定LogStore会延迟约3分钟。...

使用限制

本文为您介绍微消息队列MQTT版对某些具体指标的约束和规范,您在使用微消息队列MQTT版时请不要超过相应的限制值,以免程序出现异常。...客户端网络对IP地址设置网络防火墙策略,产品方更新了域名解析后新IP地址被您的防火墙策略拦截。

1.准备工作

实例创建成功后,您需要设置白名单,进入相应实例,左侧点击数据安全性,选择白名单设置选择切换高安全白名单模式,将专有网络中default设置为0.0.0.0/0,IP白名单设置为0.0.0.0/0代表允许所有地址访问。在VPC中设置RDS允许所有地址访问...

限制本地数据中心与云上的互通

所属专有网络选择网络ACL所属的专有网络。名称:输入网络ACL的名称。名称长度为2~128个字符,以英文字母或中文开头,可包含数字、下划线(_)和划线(-)。描述:输入网络ACL的描述。描述长度为2~256个字符,不能以http://和https://...

专有网络 VPC

如果单击 绑定已有专有网络选择已有专有网络。单击 确定。创建交换机您可以通过创建交换机为专有网络划分一个或多个子网。前提条件已创建专有网络。操作步骤登录SOFAStack控制台,在左侧导航栏单击左下角的全局设置,进入工作空间页。...

轨迹查询

本文介绍如何使用微消息队列MQTT版的轨迹查询功能排查设备在线问题和消息收发问题。当设备的状态出现异常时,您可以使用设备轨迹查询功能,查询设备的连接历史;当消息的收发不符合预期时,您可以使用消息轨迹查询功能,查询消息的收发轨迹...

常见问题

客户端首次接入消息队列Kafka版时出现异常的排查方法出现消息堆积消费客户端频繁出现Rebalance从...信息网络问题无法ping通消息队列Kafka版的接入点不在同一可用区内的ECS实例如何访问消息队列Kafka版实例能否通过公网访问消息队列Kafka版实例...

名词解释

消息堆积Producer已经将消息发送到消息队列RocketMQ版的服务端,但由于Consumer消费能力有限,未能在时间内将所有消息正确消费掉,此时在消息队列RocketMQ版的服务端保存着未被消费的消息,该状态即消息堆积。消息过滤Consumer可以根据...

实例管理

设置实例的监控报警微消息队列MQTT版除了提供每个实例的消息收发TPS、订阅关系数和客户端连接数信息的查看,还可以在监测到这些指标超过设置的报警阈值后,向联系人手机发送报警短信,提示尽快升级规格。报警阈值默认为规格的70%,报警阈值...

发送普通消息(三种方式)

消息队列RocketMQ版提供三种方式来发送普通消息:同步(Sync)发送、异步(Async)发送和单向(Oneway)发送。本文介绍了每种发送方式的原理、应用场景、示例代码,以及三种发送方式的对比。同步发送原理同步发送是指消息发送方发出一条...
< 1 2 3 4 ... 200 >
共有200页 跳转至: GO

新品推荐

你可能感兴趣

热门推荐

切换为移动版

新人福利专场 阿里云试用中心 企业支持计划 飞天会员助力企业低成本上云 智能财税30天免费试用 云解析DNS新用户首购低至36元/年起 ECS限时升级特惠6.5折
消息队列 MQ
MQ 产品生态丰富,多个子产品线联合打造金融级高可用消息服务以及对物联网的原生支持,覆盖金融保险、(新)零售、物联网、移动互联网、传媒泛娱乐、教育、物流、能源、交通等行业。