由于项目内请求的数据需要 等待设备处理完毕后返回才能得到.请求命令返回的是发送成功的包,而不是设备处理的包,所以需要请求等待..
方式一:项目中 添加了redis作为一个缓存, webservlet 异步启动线程,线程中加一个轮询查redis ,如果redis有需要的值,则返回, 设置timeout 在规定时间内没有查到值,则返回超时..
这个流程在实际做起来,会存在一定的bug 因为timeout了, while循环未退出导致这个线程内,还在轮询这个redis ,当下一次请求返回值之后,这个为了循环就能取到值了,于是出现了一些bug ,
第一个bug IllegalStateException 异常
@Override public ServletResponse getResponse() { check(); return servletResponse; } private void check() { if (request == null) { // AsyncContext has been recycled and should not be being used throw new IllegalStateException(sm.getString( "asyncContextImpl.requestEnded"));//此处即为抛出的异常 } }
由于timeout 已经把请求断掉了,request 已经是null了, while循环中获取到了redis信息又要返回request ,出现了异常
第二种 使用redis的订阅模式,类似观察者模式, request 请求起异步线程时,同时加载一个频道, redis 读取线程启动推送者,当收到远端设备返回指令的消息后, 推送到订阅者,也就是这个请求端.其实本人也不知道别人有没有这么用的,
只是在c#中用惯了观察者模式, 感觉轮询取redis 的方式是在浪费资源和不够实时..............