{"id":2278,"date":"2025-03-03T23:20:02","date_gmt":"2025-03-03T15:20:02","guid":{"rendered":"https:\/\/www.laixuexila.com\/?p=2278"},"modified":"2025-03-03T23:20:02","modified_gmt":"2025-03-03T15:20:02","slug":"java-%e5%a4%9a%e7%ba%bf%e7%a8%8b%e5%9c%a8%e9%ab%98%e5%b9%b6%e5%8f%91%e3%80%81%e5%88%86%e5%b8%83%e5%bc%8f%e7%b3%bb%e7%bb%9f%e3%80%81%e5%be%ae%e6%9c%8d%e5%8a%a1%e9%a2%86%e5%9f%9f%e7%9a%84%e5%ba%94","status":"publish","type":"post","link":"https:\/\/www.laixuexila.com\/index.php\/2025\/03\/03\/java-%e5%a4%9a%e7%ba%bf%e7%a8%8b%e5%9c%a8%e9%ab%98%e5%b9%b6%e5%8f%91%e3%80%81%e5%88%86%e5%b8%83%e5%bc%8f%e7%b3%bb%e7%bb%9f%e3%80%81%e5%be%ae%e6%9c%8d%e5%8a%a1%e9%a2%86%e5%9f%9f%e7%9a%84%e5%ba%94\/","title":{"rendered":"Java \u591a\u7ebf\u7a0b\u5728\u9ad8\u5e76\u53d1\u3001\u5206\u5e03\u5f0f\u7cfb\u7edf\u3001\u5fae\u670d\u52a1\u9886\u57df\u7684\u5e94\u7528"},"content":{"rendered":"\n

Java \u591a\u7ebf\u7a0b\u6280\u672f\u5e7f\u6cdb\u5e94\u7528\u4e8e \u9ad8\u5e76\u53d1\u3001\u5206\u5e03\u5f0f\u7cfb\u7edf\u3001\u5fae\u670d\u52a1\u67b6\u6784<\/strong>\uff0c\u4e3b\u8981\u7528\u4e8e \u63d0\u9ad8\u7cfb\u7edf\u541e\u5410\u91cf\u3001\u964d\u4f4e\u5ef6\u8fdf\u3001\u4f18\u5316\u8d44\u6e90\u5229\u7528\u7387<\/strong>\u3002\u4e0b\u9762\u8be6\u7ec6\u4ecb\u7ecd\u591a\u7ebf\u7a0b\u5728\u8fd9\u4e9b\u9886\u57df\u7684\u6838\u5fc3\u5e94\u7528\u573a\u666f\u3002<\/p>\n\n\n\n

\n\n\n\n

1. \u9ad8\u5e76\u53d1\u573a\u666f\u4e2d\u7684\u591a\u7ebf\u7a0b<\/strong><\/h2>\n\n\n\n

\u9ad8\u5e76\u53d1\u662f\u6307 \u591a\u4e2a\u8bf7\u6c42\u6216\u4efb\u52a1\u540c\u65f6\u5230\u8fbe<\/strong>\uff0c\u7cfb\u7edf\u9700\u8981\u9ad8\u6548\u5904\u7406\u4ee5\u51cf\u5c11\u5ef6\u8fdf\u3002Java \u591a\u7ebf\u7a0b\u53ef\u7528\u4e8e\uff1a<\/p>\n\n\n\n

    \n
  • \u5f02\u6b65\u4efb\u52a1\u6267\u884c<\/strong><\/li>\n\n\n\n
  • \u8bf7\u6c42\u5206\u53d1<\/strong><\/li>\n\n\n\n
  • \u7f13\u5b58\u66f4\u65b0<\/strong><\/li>\n\n\n\n
  • \u6d88\u606f\u5904\u7406<\/strong><\/li>\n\n\n\n
  • \u9650\u6d41\u4e0e\u7194\u65ad<\/strong><\/li>\n<\/ul>\n\n\n\n

    1.1 \u7ebf\u7a0b\u6c60\u4f18\u5316\u9ad8\u5e76\u53d1\u8bf7\u6c42<\/strong><\/h3>\n\n\n\n

    \u5728\u9ad8\u5e76\u53d1\u7cfb\u7edf\u4e2d\uff0c\u6bcf\u4e2a\u8bf7\u6c42\u90fd\u521b\u5efa\u4e00\u4e2a\u7ebf\u7a0b\u662f \u4f4e\u6548\u7684<\/strong>\uff08\u7ebf\u7a0b\u521b\u5efa\u548c\u9500\u6bc1\u6210\u672c\u9ad8\uff09\u3002\u4f7f\u7528 \u7ebf\u7a0b\u6c60\uff08Executor \u6846\u67b6\uff09<\/strong> \u53ef\u4ee5\u4f18\u5316\u8bf7\u6c42\u5904\u7406\u3002<\/p>\n\n\n\n

    \u793a\u4f8b\uff1a\u4f7f\u7528\u7ebf\u7a0b\u6c60\u5904\u7406\u9ad8\u5e76\u53d1\u8bf7\u6c42<\/strong><\/h4>\n\n\n\n
    import java.util.concurrent.ExecutorService;\nimport java.util.concurrent.Executors;\n\npublic class HighConcurrencyExample {\n    public static void main(String[] args) {\n        ExecutorService threadPool = Executors.newFixedThreadPool(10);\n\n        for (int i = 0; i < 100; i++) {\n            threadPool.execute(() -> {\n                System.out.println(Thread.currentThread().getName() + \" \u5904\u7406\u8bf7\u6c42\");\n            });\n        }\n\n        threadPool.shutdown();\n    }\n}<\/code><\/pre>\n\n\n\n
    \u4f18\u52bf<\/strong><\/p>\n\n\n\n
      \n
    • \u907f\u514d\u7ebf\u7a0b\u521b\u5efa\/\u9500\u6bc1\u7684\u5f00\u9500<\/li>\n\n\n\n
    • \u9650\u5236\u6700\u5927\u5e76\u53d1\u6570\uff0c\u9632\u6b62 OOM\uff08\u5185\u5b58\u6ea2\u51fa\uff09<\/li>\n<\/ul>\n\n\n\n
      \n\n\n\n
      1.2 \u4f7f\u7528 CompletableFuture \u8fdb\u884c\u5f02\u6b65\u8c03\u7528<\/strong><\/h3>\n\n\n\n
      \u5728\u9ad8\u5e76\u53d1\u5e94\u7528\u4e2d\uff0c\u4f7f\u7528 CompletableFuture<\/code><\/strong> \u53ef\u4ee5\u5b9e\u73b0 \u975e\u963b\u585e<\/strong> \u5f02\u6b65\u7f16\u7a0b\uff0c\u4f8b\u5982\u8c03\u7528\u591a\u4e2a\u63a5\u53e3\u5e76\u884c\u6267\u884c\u3002<\/p>\n\n\n\n
      import java.util.concurrent.CompletableFuture;\n\npublic class AsyncExample {\n    public static void main(String[] args) {\n        CompletableFuture<Void> future = CompletableFuture.runAsync(() -> {\n            System.out.println(\"\u5f02\u6b65\u4efb\u52a1\u6267\u884c\u4e2d\uff1a\" + Thread.currentThread().getName());\n        });\n\n        future.join(); \/\/ \u7b49\u5f85\u4efb\u52a1\u5b8c\u6210\n        System.out.println(\"\u4e3b\u7ebf\u7a0b\u7ee7\u7eed\u6267\u884c\");\n    }\n}<\/code><\/pre>\n\n\n\n
      \u5e94\u7528\u573a\u666f<\/strong><\/p>\n\n\n\n
        \n
      • \u5e76\u884c\u8c03\u7528\u591a\u4e2a API<\/strong>\uff08\u5982\u805a\u5408\u6570\u636e\uff09<\/li>\n\n\n\n
      • \u5f02\u6b65\u5904\u7406 I\/O \u64cd\u4f5c<\/strong>\uff08\u5982\u6570\u636e\u5e93\u67e5\u8be2\u3001\u6587\u4ef6\u8bfb\u5199\uff09<\/li>\n\n\n\n
      • \u63d0\u5347\u7cfb\u7edf\u541e\u5410\u91cf<\/strong><\/li>\n<\/ul>\n\n\n\n
        \n\n\n\n
        2. \u5206\u5e03\u5f0f\u7cfb\u7edf\u4e2d\u7684\u591a\u7ebf\u7a0b<\/strong><\/h2>\n\n\n\n
        \u5728 \u5206\u5e03\u5f0f\u67b6\u6784<\/strong> \u4e2d\uff0cJava \u591a\u7ebf\u7a0b\u4e3b\u8981\u5e94\u7528\u4e8e\uff1a<\/p>\n\n\n\n
          \n
        • \u5206\u5e03\u5f0f\u4efb\u52a1\u8c03\u5ea6<\/strong><\/li>\n\n\n\n
        • \u6570\u636e\u540c\u6b65<\/strong><\/li>\n\n\n\n
        • \u5206\u5e03\u5f0f\u9501<\/strong><\/li>\n\n\n\n
        • \u6d88\u606f\u961f\u5217\uff08MQ\uff09\u6d88\u8d39<\/strong><\/li>\n\n\n\n
        • \u5fae\u670d\u52a1\u4e4b\u95f4\u7684\u5e76\u884c\u8c03\u7528<\/strong><\/li>\n<\/ul>\n\n\n\n
          2.1 \u5206\u5e03\u5f0f\u4efb\u52a1\u8c03\u5ea6<\/strong><\/h3>\n\n\n\n
          \u5728\u5927\u89c4\u6a21\u7cfb\u7edf\u4e2d\uff0c\u4efb\u52a1\u5f80\u5f80\u9700\u8981\u5e76\u53d1\u6267\u884c\uff0c\u4f8b\u5982\uff1a<\/p>\n\n\n\n
            \n
          • \u65e5\u5fd7\u5206\u6790<\/strong><\/li>\n\n\n\n
          • \u722c\u866b\u7cfb\u7edf<\/strong><\/li>\n\n\n\n
          • \u5927\u6570\u636e\u5904\u7406<\/strong><\/li>\n<\/ul>\n\n\n\n
            \u793a\u4f8b\uff1aScheduledExecutorService \u5b9a\u65f6\u4efb\u52a1<\/strong><\/h4>\n\n\n\n
            import java.util.concurrent.Executors;\nimport java.util.concurrent.ScheduledExecutorService;\nimport java.util.concurrent.TimeUnit;\n\npublic class DistributedTaskScheduler {\n    public static void main(String[] args) {\n        ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(5);\n\n        scheduler.scheduleAtFixedRate(() -> {\n            System.out.println(\"\u6267\u884c\u5b9a\u65f6\u4efb\u52a1\uff1a\" + Thread.currentThread().getName());\n        }, 0, 5, TimeUnit.SECONDS);\n    }\n}<\/code><\/pre>\n\n\n\n
            \u5e94\u7528\u573a\u666f<\/strong><\/p>\n\n\n\n
              \n
            • \u5b9a\u65f6\u4efb\u52a1\u8c03\u5ea6<\/strong>\uff08\u5982 Quartz\u3001xxl-job\uff09<\/li>\n\n\n\n
            • \u6279\u91cf\u6570\u636e\u5904\u7406<\/strong>\uff08\u5982 ETL\uff09<\/li>\n\n\n\n
            • \u5fc3\u8df3\u68c0\u6d4b<\/strong>\uff08\u5fae\u670d\u52a1\u5065\u5eb7\u68c0\u67e5\uff09<\/li>\n<\/ul>\n\n\n\n
              \n\n\n\n
              2.2 \u5206\u5e03\u5f0f\u9501\uff08Redis \u5b9e\u73b0\uff09<\/strong><\/h3>\n\n\n\n
              \u5728\u5206\u5e03\u5f0f\u7cfb\u7edf\u4e2d\uff0c\u591a\u4e2a\u7ebf\u7a0b\u53ef\u80fd\u8bbf\u95ee\u76f8\u540c\u7684\u5171\u4eab\u8d44\u6e90\uff0c\u9700\u8981 \u5206\u5e03\u5f0f\u9501<\/strong> \u4fdd\u8bc1\u6570\u636e\u4e00\u81f4\u6027\u3002<\/p>\n\n\n\n
              \u793a\u4f8b\uff1a\u4f7f\u7528 Redis \u4f5c\u4e3a\u5206\u5e03\u5f0f\u9501<\/strong><\/h4>\n\n\n\n
              import redis.clients.jedis.Jedis;\n\npublic class DistributedLock {\n    public static void main(String[] args) {\n        Jedis jedis = new Jedis(\"localhost\", 6379);\n        String lockKey = \"lock:order\";\n        String lockValue = \"123\";\n\n        \/\/ \u5c1d\u8bd5\u52a0\u9501\n        String result = jedis.set(lockKey, lockValue, \"NX\", \"PX\", 5000);\n        if (\"OK\".equals(result)) {\n            try {\n                System.out.println(\"\u83b7\u53d6\u9501\u6210\u529f\uff0c\u6267\u884c\u4efb\u52a1\");\n                \/\/ \u4e1a\u52a1\u903b\u8f91\n            } finally {\n                \/\/ \u91ca\u653e\u9501\n                if (lockValue.equals(jedis.get(lockKey))) {\n                    jedis.del(lockKey);\n                }\n            }\n        } else {\n            System.out.println(\"\u83b7\u53d6\u9501\u5931\u8d25\");\n        }\n    }\n}<\/code><\/pre>\n\n\n\n
              \u5e94\u7528\u573a\u666f<\/strong><\/p>\n\n\n\n
                \n
              • \u8ba2\u5355\u552f\u4e00\u6027\u4fdd\u8bc1<\/strong><\/li>\n\n\n\n
              • \u5e93\u5b58\u6263\u51cf<\/strong><\/li>\n\n\n\n
              • \u9632\u6b62\u91cd\u590d\u63d0\u4ea4<\/strong><\/li>\n<\/ul>\n\n\n\n
                \n\n\n\n
                3. \u5fae\u670d\u52a1\u4e2d\u7684\u591a\u7ebf\u7a0b<\/strong><\/h2>\n\n\n\n
                \u5fae\u670d\u52a1\u67b6\u6784\u91c7\u7528 \u591a\u8fdb\u7a0b + \u7ebf\u7a0b\u6c60<\/strong>\uff0c\u591a\u7ebf\u7a0b\u53ef\u4ee5\u63d0\u5347\u5fae\u670d\u52a1\u7684\u541e\u5410\u91cf\u3002<\/p>\n\n\n\n
                3.1 \u591a\u7ebf\u7a0b\u4f18\u5316 REST API<\/strong><\/h3>\n\n\n\n
                \u5728 Spring Boot \u4e2d\uff0c\u53ef\u4ee5\u4f7f\u7528 @Async<\/code> \u5b9e\u73b0 \u5f02\u6b65\u8bf7\u6c42\u5904\u7406<\/strong>\u3002<\/p>\n\n\n\n
                \u793a\u4f8b\uff1aSpring Boot \u5f02\u6b65\u6267\u884c\u4efb\u52a1<\/strong><\/h4>\n\n\n\n
                import org.springframework.scheduling.annotation.Async;\nimport org.springframework.stereotype.Service;\n\n@Service\npublic class AsyncService {\n    @Async\n    public void executeAsyncTask() {\n        System.out.println(\"\u5f02\u6b65\u4efb\u52a1\u6267\u884c\uff1a\" + Thread.currentThread().getName());\n    }\n}<\/code><\/pre>\n\n\n\n
                import org.springframework.web.bind.annotation.GetMapping;\nimport org.springframework.web.bind.annotation.RequestMapping;\nimport org.springframework.web.bind.annotation.RestController;\n\n@RestController\n@RequestMapping(\"\/api\")\npublic class AsyncController {\n    private final AsyncService asyncService;\n\n    public AsyncController(AsyncService asyncService) {\n        this.asyncService = asyncService;\n    }\n\n    @GetMapping(\"\/task\")\n    public String runTask() {\n        asyncService.executeAsyncTask();\n        return \"\u4efb\u52a1\u5df2\u63d0\u4ea4\";\n    }\n}<\/code><\/pre>\n\n\n\n
                \u5e94\u7528\u573a\u666f<\/strong><\/p>\n\n\n\n
                  \n
                • \u5f02\u6b65\u5904\u7406 HTTP \u8bf7\u6c42<\/strong>\uff08\u5982\u56fe\u7247\u5904\u7406\u3001\u65e5\u5fd7\u5b58\u50a8\uff09<\/li>\n\n\n\n
                • \u6d88\u606f\u961f\u5217\uff08Kafka\u3001RabbitMQ\uff09\u5f02\u6b65\u6d88\u8d39<\/strong><\/li>\n\n\n\n
                • \u5fae\u670d\u52a1\u8c03\u7528\u5f02\u6b65\u6267\u884c<\/strong><\/li>\n<\/ul>\n\n\n\n
                  \n\n\n\n
                  3.2 \u5e76\u884c\u8c03\u7528\u591a\u4e2a\u5fae\u670d\u52a1<\/strong><\/h3>\n\n\n\n
                  \u5fae\u670d\u52a1\u67b6\u6784\u4e2d\uff0c\u4e00\u4e2a\u8bf7\u6c42\u53ef\u80fd\u9700\u8981\u8c03\u7528\u591a\u4e2a\u5b50\u670d\u52a1\u3002\u53ef\u4ee5\u4f7f\u7528 CompletableFuture<\/code><\/strong> \u63d0\u9ad8\u5e76\u53d1\u6027\u80fd\u3002<\/p>\n\n\n\n
                  \u793a\u4f8b\uff1a\u5e76\u884c\u8c03\u7528\u591a\u4e2a\u5fae\u670d\u52a1<\/strong><\/h4>\n\n\n\n
                  import java.util.concurrent.CompletableFuture;\n\npublic class MicroserviceParallel {\n    public static void main(String[] args) {\n        CompletableFuture<String> service1 = CompletableFuture.supplyAsync(() -> callService(\"Service1\"));\n        CompletableFuture<String> service2 = CompletableFuture.supplyAsync(() -> callService(\"Service2\"));\n\n        CompletableFuture.allOf(service1, service2).join();\n\n        System.out.println(\"\u6240\u6709\u670d\u52a1\u8c03\u7528\u5b8c\u6210\");\n    }\n\n    private static String callService(String serviceName) {\n        System.out.println(\"\u8c03\u7528\uff1a\" + serviceName);\n        return serviceName + \" \u5b8c\u6210\";\n    }\n}<\/code><\/pre>\n\n\n\n
                  \u5e94\u7528\u573a\u666f<\/strong><\/p>\n\n\n\n
                    \n
                  • \u805a\u5408\u591a\u4e2a\u5fae\u670d\u52a1\u8fd4\u56de\u7684\u6570\u636e<\/strong><\/li>\n\n\n\n
                  • \u5e76\u884c\u8fdc\u7a0b\u8c03\u7528\uff0c\u51cf\u5c11\u54cd\u5e94\u65f6\u95f4<\/strong><\/li>\n<\/ul>\n\n\n\n
                    \n\n\n\n
                    4. \u603b\u7ed3<\/strong><\/h2>\n\n\n\n
                    \u5e94\u7528\u573a\u666f<\/strong><\/th>\u591a\u7ebf\u7a0b\u6280\u672f<\/strong><\/th>\u5173\u952e\u4f5c\u7528<\/strong><\/th><\/tr><\/thead>
                    \u9ad8\u5e76\u53d1\u8bf7\u6c42<\/strong><\/td>\u7ebf\u7a0b\u6c60\u3001CompletableFuture<\/td>\u63d0\u9ad8\u541e\u5410\u91cf\uff0c\u51cf\u5c11\u963b\u585e<\/td><\/tr>
                    \u5b9a\u65f6\u4efb\u52a1\u8c03\u5ea6<\/strong><\/td>ScheduledExecutorService<\/td>\u5b9a\u65f6\u4efb\u52a1\u5904\u7406\uff08\u65e5\u5fd7\u5206\u6790\u3001ETL\uff09<\/td><\/tr>
                    \u5206\u5e03\u5f0f\u9501<\/strong><\/td>Redis\u3001Zookeeper<\/td>\u89e3\u51b3\u6570\u636e\u4e00\u81f4\u6027\u95ee\u9898<\/td><\/tr>
                    \u5fae\u670d\u52a1\u5f02\u6b65\u8c03\u7528<\/strong><\/td>@Async<\/code>\u3001CompletableFuture<\/td>\u5e76\u884c\u8c03\u7528\u591a\u4e2a\u5fae\u670d\u52a1<\/td><\/tr>
                    \u6d88\u606f\u961f\u5217\u6d88\u8d39<\/strong><\/td>Kafka\u3001RabbitMQ<\/td>\u9ad8\u6548\u6d88\u8d39\u5f02\u6b65\u4efb\u52a1<\/td><\/tr><\/tbody><\/table><\/figure>\n\n\n\n
                    Java \u591a\u7ebf\u7a0b\u5728 \u9ad8\u5e76\u53d1\u3001\u5206\u5e03\u5f0f\u3001\u5fae\u670d\u52a1<\/strong> \u9886\u57df\u7684\u5e94\u7528\u975e\u5e38\u5e7f\u6cdb\uff0c\u5408\u7406\u4f7f\u7528\u7ebf\u7a0b\u6c60\u3001\u5f02\u6b65\u7f16\u7a0b\u3001\u5e76\u53d1\u63a7\u5236\u53ef\u4ee5\u663e\u8457\u63d0\u5347\u7cfb\u7edf\u6027\u80fd\u3002\u66f4\u591a\u8be6\u7ec6\u5185\u5bb9\u8bf7\u5173\u6ce8\u5176\u4ed6\u76f8\u5173\u6587\u7ae0\u3002<\/p>\n","protected":false},"excerpt":{"rendered":"
                    Java \u591a\u7ebf\u7a0b\u6280\u672f\u5e7f\u6cdb\u5e94\u7528\u4e8e \u9ad8\u5e76\u53d1\u3001\u5206\u5e03\u5f0f\u7cfb\u7edf\u3001\u5fae\u670d\u52a1\u67b6\u6784\uff0c\u4e3b\u8981\u7528\u4e8e \u63d0\u9ad8\u7cfb\u7edf\u541e\u5410\u91cf\u3001\u964d\u4f4e\u5ef6\u8fdf\u3001\u4f18\u5316\u8d44\u6e90\u5229 […]<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[68],"tags":[],"class_list":["post-2278","post","type-post","status-publish","format-standard","hentry","category-java"],"_links":{"self":[{"href":"https:\/\/www.laixuexila.com\/index.php\/wp-json\/wp\/v2\/posts\/2278","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.laixuexila.com\/index.php\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.laixuexila.com\/index.php\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.laixuexila.com\/index.php\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/www.laixuexila.com\/index.php\/wp-json\/wp\/v2\/comments?post=2278"}],"version-history":[{"count":1,"href":"https:\/\/www.laixuexila.com\/index.php\/wp-json\/wp\/v2\/posts\/2278\/revisions"}],"predecessor-version":[{"id":2279,"href":"https:\/\/www.laixuexila.com\/index.php\/wp-json\/wp\/v2\/posts\/2278\/revisions\/2279"}],"wp:attachment":[{"href":"https:\/\/www.laixuexila.com\/index.php\/wp-json\/wp\/v2\/media?parent=2278"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.laixuexila.com\/index.php\/wp-json\/wp\/v2\/categories?post=2278"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.laixuexila.com\/index.php\/wp-json\/wp\/v2\/tags?post=2278"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}