0

組み込み機能を使用して、Netty に HTTP サーバーを実装しました。現在、ページの一部のみを受信できる範囲ヘッダーのサポートを実装しました。私がnettyで行うことは次のとおりです。

final RandomAccessFile raf = new RandomAccessFile( file, "r" );
raf.seek( ranges[ 0 ] );

HttpResponse response = new DefaultHttpResponse( HttpVersion.HTTP_1_1, HttpResponseStatus.PARTIAL_CONTENT );
// MUST include accept-ranges!!
response.setHeader( HttpHeaders.Names.ACCEPT_RANGES, "bytes" );
// MUST include content-range
response.setHeader( HttpHeaders.Names.CONTENT_RANGE , "bytes " + ranges[ 0 ] + "-" + ranges[ 1 ] + "/" + file.length() );

if ( null != mime )
  response.addHeader( HttpHeaders.Names.CONTENT_TYPE, mime.substring( 0, mime.indexOf(' ') ) );
response.setHeader( HttpHeaders.Names.CONTENT_LENGTH, "" + ( ( ranges[ 1 ] - ranges[ 0 ] ) + 1 ) );

event.getChannel().write( response );

event.getChannel().write( new ChunkedInput() {
   private boolean endOfStream = false;
   private byte[] buffer = new byte[ 4096 ];
   private long bytesRead = ranges[ 0 ];

   @Override
   public boolean hasNextChunk() throws Exception {
     return !this.endOfStream;
   }

   @Override
   public Object nextChunk() throws Exception {
     if ( false == this.endOfStream ) {
       int read = raf.read( this.buffer );
       if ( read == -1 || this.bytesRead >= ranges[ 1 ] ) {
         this.endOfStream = true;
         return new DefaultHttpChunk( ChannelBuffers.EMPTY_BUFFER ); // send isLast 
       }

       if ( this.bytesRead + read > ranges[ 1 ] ) {
         read = ( int ) ( ranges[ 1 ] - this.bytesRead ) + 1;
         this.bytesRead = ranges[ 1 ]; // next iteration will send last chunk
       }

       this.bytesRead += read;

       return new DefaultHttpChunk( ChannelBuffers.copiedBuffer( this.buffer, 0, read ) );
     }

    return null;
  }

  @Override
  public boolean isEndOfInput() throws Exception {
    return this.endOfStream;
  }

  @Override
  public void close() throws Exception {
    raf.close();
  }
} ).addListener( ChannelFutureListener.CLOSE );

問題は、 ChannelFutureListener.CLOSE が呼び出されないことです。リスナーの独自の実装も試しましたが、呼び出されません。ChunkedInput-Implementation が問題だとは思いません。サーバーのさまざまな部分で同じ原則を使用しています。ストリームが終了すると ChannelBuffers.EMPTY_BUFFER が返され、netty から close が呼び出されるため、ストリームは確実に終了します。close メソッドで raf.close の後に channel.close() を実行することで問題を回避できましたが、このハックでは満足できません。私は何を間違っていますか？

4

1 に答える 1

0

isEndOfInput() が true を返すと、FutureListener に通知されます。したがって、この場合に isEndOfInput() が真になるかどうかをデバッグする必要があると思います。

于 2012-05-03T06:35:48.090 に答える