Jersey 客户端上传进度

我有一个球衣客户端，需要上传一个足够大的文件以需要进度条。
问题是，对于需要几分钟的上传，我看到传输的字节数达到 100%申请一开始。然后需要几分钟时间来打印“on finish”字符串。
就好像字节被发送到缓冲区，我正在读取传输到缓冲区的速度而不是实际的上传速度。这使得进度条毫无用处。

这是非常简单的代码：

ClientConfig config = new DefaultClientConfig();
Client client = Client.create(config);
WebResource resource = client.resource("www.myrestserver.com/uploads");
WebResource.Builder builder = resource.type(MediaType.MULTIPART_FORM_DATA_TYPE);

FormDataMultiPart multiPart = new FormDataMultiPart();
FileDataBodyPart fdbp = new FileDataBodyPart("data.zip", new File("data.zip"));
BodyPart bp = multiPart.bodyPart(fdbp);
String response = builder.post(String.class, multiPart);

为了获取进度状态，我在调用 builder.post 之前添加了一个 ContainerListener 过滤器：

final ContainerListener containerListener = new ContainerListener() {

        @Override
        public void onSent(long delta, long bytes) {
            System.out.println(delta + " : " + long);
        }

        @Override
        public void onFinish() {
            super.onFinish();
            System.out.println("on finish");
        }

    };

    OnStartConnectionListener connectionListenerFactory = new OnStartConnectionListener() {
        @Override
        public ContainerListener onStart(ClientRequest cr) {
            return containerListener;
        }

    };

    resource.addFilter(new ConnectionListenerFilter(connectionListenerFactory));

在 Jersey 2.X 中，我使用了作家拦截器使用 Apache Commons IO CountingOutputStream 的子类包装输出流，该子类跟踪写入并通知我的上传进度代码（未显示）。

public class UploadMonitorInterceptor implements WriterInterceptor {

    @Override
    public void aroundWriteTo(WriterInterceptorContext context) throws IOException, WebApplicationException {

        // the original outputstream jersey writes with
        final OutputStream os = context.getOutputStream();

        // you can use Jersey's target/builder properties or 
        // special headers to set identifiers of the source of the stream
        // and other info needed for progress monitoring
        String id = (String) context.getProperty("id");
        long fileSize = (long) context.getProperty("fileSize");

        // subclass of counting stream which will notify my progress
        // indicators.
        context.setOutputStream(new MyCountingOutputStream(os, id, fileSize));

        // proceed with any other interceptors
        context.proceed();
    }

}

然后，我向客户端或您想要使用拦截器的特定目标注册了该拦截器。