update java test

Author: jarry

.gitignore

@@ -2,6 +2,7 @@
 a.out
 *.o
 *.class
+target/
 *.pyc
 .idea
 

domain-driven-design/java-web/README.md

@@ -71,16 +71,21 @@ java-web/
 
 ## 运行
 ```bash
+# 安装
 $ mvn clean install -U
-$ mvn clean package
+# 打包
+$ mvn clean package -DskipTests
+# 执行
 $ java -jar target/java-web-order-1.0.0.jar
-Starting server on http://localhost:8080 successfully.
+# 看到最后出现成功提示
+The Server has started. please visit localhost:8080.
 # 通过 http://localhost:8080 访问系统
 
 # 测试用例
 $ mvn test
+# 单个测试
 $ mvn  surefire:test -Dtest=com.javaweborder.TomcatServerTest 
-# 展示测试结果
+$ mvn  surefire:test -Dtest=com.javaweborder.interfaces.routes.OrderRoutesTest 
 ```
 
 ## Java 语言 DDD（领域驱动设计）特点

domain-driven-design/java-web/pom.xml

@@ -1,3 +1,4 @@
+<?xml version="1.0" encoding="UTF-8"?>
 <project xmlns="http://maven.apache.org/POM/4.0.0"
          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">

domain-driven-design/java-web/src/test/java/com/javaweborder/TomcatServerTest.java

