失敗失敗的承諾，因爲它已經完成：

我是很新，Netty中，我試圖建立一個異步HTTP客戶端POST和GET請求。然而，粘貼下面的代碼工作在重負荷下我偶爾會出現以下錯誤：失敗失敗的承諾，因爲它已經完成：

[18:49:56] [nioEventLoopGroup-2-1/WARN]: Failed to fail the promise because it's done already: [email protected](failure(io.netty.util.IllegalReferenceCountException: refCnt: 0) 
io.netty.util.IllegalReferenceCountException: refCnt: 0, decrement: 1 
     at io.netty.buffer.AbstractReferenceCountedByteBuf.release(AbstractReferenceCountedByteBuf.java:101) ~[server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.buffer.AbstractDerivedByteBuf.release(AbstractDerivedByteBuf.java:50) ~[server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.buffer.CompositeByteBuf$Component.freeIfNecessary(CompositeByteBuf.java:1335) ~[server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.buffer.CompositeByteBuf.deallocate(CompositeByteBuf.java:1590) ~[server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.buffer.AbstractReferenceCountedByteBuf.release(AbstractReferenceCountedByteBuf.java:106) ~[server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.buffer.AbstractDerivedByteBuf.release(AbstractDerivedByteBuf.java:50) ~[server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.buffer.CompositeByteBuf$Component.freeIfNecessary(CompositeByteBuf.java:1335) ~[server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.buffer.CompositeByteBuf.deallocate(CompositeByteBuf.java:1590) ~[server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.buffer.AbstractReferenceCountedByteBuf.release(AbstractReferenceCountedByteBuf.java:106) ~[server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.buffer.AbstractDerivedByteBuf.release(AbstractDerivedByteBuf.java:50) ~[server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.buffer.CompositeByteBuf$Component.freeIfNecessary(CompositeByteBuf.java:1335) ~[server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.buffer.CompositeByteBuf.deallocate(CompositeByteBuf.java:1590) ~[server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.buffer.AbstractReferenceCountedByteBuf.release(AbstractReferenceCountedByteBuf.java:106) ~[server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.buffer.AbstractDerivedByteBuf.release(AbstractDerivedByteBuf.java:50) ~[server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.buffer.CompositeByteBuf$Component.freeIfNecessary(CompositeByteBuf.java:1335) ~[server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.buffer.CompositeByteBuf.deallocate(CompositeByteBuf.java:1590) ~[server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.buffer.AbstractReferenceCountedByteBuf.release(AbstractReferenceCountedByteBuf.java:106) ~[server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.buffer.AbstractDerivedByteBuf.release(AbstractDerivedByteBuf.java:50) ~[server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.buffer.CompositeByteBuf$Component.freeIfNecessary(CompositeByteBuf.java:1335) ~[server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.buffer.CompositeByteBuf.deallocate(CompositeByteBuf.java:1590) ~[server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.buffer.AbstractReferenceCountedByteBuf.release(AbstractReferenceCountedByteBuf.java:106) ~[server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.buffer.AbstractDerivedByteBuf.release(AbstractDerivedByteBuf.java:50) ~[server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.buffer.CompositeByteBuf$Component.freeIfNecessary(CompositeByteBuf.java:1335) ~[server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.buffer.CompositeByteBuf.deallocate(CompositeByteBuf.java:1590) ~[server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.buffer.AbstractReferenceCountedByteBuf.release(AbstractReferenceCountedByteBuf.java:106) ~[server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.buffer.AbstractDerivedByteBuf.release(AbstractDerivedByteBuf.java:50) ~[server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.buffer.CompositeByteBuf$Component.freeIfNecessary(CompositeByteBuf.java:1335) ~[server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.buffer.CompositeByteBuf.deallocate(CompositeByteBuf.java:1590) ~[server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.buffer.AbstractReferenceCountedByteBuf.release(AbstractReferenceCountedByteBuf.java:106) ~[server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.buffer.AbstractDerivedByteBuf.release(AbstractDerivedByteBuf.java:50) ~[server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.buffer.CompositeByteBuf$Component.freeIfNecessary(CompositeByteBuf.java:1335) ~[server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.buffer.CompositeByteBuf.deallocate(CompositeByteBuf.java:1590) ~[server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.buffer.AbstractReferenceCountedByteBuf.release(AbstractReferenceCountedByteBuf.java:106) ~[server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.buffer.AbstractDerivedByteBuf.release(AbstractDerivedByteBuf.java:50) ~[server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.buffer.CompositeByteBuf$Component.freeIfNecessary(CompositeByteBuf.java:1335) ~[server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.buffer.CompositeByteBuf.deallocate(CompositeByteBuf.java:1590) ~[server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.buffer.AbstractReferenceCountedByteBuf.release(AbstractReferenceCountedByteBuf.java:106) ~[server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.buffer.AbstractDerivedByteBuf.release(AbstractDerivedByteBuf.java:50) ~[server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.buffer.CompositeByteBuf$Component.freeIfNecessary(CompositeByteBuf.java:1335) ~[server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.buffer.CompositeByteBuf.deallocate(CompositeByteBuf.java:1590) ~[server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.buffer.AbstractReferenceCountedByteBuf.release(AbstractReferenceCountedByteBuf.java:106) ~[server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.buffer.AbstractDerivedByteBuf.release(AbstractDerivedByteBuf.java:50) ~[server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.buffer.CompositeByteBuf$Component.freeIfNecessary(CompositeByteBuf.java:1335) ~[server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.buffer.CompositeByteBuf.deallocate(CompositeByteBuf.java:1590) ~[server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.buffer.AbstractReferenceCountedByteBuf.release(AbstractReferenceCountedByteBuf.java:106) ~[server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.util.ReferenceCountUtil.release(ReferenceCountUtil.java:59) ~[server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.channel.AbstractChannel$AbstractUnsafe.write(AbstractChannel.java:661) ~[server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.channel.DefaultChannelPipeline$HeadContext.write(DefaultChannelPipeline.java:1054) ~[server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.channel.AbstractChannelHandlerContext.invokeWrite(AbstractChannelHandlerContext.java:658) [server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:716) [server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:651) [server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.handler.codec.MessageToMessageEncoder.write(MessageToMessageEncoder.java:125) [server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.channel.CombinedChannelDuplexHandler.write(CombinedChannelDuplexHandler.java:192) [server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.channel.AbstractChannelHandlerContext.invokeWrite(AbstractChannelHandlerContext.java:658) [server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:716) [server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:651) [server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:637) [server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.handler.stream.ChunkedWriteHandler.doFlush(ChunkedWriteHandler.java:258) [server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.handler.stream.ChunkedWriteHandler.flush(ChunkedWriteHandler.java:141) [server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:688) [server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:669) [server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.channel.DefaultChannelPipeline.flush(DefaultChannelPipeline.java:838) [server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.channel.AbstractChannel.flush(AbstractChannel.java:188) [server.jar:git-Spigot-f928e7a-e91aed8] 
     at com.werter03886.wtlevelcommand.HttpClient$2.operationComplete(HttpClient.java:120) [WTLevelCommand-1.1.2.jar:?] 
     at com.werter03886.wtlevelcommand.HttpClient$2.operationComplete(HttpClient.java:90) [WTLevelCommand-1.1.2.jar:?] 
     at io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:680) [server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.util.concurrent.DefaultPromise.notifyListeners0(DefaultPromise.java:603) [server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:563) [server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:406) [server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.channel.DefaultChannelPromise.trySuccess(DefaultChannelPromise.java:82) [server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.fulfillConnectPromise(AbstractNioChannel.java:253) [server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:288) [server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:528) [server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:468) [server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:382) [server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:354) [server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116) [server.jar:git-Spigot-f928e7a-e91aed8] 
     at io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:137) [server.jar:git-Spigot-f928e7a-e91aed8] 
     at java.lang.Thread.run(Thread.java:745) [?:1.8.0_31]

這些都是我的網狀處理：

ChannelInitializer

public class HttpInitalizer extends ChannelInitializer<Channel> { 

    private final Callback<String> callback; 

    public HttpInitalizer(Callback<String> callback) { 

     this.callback = callback; 
    } 

    @Override 
    protected void initChannel(Channel ch) throws Exception { 

     ch.pipeline().addLast("codec", new HttpClientCodec()); 
     ch.pipeline().addLast("inflater", new HttpContentDecompressor()); 
     ch.pipeline().addLast("chunkedWriter", new ChunkedWriteHandler()); 
     ch.pipeline().addLast("handler", new HttpHandler(callback)); 
    } 
}

SimpleChannelInboundHandler

@Sharable 
public class HttpHandler extends SimpleChannelInboundHandler<HttpObject> { 

     private final Callback<String> callback; 
     private final StringBuilder buffer = new StringBuilder(); 

     public HttpHandler (Callback<String> callback) { 

       this.callback = callback; 
     } 

     @Override 
     public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception { 

       try { 

         callback.done(null, cause); 
       } 
       catch(Exception ex) { 

         ex.printStackTrace(); 
       } 
       finally { 

         ctx.channel().close(); 
       } 
     } 

     protected void channelRead0(ChannelHandlerContext ctx, HttpObject msg) throws Exception { 

       if (msg instanceof HttpResponse) { 

         HttpResponse response = (HttpResponse) msg; 
         int responseCode = response.getStatus().code(); 

         if (responseCode == HttpResponseStatus.NO_CONTENT.code()) { 

           done(ctx); 
           return; 
         } 

         if (responseCode != HttpResponseStatus.OK.code()) { 

           throw new IllegalStateException("Expected HTTP response 200 OK, got " + response.getStatus()); 
         } 
       } 

       if (msg instanceof HttpContent) { 

         HttpContent content = (HttpContent) msg; 
         buffer.append(content.content().toString(CharsetUtil.UTF_8)); 

         if (msg instanceof LastHttpContent) { 

           done(ctx); 
         } 
       } 
     } 

     private void done(ChannelHandlerContext ctx) { 

       try { 

         callback.done(buffer.toString(), null); 
       } 
       catch(Exception ex) { 

         ex.printStackTrace(); 
       } 
       finally { 

         ctx.channel().close(); 
       } 
     } 
}

HttpClient的

public final class HttpClient { 
     public static final int TIMEOUT = 500000; 
     private static EventLoopGroup group; 

     public HttpClient() { 

       group = new NioEventLoopGroup(); 
     } 

     public static void get (String url, final Callback<String> callback) { 

       final URI uri = URI.create(url); 

       InetAddress inetHost = null; 

       try { 

         inetHost = InetAddress.getByName(uri.getHost()); 
       } 
       catch (UnknownHostException e) { 

         e.printStackTrace(); 
       } 

       int port = 80; 

       ChannelFutureListener future = new ChannelFutureListener() { 

         public void operationComplete(ChannelFuture future) throws Exception { 

           if (future.isSuccess()) { 

             String path = uri.getRawPath() + ((uri.getRawQuery() == null) ? "" : "?" + uri.getRawQuery()); 
        HttpRequest request = new DefaultHttpRequest(HttpVersion.HTTP_1_1, HttpMethod.GET, path); 
        request.headers().set(HttpHeaders.Names.HOST, uri.getHost());     
        future.channel().writeAndFlush(request); 

           } else { 

             callback.done(null, future.cause()); 
           } 
         } 
       }; 

       new Bootstrap().channel(NioSocketChannel.class).group(group).handler(new HttpInitalizer(callback)). 
       option(ChannelOption.CONNECT_TIMEOUT_MILLIS, TIMEOUT).remoteAddress(inetHost, port).connect().addListener(future); 
     } 

     public static void post (String url, final Map<String, Object> params, final Callback<String> callback) { 

       final URI uri = URI.create(url); 

       InetAddress inetHost = null; 

       try { 

         inetHost = InetAddress.getByName(uri.getHost()); 
       } 
       catch (UnknownHostException e) { 

         e.printStackTrace(); 
       } 
       int port = 80; 

       ChannelFutureListener future = new ChannelFutureListener() { 

         public void operationComplete(ChannelFuture future) throws Exception { 

           if (future.isSuccess()) { 

             String path = uri.getRawPath() + ((uri.getRawQuery() == null) ? "" : "?" + uri.getRawQuery()); 
        HttpRequest request = new DefaultHttpRequest(HttpVersion.HTTP_1_1, HttpMethod.POST, path); 
        HttpPostRequestEncoder bodyRequestEncoder = new HttpPostRequestEncoder(request, false); 

        for(Entry<String, Object> es : params.entrySet()) { 

         bodyRequestEncoder.addBodyAttribute(es.getKey(), es.getValue().toString()); 
        } 

        request = bodyRequestEncoder.finalizeRequest(); 
        request.headers().set(HttpHeaders.Names.HOST, uri.getHost());  
        request.headers().set(HttpHeaders.Names.CONNECTION, HttpHeaders.Values.KEEP_ALIVE); 
        request.headers().set(HttpHeaders.Names.ACCEPT_ENCODING, HttpHeaders.Values.GZIP); 
        request.headers().set(HttpHeaders.Names.CONTENT_TYPE, "application/x-www-form-urlencoded"); 

        future.channel().write(request); 

        if (bodyRequestEncoder.isChunked()) { 

         future.channel().write(bodyRequestEncoder); 
        } 

        future.channel().flush(); 

        bodyRequestEncoder.cleanFiles(); 
        future.channel().closeFuture(); 
           } 
           else { 

             callback.done(null, future.cause()); 
           } 
         } 
       }; 

       new Bootstrap().channel(NioSocketChannel.class).group(group).handler(new HttpInitalizer(callback)). 
       option(ChannelOption.CONNECT_TIMEOUT_MILLIS, TIMEOUT).remoteAddress(inetHost, port).connect().addListener(future); 
     } 
}

如果任何人都可以點我在正確的方向它會不勝感激！

預先感謝您

來源

2015-11-11 Danny Bisby

把你的代碼和錯誤放在問題本身。除了讓潛在的回答者做更多的工作，如果鏈接的頁面消失了，那麼問題就沒有用了。 – blm

Woops！對不起，我的第一個問題 - 謝謝@blm –

我得到了這個問題，當我用NioSocketChannel網絡程序。我從ChannelHandler接口實現了handlder，沒有使用ChannelHandlerAdapter作爲父類來擴展。默認方法我沒有實現，也沒有使用super方法。所以程序運行時會出現異常，因爲IDE的幫助，這是一個愚蠢的錯誤。

來源

2016-08-12 15:12:09

失敗失敗的承諾，因爲它已經完成：

回答

相關問題