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 的方式是在浪费资源和不够实时..............

  • 相关阅读:
    C#使用各种时间戳及转换
    Rust借用机制的理解分析
    C# QRCoder 生成二维码
    Android 使用 JCIFS 访问共享文件
    Linux samba 创建共享盘
    WPF 等待对话框
    IIS实现Nginx功能:转发
    js jquery ajax跨域
    依赖注入
    .net standard
  • 原文地址:https://www.cnblogs.com/zuochanzi/p/10101319.html
Copyright © 2011-2022 走看看