用於Java Netty服務器的高效channelRead

我正在使用netty開發代理服務器，並且我的代理ProxyBackendHandler類如下所示。在channelRead方法中，我需要獲取msg數據並以TextWebSocketFrame的形式寫入客戶端。爲此，我使用了一個StringBuilder和一個while循環來迭代ByteBuf。任何人都可以建議我一個更好的方法來做到這一點，因爲在高數據加載時，上面的代碼似乎具有較高的性能開銷。用於Java Netty服務器的高效channelRead

public class ProxyBackendHandler extends ChannelInboundHandlerAdapter { 

    private final Channel inboundChannel; 
    StringBuilder sReplyBuffer; 

    public ProxyBackendHandler(Channel inboundChannel) { 
     this.inboundChannel = inboundChannel; 
     sReplyBuffer = new StringBuilder(4000); 
    } 

    @Override 
    public void channelRead(final ChannelHandlerContext ctx, Object msg) { 

     // Please suggest a efficient implementation for read msg and pass it to writeAndFlush. 
     ByteBuf in = (ByteBuf) msg; 
     sReplyBuffer.setLength(0); 

     try { 
      while (in.isReadable()) { 
       sReplyBuffer.append((char) in.readByte()); 
      } 
     } finally { 
      ((ByteBuf) msg).release(); 
     } 

     inboundChannel.writeAndFlush(new TextWebSocketFrame (sReplyBuffer.toString())).addListener(new ChannelFutureListener() { 
      @Override 
      public void operationComplete(ChannelFuture future) { 
       if (future.isSuccess()) { 
        ctx.channel().read(); 
        System.out.println("Sent To Client"); 
       } else { 
        future.channel().close(); 
       } 
      } 
     }); 
    } 
}

來源

2015-11-02 user1308004

也許是這樣的：

public class ProxyBackendHandler extends ChannelInboundHandlerAdapter { 

    private final Channel inboundChannel; 

    public ProxyBackendHandler(Channel inboundChannel) { 
     this.inboundChannel = inboundChannel; 
    } 

    @Override 
    public void channelRead(final ChannelHandlerContext ctx, Object msg) { 
     inboundChannel.writeAndFlush(new TextWebSocketFrame((ByteBuf) msg)).addListener(new ChannelFutureListener() { 
      @Override 
      public void operationComplete(ChannelFuture future) { 
       if (future.isSuccess()) { 
        ctx.channel().read(); 
        System.out.println("Sent To Client"); 
       } else { 
        future.channel().close(); 
       } 
      } 
     }); 
    } 
}

來源

2015-11-03 08:28:32

我建議不要使用StringBuilder的所有

。只需使用你已有的緩衝區。你沒有說明TextWebSocketFrame可能是什麼，或者你爲什麼認爲你需要它，但最終代理服務器只需要複製字節。你不需要StringBuilder或額外的類。坦率地說，或者Netty。

來源

2015-11-03 08:34:37 EJP

用於Java Netty服務器的高效channelRead

回答

相關問題