我正在编写一个 Package 器来 Package 请求处理程序,使它们能够流式传输HTTP响应。
响应封装:
@Component
public class ResponseBodyEmitterProcessor {
public ResponseBodyEmitter process(Supplier<?> supplier) {
ResponseBodyEmitter emitter = new ResponseBodyEmitter();
Executors.newSingleThreadExecutor()
.execute(() -> {
CompletableFuture<?> future = CompletableFuture.supplyAsync(supplier)
.thenAccept(result -> {
try {
emitter.send(result, MediaType.APPLICATION_JSON_UTF8);
emitter.complete();
} catch (IOException e) {
emitter.completeWithError(e);
}
});
while (!future.isDone()) {
try {
emitter.send("", MediaType.APPLICATION_JSON_UTF8);
Thread.sleep(500);
} catch (IOException | InterruptedException e) {
emitter.completeWithError(e);
}
}
});
return emitter;
}
}
字符串
控制器:
@RestController
@RequestMapping("/something")
public class MyController extends AbstractController {
@GetMapping(value = "/anything")
public ResponseEntity<ResponseBodyEmitter> getAnything() {
return ResponseEntity.ok()
.contentType(MediaType.APPLICATION_JSON_UTF8)
.body(process(() -> {
//long operation
}));
}
型
我所做的只是每隔半秒发送一个空字符串来保持请求的活动。这是一些工具不超时关闭它所必需的。这里的问题是,我在响应中没有看到任何Content-Type头。根本什么都没有,尽管我从我的控制器方法返回ResponseEntity,正如它在这个线程中所说的那样:
https://github.com/spring-projects/spring-framework/issues/18518
看起来只有TEXT_HTML媒体类型才能接受流式传输。难道没有一种方法可以流式传输json吗?我甚至使用objectMapper手动将我的dtosMap到json字符串,但仍然没有运气。尝试使用APPLICATION_JSON和APPLICATION_STREAM_JSON -不起作用。在不同的浏览器中尝试-相同的结果。
我还在控制器中手动设置了ResponseEntity的Content-Type header。现在响应中有了header,但我不确定我的数据是否真的流了。在Chrome中,我只能看到我的操作结果,而不能看到我发送的中间字符(为了测试,将它们改为“a”)。
我检查了两个选项的请求处理时间:
**不带发射器(只是普通的控制器处理程序)**x1c 0d1x
带发射器
据我所知,等待状态的意思是:“等待第一个字节出现”。似乎发射器的第一个字节出现得更早-这看起来像我需要的。我可以把它作为我的解决方案工作的证明吗?
也许在Spring中还有另一种方法可以做到这一点?我需要的只是通过发送一些无用的数据来通知浏览器请求仍在处理中,直到实际操作完成-然后返回结果。
任何帮助都将不胜感激。
2条答案
按热度按时间sg24os4d1#
查看
ResponseBodyEmitter#send
的源代码,似乎应该在AbstractHttpMessageConverter#addDefaultHeaders
方法中设置指定的MediaType
,但仅当没有其他contentType头时才存在。字符串
我建议在那里设置一个断点,看看为什么头不被应用。也许
@RestController
设置了一个默认头。作为一种解决方法,你可以尝试通过MVC控制器中的注解来设置contentType头。
例如
型
esyap4oy2#
你可以直接继承ResponseBodyException,然后覆盖方法
extendResponse(ServerHttpResponse outputMessage)
,就像SseEmitter
一样。然后使用这个子类:字符串