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)”错误。
最佳答案
您间接将 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
)。
关于http - Kemal 使用处理程序中间件缓存响应,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/47121991/