package com.zy.acs.charge.protocol;
|
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.stereotype.Component;
|
|
import javax.annotation.PostConstruct;
|
|
@Component
|
@Slf4j
|
public class ModbusConnectionManager {
|
|
@Autowired
|
private ModbusAdapter modbusAdapter;
|
|
@Value("${charger.modbus.retry.max-attempts:3}")
|
private int maxRetry;
|
|
@Value("${charger.modbus.retry.initial-delay:1000}")
|
private long initialDelay;
|
|
@PostConstruct
|
public void startAsyncConnect() {
|
// 启动异步线程尝试连接
|
new Thread(() -> {
|
for (int i = 0; i < maxRetry; i++) {
|
try {
|
modbusAdapter.connect();
|
log.info("Modbus connection established after {} attempts", i + 1);
|
// 可选：启动心跳
|
startHeartbeat();
|
return;
|
} catch (Exception e) {
|
log.warn("Modbus connection attempt {} failed: {}", i + 1, e.getMessage());
|
if (i < maxRetry - 1) {
|
try {
|
Thread.sleep(initialDelay);
|
} catch (InterruptedException ignored) {
|
}
|
}
|
}
|
}
|
log.error("Failed to connect to Modbus charger after {} attempts", maxRetry);
|
}).start();
|
}
|
|
private void startHeartbeat() {
|
// 实现心跳
|
}
|
|
}
|
