http - Kemal 使用处理程序中间件缓存响应

Question

Kemal 使用处理程序中间件缓存响应

我正在尝试使用 Kemal 缓存一些 GET 请求。

class CachingHandler < Kemal::Handler

    property cache : Hash(String, IO::Memory)

    def initialize
        @cache = Hash(String, IO::Memory).new
    end

    def call(context)
        puts "Caching"
        puts "Key: #{ context.request.resource }"
        if output = @cache[context.request.resource]?
            puts "Cache: true"
            IO.copy output, context.response.output
        else
            puts "Cache: false"
            puts "Cache: building"
            context.response.output          =
            @cache[context.request.resource] = IO::Memory.new
            # continue
            puts "Cache: continue"
            call_next context
        end
    end
end

但在第一个请求中，浏览器总是在等待响应。并在第二个请求中发送“Closed stream (IO::Error)”错误。

Answer 1

您间接将 context.response.output 设置为 IO::Memory.new。因此，下一个处理程序不会写入连接的输出流，而是写入内存 IO。

您需要将流数据复制到内存和 套接字。也许 IO::MultiWriter 可以提供帮助，例如 response.output = IO::MultiWriter.new(response.output, memory_io)。

此外，我建议不要存储 IO::Memory 实例，而是将它们的原始数据存储为 Bytes (io.to_slice) .一旦将其放入缓存中，就没有必要再使用 IO 了。您可以在命中缓存时直接将字节写入输出流 (response.write(bytes)。