{"id":1183,"date":"2025-03-24T08:52:40","date_gmt":"2025-03-23T23:52:40","guid":{"rendered":"https:\/\/dexall.co.jp\/articles\/?p=1183"},"modified":"2025-03-24T08:52:40","modified_gmt":"2025-03-23T23:52:40","slug":"%e3%80%90%e4%bf%9d%e5%ad%98%e7%89%88%e3%80%91netty%e5%85%a5%e9%96%80%e3%81%8b%e3%82%89%e5%ae%9f%e8%b7%b5%e3%81%be%e3%81%a7-%e9%ab%98%e6%80%a7%e8%83%bd%e9%9d%9e%e5%90%8c%e6%9c%9f%e3%83%8d%e3%83%83","status":"publish","type":"post","link":"https:\/\/dexall.co.jp\/articles\/?p=1183","title":{"rendered":"\u3010\u4fdd\u5b58\u7248\u3011Netty\u5165\u9580\u304b\u3089\u5b9f\u8df5\u307e\u3067 &#8211; \u9ad8\u6027\u80fd\u975e\u540c\u671f\u30cd\u30c3\u30c8\u30ef\u30fc\u30af\u30d7\u30ed\u30b0\u30e9\u30df\u30f3\u30b0\u5b8c\u5168\u30ac\u30a4\u30c92024"},"content":{"rendered":"\n<h1 class=\"wp-block-heading\" id=\"i-0\">Netty\u3068\u306f\uff1f\u57fa\u790e\u304b\u3089\u7406\u89e3\u3059\u308b\u975e\u540c\u671f\u30cd\u30c3\u30c8\u30ef\u30fc\u30af\u30d5\u30ec\u30fc\u30e0\u30ef\u30fc\u30af<\/h1>\n\n\n\n<div class=\"toc\"><br \/>\n<b>Warning<\/b>:  Undefined array key \"is_admin\" in <b>\/home\/xs392991\/dexall.co.jp\/public_html\/articles\/wp-content\/themes\/sango-theme\/library\/gutenberg\/dist\/classes\/Toc.php<\/b> on line <b>116<\/b><br \/>\n<br \/>\n<b>Warning<\/b>:  Undefined array key \"is_category_top\" in <b>\/home\/xs392991\/dexall.co.jp\/public_html\/articles\/wp-content\/themes\/sango-theme\/library\/gutenberg\/dist\/classes\/Toc.php<\/b> on line <b>121<\/b><br \/>\n<br \/>\n<b>Warning<\/b>:  Undefined array key \"is_top\" in <b>\/home\/xs392991\/dexall.co.jp\/public_html\/articles\/wp-content\/themes\/sango-theme\/library\/gutenberg\/dist\/classes\/Toc.php<\/b> on line <b>128<\/b><br \/>\n    <div id=\"toc_container\" class=\"sgb-toc--bullets js-smooth-scroll\" data-dialog-title=\"\u76ee\u6b21\">\n      <p class=\"toc_title\">\u76ee\u6b21 <\/p>\n      <ul class=\"toc_list\">  <li class=\"first\">    <a href=\"#i-0\">Netty\u3068\u306f\uff1f\u57fa\u790e\u304b\u3089\u7406\u89e3\u3059\u308b\u975e\u540c\u671f\u30cd\u30c3\u30c8\u30ef\u30fc\u30af\u30d5\u30ec\u30fc\u30e0\u30ef\u30fc\u30af<\/a>    <ul class=\"menu_level_1\">      <li class=\"first\">        <a href=\"#i-1\">Java\u306e\u6a19\u6e96\u30cd\u30c3\u30c8\u30ef\u30fc\u30afAPI\u306e\u9650\u754c\u3068\u8ab2\u984c<\/a>      <\/li>      <li>        <a href=\"#i-2\">Netty\u304c\u89e3\u6c7a\u3059\u308b5\u3064\u306e\u6280\u8853\u8ab2\u984c<\/a>      <\/li>      <li class=\"last\">        <a href=\"#i-3\">Netty\u306e\u30a2\u30fc\u30ad\u30c6\u30af\u30c1\u30e3\u3068\u4e3b\u8981\u8981\u7d20<\/a>      <\/li>    <\/ul>  <\/li>  <li>    <a href=\"#i-4\">Netty\u5b9f\u8df5\u5165\u9580\uff1a\u57fa\u672c\u7684\u306a\u5b9f\u88c5\u30d1\u30bf\u30fc\u30f3<\/a>    <ul class=\"menu_level_1\">      <li class=\"first\">        <a href=\"#i-5\">\u30b7\u30f3\u30d7\u30eb\u306aTCP\u30b5\u30fc\u30d0\u30fc\u306e\u5b9f\u88c5\u624b\u9806<\/a>      <\/li>      <li>        <a href=\"#i-8\">\u52b9\u7387\u7684\u306a\u30a4\u30d9\u30f3\u30c8\u30cf\u30f3\u30c9\u30e9\u30fc\u306e\u8a2d\u8a08\u65b9\u6cd5<\/a>      <\/li>      <li class=\"last\">        <a href=\"#i-11\">ByteBuf\u3092\u4f7f\u3063\u305f\u52b9\u7387\u7684\u306a\u30c7\u30fc\u30bf\u51e6\u7406<\/a>      <\/li>    <\/ul>  <\/li>  <li>    <a href=\"#i-14\">\u5b9f\u8df5\u7684\u306aNetty\u30a2\u30d7\u30ea\u30b1\u30fc\u30b7\u30e7\u30f3\u958b\u767a<\/a>    <ul class=\"menu_level_1\">      <li class=\"first\">        <a href=\"#i-15\">WebSocket\u306e\u30b5\u30fc\u30d0\u30fc\u5b9f\u88c5\u4f8b\u3068\u89e3\u8aac<\/a>      <\/li>      <li>        <a href=\"#i-16\">HTTP\u30b5\u30fc\u30d0\u30fc\u306e\u69cb\u7bc9\u3068RESTful API\u306e\u5b9f\u88c5<\/a>      <\/li>      <li class=\"last\">        <a href=\"#i-17\">\u30d7\u30ed\u30c8\u30b3\u30eb\u30d0\u30c3\u30d5\u30a1\u3092\u4f7f\u7528\u3057\u305f\u52b9\u7387\u7684\u306a\u901a\u4fe1<\/a>      <\/li>    <\/ul>  <\/li>  <li>    <a href=\"#i-18\">Netty\u30a2\u30d7\u30ea\u30b1\u30fc\u30b7\u30e7\u30f3\u306e\u6027\u80fd\u6700\u9069\u5316<\/a>    <ul class=\"menu_level_1\">      <li class=\"first\">        <a href=\"#i-19\">\u30e1\u30e2\u30ea\u30ea\u30fc\u30af\u3092\u9632\u3050\u305f\u3081\u306e\u30d9\u30b9\u30c8\u30d7\u30e9\u30af\u30c6\u30a3\u30b9<\/a>      <\/li>      <li>        <a href=\"#i-20\">\u30b9\u30ec\u30c3\u30c9\u30e2\u30c7\u30eb\u306e\u30c1\u30e5\u30fc\u30cb\u30f3\u30b0\u30c6\u30af\u30cb\u30c3\u30af<\/a>      <\/li>      <li class=\"last\">        <a href=\"#i-21\">\u30d1\u30d5\u30a9\u30fc\u30de\u30f3\u30b9\u30e2\u30cb\u30bf\u30ea\u30f3\u30b0\u3068\u554f\u984c\u89e3\u6c7a<\/a>      <\/li>    <\/ul>  <\/li>  <li class=\"last\">    <a href=\"#i-22\">\u5b9f\u904b\u7528\u306b\u5411\u3051\u305fNetty\u306e\u8a2d\u8a08\u30d1\u30bf\u30fc\u30f3<\/a>    <ul class=\"menu_level_1\">      <li class=\"first\">        <a href=\"#i-23\">\u30de\u30a4\u30af\u30ed\u30b5\u30fc\u30d3\u30b9\u3067\u306eNetty\u6d3b\u7528\u4e8b\u4f8b<\/a>      <\/li>      <li>        <a href=\"#i-24\">Spring WebFlux\u3068Netty\u306e\u7d71\u5408\u65b9\u6cd5<\/a>      <\/li>      <li class=\"last\">        <a href=\"#i-25\">\u672c\u756a\u74b0\u5883\u3067\u306e\u969c\u5bb3\u5bfe\u7b56\u3068\u30c8\u30e9\u30d6\u30eb\u30b7\u30e5\u30fc\u30c6\u30a3\u30f3\u30b0<\/a>      <\/li>    <\/ul>  <\/li><\/ul>\n      <a href=\"#\" class=\"sgb-toc-button js-toc-button\" rel=\"nofollow\" data-open-dialog=\"true\"><i class=\"fa fa-list\"><\/i><span class=\"sgb-toc-button__text\">\u76ee\u6b21\u3078<\/span><\/a>\n    <\/div><\/div><h2 class=\"wp-block-heading\" id=\"i-1\">Java\u306e\u6a19\u6e96\u30cd\u30c3\u30c8\u30ef\u30fc\u30afAPI\u306e\u9650\u754c\u3068\u8ab2\u984c<\/h2>\n\n\n\n<p>\u5f93\u6765\u306eJava\u30cd\u30c3\u30c8\u30ef\u30fc\u30af\u30d7\u30ed\u30b0\u30e9\u30df\u30f3\u30b0\u3067\u306f\u3001java.net\u30d1\u30c3\u30b1\u30fc\u30b8\u3092\u4f7f\u7528\u3057\u3066\u4ee5\u4e0b\u306e\u3088\u3046\u306a\u5b9f\u88c5\u3092\u884c\u3063\u3066\u3044\u307e\u3057\u305f\uff1a<\/p>\n\n\n\n<pre class=\"EnlighterJSRAW\" data-enlighter-language=\"generic\" data-enlighter-theme=\"\" data-enlighter-highlight=\"\" data-enlighter-linenumbers=\"\" data-enlighter-lineoffset=\"\" data-enlighter-title=\"\" data-enlighter-group=\"\">\/\/ \u5f93\u6765\u306e\u540c\u671f\u578b\u30b5\u30fc\u30d0\u30fc\u5b9f\u88c5\npublic class TraditionalServer {\n    public static void main(String[] args) throws IOException {\n        ServerSocket serverSocket = new ServerSocket(8080);\n        while (true) {\n            \/\/ \u30af\u30e9\u30a4\u30a2\u30f3\u30c8\u63a5\u7d9a\u3092\u5f85\u6a5f\uff08\u30d6\u30ed\u30c3\u30ad\u30f3\u30b0\uff09\n            Socket clientSocket = serverSocket.accept();\n            \/\/ 1\u63a5\u7d9a\u306b\u5bfe\u3057\u30661\u30b9\u30ec\u30c3\u30c9\u3092\u5272\u308a\u5f53\u3066\n            new Thread(() -&gt; {\n                try {\n                    handleClient(clientSocket);\n                } catch (IOException e) {\n                    e.printStackTrace();\n                }\n            }).start();\n        }\n    }\n\n    private static void handleClient(Socket socket) throws IOException {\n        \/\/ \u30af\u30e9\u30a4\u30a2\u30f3\u30c8\u51e6\u7406\uff08\u5165\u51fa\u529b\u51e6\u7406\u3082\u30d6\u30ed\u30c3\u30ad\u30f3\u30b0\uff09\n        BufferedReader in = new BufferedReader(\n            new InputStreamReader(socket.getInputStream()));\n        PrintWriter out = new PrintWriter(socket.getOutputStream(), true);\n\n        String line;\n        while ((line = in.readLine()) != null) {\n            out.println(\"\u30b5\u30fc\u30d0\u30fc\u30ec\u30b9\u30dd\u30f3\u30b9: \" + line);\n        }\n    }\n}<\/pre>\n\n\n\n<p>\u3053\u306e\u5b9f\u88c5\u306b\u306f\u4ee5\u4e0b\u306e\u8ab2\u984c\u304c\u3042\u308a\u307e\u3059\uff1a<\/p>\n\n\n\n<ol class=\"wp-block-list\">\n<li>\u30b9\u30b1\u30fc\u30e9\u30d3\u30ea\u30c6\u30a3\u306e\u5236\u9650<\/li>\n<\/ol>\n\n\n\n<ul class=\"wp-block-list\">\n<li>\u63a5\u7d9a\u3054\u3068\u306b\u30b9\u30ec\u30c3\u30c9\u3092\u751f\u6210<\/li>\n\n\n\n<li>\u5927\u91cf\u63a5\u7d9a\u6642\u306e\u30e1\u30e2\u30ea\u6d88\u8cbb\u304c\u5897\u5927<\/li>\n\n\n\n<li>\u30b3\u30f3\u30c6\u30ad\u30b9\u30c8\u30b9\u30a4\u30c3\u30c1\u306e\u30aa\u30fc\u30d0\u30fc\u30d8\u30c3\u30c9<\/li>\n<\/ul>\n\n\n\n<ol class=\"wp-block-list\">\n<li>\u30d6\u30ed\u30c3\u30ad\u30f3\u30b0\u51e6\u7406\u306b\u3088\u308b\u975e\u52b9\u7387\u6027<\/li>\n<\/ol>\n\n\n\n<ul class=\"wp-block-list\">\n<li>I\/O\u51e6\u7406\u4e2d\u306f\u30b9\u30ec\u30c3\u30c9\u304c\u30d6\u30ed\u30c3\u30af<\/li>\n\n\n\n<li>\u30ea\u30bd\u30fc\u30b9\u306e\u52b9\u7387\u7684\u306a\u5229\u7528\u304c\u3067\u304d\u306a\u3044<\/li>\n\n\n\n<li>\u30ec\u30b9\u30dd\u30f3\u30b9\u6642\u9593\u306e\u5897\u5927<\/li>\n<\/ul>\n\n\n\n<h2 class=\"wp-block-heading\" id=\"i-2\">Netty\u304c\u89e3\u6c7a\u3059\u308b5\u3064\u306e\u6280\u8853\u8ab2\u984c<\/h2>\n\n\n\n<p>Netty\u306f\u4ee5\u4e0b\u306e\u8ab2\u984c\u3092\u52b9\u679c\u7684\u306b\u89e3\u6c7a\u3057\u307e\u3059\uff1a<\/p>\n\n\n\n<ol class=\"wp-block-list\">\n<li>\u975e\u540c\u671fI\/O\u306e\u5b9f\u73fe<\/li>\n<\/ol>\n\n\n\n<ul class=\"wp-block-list\">\n<li>\u30a4\u30d9\u30f3\u30c8\u99c6\u52d5\u578b\u30a2\u30fc\u30ad\u30c6\u30af\u30c1\u30e3\u306e\u63a1\u7528<\/li>\n\n\n\n<li>\u30ce\u30f3\u30d6\u30ed\u30c3\u30ad\u30f3\u30b0I\/O\u306e\u5b9f\u88c5<\/li>\n\n\n\n<li>\u52b9\u7387\u7684\u306a\u30ea\u30bd\u30fc\u30b9\u5229\u7528<\/li>\n<\/ul>\n\n\n\n<ol class=\"wp-block-list\">\n<li>\u30e1\u30e2\u30ea\u7ba1\u7406\u306e\u6700\u9069\u5316<\/li>\n<\/ol>\n\n\n\n<ul class=\"wp-block-list\">\n<li>ByteBuf\u306b\u3088\u308b\u52b9\u7387\u7684\u306a\u30e1\u30e2\u30ea\u7ba1\u7406<\/li>\n\n\n\n<li>\u30d7\u30fc\u30ea\u30f3\u30b0\u306b\u3088\u308b\u30e1\u30e2\u30ea\u518d\u5229\u7528<\/li>\n\n\n\n<li>\u30bc\u30ed\u30b3\u30d4\u30fc\u8ee2\u9001\u306e\u30b5\u30dd\u30fc\u30c8<\/li>\n<\/ul>\n\n\n\n<ol class=\"wp-block-list\">\n<li>\u30d7\u30ed\u30c8\u30b3\u30eb\u5bfe\u5fdc\u306e\u7c21\u7d20\u5316<\/li>\n<\/ol>\n\n\n\n<ul class=\"wp-block-list\">\n<li>\u8c4a\u5bcc\u306a\u7d44\u307f\u8fbc\u307f\u30d7\u30ed\u30c8\u30b3\u30eb<\/li>\n\n\n\n<li>\u30ab\u30b9\u30bf\u30e0\u30d7\u30ed\u30c8\u30b3\u30eb\u306e\u5bb9\u6613\u306a\u5b9f\u88c5<\/li>\n\n\n\n<li>\u30d7\u30ed\u30c8\u30b3\u30eb\u5909\u63db\u306e\u67d4\u8edf\u6027<\/li>\n<\/ul>\n\n\n\n<ol class=\"wp-block-list\">\n<li>\u30b9\u30ec\u30c3\u30c9\u7ba1\u7406\u306e\u6700\u9069\u5316<\/li>\n<\/ol>\n\n\n\n<ul class=\"wp-block-list\">\n<li>EventLoop\u306b\u3088\u308b\u52b9\u7387\u7684\u306a\u30b9\u30ec\u30c3\u30c9\u5229\u7528<\/li>\n\n\n\n<li>\u30b9\u30ec\u30c3\u30c9\u30d7\u30fc\u30eb\u306e\u81ea\u52d5\u7ba1\u7406<\/li>\n\n\n\n<li>\u30de\u30eb\u30c1\u30b3\u30a2\u6d3b\u7528\u306e\u6700\u9069\u5316<\/li>\n<\/ul>\n\n\n\n<ol class=\"wp-block-list\">\n<li>\u30a8\u30e9\u30fc\u30cf\u30f3\u30c9\u30ea\u30f3\u30b0\u306e\u6539\u5584<\/li>\n<\/ol>\n\n\n\n<ul class=\"wp-block-list\">\n<li>\u7d71\u4e00\u7684\u306a\u4f8b\u5916\u51e6\u7406\u306e\u4ed5\u7d44\u307f<\/li>\n\n\n\n<li>\u30c7\u30d0\u30c3\u30b0\u60c5\u5831\u306e\u5145\u5b9f<\/li>\n\n\n\n<li>\u30c8\u30e9\u30d6\u30eb\u30b7\u30e5\u30fc\u30c6\u30a3\u30f3\u30b0\u306e\u5bb9\u6613\u3055<\/li>\n<\/ul>\n\n\n\n<h2 class=\"wp-block-heading\" id=\"i-3\">Netty\u306e\u30a2\u30fc\u30ad\u30c6\u30af\u30c1\u30e3\u3068\u4e3b\u8981\u8981\u7d20<\/h2>\n\n\n\n<p>Netty\u306e\u57fa\u672c\u7684\u306a\u30a2\u30fc\u30ad\u30c6\u30af\u30c1\u30e3\u306f\u4ee5\u4e0b\u306e\u8981\u7d20\u3067\u69cb\u6210\u3055\u308c\u3066\u3044\u307e\u3059\uff1a<\/p>\n\n\n\n<pre class=\"EnlighterJSRAW\" data-enlighter-language=\"generic\" data-enlighter-theme=\"\" data-enlighter-highlight=\"\" data-enlighter-linenumbers=\"\" data-enlighter-lineoffset=\"\" data-enlighter-title=\"\" data-enlighter-group=\"\">\/\/ Netty\u3092\u4f7f\u7528\u3057\u305f\u57fa\u672c\u7684\u306a\u30b5\u30fc\u30d0\u30fc\u5b9f\u88c5\npublic class NettyServer {\n    public static void main(String[] args) throws Exception {\n        \/\/ \u30a4\u30d9\u30f3\u30c8\u30eb\u30fc\u30d7\u30b0\u30eb\u30fc\u30d7\u306e\u8a2d\u5b9a\n        EventLoopGroup bossGroup = new NioEventLoopGroup(1);\n        EventLoopGroup workerGroup = new NioEventLoopGroup();\n\n        try {\n            ServerBootstrap b = new ServerBootstrap();\n            b.group(bossGroup, workerGroup)\n                .channel(NioServerSocketChannel.class)\n                .childHandler(new ChannelInitializer&lt;SocketChannel&gt;() {\n                    @Override\n                    protected void initChannel(SocketChannel ch) {\n                        \/\/ \u30d1\u30a4\u30d7\u30e9\u30a4\u30f3\u306e\u8a2d\u5b9a\n                        ch.pipeline().addLast(\n                            new StringDecoder(),\n                            new StringEncoder(),\n                            new SimpleChannelInboundHandler&lt;String&gt;() {\n                                @Override\n                                protected void channelRead0(\n                                    ChannelHandlerContext ctx, String msg) {\n                                    \/\/ \u30e1\u30c3\u30bb\u30fc\u30b8\u51e6\u7406\n                                    ctx.writeAndFlush(\"\u5fdc\u7b54: \" + msg);\n                                }\n                            });\n                    }\n                });\n\n            \/\/ \u30b5\u30fc\u30d0\u30fc\u306e\u8d77\u52d5\n            ChannelFuture f = b.bind(8080).sync();\n            f.channel().closeFuture().sync();\n        } finally {\n            \/\/ \u30ea\u30bd\u30fc\u30b9\u306e\u89e3\u653e\n            bossGroup.shutdownGracefully();\n            workerGroup.shutdownGracefully();\n        }\n    }\n}<\/pre>\n\n\n\n<p>\u4e3b\u8981\u30b3\u30f3\u30dd\u30fc\u30cd\u30f3\u30c8\u306e\u8aac\u660e\uff1a<\/p>\n\n\n\n<ol class=\"wp-block-list\">\n<li>EventLoopGroup<\/li>\n<\/ol>\n\n\n\n<ul class=\"wp-block-list\">\n<li>\u30dc\u30b9\u30b0\u30eb\u30fc\u30d7\uff1a\u65b0\u898f\u63a5\u7d9a\u306e\u53d7\u4ed8<\/li>\n\n\n\n<li>\u30ef\u30fc\u30ab\u30fc\u30b0\u30eb\u30fc\u30d7\uff1a\u63a5\u7d9a\u6e08\u307f\u30c1\u30e3\u30cd\u30eb\u306e\u51e6\u7406<\/li>\n<\/ul>\n\n\n\n<ol class=\"wp-block-list\">\n<li>Channel<\/li>\n<\/ol>\n\n\n\n<ul class=\"wp-block-list\">\n<li>\u30cd\u30c3\u30c8\u30ef\u30fc\u30af\u64cd\u4f5c\u306e\u62bd\u8c61\u5316<\/li>\n\n\n\n<li>\u975e\u540c\u671fI\/O\u306e\u5b9f\u73fe<\/li>\n\n\n\n<li>\u30d0\u30c3\u30d5\u30a1\u7ba1\u7406\u306e\u52b9\u7387\u5316<\/li>\n<\/ul>\n\n\n\n<ol class=\"wp-block-list\">\n<li>ChannelPipeline<\/li>\n<\/ol>\n\n\n\n<ul class=\"wp-block-list\">\n<li>\u30c1\u30e3\u30cd\u30eb\u30cf\u30f3\u30c9\u30e9\u306e\u7ba1\u7406<\/li>\n\n\n\n<li>\u30c7\u30fc\u30bf\u51e6\u7406\u306e\u6d41\u308c\u5236\u5fa1<\/li>\n\n\n\n<li>\u30d7\u30ed\u30c8\u30b3\u30eb\u5909\u63db\u306e\u5b9f\u88c5<\/li>\n<\/ul>\n\n\n\n<ol class=\"wp-block-list\">\n<li>ByteBuf<\/li>\n<\/ol>\n\n\n\n<ul class=\"wp-block-list\">\n<li>\u52b9\u7387\u7684\u306a\u30e1\u30e2\u30ea\u7ba1\u7406<\/li>\n\n\n\n<li>\u53c2\u7167\u30ab\u30a6\u30f3\u30c8\u65b9\u5f0f<\/li>\n\n\n\n<li>\u30d7\u30fc\u30ea\u30f3\u30b0\u306b\u3088\u308b\u518d\u5229\u7528<\/li>\n<\/ul>\n\n\n\n<p>\u3053\u306e\u30a2\u30fc\u30ad\u30c6\u30af\u30c1\u30e3\u306b\u3088\u308a\u3001Netty\u306f\u9ad8\u6027\u80fd\u3067\u67d4\u8edf\u306a\u30cd\u30c3\u30c8\u30ef\u30fc\u30af\u30a2\u30d7\u30ea\u30b1\u30fc\u30b7\u30e7\u30f3\u306e\u958b\u767a\u3092\u53ef\u80fd\u306b\u3057\u3066\u3044\u307e\u3059\u3002<\/p>\n\n\n\n<h1 class=\"wp-block-heading\" id=\"i-4\">Netty\u5b9f\u8df5\u5165\u9580\uff1a\u57fa\u672c\u7684\u306a\u5b9f\u88c5\u30d1\u30bf\u30fc\u30f3<\/h1>\n\n\n\n<h2 class=\"wp-block-heading\" id=\"i-5\">\u30b7\u30f3\u30d7\u30eb\u306aTCP\u30b5\u30fc\u30d0\u30fc\u306e\u5b9f\u88c5\u624b\u9806<\/h2>\n\n\n\n<p>\u57fa\u672c\u7684\u306aTCP\u30b5\u30fc\u30d0\u30fc\u3092\u5b9f\u88c5\u3059\u308b\u624b\u9806\u3092\u3001\u6bb5\u968e\u7684\u306b\u8aac\u660e\u3057\u307e\u3059\u3002<\/p>\n\n\n\n<h3 class=\"wp-block-heading\" id=\"i-6\">1. \u30b5\u30fc\u30d0\u30fc\u5b9f\u88c5\u306e\u57fa\u672c\u69cb\u9020<\/h3>\n\n\n\n<pre class=\"EnlighterJSRAW\" data-enlighter-language=\"generic\" data-enlighter-theme=\"\" data-enlighter-highlight=\"\" data-enlighter-linenumbers=\"\" data-enlighter-lineoffset=\"\" data-enlighter-title=\"\" data-enlighter-group=\"\">public class EchoServer {\n    private final int port;\n\n    public EchoServer(int port) {\n        this.port = port;\n    }\n\n    public void start() throws Exception {\n        \/\/ \u30a4\u30d9\u30f3\u30c8\u30eb\u30fc\u30d7\u30b0\u30eb\u30fc\u30d7\u306e\u4f5c\u6210\n        EventLoopGroup bossGroup = new NioEventLoopGroup(1);\n        EventLoopGroup workerGroup = new NioEventLoopGroup();\n\n        try {\n            \/\/ \u30b5\u30fc\u30d0\u30fc\u30d6\u30fc\u30c8\u30b9\u30c8\u30e9\u30c3\u30d7\u306e\u8a2d\u5b9a\n            ServerBootstrap b = new ServerBootstrap();\n            b.group(bossGroup, workerGroup)\n             .channel(NioServerSocketChannel.class)\n             .option(ChannelOption.SO_BACKLOG, 128)\n             .childOption(ChannelOption.SO_KEEPALIVE, true)\n             .childHandler(new ChannelInitializer&lt;SocketChannel&gt;() {\n                 @Override\n                 protected void initChannel(SocketChannel ch) {\n                     ch.pipeline().addLast(new EchoServerHandler());\n                 }\n             });\n\n            \/\/ \u30b5\u30fc\u30d0\u30fc\u306e\u8d77\u52d5\n            ChannelFuture f = b.bind(port).sync();\n            System.out.println(\"\u30b5\u30fc\u30d0\u30fc\u304c\u8d77\u52d5\u3057\u307e\u3057\u305f\u3002\u30dd\u30fc\u30c8: \" + port);\n\n            \/\/ \u30b7\u30e3\u30c3\u30c8\u30c0\u30a6\u30f3\u5f85\u6a5f\n            f.channel().closeFuture().sync();\n        } finally {\n            \/\/ \u30ea\u30bd\u30fc\u30b9\u306e\u89e3\u653e\n            workerGroup.shutdownGracefully();\n            bossGroup.shutdownGracefully();\n        }\n    }\n}<\/pre>\n\n\n\n<h3 class=\"wp-block-heading\" id=\"i-7\">2. \u30cf\u30f3\u30c9\u30e9\u30fc\u306e\u5b9f\u88c5<\/h3>\n\n\n\n<pre class=\"EnlighterJSRAW\" data-enlighter-language=\"generic\" data-enlighter-theme=\"\" data-enlighter-highlight=\"\" data-enlighter-linenumbers=\"\" data-enlighter-lineoffset=\"\" data-enlighter-title=\"\" data-enlighter-group=\"\">public class EchoServerHandler extends ChannelInboundHandlerAdapter {\n    @Override\n    public void channelRead(ChannelHandlerContext ctx, Object msg) {\n        \/\/ \u53d7\u4fe1\u30c7\u30fc\u30bf\u306e\u51e6\u7406\n        ByteBuf in = (ByteBuf) msg;\n        try {\n            \/\/ \u30c7\u30fc\u30bf\u306e\u8aad\u307f\u53d6\u308a\u3068\u51e6\u7406\n            System.out.println(\"\u53d7\u4fe1\u30e1\u30c3\u30bb\u30fc\u30b8: \" + in.toString(CharsetUtil.UTF_8));\n            \/\/ \u30a8\u30b3\u30fc\u30d0\u30c3\u30af\n            ctx.write(in);\n        } finally {\n            \/\/ \u660e\u793a\u7684\u306a\u89e3\u653e\u306f\u4e0d\u8981\uff08write\u3067\u8ee2\u9001\uff09\n        }\n    }\n\n    @Override\n    public void channelReadComplete(ChannelHandlerContext ctx) {\n        \/\/ \u66f8\u304d\u8fbc\u307f\u30d0\u30c3\u30d5\u30a1\u306e\u30d5\u30e9\u30c3\u30b7\u30e5\n        ctx.flush();\n    }\n\n    @Override\n    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {\n        \/\/ \u30a8\u30e9\u30fc\u30cf\u30f3\u30c9\u30ea\u30f3\u30b0\n        cause.printStackTrace();\n        ctx.close();\n    }\n}<\/pre>\n\n\n\n<h2 class=\"wp-block-heading\" id=\"i-8\">\u52b9\u7387\u7684\u306a\u30a4\u30d9\u30f3\u30c8\u30cf\u30f3\u30c9\u30e9\u30fc\u306e\u8a2d\u8a08\u65b9\u6cd5<\/h2>\n\n\n\n<p>\u30a4\u30d9\u30f3\u30c8\u30cf\u30f3\u30c9\u30e9\u30fc\u306e\u8a2d\u8a08\u3067\u306f\u3001\u4ee5\u4e0b\u306e\u30d1\u30bf\u30fc\u30f3\u3092\u6d3b\u7528\u3057\u307e\u3059\uff1a<\/p>\n\n\n\n<h3 class=\"wp-block-heading\" id=\"i-9\">1. \u30d1\u30a4\u30d7\u30e9\u30a4\u30f3\u51e6\u7406\u306e\u5b9f\u88c5<\/h3>\n\n\n\n<pre class=\"EnlighterJSRAW\" data-enlighter-language=\"generic\" data-enlighter-theme=\"\" data-enlighter-highlight=\"\" data-enlighter-linenumbers=\"\" data-enlighter-lineoffset=\"\" data-enlighter-title=\"\" data-enlighter-group=\"\">public class ServerInitializer extends ChannelInitializer&lt;SocketChannel&gt; {\n    @Override\n    protected void initChannel(SocketChannel ch) {\n        ChannelPipeline p = ch.pipeline();\n\n        \/\/ \u30c7\u30b3\u30fc\u30c0\u30fc\u306e\u8ffd\u52a0\n        p.addLast(new ByteToMessageDecoder() {\n            @Override\n            protected void decode(ChannelHandlerContext ctx, \n                                ByteBuf in, \n                                List&lt;Object&gt; out) {\n                if (in.readableBytes() &lt; 4) {\n                    return;\n                }\n                out.add(in.readInt());\n            }\n        });\n\n        \/\/ \u30a8\u30f3\u30b3\u30fc\u30c0\u30fc\u306e\u8ffd\u52a0\n        p.addLast(new MessageToByteEncoder&lt;Integer&gt;() {\n            @Override\n            protected void encode(ChannelHandlerContext ctx, \n                                Integer msg, \n                                ByteBuf out) {\n                out.writeInt(msg);\n            }\n        });\n\n        \/\/ \u30d3\u30b8\u30cd\u30b9\u30ed\u30b8\u30c3\u30af\u30cf\u30f3\u30c9\u30e9\u30fc\u306e\u8ffd\u52a0\n        p.addLast(new BusinessLogicHandler());\n    }\n}<\/pre>\n\n\n\n<h3 class=\"wp-block-heading\" id=\"i-10\">2. \u72b6\u614b\u7ba1\u7406\u30d1\u30bf\u30fc\u30f3<\/h3>\n\n\n\n<pre class=\"EnlighterJSRAW\" data-enlighter-language=\"generic\" data-enlighter-theme=\"\" data-enlighter-highlight=\"\" data-enlighter-linenumbers=\"\" data-enlighter-lineoffset=\"\" data-enlighter-title=\"\" data-enlighter-group=\"\">public class StatefulHandler extends ChannelInboundHandlerAdapter {\n    private enum State {\n        WAIT_LENGTH, WAIT_CONTENT\n    }\n\n    private State currentState = State.WAIT_LENGTH;\n    private int expectedLength;\n\n    @Override\n    public void channelRead(ChannelHandlerContext ctx, Object msg) {\n        ByteBuf in = (ByteBuf) msg;\n\n        switch (currentState) {\n            case WAIT_LENGTH:\n                if (in.readableBytes() &gt;= 4) {\n                    expectedLength = in.readInt();\n                    currentState = State.WAIT_CONTENT;\n                }\n                break;\n\n            case WAIT_CONTENT:\n                if (in.readableBytes() &gt;= expectedLength) {\n                    ByteBuf content = in.readBytes(expectedLength);\n                    \/\/ \u30b3\u30f3\u30c6\u30f3\u30c4\u306e\u51e6\u7406\n                    currentState = State.WAIT_LENGTH;\n                }\n                break;\n        }\n    }\n}<\/pre>\n\n\n\n<h2 class=\"wp-block-heading\" id=\"i-11\">ByteBuf\u3092\u4f7f\u3063\u305f\u52b9\u7387\u7684\u306a\u30c7\u30fc\u30bf\u51e6\u7406<\/h2>\n\n\n\n<p>ByteBuf\u306e\u52b9\u7387\u7684\u306a\u4f7f\u7528\u65b9\u6cd5\u3092\u793a\u3057\u307e\u3059\uff1a<\/p>\n\n\n\n<h3 class=\"wp-block-heading\" id=\"i-12\">1. ByteBuf\u64cd\u4f5c\u306e\u57fa\u672c\u30d1\u30bf\u30fc\u30f3<\/h3>\n\n\n\n<pre class=\"EnlighterJSRAW\" data-enlighter-language=\"generic\" data-enlighter-theme=\"\" data-enlighter-highlight=\"\" data-enlighter-linenumbers=\"\" data-enlighter-lineoffset=\"\" data-enlighter-title=\"\" data-enlighter-group=\"\">public class ByteBufHandler extends ChannelInboundHandlerAdapter {\n    @Override\n    public void channelRead(ChannelHandlerContext ctx, Object msg) {\n        ByteBuf buf = (ByteBuf) msg;\n        try {\n            \/\/ \u8aad\u307f\u53d6\u308a\u64cd\u4f5c\n            while (buf.isReadable()) {\n                System.out.print((char) buf.readByte());\n            }\n            System.out.println();\n\n            \/\/ \u65b0\u3057\u3044\u30d0\u30c3\u30d5\u30a1\u306e\u4f5c\u6210\n            ByteBuf response = ctx.alloc().buffer();\n            response.writeBytes(\"\u5fdc\u7b54\u30e1\u30c3\u30bb\u30fc\u30b8\".getBytes());\n            ctx.writeAndFlush(response);\n\n        } finally {\n            \/\/ \u30ea\u30bd\u30fc\u30b9\u306e\u89e3\u653e\n            buf.release();\n        }\n    }\n}<\/pre>\n\n\n\n<h3 class=\"wp-block-heading\" id=\"i-13\">2. \u52b9\u7387\u7684\u306a\u30e1\u30e2\u30ea\u5229\u7528<\/h3>\n\n\n\n<pre class=\"EnlighterJSRAW\" data-enlighter-language=\"generic\" data-enlighter-theme=\"\" data-enlighter-highlight=\"\" data-enlighter-linenumbers=\"\" data-enlighter-lineoffset=\"\" data-enlighter-title=\"\" data-enlighter-group=\"\">public class MemoryEfficientHandler extends ChannelInboundHandlerAdapter {\n    private static final ByteBufAllocator POOLED_ALLOCATOR = \n        PooledByteBufAllocator.DEFAULT;\n\n    @Override\n    public void channelRead(ChannelHandlerContext ctx, Object msg) {\n        \/\/ \u30d7\u30fc\u30eb\u3055\u308c\u305f\u30d0\u30c3\u30d5\u30a1\u306e\u4f7f\u7528\n        ByteBuf buf = POOLED_ALLOCATOR.directBuffer();\n        try {\n            \/\/ \u30bc\u30ed\u30b3\u30d4\u30fc\u8ee2\u9001\u306e\u5b9f\u88c5\n            ByteBuf input = (ByteBuf) msg;\n            buf.writeBytes(input, input.readerIndex(), input.readableBytes());\n\n            \/\/ \u30c7\u30fc\u30bf\u51e6\u7406\n            processBuffer(buf);\n\n            \/\/ \u5fdc\u7b54\u9001\u4fe1\n            ctx.writeAndFlush(buf.retain());\n        } finally {\n            buf.release();\n        }\n    }\n\n    private void processBuffer(ByteBuf buf) {\n        \/\/ \u30d0\u30c3\u30d5\u30a1\u306e\u51e6\u7406\u30ed\u30b8\u30c3\u30af\n        \/\/ \u8907\u5408\u30d0\u30c3\u30d5\u30a1\u306e\u4f7f\u7528\u4f8b\n        CompositeByteBuf compositeBuf = POOLED_ALLOCATOR.compositeBuffer();\n        compositeBuf.addComponent(true, buf.retain());\n        compositeBuf.release();\n    }\n}<\/pre>\n\n\n\n<p>\u3053\u308c\u3089\u306e\u5b9f\u88c5\u30d1\u30bf\u30fc\u30f3\u3092\u7406\u89e3\u3057\u9069\u5207\u306b\u4f7f\u7528\u3059\u308b\u3053\u3068\u3067\u3001\u52b9\u7387\u7684\u3067\u5b89\u5b9a\u3057\u305fNetty\u30a2\u30d7\u30ea\u30b1\u30fc\u30b7\u30e7\u30f3\u3092\u69cb\u7bc9\u3067\u304d\u307e\u3059\u3002\u7279\u306b\u3001ByteBuf\u306e\u9069\u5207\u306a\u7ba1\u7406\u3068\u30a4\u30d9\u30f3\u30c8\u30cf\u30f3\u30c9\u30e9\u30fc\u306e\u8a2d\u8a08\u306f\u3001\u30a2\u30d7\u30ea\u30b1\u30fc\u30b7\u30e7\u30f3\u306e\u30d1\u30d5\u30a9\u30fc\u30de\u30f3\u30b9\u3068\u4fdd\u5b88\u6027\u306b\u5927\u304d\u304f\u5f71\u97ff\u3057\u307e\u3059\u3002<\/p>\n\n\n\n<h1 class=\"wp-block-heading\" id=\"i-14\">\u5b9f\u8df5\u7684\u306aNetty\u30a2\u30d7\u30ea\u30b1\u30fc\u30b7\u30e7\u30f3\u958b\u767a<\/h1>\n\n\n\n<h2 class=\"wp-block-heading\" id=\"i-15\">WebSocket\u306e\u30b5\u30fc\u30d0\u30fc\u5b9f\u88c5\u4f8b\u3068\u89e3\u8aac<\/h2>\n\n\n\n<p>WebSocket\u30b5\u30fc\u30d0\u30fc\u306e\u5b9f\u88c5\u4f8b\u3092\u793a\u3057\u307e\u3059\u3002\u3053\u306e\u30b5\u30fc\u30d0\u30fc\u306f\u30ea\u30a2\u30eb\u30bf\u30a4\u30e0\u306a\u53cc\u65b9\u5411\u901a\u4fe1\u3092\u5b9f\u73fe\u3057\u307e\u3059\u3002<\/p>\n\n\n\n<pre class=\"EnlighterJSRAW\" data-enlighter-language=\"generic\" data-enlighter-theme=\"\" data-enlighter-highlight=\"\" data-enlighter-linenumbers=\"\" data-enlighter-lineoffset=\"\" data-enlighter-title=\"\" data-enlighter-group=\"\">public class WebSocketServer {\n    private final int port;\n\n    public WebSocketServer(int port) {\n        this.port = port;\n    }\n\n    public void start() throws Exception {\n        EventLoopGroup bossGroup = new NioEventLoopGroup(1);\n        EventLoopGroup workerGroup = new NioEventLoopGroup();\n\n        try {\n            ServerBootstrap b = new ServerBootstrap();\n            b.group(bossGroup, workerGroup)\n             .channel(NioServerSocketChannel.class)\n             .childHandler(new WebSocketServerInitializer());\n\n            Channel ch = b.bind(port).sync().channel();\n            System.out.println(\"WebSocket\u30b5\u30fc\u30d0\u30fc\u3092\u8d77\u52d5\u3057\u307e\u3057\u305f\u3002ws:\/\/localhost:\" + port + '\/');\n            ch.closeFuture().sync();\n        } finally {\n            bossGroup.shutdownGracefully();\n            workerGroup.shutdownGracefully();\n        }\n    }\n}\n\nclass WebSocketServerInitializer extends ChannelInitializer&lt;SocketChannel&gt; {\n    @Override\n    protected void initChannel(SocketChannel ch) {\n        ChannelPipeline pipeline = ch.pipeline();\n\n        \/\/ WebSocket\u306b\u5fc5\u8981\u306a\u30cf\u30f3\u30c9\u30e9\u30fc\u306e\u8a2d\u5b9a\n        pipeline.addLast(new HttpServerCodec());\n        pipeline.addLast(new HttpObjectAggregator(65536));\n        pipeline.addLast(new WebSocketServerProtocolHandler(\"\/websocket\"));\n        pipeline.addLast(new WebSocketFrameHandler());\n    }\n}\n\nclass WebSocketFrameHandler extends SimpleChannelInboundHandler&lt;WebSocketFrame&gt; {\n    @Override\n    protected void channelRead0(ChannelHandlerContext ctx, WebSocketFrame frame) {\n        if (frame instanceof TextWebSocketFrame) {\n            String request = ((TextWebSocketFrame) frame).text();\n            System.out.println(\"\u53d7\u4fe1\u30e1\u30c3\u30bb\u30fc\u30b8: \" + request);\n\n            \/\/ \u30a8\u30b3\u30fc\u30ec\u30b9\u30dd\u30f3\u30b9\u306e\u9001\u4fe1\n            ctx.channel().writeAndFlush(\n                new TextWebSocketFrame(\"\u30b5\u30fc\u30d0\u30fc\u30ec\u30b9\u30dd\u30f3\u30b9: \" + request));\n        } else {\n            String message = \"\u672a\u30b5\u30dd\u30fc\u30c8\u306e\u30d5\u30ec\u30fc\u30e0\u30bf\u30a4\u30d7: \" + frame.getClass().getName();\n            throw new UnsupportedOperationException(message);\n        }\n    }\n}<\/pre>\n\n\n\n<h2 class=\"wp-block-heading\" id=\"i-16\">HTTP\u30b5\u30fc\u30d0\u30fc\u306e\u69cb\u7bc9\u3068RESTful API\u306e\u5b9f\u88c5<\/h2>\n\n\n\n<p>HTTP\u30b5\u30fc\u30d0\u30fc\u3068RESTful API\u306e\u5b9f\u88c5\u4f8b\u3092\u793a\u3057\u307e\u3059\u3002<\/p>\n\n\n\n<pre class=\"EnlighterJSRAW\" data-enlighter-language=\"generic\" data-enlighter-theme=\"\" data-enlighter-highlight=\"\" data-enlighter-linenumbers=\"\" data-enlighter-lineoffset=\"\" data-enlighter-title=\"\" data-enlighter-group=\"\">public class HttpServer {\n    private final int port;\n\n    public HttpServer(int port) {\n        this.port = port;\n    }\n\n    public void start() throws Exception {\n        EventLoopGroup bossGroup = new NioEventLoopGroup(1);\n        EventLoopGroup workerGroup = new NioEventLoopGroup();\n\n        try {\n            ServerBootstrap b = new ServerBootstrap();\n            b.group(bossGroup, workerGroup)\n             .channel(NioServerSocketChannel.class)\n             .childHandler(new HttpServerInitializer());\n\n            Channel ch = b.bind(port).sync().channel();\n            System.out.println(\"HTTP\u30b5\u30fc\u30d0\u30fc\u3092\u8d77\u52d5\u3057\u307e\u3057\u305f\u3002http:\/\/localhost:\" + port + '\/');\n            ch.closeFuture().sync();\n        } finally {\n            bossGroup.shutdownGracefully();\n            workerGroup.shutdownGracefully();\n        }\n    }\n}\n\nclass HttpServerInitializer extends ChannelInitializer&lt;SocketChannel&gt; {\n    @Override\n    protected void initChannel(SocketChannel ch) {\n        ChannelPipeline p = ch.pipeline();\n        p.addLast(new HttpServerCodec());\n        p.addLast(new HttpObjectAggregator(65536));\n        p.addLast(new HttpServerHandler());\n    }\n}\n\nclass HttpServerHandler extends SimpleChannelInboundHandler&lt;FullHttpRequest&gt; {\n    private static final ObjectMapper objectMapper = new ObjectMapper();\n\n    @Override\n    protected void channelRead0(ChannelHandlerContext ctx, FullHttpRequest request) {\n        if (!request.decoderResult().isSuccess()) {\n            sendError(ctx, HttpResponseStatus.BAD_REQUEST);\n            return;\n        }\n\n        \/\/ URI\u306b\u57fa\u3065\u304f\u30eb\u30fc\u30c6\u30a3\u30f3\u30b0\n        String uri = request.uri();\n        HttpMethod method = request.method();\n\n        if (\"\/api\/users\".equals(uri) &amp;&amp; method.equals(HttpMethod.GET)) {\n            handleGetUsers(ctx);\n        } else if (\"\/api\/users\".equals(uri) &amp;&amp; method.equals(HttpMethod.POST)) {\n            handleCreateUser(ctx, request);\n        } else {\n            sendError(ctx, HttpResponseStatus.NOT_FOUND);\n        }\n    }\n\n    private void handleGetUsers(ChannelHandlerContext ctx) {\n        \/\/ \u30e6\u30fc\u30b6\u30fc\u4e00\u89a7\u306eJSON\u30ec\u30b9\u30dd\u30f3\u30b9\u4f8b\n        List&lt;User&gt; users = Arrays.asList(\n            new User(\"user1\", \"John\"),\n            new User(\"user2\", \"Jane\")\n        );\n\n        try {\n            String json = objectMapper.writeValueAsString(users);\n            sendJsonResponse(ctx, json);\n        } catch (JsonProcessingException e) {\n            sendError(ctx, HttpResponseStatus.INTERNAL_SERVER_ERROR);\n        }\n    }\n\n    private void sendJsonResponse(ChannelHandlerContext ctx, String json) {\n        FullHttpResponse response = new DefaultFullHttpResponse(\n            HttpVersion.HTTP_1_1,\n            HttpResponseStatus.OK,\n            Unpooled.copiedBuffer(json, CharsetUtil.UTF_8));\n\n        response.headers().set(HttpHeaderNames.CONTENT_TYPE, \"application\/json\");\n        response.headers().set(HttpHeaderNames.CONTENT_LENGTH, \n                             response.content().readableBytes());\n\n        ctx.writeAndFlush(response).addListener(ChannelFutureListener.CLOSE);\n    }\n}<\/pre>\n\n\n\n<h2 class=\"wp-block-heading\" id=\"i-17\">\u30d7\u30ed\u30c8\u30b3\u30eb\u30d0\u30c3\u30d5\u30a1\u3092\u4f7f\u7528\u3057\u305f\u52b9\u7387\u7684\u306a\u901a\u4fe1<\/h2>\n\n\n\n<p>Protocol Buffers\u3092\u4f7f\u7528\u3057\u305f\u52b9\u7387\u7684\u306a\u901a\u4fe1\u306e\u5b9f\u88c5\u4f8b\u3092\u793a\u3057\u307e\u3059\u3002<\/p>\n\n\n\n<pre class=\"EnlighterJSRAW\" data-enlighter-language=\"generic\" data-enlighter-theme=\"\" data-enlighter-highlight=\"\" data-enlighter-linenumbers=\"\" data-enlighter-lineoffset=\"\" data-enlighter-title=\"\" data-enlighter-group=\"\">\/\/ \u30d7\u30ed\u30c8\u30b3\u30eb\u5b9a\u7fa9\uff08example.proto\uff09\nsyntax = \"proto3\";\npackage example;\n\nmessage User {\n    string id = 1;\n    string name = 2;\n    int32 age = 3;\n}\n\nmessage UserList {\n    repeated User users = 1;\n}<\/pre>\n\n\n\n<pre class=\"EnlighterJSRAW\" data-enlighter-language=\"generic\" data-enlighter-theme=\"\" data-enlighter-highlight=\"\" data-enlighter-linenumbers=\"\" data-enlighter-lineoffset=\"\" data-enlighter-title=\"\" data-enlighter-group=\"\">public class ProtobufServer {\n    private final int port;\n\n    public ProtobufServer(int port) {\n        this.port = port;\n    }\n\n    public void start() throws Exception {\n        EventLoopGroup bossGroup = new NioEventLoopGroup(1);\n        EventLoopGroup workerGroup = new NioEventLoopGroup();\n\n        try {\n            ServerBootstrap b = new ServerBootstrap();\n            b.group(bossGroup, workerGroup)\n             .channel(NioServerSocketChannel.class)\n             .childHandler(new ProtobufServerInitializer());\n\n            Channel ch = b.bind(port).sync().channel();\n            System.out.println(\"Protobuf\u30b5\u30fc\u30d0\u30fc\u3092\u8d77\u52d5\u3057\u307e\u3057\u305f\u3002port: \" + port);\n            ch.closeFuture().sync();\n        } finally {\n            bossGroup.shutdownGracefully();\n            workerGroup.shutdownGracefully();\n        }\n    }\n}\n\nclass ProtobufServerInitializer extends ChannelInitializer&lt;SocketChannel&gt; {\n    @Override\n    protected void initChannel(SocketChannel ch) {\n        ChannelPipeline p = ch.pipeline();\n\n        \/\/ Protocol Buffers\u306e\u30a8\u30f3\u30b3\u30fc\u30c0\u30fc\/\u30c7\u30b3\u30fc\u30c0\u30fc\u3092\u8ffd\u52a0\n        p.addLast(new ProtobufVarint32FrameDecoder());\n        p.addLast(new ProtobufDecoder(User.getDefaultInstance()));\n        p.addLast(new ProtobufVarint32LengthFieldPrepender());\n        p.addLast(new ProtobufEncoder());\n\n        p.addLast(new ProtobufServerHandler());\n    }\n}\n\nclass ProtobufServerHandler extends SimpleChannelInboundHandler&lt;User&gt; {\n    @Override\n    protected void channelRead0(ChannelHandlerContext ctx, User user) {\n        \/\/ Protocol Buffers\u30e1\u30c3\u30bb\u30fc\u30b8\u306e\u51e6\u7406\n        System.out.println(\"\u53d7\u4fe1\u30e6\u30fc\u30b6\u30fc: \" + user.getName());\n\n        \/\/ \u30ec\u30b9\u30dd\u30f3\u30b9\u306e\u4f5c\u6210\u3068\u9001\u4fe1\n        User response = User.newBuilder()\n            .setId(user.getId())\n            .setName(\"\u5fdc\u7b54: \" + user.getName())\n            .setAge(user.getAge())\n            .build();\n\n        ctx.writeAndFlush(response);\n    }\n}<\/pre>\n\n\n\n<p>\u3053\u308c\u3089\u306e\u5b9f\u88c5\u4f8b\u306f\u3001\u5b9f\u969b\u306e\u30a2\u30d7\u30ea\u30b1\u30fc\u30b7\u30e7\u30f3\u958b\u767a\u3067\u5fc5\u8981\u3068\u306a\u308b\u4e3b\u8981\u306a\u30d7\u30ed\u30c8\u30b3\u30eb\u3068\u306e\u7d71\u5408\u65b9\u6cd5\u3092\u793a\u3057\u3066\u3044\u307e\u3059\u3002\u5404\u5b9f\u88c5\u306b\u304a\u3044\u3066\u3001\u4ee5\u4e0b\u306e\u70b9\u306b\u6ce8\u610f\u304c\u5fc5\u8981\u3067\u3059\uff1a<\/p>\n\n\n\n<ol class=\"wp-block-list\">\n<li>WebSocket\u5b9f\u88c5\u306e\u30dd\u30a4\u30f3\u30c8\uff1a<\/li>\n<\/ol>\n\n\n\n<ul class=\"wp-block-list\">\n<li>WebSocket\u30cf\u30f3\u30c9\u30b7\u30a7\u30a4\u30af\u306e\u81ea\u52d5\u51e6\u7406<\/li>\n\n\n\n<li>\u30d5\u30ec\u30fc\u30e0\u30bf\u30a4\u30d7\u306b\u5fdc\u3058\u305f\u9069\u5207\u306a\u51e6\u7406<\/li>\n\n\n\n<li>\u7d99\u7d9a\u7684\u306a\u63a5\u7d9a\u7ba1\u7406<\/li>\n<\/ul>\n\n\n\n<ol class=\"wp-block-list\">\n<li>RESTful API\u5b9f\u88c5\u306e\u30dd\u30a4\u30f3\u30c8\uff1a<\/li>\n<\/ol>\n\n\n\n<ul class=\"wp-block-list\">\n<li>HTTP\u30e1\u30bd\u30c3\u30c9\u3068URI\u306b\u57fa\u3065\u304f\u30eb\u30fc\u30c6\u30a3\u30f3\u30b0<\/li>\n\n\n\n<li>JSON\u30b7\u30ea\u30a2\u30e9\u30a4\u30bc\u30fc\u30b7\u30e7\u30f3\/\u30c7\u30b7\u30ea\u30a2\u30e9\u30a4\u30bc\u30fc\u30b7\u30e7\u30f3<\/li>\n\n\n\n<li>\u9069\u5207\u306a\u30b9\u30c6\u30fc\u30bf\u30b9\u30b3\u30fc\u30c9\u3068\u30d8\u30c3\u30c0\u30fc\u306e\u8a2d\u5b9a<\/li>\n<\/ul>\n\n\n\n<ol class=\"wp-block-list\">\n<li>Protocol Buffers\u5b9f\u88c5\u306e\u30dd\u30a4\u30f3\u30c8\uff1a<\/li>\n<\/ol>\n\n\n\n<ul class=\"wp-block-list\">\n<li>\u30e1\u30c3\u30bb\u30fc\u30b8\u5b9a\u7fa9\u306e\u7ba1\u7406<\/li>\n\n\n\n<li>\u30a8\u30f3\u30b3\u30fc\u30c9\/\u30c7\u30b3\u30fc\u30c9\u306e\u52b9\u7387\u5316<\/li>\n\n\n\n<li>\u30d0\u30fc\u30b8\u30e7\u30cb\u30f3\u30b0\u306e\u8003\u616e<\/li>\n<\/ul>\n\n\n\n<p>\u3053\u308c\u3089\u306e\u30d7\u30ed\u30c8\u30b3\u30eb\u5b9f\u88c5\u3092\u9069\u5207\u306b\u7d44\u307f\u5408\u308f\u305b\u308b\u3053\u3068\u3067\u3001\u69d8\u3005\u306a\u30e6\u30fc\u30b9\u30b1\u30fc\u30b9\u306b\u5bfe\u5fdc\u3067\u304d\u308b\u67d4\u8edf\u306a\u30a2\u30d7\u30ea\u30b1\u30fc\u30b7\u30e7\u30f3\u3092\u69cb\u7bc9\u3067\u304d\u307e\u3059\u3002<\/p>\n\n\n\n<h1 class=\"wp-block-heading\" id=\"i-18\">Netty\u30a2\u30d7\u30ea\u30b1\u30fc\u30b7\u30e7\u30f3\u306e\u6027\u80fd\u6700\u9069\u5316<\/h1>\n\n\n\n<h2 class=\"wp-block-heading\" id=\"i-19\">\u30e1\u30e2\u30ea\u30ea\u30fc\u30af\u3092\u9632\u3050\u305f\u3081\u306e\u30d9\u30b9\u30c8\u30d7\u30e9\u30af\u30c6\u30a3\u30b9<\/h2>\n\n\n\n<p>Netty\u30a2\u30d7\u30ea\u30b1\u30fc\u30b7\u30e7\u30f3\u3067\u30e1\u30e2\u30ea\u30ea\u30fc\u30af\u3092\u9632\u3050\u305f\u3081\u306e\u4e3b\u8981\u306a\u30dd\u30a4\u30f3\u30c8\u3068\u5b9f\u88c5\u4f8b\u3092\u793a\u3057\u307e\u3059\u3002<\/p>\n\n\n\n<pre class=\"EnlighterJSRAW\" data-enlighter-language=\"generic\" data-enlighter-theme=\"\" data-enlighter-highlight=\"\" data-enlighter-linenumbers=\"\" data-enlighter-lineoffset=\"\" data-enlighter-title=\"\" data-enlighter-group=\"\">public class MemoryLeakPreventionHandler extends ChannelInboundHandlerAdapter {\n    \/\/ \u30e1\u30c3\u30bb\u30fc\u30b8\u30ad\u30e5\u30fc\u306e\u6700\u5927\u30b5\u30a4\u30ba\u3092\u5236\u9650\n    private static final int MAX_MESSAGES = 1000;\n    private final Queue&lt;ByteBuf&gt; messageQueue = new ConcurrentLinkedQueue&lt;&gt;();\n\n    @Override\n    public void channelRead(ChannelHandlerContext ctx, Object msg) {\n        if (msg instanceof ByteBuf) {\n            ByteBuf buf = (ByteBuf) msg;\n            try {\n                \/\/ \u30e1\u30c3\u30bb\u30fc\u30b8\u30ad\u30e5\u30fc\u306e\u30b5\u30a4\u30ba\u30c1\u30a7\u30c3\u30af\n                if (messageQueue.size() &gt;= MAX_MESSAGES) {\n                    \/\/ \u53e4\u3044\u30e1\u30c3\u30bb\u30fc\u30b8\u3092\u7834\u68c4\n                    ByteBuf oldMsg = messageQueue.poll();\n                    if (oldMsg != null) {\n                        oldMsg.release();\n                    }\n                }\n\n                \/\/ \u30e1\u30c3\u30bb\u30fc\u30b8\u306e\u51e6\u7406\u3068\u30ad\u30e5\u30fc\u3078\u306e\u8ffd\u52a0\n                processMessage(buf.retain());\n                messageQueue.offer(buf);\n            } finally {\n                \/\/ \u53c2\u7167\u30ab\u30a6\u30f3\u30c8\u306e\u9069\u5207\u306a\u7ba1\u7406\n                buf.release();\n            }\n        }\n    }\n\n    @Override\n    public void channelInactive(ChannelHandlerContext ctx) {\n        \/\/ \u30b3\u30cd\u30af\u30b7\u30e7\u30f3\u7d42\u4e86\u6642\u306e\u30af\u30ea\u30fc\u30f3\u30a2\u30c3\u30d7\n        clearMessageQueue();\n    }\n\n    private void clearMessageQueue() {\n        ByteBuf msg;\n        while ((msg = messageQueue.poll()) != null) {\n            msg.release();\n        }\n    }\n\n    private void processMessage(ByteBuf buf) {\n        \/\/ \u30e1\u30c3\u30bb\u30fc\u30b8\u51e6\u7406\u30ed\u30b8\u30c3\u30af\n    }\n}<\/pre>\n\n\n\n<p>\u30e1\u30e2\u30ea\u30ea\u30fc\u30af\u9632\u6b62\u306e\u305f\u3081\u306e\u4e3b\u8981\u306a\u30dd\u30a4\u30f3\u30c8\uff1a<\/p>\n\n\n\n<ol class=\"wp-block-list\">\n<li>ByteBuf\u7ba1\u7406<\/li>\n<\/ol>\n\n\n\n<ul class=\"wp-block-list\">\n<li>\u53c2\u7167\u30ab\u30a6\u30f3\u30c8\u306e\u9069\u5207\u306a\u7ba1\u7406<\/li>\n\n\n\n<li>release()\u30e1\u30bd\u30c3\u30c9\u306e\u78ba\u5b9f\u306a\u547c\u3073\u51fa\u3057<\/li>\n\n\n\n<li>try-finally\u30d6\u30ed\u30c3\u30af\u306e\u6d3b\u7528<\/li>\n<\/ul>\n\n\n\n<ol class=\"wp-block-list\">\n<li>\u30ea\u30bd\u30fc\u30b9\u7ba1\u7406<\/li>\n<\/ol>\n\n\n\n<ul class=\"wp-block-list\">\n<li>\u30ad\u30e5\u30fc\u3084\u30d0\u30c3\u30d5\u30a1\u306e\u30b5\u30a4\u30ba\u5236\u9650<\/li>\n\n\n\n<li>\u9069\u5207\u306a\u30af\u30ea\u30fc\u30f3\u30a2\u30c3\u30d7\u51e6\u7406<\/li>\n\n\n\n<li>\u30e1\u30e2\u30ea\u30d7\u30fc\u30eb\u306e\u6d3b\u7528<\/li>\n<\/ul>\n\n\n\n<h2 class=\"wp-block-heading\" id=\"i-20\">\u30b9\u30ec\u30c3\u30c9\u30e2\u30c7\u30eb\u306e\u30c1\u30e5\u30fc\u30cb\u30f3\u30b0\u30c6\u30af\u30cb\u30c3\u30af<\/h2>\n\n\n\n<p>Netty\u306e\u30b9\u30ec\u30c3\u30c9\u30e2\u30c7\u30eb\u3092\u6700\u9069\u5316\u3059\u308b\u305f\u3081\u306e\u5b9f\u88c5\u4f8b\u3068\u8a2d\u5b9a\u65b9\u6cd5\u3092\u793a\u3057\u307e\u3059\u3002<\/p>\n\n\n\n<pre class=\"EnlighterJSRAW\" data-enlighter-language=\"generic\" data-enlighter-theme=\"\" data-enlighter-highlight=\"\" data-enlighter-linenumbers=\"\" data-enlighter-lineoffset=\"\" data-enlighter-title=\"\" data-enlighter-group=\"\">public class OptimizedServer {\n    private final int port;\n    private final int bossThreads;\n    private final int workerThreads;\n\n    public OptimizedServer(int port, int bossThreads, int workerThreads) {\n        this.port = port;\n        this.bossThreads = bossThreads;\n        this.workerThreads = workerThreads;\n    }\n\n    public void start() throws Exception {\n        \/\/ \u30b9\u30ec\u30c3\u30c9\u30d7\u30fc\u30eb\u306e\u6700\u9069\u5316\u8a2d\u5b9a\n        EventLoopGroup bossGroup = new NioEventLoopGroup(bossThreads, \n            new DefaultThreadFactory(\"boss\"));\n        EventLoopGroup workerGroup = new NioEventLoopGroup(workerThreads,\n            new DefaultThreadFactory(\"worker\"));\n\n        try {\n            ServerBootstrap b = new ServerBootstrap();\n            b.group(bossGroup, workerGroup)\n             .channel(NioServerSocketChannel.class)\n             .option(ChannelOption.SO_BACKLOG, 1024)\n             .childOption(ChannelOption.SO_KEEPALIVE, true)\n             .childOption(ChannelOption.TCP_NODELAY, true)\n             .childHandler(new OptimizedServerInitializer());\n\n            \/\/ \u9ad8\u5ea6\u306a\u8a2d\u5b9a\n            b.childOption(ChannelOption.ALLOCATOR, \n                PooledByteBufAllocator.DEFAULT);\n            b.childOption(ChannelOption.WRITE_BUFFER_WATER_MARK, \n                new WriteBufferWaterMark(32 * 1024, 64 * 1024));\n\n            Channel ch = b.bind(port).sync().channel();\n            ch.closeFuture().sync();\n        } finally {\n            bossGroup.shutdownGracefully();\n            workerGroup.shutdownGracefully();\n        }\n    }\n}<\/pre>\n\n\n\n<p>\u30b9\u30ec\u30c3\u30c9\u30e2\u30c7\u30eb\u6700\u9069\u5316\u306e\u30dd\u30a4\u30f3\u30c8\uff1a<\/p>\n\n\n\n<ol class=\"wp-block-list\">\n<li>\u30b9\u30ec\u30c3\u30c9\u6570\u306e\u8a2d\u5b9a<\/li>\n<\/ol>\n\n\n\n<ul class=\"wp-block-list\">\n<li>CPU\u30b3\u30a2\u6570\u306b\u57fa\u3065\u304f\u9069\u5207\u306a\u30b9\u30ec\u30c3\u30c9\u6570<\/li>\n\n\n\n<li>\u30ef\u30fc\u30af\u30ed\u30fc\u30c9\u306b\u5fdc\u3058\u305f\u8abf\u6574<\/li>\n\n\n\n<li>\u30e2\u30cb\u30bf\u30ea\u30f3\u30b0\u306b\u57fa\u3065\u304f\u6700\u9069\u5316<\/li>\n<\/ul>\n\n\n\n<ol class=\"wp-block-list\">\n<li>\u30a4\u30d9\u30f3\u30c8\u30eb\u30fc\u30d7\u306e\u8a2d\u5b9a<\/li>\n<\/ol>\n\n\n\n<ul class=\"wp-block-list\">\n<li>\u9069\u5207\u306a\u30a4\u30d9\u30f3\u30c8\u30eb\u30fc\u30d7\u30b0\u30eb\u30fc\u30d7\u306e\u5206\u5272<\/li>\n\n\n\n<li>\u30bf\u30b9\u30af\u5b9f\u884c\u306e\u512a\u5148\u9806\u4f4d\u4ed8\u3051<\/li>\n\n\n\n<li>\u30d0\u30c3\u30af\u30d7\u30ec\u30c3\u30b7\u30e3\u30fc\u306e\u5236\u5fa1<\/li>\n<\/ul>\n\n\n\n<h2 class=\"wp-block-heading\" id=\"i-21\">\u30d1\u30d5\u30a9\u30fc\u30de\u30f3\u30b9\u30e2\u30cb\u30bf\u30ea\u30f3\u30b0\u3068\u554f\u984c\u89e3\u6c7a<\/h2>\n\n\n\n<p>\u30d1\u30d5\u30a9\u30fc\u30de\u30f3\u30b9\u30e2\u30cb\u30bf\u30ea\u30f3\u30b0\u3068\u554f\u984c\u89e3\u6c7a\u306e\u305f\u3081\u306e\u5b9f\u88c5\u4f8b\u3092\u793a\u3057\u307e\u3059\u3002<\/p>\n\n\n\n<pre class=\"EnlighterJSRAW\" data-enlighter-language=\"generic\" data-enlighter-theme=\"\" data-enlighter-highlight=\"\" data-enlighter-linenumbers=\"\" data-enlighter-lineoffset=\"\" data-enlighter-title=\"\" data-enlighter-group=\"\">public class PerformanceMonitorHandler extends ChannelDuplexHandler {\n    private static final Logger logger = \n        LoggerFactory.getLogger(PerformanceMonitorHandler.class);\n\n    private final AtomicLong totalProcessingTime = new AtomicLong(0);\n    private final AtomicLong totalMessages = new AtomicLong(0);\n    private final Map&lt;ChannelId, Long&gt; processingStartTimes = \n        new ConcurrentHashMap&lt;&gt;();\n\n    @Override\n    public void channelRead(ChannelHandlerContext ctx, Object msg) {\n        \/\/ \u51e6\u7406\u958b\u59cb\u6642\u9593\u306e\u8a18\u9332\n        processingStartTimes.put(ctx.channel().id(), System.nanoTime());\n\n        \/\/ \u30e1\u30c3\u30bb\u30fc\u30b8\u51e6\u7406\u306e\u7d71\u8a08\n        totalMessages.incrementAndGet();\n\n        ctx.fireChannelRead(msg);\n    }\n\n    @Override\n    public void flush(ChannelHandlerContext ctx) {\n        Long startTime = processingStartTimes.remove(ctx.channel().id());\n        if (startTime != null) {\n            long processingTime = System.nanoTime() - startTime;\n            totalProcessingTime.addAndGet(processingTime);\n\n            \/\/ \u30d1\u30d5\u30a9\u30fc\u30de\u30f3\u30b9\u30e1\u30c8\u30ea\u30af\u30b9\u306e\u8a18\u9332\n            if (totalMessages.get() % 1000 == 0) {\n                logPerformanceMetrics();\n            }\n        }\n\n        ctx.flush();\n    }\n\n    private void logPerformanceMetrics() {\n        long avgProcessingTime = totalProcessingTime.get() \/ \n            Math.max(1, totalMessages.get());\n\n        logger.info(\"Performance Metrics:\");\n        logger.info(\"Total Messages: {}\", totalMessages.get());\n        logger.info(\"Average Processing Time: {} ns\", avgProcessingTime);\n    }\n}<\/pre>\n\n\n\n<p>\u30e2\u30cb\u30bf\u30ea\u30f3\u30b0\u3068\u554f\u984c\u89e3\u6c7a\u306e\u30dd\u30a4\u30f3\u30c8\uff1a<\/p>\n\n\n\n<ol class=\"wp-block-list\">\n<li>\u30e1\u30c8\u30ea\u30af\u30b9\u53ce\u96c6<\/li>\n<\/ol>\n\n\n\n<ul class=\"wp-block-list\">\n<li>\u30b9\u30eb\u30fc\u30d7\u30c3\u30c8\u306e\u6e2c\u5b9a<\/li>\n\n\n\n<li>\u30ec\u30a4\u30c6\u30f3\u30b7\u30fc\u306e\u76e3\u8996<\/li>\n\n\n\n<li>\u30ea\u30bd\u30fc\u30b9\u4f7f\u7528\u7387\u306e\u8ffd\u8de1<\/li>\n<\/ul>\n\n\n\n<ol class=\"wp-block-list\">\n<li>\u554f\u984c\u691c\u51fa\u3068\u89e3\u6c7a<\/li>\n<\/ol>\n\n\n\n<ul class=\"wp-block-list\">\n<li>\u30dc\u30c8\u30eb\u30cd\u30c3\u30af\u306e\u7279\u5b9a<\/li>\n\n\n\n<li>\u30e1\u30e2\u30ea\u30ea\u30fc\u30af\u306e\u691c\u51fa<\/li>\n\n\n\n<li>\u30d1\u30d5\u30a9\u30fc\u30de\u30f3\u30b9\u4f4e\u4e0b\u306e\u539f\u56e0\u5206\u6790<\/li>\n<\/ul>\n\n\n\n<ol class=\"wp-block-list\">\n<li>\u30c1\u30e5\u30fc\u30cb\u30f3\u30b0\u306e\u30a2\u30d7\u30ed\u30fc\u30c1<\/li>\n<\/ol>\n\n\n\n<ul class=\"wp-block-list\">\n<li>\u6bb5\u968e\u7684\u306a\u6700\u9069\u5316<\/li>\n\n\n\n<li>A\/B\u30c6\u30b9\u30c8\u306b\u3088\u308b\u691c\u8a3c<\/li>\n\n\n\n<li>\u7d99\u7d9a\u7684\u306a\u30e2\u30cb\u30bf\u30ea\u30f3\u30b0<\/li>\n<\/ul>\n\n\n\n<p>\u3053\u308c\u3089\u306e\u6700\u9069\u5316\u30c6\u30af\u30cb\u30c3\u30af\u3092\u9069\u5207\u306b\u7d44\u307f\u5408\u308f\u305b\u308b\u3053\u3068\u3067\u3001\u9ad8\u6027\u80fd\u3067\u5b89\u5b9a\u3057\u305fNetty\u30a2\u30d7\u30ea\u30b1\u30fc\u30b7\u30e7\u30f3\u3092\u5b9f\u73fe\u3067\u304d\u307e\u3059\u3002<\/p>\n\n\n\n<h1 class=\"wp-block-heading\" id=\"i-22\">\u5b9f\u904b\u7528\u306b\u5411\u3051\u305fNetty\u306e\u8a2d\u8a08\u30d1\u30bf\u30fc\u30f3<\/h1>\n\n\n\n<h2 class=\"wp-block-heading\" id=\"i-23\">\u30de\u30a4\u30af\u30ed\u30b5\u30fc\u30d3\u30b9\u3067\u306eNetty\u6d3b\u7528\u4e8b\u4f8b<\/h2>\n\n\n\n<p>\u30de\u30a4\u30af\u30ed\u30b5\u30fc\u30d3\u30b9\u30a2\u30fc\u30ad\u30c6\u30af\u30c1\u30e3\u3067\u306eNetty\u6d3b\u7528\u4f8b\u3092\u793a\u3057\u307e\u3059\u3002<\/p>\n\n\n\n<pre class=\"EnlighterJSRAW\" data-enlighter-language=\"generic\" data-enlighter-theme=\"\" data-enlighter-highlight=\"\" data-enlighter-linenumbers=\"\" data-enlighter-lineoffset=\"\" data-enlighter-title=\"\" data-enlighter-group=\"\">public class MicroserviceNettyServer {\n    private final int port;\n    private final ServiceRegistry serviceRegistry;\n    private final LoadBalancer loadBalancer;\n\n    public MicroserviceNettyServer(int port) {\n        this.port = port;\n        this.serviceRegistry = new ServiceRegistry();\n        this.loadBalancer = new LoadBalancer();\n    }\n\n    public void start() throws Exception {\n        EventLoopGroup bossGroup = new NioEventLoopGroup(1);\n        EventLoopGroup workerGroup = new NioEventLoopGroup();\n\n        try {\n            ServerBootstrap b = new ServerBootstrap();\n            b.group(bossGroup, workerGroup)\n             .channel(NioServerSocketChannel.class)\n             .childHandler(new MicroserviceChannelInitializer(\n                 serviceRegistry, loadBalancer));\n\n            \/\/ \u30b5\u30fc\u30d3\u30b9\u767b\u9332\n            registerService();\n\n            Channel ch = b.bind(port).sync().channel();\n            ch.closeFuture().sync();\n        } finally {\n            unregisterService();\n            bossGroup.shutdownGracefully();\n            workerGroup.shutdownGracefully();\n        }\n    }\n\n    private class MicroserviceChannelInitializer \n            extends ChannelInitializer&lt;SocketChannel&gt; {\n        private final ServiceRegistry serviceRegistry;\n        private final LoadBalancer loadBalancer;\n\n        MicroserviceChannelInitializer(\n            ServiceRegistry serviceRegistry, LoadBalancer loadBalancer) {\n            this.serviceRegistry = serviceRegistry;\n            this.loadBalancer = loadBalancer;\n        }\n\n        @Override\n        protected void initChannel(SocketChannel ch) {\n            ChannelPipeline p = ch.pipeline();\n            p.addLast(new HttpServerCodec());\n            p.addLast(new HttpObjectAggregator(65536));\n            p.addLast(new MicroserviceHandler(\n                serviceRegistry, loadBalancer));\n        }\n    }\n}<\/pre>\n\n\n\n<h2 class=\"wp-block-heading\" id=\"i-24\">Spring WebFlux\u3068Netty\u306e\u7d71\u5408\u65b9\u6cd5<\/h2>\n\n\n\n<p>Spring WebFlux\u3068Netty\u3092\u7d71\u5408\u3059\u308b\u5b9f\u88c5\u4f8b\u3092\u793a\u3057\u307e\u3059\u3002<\/p>\n\n\n\n<pre class=\"EnlighterJSRAW\" data-enlighter-language=\"generic\" data-enlighter-theme=\"\" data-enlighter-highlight=\"\" data-enlighter-linenumbers=\"\" data-enlighter-lineoffset=\"\" data-enlighter-title=\"\" data-enlighter-group=\"\">@Configuration\npublic class NettyWebFluxConfig {\n    @Bean\n    public HttpHandler httpHandler(WebFluxProperties properties) {\n        return WebHttpHandlerBuilder\n            .applicationContext(context)\n            .build();\n    }\n\n    @Bean\n    public ReactorHttpHandlerAdapter handlerAdapter(HttpHandler httpHandler) {\n        return new ReactorHttpHandlerAdapter(httpHandler);\n    }\n\n    @Bean\n    public DisposableServer nettyServer(\n            ReactorHttpHandlerAdapter handlerAdapter,\n            @Value(\"${server.port:8080}\") int port) {\n        return HttpServer.create()\n            .port(port)\n            .handle(handlerAdapter)\n            .bind()\n            .block();\n    }\n}\n\n@RestController\n@RequestMapping(\"\/api\")\npublic class ReactiveController {\n    @GetMapping(\"\/data\")\n    public Flux&lt;DataItem&gt; getData() {\n        return Flux.interval(Duration.ofMillis(100))\n            .map(i -&gt; new DataItem(\"item-\" + i))\n            .take(10);\n    }\n\n    @PostMapping(\"\/process\")\n    public Mono&lt;Response&gt; processData(@RequestBody Mono&lt;Request&gt; request) {\n        return request\n            .flatMap(this::processRequest)\n            .timeout(Duration.ofSeconds(5));\n    }\n}<\/pre>\n\n\n\n<h2 class=\"wp-block-heading\" id=\"i-25\">\u672c\u756a\u74b0\u5883\u3067\u306e\u969c\u5bb3\u5bfe\u7b56\u3068\u30c8\u30e9\u30d6\u30eb\u30b7\u30e5\u30fc\u30c6\u30a3\u30f3\u30b0<\/h2>\n\n\n\n<p>\u672c\u756a\u74b0\u5883\u3067\u306e\u969c\u5bb3\u5bfe\u7b56\u3068\u30c8\u30e9\u30d6\u30eb\u30b7\u30e5\u30fc\u30c6\u30a3\u30f3\u30b0\u306e\u5b9f\u88c5\u4f8b\u3092\u793a\u3057\u307e\u3059\u3002<\/p>\n\n\n\n<pre class=\"EnlighterJSRAW\" data-enlighter-language=\"generic\" data-enlighter-theme=\"\" data-enlighter-highlight=\"\" data-enlighter-linenumbers=\"\" data-enlighter-lineoffset=\"\" data-enlighter-title=\"\" data-enlighter-group=\"\">public class ProductionReadyServer {\n    private static final Logger logger = \n        LoggerFactory.getLogger(ProductionReadyServer.class);\n\n    private final MetricsRegistry metricsRegistry;\n    private final CircuitBreaker circuitBreaker;\n    private final RetryPolicy retryPolicy;\n\n    public ProductionReadyServer() {\n        this.metricsRegistry = new MetricsRegistry();\n        this.circuitBreaker = new CircuitBreaker();\n        this.retryPolicy = new RetryPolicy();\n    }\n\n    @Override\n    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {\n        \/\/ \u4f8b\u5916\u306e\u5206\u985e\u3068\u9069\u5207\u306a\u51e6\u7406\n        if (cause instanceof ConnectTimeoutException) {\n            handleTimeout(ctx, (ConnectTimeoutException) cause);\n        } else if (cause instanceof MemoryLeakException) {\n            handleMemoryLeak(ctx, (MemoryLeakException) cause);\n        } else {\n            handleUnexpectedError(ctx, cause);\n        }\n    }\n\n    private void handleTimeout(\n            ChannelHandlerContext ctx, ConnectTimeoutException e) {\n        \/\/ \u30bf\u30a4\u30e0\u30a2\u30a6\u30c8\u6642\u306e\u51e6\u7406\n        if (retryPolicy.shouldRetry()) {\n            retryOperation(ctx);\n        } else {\n            sendErrorResponse(ctx, HttpResponseStatus.GATEWAY_TIMEOUT);\n        }\n        metricsRegistry.incrementTimeoutCounter();\n    }\n\n    private void handleMemoryLeak(\n            ChannelHandlerContext ctx, MemoryLeakException e) {\n        \/\/ \u30e1\u30e2\u30ea\u30ea\u30fc\u30af\u691c\u51fa\u6642\u306e\u51e6\u7406\n        logger.error(\"Memory leak detected\", e);\n        System.gc(); \/\/ \u660e\u793a\u7684\u306aGC\u547c\u3073\u51fa\u3057\n        metricsRegistry.incrementMemoryLeakCounter();\n        ctx.close();\n    }\n\n    private class HealthCheckHandler extends ChannelInboundHandlerAdapter {\n        @Override\n        public void channelRead(ChannelHandlerContext ctx, Object msg) {\n            if (msg instanceof HealthCheckRequest) {\n                \/\/ \u30d8\u30eb\u30b9\u30c1\u30a7\u30c3\u30af\u306e\u5b9f\u884c\n                performHealthCheck(ctx);\n            } else {\n                ctx.fireChannelRead(msg);\n            }\n        }\n\n        private void performHealthCheck(ChannelHandlerContext ctx) {\n            HealthStatus status = new HealthStatus();\n            status.setMemoryUsage(getMemoryUsage());\n            status.setThreadStats(getThreadStats());\n            status.setConnectionCount(getActiveConnections());\n\n            ctx.writeAndFlush(status);\n        }\n    }\n}<\/pre>\n\n\n\n<p>\u672c\u756a\u74b0\u5883\u3067\u306e\u904b\u7528\u30dd\u30a4\u30f3\u30c8\uff1a<\/p>\n\n\n\n<ol class=\"wp-block-list\">\n<li>\u969c\u5bb3\u691c\u51fa\u3068\u5bfe\u7b56<\/li>\n<\/ol>\n\n\n\n<ul class=\"wp-block-list\">\n<li>\u81ea\u52d5\u30d8\u30eb\u30b9\u30c1\u30a7\u30c3\u30af<\/li>\n\n\n\n<li>\u30b5\u30fc\u30ad\u30c3\u30c8\u30d6\u30ec\u30fc\u30ab\u30fc\u30d1\u30bf\u30fc\u30f3<\/li>\n\n\n\n<li>\u30ea\u30c8\u30e9\u30a4\u30e1\u30ab\u30cb\u30ba\u30e0<\/li>\n<\/ul>\n\n\n\n<ol class=\"wp-block-list\">\n<li>\u30e2\u30cb\u30bf\u30ea\u30f3\u30b0\u3068\u8b66\u544a<\/li>\n<\/ol>\n\n\n\n<ul class=\"wp-block-list\">\n<li>\u30e1\u30c8\u30ea\u30af\u30b9\u53ce\u96c6<\/li>\n\n\n\n<li>\u30ed\u30b0\u7ba1\u7406<\/li>\n\n\n\n<li>\u30a2\u30e9\u30fc\u30c8\u8a2d\u5b9a<\/li>\n<\/ul>\n\n\n\n<ol class=\"wp-block-list\">\n<li>\u30b9\u30b1\u30fc\u30e9\u30d3\u30ea\u30c6\u30a3\u5bfe\u7b56<\/li>\n<\/ol>\n\n\n\n<ul class=\"wp-block-list\">\n<li>\u6c34\u5e73\u30b9\u30b1\u30fc\u30ea\u30f3\u30b0<\/li>\n\n\n\n<li>\u30ed\u30fc\u30c9\u30d0\u30e9\u30f3\u30b7\u30f3\u30b0<\/li>\n\n\n\n<li>\u30bb\u30c3\u30b7\u30e7\u30f3\u7ba1\u7406<\/li>\n<\/ul>\n\n\n\n<p>\u3053\u308c\u3089\u306e\u8a2d\u8a08\u30d1\u30bf\u30fc\u30f3\u3068\u904b\u7528\u624b\u6cd5\u3092\u9069\u5207\u306b\u7d44\u307f\u5408\u308f\u305b\u308b\u3053\u3068\u3067\u3001\u5b89\u5b9a\u3057\u305f\u672c\u756a\u74b0\u5883\u306e\u904b\u7528\u304c\u53ef\u80fd\u306b\u306a\u308a\u307e\u3059\u3002<\/p>\n","protected":false},"excerpt":{"rendered":"<p>Netty\u3068\u306f\uff1f\u57fa\u790e\u304b\u3089\u7406\u89e3\u3059\u308b\u975e\u540c\u671f\u30cd\u30c3\u30c8\u30ef\u30fc\u30af\u30d5\u30ec\u30fc\u30e0\u30ef\u30fc\u30af Warning: Undefined array key &#8220;is_admin&#8221; in \/home\/xs392991\/dexall.co.jp\/public &#8230; <\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"closed","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[2],"tags":[],"class_list":{"0":"post-1183","1":"post","2":"type-post","3":"status-publish","4":"format-standard","6":"category-java","7":"nothumb"},"_links":{"self":[{"href":"https:\/\/dexall.co.jp\/articles\/index.php?rest_route=\/wp\/v2\/posts\/1183","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/dexall.co.jp\/articles\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/dexall.co.jp\/articles\/index.php?rest_route=\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/dexall.co.jp\/articles\/index.php?rest_route=\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/dexall.co.jp\/articles\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=1183"}],"version-history":[{"count":1,"href":"https:\/\/dexall.co.jp\/articles\/index.php?rest_route=\/wp\/v2\/posts\/1183\/revisions"}],"predecessor-version":[{"id":1184,"href":"https:\/\/dexall.co.jp\/articles\/index.php?rest_route=\/wp\/v2\/posts\/1183\/revisions\/1184"}],"wp:attachment":[{"href":"https:\/\/dexall.co.jp\/articles\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=1183"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/dexall.co.jp\/articles\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=1183"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/dexall.co.jp\/articles\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=1183"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}