我可以限制JSF/PrimeFaces中的下载/上传速度吗?

Question

我正在使用带有PrimeFaces的JSF，上传/下载组件非常适合我的项目。但是，由于该软件将部署在一些低带宽环境中，我只是想知道是否可以限制这些组件将使用的上传/下载速度？

感谢您的建议和最诚挚的问候帕斯卡

Answer 1

似乎没有开箱即用的方法。我最终编写了一个自己的"LimitedInputStream"实现。

有限输入流：

public class LimitedInputStream extends InputStream {
    public static InputStream create(ILimitedInputStreamPolicy policy, InputStream wrapped) {
        return new LimitedInputStream(policy, wrapped);
    }
    public static InputStream create(Logger log, InputStream wrapped) {
        final ILimitedInputStreamPolicy policy = BytesPerIntervalLimitedInputStreamPolicy.create(log);
        return new LimitedInputStream(policy, wrapped);
    }
    private final ILimitedInputStreamPolicy policy;
    private final InputStream wrapped;
    private LimitedInputStream(ILimitedInputStreamPolicy policy, InputStream wrapped) {
        this.policy = policy;
        this.wrapped = wrapped;
    }
    @Override
    public int available() throws IOException {
        return wrapped.available();
    }
    @Override
    public void close() throws IOException {
        wrapped.close();
    }
    @Override
    public boolean equals(Object obj) {
        return wrapped.equals(obj);
    }
    @Override
    public int hashCode() {
        return wrapped.hashCode();
    }
    @Override
    public void mark(int readlimit) {
        wrapped.mark(readlimit);
    }
    @Override
    public boolean markSupported() {
        return wrapped.markSupported();
    }
    @Override
    public int read() throws IOException {
        policy.waitForBytesToRead();
        final int result = wrapped.read();
        policy.bytesRead(1);
        return result;
    }
    @Override
    public int read(byte[] b, int off, int len) throws IOException {
        final long bytesLeft = policy.waitForBytesToRead();
        final int bytesToRead = Long.valueOf(Math.min(bytesLeft, len)).intValue();
        final int bytesRead = wrapped.read(b, off, bytesToRead);
        policy.bytesRead(bytesRead);
        return bytesRead;
    }
    @Override
    public void reset() throws IOException {
        wrapped.reset();
    }
    @Override
    public long skip(long n) throws IOException {
        return wrapped.skip(n);
    }
}

ILimitedInputStreamPolicy.java：

/**
 * Implementing class provide information about in which intervals how much data
 * may be read from a stream.
 */
public interface ILimitedInputStreamPolicy {
    /**
     * Indicates that the given number of bytes have been read in any atomic
     * action.
     * 
     * @param numberOfBytes
     *            The number of bytes read.
     */
    public void bytesRead(int numberOfBytes);
    /**
     * Pauses the current thread until the implemented policy allows for the
     * returned amount of bytes to read,
     * 
     * @return The number of bytes allowed to read.
     */
    public int waitForBytesToRead();
}