{"id":29883,"date":"2025-04-20T13:46:04","date_gmt":"2025-04-20T05:46:04","guid":{"rendered":"https:\/\/www.wsisp.com\/helps\/29883.html"},"modified":"2025-04-20T13:46:04","modified_gmt":"2025-04-20T05:46:04","slug":"netty-%e5%85%a5%e9%97%a8%e5%ba%94%e7%94%a8%ef%bc%9a%e7%bb%93%e5%90%88-redis-%e5%ae%9e%e7%8e%b0%e6%9c%8d%e5%8a%a1%e5%99%a8%e9%80%9a%e4%bf%a1","status":"publish","type":"post","link":"https:\/\/www.wsisp.com\/helps\/29883.html","title":{"rendered":"Netty \u5165\u95e8\u5e94\u7528\uff1a\u7ed3\u5408 Redis \u5b9e\u73b0\u670d\u52a1\u5668\u901a\u4fe1"},"content":{"rendered":"

\u5728\u4e0a\u7bc7\u535a\u5ba2\u4e2d，\u6211\u4eec\u4e86\u89e3\u4e86 Netty \u7684\u57fa\u672c\u6982\u5ff5\u548c\u67b6\u6784\u3002\u672c\u7bc7\u6587\u7ae0\u5c06\u5e26\u4f60\u6df1\u5165\u5b9e\u8df5，\u6784\u5efa\u4e00\u4e2a\u7b80\u5355\u7684 Netty \u670d\u52a1\u7aef，\u5e76\u7ed3\u5408 Redis \u5b9e\u73b0\u4e00\u4e2a\u6570\u636e\u5b58\u53d6\u7684\u793a\u4f8b\u3002\u5728\u8fd9\u4e2a\u573a\u666f\u4e2d，Redis \u4f5c\u4e3a\u7f13\u5b58\u5b58\u50a8，Netty \u4f5c\u4e3a\u670d\u52a1\u7aef\u5904\u7406\u5ba2\u6237\u7aef\u8bf7\u6c42\u3002\u901a\u8fc7\u8fd9\u79cd\u7ec4\u5408，\u80fd\u591f\u5e2e\u52a9\u4f60\u7406\u89e3\u5982\u4f55\u5728\u771f\u5b9e\u7684\u9879\u76ee\u4e2d\u5c06 Netty \u4e0e Redis \u4e00\u8d77\u4f7f\u7528\u3002<\/p>\n

\u73af\u5883\u51c6\u5907\u4e0e\u5b89\u88c5<\/h4>\n

\u4e3a\u4e86\u5f00\u59cb\u4f7f\u7528 Netty \u548c Redis，\u6211\u4eec\u9996\u5148\u9700\u8981\u914d\u7f6e\u5f00\u53d1\u73af\u5883\u3002\u4f60\u9700\u8981\u5728\u9879\u76ee\u7684 pom.xml \u4e2d\u6dfb\u52a0\u4ee5\u4e0b Maven \u4f9d\u8d56\u6765\u4f7f\u7528 Netty \u548c Jedis（Java \u7684 Redis \u5ba2\u6237\u7aef）\u3002<\/p>\n

<<\/span>dependency<\/span>><\/span><\/span>
\n <<\/span>groupId<\/span>><\/span><\/span>io.netty<\/<\/span>groupId<\/span>><\/span><\/span>
\n <<\/span>artifactId<\/span>><\/span><\/span>netty-all<\/<\/span>artifactId<\/span>><\/span><\/span>
\n <<\/span>version<\/span>><\/span><\/span>4.1.75.Final<\/<\/span>version<\/span>><\/span><\/span>
\n<\/<\/span>dependency<\/span>><\/span><\/span>
\n<<\/span>dependency<\/span>><\/span><\/span>
\n <<\/span>groupId<\/span>><\/span><\/span>redis.clients<\/<\/span>groupId<\/span>><\/span><\/span>
\n <<\/span>artifactId<\/span>><\/span><\/span>jedis<\/<\/span>artifactId<\/span>><\/span><\/span>
\n <<\/span>version<\/span>><\/span><\/span>4.0.1<\/<\/span>version<\/span>><\/span><\/span>
\n<\/<\/span>dependency<\/span>><\/span><\/span><\/p>\n

\u8fd9\u6bb5\u914d\u7f6e\u5c06\u5f15\u5165 Netty \u548c Jedis，\u7528\u4e8e\u5b9e\u73b0 Redis \u64cd\u4f5c\u548c\u7f51\u7edc\u901a\u4fe1\u3002<\/p>\n

Redis \u4e0e Netty \u7684\u7ed3\u5408\u573a\u666f\u4ecb\u7ecd<\/h4>\n

\u5728\u5b9e\u9645\u7684\u5e94\u7528\u573a\u666f\u4e2d，Netty \u53ef\u4ee5\u7528\u4e8e\u5904\u7406\u9ad8\u5e76\u53d1\u7684\u5ba2\u6237\u7aef\u8bf7\u6c42，\u800c Redis \u4f5c\u4e3a\u5185\u5b58\u5b58\u50a8，\u53ef\u4ee5\u5b58\u50a8\u4e34\u65f6\u6570\u636e\u6216\u5e38\u7528\u7684\u6570\u636e\u4ee5\u63d0\u9ad8\u54cd\u5e94\u901f\u5ea6\u3002\u6211\u4eec\u53ef\u4ee5\u7528 Netty \u4f5c\u4e3a\u670d\u52a1\u7aef，\u63a5\u53d7\u5ba2\u6237\u7aef\u7684\u6570\u636e\u8bf7\u6c42，\u5e76\u5c06\u6570\u636e\u5b58\u50a8\u6216\u8bfb\u53d6\u5230 Redis \u4e2d\u3002\u8fd9\u79cd\u7ec4\u5408\u5728\u5206\u5e03\u5f0f\u7f13\u5b58\u3001\u5b9e\u65f6\u6d88\u606f\u63a8\u9001\u7b49\u573a\u666f\u4e0b\u975e\u5e38\u5e38\u89c1\u3002<\/p>\n

Netty Hello World \u793a\u4f8b：\u5b9e\u73b0 Redis \u6570\u636e\u5b58\u50a8\u7684\u670d\u52a1\u7aef<\/h4>\n

\u5728\u8fd9\u4e2a\u793a\u4f8b\u4e2d，\u6211\u4eec\u5c06\u6784\u5efa\u4e00\u4e2a Netty \u670d\u52a1\u7aef\u6765\u63a5\u6536\u5ba2\u6237\u7aef\u7684\u5b58\u53d6\u8bf7\u6c42，\u5c06\u6570\u636e\u5b58\u50a8\u5230 Redis \u4e2d，\u6216\u8005\u4ece Redis \u83b7\u53d6\u5e76\u8fd4\u56de\u7ed9\u5ba2\u6237\u7aef\u3002<\/p>\n

\u670d\u52a1\u7aef\u4ee3\u7801\u5b9e\u73b0<\/h5>\n

import<\/span> io.<\/span>netty.<\/span>bootstrap.<\/span><\/span>ServerBootstrap<\/span><\/span>;<\/span>
\nimport<\/span> io.<\/span>netty.<\/span>channel.<\/span><\/span>ChannelFuture<\/span><\/span>;<\/span>
\nimport<\/span> io.<\/span>netty.<\/span>channel.<\/span><\/span>ChannelInitializer<\/span><\/span>;<\/span>
\nimport<\/span> io.<\/span>netty.<\/span>channel.<\/span><\/span>ChannelPipeline<\/span><\/span>;<\/span>
\nimport<\/span> io.<\/span>netty.<\/span>channel.<\/span><\/span>EventLoopGroup<\/span><\/span>;<\/span>
\nimport<\/span> io.<\/span>netty.<\/span>channel.<\/span>nio.<\/span><\/span>NioEventLoopGroup<\/span><\/span>;<\/span>
\nimport<\/span> io.<\/span>netty.<\/span>channel.<\/span>socket.<\/span><\/span>SocketChannel<\/span><\/span>;<\/span>
\nimport<\/span> io.<\/span>netty.<\/span>channel.<\/span>socket.<\/span>nio.<\/span><\/span>NioServerSocketChannel<\/span><\/span>;<\/span>
\nimport<\/span> io.<\/span>netty.<\/span>handler.<\/span>codec.<\/span>string.<\/span><\/span>StringDecoder<\/span><\/span>;<\/span>
\nimport<\/span> io.<\/span>netty.<\/span>handler.<\/span>codec.<\/span>string.<\/span><\/span>StringEncoder<\/span><\/span>;<\/span>
\nimport<\/span> redis.<\/span>clients.<\/span>jedis.<\/span><\/span>Jedis<\/span><\/span>;<\/span><\/p>\n

public<\/span> class<\/span> RedisNettyServer<\/span> {<\/span>
\n public<\/span> static<\/span> void<\/span> main<\/span>(<\/span>String<\/span>[<\/span>]<\/span> args)<\/span> throws<\/span> Exception<\/span> {<\/span>
\n \/\/ \u521b\u5efa\u4e24\u4e2a\u4e8b\u4ef6\u5faa\u73af\u7ec4，BossGroup \u7528\u4e8e\u63a5\u6536\u8fde\u63a5，WorkerGroup \u7528\u4e8e\u5904\u7406\u8fde\u63a5\u7684\u6570\u636e<\/span>
\n EventLoopGroup<\/span> bossGroup =<\/span> new<\/span> NioEventLoopGroup<\/span>(<\/span>1<\/span>)<\/span>;<\/span>
\n EventLoopGroup<\/span> workerGroup =<\/span> new<\/span> NioEventLoopGroup<\/span>(<\/span>)<\/span>;<\/span><\/p>\n

try<\/span> {<\/span>
\n ServerBootstrap<\/span> bootstrap =<\/span> new<\/span> ServerBootstrap<\/span>(<\/span>)<\/span>;<\/span>
\n bootstrap.<\/span>group<\/span>(<\/span>bossGroup,<\/span> workerGroup)<\/span>
\n .<\/span>channel<\/span>(<\/span>NioServerSocketChannel<\/span>.<\/span>class<\/span>)<\/span>
\n .<\/span>childHandler<\/span>(<\/span>new<\/span> ChannelInitializer<\/span><<\/span>SocketChannel<\/span>><\/span><\/span>(<\/span>)<\/span> {<\/span>
\n @Override<\/span>
\n protected<\/span> void<\/span> initChannel<\/span>(<\/span>SocketChannel<\/span> ch)<\/span> throws<\/span> Exception<\/span> {<\/span>
\n ChannelPipeline<\/span> pipeline =<\/span> ch.<\/span>pipeline<\/span>(<\/span>)<\/span>;<\/span>
\n pipeline.<\/span>addLast<\/span>(<\/span>new<\/span> StringDecoder<\/span>(<\/span>)<\/span>)<\/span>;<\/span> \/\/ \u6dfb\u52a0\u5b57\u7b26\u4e32\u89e3\u7801\u5668<\/span>
\n pipeline.<\/span>addLast<\/span>(<\/span>new<\/span> StringEncoder<\/span>(<\/span>)<\/span>)<\/span>;<\/span> \/\/ \u6dfb\u52a0\u5b57\u7b26\u4e32\u7f16\u7801\u5668<\/span>
\n pipeline.<\/span>addLast<\/span>(<\/span>new<\/span> RedisServerHandler<\/span>(<\/span>)<\/span>)<\/span>;<\/span> \/\/ \u81ea\u5b9a\u4e49\u5904\u7406\u5668<\/span>
\n }<\/span>
\n }<\/span>)<\/span>;<\/span><\/p>\n

\/\/ \u7ed1\u5b9a\u7aef\u53e3\u5e76\u542f\u52a8\u670d\u52a1\u5668<\/span>
\n ChannelFuture<\/span> channelFuture =<\/span> bootstrap.<\/span>bind<\/span>(<\/span>8080<\/span>)<\/span>.<\/span>sync<\/span>(<\/span>)<\/span>;<\/span>
\n System<\/span>.<\/span>out.<\/span>println<\/span>(<\/span>"Redis Netty Server started on port 8080."<\/span>)<\/span>;<\/span>
\n channelFuture.<\/span>channel<\/span>(<\/span>)<\/span>.<\/span>closeFuture<\/span>(<\/span>)<\/span>.<\/span>sync<\/span>(<\/span>)<\/span>;<\/span>
\n }<\/span> finally<\/span> {<\/span>
\n bossGroup.<\/span>shutdownGracefully<\/span>(<\/span>)<\/span>;<\/span>
\n workerGroup.<\/span>shutdownGracefully<\/span>(<\/span>)<\/span>;<\/span>
\n }<\/span>
\n }<\/span>
\n}<\/span><\/p>\n

\u81ea\u5b9a\u4e49\u5904\u7406\u5668：RedisServerHandler<\/h5>\n

\u6211\u4eec\u901a\u8fc7 RedisServerHandler \u6765\u5904\u7406\u5ba2\u6237\u7aef\u7684\u8bf7\u6c42，\u5c06\u6570\u636e\u5b58\u53d6\u64cd\u4f5c\u8f6c\u53d1\u5230 Redis\u3002<\/p>\n

import<\/span> io.<\/span>netty.<\/span>channel.<\/span><\/span>ChannelHandlerContext<\/span><\/span>;<\/span>
\nimport<\/span> io.<\/span>netty.<\/span>channel.<\/span><\/span>ChannelInboundHandlerAdapter<\/span><\/span>;<\/span>
\nimport<\/span> redis.<\/span>clients.<\/span>jedis.<\/span><\/span>Jedis<\/span><\/span>;<\/span><\/p>\n

public<\/span> class<\/span> RedisServerHandler<\/span> extends<\/span> ChannelInboundHandlerAdapter<\/span> {<\/span>
\n @Override<\/span>
\n public<\/span> void<\/span> channelRead<\/span>(<\/span>ChannelHandlerContext<\/span> ctx,<\/span> Object<\/span> msg)<\/span> {<\/span>
\n String<\/span> message =<\/span> (<\/span>String<\/span>)<\/span> msg;<\/span>
\n System<\/span>.<\/span>out.<\/span>println<\/span>(<\/span>"Received: "<\/span> +<\/span> message)<\/span>;<\/span><\/p>\n

try<\/span> (<\/span>Jedis<\/span> jedis =<\/span> new<\/span> Jedis<\/span>(<\/span>"localhost"<\/span>)<\/span>)<\/span> {<\/span>
\n \/\/ \u89e3\u6790\u5ba2\u6237\u7aef\u7684\u8bf7\u6c42<\/span>
\n if<\/span> (<\/span>message.<\/span>startsWith<\/span>(<\/span>"SET"<\/span>)<\/span>)<\/span> {<\/span>
\n \/\/ \u793a\u4f8b\u547d\u4ee4：SET key value<\/span>
\n String<\/span>[<\/span>]<\/span> parts =<\/span> message.<\/span>split<\/span>(<\/span>" "<\/span>)<\/span>;<\/span>
\n if<\/span> (<\/span>parts.<\/span>length ==<\/span> 3<\/span>)<\/span> {<\/span>
\n String<\/span> key =<\/span> parts[<\/span>1<\/span>]<\/span>;<\/span>
\n String<\/span> value =<\/span> parts[<\/span>2<\/span>]<\/span>;<\/span>
\n jedis.<\/span>set<\/span>(<\/span>key,<\/span> value)<\/span>;<\/span>
\n ctx.<\/span>writeAndFlush<\/span>(<\/span>"OK\\\\n"<\/span>)<\/span>;<\/span>
\n }<\/span> else<\/span> {<\/span>
\n ctx.<\/span>writeAndFlush<\/span>(<\/span>"ERROR: Invalid SET command\\\\n"<\/span>)<\/span>;<\/span>
\n }<\/span>
\n }<\/span> else<\/span> if<\/span> (<\/span>message.<\/span>startsWith<\/span>(<\/span>"GET"<\/span>)<\/span>)<\/span> {<\/span>
\n \/\/ \u793a\u4f8b\u547d\u4ee4：GET key<\/span>
\n String<\/span>[<\/span>]<\/span> parts =<\/span> message.<\/span>split<\/span>(<\/span>" "<\/span>)<\/span>;<\/span>
\n if<\/span> (<\/span>parts.<\/span>length ==<\/span> 2<\/span>)<\/span> {<\/span>
\n String<\/span> key =<\/span> parts[<\/span>1<\/span>]<\/span>;<\/span>
\n String<\/span> value =<\/span> jedis.<\/span>get<\/span>(<\/span>key)<\/span>;<\/span>
\n ctx.<\/span>writeAndFlush<\/span>(<\/span>value !=<\/span> null<\/span> ?<\/span> value +<\/span> "\\\\n"<\/span> :<\/span> "(nil)\\\\n"<\/span>)<\/span>;<\/span>
\n }<\/span> else<\/span> {<\/span>
\n ctx.<\/span>writeAndFlush<\/span>(<\/span>"ERROR: Invalid GET command\\\\n"<\/span>)<\/span>;<\/span>
\n }<\/span>
\n }<\/span> else<\/span> {<\/span>
\n ctx.<\/span>writeAndFlush<\/span>(<\/span>"ERROR: Unknown command\\\\n"<\/span>)<\/span>;<\/span>
\n }<\/span>
\n }<\/span> catch<\/span> (<\/span>Exception<\/span> e)<\/span> {<\/span>
\n e.<\/span>printStackTrace<\/span>(<\/span>)<\/span>;<\/span>
\n ctx.<\/span>writeAndFlush<\/span>(<\/span>"ERROR: Redis connection failed\\\\n"<\/span>)<\/span>;<\/span>
\n }<\/span>
\n }<\/span><\/p>\n

@Override<\/span>
\n public<\/span> void<\/span> exceptionCaught<\/span>(<\/span>ChannelHandlerContext<\/span> ctx,<\/span> Throwable<\/span> cause)<\/span> {<\/span>
\n cause.<\/span>printStackTrace<\/span>(<\/span>)<\/span>;<\/span>
\n ctx.<\/span>close<\/span>(<\/span>)<\/span>;<\/span>
\n }<\/span>
\n}<\/span><\/p>\n

\u89e3\u91ca：<\/p>\n