netty客户端读取文件内容内存溢出

highstar0617 发布于 2016/01/27 14:58
阅读 762
收藏 0

基于netty 4.0.14final

最近做一个存储转发项目,使用netty框架,客户端发送报文到服务器端,服务器端将报文入库,在客户端模拟报文时,采用读取txt文件的方式,每读取一行就发送到服务器端,小文件没什么问题,但读取200M左右的文件时,机器内存就无限飙升,直到死机,我的机器内存是4G的,按理说不会出现这种问题的啊,求大婶们解答新手疑惑。。公司开发机器不联网,不过我这个代码基本上和Netty权威指南上一样的:

//客户端

public class EchoClient {


    public void connect(int port, String host) throws Exception {
// 配置客户端NIO线程组
EventLoopGroup group = new NioEventLoopGroup();
try {
   Bootstrap b = new Bootstrap();
   b.group(group).channel(NioSocketChannel.class)
   .option(ChannelOption.TCP_NODELAY, true)
   .handler(new ChannelInitializer<SocketChannel>() {
@Override
public void initChannel(SocketChannel ch)
throws Exception {
   ByteBuf delimiter = Unpooled.copiedBuffer("$_"
   .getBytes());
   ch.pipeline().addLast(
   new DelimiterBasedFrameDecoder(1024,
   delimiter));
   ch.pipeline().addLast(new StringDecoder());
   ch.pipeline().addLast(new EchoClientHandler());
}
   });


   // 发起异步连接操作
   ChannelFuture f = b.connect(host, port).sync();


   // 当代客户端链路关闭
   f.channel().closeFuture().sync();
} finally {
   // 优雅退出,释放NIO线程组
   group.shutdownGracefully();
}
    }


    /**
     * @param args
     * @throws Exception
     */
    public static void main(String[] args) throws Exception {
int port = 8080;
if (args != null && args.length > 0) {
   try {
port = Integer.valueOf(args[0]);
   } catch (NumberFormatException e) {
// 采用默认值
   }
}
new EchoClient().connect(port, "127.0.0.1");
    }
}

//客户端业务处理Handler

public class EchoClientHandler extends ChannelHandlerAdapter {


   
     * Creates a client-side handler.
     */
    public EchoClientHandler() {
    }


    @Override
    public void channelActive(ChannelHandlerContext ctx) {
    String fileName="D:\\test.txt";

try{

File f=new File(fileName);

InputStreamReader in =new InputStreamReader(new FileInputStream(f),"utf8");

BufferedReader br=new BufferedReader(in);

String lintxt=null;

while((lintxt=br.readline())!=null){

byte[] req=(lintxt+"$_").getBytes();

ByteBuf mes=Unpooled.buffer(reqq.length);

mes.writeBytes(req);

ctx.writeAndFlush(mes);

}

br.close

}catch(Exception e){

e.printStackTrace();

}
    }


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

    }


    @Override
    public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {
ctx.flush();
    }


    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
cause.printStackTrace();
ctx.close();
    }
}

实在抱歉,刚来社区,不知道提问规则,排版也不好,请多多包涵


加载中
0
BISM
BISM
贴代码
h
highstar0617
我贴了代码,您可以帮我看看嘛
0
BISM
BISM

别用BufferedReader,还有最好是不要readline,直接读取到缓冲区发送出去

h
highstar0617
好的,我试试,谢谢您
返回顶部
顶部