카테고리 없음
spring과 netty
머룽
2023. 4. 19. 09:55
이번엔 spring을 이용해서 netty의 서버를 만들어보자
내용은 비슷하다.
기존에 했던거와 비슷하다. 스프링의 설정만 사용했다.
main부터 보자
public static void main(String[] args) {
try(AnnotationConfigApplicationContext context = new AnnotationConfigApplicationContext(SpringConfig.class)){
context.registerShutdownHook();
NettyServer nettyServer = context.getBean(NettyServer.class);
nettyServer.start();
}
}
@Configuration
@ComponentScan("me.wonwoo.spring")
@PropertySource("classpath:server.properties")
@Getter
public class SpringConfig {
@Value("${tcp.port}")
private int port;
@Bean
public InetSocketAddress tcpPort() {
return new InetSocketAddress(port);
}
@Bean
public static PropertySourcesPlaceholderConfigurer propertySourcesPlaceholderConfigurer() {
return new PropertySourcesPlaceholderConfigurer();
}
}
@Component
public class NettyServer {
@Value("${boss.thread.count}")
private int bossCount;
@Value("${worker.thread.count}")
private int workerCount;
@Autowired
private InetSocketAddress port;
private static final ServiceHandler SERVICE_HANDLER = new ServiceHandler();
public void start() {
EventLoopGroup bossGroup = new NioEventLoopGroup(bossCount);
EventLoopGroup workerGroup = new NioEventLoopGroup(workerCount);
try {
ServerBootstrap b = new ServerBootstrap();
b.group(bossGroup, workerGroup)
.channel(NioServerSocketChannel.class)
.childHandler(new ChannelInitializer<SocketChannel>() {
@Override
protected void initChannel(SocketChannel ch) throws Exception {
ChannelPipeline pipeline = ch.pipeline();
pipeline.addLast(SERVICE_HANDLER);
}
});
ChannelFuture channelFuture = b.bind(port).sync();
channelFuture.channel().closeFuture().sync();
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
bossGroup.shutdownGracefully();
workerGroup.shutdownGracefully();
}
}
}
@ChannelHandler.Sharable
public class ServiceHandler extends ChannelInboundHandlerAdapter {
Logger logger = LoggerFactory.getLogger(this.getClass());
private final ChannelGroup channels = new DefaultChannelGroup(GlobalEventExecutor.INSTANCE);
@Override
public void channelActive(ChannelHandlerContext ctx) throws Exception {
channels.add(ctx.channel());
}
@Override
public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
ByteBuf byteBuf = (ByteBuf) msg;
logger.debug("message : {} ",byteBuf.toString(Charset.defaultCharset()));
channels.writeAndFlush(msg);
}
}