步骤三:调用SDK收发消息

消息队列 RocketMQ 版 提供多种语言的SDK用于收发不同类型的消息,本文以Java SDK为例,说明如何调用SDK连接 云消息队列 RocketMQ 版 服务端,完成普通消息的收发流程。前提条件 步骤二:创建资源 安装IDEA 您可以使用IntelliJ IDEA或者...

步骤三:调用SDK收发消息

本文以Java SDK为例,说明如何将开源SDK客户端接入 云消息队列 RabbitMQ 版 服务端,并完成消息收发。前提条件 创建资源 安装IDEA 您可以使用IntelliJ IDEA或者Eclipse,本文以IntelliJ IDEA Ultimate为例。安装JDK 安装Maven 安装Java依赖...

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

在控制台创建完所有资源之后,您可以调用 云消息队列 RocketMQ 版 的TCP协议的SDK收发普通消息。前提条件 创建资源 说明 本文以普通消息为例进行说明,因此您创建的普通消息的Topic不能用来收发其他类型的消息,包括定时、延时、顺序和事务...

创建MaxCompute Sink Connector

本文介绍如何创建使用MaxCompute Sink Connector,您可以通过MaxCompute Sink Connector将数据从 云消息队列 Kafka 版 实例的数据源Topic导出至MaxCompute的表中。前提条件 详细步骤,请参见 创建前提。注意事项 如需使用MaxCompute分区...

实例限流最佳实践

消息队列 RabbitMQ 版 服务端 关闭当前请求的Channel。代码中可以捕获异常重新开启Channel。错误码信息:错误码:reply-code=530 错误信息:reply-text=denied for too many requests Java客户端错误堆栈示例:Caused by:...

使用Canal和RocketMQ实现数据库变更订阅处理

本文以MySQL数据库为例介绍如何使用Canal接入 云消息队列 RocketMQ 版,实现MySQL数据库Binlog数据的变更处理。背景信息 CDC(Change Data Capture)是一种监测并捕获数据库变更的典型技术方案,常应用于异构数据源之间的数据同步。Canal...

版本说明

本文介绍RocketMQ ONS 1.x系列Java SDK的版本信息,包含下载链接、发布时间、更新点等,以便您按需获取适用的Java SDK收发消息。重要 JDK 1.8适用于所有Java ons-client版本,JDK 1.6仅支持ons-client v1.8.4.Final及之前的版本使用。为...

功能发布列表

本文介绍了 云消息队列 RocketMQ 版 每次发布涉及的新增功能、功能优化、重要问题修复及对应的文档,帮助您了解 云消息队列 RocketMQ 版 的发布动态。2024-04-24 实例系列 功能名称 功能描述 变更类型 相关文档 5.x系列实例 Serverless公网...

版本说明

本文介绍Java SDK的版本信息,包含使用限制、下载链接、发布时间、更新点等,以便您按需获取适用的Java SDK收发消息。使用限制 JDK 1.8适用于所有Java ons-client版本,JDK 1.6仅支持ons-client v1.8.4.Final及之前的版本使用。为避免升级...

自由使用Group

打开自由使用Group的开关表示 云消息队列 Kafka 版 允许未在控制台创建的Group可以调用API进行消息消费和位点提交等操作,如果关闭自由使用Group功能,那么未在控制台创建的Group(即控制台上 自动创建 栏显示为 是 的Group)将无法进行...

使用Canal和RocketMQ实现数据库变更订阅处理

true:开启 false:关闭 false rocketmq.namespace 云消息队列 RocketMQ 版 实例的ID,在 云消息队列 RocketMQ 版 控制台 实例详情 页面获取。使用Canal连接 云消息队列 RocketMQ 版 4.x实例时,该参数必须填写。MQ_INST_1266540465*_...

CreateInstance-创建实例

创建云消息队列 RocketMQ 版5.x系列实例。接口说明 注意 阿里云提供的 OpenAPI 属于管控类 API,用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成,消息收发的核心数据链路中严禁依赖 OpenAPI 实现,否则可能会导致链路产生风险...

Token鉴权概述

消息队列 MQTT 版 通过Token鉴权模式向MQTT客户端提供临时访问权限。您可通过MQTT Token服务来给本地账号系统管理的用户颁发临时的访问凭证,并限制访问权限,以实现对单一客户端、单一资源的细粒度权限控制。本文介绍使用流程以及相关...

Token鉴权概述

