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介绍。
- 提示下载完但解压或打开不了？
- 找不到素材资源介绍文章里的示例图片？
- 一个高级程序员模板开发平台
