자바 netty 데이터 저장

Question

안녕하세요.netty로 tcp 서버를 구축하고 있는데,tcp 클라이언트에서 받아온 데이터가 ChannelInboundHandlerAdapter 의 오버라이딩 한 channelRead() 메소드에서 db 저장처리하는 로직을 구현하고 싶은데.자꾸 서비스 객체를 선언하면, 널포인트 익셉션이 발생합니다.netty에서는 db에 저장이 불가능한건가요?

Dierslair · Accepted Answer

&#64;Component public class TcpSocketServer { &#64;Autowired private SocketInServerHandler socketInServerHandler; public void run() { .. ServerBootstrap bootstrap &#61; new ServerBootstrap() .group(.., ..) ... .childHandler(new ChannelInitializer<>() { &#64;Override protected void initChannel(Channel channel) throws Exception { channel.pipeline() .addLast(socketInServerHandler); // new 생성자 사용 x } }) .. } } &#64;Component &#64;ChannelHandler.Sharable // 모든 파이프라인에서 공통으로 사용하는 공유 객체(로컬 변수 사용 금지) public class SocketInServerHandler extends ChannelInboundHandlerAdapter { &#64;Autowired private TDAHSocketServerServiceImpl tDAHSocketServerServiceImpl; &#64;Override public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception { ... } }new 생성자를 사용하셨으니 주입이 되지 않지요

HJOW · Answer

아뇨.코드를 봐야 알 수 있지만 대개 개발자가 코딩을 잘못해 벌어진 일입니다.특히 netty 도 제법 오래됐고 나름 검증된 라이브러리고, 당연히 DB저장 가능합니다.애시당초 NullPointerException 자체가 개발자가 실수를 하지 않는 이상 어지간하면 발생하지 않습니다.

칵키 · Answer

public class TcpSocketServer {private int port; TcpSocketServer(int port) {this.port = port; }public void run() { EventLoopGroup boosGroup = new NioEventLoopGroup(); // 인자값으로 쓰레드 갯수 지정 가능하나 빈값으로 설정. EventLoopGroup workerGroup = new NioEventLoopGroup();// 서버 APP을 위한 부트스트랩// 네트가 작동할 때 기본적으로 설정해야 하는 클래스. 네티 소켓의 모드, 스레드, 이벤트 핸들러 설정. ServerBootstrap boot = new ServerBootstrap(); boot.group(boosGroup, workerGroup) .channel(NioServerSocketChannel.class) .handler(new LoggingHandler(LogLevel.DEBUG)) .childHandler(new ChannelInitializer() { @Overrideprotected void initChannel(Channel ch) throws Exception { ChannelPipeline pipeline = ch.pipeline(); pipeline .addLast(new SocketInServerHandler()); } }) .option(ChannelOption.SO_BACKLOG, 300) // 동시 접속자 값 .childOption(ChannelOption.SO_KEEPALIVE, true); ChannelFuture f;try { f = boot.bind(port).sync(); f.channel().closeFuture().sync(); } catch (InterruptedException e) { e.printStackTrace(); } }}@Sharable // 안전한 데이터 처리를 위한 어노테이션public class SocketInServerHandler extends ChannelInboundHandlerAdapter{ @Autowiredprivate TDAHSocketServerServiceImpl tDAHSocketServerServiceImpl;// 클라이언트에서 받은 데이터 처리// 데이터가 수신되었음을 알려주는 이벤트 @Overridepublic void channelRead(ChannelHandlerContext ctx, Object msg) { HashMap map = new HashMap<>();String readMessage = ((ByteBuf) msg).toString(Charset.forName("UTF8"));String dataType = readMessage.substring(0,4); map.put("readMessage", readMessage); ctx.write(msg);if(dataType.equals("TDAH")) { tDAHSocketServerServiceImpl.insertTDAHData(map); } }}@Servicepublic class TDAHSocketServerServiceImpl implements TDAHSocketServerService{ @Autowiredprivate TDAHSocketServerMapper tDAHSocketServerMapper;int resultCtn = 0;public int insertTDAHData(HashMap map) {try {String receivedData = map.get("readMessage").toString();System.out.println("------ TDAHSocketServerServiceImpl ------");System.out.println(receivedData);String msgNm = receivedData.substring(0,4); //메시지명String businessCd = receivedData.substring(4,11); //사업장코드String ChimneyCd = receivedData.substring(11,14); //굴뚞코드String dataLength = receivedData.substring(14,16); //길이String measurementTime = receivedData.substring(16,26); //측정시간String dataGubun = receivedData.substring(26,29); //자료구분int itemCnt = Integer.parseInt(receivedData.substring(29,30)); //항목수String facilityCd = ""; //시설코드String itemCd = ""; //항목코드float measurementData = 0; //측정값String dataState = ""; //자료상태String operateState = ""; //가동상태String preventYN = ""; //방지시설정상여부 map.put("businessCd" , businessCd ); map.put("ChimneyCd" , ChimneyCd ); map.put("dataLength" , dataLength ); map.put("measurementTime" , measurementTime ); map.put("dataGubun" , dataGubun ); map.put("itemCnt" , itemCnt ); map.put("facilityCd" , facilityCd ); map.put("itemCd" , itemCd ); map.put("measurementData" , measurementData ); map.put("dataState" , dataState ); map.put("operateState" , operateState ); map.put("preventYN" , preventYN ); resultCtn = tDAHSocketServerMapper.insertTDAHData(map); } catch (Exception e) { e.printStackTrace(); }return 0; }}@Mapperpublic interface TDAHSocketServerMapper {public int insertTDAHData(HashMap map) throws Exception;}코드는 위와 같습니다..근데 자꾸 널포인트 에러가 떨어지고 의존성 주입이 안되네요 ㅜ

칵키 · Answer

new 객체를 생성하지 않고 위에 선언해서 로직을 태워도 에러가 발생합니다ㅜㅜ @Controllerpublic class TcpSocketController {@PostConstructprivate void start() {new Thread(new Runnable() {@Overridepublic void run() {try {new TcpSocketServer(5010).run();}catch (Exception e) {e.printStackTrace();}}}).start();}@PreDestroy // 소켓 종료전 처리할 로직private void destory() {}}이게 서버 시작할때 최초로 타는 부분인데... 서버 올리면 클라이언트에서 연결은 되는데 데이터를 수신한 서버가 제대로 데이터를 콘솔에 못찎어주세요 ㅠㅠ 왜이런걸까요 ㅠㅠ

자바 netty 데이터 저장

4개의 답변

기술 목록