Java SDK接入示例

运行 AmqpClient.java 程序。成功:返回类似如下日志信息,表示AMQP客户端已接入物联网平台并成功接收消息。topic=*/*/thing/event/property/post,message=2*7,content={"temperature":29,"humidity":29,"time":1617357297270} 参数 说明 ...

设置SSL加密

说明 在Java中使用JKS证书文件时,jdk7和jdk8需要修改默认的jdk安全配置,在连接PolarDB数据库的服务器的 jre/lib/security/java.security 文件中,修改如下两项配置:jdk.tls.disabledAlgorithms=SSLv3,RC4,DH keySize,RSA keySize若不...

Java UDAF

Resolve("double->double")public class AggrAvg extends Aggregator {/实现Java类的方法。private static class AvgBuffer implements Writable { private double sum=0;private long count=0;Override public void write(DataOutput out)...

Java SDK使用说明

物联网平台提供的Java SDK,可以帮助开发人员通过Java程序更便捷地操作物联网平台。开发人员可以添加包含Maven依赖的SDK,也可以下载安装包到本地直接安装。安装SDK 安装Java开发环境。您可以从 Java 官方网站 下载,并按说明安装Java开发...

通过Syslog投递日志到SIEM

并发消费 基于消费组的程序,可以直接启动多次程序实现并发效果。nohup python3 sync_data.py&nohup python3 sync_data.py&nohup python3 sync_data.py&.说明 所有消费者的名称均不相同(消费者名以进程ID为后缀),且属于同一个消费组。...

配置Gremlin请求超时时间

cd/home/gdb-gremlin-test 执行如下命令,编译并执行Java程序。mvn compile exec:java-Dexec.args="/home/apache-tinkerpop-gmlin-console-3.4.0/conf/gdb-remote.yaml"Python 执行如下命令,初始化客户端。client=client.Client('ws:/${...

对接JDBC

使用Java的JDBC、Python的MySQLdb等库在程序中访问日志服务,在程序中处理查询结果。日志示例 以共享单车日志为例,共享单车日志内容包括用户年龄、性别、电量使用量、车辆ID、操作延时、纬度、锁类型、经度、操作类型、操作结果和开锁方式...

Java SDK使用说明

物联网平台提供的Java SDK,可帮助开发人员通过Java程序更便捷地操作物联网平台。开发人员可以添加包含Maven依赖的SDK,也可以下载安装包到本地直接安装。安装SDK 安装Java开发环境。您可以从 Java 官方网站 下载,并按说明安装Java开发...

订阅消息

本文介绍如何通过 云消息队列 RocketMQ 版 的Java SDK订阅消息。订阅方式 云消息队列 RocketMQ 版 支持以下两种订阅方式:集群订阅 同一个Group ID所标识的所有Consumer平均分摊消费消息。例如某个Topic有9条消息,一个Group ID有3个...

操作链路概述

发送消息 您可以通过控制台发送测试消息或通过调用 TCP Java SDK 发送消息。发送测试消息 用于快速验证 Topic 资源的可用性,主要用作测试。在左侧导航栏,选择 中间件>消息队列>Topic 管理。在 Topic 管理页面,找到您刚刚创建的 Topic,...

MaxCompute UDF(Java)常见问题

解决措施:如果实际计算量很大,可以在MaxCompute UDF的实现Java类的方法中调用 ExecutionContext.claimAlive 来重置计时器。重点优化MaxCompute UDF代码逻辑。后续调用MaxCompute UDF时,可同时在Session级别配置如下参数辅助调节...

医疗

解决方案 借助 mPaas 小程序实现 App 端多个业务模块改造,不仅获得媲美原生应用的用户体验,同时能有效规避“发版周期长”、“无法快速在线修复 Bug”等弊端,实现真正的动态发布与更新能力。基于 mPaaS,后续将进一步接入其他组件能力...

接入示例(一方认证)

本示例使用Java语言开发设备程序,准备Java开发环境如下:JDK版本:JDK8 集成开发环境:IntelliJ IDEA社区版 下载开源代码 本示例对开源的Demo做了简化,需要打上 Patch文件。具体操作如下:执行以下命令,获取到Demo文件 tsp。git clone ...

使用ACK Net Exporter定位网络问题

type=PACKETLOSS pod=hostNetwork namespace=hostNetwork protocol=TCP saddr=10.1.17.172 sport=6443 daddr=10.1.17.176 dport=43018 stacktrace:skb_release_data+0xA3_kfree_skb+0xE tcp_recvmsg+0x61D inet_recvmsg+0x58 sock_read_...

CLB健康检查工作原理

实现机制可能会导致后端服务器认为相关TCP连接出现异常(非正常退出),并在业务软件如Java连接池等日志中抛出相应的错误信息,如 Connection reset by peer。解决方案:TCP监听采用HTTP方式进行健康检查。在后端服务器配置了获取客户端...

多种阿里云SDK的托管凭据插件

阿里云SDK名称 支持插件的SDK版本 对应SDK的托管凭据插件 阿里云Java SDK 4.3.2~4.5.17 阿里云Java SDK托管凭据插件 OSS Java SDK 2.1.0~3.10.2 OSS Java SDK托管凭据插件 消息队列商业版TCP协议Java SDK 1.8.5.Final~1.8.7.4.Final 消息...

Linux系统常用内核网络参数介绍与常见问题处理

本文介绍常见的Linux系统内核网络参数及常见问题的解决方案。注意事项 在修改内核参数前,您需要注意以下几点:从实际需求出发,尽量有相关数据的支撑,不建议您随意调整内核参数。了解参数的具体作用,需注意不同类型或...net.ipv4.tcp...

Linux系统常用内核网络参数介绍与常见问题处理

本文介绍常见的Linux系统内核网络参数及常见问题的解决方案。注意事项 在修改内核参数前,您需要注意以下几点:从实际需求出发,尽量有相关数据的支撑,不建议您随意调整内核参数。了解参数的具体作用,需注意不同类型或...net.ipv4.tcp...

为Spring Boot应用设置健康检查

对于Spring Boot的应用,除了使用HTTP或TCP端口检测来进行应用健康检查之外,您也可以使用Actuator组件实现定制化健康检查。本文介绍如何通过Actuator组件为Spring Boot应用设置健康检查。背景信息 Actuator组件是Spring Boot提供的用来对...

云安全中心反弹Shell多维检测技术详解

受害服务器主动连接攻击者的服务端程序,攻击者的服务端通过监听来自受害服务器的请求,对目标服务器下发指令并获取执行结果,以达到攻击者可以控制受害服务器的目的。反弹Shell攻击现状 阿里云安全团队通过分析历史中云上环境的Linux...

实现 Dubbo 断网

结果验证 执行程序后,日志输出内容如下:2019-02-01 17:20:30[INFO][main]c.a.p.c.client.utils.NetAccessUtils-Block port 8085 protcol TCP,dalay time 20 seconds.2019-02-01 17:20:45[INFO][main]c.a.p.rocketmq.TestDubboNetwork-...

新手指引

选择 SAE内置Nacos 后,SAE 通过自动注入相关环境变量以及借助于Java Agent修改字节码的技术,支持自动修改程序的注册中心地址。因此,您无需对程序做任何修改即可将其直接部署到 SAE。不适用于使用非Nacos注册中心的程序,相关逻辑完全由...

获取MQTT客户端在线状态

云消息队列 RocketMQ 版 的接收程序请参见 订阅消息。示例代码详细信息,请参见 MQTTClientStatusNoticeProcessDemo.java。事件类型放在 云消息队列 RocketMQ 版 的Tag中,代表上线或下线。数据格式如下:MQ Tag:connect/disconnect/...

MQTT客户端上下线事件数据流出

云消息队列 RocketMQ 版 的接收程序,请参见 订阅消息。示例代码详细信息,请参见 MQTTClientStatusNoticeProcessDemo.java。事件类型放在 云消息队列 RocketMQ 版 的Tag中,代表上线或下线。数据格式如下:MQ Tag:connect/disconnect/...

Paho-MQTT Android接入示例

您需编写程序调用 AiotMqttOption.java 中的 AiotMqttOption()类计算MQTT连接参数,实现接入物联网平台和通信。开发说明和示例代码如下:计算MQTT连接参数 clientId、username 和 password,并将 username 和 password 设置到 ...

RAM凭据插件

消息队列商业版 TCP协议Java SDK ons-client-managed-credentials-provider 无。Python SDK 阿里云SDK名称 RAM凭据插件模块名称 说明 阿里云 Python SDK(V1.0)aliyun-openapi-python-sdk-managed-credentials-provider 仅支持V1.0版本,...

事件请求处理程序(Event Handler)

本文介绍Java事件请求处理程序的结构特点和示例。处理程序接口 您在使用Java编程时,必须要实现 函数计算 提供的接口类,fc-java-core 库为事件请求处理程序定义了以下两个接口...java11-blank-pojo-event:使用POJO格式的事件回调处理程序。

配置基于ALB网关的全链路灰度

场景示例:按照域名路由,实现全链路灰度 若应用的架构由ALB负载均衡以及后端的微服务架构(Spring Cloud)组成,后端调用链路有3个:交易中心(A)、商品中心(B)和库存中心(C),可以通过客户端或者是HTML来访问后端服务,这些服务之间...

功能与特性概述

事务消息 实现类似XA或Open XA的分布事务功能,以达到事务最终一致性状态。small-tile {height:130px!important;min-width:auto!important;} 表 1.消息类型对比 消息类型 是否支持可靠同步发送 是否支持可靠异步发送 是否支持Oneway发送 ...

基于MSE Ingress的全链路灰度

通过MSE Ingress网关提供的全链路灰度能力,您可以在不需要修改任何业务代码的情况下,实现全链路流量控制。本文介绍如何通过MSE Ingress网关实现全链路灰度功能。前提条件 已创建Kubernetes集群。具体操作,请参见 创建Kubernetes托管版...

配置推空保护

部署Demo应用程序 在 容器服务控制台 左侧导航栏,单击 集群。在 集群列表 页面,单击目标集群名称。在集群管理页左侧导航栏,选择 工作负载>无状态。在 无状态 页面的顶部,选择 命名空间,然后单击 使用YAML创建资源。对模板进行相关配置...

基于Ingress-APISIX网关实现全链路灰度

通过Ingress-APISIX提供的灵活的路由功能,您可以在不需要修改任何业务代码的情况下,实现全链路灰度能力。本文介绍如何通过Ingress-APISIX实现全链路灰度功能。前提条件 创建Kubernetes集群。具体操作,请参见 创建Kubernetes托管版集群、...

常见报错

Connection to xxx not allowed.This Partition is not known in the cluster view.io.lettuce.core.RedisConnectionException:Unable to connect xxx java.nio.channels.UnresolvedAddressException ERR Unknown sentinel subcommand '...

常见报错

Connection to xxx not allowed.This Partition is not known in the cluster view.io.lettuce.core.RedisConnectionException:Unable to connect xxx java.nio.channels.UnresolvedAddressException ERR Unknown sentinel subcommand '...

连接方式概述

Java 数据库连接器(Java Database Connectivity,JDBC)提供了 Java 连接关系数据库的接口,是一种 Java 标准。JDBC 标准由 Sun Microsystems 定义,通过标准 java.sql 接口实现,支持各个提供程序使用自己的 JDBC 驱动程序来实现和扩展...

快速入门

在新建的WordCount.java脚本界面,编写WordCount MapReduce程序实现统计单词个数功能。WordCount完整代码示例,请参见 代码示例。在左侧导航栏的WordCount.java脚本上,单击右键,选择 Run。在 Run/Debug Configurations 对话框,配置 ...

请求处理程序(Handler)

您可以使用Java请求处理程序响应接收到的事件并执行相应的业务逻辑。本文介绍Java请求处理程序的相关概念、结构特点和示例。...什么是请求处理程序 FC 函数的请求处理程序,是函数...java11-blank-pojo-event:使用POJO格式的事件回调处理程序。

开发Graph

前提条件 您需要完成以下操作:管理项目连接 创建MaxCompute Java Module 编写Graph 在 Project 区域,右键单击Module的源码目录(即 src>main>java),选择 new>MaxCompute Java。填写 Name 并选择类型为 GraphLoader 或 Vertex,按下...

应用适配概述

Alibaba Cloud Linux 3操作系统基于阿里云弹性RDMA技术首次将SMC-R带上云上场景,实现TCP应用透明无损的替换,提供高性能、普惠的硬件卸载网络。更多信息,请参见 共享内存通信(SMC)使用说明。用户态适配方案:NetACC NetACC(Network ...

架构模块介绍

本文介绍 SOFARPC 的架构模块。工程架构 SOFARPC 架构如下所示:SOFARPC 从下到上...core transport-网络传输实现模块 TCP 连接的建立、数据分包粘包处理、请求响应对象分发等。core registry-注册中心实现模块 实现注册中心,例如 zk。core
共有200条 < 1 2 3 4 ... 200 >
跳转至: GO
产品推荐
云服务器 安全管家服务 安全中心
这些文档可能帮助您
云监控 应用实时监控服务 文件存储NAS 弹性公网IP 短信服务 人工智能平台 PAI
新人特惠 爆款特惠 最新活动 免费试用