Apollo的长连接实现是
- Spring的DeferredResult来实现的,先看怎么用
import ...
@RestController
@RequestMapping("deferredResult")
public class DeferredResultController {
private Map<String, Consumer<DeferredResultResponse>> taskMap = new HashMap<>();
private String requestId = "demo";
@GetMapping("get")
public DeferredResult<DeferredResultResponse> deferredResult(){
DeferredResult<DeferredResultResponse> ret = new DeferredResult<>();
ret.onTimeout(() -> {
DeferredResultResponse deferredResultResponse = new DeferredResultResponse();
deferredResultResponse.setCode(HttpStatus.REQUEST_TIMEOUT.value());
deferredResultResponse.setMsg(DeferredResultResponse.Msg.TIMEOUT.getDesc());
ret.setResult(deferredResultResponse);
});
taskMap.put(requestId, ret::setResult);
return ret;
}
@GetMapping("set")
public void setResult(){
DeferredResultResponse deferredResultResponse = new DeferredResultResponse();
deferredResultResponse.setCode(HttpStatus.OK.value());
deferredResultResponse.setMsg(DeferredResultResponse.Msg.SUCCESS.getDesc());
taskMap.get(requestId).accept(deferredResultResponse);
taskMap.remove(requestId);
}
public static class DeferredResultResponse{
private Integer code;
private String msg;
...
public enum Msg {
TIMEOUT("超时"),
FAILED("失败"),
SUCCESS("成功");
private String desc;
...
Msg(String desc) {
this.desc = desc;
}
}
}
}
-
这时候请求get接口，客户端是卡住的
-
当有结果设置的时候才会响应，调set接口来设置结果
-
如果一直没有结果设置，就会等到超时的时候才会响应
-
对于Apollo的客户端来说请求流程也是这样的
调用notification/v3接口等待获取变更的数据(namespace)，如果一直没有变更，就会等到60秒超时的时候才响应。
原理
在了解原理之前，问几个问题？
- 这个客户端阻塞是怎么实现的？
- 超时是怎么唤醒的？
- 设置值的时候如果找到原来的请求
回答
- 阻塞是通过socket来实现的，只要socket请求之后不往回写response，就会一直等待
spring判断controller是DeferredResult异步请求，就会把这个请求挂起，请求的信息先保存起来，不返回response - 超时唤醒是利用tomcat的能力，tomcat会启动线程去扫描队列里面挂起的请求，如果有超时时间到的，会重新dispatch
- setResult会AsyncManager保存的request，把结果设置之后，重新dispatch
