<dependency> \u00a0 \u00a0 <groupId>io.netty<\/groupId> \u00a0 \u00a0 <artifactId>netty-all<\/artifactId> \u00a0 \u00a0 <version>4.1.68.Final<\/version> <\/dependency> \u00a0<\/p>\n
@Component
\n@RequiredArgsConstructor
\npublic class NettyServerConfig {<\/p>\n
\/\/ \u5b9a\u4e49\u670d\u52a1\u5668\u7aef\u53e3\u53f7
\n private final int port = 13030;<\/p>\n
\/\/ \u6ce8\u5165JsonServerHandler\u5904\u7406\u5668
\n private final JsonServerHandler jsonServerHandler;<\/p>\n
\/\/ \u521d\u59cb\u5316\u65b9\u6cd5，\u5728Bean\u521b\u5efa\u65f6\u542f\u52a8Netty\u670d\u52a1\u5668
\n @PostConstruct
\n public void startNetty() {
\n new Thread(() -> {
\n \/\/ \u521b\u5efaboss\u548cworker\u4e24\u4e2a\u7ebf\u7a0b\u7ec4
\n EventLoopGroup bossGroup = new NioEventLoopGroup();
\n EventLoopGroup workerGroup = new NioEventLoopGroup();
\n try {
\n \/\/ \u521b\u5efaServerBootstrap\u5b9e\u4f8b\u4ee5\u914d\u7f6e\u670d\u52a1\u5668
\n ServerBootstrap bootstrap = new ServerBootstrap();
\n bootstrap.group(bossGroup, workerGroup)
\n .channel(NioServerSocketChannel.class) \/\/ \u6307\u5b9a\u4f7f\u7528NIO\u4f20\u8f93Channel
\n .childHandler(new ChannelInitializer<SocketChannel>() {
\n @Override
\n protected void initChannel(SocketChannel ch) throws Exception {
\n \/\/ \u914d\u7f6e\u901a\u9053\u5904\u7406\u5668，\u5305\u62ec\u89e3\u7801\u5668\u3001\u7f16\u7801\u5668\u548c\u4e1a\u52a1\u5904\u7406\u5668
\n ch.pipeline().addLast(new StringDecoder(CharsetUtil.UTF_8));
\n ch.pipeline().addLast(new StringEncoder(CharsetUtil.UTF_8));
\n ch.pipeline().addLast(jsonServerHandler); \/\/ \u4f7f\u7528\u6ce8\u5165\u7684JsonServerHandler
\n }
\n })
\n .option(ChannelOption.SO_BACKLOG, 128) \/\/ \u8bbe\u7f6e\u961f\u5217\u5927\u5c0f
\n .childOption(ChannelOption.SO_KEEPALIVE, true); \/\/ \u4fdd\u6301\u8fde\u63a5<\/p>\n
\/\/ \u7ed1\u5b9a\u7aef\u53e3\u5e76\u542f\u52a8\u670d\u52a1\u5668
\n ChannelFuture f = bootstrap.bind(port).sync();
\n \/\/ \u7b49\u5f85\u670d\u52a1\u5668\u901a\u9053\u5173\u95ed
\n f.channel().closeFuture().sync();
\n } catch (InterruptedException e) {
\n e.printStackTrace();
\n } finally {
\n \/\/ \u4f18\u96c5\u5730\u5173\u95ed\u7ebf\u7a0b\u7ec4
\n workerGroup.shutdownGracefully();
\n bossGroup.shutdownGracefully();
\n }
\n }).start();
\n }
\n} <\/p>\n
@Slf4j
\n@ChannelHandler.Sharable
\n@Component
\npublic class JsonServerHandler extends SimpleChannelInboundHandler<String> {
\n @Autowired
\n private ReceptionMapper receptionMapper;<\/p>\n
private final ObjectMapper objectMapper = new ObjectMapper();<\/p>\n
\/\/ \u5904\u7406\u63a5\u6536\u5230\u7684\u6d88\u606f
\n @Override
\n @Transactional
\n protected void channelRead0(ChannelHandlerContext ctx, String msg) throws Exception {
\n try {
\n \/\/ \u53cd\u5e8f\u5217\u5316\u63a5\u6536\u5230\u7684JSON\u6d88\u606f
\n ReceptionData receptionData = null;
\n try {
\n receptionData = objectMapper.readValue(msg, ReceptionData.class);
\n } catch (JsonProcessingException e) {
\n log.error("\u89e3\u7801\u6570\u636e\u9519\u8bef", e);
\n }
\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/\u5b58\u5165\u6570\u636e\u5e93
\n receptionMapper.saveData(receptionData );<\/p>\n
} catch (Exception e) {
\n log.error("\u63a5\u6536\u6570\u636e\u9519\u8bef", e);
\n }
\n }<\/p>\n","protected":false},"excerpt":{"rendered":"
\u6587\u7ae0\u6d4f\u89c8\u9605\u8bfb881\u6b21\uff0c\u70b9\u8d5e12\u6b21\uff0c\u6536\u85cf6\u6b21\u3002\/ \u4f7f\u7528\u6ce8\u5165\u7684JsonServerHandler\u3002.channel(NioServerSocketChannel.class) \/\/ \u6307\u5b9a\u4f7f\u7528NIO\u4f20\u8f93Channel\u3002.option(ChannelOption.SO_BACKLOG, 128) \/\/ \u8bbe\u7f6e\u961f\u5217\u5927\u5c0f\u3002\/\/ \u6ce8\u5165JsonServerHandler\u5904\u7406\u5668\u3002\/\/ \u7ed1\u5b9a\u7aef\u53e3\u5e76\u542f\u52a8\u670d\u52a1\u5668\u3002\/\/ \u53cd\u5e8f\u5217\u5316\u63a5\u6536\u5230\u7684JSON\u6d88\u606f\u3002\/\/ \u7b49\u5f85\u670d\u52a1\u5668\u901a\u9053\u5173\u95ed\u3002\/\/ \u4f18\u96c5\u5730\u5173\u95ed\u7ebf\u7a0b\u7ec4\u3002\/\/ \u5b9a\u4e49\u670d\u52a1\u5668\u7aef\u53e3\u53f7\u3002\/\/ \u5904\u7406\u63a5\u6536\u5230\u7684\u6d88\u606f\u3002_springboot+netty\u63a5\u6536\u8bbe\u5907\u4fe1\u606f<\/p>\n","protected":false},"author":2,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[386,99,1133,98,2312,43],"topic":[],"class_list":["post-28671","post","type-post","status-publish","format-standard","hentry","category-server","tag-intellij-idea","tag-java","tag-servlet","tag-spring-boot","tag-2312","tag-43"],"yoast_head":"\n