博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
springmvc webservlet 加redis 订阅消息
阅读量:6182 次
发布时间:2019-06-21

本文共 961 字,大约阅读时间需要 3 分钟。

由于项目内请求的数据需要 等待设备处理完毕后返回才能得到.请求命令返回的是发送成功的包,而不是设备处理的包,所以需要请求等待..

方式一:项目中 添加了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 的方式是在浪费资源和不够实时..............

转载于:https://www.cnblogs.com/zuochanzi/p/10101319.html

你可能感兴趣的文章
【java】resteasy 使用
查看>>
asterisk meetme 会议实现
查看>>
Mockito入门
查看>>
sentry部署整理
查看>>
Oracle 列名 备注
查看>>
免费申请泛域名 ssl 证书
查看>>
我的网站搭建: (第五天) 分类和归档
查看>>
java合同生成策略
查看>>
IntelliJ IDEA使用Application Server开发普通Java Web项目
查看>>
服务器tomcat的优化
查看>>
C#类和接口、虚方法和抽象方法及值类型和引用类型的区别
查看>>
好文:「大搜车」凭什么获得阿里如此青睐?
查看>>
JDK1.8的HashMap和ConcurrentHashMap
查看>>
mysql 分区与分表
查看>>
java 值传递 数组传递
查看>>
分布式锁
查看>>
<![CDATA[ ]]>
查看>>
HP Gen8 + Epson L211 + Ubuntu 搭建内部服务器
查看>>
UITextView字数限制自适应高度限制输入
查看>>
php 跨域、跨子域,跨服务器读取session的方法介绍
查看>>