ruochen
/
zn-car
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix 获取连接

master
rouchen 2024-06-13 22:32:20 +08:00
parent c6b07df79b
commit 296db9bb3b
2 changed files with 6 additions and 33 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/main/java/com/car/service/ConnectService.java
View File

@ -16,6 +16,11 @@ import java.util.List;
* Date 2024/5/28 21:49 * Date 2024/5/28 21:49
*/ */
public interface ConnectService { public interface ConnectService {
/**
* 获取连接
* @param vehicleConnectionReq
* @return
*/
Result<MqttServerModel> getConnect(VehicleConnectionReq vehicleConnectionReq); Result<MqttServerModel> getConnect(VehicleConnectionReq vehicleConnectionReq);
void LoadCenterAdd(LoadEnterNumber loadEnterNumber); void LoadCenterAdd(LoadEnterNumber loadEnterNumber);

34
src/main/java/com/car/service/impl/ConnectServiceImpl.java
View File

@ -47,7 +47,6 @@ public class ConnectServiceImpl implements ConnectService {
} else { } else {
redisTemplate.opsForValue().set("subscript", String.valueOf(count + 1)); redisTemplate.opsForValue().set("subscript", String.valueOf(count + 1));
} }
String ip = redisTemplate.opsForList().index("ips", count); String ip = redisTemplate.opsForList().index("ips", count);
return Result.success(new MqttServerModel("tcp://" + ip + ":1883", "test1")); return Result.success(new MqttServerModel("tcp://" + ip + ":1883", "test1"));
} finally { } finally {
@ -63,38 +62,7 @@ public class ConnectServiceImpl implements ConnectService {
lock.unlock(); // 释放锁 lock.unlock(); // 释放锁
} }
} }
// @Override
// public Result<MqttServerModel> getConnect(VehicleConnectionReq vehicleConnectionReq) {
// // 检查Redis中连接次数"count"是否存在
// if (redisTemplate.hasKey("count")){
// // 获取当前连接次数
// Integer count = Integer.valueOf(redisTemplate.opsForValue().get("count"));
// // 当连接次数达到100时，重置连接次数为0
// if (count == 100){
// redisTemplate.opsForValue().set("count", String.valueOf(0));
// }else{
// // 连接次数未达到100，递增连接次数
// redisTemplate.opsForValue().set("count", String.valueOf(count+1));
// }
// // 根据当前连接次数，获取对应的IP地址
// String ip = redisTemplate.opsForList().index("ipList", count);
// long timestamp = System.currentTimeMillis();
// this.insert(new VinIp(vehicleConnectionReq.getVehicleVin(), ip,timestamp));
// // 创建并返回Mqtt服务器模型
// MqttServerModel mqttServerModel = new MqttServerModel("tcp://" + ip + ":1883", "test1");
// return Result.success(mqttServerModel);
// }else{
// // "count"不存在时，初始化连接次数为1
// redisTemplate.opsForValue().set("count", String.valueOf(1));
// // 获取列表中的第一个IP地址
// String s = redisTemplate.opsForList().index("ipList", 0);
// long timestamp = System.currentTimeMillis();
// this.insert(new VinIp(vehicleConnectionReq.getVehicleVin(), s,timestamp));
// // 创建并返回第一个IP地址对应的Mqtt服务器模型
// MqttServerModel test1 = new MqttServerModel("tcp://" + s + ":1883", "test1");
// return Result.success(test1);
// }
// }
} }
/** /**
* 添加负载中心 * 添加负载中心