AT 模式接入
AT 模式接入适用的场景包括跨数据库事务、MQ 的消息事务、EDAS 的服务事务及多场景混合型事务方案。本文介绍如何基于@TxcTransaction 注解使用 GTS 服务。前提条件 在使用 AT 模式接入 GTS 前，请先完成以下工作：开通 GTS（创建事务分组）...
消息重试
顺序消息的重试 对于顺序消息，当消费者消费消息失败后，消息队列会自动不断地进行消息重试（每次间隔时间为 1 秒），这时，应用会出现消息消费被阻塞的情况。因此，建议您使用顺序消息时，务必保证应用能够及时监控并处理消费失败的情况，...
消息过滤
场景示例 以下图电商交易场景为例，从客户下单到收到商品这一过程会生产一系列消息，按照类型将消息分为订单消息和物流消息，其中给物流消息定义地域属性，按照地域分为杭州和上海：订单消息 物流消息 物流消息且地域为杭州 物流消息且地域...
任务常见问题
如果是单机任务，业务直接抛异常，可以在 执行列表 页面，单击 任务实例列表，在对应任务实例的操作列，单击 详情 查看错误信息。如果任务没有抛异常或者使用了分布式任务，您的专业版应用可以通过日志服务来排查问题。如果是基础版应用，...
任务常见问题
如果是单机任务，业务直接抛异常，可以在 执行列表 页面，单击 任务实例列表，在对应任务实例的操作列，单击 详情 查看错误信息。如果任务没有抛异常或者使用了分布式任务，您的专业版应用可以通过日志服务来排查问题。如果是基础版应用，...
任务常见问题
如果是单机任务，业务直接抛异常，可以在 执行列表 页面，单击 任务实例列表，在对应任务实例的操作列，单击 详情 查看错误信息。如果任务没有抛异常或者使用了分布式任务，您的专业版应用可以通过日志服务来排查问题。如果是基础版应用，...
我是数采实施商
1）0x01（读线圈寄存器）2）0x02（读离散输入寄存器）3）0x03（读保持寄存器）4）0x04（读输入寄存器）写功能码 1）0x05（写单个线圈寄存器）2）0x06（写单个保持寄存器）3）0x0F（写多个线圈寄存器）4）0x10（写多个保持寄存器）批量操作 ...
Cava 异常处理
浮点数除0不抛异常 最佳实践：int b=0;int a=0；if(b!0){ a=1/b;} 数组访问越界异常 代码示例：int[]a=new int[10];a[-1]/不合法，超数组下限 a[10]/不合法，超数组上限 最佳实践：int[]a=new int[10];int idx=10；if(idx>0&idx){ int b=a...
Cava 异常处理
浮点数除0不抛异常 最佳实践：int b=0;int a=0；if(b!0){ a=1/b;} 数组访问越界异常 代码示例：int[]a=new int[10];a[-1]/不合法，超数组下限 a[10]/不合法，超数组上限 最佳实践：int[]a=new int[10];int idx=10；if(idx>0&idx){ int b=a...
Spring集成
云消息队列 RabbitMQ 版 支持Spring框架的SDK，本文介绍如何集成Spring框架的SDK客户端收发消息。前提条件 您已在 云消息队列 RabbitMQ 版控制台 创建实例、Vhost、Exchange、Queue等相关资源，具体操作，请参见 步骤二：创建资源。安装...
MQTT和RocketMQ进行数据互通（跨产品数据流入）
如果您的云端应用需要使用 云消息队列 RocketMQ 版 产品的某些功能，例如顺序消息特性、事务消息特性等，您可以通过消息流入或流出规则将 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 数据进行流转。本文介绍如何将 云消息队列 RocketMQ...
专业版
v2.1.2 2019-11-26【修复】修复了同一个边缘实例下，某一驱动的更新部署（例如，更新配置或增删子设备等，然后部署实例）会影响其它驱动的子设备状态问题。【优化】支持函数计算的容器在Kubernetes上运行。【优化】优化远程访问功能的流量...
标准版
v2.1.2 2019-11-26【修复】修复了同一个边缘实例下，某一驱动的更新部署（例如，更新配置或增删子设备等，然后部署实例）会影响其它驱动的子设备状态问题。【优化】优化远程访问功能的流量消耗。【优化】减少远程访问功能的重连间隔。...
管理运维工具lectl
lectl driver show 44c0*78204641a4b9bcf1024176c2$lectl driver show-c 44c0*78204641a4b9bcf1024176c2$lectl driver show-devices 44c0*78204641a4b9bcf1024176c2$lectl driver show-devices=a1t8*n42K/GjCb*gcKYaluGJLN 44c0*78204641a4...
常见错误码参考
使用Lindorm SQL访问宽表引擎或时序引擎遇到异常时，系统会以错误码的形式将异常或程序错误返回给开发人员。您可以在本文的表格中搜索报错返回的错误编号，快速查找具体的错误信息及处理建议。常见错误 下表中的错误码与MySQL中的部分服务...
监测和诊断eRDMA
upgrade pip=20.3.4 sudo python2-m pip install paramiko Ubuntu#python3 sudo python3-m pip install-upgrade pip sudo python3-m pip install paramiko#python2#如果当前节点未安装python2-pip sudo apt install software-properties-...
使用PyJindo访问阿里云OSS-HDFS
本文将以两种方式为您介绍如何在Python 3.6及更高版本中，利用Python的工具包PyJindo来操作OSS-HDFS。背景信息 方式一：直接使用PyJindo包 是直接使用PyJindo包的原生接口来操作OSS-HDFS。这种方式更依赖于PyJindo自己的API，且通常需要更...
兼容版本SDK概述
抛异常 JobClient getFs()否，抛异常 JobClient getJob(JobID jobid)否，抛异常 JobClient getJob(String jobid)否，抛异常 JobClient getJobsFromQueue(String queueName)否，抛异常 JobClient getMapTaskReports(JobID jobId)否，抛异常 ...
消息重试
云消息队列 RocketMQ 版 支持消息重试功能，即Consumer消费某条消息失败或消费超时，云消息队列 RocketMQ 版 会根据消息重试机制重新投递消息。本文介绍 云消息队列 RocketMQ 版 分别在HTTP协议和TCP协议下的消息重试策略。注意事项 一条...
收发普通消息
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。本文提供使用HTTP协议下的Java SDK收发普通消息的示例代码。前提条件 您已完成以下操作：安装Java SDK。更多信息，请参见 准备...
通过Knative事件驱动实现消息发送
本文通过一个Demo示例介绍如何通过Knative部署消息处理、事件驱动和Homepage，实现消息发送。前提条件 创建ACK Serverless集群 部署Knative 部署Eventing Demo介绍 Demo主要包含以下三部分：HomePage：用于发送和接收弹幕，通过Knative ...
收发定时消息和延时消息
背景信息 延时消息：Producer将消息发送到 云消息队列 RocketMQ 版 服务端，但并不期望立马投递这条消息，而是延迟一定时间后才投递到Consumer进行消费，该消息即延时消息。定时消息：Producer将消息发送到 云消息队列 RocketMQ 版 服务端...
收发顺序消息
顺序消息（FIFO消息）是 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用HTTP协议下的Java SDK收发顺序消息的示例代码。背景信息 顺序消息分为两类：全局顺序：对于指定的一个Topic，所有消息按照严格...
收发定时消息
发送消息，只要不抛出异常，就代表发送成功。try { SendResultONS sendResult=pProducer->send(msg);} catch(ONSClientException&e){/自定义处理exception的细节。}/在应用退出前，必须销毁Producer对象，否则会导致内存泄露等问题。...
示例代码
try {/发送消息，只要不抛异常就是成功。SendResultONS sendResult=pProducer->send(msg,shardingKey);std:cout;} catch(ONSClientException&e){/添加对exception的处理。}/在应用退出前，必须销毁Producer对象，否则会导致内存泄露等问题...
Spring 集成
发送消息，只要不抛异常就是成功 try{ SendResult sendResult=producer.send(msg);assert sendResult!null;System.out.println(sendResult);}catch(OMSRuntimeException e){ System.out.println("发送失败");出现异常意味着发送失败，为了...
错误处理
错误类型 捕获异常 如果函数在执行过程中抛出异常，函数计算会捕获到错误，并生成一个包含错误信息、类型和堆栈信息的JSON格式的数据，示例如下所示。ES模块 说明 此示例仅支持运行在Node.js 18及以上版本的运行时环境。当前示例代码支持一...
示例代码
同步发送消息，只要不抛异常就是成功。if(sendResult!null){ System.out.println(new Date()+"Send mq message success.Topic is:"+msg.getTopic()+"msgId is:"+sendResult.getMessageId());} } catch(Exception e){/消息发送失败，需要...
处理异常
异常分类 异常产生的原因有以下几类：通过调用 Revert()或 Require()主动抛出异常，此时异常信息会进入到交易回执的 output 字段中。合约代码存在逻辑错误，导致mychainlib等第三方库中抛出异常。合约代码存在逻辑错误，导致虚拟机执行字节...
客户端连接常见问题
}@Override public void messageArrived(String s,MqttMessage mqttMessage)throws Exception {/*消费消息的回调接口，需要确保该接口不抛异常，该接口运行返回即代表消息消费成功。消费消息需要保证在规定时间内完成，如果消费耗时超过...
处理异常
异常分类 异常产生的原因有以下几类：通过调用 Revert()或 Require()主动抛出异常，此时异常信息会进入到交易回执的 output 字段中。合约代码存在逻辑错误，导致mychainlib等第三方库中抛出异常。合约代码存在逻辑错误，导致虚拟机执行字节...
收发定时消息
发送消息，只要不抛出异常，就代表发送成功。try { SendResultONS sendResult=pProducer.send(msg);} catch(ONSClientException e){/发送失败处理。}/在应用退出前，必须销毁Producer对象，否则会导致内存泄露等问题。pProducer.shutdown()...
VPC接入
如果仅需要在VPC网络接入 云消息队列 Kafka 版，您可以购买并部署VPC实例。前提条件 已授予 云消息队列 Kafka 版 访问其他云服务资源的权限。具体信息，请参见 步骤一：获取访问授权。已搭建VPC网络。具体操作，请参见 创建和管理专有网络...
公网和VPC接入
如果需要同时在VPC网络和公网接入 云消息队列 Kafka 版，您需要购买并部署公网/VPC实例。前提条件 已授予 云消息队列 Kafka 版 访问其他云服务资源的权限。具体信息，请参见 获取访问授权。已搭建VPC网络。具体操作，请参见 创建和管理专有...
Modbus驱动
Link IoT Edge提供Modbus官方驱动，用于支持工业领域广泛应用的Modbus通信协议设备。本文主要介绍Modbus驱动及其用法。概览 Modbus是常用的应用层数据通信协议，阿里云官方Modbus驱动（以下简称Modbus驱动）支持Modbus RTU和Modbus TCP两种...
JDBC连接表格存储
注意事项 目前支持使用SQL查询功能的地域有华东1（杭州）、华东2（上海）、华北2（北京）、华北3（张家口）、华北5（呼和浩特）、华北6（乌兰察布）、华南1（深圳）、西南1（成都）、中国香港、新加坡、印度尼西亚（雅加达）、印度（孟买）...
错误码
SDK 集成相关 错误码 错误消息 错误说明 解决方案 DTX-000 dtx component scanner init error.SDK 启动失败，分布式事务不可用。DTX-001 Bean[%s]can not have@DtxTransaction and@TccBusinessAction both.同一个 bean 不能既有@...
快速使用MQTT的Java SDK收发消息（终端和终端消息收发...
}@Override public void messageArrived(String s,MqttMessage mqttMessage)throws Exception {/*消费消息的回调接口，需要确保该接口不抛异常，该接口运行返回即代表消息消费成功。消费消息需要保证在规定时间内完成，如果消费耗时超过...
收发事务消息
当步骤1半事务消息发送完成，但本地事务返回状态为 TransactionStatus.Unknow 时，亦或是应用退出导致本地事务未提交任何状态时，从Broker的角度看，这条半状态的消息的状态是未知的，因此Broker会定期向消息发送方即消息生产者集群中的...
迁移上云操作
和开源Apache RocketMQ相比，阿里云 云消息队列 RocketMQ 版 具有更高的稳定性、安全性及更完善的运维体系。您可以将开源RocketMQ集群迁移到 云消息队列 RocketMQ 版 上以获得更好的业务体验。本文为您介绍如何使用 云消息队列 RocketMQ 版...
- 产品推荐
- 这些文档可能帮助您