From f38bffe06a356c009dcfb2d7cdf117d62d950135 Mon Sep 17 00:00:00 2001 From: bunny <1319900154@qq.com> Date: Wed, 31 Jul 2024 15:56:57 +0800 Subject: [PATCH] =?UTF-8?q?:rocket:=20feat(=E6=96=B0=E5=A2=9E):=20OutputSt?= =?UTF-8?q?ream=E5=92=8C=E8=BE=93=E5=85=A5=E6=B5=81=E4=BD=BF=E7=94=A8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- service/src/test/java/cn/bunny/FileTest.java | 4 + .../java/cn/bunny/http/HttpClientTest.java | 78 +++++++++++++++ .../java/cn/bunny/http/HttpRequestTest.java | 17 ++++ .../src/test/java/cn/bunny/path/PathTest.java | 96 +++++++++++++++++++ .../java/cn/bunny/stream/InputStreamTest.java | 41 ++++++++ .../cn/bunny/stream/OutputStreamTest.java | 12 +++ 6 files changed, 248 insertions(+) create mode 100644 service/src/test/java/cn/bunny/FileTest.java create mode 100644 service/src/test/java/cn/bunny/http/HttpClientTest.java create mode 100644 service/src/test/java/cn/bunny/http/HttpRequestTest.java create mode 100644 service/src/test/java/cn/bunny/path/PathTest.java create mode 100644 service/src/test/java/cn/bunny/stream/InputStreamTest.java create mode 100644 service/src/test/java/cn/bunny/stream/OutputStreamTest.java diff --git a/service/src/test/java/cn/bunny/FileTest.java b/service/src/test/java/cn/bunny/FileTest.java new file mode 100644 index 0000000..5660330 --- /dev/null +++ b/service/src/test/java/cn/bunny/FileTest.java @@ -0,0 +1,4 @@ +package cn.bunny; + +public class FileTest { +} diff --git a/service/src/test/java/cn/bunny/http/HttpClientTest.java b/service/src/test/java/cn/bunny/http/HttpClientTest.java new file mode 100644 index 0000000..4567fe3 --- /dev/null +++ b/service/src/test/java/cn/bunny/http/HttpClientTest.java @@ -0,0 +1,78 @@ +package cn.bunny.http; + +import lombok.SneakyThrows; + +import java.net.URI; +import java.net.http.HttpClient; +import java.net.http.HttpRequest; +import java.net.http.HttpResponse; +import java.util.Optional; +import java.util.concurrent.CompletableFuture; +import java.util.concurrent.Executor; + +public class HttpClientTest { + // 同步发送HTTP请求 + private static void sendSyncRequest(HttpClient httpClient, String URL) throws Exception { + HttpRequest request = HttpRequest.newBuilder() + .uri(new URI(URL)) + .GET() + .build(); + + HttpResponse response = httpClient.send(request, HttpResponse.BodyHandlers.ofString()); + + System.out.println("Response status code: " + response.statusCode()); + System.out.println("Response body: " + response.body()); + System.out.println("Response header: " + response.headers()); + } + + // 异步发送HTTP请求 + private static void sendAsyncRequest(HttpClient httpClient, String URL) { + HttpRequest request = HttpRequest.newBuilder() + .uri(URI.create(URL)) + .GET() + .build(); + + CompletableFuture> future = httpClient.sendAsync(request, HttpResponse.BodyHandlers.ofString()); + + future.thenAccept(response -> { + System.out.println("Async Response status code: " + response.statusCode()); + System.out.println("Async Response body: " + response.body()); + }).join(); // 等待异步请求完成 + } + + // 设置重定向策略 + private static void setRedirectPolicy(HttpClient httpClient) { + // 设置自动重定向策略 + HttpClient.Redirect newClient = httpClient.followRedirects(); + // 使用newClient继续发送请求 + } + + // 设置自定义执行器 + private static void setExecutor(HttpClient httpClient) { + // 设置自定义执行器 + Optional newClient = httpClient.executor(); // 可以传入自定义的Executor + // 使用newClient继续发送请求 + } + + @SneakyThrows + public static void main(String[] args) { + String URL = "https://www.itxst.com/sortablejs/neuinffi.html"; + + // 创建HttpClient对象 + HttpClient httpClient = HttpClient.newHttpClient(); + + // 同步发送HTTP请求 + sendSyncRequest(httpClient, URL); + + // 异步发送HTTP请求 + sendAsyncRequest(httpClient, URL); + + // 设置重定向策略 + setRedirectPolicy(httpClient); + + // 设置自定义执行器 + setExecutor(httpClient); + + httpClient.close(); + } +} diff --git a/service/src/test/java/cn/bunny/http/HttpRequestTest.java b/service/src/test/java/cn/bunny/http/HttpRequestTest.java new file mode 100644 index 0000000..29165b4 --- /dev/null +++ b/service/src/test/java/cn/bunny/http/HttpRequestTest.java @@ -0,0 +1,17 @@ +package cn.bunny.http; + +import lombok.SneakyThrows; +import org.junit.jupiter.api.Test; + +import java.net.URI; +import java.net.http.HttpRequest; + +public class HttpRequestTest { + @SneakyThrows + @Test + void requestTest() { + String URL = "https://www.itxst.com/sortablejs/neuinffi.html"; + HttpRequest httpRequestGet = HttpRequest.newBuilder().uri(new URI(URL)).GET().build(); + HttpRequest httpRequestPost = HttpRequest.newBuilder().uri(new URI(URL)).POST(HttpRequest.BodyPublishers.ofString("json")).build(); + } +} diff --git a/service/src/test/java/cn/bunny/path/PathTest.java b/service/src/test/java/cn/bunny/path/PathTest.java new file mode 100644 index 0000000..1badba2 --- /dev/null +++ b/service/src/test/java/cn/bunny/path/PathTest.java @@ -0,0 +1,96 @@ +package cn.bunny.path; + +import lombok.SneakyThrows; +import org.junit.jupiter.api.Test; + +import java.io.File; +import java.io.IOException; +import java.nio.file.Files; +import java.nio.file.Path; +import java.nio.file.Paths; +import java.util.stream.Stream; + +public class PathTest { + // 关闭流的正确方式： + // 在Java中，使用流（Stream）操作后，应该使用try-with-resources语句来确保流资源被正确关闭，而不是直接调用close()方法。 + // 另外，Stream并不是实现AutoCloseable接口的，因此不能直接调用close()方法关闭，应该通过使用try-with-resources或者使用forEach方法内部自动关闭流。 + @SneakyThrows + @Test + void pathTest1() { + Path listPath = Path.of("D:/MyFolder/文档和软件"); + + // 输出这个目录下所有文件、文件夹 + try (Stream list = Files.list(listPath)) { + list.forEach(System.out::println); + } catch (IOException e) { + e.printStackTrace(); + } + + // 循环遍历这个目录下所有文件 + try (Stream walk = Files.walk(Path.of("D:/MyFolder/文档和软件/图片"))) { + walk.forEach(System.out::println); + } catch (IOException e) { + e.printStackTrace(); + } + } + + // 创建路径对象 + @Test + void pathsTest() { + // 创建一个表示当前工作目录的Path对象 + Path currentPath = Paths.get(""); + System.out.println("Current Path: " + currentPath); + + // 创建一个表示绝对路径的Path对象 + Path absolutePath = Paths.get("C:/Users/username/Documents"); + System.out.println("Absolute Path: " + absolutePath); + + // 创建一个表示相对路径的Path对象 + Path relativePath = Paths.get("src/main/java/com/example"); + System.out.println("Relative Path: " + relativePath); + + // 创建一个带有多个路径组件的Path对象 + Path nestedPath = Paths.get("C:/", "Users", "username", "Documents", "JavaProjects"); + System.out.println("Nested Path: " + nestedPath); + } + + + @Test + void pathTest() { + Path path = Path.of("D:\\MyFolder\\文档和软件"); + + // resolve(String other)方法用于将当前路径解析为另一个路径。它接受一个字符串参数other，可以是相对路径或者绝对路径。示例中，将当前路径与subfolder/file.txt组合，返回一个新的Path对象resolvedPath，表示完整的路径D:\MyFolder\文档和软件\subfolder\file.txt。 + Path resolvedPath = path.resolve("subfolder/file.txt"); + // D:\MyFolder\文档和软件\subfolder\file.txt + System.out.println(resolvedPath); + + // `resolveSibling(String other)`方法与`resolve()`类似，但是它是相对于当前路径的父路径进行解析的。示例中，将当前路径的父路径与`anotherFolder`组合，返回一个新的`Path`对象`resolvedSiblingPath`，表示路径`D:\MyFolder\anotherFolder`。 + Path siblingResolvedPath = path.resolveSibling("anotherFolder"); + System.out.println(siblingResolvedPath); + + // `relativize(Path other)`方法用于计算两个路径之间的相对路径。示例中，假设`otherPath`表示另一个路径`D:\MyFolder\文档和软件\subfolder\file.txt`，则`relativePath`表示从`path`到`otherPath`的相对路径`subfolder\file.txt`。 + Path siblingResolvedPath2 = path.resolveSibling("anotherFolder"); + System.out.println(siblingResolvedPath2); + + // relativize(Path other)方法用于计算两个路径之间的相对路径。示例中，假设otherPath表示另一个路径D:\MyFolder\文档和软件\subfolder\file.txt，则relativePath表示从path到otherPath的相对路径subfolder\file.txt。 + Path otherPath = Path.of("D:\\MyFolder\\文档和软件\\subfolder\\file.txt"); + Path relativePath = path.relativize(otherPath); + System.out.println(relativePath); + + // normalize()方法用于标准化路径。它消除路径中的冗余部分，例如.（当前目录）和..（上级目录）。示例中，normalizedPath将返回一个标准化后的路径对象，即D:\MyFolder\文档和软件。 + Path absolutePath = path.toAbsolutePath(); + System.out.println("absolutePath：" + absolutePath); + + // getParent()方法返回当前路径的父路径。示例中，如果path是D:\MyFolder\文档和软件，则parentPath会返回D:\MyFolder。 + Path parentPath = path.getParent(); + System.out.println(parentPath); + + // getRoot()方法返回当前路径的根路径部分。对于D:\MyFolder\文档和软件，rootPath将返回D:\作为根路径。 + Path rootPath = path.getRoot(); + System.out.println(rootPath); + + // toFile()方法将Path对象转换为对应的java.io.File对象。这在需要与旧版Java API或需要使用File对象的库中特别有用。 + File file = path.toFile(); + System.out.println(file); + } +} diff --git a/service/src/test/java/cn/bunny/stream/InputStreamTest.java b/service/src/test/java/cn/bunny/stream/InputStreamTest.java new file mode 100644 index 0000000..476da72 --- /dev/null +++ b/service/src/test/java/cn/bunny/stream/InputStreamTest.java @@ -0,0 +1,41 @@ +package cn.bunny.stream; + +import lombok.SneakyThrows; +import org.junit.jupiter.api.Test; + +import java.io.FileInputStream; +import java.io.InputStream; +import java.util.Arrays; + +public class InputStreamTest { + @SneakyThrows + @Test + void testInputStream() { + InputStream inputStream = new FileInputStream("D:\\MyFolder\\文档和软件\\图片.zip"); + + // read()方法从输入流中读取下一个字节，并返回读取的字节数据（以整数形式）。如果已到达流的末尾，则返回 -1。这个方法通常用于逐字节地读取数据。 + int read = inputStream.read(); + System.out.println(read); + + // 读取所有字节 + byte[] bytes = inputStream.readAllBytes(); + System.out.println(Arrays.toString(bytes)); + + // 处理每个字节的数据 + int byteRead; + while ((byteRead = inputStream.read()) != -1) { + System.out.println(byteRead); + } + + // skip(long n)方法跳过并丢弃输入流中的 n 个字节数据，并返回实际跳过的字节数。这对于跳过文件中一些特定字节的数据很有用。 + long bytesSkipped = inputStream.skip(10); + System.out.println(bytesSkipped); + + // available()方法返回当前可从输入流中读取的字节数。这个方法通常用于检查流中是否还有未读取的数据。 + int bytesAvailable = inputStream.available(); + System.out.println(bytesAvailable); + + // close()方法关闭输入流并释放与之关联的任何系统资源。在使用完输入流后调用此方法是非常重要的，以避免资源泄漏和系统资源的浪费。 + inputStream.close(); + } +} diff --git a/service/src/test/java/cn/bunny/stream/OutputStreamTest.java b/service/src/test/java/cn/bunny/stream/OutputStreamTest.java new file mode 100644 index 0000000..1a31f5b --- /dev/null +++ b/service/src/test/java/cn/bunny/stream/OutputStreamTest.java @@ -0,0 +1,12 @@ +package cn.bunny.stream; + +import lombok.SneakyThrows; +import org.junit.jupiter.api.Test; + +public class OutputStreamTest { + @SneakyThrows + @Test + void testOutputStream() { + + } +}