zoukankan      html  css  js  c++  java
  • springmvc webservlet 加redis 订阅消息

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

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

  • 相关阅读:
    FTP文件传输应用分析
    A*寻路算法
    Asp.net页面事件引发后台程序处理原理
    开发人员的基本原则(转)
    定位new表达式
    常量对象的动态分配和释放
    PostThreadMessage使用
    最美丽的数学公式
    仿函数
    CF1598EStaircases【计数】
  • 原文地址:https://www.cnblogs.com/zuochanzi/p/10101319.html
Copyright © 2011-2022 走看看