|
|
|
@ -25,14 +25,14 @@ import io.netty.handler.logging.LoggingHandler;
|
|
|
|
|
public class SocketServer { |
|
|
|
|
private Logger logger = LoggerFactory.getLogger(getClass()); |
|
|
|
|
|
|
|
|
|
@Value("${netty.socket.port}") |
|
|
|
|
private int port; |
|
|
|
|
|
|
|
|
|
@Value("${netty.socket.thread.boss}") |
|
|
|
|
private int threadBoss; |
|
|
|
|
|
|
|
|
|
@Value("${netty.socket.thread.worker}") |
|
|
|
|
private int threadWorker; |
|
|
|
|
// @Value("${netty.socket.port}")
|
|
|
|
|
// private int port;
|
|
|
|
|
//
|
|
|
|
|
// @Value("${netty.socket.thread.boss}")
|
|
|
|
|
// private int threadBoss;
|
|
|
|
|
//
|
|
|
|
|
// @Value("${netty.socket.thread.worker}")
|
|
|
|
|
// private int threadWorker;
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
private Channel ch; |
|
|
|
@ -92,18 +92,18 @@ public class SocketServer {
|
|
|
|
|
private void connection() { |
|
|
|
|
//서버는 Listen상태로 기다려야하는데, 톰캣이 Timeout이 발생함
|
|
|
|
|
//이를 방지하기 위해 Thread로 처리한다.
|
|
|
|
|
new Thread(new Runnable() { |
|
|
|
|
@Override |
|
|
|
|
public void run() { |
|
|
|
|
try { |
|
|
|
|
ChannelFuture future = b.bind(port).sync(); |
|
|
|
|
future.channel().closeFuture().sync(); |
|
|
|
|
|
|
|
|
|
} catch (InterruptedException e) { |
|
|
|
|
logger.error("InterruptedException", e); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
}).start(); |
|
|
|
|
// new Thread(new Runnable() {
|
|
|
|
|
// @Override
|
|
|
|
|
// public void run() {
|
|
|
|
|
// try {
|
|
|
|
|
// ChannelFuture future = b.bind(port).sync();
|
|
|
|
|
// future.channel().closeFuture().sync();
|
|
|
|
|
//
|
|
|
|
|
// } catch (InterruptedException e) {
|
|
|
|
|
// logger.error("InterruptedException", e);
|
|
|
|
|
// }
|
|
|
|
|
// }
|
|
|
|
|
// }).start();
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|