diff --git a/ebike-gather/src/main/java/org/cdzy/gather/mqtt/MqttConnectionPool.java b/ebike-gather/src/main/java/org/cdzy/gather/mqtt/MqttConnectionPool.java index 55f3af7..978f83d 100644 --- a/ebike-gather/src/main/java/org/cdzy/gather/mqtt/MqttConnectionPool.java +++ b/ebike-gather/src/main/java/org/cdzy/gather/mqtt/MqttConnectionPool.java @@ -46,16 +46,18 @@ public class MqttConnectionPool implements DisposableBean, InitializingBean { config.setMinIdle(MqttConfig.getPoolMinIdle()); config.setBlockWhenExhausted(true); // 必须设置为 true - config.setMaxWaitMillis(5000); // 等待5秒,不能无限等待 + config.setMaxWaitMillis(5000); // 等待5秒,不能无限等待 + // 禁用空闲连接维护 +// config.setTimeBetweenEvictionRuns(Duration.ofMillis(-1)); // 启用空闲连接维护 config.setTimeBetweenEvictionRuns(Duration.ofMinutes(5)); - config.setSoftMinEvictableIdleTime(Duration.ofMinutes(30)); - config.setMinEvictableIdleTime(Duration.ofMinutes(30)); +// config.setSoftMinEvictableIdleTime(Duration.ofMinutes(30)); //开启则会驱逐(定期销毁空闲) +// config.setMinEvictableIdleTime(Duration.ofMinutes(30)); config.setNumTestsPerEvictionRun(-1); - config.setTestOnBorrow(false); - config.setTestOnReturn(false); + config.setTestOnBorrow(true); + config.setTestOnReturn(true); config.setTestWhileIdle(true); // 空闲时验证(保持连接健康) connectionPool = new GenericObjectPool<>(mqttConnectionFactory, config); diff --git a/ebike-operations/src/main/resources/mapper/EbikeRegionMapper.xml b/ebike-operations/src/main/resources/mapper/EbikeRegionMapper.xml index f79a19e..3fc9a46 100644 --- a/ebike-operations/src/main/resources/mapper/EbikeRegionMapper.xml +++ b/ebike-operations/src/main/resources/mapper/EbikeRegionMapper.xml @@ -21,16 +21,12 @@