场景：功能要求管理员可以通过在pc端web页面通过后台,给连接后台的一些设备设置定时开关。
后台和设备直接使用tcp保持长连接,并使用约定的格式编码数据，这不是重点。
为了满足上面的需求,使用了WebAsyncTask进行处理后台与设备之间的交互,交互完成后,后台再将交互结果反馈给前端,告知管理员。
这部分顺便贴下关键代码:
@RequestMapping("/")
public WebAsyncTask<BaseResult> testActionRecord() {
Callable<BaseResult> callable=new Callable<BaseResult>() {
@Override
@ActionRecord(async = true, description = "什么都不是", action = "/test")
public BaseResult call() throws Exception {
System.err.println("test()");
Test1 test1 = new Test1();
test1.setAction("11");
mapper.insertSelective(test1);
BaseResult baseResult = new BaseResult();
baseResult.setStatu(Status.STATU_SUCCESS);
baseResult.setMsg(Status.MSG_SUCCESS);
return baseResult;
}
};
return new WebAsyncTask<>(callable);
}
上面的代码直接简单模拟下了异步任务如何使用，其实为了与后台交互还需要用到回调函数。
tcp端使用mina，每个客户端有专门的连接IoSession，全部通过ip和IoSession的key--value格式保存到本地Map。
回调函数通过IoSession.setAttribute方法以一个属性的形式绑定到连接IoSession上。在接口处使用thread.wait暂停主线程，然后等tcp那边处理完毕后调用回调函数通知这边主线程调用notify唤醒，然后将结果告知客户。
这也不是重点。
重点是要添加操作日志，记录用户行为，网上一搜一大堆，spring + aop +自定义注解实现。不多说。
上面代码中@ActionRecord注解就是我自己实现的注解，需要记录操作日志的接口方法上只需要添加这个注解，里面的属性也是自定义的。
然而，对于那些失败的操作，我们是没必要记录日志的，所以，在注解业务里面涉及到了获取接口返回状态的操作，也不难，网上一搜一大堆。
现在碰到了上面这种异步的返回，如果在注解业务里面做的话，通过
ProceedingJoinPoint 的 proceed方法,只能拿到WebAsyncTask这个对象,还要用这个对象去执行 getCallable().call()才能拿到结果。
这么一来,异步任务相当于执行了两次。
所以,对于这种异步任务要记录操作日志，就不能在接口上面加记录操作日志的自定义注解了，而是像上面贴出的代码那样,写到call()方法上。
另：上面的自定义属性async,当时就是为了区分普通接口和异步执行接口的,现在也没必要留着了。
网友评论