@Download(source = "classpath:/download/README.txt")
@GetMapping("/classpath")
public void classpath() {
}
@Download
@GetMapping("/file")
public File file() {
    return new File("/Users/Shared/README.txt");
}
@Download
@GetMapping("/http")
public String http() {
    return "http://127.0.0.1:8080/concept-download/image.jpg";
}

@Download(filename = "二維碼.zip")
@GetMapping("/download")
public List<Device> download() {
    return deviceService.all();
}
public class Device {
    //設(shè)備名稱
    private String name;
    //設(shè)備二維碼
    //注解表示該http地址是需要下載的數(shù)據(jù)
    @SourceObject
    private String qrCodeUrl;
    //注解表示文件名稱
    @SourceName
    public String getQrCodeName() {
        return name + ".png";
    }
    //省略其他屬性方法
}

@Download(source = "classpath:/download/README.txt")
@GetMapping("/classpath")
public void classpath(ServerHttpResponse response) {
}

/**
 * 用于設(shè)置當(dāng)前的請(qǐng)求和響應(yīng)。
 *
 * @see ReactiveDownloadHolder
 */
public class ReactiveDownloadFilter implements WebFilter {
    @Override
    public Mono<Void> filter(ServerWebExchange exchange, WebFilterChain chain) {
        ServerHttpRequest request = exchange.getRequest();
        ServerHttpResponse response = exchange.getResponse();
        return chain.filter(exchange)
                //低版本使用subscriberContext
                .contextWrite(ctx -> ctx.put(ServerHttpRequest.class, request))
                .contextWrite(ctx -> ctx.put(ServerHttpResponse.class, response));
    }
}
/**
 * 用于獲得當(dāng)前的請(qǐng)求和響應(yīng)。
 *
 * @see ReactiveDownloadFilter
 */
public class ReactiveDownloadHolder {
    public static Mono<ServerHttpRequest> getRequest() {
        //低版本使用subscriberContext
        return Mono.deferContextual(contextView -> Mono.just(contextView.get(ServerHttpRequest.class)));
    }
    public static Mono<ServerHttpResponse> getResponse() {
        //低版本使用subscriberContext
        return Mono.deferContextual(contextView -> Mono.just(contextView.get(ServerHttpResponse.class)));
    }
}

/**
 * 下載處理器。
 */
public interface DownloadHandler extends OrderProvider {
    /**
     * 執(zhí)行處理。
     *
     * @param context {@link DownloadContext}
     * @param chain   {@link DownloadHandlerChain}
     */
    Mono<Void> handle(DownloadContext context, DownloadHandlerChain chain);
}
/**
 * 下載處理鏈。
 */
public interface DownloadHandlerChain {
    /**
     * 調(diào)度下一個(gè)下載處理器。
     *
     * @param context {@link DownloadContext}
     */
    Mono<Void> next(DownloadContext context);
}

/**
 * {@link Source} 工廠。
 */
public interface SourceFactory extends OrderProvider {
    /**
     * 是否支持需要下載的原始數(shù)據(jù)對(duì)象。
     *
     * @param source  需要下載的原始數(shù)據(jù)對(duì)象
     * @param context {@link DownloadContext}
     * @return 如果支持則返回 true
     */
    boolean support(Object source, DownloadContext context);
    /**
     * 創(chuàng)建。
     *
     * @param source  需要下載的原始數(shù)據(jù)對(duì)象
     * @param context {@link DownloadContext}
     * @return 創(chuàng)建的 {@link Source}
     */
    Source create(Object source, DownloadContext context);
}

@Download(filename = "二維碼.zip")
@GetMapping("/download")
public List<Device> download() {
    return deviceService.all();
}
public class Device {
    //設(shè)備名稱
    private String name;
    //設(shè)備二維碼
    //注解表示該http地址是需要下載的數(shù)據(jù)
    @SourceObject
    private String qrCodeUrl;
    //注解表示文件名稱
    @SourceName
    public String getQrCodeName() {
        return name + ".png";
    }
    //省略其他屬性方法
}

/**
 * {@link Source} 加載器。
 *
 * @see DefaultSourceLoader
 * @see SchedulerSourceLoader
 */
public interface SourceLoader {
    /**
     * 執(zhí)行加載。
     *
     * @param source  {@link Source}
     * @param context {@link DownloadContext}
     * @return 加載后的 {@link Source}
     */
    Mono<Source> load(Source source, DownloadContext context);
}

/**
 * {@link Source} 壓縮器。
 *
 * @see ZipSourceCompressor
 */
