From 48a01752f274e8d455f4a63217728f5192341d42 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=AD=99=E5=B0=8F=E4=BA=91?= Date: Wed, 10 Dec 2025 11:18:09 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E4=BA=86ZLM=20SDK=E7=9A=84?= =?UTF-8?q?=E5=86=85=E5=AE=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/main/java/com/tuoheng/App.java | 56 ----- src/main/java/com/tuoheng/IOTClient.java | 74 +++++++ src/main/java/com/tuoheng/ZlmClient.java | 271 +++++++++++++++++++++++ 3 files changed, 345 insertions(+), 56 deletions(-) create mode 100644 src/main/java/com/tuoheng/IOTClient.java create mode 100644 src/main/java/com/tuoheng/ZlmClient.java diff --git a/src/main/java/com/tuoheng/App.java b/src/main/java/com/tuoheng/App.java index 4d0a07e..d8592da 100644 --- a/src/main/java/com/tuoheng/App.java +++ b/src/main/java/com/tuoheng/App.java @@ -23,61 +23,5 @@ public class App { public static void main(String[] args) { - // ThingsBoard REST API URL - String url = "http://iot.t-aaron.com:18080"; - // Default Tenant Administrator credentials - String username = "tenant@thingsboard.org"; - String password = "tuoheng2023"; - // Creating new rest client and auth with credentials - RestClient client = new RestClient(url); - client.login(username, password); - - PageData tenantDevices; - PageLink pageLink = new PageLink(10); - do { - // Fetch all tenant devices using current page link and print each of them - tenantDevices = client.getTenantDevices("", pageLink); -// tenantDevices.getData().forEach(System.out::println); - for (Device device : tenantDevices.getData()) { - System.out.println(device.getName()); - System.out.println(device.getId().getEntityType().name()); - - ArrayList arrayList = new ArrayList(); - arrayList.add("connectorType"); - arrayList.add("humidity"); - arrayList.add("data.job_number"); - List attributeKvEntries = client.getAttributeKvEntries(device.getId(), arrayList); - - for (AttributeKvEntry attributeKvEntry : attributeKvEntries) { - System.out.println(attributeKvEntry.getKey() + ":" + attributeKvEntry.getValue()); - } - - if(device.getId().getEntityType().name().equals("DEVICE")) { - List kvEntries = client.getTimeseriesKeys(device.getId()); - if(!CollectionsUtil.isEmpty(kvEntries)){ - - List latest = client.getLatestTimeseries(device.getId(),kvEntries); - if(!CollectionsUtil.isEmpty(latest)){ - for(TsKvEntry latestKvEntry : latest){ - System.out.println(latestKvEntry.getKey() + ":" + latestKvEntry.getValue()); - } - } - } - } - - - } - - pageLink = pageLink.nextPageLink(); - } while (tenantDevices.hasNext()); - - // Get information of current logged in user and print it -// client.getUser().ifPresent(System.out::println); - - // Perform logout of current user and close the client - - - client.logout(); - client.close(); } } diff --git a/src/main/java/com/tuoheng/IOTClient.java b/src/main/java/com/tuoheng/IOTClient.java new file mode 100644 index 0000000..eacc668 --- /dev/null +++ b/src/main/java/com/tuoheng/IOTClient.java @@ -0,0 +1,74 @@ +package com.tuoheng; + +import org.thingsboard.rest.client.RestClient; +import org.thingsboard.server.common.data.Device; +import org.thingsboard.server.common.data.kv.AttributeKvEntry; +import org.thingsboard.server.common.data.kv.TsKvEntry; +import org.thingsboard.server.common.data.page.PageData; +import org.thingsboard.server.common.data.page.PageLink; +import org.thingsboard.server.common.data.util.CollectionsUtil; + +import java.util.ArrayList; +import java.util.List; + +public class IOTClient { + public static void main(String[] args) { + + // ThingsBoard REST API URL + String url = "http://iot.t-aaron.com:18080"; + // Default Tenant Administrator credentials + String username = "tenant@thingsboard.org"; + String password = "tuoheng2023"; + // Creating new rest client and auth with credentials + RestClient client = new RestClient(url); + client.login(username, password); + + PageData tenantDevices; + PageLink pageLink = new PageLink(10); + do { + // Fetch all tenant devices using current page link and print each of them + tenantDevices = client.getTenantDevices("", pageLink); +// tenantDevices.getData().forEach(System.out::println); + for (Device device : tenantDevices.getData()) { + System.out.println(device.getName()); + System.out.println(device.getId().getEntityType().name()); + + ArrayList arrayList = new ArrayList(); + arrayList.add("connectorType"); + arrayList.add("humidity"); + arrayList.add("data.job_number"); + List attributeKvEntries = client.getAttributeKvEntries(device.getId(), arrayList); + + for (AttributeKvEntry attributeKvEntry : attributeKvEntries) { + System.out.println(attributeKvEntry.getKey() + ":" + attributeKvEntry.getValue()); + } + + if(device.getId().getEntityType().name().equals("DEVICE")) { + List kvEntries = client.getTimeseriesKeys(device.getId()); + if(!CollectionsUtil.isEmpty(kvEntries)){ + + List latest = client.getLatestTimeseries(device.getId(),kvEntries); + if(!CollectionsUtil.isEmpty(latest)){ + for(TsKvEntry latestKvEntry : latest){ + System.out.println(latestKvEntry.getKey() + ":" + latestKvEntry.getValue()); + } + } + } + } + + + } + + pageLink = pageLink.nextPageLink(); + } while (tenantDevices.hasNext()); + + // Get information of current logged in user and print it +// client.getUser().ifPresent(System.out::println); + + // Perform logout of current user and close the client + + + client.logout(); + client.close(); + } +} diff --git a/src/main/java/com/tuoheng/ZlmClient.java b/src/main/java/com/tuoheng/ZlmClient.java new file mode 100644 index 0000000..7d7e55e --- /dev/null +++ b/src/main/java/com/tuoheng/ZlmClient.java @@ -0,0 +1,271 @@ +package com.tuoheng; + +import java.io.BufferedReader; +import java.io.InputStreamReader; +import java.net.HttpURLConnection; +import java.net.URL; +import java.net.URLEncoder; +import java.nio.charset.StandardCharsets; + +public class ZlmClient { + + private static final String ZLM_BASE_URL = "http://114.67.89.4:8778"; + private static final String SECRET = "su6TiedN2rVAmBbIDX0aa0QTiBJLBdcf"; + + public static void main(String[] args) { + try { + // 调用 startRecord 方法 +// String result = startRecord(1, "__defaultVhost__", "live", "prod", 86400); +// System.out.println("startRecord 响应结果:"); +// System.out.println(result); +// +// System.out.println("\n" + "=".repeat(50) + "\n"); + + // 调用 isRecording 方法 +// String recordingStatus = isRecording(1, "__defaultVhost__", "live", "prod"); +// System.out.println("isRecording 响应结果:"); +// System.out.println(recordingStatus); +// +// System.out.println("\n" + "=".repeat(50) + "\n"); + + // 调用 getMp4RecordFile 方法 + String mp4Files = getMp4RecordFile("__defaultVhost__", "live", "prod", "2025-12-10"); + System.out.println("getMp4RecordFile 响应结果:"); + System.out.println(mp4Files); + + System.out.println("\n" + "=".repeat(50) + "\n"); + + // 调用 deleteRecordDirectory 方法 + String deleteResult = deleteRecordDirectory("__defaultVhost__", "live", "prod", "2025-12-10"); + System.out.println("deleteRecordDirectory 响应结果:"); + System.out.println(deleteResult); + + System.out.println("\n" + "=".repeat(50) + "\n"); + + // 调用 stopRecord 方法 +// String stopResult = stopRecord(1, "__defaultVhost__", "live", "prod"); +// System.out.println("stopRecord 响应结果:"); +// System.out.println(stopResult); + } catch (Exception e) { + System.err.println("调用失败: " + e.getMessage()); + e.printStackTrace(); + } + } + + /** + * 开始录制 + * + * @param type 类型 (0 或 1) + * @param vhost 虚拟主机 + * @param app 应用名 + * @param stream 流ID + * @param maxSecond 最大录制时长（秒） + * @return 响应结果 JSON 字符串 + * @throws Exception 如果请求失败 + */ + public static String startRecord(int type, String vhost, String app, String stream, int maxSecond) throws Exception { + // 构建 URL 参数 + StringBuilder urlBuilder = new StringBuilder(ZLM_BASE_URL); + urlBuilder.append("/index/api/startRecord?"); + urlBuilder.append("secret=").append(URLEncoder.encode(SECRET, StandardCharsets.UTF_8.name())); + urlBuilder.append("&type=").append(type); + urlBuilder.append("&vhost=").append(URLEncoder.encode(vhost, StandardCharsets.UTF_8.name())); + urlBuilder.append("&app=").append(URLEncoder.encode(app, StandardCharsets.UTF_8.name())); + urlBuilder.append("&stream=").append(URLEncoder.encode(stream, StandardCharsets.UTF_8.name())); + urlBuilder.append("&max_second=").append(maxSecond); + + // 创建 HTTP 连接 + URL url = new URL(urlBuilder.toString()); + HttpURLConnection connection = (HttpURLConnection) url.openConnection(); + connection.setRequestMethod("GET"); + connection.setConnectTimeout(10000); + connection.setReadTimeout(10000); + + // 获取响应 + int responseCode = connection.getResponseCode(); + if (responseCode == HttpURLConnection.HTTP_OK) { + BufferedReader reader = new BufferedReader(new InputStreamReader(connection.getInputStream(), StandardCharsets.UTF_8)); + StringBuilder response = new StringBuilder(); + String line; + while ((line = reader.readLine()) != null) { + response.append(line); + } + reader.close(); + return response.toString(); + } else { + throw new Exception("HTTP 请求失败，状态码: " + responseCode); + } + } + + /** + * 检查录制状态 + * + * @param type 类型 (0 或 1) + * @param vhost 虚拟主机 + * @param app 应用名 + * @param stream 流ID + * @return 响应结果 JSON 字符串 + * @throws Exception 如果请求失败 + */ + public static String isRecording(int type, String vhost, String app, String stream) throws Exception { + // 构建 URL 参数 + StringBuilder urlBuilder = new StringBuilder(ZLM_BASE_URL); + urlBuilder.append("/index/api/isRecording?"); + urlBuilder.append("secret=").append(URLEncoder.encode(SECRET, StandardCharsets.UTF_8.name())); + urlBuilder.append("&type=").append(type); + urlBuilder.append("&vhost=").append(URLEncoder.encode(vhost, StandardCharsets.UTF_8.name())); + urlBuilder.append("&app=").append(URLEncoder.encode(app, StandardCharsets.UTF_8.name())); + urlBuilder.append("&stream=").append(URLEncoder.encode(stream, StandardCharsets.UTF_8.name())); + + // 创建 HTTP 连接 + URL url = new URL(urlBuilder.toString()); + HttpURLConnection connection = (HttpURLConnection) url.openConnection(); + connection.setRequestMethod("GET"); + connection.setConnectTimeout(10000); + connection.setReadTimeout(10000); + + // 获取响应 + int responseCode = connection.getResponseCode(); + if (responseCode == HttpURLConnection.HTTP_OK) { + BufferedReader reader = new BufferedReader(new InputStreamReader(connection.getInputStream(), StandardCharsets.UTF_8)); + StringBuilder response = new StringBuilder(); + String line; + while ((line = reader.readLine()) != null) { + response.append(line); + } + reader.close(); + return response.toString(); + } else { + throw new Exception("HTTP 请求失败，状态码: " + responseCode); + } + } + + /** + * 停止录制 + * + * @param type 类型 (0 或 1) + * @param vhost 虚拟主机 + * @param app 应用名 + * @param stream 流ID + * @return 响应结果 JSON 字符串 + * @throws Exception 如果请求失败 + */ + public static String stopRecord(int type, String vhost, String app, String stream) throws Exception { + // 构建 URL 参数 + StringBuilder urlBuilder = new StringBuilder(ZLM_BASE_URL); + urlBuilder.append("/index/api/stopRecord?"); + urlBuilder.append("secret=").append(URLEncoder.encode(SECRET, StandardCharsets.UTF_8.name())); + urlBuilder.append("&type=").append(type); + urlBuilder.append("&vhost=").append(URLEncoder.encode(vhost, StandardCharsets.UTF_8.name())); + urlBuilder.append("&app=").append(URLEncoder.encode(app, StandardCharsets.UTF_8.name())); + urlBuilder.append("&stream=").append(URLEncoder.encode(stream, StandardCharsets.UTF_8.name())); + + // 创建 HTTP 连接 + URL url = new URL(urlBuilder.toString()); + HttpURLConnection connection = (HttpURLConnection) url.openConnection(); + connection.setRequestMethod("GET"); + connection.setConnectTimeout(10000); + connection.setReadTimeout(10000); + + // 获取响应 + int responseCode = connection.getResponseCode(); + if (responseCode == HttpURLConnection.HTTP_OK) { + BufferedReader reader = new BufferedReader(new InputStreamReader(connection.getInputStream(), StandardCharsets.UTF_8)); + StringBuilder response = new StringBuilder(); + String line; + while ((line = reader.readLine()) != null) { + response.append(line); + } + reader.close(); + return response.toString(); + } else { + throw new Exception("HTTP 请求失败，状态码: " + responseCode); + } + } + + /** + * 获取MP4录制文件列表 + * + * @param vhost 虚拟主机 + * @param app 应用名 + * @param stream 流ID + * @param period 日期 (格式: YYYY-MM-DD) + * @return 响应结果 JSON 字符串 + * @throws Exception 如果请求失败 + */ + public static String getMp4RecordFile(String vhost, String app, String stream, String period) throws Exception { + // 构建 URL 参数 + StringBuilder urlBuilder = new StringBuilder(ZLM_BASE_URL); + urlBuilder.append("/index/api/getMp4RecordFile?"); + urlBuilder.append("secret=").append(URLEncoder.encode(SECRET, StandardCharsets.UTF_8.name())); + urlBuilder.append("&vhost=").append(URLEncoder.encode(vhost, StandardCharsets.UTF_8.name())); + urlBuilder.append("&app=").append(URLEncoder.encode(app, StandardCharsets.UTF_8.name())); + urlBuilder.append("&stream=").append(URLEncoder.encode(stream, StandardCharsets.UTF_8.name())); + urlBuilder.append("&period=").append(URLEncoder.encode(period, StandardCharsets.UTF_8.name())); + + // 创建 HTTP 连接 + URL url = new URL(urlBuilder.toString()); + HttpURLConnection connection = (HttpURLConnection) url.openConnection(); + connection.setRequestMethod("GET"); + connection.setConnectTimeout(10000); + connection.setReadTimeout(10000); + + // 获取响应 + int responseCode = connection.getResponseCode(); + if (responseCode == HttpURLConnection.HTTP_OK) { + BufferedReader reader = new BufferedReader(new InputStreamReader(connection.getInputStream(), StandardCharsets.UTF_8)); + StringBuilder response = new StringBuilder(); + String line; + while ((line = reader.readLine()) != null) { + response.append(line); + } + reader.close(); + return response.toString(); + } else { + throw new Exception("HTTP 请求失败，状态码: " + responseCode); + } + } + + /** + * 删除录制目录 + * + * @param vhost 虚拟主机 + * @param app 应用名 + * @param stream 流ID + * @param period 日期 (格式: YYYY-MM-DD) + * @return 响应结果 JSON 字符串 + * @throws Exception 如果请求失败 + */ + public static String deleteRecordDirectory(String vhost, String app, String stream, String period) throws Exception { + // 构建 URL 参数 + StringBuilder urlBuilder = new StringBuilder(ZLM_BASE_URL); + urlBuilder.append("/index/api/deleteRecordDirectory?"); + urlBuilder.append("secret=").append(URLEncoder.encode(SECRET, StandardCharsets.UTF_8.name())); + urlBuilder.append("&vhost=").append(URLEncoder.encode(vhost, StandardCharsets.UTF_8.name())); + urlBuilder.append("&app=").append(URLEncoder.encode(app, StandardCharsets.UTF_8.name())); + urlBuilder.append("&stream=").append(URLEncoder.encode(stream, StandardCharsets.UTF_8.name())); + urlBuilder.append("&period=").append(URLEncoder.encode(period, StandardCharsets.UTF_8.name())); + + // 创建 HTTP 连接 + URL url = new URL(urlBuilder.toString()); + HttpURLConnection connection = (HttpURLConnection) url.openConnection(); + connection.setRequestMethod("GET"); + connection.setConnectTimeout(10000); + connection.setReadTimeout(10000); + + // 获取响应 + int responseCode = connection.getResponseCode(); + if (responseCode == HttpURLConnection.HTTP_OK) { + BufferedReader reader = new BufferedReader(new InputStreamReader(connection.getInputStream(), StandardCharsets.UTF_8)); + StringBuilder response = new StringBuilder(); + String line; + while ((line = reader.readLine()) != null) { + response.append(line); + } + reader.close(); + return response.toString(); + } else { + throw new Exception("HTTP 请求失败，状态码: " + responseCode); + } + } +}