SpringBoot的DeferredResult案例：DeferredResult的超时处
理⽅式
DeferredResult的超时处理，采⽤委托机制，也就是在实例DeferredResult时给予⼀个超时时长（毫秒），同时在onTimeout中委托（传⼊）⼀个新的处理线程（我们可以认为是超时线程）；当超时时间到来，DeferredResult启动超时线程，超时线程处理业务，封装返回数据，给DeferredResult赋值（正确返回的或错误返回的）。
这个实例可以对上⼀个实例的代码稍作改动即可。
⼀、增加超时处理任务TimeOutWork
ample;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.t.request.async.DeferredResult;
public class TimeOutWork implements Runnable{
private final Logger logger = Class());
private DeferredResult<ResponseMsg<String>> deferredResult;
public TimeOutWork(DeferredResult<ResponseMsg<String>> deferredResult) {
this.deferredResult = deferredResult;
}
@Override
public void run() {
logger.debug("我超时啦!");
ResponseMsg<String> msg = new ResponseMsg<String>();
msg.fail("我超时啦!");
/
/deferredResult.setResult(msg);
deferredResult.setErrorResult(msg);
}
}
⼆、DeferredResult请求中注册超时任务处理
修改第⼀个请求，修改了两处，请⾃⼰⽐较
ample;
import java.util.HashMap;
import java.util.Map;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.bind.annotation.RestController;
import org.t.request.async.DeferredResult;
@RestController
@RequestMapping("/api")
public class DeferredRestController {
private final Logger logger = Class());
private final Map<Integer, DeferredResult<ResponseMsg<String>>> responseBodyMap = new HashMap<Integer, DeferredResult<ResponseMsg<String>>>();
private final Map<Integer, RequestMsg> requestBodyMap = new HashMap<Integer, RequestMsg>();
/**
* 第⼀个请求
*
* @param req
* @return
*/
@RequestMapping("/request1")
@ResponseBody
public DeferredResult<ResponseMsg<String>> request1(RequestMsg req) {
logger.debug("request1：请求参数{}", Param());
DeferredResult<ResponseMsg<String>> result =new DeferredResult<ResponseMsg<String>>(10000l);//10秒
requestBodyMap.put(1, req);// 把请求放到第⼀个请求map中
responseBodyMap.put(1, result);// 把请求响应的DeferredResult实体放到第⼀个响应map中
return result;
}
/**
* 第⼆个请求
* @param req
* @return
*/
@RequestMapping("/request2")
@ResponseBody
public DeferredResult<ResponseMsg<String>> request2(RequestMsg req) {
logger.debug("request2：请求参数{}", Param());
DeferredResult<ResponseMsg<String>> result = new DeferredResult<ResponseMsg<String>>(); requestBodyMap.put(2, req);// 把请求放到第⼆个请求map中
responseBodyMap.put(2, result);// 把请求响应的DeferredResult实体放到第⼆个响应map中
return result;
}
/**
* 第三个请求
*
* @param req
* @return
*/
@RequestMapping("/request3")
@ResponseBody
public DeferredResult<ResponseMsg<String>> request3(RequestMsg req) {
logger.debug("request3：请求参数{}", Param());
DeferredResult<ResponseMsg<String>> result = new DeferredResult<ResponseMsg<String>>(); requestBodyMap.put(3, req);// 把请求放到第三个请求map中
responseBodyMap.put(3, result);// 把请求响应的DeferredResult实体放到第三个响应map中
return result;
}
/**
* 控制第x个请求执⾏返回操作，同时⾃⼰也返回同样的值
*
* @param x
* @return
*/
@RequestMapping(value = "/requestXReturn", method = RequestMethod.POST)
@ResponseBody
public ResponseMsg<String> request1Return(Integer x) {
ResponseMsg<String> msg = new ResponseMsg<String>();
logger.debug("requestXReturn--1：请求参数{}", x);
DeferredResult<ResponseMsg<String>> result = (x);
if (result == null) {
springframework是什么意思msg.fail("錯誤!请求已经释放");
return msg;
}
String resultStr = "result" + x.toString() + ". Received:" + (x).getParam();
msg.success("成功", resultStr);
result.setResult(msg);// 设置DeferredResult的结果值，设置之后，它对应的请求进⾏返回处理
logger.debug("requestXReturn--2：请求参数{}", x);
logger.debug("requestXReturn--3：返回参数{}", msg);
return msg;
}
}
三、修改页⾯index.html
<script th:src="@{jquery-1.12.4.min.js}" type="text/javascript"></script>
<script th:inline="javascript">
function button1RequestClick(){
var param=$("#request1RequestId").val();
$.ajax({
type:'post',
url:'/api/request1',
dataType : 'json',
data : {
'param' : param
},
success : function(data) {
console.log(data);
if (data.status==0){
$("#request1ResultId").val(data.data);
} else {
$("#request1ResultId").val(data.msg);
}
},
error : function(data) {
console.log("button1RequestClick---error");
console.log(data);
//alert("错误消息：" + data);
}
};
前后的代码都省略了，其实仅仅修改了
if (data.status==0){
$("#request1ResultId").val(data.data);
} else {
$("#request1ResultId").val(data.msg);
}
四、⼩结
DeferredResult的超时处理⽐较简单，定义时长及注册⼀个处理Runnable实例即可。对于setResult、setErrorResult还需要继续研究。
1、setResult
2、setErrorResult
3、isSetOrExpired
补充：解决了DeferredResult请求长时间占⽤数据库连接的问题
最近看了看开源项⽬appllo配置中⼼的源码，发现⼀个很有意思的东东：
（1）原理：由于使⽤了DeferredResult，根据Spring DispatcherServlet的默认逻辑，数据库连接只有在异步请求真正返回给客户端的时候才会释放回连接池
（2）应⽤场景：长连接时间很长，对于⼤部分请求可能都要数⼩时以上才会返回。在这么长的⼀段时间内⼀直占⽤着数据库连接是不合理的
长连接场景解决：
@Component
public class EntityManagerUtil extends EntityManagerFactoryAccessor {
private static final Logger logger = Logger(EntityManagerUtil.class);
/**
* close the entity manager.
* Use it with caution! This is only intended for use with async request, which
* Spring won't close the entity manager until the async request is finished.
*/
public void closeEntityManager() {
EntityManagerHolder emHolder = (EntityManagerHolder)
if (emHolder == null) {
return;
}
logger.debug("Closing JPA EntityManager in EntityManagerUtil");
EntityManagerFactoryUtils.EntityManager());
}
}
以上为个⼈经验，希望能给⼤家⼀个参考，也希望⼤家多多⽀持。如有错误或未考虑完全的地⽅，望不吝赐教。
版权声明：本站内容均来自互联网，仅供演示用，请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198，我们将在24小时内删除。
发表评论