快速使用MQTT的Java SDK收发消息（终端和云端消息收发...
本文介绍如何快速使用 云消息队列 MQTT 版 的Java SDK实现MQTT终端和云端服务的消息收发。前提条件 创建资源 获取AccessKey 安装 IDE。您可以使用IntelliJ IDEA或者Eclipse，本文以IntelliJ IDEA为例。下载安装 JDK。背景信息 MQTT终端和...
订阅消息
本文介绍如何通过 SOFAStack 消息队列的 Java SDK 订阅消息。订阅方式 消息队列支持以下两种订阅方式：集群订阅同一个 Group ID 所标识的所有 Consumer 平均分摊消费消息。例如某个 Topic 有 9 条消息，一个 Group ID 有 3 个 Consumer ...
MQTT和RocketMQ进行数据互通（客户端上下线通知）
MQTT客户端的上下线事件将会触发MQTT服务端生成一条通知消息，云消息队列 MQTT 版 支持将该条消息数据导出至其他阿里云产品，并使用MQTT的Java SDK实现MQTT客户端与后端应用收发消息。本文以当前仅支持的 云消息队列 RocketMQ 版 数据互通...
接口和参数说明
SOFAStack 消息队列提供 Java SDK 实现消息发送与订阅，您可通过本文了解消息发送和订阅相关接口的参数说明。通用参数 参数名 参数说明 ENDPOINT 设置 TCP 协议接入点，从消息队列控制台的 概览>接入配置 获取。INSTANCE_ID 设置实例 ID，...
MQTT和RocketMQ进行数据互通（跨产品数据流入）
如果您的云端应用需要使用 云消息队列 RocketMQ 版 产品的某些功能，例如顺序消息特性、事务消息特性等，您可以通过消息流入或流出规则将 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 数据进行流转。本文介绍如何将 云消息队列 RocketMQ...
MQTT和RocketMQ进行数据互通（跨产品数据流出）
如果您的云端应用需要使用 云消息队列 RocketMQ 版 产品的某些功能，例如顺序消息特性、事务消息特性等，您可以通过消息流入或流出规则将 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 数据进行流转。本文介绍如何将 云消息队列 MQTT 版 ...
接收消息通知
通知发布成功后，您可以在消息服务MNS（Message Service）中通过队列方式或主题通知方式接收消息通知。本文为您介绍如何接收消息通知。前提条件 您已设置消息通知。具体操作，请参见 设置消息通知。队列方式接收消息通知 使用Java SDK接收...
接口和参数说明
云消息队列 RocketMQ 版 提供Java SDK实现消息发送与订阅，订阅方可通过Push或Pull的方式从 云消息队列 RocketMQ 版 获取消息。本文介绍消息发送和订阅的接口和参数说明。背景信息 云消息队列 RocketMQ 版 支持以下两种消息获取方式：Push...
Java SDK版本说明
说明 使用Java SDK时，建议将其升级至1.1.9及以上版本。添加jaxb依赖 当使用Java 9及以上版本时，需要在pom.xml中添加jaxb相关依赖。groupId>javax.xml.bind</groupId><artifactId>jaxb-api</artifactId><version>2.3.1...
通过SkyWalking上报Java应用数据
Java Agent插件 SkyWalking Java Agent支持多种中间件、框架和库。支持的所有插件可在示例Demo的/plugins 文件夹下查看。激活插件 所有在/plugins 文件夹下的插件都是已被激活的插件。若从/plugins 中移除某个插件的jar包，则表示插件不...
通过SkyWalking上报Java应用数据
Java Agent插件 SkyWalking Java Agent支持多种中间件、框架和库。支持的所有插件可在示例Demo的/plugins 文件夹下查看。激活插件 所有在/plugins 文件夹下的插件都是已被激活的插件。若从/plugins 中移除某个插件的jar包，则表示插件不...
消息类型
TCP Java SDK 收发普通消息的示例代码 发送普通消息（三种方式）发送消息（多线程）订阅消息 定时和延时消息 定时消息：Producer 将消息发送到消息队列服务端，但并不期望这条消息立马投递，而是推迟到在当前时间点之后的某一个时间投递到 ...
可观测性体系概述
作为一款典型的分布式中间件产品，云消息队列 RocketMQ 版 被广泛应用于业务核心链路中，每条消息都关联着核心业务数据的变化，通过可观测能力及时发现问题、定位问题、解决问题对于业务运行是一项重要的保障能力。本文介绍 云消息队列 ...
开通消息服务MNS并授权
步骤一：开通消息服务MNS 登录 阿里云官网，选择 产品>中间件>云消息队列>消息服务 MNS。在产品页，单击 立即开通。请仔细阅读 消息服务MNS服务协议，选中 消息服务MNS服务协议，然后单击 立即开通。页面显示 恭喜，开通成功！步骤二：...
概述
物联网平台提供设备上云、设备上报消息、云端订阅设备消息、云端下发指令到设备等服务，本文以路灯设备接入物联网平台为例，介绍设备如何接入物联网平台，及如何从物联网平台控制设备开关，帮助您快速了解物联网平台的基础能力。...
Java 驱动连接 OceanBase 数据库
本文介绍了 Java 如何使用 OceanBase Connector/J 驱动连接并使用 OceanBase 数据库。前提条件 确保设置了基本的数据库开发环境。确保计算机上的 Java 环境为 Java JDK 8 版本。获取 OceanBase Connector/J 驱动程序。请在 OceanBase 官方...
概述
本文帮助您快速了解物联网平台的基础能力，包括设备接入物联网平台、设备上报消息至物联网平台、服务端订阅设备消息、从物联网平台下发指令到设备等。前提条件 开通 物联网平台服务。说明 免费开通后，您可先试用物联网平台服务，试用流程...
新建工程
结合中间件 SOFAREST 服务，可提供基于 JAX-RS（Java API for RESTful Web Services）标准的前后端分离解决方案。Core 工程：通常用于实现无页面展现的后端服务。当使用 SOFABoot 开发一个 J2SE 程序（无 Web 页面访问），相当于“基于 ...
ARMS应用监控支持的Java组件和框架
消息相关 RocketMQ Java Client 4.X Spring-RocketMQ 2.0.X~2.2.X Aliyun ONS 1.X+RabbitMQ Java Client 4.X+Kafka-client 1.0.X~3.5.X 定时任务 XXLJob 2.0.X~2.4.X ElasticJob 2.0.X~2.1.X SchedulerX 1.2.X~1.5.X Spring Scheduled 3.2....
采集部署
profiler.app.port=8080#应用启动端口，应用有很多个不同功能的端口，只配请求的那个端口即可，一个JVM下无论是否一个应用都只配置一个 profiler.applicationservertype=TOMCAT#应用中间件容器类型，TOMCAT\JBOSS\WEBLOGIC等。以下非必选...
订阅者最佳实践
Java客户端可以通过 auto.offset.reset 来配置重置策略，主要有三种策略：latest：从最大位点开始消费。earliest：从最小位点开始消费。none：不做任何操作，即不重置。说明 建议设置成latest，而不要设置成earliest，避免因位点非法时从头...
上下游存储
问题现象 来自Kafka数据源的消息，这些消息数据被序列化成了两个JSON格式的串。这种情况下，键（key）和值（value）的内容中，均存在一个相同名称的字段（例如示例中id字段）。如果将其直接解析为Flink表进行处理，将会引发现字段命名冲突...
制作Java镜像
EDAS_CATALINA_OPTS 中间件运行时所需的 CATALINA_OPTS 参数。CATALINA_OPTS 与 EDAS_CATALINA_OPTS 类似，默认Tomcat启动参数。CATALINA_HOME 安装的Tomcat路径。PANDORA_LOCATION 安装的Pandora路径，仅HSF应用中可见。Spring Cloud或...
序列化方式选择
序列化的过程是将Java对象转成byte数组在网络中传输，反序列化会将byte数组转成Java对象。简介 序列化的选择需要考虑兼容性，性能等因素，HSF的序列化方式支持java、hessian2，默认是hessian2。序列化方式的对比和配置（只在服务端配置HSF...
序列化方式选择
序列化的过程是将Java对象转成byte数组在网络中传输，反序列化会将byte数组转成Java对象。简介 序列化的选择需要考虑兼容性，性能等因素，HSF的序列化方式支持java、hessian2，默认是hessian2。序列化方式的对比和配置（只在服务端配置HSF...
制作 SOFABoot 应用的 Docker 镜像
在将应用工程打包成 Docker 镜像的方法...web-1.0.0.jar/app.jar ENV JAVA_OPTS=""#商业版 SOFAStack 中间件需要输入四元组进行服务端注册鉴权，可以按照以下约定，在进行容器化发布时以环境变量方式注入。详情请参见服务网格的快速入门文档。...
连接方式概述
Java 数据库连接器（Java Database Connectivity，JDBC）提供了 Java 连接关系数据库的接口，是一种 Java 标准。JDBC 标准由 Sun Microsystems 定义，通过标准 java.sql 接口实现，支持各个提供程序使用自己的 JDBC 驱动程序来实现和扩展...
接入JVM监控数据（新版）
Java Virtual Machine（JVM）提供多项监控指标，您可以将JVM中的监控指标接入到全栈可观测应用中，进行可视化展示。前提条件 已创建全栈可观测实例。具体操作，请参见 创建实例。已在服务器上安装Java 1.7或以上版本。基本原理 Java ...
单元测试
测试类路径：测试基类（AbstractTestBasesrc）：projectName/app/web/src/main/test/java/./base/AbstractTestBase.java 测试子类（SofaRestServiceTest）：projectName/app/web/src/main/test/java/./usercases/SofaRestServiceTest.java ...
使用Prometheus监控MicroMeter的Java应用
本文介绍如何使用Prometheus监控MicroMeter的Java应用。前提条件 已创建Java应用。这里以目前最常用的 Spring Boot 2.x 应用为例介绍。步骤一：将Spring Boot Actuator加入Java应用 在Project的pom.xml中添加 Actuator 依赖。...
使用Prometheus监控MicroMeter的Java应用
本文介绍如何使用Prometheus监控MicroMeter的Java应用。前提条件 已创建Java应用。已创建Prometheus for ECS或容器服务实例，具体步骤，请参见 Prometheus实例 for ECS 和 Prometheus实例 for 容器服务。这里以目前最常用的 Spring Boot 2....
DescribePropertyScaItem-查询资产指纹调查中间件列表
查询资产指纹调查中间件列表。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。调试 授权信息 下表是API对应的授权信息，可以在RAM权限策略语句的 Action ...
Java SDK
本文介绍如何使用智能语音交互流式文本语音合成的Java SDK，包括SDK的安装方法及SDK代码示例等。前提条件 在使用SDK之前，请先阅读 接口说明。下载安装 从Maven服务器下载最新版本的SDK nls-sdk-java-demo+flowingtts+3.zip。...
SAE弹性伸缩最佳实践
考虑梳理上下游、中间件和DB等相关依赖性，并配置对应的弹性规则或限流降级手段，以确保扩容时全链路的可用性。弹性规则配置完成后，您可以通过监控并调整弹性规则使容量接近应用实际负载。关于查看监控的具体步骤，请参见 基础监控。配置...
查看日志
默认设置 日志门面：默认为 SLF4J（Simple Logging Facade for Java）日志实现：默认通过 Logback 实现 中间件日志 关于各个中间件的日志详细信息，参见 日志格式。应用日志 假设用工程原型创建的工程依赖信息为下述内容：groupId：...
SOFAArk 配置说明
本文介绍 SOFAArk 的配置目录，以及各配置说明。SOFAArk 配置目录 SOFAArk 的配置目录不是必须存在，如果需要，统一放在工程根...通过应用启动参数传入 例如：java-jar demo-executable-ark.jar-Aprofile=dev,dev2，多个值英文逗号（,）隔开。
动态配置快速入门
} } 代码说明：该配置类是一个普通的 Java 类，要符合 Java Bean 的规范，有若干私有属性，属性有对应的 get 和 set 方法。例如上面的 name、age、man 称为资源属性，资源属性只允许 String 和基本类型。在配置类上加上@DObject 注解，它的...
应用身份识别
根据您选择的中间件类型，控制台会显示可选的中间件版本供您选择。JDK版本 选择JDK（Java语言软件开发工具包）版本。数据库类型 选择数据库类型，请根据数据库的实际情况选择。可选项：Oracle MySQL SQLServer PostgreSQL DB2 登录URL关键...
DescribePropertyTypeScaItem-查询资产指纹中间件类型...
查询资产指纹中间件类型列表。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。调试 授权信息 下表是API对应的授权信息，可以在RAM权限策略语句的 Action ...
发布 SOFARPC 服务
RPC 是日常开发中最常用的中间件，本文主要说明如何发布一个 RPC 服务。前提条件 已完成环境搭建。具体步骤，请参见 搭建环境。已下载 示例工程。已将工程导入 IDE 工具。具体操作，请参见 快速入门。发布 SOFARPC 服务 要发布一个 RPC ...
- 产品推荐
- 这些文档可能帮助您