public interface SourceCompressor extends OrderProvider {
    /**
     * 獲得壓縮格式。
     *
     * @return 壓縮格式
     */
    String getFormat();
    /**
     * 判斷是否支持對(duì)應(yīng)的壓縮格式。
     *
     * @param format  壓縮格式
     * @param context {@link DownloadContext}
     * @return 如果支持則返回 true
     */
    default boolean support(String format, DownloadContext context) {
        return format.equalsIgnoreCase(getFormat());
    }
    /**
     * 如果支持對(duì)應(yīng)的格式就會(huì)調(diào)用該方法執(zhí)行壓縮。
     *
     * @param source  {@link Source}
     * @param writer  {@link DownloadWriter}
     * @param context {@link DownloadContext}
     * @return {@link Compression}
     */
    Compression compress(Source source, DownloadWriter writer, DownloadContext context);
}

//HttpServletResponse
response.getOutputStream().write(byte b[], int off, int len);
//ServerHttpResponse
response.writeWith(Publisher<? extends DataBuffer> body);

/**
 * 持有 {@link ServerHttpResponse} 的 {@link DownloadResponse}，用于 webflux。
 */
@Getter
public class ReactiveDownloadResponse implements DownloadResponse {
    private final ServerHttpResponse response;
    private OutputStream os;
    private Mono<Void> mono;
    public ReactiveDownloadResponse(ServerHttpResponse response) {
        this.response = response;
    }
    @Override
    public Mono<Void> write(Consumer<OutputStream> consumer) {
        if (os == null) {
            mono = response.writeWith(Flux.create(fluxSink -> {
                try {
                    os = new FluxSinkOutputStream(fluxSink, response);
                    consumer.accept(os);
                } catch (Throwable e) {
                    fluxSink.error(e);
                }
            }));
        } else {
            consumer.accept(os);
        }
        return mono;
    }
    @SneakyThrows
    @Override
    public void flush() {
        if (os != null) {
            os.flush();
        }
    }
    @AllArgsConstructor
    public static class FluxSinkOutputStream extends OutputStream {
        private FluxSink<DataBuffer> fluxSink;
        private ServerHttpResponse response;
        @Override
        public void write(byte[] b) throws IOException {
            writeSink(b);
        }
        @Override
        public void write(byte[] b, int off, int len) throws IOException {
            byte[] bytes = new byte[len];
            System.arraycopy(b, off, bytes, 0, len);
            writeSink(bytes);
        }
        @Override
        public void write(int b) throws IOException {
            writeSink((byte) b);
        }
        @Override
        public void flush() {
            fluxSink.complete();
        }
        public void writeSink(byte... bytes) {
            DataBuffer buffer = response.bufferFactory().wrap(bytes);
            fluxSink.next(buffer);
            //在這里可能有問(wèn)題，但是目前沒(méi)有沒(méi)有需要釋放的數(shù)據(jù)
            DataBufferUtils.release(buffer);
        }
    }
}

/**
 * 具體操作 {@link InputStream} 和 {@link OutputStream} 的寫入器。
 */
public interface DownloadWriter extends OrderProvider {
    /**
     * 該寫入器是否支持寫入。
     *
     * @param resource {@link Resource}
     * @param range    {@link Range}
     * @param context  {@link DownloadContext}
     * @return 如果支持則返回 true
     */
    boolean support(Resource resource, Range range, DownloadContext context);
    /**
     * 執(zhí)行寫入。
     *
     * @param is      {@link InputStream}
     * @param os      {@link OutputStream}
     * @param range   {@link Range}
     * @param charset {@link Charset}
     * @param length  總大小，可能為 null
     */
    default void write(InputStream is, OutputStream os, Range range, Charset charset, Long length) {
        write(is, os, range, charset, length, null);
    }
    /**
     * 執(zhí)行寫入。
     *
     * @param is       {@link InputStream}
     * @param os       {@link OutputStream}
     * @param range    {@link Range}
     * @param charset  {@link Charset}
     * @param length   總大小，可能為 null
     * @param callback 回調(diào)當(dāng)前進(jìn)度和增長(zhǎng)的大小
     */
    void write(InputStream is, OutputStream os, Range range, Charset charset, Long length, Callback callback);
    /**
     * 進(jìn)度回調(diào)。
     */
    interface Callback {
        /**
         * 回調(diào)進(jìn)度。
         *
         * @param current  當(dāng)前值
         * @param increase 增長(zhǎng)值
         */
        void onWrite(long current, long increase);
    }
}