消息队列 MQTT 版 通过Token鉴权模式向MQTT客户端提供临时访问权限。您可通过MQTT Token服务来给本地账号系统管理的用户颁发临时的访问凭证,并限制访问权限,以实现对单一客户端、单一资源的细粒度权限控制。本文介绍使用流程以及相关...

环境准备

64/ONSClient4CPP.lib ONSClient4CPP.dll ONSClient4CPP.pdb vc_redist.x64.exe demo/包含了普通消息发送、Oneway消息发送、顺序消息发送、普通消息消费、顺序消息消费等代码示例。interface/封装PINVOKE调用的代码,需要包含到您的项目...

环境准备

64/ONSClient4CPP.lib ONSClient4CPP.dll ONSClient4CPP.pdb vc_redist.x64.exe demo/包含了普通消息发送、Oneway消息发送、顺序消息发送、普通消息消费、顺序消息消费等代码示例。interface/封装PINVOKE调用的代码,需要包含到您的项目...

AMQP协议返回码

本文说明 云消息队列 RabbitMQ 版 客户端调用AMQP 0-9-1协议时的返回码,您可以根据返回信息与解决方案自助排查错误。返回码列表 返回码(reply-code)返回信息(reply-text)描述 解决方案 200 no route has mandatory 调用 basicPublish ...

查看Rebalance详情

消费者数量过多,为避免当前Topic-Partition的任务浪费,需要关闭一定数量的消费者,触发Rebalance。消费者数量不足,当前Topic-Partition的任务出现延迟,需要增加一定数量的消费者,触发Rebalance。操作步骤 登录 云消息队列 Kafka 版 ...

客户端连接常见问题

本文介绍 云消息队列 MQTT 版 客户端连接服务端时的常见问题。使用安卓的Demo,返回连接失败报错。问题描述 资源填写正确,且网络可以连通。AK(AccessKey ID)、SK(AccessKey Secret)填写正确且已授权。可能原因 接入点格式不正确,正确...

创建实例

创建云消息队列RabbitMQ的实例。调试 您可以在OpenAPI Explorer中直接运行该接口,免去您计算签名的困扰。运行成功后,OpenAPI Explorer可以自动生成SDK代码示例。请求参数 名称 类型 是否必选 示例值 描述 Action String 是 ...

使用Canal将MySQL的数据同步至云消息队列 Kafka 版

本教程介绍如何使用Canal将MySQL的数据同步至 云消息队列 Kafka 版。背景信息 Canal的主要用途是基于MySQL数据库增量日志解析,提供增量数据订阅和消费。Canal伪装自己为MySQL Slave,向MySQL Master发送dump请求。MySQL Master收到dump...

使用实例接入点收发消息

当使用应用程序与Kafka集群建立连接时,可通过实例接入点接入 云消息队列 Kafka 版 并收发消息。Kafka实例提供默认接入点、SSL接入点和SASL接入点,以满足您不同的连接和安全需求。默认接入点适用于在保密性较高的VPC环境收发消息;SASL接...

SSL接入点PLAIN机制收发消息

本文以Java SDK为例介绍如何在公网环境下使用SDK接入 云消息队列 Kafka 版 的SSL接入点并使用PLAIN机制收发消息。前提条件 步骤三:创建资源 安装1.8或以上版本JDK 安装2.5或以上版本Maven 安装Java依赖库 在 pom.xml 中添加以下依赖。...

开启幂等功能,发送消息报“Cluster authorization ...

问题描述 开启幂等功能后,发送消息时客户端报 Cluster authorization failed 错误。问题原因 您使用了云存储Topic,云存储Topic不支持幂等功能。如果使用Local Topic,并开启了ACL功能,默认情况下,根据Kafka开源协议,Broker会判断发送...

排他队列

如果您想创建一个只有自己可见的队列,不允许其他用户访问,您可以使用 云消息队列 RabbitMQ 版 的排他性队列特性,将指定的队列声明为排他性。什么是排他队列 排他性队列的特点如下:排他队列只对首次声明它的连接(Connection)可见,...

使用Exactly-Once投递语义收发消息

本文主要介绍如何使用 云消息队列 RocketMQ 版 的Exactly-Once投递语义收发消息,以保证消息的最终处理结果写入到数据库有且仅有一次。背景信息 重要 目前Exactly-Once投递语义仅在Java SDK中支持。相关SDK下载,请参见 版本说明。云消息...

网络异常自动恢复

