Netty:ChannelProgressiveFutureListener未使用DefaultFileRegion调用

Question

我正在使用一个去福尔菲区域从我的基于网络的服务器进行下游访问。当客户端接收数据时，我添加到频道未来的频道进程接收器永远不会被调用。我在使用netty编程方面不是很有经验，所以我认为我误解了nettys渐进式频道未来的工作原理。因此，我在这里查看了我在这里找到的示例代码：programcreek.com.但它基本上是相同的代码？我试图在这里找到类似的问题，但找不到原因。提前感谢您的任何提示，为什么听众永远不会被叫到。

   long todo = file.length () - mRequest.pCursor;
    ctx.writeAndFlush (mFileCursorPacket.encodeInformation (new FileCursor (mRequest.pToken, todo)));


    mFileregion = new DefaultFileRegion (file, mRequest.pCursor, todo);
    ChannelFuture future = ctx.writeAndFlush (mFileregion,ctx.newProgressivePromise ());

    //the listener that is never called!
    future.addListener (new ChannelProgressiveFutureListener () {
        @Override
        public void operationProgressed (ChannelProgressiveFuture future, long progress, long total) throws Exception {
            O.debug (mSession.getId ()+": downloaded "+progress+" bytes  = "+String.valueOf ((float)progress/(float)total));
        }

        @Override
        public void operationComplete (ChannelProgressiveFuture future) throws Exception {
            boolean success = future.isSuccess ();
            O.info (mSession.getId () + ": downloaded successfull: " + success);
            if (mFileregion != null) mFileregion.release ();
            mFileregion = null;
        }
    });

我的管道看起来像这样：

        ServerBootstrap b = new ServerBootstrap (); // 
        b.group (mBossGroup, mWorkerGroup).channel (NioServerSocketChannel.class) // 
                //.channel(ServerSocketChannel.class)
                .childHandler (new ChannelInitializer<SocketChannel> () { // 
                    @Override
                    public void initChannel (SocketChannel ch) throws Exception {

                        ProtocolMessageInboundHandler inboundHandler = new ProtocolMessageInboundHandler ();
                        inboundHandler.setMessageSizeLimit (MAX_PACKET_LENGTH);
                        ch.pipeline ().addLast (ReadTimeoutHandler.class.getName (), new ReadTimeoutHandler (SO_TIMEOUT_STD));
                        ch.pipeline ().addLast (NAME_PROTOCOL_MESSAGE_INBOUND, inboundHandler);
                        ch.pipeline ().addLast (NAME_PROTOCOL_MESSAGE_OUTBOUND, new ProtoclMessageOutboundHandler ());

//context passed to the LoginHandler is a ServerContext and has nothing to do with netty
                        ch.pipeline ().addLast (LoginHandler.class.getName (), new LoginHandler (context));
                        ch.pipeline ().addLast (TimeoutHandler.class.getName (), new TimeoutHandler ());


                    }
                }).option (ChannelOption.SO_BACKLOG, 128).childOption (ChannelOption.SO_KEEPALIVE, true); // 

        // Bind and start to accept incoming connections.
        b.bind (PORT).sync ();

而文件发送处理程序被插入ProtocolMessageInboundHandler之后（它只修改byte[]对象并传递bytebuf对象）。因此，在文件发送处理程序和？之间没有其他处理程序？内蒂？

Answer 1

如果要发送FileRegion，则管道中应该有一个可以发送此类对象的处理程序。Netty中用于此目的的最常用类是ChunkedWriteHandler。DefaultFileRegion的示例中也使用了此选项。

将以下代码添加到您的初始值设定项中，使其支持< code>FileRegions:

ch.pipeline ().addLast(new ChunkedWriteHandler());