From 2ca9993b57bdd090c4345ea6767687e2fbb83014 Mon Sep 17 00:00:00 2001
From: zhongrj <646384940@qq.com>
Date: Tue, 27 Jun 2023 11:00:09 +0800
Subject: [PATCH] 新增任务导出接口
---
src/main/java/org/springblade/modules/nettyUdpServer/server/UdpServer.java | 37 -------------------------------------
1 files changed, 0 insertions(+), 37 deletions(-)
diff --git a/src/main/java/org/springblade/modules/nettyUdpServer/server/UdpServer.java b/src/main/java/org/springblade/modules/nettyUdpServer/server/UdpServer.java
index a08c621..a79d397 100644
--- a/src/main/java/org/springblade/modules/nettyUdpServer/server/UdpServer.java
+++ b/src/main/java/org/springblade/modules/nettyUdpServer/server/UdpServer.java
@@ -31,43 +31,6 @@
run();
}
- /**
- * 不用
- */
- public void init() {
- final NioEventLoopGroup group = new NioEventLoopGroup();
- try {
- Bootstrap b = new Bootstrap();
- b.group(group).channel(NioDatagramChannel.class)
- .option(ChannelOption.SO_BROADCAST, true)
- .handler(new ChannelInitializer<NioDatagramChannel>() {
- @Override
- public void initChannel(NioDatagramChannel ch) throws Exception {
- ChannelPipeline p = ch.pipeline();
- p.addLast("decoder", new JsonObjectDecoder());
- p.addLast(new UdpServerHandler());
- }
- });
- InetAddress address = InetAddress.getLocalHost();
- channel = b.bind(address, port).sync().channel();
- Executors.newSingleThreadExecutor().execute(new Runnable() {
- @Override
- public void run() {
- try {
- channel.closeFuture().sync();
- } catch (InterruptedException e) {
- e.printStackTrace();
- } finally {
- group.shutdownGracefully();
- }
- }
- });
- LOG.info("UDP服务器启动, host:{},port:{}", address.getHostAddress(), port);
- } catch (Exception e) {
- e.printStackTrace();
- }
- }
-
//给管道抽象出接口，给Channel更多的能力和配置，例如Channel的状态，参数，IO操作
//使用ChannelPipeline实现自定义IO
--
Gitblit v1.9.3