如题:当使用springBoot的ApplicationRunner初始化时启动使用netty做的udp两个端口的服务,解决执行完第一个服务之后,后面所有的方法都不执行的问题
-
首先看一下我改动之前的代码,我写了两个服务器,说白了就是开启两个不同的端口,来监听不同客户端发来的数据 -
之后写一个springBoot启动类,我这里实现的是ApplicationRunner,端口8822和8833都有里面有打印输入,然后我们启动项目 -
可以看到只执行了第一个8822端口的服务,下面所有的方法都没有执行,当然如果你只是启动一个服务,那只需要把启动服务的start()方法放到最下面执行也是可以的(原因是:我们在启动netty时会执行channelFuture.channel().closeFuture().sync(),Netty 会进入无限循环之中,阻塞了主线程,将会不再加载和扫描之后的类了。有可能你还需要 mybatis、redis 等,可能就扫描不到了 ) 解决方法: -
采用异步方式使用线程池来启动服务 -
使用@Async 注解,对这个注解不熟悉的可以自行百度查阅,方法加上该注解可以使其异步执行,但有个问题就是使用该注解时如果不指定线程池的名称,则使用Spring默认的线程池,Spring默认的线程池为SimpleAsyncTaskExecutor。 它有一个缺陷那就是:并发情况下,会无限创建线程。。。 -
所以我们这边要自定义线程池的配置,代码如下:
@Configuration
public class SpringAsyncConfig {
@Bean("MyExecutor")
public Executor asyncServiceExecutor(){
ThreadPoolTaskExecutor threadPoolTaskExecutor = new ThreadPoolTaskExecutor();
threadPoolTaskExecutor.setCorePoolSize(10);
threadPoolTaskExecutor.setMaxPoolSize(100);
threadPoolTaskExecutor.setQueueCapacity(10);
threadPoolTaskExecutor.setWaitForTasksToCompleteOnShutdown(true);
threadPoolTaskExecutor.setAwaitTerminationSeconds(60);
threadPoolTaskExecutor.setThreadNamePrefix("MyAsync-");
threadPoolTaskExecutor.initialize();
return threadPoolTaskExecutor;
}
}
- 然后回到NettyUDPServer服务类种加上注解
@Async("MyExecutor") 括号里面指定刚刚上面定义的名称即可,加到方法上,如下图:
- 现在启动项目来看下执行结果是不是我们想要的:
ok!至此完成,成功解决项目启动时初始化netty开启两个服务其中一个无法启动的问题,如有问题欢迎支持。
|