我正在使用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();
}
}
});
}
}