Assets.at() 仅适用于在构建时添加到类路径的资产。
见:https://www.playframework.com/documentation/2.4.x/Assets
解决方案是将文件从磁盘读取为 byte[],然后在响应正文中返回 byte[]。
将图像转换为字节[](此解决方案仅适用于小文件,大文件查看流):
private static Promise<byte[]> toBytes(final File file) {
return Promise.promise(new Function0<byte[]>() {
@Override
public byte[] apply() throws Throwable {
byte[] buffer = new byte[1024];
ByteArrayOutputStream os = new ByteArrayOutputStream();
FileInputStream is = new FileInputStream(file);
for (int readNum; (readNum = is.read(buffer)) != -1;) {
os.write(buffer, 0, readNum);
}
return os.toByteArray();
}
});
}
使用 toBytes() 提供图像的控制器:
public static Promise<Result> img() {
//path is sent as JSON in request body
JsonNode path = request().body().asJson();
Logger.debug("path -> " + path.get("path").asText());
Path p = Paths.get(path.get("path").asText());
File file = new File(path.get("path").asText());
try {
response().setHeader("Content-Type", Files.probeContentType(p));
} catch (IOException e) {
Logger.error("BUMMER!", e);
return Promise.promise(new Function0<Result>() {
@Override
public Result apply() throws Throwable {
return badRequest();
}
});
}
return toBytes(file).map(new Function<byte[], Result>() {
@Override
public Result apply(byte[] bytes) throws Throwable {
return ok(bytes);
}
}).recover(new Function<Throwable, Result>() {
@Override
public Result apply(Throwable t) throws Throwable {
return badRequest(t.getMessage());
}
});
}
路线:
POST /img controllers.YourControllerName.img()
如果需要 ETag 支持:
(不添加 Date 或 Last-Modified 标头,因为如果使用 ETag 标头,则不需要它们):
获取文件的 SHA1:
private static Promise<String> toSHA1(final byte[] bytes) {
return Promise.promise(new Function0<String>() {
@Override
public String apply() throws Throwable {
MessageDigest digest = MessageDigest.getInstance("SHA-1");
byte[] digestResult = digest.digest(bytes);
String hexResult = "";
for (int i = 0; i < digestResult.length; i++) {
hexResult += Integer.toString(( bytes[i] & 0xff ) + 0x100, 16).substring(1);
}
return hexResult;
}
});
}
设置 ETag 标头:
private static boolean setETagHeaders(String etag, String mime) {
response().setHeader("Cache-Control", "no-cache");
response().setHeader("ETag", "\"" + etag + "\"");
boolean ifNoneMatch = false;
if (request().hasHeader(IF_NONE_MATCH)) {
String header = request().getHeader(IF_NONE_MATCH);
//removing ""
if (!etag.equals(header.substring(1, header.length() - 1))) {
response().setHeader(CONTENT_TYPE, mime);
}
ifNoneMatch = true;
} else {
response().setHeader(CONTENT_TYPE, mime);
}
return ifNoneMatch;
}
支持 ETag 的控制器:
public static Promise<Result> img() {
//path is sent as JSON in request body
JsonNode path = request().body().asJson();
Logger.debug("path -> " + path.get("path").asText());
Path p = Paths.get(path.get("path").asText());
File file = new File(path.get("path").asText());
final String mime;
try {
mime = Files.probeContentType(p);
} catch (IOException e) {
Logger.error("BUMMER!", e);
return Promise.promise(new Function0<Result>() {
@Override
public Result apply() throws Throwable {
return badRequest();
}
});
}
return toBytes(file).flatMap(new Function<byte[], Promise<Result>>() {
@Override
public Promise<Result> apply(final byte[] bytes) throws Throwable {
return toSHA1(bytes).map(new Function<String, Result>() {
@Override
public Result apply(String sha1) throws Throwable {
if (setETagHeaders(sha1, mime)) {
return status(304);
}
return ok(bytes);
}
});
}
}).recover(new Function<Throwable, Result>() {
@Override
public Result apply(Throwable t) throws Throwable {
return badRequest(t.getMessage());
}
});
}
一些缺点(总有一个 BUT):
- 这是阻塞的。所以最好在另一个配置为阻塞 IO 的 Akka 线程池上执行。
- 如前所述,转换为 byte[] 仅适用于小文件,因为它使用内存进行缓冲。如果您只提供小文件(想想网站级图像),这应该不是问题。请参阅:http://docs.oracle.com/javase/tutorial/essential/io/file.html,了解使用 NIO2 读取文件的不同方式。