如何在提供文件之前使用嵌入式 Jetty 转换文件？

Question

这是我用来从带有嵌入式 Jetty 的文件系统中提供静态文件的代码。

    String directory = "dir";
    final ContextHandler contextHandler = new ContextHandler();
    final ResourceHandler resourceHandler = new ResourceHandler();
    contextHandler.setContextPath("/" + directory);
    resourceHandler.setBaseResource(Resource.newResource(new File(directory,
                directory);
    contextHandler.setHandler(resourceHandler);

如何修改它以在提供文件之前对其进行转换？

我想继续使用 ResourceHandler 和 ContextHandler 以避免在这些类中重新实现有用的逻辑。

谢谢！

Answer 1

ResourceHandler 不支持在流中（即时）修改内容。

ResourceHandler 进行了优化，以尽可能高效的方式发送文件，通常使用内存映射文件缓冲区，将文件直接从磁盘提供给网络，然后在 Java 内存中不对文件进行缓冲区处理。

你有两个选择：

1. 在单独的步骤或过程中修改磁盘上的文件（不是即时）
2. 编写您自己的文件服务处理程序，可以即时修改文件。

您可以使用 Jetty git 存储库中的 FastFileServer example 作为选择 #2 的良好起点。

Answer 2

我找到了解决方案。 它是用这样的类包装你的代码传递给 ResourceHandler.setBaseResource() 的资源：

public class TransformingResource extends Resource {
    private Resource resource;

    protected TransformingResource(Resource resource) {
        this.resource = resource;   
    }

    @Override
    public boolean isContainedIn(Resource r) throws MalformedURLException {
        return resource.isContainedIn(r);
    }

    @Override
    public void close() {
        resource.close();
    }

    @Override
    public boolean exists() {
        return resource.exists();
    }

    @Override
    public boolean isDirectory() {
        return resource.isDirectory();
    }

    @Override
    public long lastModified() {
        return resource.lastModified();
    }

    @Override
    public long length() {
        transform();

        return transformed.length();
    }

    @Override
    public URL getURL() {
        return resource.getURL();
    }

    @Override
    public File getFile() throws IOException {
        return resource.getFile();
    }

    @Override
    public String getName() {
        return resource.getName();
    }

    private String transformed;

    private void transform() {
        if(transformed != null) {
            return;
        }

        transformed = transformInputStream(resource.getInputStream());
    }

    @Override
    public InputStream getInputStream() throws IOException {
        transform();

        return new ByteArrayInputStream(transformed.getBytes(Charset.forName("UTF-8")));
    }

    @Override
    public ReadableByteChannel getReadableByteChannel() throws IOException {
        return null;
    }

    @Override
    public boolean delete() throws SecurityException {
        return resource.delete();
    }

    @Override
    public boolean renameTo(Resource dest) throws SecurityException {
        return resource.renameTo(dest);
    }

    @Override
    public String[] list() {
        return resource.list();
    }

    @Override
    public Resource addPath(String path) throws IOException,
            MalformedURLException {
        Resource toReturn = resource.addPath(path);
        if(toReturn == null) {
            return null;
        }

        return new TransformingResource(toReturn);
    }
}