在客户端开启Connection和Topology(Queue、Exchange、Binding、Consumer)自动恢复的方法如下:factory.setAutomaticRecoveryEnabled(boolean):用于开启或关闭Connection自动恢复。factory.setNetworkRecoveryInterval(long):用于设置重...

UpdateInstanceConfig-修改实例的配置

实例部署后,允许修改实例是否开启ACL、SSL、消息保留时长及最大消息大小,本文介绍如何调用UpdateInstanceConfig修改实例配置。接口说明 权限说明 RAM 用户需要先获取授权,才能调用 UpdateInstanceConfig 接口。授权的详细信息,请参见 ...

快速入门

步骤五:发送消息 在左侧导航栏,选择 消息发送,根据页面提示,填写发送相关信息。单击 发送。具体操作步骤,请参见 发送消息。相关文档 ChatApp 消息服务 开发指南,API参考及SDK参考,敬请期待。消息发送后,通过配置MNS消息队列消费...

全球消息路由

(可选)在 阿里云服务授权-从消息队列RabbitMQ版读取消息 对话框,认真阅读提示信息,单击 确认。首次创建全球消息路由任务,将自动创建服务的关联角色AliyunServiceRoleForEventBridgeSourceRabbitMQ与...

商品目录模板最佳实践

根据页面提示,填写信息。选择模板语言 选择审核通过的商品目录模板 选择发送账号 指定发送方式 设置目录,目录中的商品数据来自左侧导航 目录管理 中同步的商品。如果商品目录模板格式为目录消息时,设置封面商品。如果商品目录模板格式为...

MQTT快速入门

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

发送消息

本文为您介绍如何使用发送消息。前提条件 已开通 ChatApp 消息服务。已完成 注册阿里云账号 和 企业实名认证。创建的模板已审核通过。具体操作,请参见 创建模板。WABA账号绑定的手机号码已完成验证。具体操作,请参见 通道管理。操作步骤 ...

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

根据界面提示信息,通过SDK订阅消息,或者执行Docker命令订阅消息。发送方式 选择 Docker,运行Docker容器。执行 运行 Docker 容器生产示例消息 区域的Docker命令,发送消息。执行 发送后如何消费消息?区域的Docker命令,订阅消息。发送...

作为Input接入

根据界面提示信息,通过SDK订阅消息,或者执行Docker命令订阅消息。发送方式 选择 Docker,运行Docker容器。执行 运行 Docker 容器生产示例消息 区域的Docker命令,发送消息。执行 发送后如何消费消息?区域的Docker命令,订阅消息。发送...

作为Input接入

根据界面提示信息,通过SDK订阅消息,或者执行Docker命令订阅消息。发送方式 选择 Docker,运行Docker容器。执行 运行 Docker 容器生产示例消息 区域的Docker命令,发送消息。执行 发送后如何消费消息?区域的Docker命令,订阅消息。发送...

作为Input接入

根据界面提示信息,通过SDK订阅消息,或者执行Docker命令订阅消息。发送方式 选择 Docker,运行Docker容器。执行 运行 Docker 容器生产示例消息 区域的Docker命令,发送消息。执行 发送后如何消费消息?区域的Docker命令,订阅消息。发送...

作为Input接入

根据界面提示信息,通过SDK订阅消息,或者执行Docker命令订阅消息。发送方式 选择 Docker,运行Docker容器。执行 运行 Docker 容器生产示例消息 区域的Docker命令,发送消息。执行 发送后如何消费消息?区域的Docker命令,订阅消息。发送...

Filebeat发送失败问题

问题现象 在 云消息队列 Kafka 版 控制台 的 Topic 管理 页面,您已成功创建Topic,但使用Filebeat向该Topic发送消息却出现 Request was for a topic or partition that does not exist on this broker.的错误提示。可能原因 Filebeat向...

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

随着时间的积累,云消息队列 Kafka 版 中的日志数据会越来越多。当您需要查看并分析庞杂的日志数据时,可通过阿里云Logstash将 云消息队列 Kafka 版 中的日志数据导入阿里云Elasticsearch,然后通过Kibana进行可视化展示与分析。本文介绍将...
共有200条 < 1 2 3 4 ... 200 >
跳转至: GO
产品推荐
云服务器 安全管家服务 安全中心
这些文档可能帮助您
云消息队列 Kafka 版 消息服务 云消息队列 RocketMQ 版 智能对话机器人 表格存储 弹性公网IP
新人特惠 爆款特惠 最新活动 免费试用