最新公告
  • 欢迎您光临码巴巴,本站秉承服务宗旨 履行“站长”责任,销售只是起点 服务永无止境!立即加入我们
  • springboot 线上死循环执行一段时间后服务挂起,假死,DAM-0020TA监听,开关量转TCP/IP

    1.最近做了一款打印机程序。使用了开关量转tcp/ip 模块。 模块见下图。

    2.基本逻辑:PLC 通过继电器, 向模块发出开关量信号。 监听程序300毫秒去读取模块信号。 如果连续读到3次,则组装数据到打印机,并发送打印信号。打印机开始打印。

    3.上线过程中出现假死,进程挂起等异常异常现象, 通过一下方式解决

    package com.ruoyi.web.core.damtest;
    
    import com.ruoyi.common.enums.PrintStateEnum;
    import com.ruoyi.common.utils.DateUtils;
    import com.ruoyi.common.utils.http.HttpHelper;
    import com.ruoyi.system.domain.PrintData;
    import com.ruoyi.system.domain.PrintInfo;
    import com.ruoyi.system.mapper.PrintInfoMapper;
    import com.ruoyi.system.service.IPrintInfoService;
    import com.ruoyi.web.core.ServerSocketConfig;
    import com.ruoyi.web.core.SocketClient;
    import lombok.Data;
    import net.wimpi.modbus.util.BitVector;
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.boot.CommandLineRunner;
    import org.springframework.core.annotation.Order;
    import org.springframework.stereotype.Component;
    
    import java.io.UnsupportedEncodingException;
    import java.text.SimpleDateFormat;
    import java.util.Date;
    import java.util.concurrent.Executors;
    import java.util.concurrent.ScheduledExecutorService;
    import java.util.concurrent.ScheduledFuture;
    import java.util.concurrent.TimeUnit;
    
     
    
    /**
     * DAM-0020TA控制
      主要逻辑:1、 通过CommandLineRunner 让进程在springboot启动完成之后,就开始监听
                2、通过定时器没300毫秒执行一次。执行完成后,线程内资源会被回收,避免内存占用
                3、通过守护线程判断原有监听线程是否不在执行。如果是则重启服务。 
     */
    @Component
    @Data
    @Order(2) //springboot 初始化后运行
    public  class PrinterControl  implements CommandLineRunner {
    
        private static final Logger LOGGER = LoggerFactory.getLogger(PrinterControl.class);
        public static long LISTENNER_SLEEP_TIME = 300;
    
        //IP地址改成自己的,可放在配置文件中
        public static String IP = "1270.0.01";
        public static int PORT = 10000;
        public static int SLAVE_ID = 254;
        private int gcNum = 0;
        private int activeNum = 0;
    
        private JYDAMEquip equip = null;
    
        // 上次检查的时间
        private volatile long lastCheckTimestamp = System.currentTimeMillis();
    
    
        // 设置应用假死的阈值,例如1分钟
        private static final long APP_UNHEALTHY_THRESHOLD = 1 * 60 * 1000;
     
        @Autowired
        private IPrintInfoService printInfoService;
        @Autowired
        private PrintInfoMapper printInfoMapper;
        @Autowired
        private SocketClient socketClient;
    
    
    
    
        /**
         * 计时器核心驱动代码
         */
        public void core(){
            try{
                /**
                 * 初始换PLC转换模块
                 */
                publicOpen();
                /**
                 * 设置定时器
                 */
                ScheduledExecutorService scheduledThreadPoolExecutor= Executors.newScheduledThreadPool(1);
                ScheduledFuture future = scheduledThreadPoolExecutor.scheduleAtFixedRate(new Runnable() {
                    @Override
                    public void run() {
    
                        listenerPLC();
                    }
                }, 0,LISTENNER_SLEEP_TIME , TimeUnit.MILLISECONDS);
            }catch (Exception e){
                e.printStackTrace();
                    LOGGER.error("PLC初始化异常");
            }
    
        }
    
    
    
        /**
         * 守护线程
         */
        public void deamonThread(){
            try{
                ScheduledExecutorService scheduledThreadPoolExecutor= Executors.newScheduledThreadPool(1);
                ScheduledFuture future = scheduledThreadPoolExecutor.scheduleAtFixedRate(new Runnable() {
                    @Override
                    public void run() {
                        //定时器里必须加try catch ,不然会因为报错造成定时器不执行接下的任务
                        try {
                            long currentTimestamp = System.currentTimeMillis();
                            boolean isRestart = currentTimestamp - lastCheckTimestamp > APP_UNHEALTHY_THRESHOLD;
                            LOGGER.info("守护线程出判断线程是否掉线:{}",isRestart);
                            if (isRestart) {
                                restartApplication();
                            }
                        }catch (Exception e){
                            LOGGER.error("守护线程出现异常,异常信息为:{}",e.getMessage());
                        }
                    }
                }, 0,LISTENNER_SLEEP_TIME , TimeUnit.MILLISECONDS);
            }catch (Exception e){
                    LOGGER.error("守护线程定时器出现异常,异常信息为:{}",e.getMessage());
                    e.printStackTrace();
            }
    
        }
    
    
    
    
        /**
         * (逻辑代码)
         * 监听是否有信号输入(输入)
         *
         * @throws Exception
         * @auther liukx
         */
        public void listenerPLC() {
    
    
                try{
                    initConnect();
    
                    //初始化设备
                    BitVector  DIVal = equip.readDI(2);
                    lastCheckTimestamp = System.currentTimeMillis();
                    LOGGER.info("开始读取是否有下载任务:{}" ,lastCheckTimestamp);
                    Thread.sleep(80);
    
    
    
                    if (DIVal !=null && (DIVal.getBit(0) || DIVal.getBit(1))) activeNum = activeNum + 1;
                    LOGGER.info("下载任务下达次数:{}" , activeNum);
                    /**
                     * 如果连续传入5次以上则,认为下发打印命令,执行打印逻辑
                     */
                    if (activeNum >= 3) {
                        activeNum = 0;
                        //这里面写逻辑代码
                        LOGGER.info("计时器接收到打印信息,原始数据为:{},{}",getNowDate() , DIVal.toString());
                        //发出打印指令,这块可以是http 接口调用,也可以是其他,注意设置超时时间不达到轮训时间。
                        startPrint(equip);
    
                    }
                }catch (Exception e){
                    LOGGER.info("plc连接失败3秒后重新连接");
                    e.printStackTrace();
                    try {
                        passiveClose( equip);
                    } catch (Exception ex) {
                        LOGGER.info("处理业务异常");
                        ex.printStackTrace();
                    }
    
                }
    
            }
    
            /**
            * 当检到线程挂起时,通过执行shell文件重启
            */
          private void restartApplication() {
                // 这里可以调用Spring Boot的重启接口或者使用命令行重启
                LOGGER.info("系统正在重启。。。");
                //SpringApplication.exit(SpringApplication.run(RuoYiApplication.class, new String[0]));
                try{
                     Process process = Runtime.getRuntime().exec("sh /home/lenovo/bg/bg_startup.sh");
                    int exitCode = process.waitFor();
                    LOGGER.info("Shell脚本执行完毕,退出码为:" + exitCode);
                }catch (Exception e){
                     LOGGER.info("程序在重启是发生异常,异常信息为:{}",e.getMessage());
                     e.printStackTrace();
                }
    
            }
    
        /**
         * 初始化开关转tcp 模块
         */
        public void initConnect() throws  Exception{
                if(equip == null || !equip.IsConnect() ){
                        //初始到13~14 接口无电压输出
                    equip  = new JYDAMEquip();
                    equip.Init(IP, PORT, SLAVE_ID); //ip 端口为10000   254为设备的广播地址
                    equip.BeginConnect();
                }
        }
      
    
    
        /**
         * 关闭无源的继电器(输出)
         *
         * @throws Exception
         * @auther liukx
         */
        public void passiveClose(JYDAMEquip equip)  {
            LOGGER.info("发出异常信息-------异常异常异常异常异常异常-------");
            equip.writeSignalDO(0, 0);  //17~16
        }
    
         
    
        /**
         * 打开无源的继电器(输出)
         *
         * @throws Exception
         * @auther liukx
         */
        public   void publicOpen() throws Exception {
    
         	initConnect();
            LOGGER.info("发出正常常信息-------正常正常正常正常正常-------");
            equip.writeSignalDO(0, 1);//17~16
            equip.DisConnect();
        }
    
    
        /**
         * 打开无源的继电器(输出)
         *
         * @throws Exception
         * @auther liukx
         */
        public   void passiveOpen(JYDAMEquip equip) throws Exception {
            LOGGER.info("发出正常常信息-------正常正常正常正常正常-------");
            equip.writeSignalDO(0, 1);//17~16
        }
    
        /**
         * 获取当前时间
         *
         * @return
         */
        public static String getNowDate() {
            Date date = new Date();
            SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
            return sdf.format(date);
        }
    
    
        @Override
        public void run(String... args) throws Exception {
            deamonThread();
            core();
    
        }
    }
    
    

     

    4.总结:通过定时间替代死循环。 通过守护线程确保程序不被挂起。还可以设置root权限执行,也是比较好的方式。

     

     

     

     

     

     

    1. 本站所有资源来源于用户上传和网络,如有侵权请及时联系站长!

    2. 分享目的仅供大家学习和交流,您必须在下载后24小时内删除!

    3. 不得使用于非法商业用途,不得违反国家法律。否则后果自负!

    4. 本站提供的源码、模板、插件等等其他资源,都不包含技术服务请大家谅解!

    5. 如有链接无法下载、失效或广告,请联系管理员处理!

    6. 本站资源售价只是赞助,收取费用仅维持本站的日常运营所需!

    7. 如遇到加密压缩包,默认解压密码为"mababa.xin",如遇到无法解压的请联系管理员!


    码巴巴-优质代码创造者 » springboot 线上死循环执行一段时间后服务挂起,假死,DAM-0020TA监听,开关量转TCP/IP

    常见问题FAQ

    免费下载或者VIP会员专享资源能否直接商用?
    本站所有资源版权均属于原作者所有,这里所提供资源均只能用于参考学习用,请勿直接商用。若由于商用引起版权纠纷,一切责任均由使用者承担。更多说明请参考 VIP介绍。
    提示下载完但解压或打开不了?
    最常见的情况是下载不完整: 可对比下载完压缩包的与网盘上的容量,若小于网盘提示的容量则是这个原因。这是浏览器下载的bug,建议用百度网盘软件或迅雷下载。若排除这种情况,可在对应资源底部留言,或 联络我们.。
    找不到素材资源介绍文章里的示例图片?
    对于PPT,KEY,Mockups,APP,网页模版等类型的素材,文章内用于介绍的图片通常并不包含在对应可供下载素材包内。这些相关商业图片需另外购买,且本站不负责(也没有办法)找到出处。 同样地一些字体文件也是这种情况,但部分素材会在素材包内有一份字体下载链接清单。
    一个高级程序员模板开发平台
    问问管理员?

    发表评论

    • 44会员总数(位)
    • 95资源总数(个)
    • 0本周发布(个)
    • 0 今日发布(个)
    • 1511稳定运行(天)

    提供最优质的资源集合

    立即查看 了解详情
    升级SVIP尊享更多特权立即升级