diff --git a/casic-shelter/src/main/java/com/casic/missiles/socket/BootNettyServer.java b/casic-shelter/src/main/java/com/casic/missiles/socket/BootNettyServer.java index 87191e7..5da2f4e 100644 --- a/casic-shelter/src/main/java/com/casic/missiles/socket/BootNettyServer.java +++ b/casic-shelter/src/main/java/com/casic/missiles/socket/BootNettyServer.java @@ -11,14 +11,16 @@ import io.netty.util.CharsetUtil; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Value; -import org.springframework.stereotype.Service; +import org.springframework.boot.CommandLineRunner; +import org.springframework.scheduling.annotation.Async; +import org.springframework.stereotype.Component; /** * @author a203 */ @Slf4j -@Service -public class BootNettyServer { +@Component +public class BootNettyServer implements CommandLineRunner { @Value("${casic.socket.port}") private Integer port; @@ -29,7 +31,9 @@ this.socketService = socketService; } - public void bind() { + @Async + @Override + public void run(String... args) { EventLoopGroup bossGroup = new NioEventLoopGroup(1); EventLoopGroup workerGroup = new NioEventLoopGroup(); try { @@ -66,7 +70,7 @@ pipeline.addLast(new ChannelHandlerAdapter(socketService)); } }); - log.info("Socket port has open, and Port:" + port + " has been occupied...."); + log.info(this.getClass().getSimpleName() + " has been started, and Port:" + port + " has been occupied...."); /** * 绑定端口,同步等待成功 */ diff --git a/casic-shelter/src/main/java/com/casic/missiles/socket/BootNettyServer.java b/casic-shelter/src/main/java/com/casic/missiles/socket/BootNettyServer.java index 87191e7..5da2f4e 100644 --- a/casic-shelter/src/main/java/com/casic/missiles/socket/BootNettyServer.java +++ b/casic-shelter/src/main/java/com/casic/missiles/socket/BootNettyServer.java @@ -11,14 +11,16 @@ import io.netty.util.CharsetUtil; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Value; -import org.springframework.stereotype.Service; +import org.springframework.boot.CommandLineRunner; +import org.springframework.scheduling.annotation.Async; +import org.springframework.stereotype.Component; /** * @author a203 */ @Slf4j -@Service -public class BootNettyServer { +@Component +public class BootNettyServer implements CommandLineRunner { @Value("${casic.socket.port}") private Integer port; @@ -29,7 +31,9 @@ this.socketService = socketService; } - public void bind() { + @Async + @Override + public void run(String... args) { EventLoopGroup bossGroup = new NioEventLoopGroup(1); EventLoopGroup workerGroup = new NioEventLoopGroup(); try { @@ -66,7 +70,7 @@ pipeline.addLast(new ChannelHandlerAdapter(socketService)); } }); - log.info("Socket port has open, and Port:" + port + " has been occupied...."); + log.info(this.getClass().getSimpleName() + " has been started, and Port:" + port + " has been occupied...."); /** * 绑定端口,同步等待成功 */ diff --git a/casic-web/src/main/java/com/casic/missiles/CasicApplication.java b/casic-web/src/main/java/com/casic/missiles/CasicApplication.java index dd26429..77d3153 100644 --- a/casic-web/src/main/java/com/casic/missiles/CasicApplication.java +++ b/casic-web/src/main/java/com/casic/missiles/CasicApplication.java @@ -1,18 +1,11 @@ package com.casic.missiles; -import com.casic.missiles.socket.BootNettyServer; import lombok.extern.slf4j.Slf4j; -import org.springframework.boot.CommandLineRunner; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; -import org.springframework.cache.annotation.EnableCaching; -import org.springframework.scheduling.annotation.Async; -import org.springframework.scheduling.annotation.EnableAsync; import org.springframework.scheduling.annotation.EnableScheduling; import org.springframework.transaction.annotation.EnableTransactionManagement; -import javax.annotation.Resource; - /** * SpringBoot方式启动类 * @@ -20,27 +13,13 @@ * @Date 2021/06/06 12:06 */ @Slf4j -@EnableAsync -@EnableCaching @EnableTransactionManagement(proxyTargetClass = true) @EnableScheduling @SpringBootApplication -public class CasicApplication implements CommandLineRunner { - - @Resource - private BootNettyServer bootNettyServer; +public class CasicApplication { public static void main(String[] args) { SpringApplication.run(CasicApplication.class, args); log.info("CasicApplication is success!"); } - - @Async - @Override - public void run(String... args) { - /** - * 使用异步注解方式启动netty服务端服务 - */ - bootNettyServer.bind(); - } }