네티 클라이언트 파라미터 받기

Question

&#64;RestControllerpublic class NettyController { &#64;Autowiredprivate NettyClient nettyClient; &#64;GetMapping(&#34;/reqPdat&#34;)public void reqPdat(&#64;RequestParam String chkInfo , String gubun) throws Exception{String strArr &#61; gubun;//클라이언트 시작 nettyClient.run(); }}&#64;Componentpublic class NettyClient {private static final Logger log &#61; LoggerFactory.getLogger(NettyClient.class);private static final String HOST &#61; &#34;192.168.0.6&#34;;private static final int SERVER_PORT &#61; 9090; &#64;Autowiredprivate NettyClientHandler nettyClientHandler;public void run() throws InterruptedException { EventLoopGroup group &#61; new NioEventLoopGroup();try { Bootstrap b &#61; new Bootstrap(); b.group(group); b.channel(NioSocketChannel.class); b.remoteAddress(new InetSocketAddress(HOST, SERVER_PORT)); b.handler(new ChannelInitializer<SocketChannel>() {protected void initChannel(SocketChannel ch) throws Exception { ch.pipeline().addLast(nettyClientHandler); } }); ChannelFuture f &#61; b.connect().sync(); //원격피어 연결 대기 f.channel().closeFuture().sync(); //채널이 닫힐떄까지 블로킹함. } finally { group.shutdownGracefully().sync(); //스레드 풀 종료 , 리소스 해제 } }}//핸들러&#64;Component&#64;ChannelHandler.Sharablepublic class NettyClientHandler extends ChannelInboundHandlerAdapter{private static final Logger log &#61; LoggerFactory.getLogger(NettyClientHandler.class); &#64;Overridepublic void channelRegistered(ChannelHandlerContext ctx) throws Exception { log.info(&#34;채널 등록&#34;); } &#64;Overridepublic void channelUnregistered(ChannelHandlerContext ctx) throws Exception {System.out.println(&#34;채널 연결이 종료됨.&#34;); } &#64;Overridepublic void channelActive(ChannelHandlerContext ctx) throws Exception { log.info(&#34;채널이 메시지 발송할 준비가 됨.&#34;); ByteBuf messageBuffer &#61; Unpooled.buffer(); messageBuffer.writeBytes(&#34;sendMessage&#34;.getBytes()); ctx.writeAndFlush(messageBuffer);System.out.println(&#34;send message {&#34; &#43; &#34;sendMessage&#34; &#43; &#34;}&#34;); } &#64;Overridepublic void channelRead(ChannelHandlerContext ctx, Object msg) { log.info(&#34;메시지를 받는 메소드.&#34;); ByteBuf buf &#61; (ByteBuf)msg;int n &#61; buf.readableBytes();if( n > 0 ) {byte[] b &#61; new byte[n]; buf.readBytes(b);//수신메시지 출력String receiveMsg &#61; new String( b ); log.info(&#34;수신된 메시지 >&#34; &#43; receiveMsg);//보낼 메시지가 없으면 연결 종료// ifmsgArr.equals(&#34;&#34;) || msgArr &#61;&#61; null) {// channelClose(ctx);// }else {// sendMsg(ctx, this.idx);// } } } &#64;Overridepublic void channelReadComplete(ChannelHandlerContext ctx) { log.info(&#34;메시지를 받는 동작이 끝나면 동작하는 메소드.&#34;); }private void sendMsg(ChannelHandlerContext ctx, int i) {//String msg &#61; _msgArr; ByteBuf messageBuffer &#61; Unpooled.buffer();//messageBuffer.writeBytes(msg.getBytes()); ctx.writeAndFlush( messageBuffer ); //메시지를 발송하고 flush처리System.out.println(&#34;[sendMsg]:&#34; &#43; messageBuffer);//log.info(&#34;발송 메시지 >&#34; &#43; msg); }private void channelClose(ChannelHandlerContext ctx) { log.error(&#34;채널 연결 종료&#34;); ctx.close(); }}컨트롤러에서 넘겨받은 데이터를 네티쪽에 파라미터 어떻게 넘겨줄 수 있을까요?

네티 클라이언트 파라미터 받기

0개의 답변

기술 목록