共计 2031 个字符,预计需要花费 6 分钟才能阅读完成。
应用 Java 模仿客户端实际 CoAP
筹备工作
- IDEA 开发工具【IntelliJ IDEA 2023.1.1 (Community Edition)】
- JDK11 及以上
- MAVEN【个别 IDEA 曾经集成】(有最好,不须要手动下载 jar 引入,没有的话手动引入)
PS:【Community Edition】教育版收费
PS: 在页面最上面
CoAP 外围包
- californium-core.jar:包含 CoAP 外围局部
- element-connector.jar 包含实用于 UDP 和 DTLS 的 java 套接字形象层
-
scandium.jar: 包含 DTLS
创立我的项目
- Language– Java。
- Build system– Maven。
- JDK– JDK_version_11.XX.XX。
成果如下:
单击“Create”; 创立胜利如下:
筹备代码
pom.xml 代码中退出依赖包
代码块,放在之下
<dependencies>
<dependency>
<groupId>org.eclipse.californium</groupId>
<artifactId>californium-core</artifactId>
<version>2.0.0-M7</version>
</dependency>
<dependency>
<groupId>org.eclipse.californium</groupId>
<artifactId>element-connector</artifactId>
<version>2.0.0-M7</version>
</dependency>
<dependency>
<groupId>org.eclipse.californium</groupId>
<artifactId>scandium</artifactId>
<version>2.0.0-M7</version>
</dependency>
</dependencies>
成果如下:
依赖包配置文件退出之后;执行一下 install 下载依赖包;成果如下:
Main.java 中;替换所以代码
package org.example;
import org.eclipse.californium.core.CoapClient;
import org.eclipse.californium.core.CoapResponse;
import org.eclipse.californium.core.Utils;
import org.eclipse.californium.core.coap.MediaTypeRegistry;
import java.net.URI;
import java.net.URISyntaxException;
public class Main {public static void main(String[] args) throws URISyntaxException, InterruptedException {
// 拜访令牌 - 与平台端保持一致
String ACCESS_TOKEN = "Za3E3cfKZmXV5eBOzCRW";
// 服务器 IP 地址,填上你的 IP
String ip = "101.133.***.**";
// 遥测数据上传接口,留神默认端口为 5683
String url = "coap://" + ip + ":5683/api/v1/" + ACCESS_TOKEN + "/telemetry";
// 创立一个资源申请
URI uri = new URI(url);
CoapClient client = new CoapClient(uri);
//POST 申请
CoapResponse response;
// 反对数据格式是{"key1":"value1", "key2":"value2"}
String payload = "{\"temp\":\"21.5\", \"wet\":\"37.5\"}";
while (true) {
// 每隔 5 秒循环发送
Thread.currentThread().sleep(5000);
// 只反对 POST 申请,切为【JSON 格局】response = client.post(payload, MediaTypeRegistry.APPLICATION_JSON);
if (response != null) {
// 打印申请状态码
System.out.println(response.getCode());
// 选项参数
System.out.println(response.getOptions());
// 获取响应内容文本信息
System.out.println(response.getResponseText());
System.out.println("\nAdvanced\n");
// 打印格局良好的输入
System.out.println(Utils.prettyPrint(response));
}
}
}
}
文章起源(首发地址):ThingsKit 物联网平台
正文完