@@ -17,81 +17,86 @@
 
 public class TomcatServerTest {
 
-    private final String helloResponseText = "Hello, World! 欢迎来到 Tomcat embedded server!";
+    private static final int PORT = 8080;
+    private static final String CONTEXT_PATH = "";
+    private static final String BASE_DIR = new File("src/main/webapp").getAbsolutePath();
+    private static final String HELLO_RESPONSE_TEXT = "Hello, World! 欢迎来到 Tomcat embedded server!";
 
     @Test
     public void testTomcatServerStartup() throws Exception {
         // 创建嵌入式 Tomcat 实例并指定端口
         Tomcat tomcat = new Tomcat();
-        int port = 8080;
-        tomcat.setPort(port);
+        tomcat.setPort(PORT);
 
-        // 输出一些调试信息
-        System.out.println("Initializing Tomcat server on port " + port + "...");
+        System.out.println("Initializing Tomcat server on port " + PORT + "...");
 
         // 获取 Tomcat 的 Connector 信息
         Connector connector = tomcat.getConnector();
         System.out.println("Tomcat connector details: " + connector);
 
-        // 创建 Web 应用上下文
-        String contextPath = "";
-        String baseDir = new File("src/main/webapp").getAbsolutePath();
-        System.out.println("Base directory for the web application: " + baseDir);
-
         // 创建和添加上下文
-        Context context = tomcat.addContext(contextPath, baseDir);
+        Context context = tomcat.addContext(CONTEXT_PATH, BASE_DIR);
         System.out.println("Web application context added at: " + context.getPath());
 
         // 添加一个简单的 Servlet
         Tomcat.addServlet(context, "HelloServlet", new HttpServlet() {
             @Override
             protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws IOException {
                 resp.setContentType("text/html; charset=UTF-8");
-                resp.getWriter().write(helloResponseText);
+                resp.getWriter().write(HELLO_RESPONSE_TEXT);
             }
         });
         context.addServletMappingDecoded("/hello", "HelloServlet");
         System.out.println("Servlet '/hello' mapped successfully.");
 
         // 启动 Tomcat 服务器
         tomcat.start();
-        System.out.println("Tomcat started successfully on port " + port + ".");
+        System.out.println("Tomcat started successfully on port " + PORT + ".");
+
+        // 增加断言，验证连接器状态
+        assertEquals("STARTED", tomcat.getConnector().getStateName(), "Tomcat 连接器状态应为 STARTED");
 
-        // 验证 /hello 请求
-        testHelloRequest(port);
+        // 可以添加一些延迟，确保服务器完全启动
+        Thread.sleep(1000);
 
-        // 获取 Tomcat 服务器信息
-        String serverInfo = tomcat.getServer().getStateName();
-        System.out.println("Tomcat server info: " + serverInfo);
+        try {
+            // 验证 /hello 请求
+            testHelloRequest(PORT);
+        } finally {
+            // 关闭 Tomcat 服务器，在测试场景下避免一直阻塞
+            tomcat.stop();
+            tomcat.destroy();
+        }
 
-        // 关闭 Tomcat 服务器，在测试场景下避免一直阻塞
-        tomcat.stop();
-        tomcat.destroy();
+        // 输出所有测试通过的信息
+        System.out.println("所有测试通过！");
     }
 
     private void testHelloRequest(int port) throws IOException {
         // 构建请求 URL
         URL url = new URL("http://localhost:" + port + "/hello");
-        // 打开 HTTP 连接
         HttpURLConnection connection = (HttpURLConnection) url.openConnection();
-        // 设置请求方法为 GET
-        connection.setRequestMethod("GET");
-
-        // 获取响应状态码
-        int responseCode = connection.getResponseCode();
-        // 验证响应状态码是否为 200
-        assertEquals(200, responseCode, "响应状态码应为 200");
-
-        // 读取响应内容
-        BufferedReader reader = new BufferedReader(new InputStreamReader(connection.getInputStream()));
-        StringBuilder response = new StringBuilder();
-        String line;
-        while ((line = reader.readLine()) != null) {
-            response.append(line);
+        try {
+            // 设置请求方法为 GET
+            connection.setRequestMethod("GET");
+
+            // 获取响应状态码
+            int responseCode = connection.getResponseCode();
+            // 验证响应状态码是否为 200
+            assertEquals(200, responseCode, "响应状态码应为 200");
+
+            // 读取响应内容
+            try (BufferedReader reader = new BufferedReader(new InputStreamReader(connection.getInputStream()))) {
+                StringBuilder response = new StringBuilder();
+                String line;
+                while ((line = reader.readLine()) != null) {
+                    response.append(line);
+                }
+                // 验证响应内容是否符合预期
+                assertEquals(HELLO_RESPONSE_TEXT, response.toString(), "响应内容不符合预期");
+            }
+        } catch (IOException e) {
+            throw new RuntimeException(e);
         }
-        reader.close();
-
-        // 验证响应内容是否符合预期
-        assertEquals(helloResponseText, response.toString(), "响应内容不符合预期");
     }
 }

domain-driven-design/java-web/src/test/java/com/javaweborder/interfaces/routes/OrderRoutesTest.java

@@ -81,6 +81,13 @@ public void testOrderRoutes() throws IOException {
 
     assertEquals(200, getLastResponseCode(), "更新订单测试失败");
 
+    // 测试获取订单
+    String getAllOrdersResponse = sendRequest(BASE_URL + API_PREFIX + "/orders", "GET", null);
+    System.out.println("获取全部订单测试状态码："  + getLastResponseCode());
+    System.out.println("响应体: " + getOrderResponse);
+
+    assertEquals(200, getLastResponseCode(), "获取订单测试失败");
+
     // 测试删除订单
     String deleteOrderResponse = sendRequest(BASE_URL + API_PREFIX + "/orders/" + orderId, "DELETE", null);
     System.out.println("删除订单测试状态码："  + getLastResponseCode());
@@ -109,15 +116,15 @@ private String sendRequest(String urlString, String method, String body) throws
     setLastResponseCode(responseCode);
 
     StringBuilder response = new StringBuilder();
-    try (Scanner scanner = new Scanner(connection.getInputStream(), StandardCharsets.UTF_8)) {
+    try (Scanner scanner = new Scanner(connection.getInputStream(), String.valueOf(StandardCharsets.UTF_8))) {
       while (scanner.hasNextLine()) {
         response.append(scanner.nextLine());
       }
     } catch (IOException e) {
       // 处理获取响应体时的异常
       System.err.println("获取响应体时出错: " + e.getMessage());
       if (connection.getErrorStream() != null) {
-        try (Scanner errorScanner = new Scanner(connection.getErrorStream(), StandardCharsets.UTF_8)) {
+        try (Scanner errorScanner = new Scanner(connection.getErrorStream(), String.valueOf(StandardCharsets.UTF_8))) {
           while (errorScanner.hasNextLine()) {
             response.append(errorScanner.nextLine());
           }