From bda7de379f50f241bc7b5c23de2d220cf900dee3 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E7=8E=89=E5=AE=89=E5=90=9B?= <2746727141@qq.com> Date: Fri, 29 Mar 2024 20:23:26 +0800 Subject: [PATCH 1/2] =?UTF-8?q?fix=20commit=20=E4=BF=AE=E6=94=B9=E4=BA=86?= =?UTF-8?q?=E9=83=A8=E5=88=86=E4=BB=A3=E7=A0=81=E7=9A=84=E4=BB=A3=E7=A0=81?= =?UTF-8?q?=E8=A7=84=E8=8C=83,=E4=BF=AE=E5=A4=8D=E4=BA=86=E7=AE=A1?= =?UTF-8?q?=E7=90=86=E4=BC=81=E4=B8=9A=E5=8A=9F=E8=83=BD=E7=9A=84=E5=B7=B2?= =?UTF-8?q?=E7=9F=A5bug?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/impl/SysConfigServiceImpl.java | 48 +++++++++---------- 1 file changed, 24 insertions(+), 24 deletions(-) diff --git a/zhilian-modules/zhilian-system/src/main/java/com/zhilian/system/service/impl/SysConfigServiceImpl.java b/zhilian-modules/zhilian-system/src/main/java/com/zhilian/system/service/impl/SysConfigServiceImpl.java index 3276f47..8fb43a4 100644 --- a/zhilian-modules/zhilian-system/src/main/java/com/zhilian/system/service/impl/SysConfigServiceImpl.java +++ b/zhilian-modules/zhilian-system/src/main/java/com/zhilian/system/service/impl/SysConfigServiceImpl.java @@ -30,25 +30,27 @@ public class SysConfigServiceImpl extends ServiceImpl pageQuery (SysConfig config) { + public List pageQuery(SysConfig config) { LambdaQueryWrapper queryWrapper = new LambdaQueryWrapper<>(); - if (StringUtils.isNotEmpty(config.getConfigName())){ - queryWrapper.like(SysConfig::getConfigName, config.getConfigName()); - } - if (StringUtils.isNotEmpty(config.getConfigType())){ - queryWrapper.like(SysConfig::getConfigType, config.getConfigType()); - } - if (StringUtils.isNotEmpty(config.getConfigKey())){ - queryWrapper.like(SysConfig::getConfigKey, config.getConfigKey()); - } + //模糊条件 查询配置名称 + queryWrapper.like(StringUtils.isNotEmpty(config.getConfigName()), SysConfig::getConfigName, config.getConfigName()); + + //模块条件 通过配置进行模糊查询 + queryWrapper.like(StringUtils.isNotEmpty(config.getConfigType()), SysConfig::getConfigType, config.getConfigType()); + + //模糊条件 通过配置键 进行查询 + queryWrapper.like(StringUtils.isNotEmpty(config.getConfigKey()), SysConfig::getConfigKey, config.getConfigKey()); + Object beginTime = config.getParams().get("beginTime"); - if (Objects.nonNull(beginTime) && beginTime instanceof Date beginDate){ - queryWrapper.gt(SysConfig::getCreateTime, beginDate); - } + + //区间查询,查询大于配置创建时间的配置 + queryWrapper.gt(Objects.nonNull(beginTime) && (beginTime instanceof Date beginDate), SysConfig::getCreateTime, beginTime); + Object endTime = config.getParams().get("endTime"); - if (Objects.nonNull(endTime) && endTime instanceof Date endDate){ - queryWrapper.lt(SysConfig::getCreateTime, endDate); - } + + //区间查询,查询小于配置创建时间的配置 + queryWrapper.lt((Objects.nonNull(endTime) && endTime instanceof Date endDate), SysConfig::getCreateTime, endTime); + return this.list(queryWrapper); } @@ -56,11 +58,10 @@ public class SysConfigServiceImpl extends ServiceImpl queryWrapper = new LambdaQueryWrapper<>(); Assert.notNull(configKey, "key不可为空"); queryWrapper.eq(SysConfig::getConfigKey, configKey); @@ -69,14 +70,14 @@ public class SysConfigServiceImpl extends ServiceImpl queryWrapper = new LambdaQueryWrapper<>(); queryWrapper.eq(SysConfig::getConfigKey, config.getConfigKey()); return this.count(queryWrapper) > 0; } @Override - public void resetConfigCache () { + public void resetConfigCache() { this.clearConfigCache(); this.loadingConfigCache(); } @@ -85,7 +86,7 @@ public class SysConfigServiceImpl extends ServiceImpl keys = redisService.keys(CacheConstants.SYS_CONFIG_KEY + "*"); redisService.deleteObject(keys); } @@ -94,7 +95,7 @@ public class SysConfigServiceImpl extends ServiceImpl configsList = this.list(); for (SysConfig config : configsList) { redisService.setCacheObject(getCacheKey(config.getConfigKey()), config.getConfigValue()); @@ -105,10 +106,9 @@ public class SysConfigServiceImpl extends ServiceImpl Date: Mon, 1 Apr 2024 19:33:58 +0800 Subject: [PATCH 2/2] =?UTF-8?q?feat=20commit=20=E6=B3=A8=E5=86=8C=E8=8A=82?= =?UTF-8?q?=E7=82=B9=E6=B3=A8=E5=86=8C=E5=8A=9F=E8=83=BD?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- pom.xml | 8 + .../common/redis/service/RedisService.java | 199 ++++++++++++++---- .../business/ZhilianBusinessApplication.java | 19 ++ .../manager/ZhilianMagagerApplication.java | 19 ++ zhilian-modules/zhilian-online/pom.xml | 12 ++ .../online/ZhiLianOnlineApplication.java | 23 ++ .../zhilian/online/config/MqttxConfig.java | 107 ++++++++++ .../zhilian/online/config/RabbitConfig.java | 164 +++++++++++++++ .../online/constans/OnlineConstants.java | 32 +++ .../online/consumer/DeadQueueConsumer.java | 39 ++++ .../controller/OnlineGatherController.java | 32 +++ .../OnlineLoadCenterController.java | 83 ++++++++ .../controller/OnlineVerifyController.java | 49 +++++ .../com/zhilian/online/domain/Gather.java | 72 +++++++ .../com/zhilian/online/domain/Vehicle.java | 37 ++++ .../zhilian/online/domain/VehicleAccount.java | 70 ++++++ .../online/domain/model/MqttServerModel.java | 37 ++++ .../online/domain/req/GatherRegReq.java | 34 +++ .../online/mapper/OnlineGatherMapper.java | 17 ++ .../online/mapper/OnlineLoadCenterMapper.java | 18 ++ .../online/service/OnlineGatherService.java | 14 ++ .../service/OnlineLoadCenterService.java | 32 +++ .../service/impl/OnlineGatherServiceImpl.java | 22 ++ .../impl/OnlineLoadCenterServiceImpl.java | 96 +++++++++ .../src/main/resources/banner.txt | 23 ++ .../mapper/online/OnlineGatherMapper.xml | 7 + .../mapper/online/OnlineLoadCenterMapper.xml | 7 + .../resolver/ZhilianResolverApplication.java | 19 ++ 28 files changed, 1252 insertions(+), 39 deletions(-) create mode 100644 zhilian-modules/zhilian-business/src/main/java/com/zhilian/business/ZhilianBusinessApplication.java create mode 100644 zhilian-modules/zhilian-manager/src/main/java/com/zhilian/manager/ZhilianMagagerApplication.java create mode 100644 zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/ZhiLianOnlineApplication.java create mode 100644 zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/config/MqttxConfig.java create mode 100644 zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/config/RabbitConfig.java create mode 100644 zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/constans/OnlineConstants.java create mode 100644 zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/consumer/DeadQueueConsumer.java create mode 100644 zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/controller/OnlineGatherController.java create mode 100644 zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/controller/OnlineLoadCenterController.java create mode 100644 zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/controller/OnlineVerifyController.java create mode 100644 zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/domain/Gather.java create mode 100644 zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/domain/Vehicle.java create mode 100644 zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/domain/VehicleAccount.java create mode 100644 zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/domain/model/MqttServerModel.java create mode 100644 zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/domain/req/GatherRegReq.java create mode 100644 zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/mapper/OnlineGatherMapper.java create mode 100644 zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/mapper/OnlineLoadCenterMapper.java create mode 100644 zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/service/OnlineGatherService.java create mode 100644 zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/service/OnlineLoadCenterService.java create mode 100644 zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/service/impl/OnlineGatherServiceImpl.java create mode 100644 zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/service/impl/OnlineLoadCenterServiceImpl.java create mode 100644 zhilian-modules/zhilian-online/src/main/resources/mapper/online/OnlineGatherMapper.xml create mode 100644 zhilian-modules/zhilian-online/src/main/resources/mapper/online/OnlineLoadCenterMapper.xml create mode 100644 zhilian-modules/zhilian-resolver/src/main/java/com/zhilian/resolver/ZhilianResolverApplication.java diff --git a/pom.xml b/pom.xml index a8edc63..fba94e6 100644 --- a/pom.xml +++ b/pom.xml @@ -36,6 +36,7 @@ 4.1.2 2.14.3 3.8.1 + 1.2.5 @@ -236,6 +237,13 @@ ${zhilian.version} + + + org.eclipse.paho + org.eclipse.paho.client.mqttv3 + ${mqttv3.version} + + diff --git a/zhilian-common/zhilian-common-redis/src/main/java/com/zhilian/common/redis/service/RedisService.java b/zhilian-common/zhilian-common-redis/src/main/java/com/zhilian/common/redis/service/RedisService.java index cb12263..397c440 100644 --- a/zhilian-common/zhilian-common-redis/src/main/java/com/zhilian/common/redis/service/RedisService.java +++ b/zhilian-common/zhilian-common-redis/src/main/java/com/zhilian/common/redis/service/RedisService.java @@ -1,14 +1,14 @@ package com.zhilian.common.redis.service; +import io.lettuce.core.output.DoubleListOutput; +import org.apache.poi.ss.formula.functions.T; import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.data.redis.core.BoundSetOperations; -import org.springframework.data.redis.core.HashOperations; -import org.springframework.data.redis.core.RedisTemplate; -import org.springframework.data.redis.core.ValueOperations; +import org.springframework.data.redis.core.*; import org.springframework.stereotype.Component; import java.util.*; import java.util.concurrent.TimeUnit; +import java.util.stream.Collectors; /** * spring redis 工具类 @@ -27,7 +27,7 @@ public class RedisService { * @param key 缓存的键值 * @param value 缓存的值 */ - public void setCacheObject (final String key, final T value) { + public void setCacheObject(final String key, final T value) { redisTemplate.opsForValue().set(key, value); } @@ -39,7 +39,7 @@ public class RedisService { * @param timeout 时间 * @param timeUnit 时间颗粒度 */ - public void setCacheObject (final String key, final T value, final Long timeout, final TimeUnit timeUnit) { + public void setCacheObject(final String key, final T value, final Long timeout, final TimeUnit timeUnit) { redisTemplate.opsForValue().set(key, value, timeout, timeUnit); } @@ -48,10 +48,9 @@ public class RedisService { * * @param key Redis键 * @param timeout 超时时间 - * * @return true=设置成功；false=设置失败 */ - public boolean expire (final String key, final long timeout) { + public boolean expire(final String key, final long timeout) { return expire(key, timeout, TimeUnit.SECONDS); } @@ -61,10 +60,9 @@ public class RedisService { * @param key Redis键 * @param timeout 超时时间 * @param unit 时间单位 - * * @return true=设置成功；false=设置失败 */ - public boolean expire (final String key, final long timeout, final TimeUnit unit) { + public boolean expire(final String key, final long timeout, final TimeUnit unit) { return redisTemplate.expire(key, timeout, unit); } @@ -72,10 +70,9 @@ public class RedisService { * 获取有效时间 * * @param key Redis键 - * * @return 有效时间 */ - public long getExpire (final String key) { + public long getExpire(final String key) { return redisTemplate.getExpire(key); } @@ -83,10 +80,9 @@ public class RedisService { * 判断 key是否存在 * * @param key 键 - * * @return true 存在 false不存在 */ - public Boolean hasKey (String key) { + public Boolean hasKey(String key) { return redisTemplate.hasKey(key); } @@ -94,10 +90,9 @@ public class RedisService { * 获得缓存的基本对象。 * * @param key 缓存键值 - * * @return 缓存键值对应的数据 */ - public T getCacheObject (final String key) { + public T getCacheObject(final String key) { ValueOperations operation = redisTemplate.opsForValue(); return operation.get(key); } @@ -107,7 +102,7 @@ public class RedisService { * * @param key */ - public boolean deleteObject (final String key) { + public boolean deleteObject(final String key) { return redisTemplate.delete(key); } @@ -115,10 +110,9 @@ public class RedisService { * 删除集合对象 * * @param collection 多个对象 - * * @return */ - public boolean deleteObject (final Collection collection) { + public boolean deleteObject(final Collection collection) { return redisTemplate.delete(collection) > 0; } @@ -127,10 +121,9 @@ public class RedisService { * * @param key 缓存的键值 * @param dataList 待缓存的List数据 - * * @return 缓存的对象 */ - public long setCacheList (final String key, final List dataList) { + public long setCacheList(final String key, final List dataList) { Long count = redisTemplate.opsForList().rightPushAll(key, dataList); return count == null ? 0 : count; } @@ -139,10 +132,9 @@ public class RedisService { * 获得缓存的list对象 * * @param key 缓存的键值 - * * @return 缓存键值对应的数据 */ - public List getCacheList (final String key) { + public List getCacheList(final String key) { return redisTemplate.opsForList().range(key, 0, -1); } @@ -151,10 +143,9 @@ public class RedisService { * * @param key 缓存键值 * @param dataSet 缓存的数据 - * * @return 缓存数据的对象 */ - public BoundSetOperations setCacheSet (final String key, final Set dataSet) { + public BoundSetOperations setCacheSet(final String key, final Set dataSet) { BoundSetOperations setOperation = redisTemplate.boundSetOps(key); Iterator it = dataSet.iterator(); while (it.hasNext()) { @@ -167,10 +158,9 @@ public class RedisService { * 获得缓存的set * * @param key - * * @return */ - public Set getCacheSet (final String key) { + public Set getCacheSet(final String key) { return redisTemplate.opsForSet().members(key); } @@ -180,7 +170,7 @@ public class RedisService { * @param key * @param dataMap */ - public void setCacheMap (final String key, final Map dataMap) { + public void setCacheMap(final String key, final Map dataMap) { if (dataMap != null) { redisTemplate.opsForHash().putAll(key, dataMap); } @@ -190,10 +180,9 @@ public class RedisService { * 获得缓存的Map * * @param key - * * @return */ - public Map getCacheMap (final String key) { + public Map getCacheMap(final String key) { return redisTemplate.opsForHash().entries(key); } @@ -204,7 +193,7 @@ public class RedisService { * @param hKey Hash键 * @param value 值 */ - public void setCacheMapValue (final String key, final String hKey, final T value) { + public void setCacheMapValue(final String key, final String hKey, final T value) { redisTemplate.opsForHash().put(key, hKey, value); } @@ -213,10 +202,9 @@ public class RedisService { * * @param key Redis键 * @param hKey Hash键 - * * @return Hash中的对象 */ - public T getCacheMapValue (final String key, final String hKey) { + public T getCacheMapValue(final String key, final String hKey) { HashOperations opsForHash = redisTemplate.opsForHash(); return opsForHash.get(key, hKey); } @@ -226,10 +214,9 @@ public class RedisService { * * @param key Redis键 * @param hKeys Hash键集合 - * * @return Hash对象集合 */ - public List getMultiCacheMapValue (final String key, final Collection hKeys) { + public List getMultiCacheMapValue(final String key, final Collection hKeys) { return redisTemplate.opsForHash().multiGet(key, hKeys); } @@ -238,21 +225,155 @@ public class RedisService { * * @param key Redis键 * @param hKey Hash键 - * * @return 是否成功 */ - public boolean deleteCacheMapValue (final String key, final String hKey) { + public boolean deleteCacheMapValue(final String key, final String hKey) { return redisTemplate.opsForHash().delete(key, hKey) > 0; } + + /** + * 向Zset中存入单条数据 + * + * @param zkey ZSet键 + * @param value 值 + * @param score 分数 + */ + public void setCacheZsetValue(final String zkey, final T value, final Double score) { + redisTemplate.opsForZSet().add(zkey, value, score); + } + + /** + * 向Zset中存入多条数据 + * + * @param zkey zSet键 + * @param map => 键值对 键T 值Double分数 + */ + public void setCacheZsetBatchValue(final String zkey, final Map map) { + Set collect = map.entrySet().stream() + .map(item -> { + return new DefaultTypedTuple(item.getKey(), item.getValue()); + }) + .collect(Collectors.toSet()); + + redisTemplate.opsForZSet().add(zkey, collect); + } + + /** + * 获取Zset集合大小 + * + * @param zkey + * @return size + */ + public Long getCacheZsetSize(String zkey) { + return redisTemplate.opsForZSet().size(zkey); + } + + /** + * 查询成员分数 + * + * @param zkey + * @param value + * @param + * @return score + */ + public Double getCacheZsetScore(final String zkey, final T value) { + return redisTemplate.opsForZSet().score(zkey, value); + } + + /** + * 范围查询分数 + * + * @param zkey + * @param start + * @param end + * @return + */ + public Set getCacheZsetScoreBatch(final String zkey, final Long start, final Long end) { + return redisTemplate.opsForZSet().range(zkey, start, end); + } + + /** + * 范围查询集合携带分数 + * @param zkey + * @param start + * @param end + * @return + */ + public Set> getCacheZsetScoreWithDataBatch(final String zkey, final Long start, final Long end) { + Set> rangeSet = redisTemplate.opsForZSet().range(zkey, start, end); + Set> collect = rangeSet.stream(). + map(item -> { + HashMap objectDoubleHashMap = new HashMap(); + objectDoubleHashMap.put(item.getValue(), item.getScore()); + return objectDoubleHashMap; + }) + .collect(Collectors.toSet()); + return collect; + } + + /** + * 增加分数 + * @param zkey + * @param value + * @param delta + * @param + */ + public Double incrementScore(final String zkey, final T value, final Double delta){ + return redisTemplate.opsForZSet().incrementScore(zkey,value,delta); + } + + /** + * 删除元素 + * @param zkey + * @param values + * @return + * @param + */ + public Long removeCacheZsetBatch(final String zkey,final T... values){ + return redisTemplate.opsForZSet().remove(zkey,values); + } + + /** + * 排序并限制结果集大小,按降序返回有序集合的部分元素，支持指定索引范围。 + * @param zkey + * @param start + * @param end + * @return + */ + public Set reverseRange(final String zkey,final Long start,final Long end){ + return redisTemplate.opsForZSet().reverseRange(zkey,start,end); + } + + /** + * 按分数范围查询 + * @param zkey + * @param min + * @param max + * @return + */ + public Set rangeByScore(final String zkey,final Double min,final Double max){ + return redisTemplate.opsForZSet().rangeByScore(zkey,min,max); + } + + /** + * 获取最小值 + * @param zkey + * @return + */ + public Map getCacheZsetMin(final String zkey){ + ZSetOperations.TypedTuple typedTuple = redisTemplate.opsForZSet().popMin(zkey); + return new HashMap(){{put(typedTuple.getValue(),typedTuple.getScore());}}; + } + + /** * 获得缓存的基本对象列表 * * @param pattern 字符串前缀 - * * @return 对象列表 */ - public Collection keys (final String pattern) { + public Collection keys(final String pattern) { return redisTemplate.keys(pattern); } } diff --git a/zhilian-modules/zhilian-business/src/main/java/com/zhilian/business/ZhilianBusinessApplication.java b/zhilian-modules/zhilian-business/src/main/java/com/zhilian/business/ZhilianBusinessApplication.java new file mode 100644 index 0000000..b5120ee --- /dev/null +++ b/zhilian-modules/zhilian-business/src/main/java/com/zhilian/business/ZhilianBusinessApplication.java @@ -0,0 +1,19 @@ +package com.zhilian.business; + +import org.springframework.boot.SpringApplication; +import org.springframework.boot.autoconfigure.SpringBootApplication; + +/** + * @BelongsProject: smart-cloud-server + * @BelongsPackage: com.zhilian.business + * @Author: LiYuan + * @CreateTime: 2024-03-31 10:13 + * @Description: TODO + * @Version: 1.0 + */ +@SpringBootApplication +public class ZhilianBusinessApplication { + public static void main(String[] args) { + SpringApplication.run(ZhilianBusinessApplication.class); + } +} diff --git a/zhilian-modules/zhilian-manager/src/main/java/com/zhilian/manager/ZhilianMagagerApplication.java b/zhilian-modules/zhilian-manager/src/main/java/com/zhilian/manager/ZhilianMagagerApplication.java new file mode 100644 index 0000000..e0aa58e --- /dev/null +++ b/zhilian-modules/zhilian-manager/src/main/java/com/zhilian/manager/ZhilianMagagerApplication.java @@ -0,0 +1,19 @@ +package com.zhilian.manager; + +import org.springframework.boot.SpringApplication; +import org.springframework.boot.autoconfigure.SpringBootApplication; + +/** + * @BelongsProject: smart-cloud-server + * @BelongsPackage: com.zhilian.manager + * @Author: LiYuan + * @CreateTime: 2024-03-31 10:17 + * @Description: TODO + * @Version: 1.0 + */ +@SpringBootApplication +public class ZhilianMagagerApplication { + public static void main(String[] args) { + SpringApplication.run(ZhilianMagagerApplication.class,args); + } +} diff --git a/zhilian-modules/zhilian-online/pom.xml b/zhilian-modules/zhilian-online/pom.xml index d4c232f..34d2c0a 100644 --- a/zhilian-modules/zhilian-online/pom.xml +++ b/zhilian-modules/zhilian-online/pom.xml @@ -78,6 +78,18 @@ zhilian-common-swagger + + + org.springframework.amqp + spring-rabbit-test + + + + + org.eclipse.paho + org.eclipse.paho.client.mqttv3 + + diff --git a/zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/ZhiLianOnlineApplication.java b/zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/ZhiLianOnlineApplication.java new file mode 100644 index 0000000..db07c36 --- /dev/null +++ b/zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/ZhiLianOnlineApplication.java @@ -0,0 +1,23 @@ +package com.zhilian.online; + +import com.zhilian.common.security.annotation.EnableCustomConfig; +import com.zhilian.common.security.annotation.EnableMyFeignClients; +import com.zhilian.common.swagger.annotation.EnableCustomSwagger2; +import org.springframework.boot.SpringApplication; +import org.springframework.boot.autoconfigure.SpringBootApplication; + +/** + * @version: + * @Author: LiYuan + * @description: 智联车辆上线服务启动类 + * @date: 2024/3/29 20:36 + */ +@EnableCustomConfig +@EnableCustomSwagger2 +@EnableMyFeignClients +@SpringBootApplication +public class ZhiLianOnlineApplication { + public static void main(String[] args) { + SpringApplication.run(ZhiLianOnlineApplication.class,args); + } +} diff --git a/zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/config/MqttxConfig.java b/zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/config/MqttxConfig.java new file mode 100644 index 0000000..d0d2028 --- /dev/null +++ b/zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/config/MqttxConfig.java @@ -0,0 +1,107 @@ +package com.zhilian.online.config; + +import lombok.extern.slf4j.Slf4j; +import org.eclipse.paho.client.mqttv3.*; +import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence; +import org.springframework.beans.factory.annotation.Value; +import org.springframework.stereotype.Component; + +import javax.annotation.PostConstruct; + +/** + * @BelongsProject: smart-cloud-server + * @BelongsPackage: com.zhilian.online.config + * @Author: LiYuan + * @CreateTime: 2024-03-31 09:45 + * @Description: TODO + * @Version: 1.0 + */ +@Component +@Slf4j +public class MqttxConfig { + + /** + * 路径 + */ + @Value("${mqtt.server.broker}") + private String broker; + + /** + * 主题 + */ + @Value("${mqtt.server.topic}") + private String topic; + + /** + * 客户端ID + */ + @Value("${mqtt.server.clientId}") + private String clientId; + + /** + * 用户名 + */ + @Value("${mqtt.server.username}") + private String username; + + /** + * 密码 + */ + @Value("${mqtt.server.password}") + private String password; + + /** + * qos + */ + @Value("${mqtt.server.qos}") + private Integer qos; + + + @PostConstruct + public void initMqtt() { + log.info("mqttx连接中......"); + + try { + MqttClient mqttClient = new MqttClient(broker, clientId, new MemoryPersistence()); + + MqttConnectOptions mqttConnectOptions = new MqttConnectOptions(); + + mqttConnectOptions.setUserName(username); + mqttConnectOptions.setPassword(password.toCharArray()); + + //链接超时 + mqttConnectOptions.setConnectionTimeout(60); + //心跳检测 + mqttConnectOptions.setKeepAliveInterval(60); + mqttClient.connect(mqttConnectOptions); + log.info("mqtt{}服务连接成功", broker); + + //回调 + mqttClient.setCallback(new MqttCallback() { + @Override + public void connectionLost(Throwable throwable) { + log.error("连接断开{}", throwable.getMessage()); + } + + @Override + public void messageArrived(String s, MqttMessage mqttMessage) throws Exception { + log.info("消息到达,接受消息主题{},接受消息Qos{},接受消息内容{}", topic, mqttMessage.getQos(), new String(mqttMessage.getPayload())); + } + + @Override + public void deliveryComplete(IMqttDeliveryToken iMqttDeliveryToken) { + log.info("消息{}发送成功" + iMqttDeliveryToken.isComplete()); + } + }); + + mqttClient.subscribe(topic,qos); + + } catch (MqttException e) { + throw new RuntimeException(e); + } + + + } + + +} diff --git a/zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/config/RabbitConfig.java b/zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/config/RabbitConfig.java new file mode 100644 index 0000000..4b5ca67 --- /dev/null +++ b/zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/config/RabbitConfig.java @@ -0,0 +1,164 @@ +package com.zhilian.online.config;/** + * @version: + * @Author: LiYuan + * @description: + * @date: 2024/3/30 19:33 + */ + +import lombok.extern.slf4j.Slf4j; +import org.springframework.amqp.core.Binding; +import org.springframework.amqp.core.BindingBuilder; +import org.springframework.amqp.core.DirectExchange; +import org.springframework.amqp.core.Queue; +import org.springframework.amqp.rabbit.connection.ConnectionFactory; +import org.springframework.amqp.rabbit.core.RabbitTemplate; +import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter; +import org.springframework.amqp.support.converter.MessageConverter; +import org.springframework.context.annotation.Bean; +import org.springframework.context.annotation.Configuration; + +import java.util.HashMap; +import java.util.Map; +import java.util.Objects; + +/** + * @BelongsProject: smart-cloud-server + * @BelongsPackage: com.zhilian.online.config + * @Author: LiYuan + * @CreateTime: 2024-03-30 19:33 + * @Description: 负载中心RabbitMQ配置 + * @Version: 1.0 + */ +@Configuration +@Slf4j +public class RabbitConfig { + + /** + * 延迟队列名称 + */ + public static final String DELAY_QUEUE_NAME = "delay_queue"; + + /** + * 延迟交换机名称 + */ + public static final String DELAY_EXCHANGE_NAME = "delay_exchange"; + + /** + * 延迟路由键 + */ + public static final String DELAY_ROUTING_KEY = "delay_routing"; + + /** + * 死信队列名称 + */ + public static final String DEAD_QUEUE_NAME = "dead_queue"; + + /** + * 死信交换机名称 + */ + public static final String DEAD_EXCHANGE_NAME = "dead_exchange"; + + /** + * 死信路由键 + */ + public static final String DEAD_ROUTING_KEY = "dead_routing"; + + /** + * 注入死信队列实例 + * + * @return Queue + */ + @Bean + Queue deadQueue() { + log.info("死信队列创建成功"); + return new Queue(DEAD_QUEUE_NAME, true, false, false); + } + + /** + * 注入死信交换机实例 + * + * @return DirectExchange + */ + @Bean + DirectExchange deadExchange() { + log.info("死信交换机创建成功"); + return new DirectExchange(DEAD_EXCHANGE_NAME, true, false); + } + + /** + * 将死信队列与死信交换机绑定 + * + * @return Binding + */ + @Bean + Binding deadBinding() { + log.info("死信通道建立成功"); + return BindingBuilder.bind(deadQueue()) + .to(deadExchange()) + .with(DEAD_ROUTING_KEY); + } + + + /** + * 注入延迟队列实例 + * + * @return Queue + */ + @Bean + Queue delayQueue() { + Map map = new HashMap<>(); + //设置消息过期时间为30秒 + map.put("x-message-ttl", 1000 * 30); + //设置消息过期后存储的死信交换机 + map.put("x-dead-letter-exchange", DEAD_EXCHANGE_NAME); + //设置死信路由键 + map.put("x-dead-letter-routing-key", DEAD_ROUTING_KEY); + log.info("延迟队列创建成功"); + return new Queue(DELAY_QUEUE_NAME, true, false, false, map); + } + + /** + * 注入延迟交换机实例 + * + * @return DirectExchange + */ + @Bean + DirectExchange delayExchange() { + log.info("延迟交换机创建成功"); + return new DirectExchange(DELAY_EXCHANGE_NAME, true, false); + } + + /** + * 将延迟队列与延迟交换机绑定 + * + * @return + */ + @Bean + Binding delayBinding() { + log.info("延迟通道创建成功"); + return BindingBuilder.bind(deadQueue()) + .to(delayExchange()) + .with(DELAY_ROUTING_KEY); + } + + /** + * 配置RabbitMq序列化器 + * @param connectionFactory + * @return + */ +// @Bean +// public RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory){ +// RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory); +// rabbitTemplate.setMessageConverter(new Jackson2JsonMessageConverter()); +// return rabbitTemplate; +// } + + + +// @Bean +// public MessageConverter jsonMessageConverter(){ +// return new Jackson2JsonMessageConverter(); +// } + + +} diff --git a/zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/constans/OnlineConstants.java b/zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/constans/OnlineConstants.java new file mode 100644 index 0000000..4efc658 --- /dev/null +++ b/zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/constans/OnlineConstants.java @@ -0,0 +1,32 @@ +package com.zhilian.online.constans; + +import lombok.AllArgsConstructor; +import lombok.Data; + +/** + * @BelongsProject: smart-cloud-server + * @BelongsPackage: com.zhilian.online.constans + * @Author: LiYuan + * @CreateTime: 2024-03-31 09:35 + * @Description: 车辆网关上线服务常量 + * @Version: 1.0 + */ +@Data +public class OnlineConstants { + + /** + * 申请注册令牌缓存前缀 + */ + public static final String ONLINE_TOKEN_PREFIX = "online_token:"; + + /** + * 申请令牌过期时间 + */ + public static final Long ONLINE_TOKEN_EXPIRE = 60L; + + /** + * 节点负载前缀 + */ + public static final String NODE_LOAD_PREFIX = "node_load"; + +} diff --git a/zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/consumer/DeadQueueConsumer.java b/zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/consumer/DeadQueueConsumer.java new file mode 100644 index 0000000..f01f88b --- /dev/null +++ b/zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/consumer/DeadQueueConsumer.java @@ -0,0 +1,39 @@ +package com.zhilian.online.consumer; + +import com.alibaba.fastjson.JSON; +import com.zhilian.online.config.RabbitConfig; +import com.zhilian.online.domain.req.GatherRegReq; +import lombok.extern.slf4j.Slf4j; +import org.springframework.amqp.rabbit.annotation.RabbitListener; +import org.springframework.stereotype.Component; + +/** + * @BelongsProject: smart-cloud-server + * @BelongsPackage: com.zhilian.online.consumer + * @Author: LiYuan + * @CreateTime: 2024-03-30 19:57 + * @Description: 监听死信队列消费者 + * @Version: 1.0 + */ +@Component +@Slf4j +public class DeadQueueConsumer { + + + /** + * 消费死信队列中的消息,确保车辆上线成功 + */ + @RabbitListener(queues = RabbitConfig.DEAD_QUEUE_NAME) + public void SecureOnline(String gatherRegReqMsg) { + GatherRegReq gatherRegReq = JSON.parseObject(gatherRegReqMsg, GatherRegReq.class); + log.info("开始检查节点{}的上线状态......", + gatherRegReq.getClientId()); + + + log.info("节点上线成功"); + + log.info("节点上线失败"); + + } + +} diff --git a/zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/controller/OnlineGatherController.java b/zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/controller/OnlineGatherController.java new file mode 100644 index 0000000..966ca20 --- /dev/null +++ b/zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/controller/OnlineGatherController.java @@ -0,0 +1,32 @@ +package com.zhilian.online.controller; + +import com.zhilian.common.core.domain.Result; + +import com.zhilian.online.service.OnlineGatherService; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.validation.annotation.Validated; +import org.springframework.web.bind.annotation.GetMapping; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RestController; + +/** + * @version: + * @Author: LiYuan + * @description: 车辆收集节点控制层 + * @date: 2024/3/29 20:46 + */ +@RestController +@RequestMapping("/gather") +public class OnlineGatherController { + + /** + * 车辆收集节点 + */ + @Autowired + private OnlineGatherService onlineGatherService; + + + + + +} diff --git a/zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/controller/OnlineLoadCenterController.java b/zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/controller/OnlineLoadCenterController.java new file mode 100644 index 0000000..24879eb --- /dev/null +++ b/zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/controller/OnlineLoadCenterController.java @@ -0,0 +1,83 @@ +package com.zhilian.online.controller; + +import com.alibaba.fastjson2.JSON; +import com.zhilian.common.core.domain.Result; +import com.zhilian.common.core.utils.ip.IpUtils; +import com.zhilian.common.core.web.controller.BaseController; + +import com.zhilian.online.domain.Gather; +import com.zhilian.online.domain.req.GatherRegReq; +import com.zhilian.online.service.OnlineLoadCenterService; +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.validation.annotation.Validated; +import org.springframework.web.bind.annotation.GetMapping; +import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RestController; + +import javax.servlet.http.HttpServletRequest; + +/** + * @version: + * @Author: LiYuan + * @description: 负载中心Controller + * @date: 2024/3/29 20:40 + */ +@RestController +@RequestMapping("/load/center") +@Slf4j +public class OnlineLoadCenterController extends BaseController { + + /** + * 请求对象 + */ + @Autowired + private HttpServletRequest request; + + /** + * 车辆收集节点服务层 + */ + @Autowired + private OnlineLoadCenterService onlineLoadCenterService; + + + /** + * @description: 节点申请注解令牌接口,仅限内网访问 + * @author: LiYuan + * @param: vehicle + * @return: Result + **/ + @GetMapping("/applyForReg") + public Result applyForReg(){ + log.info("申请注册令牌"); + return onlineLoadCenterService.applyForReg(); + } + + + /** + * @description: 收集节点注册 + * @author: LiYuan + * @param: Gather + * @return: Result + **/ + @PostMapping("/regGather") + public Result regGather(@Validated Gather gather){ + String ipAddr = IpUtils.getIpAddr(request); + gather.setIpAddress(ipAddr); + log.info("节点{}正在上线",gather); + return onlineLoadCenterService.regGather(gather); + } + + + /** + * 车辆上线至收集节点 + * @return null + */ + public Result getConnectionOption(){ + + return null; + } + + +} diff --git a/zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/controller/OnlineVerifyController.java b/zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/controller/OnlineVerifyController.java new file mode 100644 index 0000000..3e53dd6 --- /dev/null +++ b/zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/controller/OnlineVerifyController.java @@ -0,0 +1,49 @@ +package com.zhilian.online.controller;/** + * @version: + * @Author: LiYuan + * @description: + * @date: 2024/3/30 11:18 + */ + +import com.zhilian.common.core.domain.Result; +import com.zhilian.online.domain.model.MqttServerModel; +import org.springframework.beans.factory.annotation.Value; +import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RestController; + +/** + * @BelongsProject: smart-cloud-server + * @BelongsPackage: com.zhilian.online.controller + * @Author: LiYuan + * @CreateTime: 2024-03-30 11:18 + * @Description: 新增车辆上线验证控制器 + * @Version: 1.0 + */ +@RestController +@RequestMapping("/verify") +public class OnlineVerifyController { + + /** + * 读取配置文件中的mqtt服务地址 + */ + @Value("${mqtt.server.broker}") + private String broker; + + /** + * 读取配置文件中的订阅主题 + */ + @Value("${mqtt.server.topic}") + private String topic; + + @PostMapping("/vehicleConnection") + public Result vehicleConnection() { + return Result.success( + MqttServerModel.builder() + .broker(broker) + .topic(topic) + .build() + ); + } + +} diff --git a/zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/domain/Gather.java b/zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/domain/Gather.java new file mode 100644 index 0000000..251cbdc --- /dev/null +++ b/zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/domain/Gather.java @@ -0,0 +1,72 @@ +package com.zhilian.online.domain; + +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableId; +import com.zhilian.common.core.web.domain.BaseEntity; +import lombok.*; +import org.bouncycastle.util.IPAddress; + +import javax.validation.constraints.NotBlank; + +/** + * @BelongsProject: smart-cloud-server + * @BelongsPackage: com.zhilian.online.domain + * @Author: LiYuan + * @CreateTime: 2024-03-31 08:58 + * @Description: 收集节点实体类 + * @Version: 1.0 + */ +@Data +@AllArgsConstructor +@NoArgsConstructor +@ToString +public class Gather extends BaseEntity { + + /** + * 收集节点ID + */ + @TableId(type = IdType.INPUT) + private String clientId; + +// /** +// * 收集节点登录令牌 +// */ +// @NotBlank +// private String token; + + /** + * broker + */ + @NotBlank + private String broker; + + /** + * username + */ + private String username; + + /** + * password + */ + private String password; + + /** + * qos + */ + private Integer qos; + + /** + * topic + */ + @NotBlank + private String topic; + + /** + * ip地址 + */ + private String ipAddress; + + + + +} diff --git a/zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/domain/Vehicle.java b/zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/domain/Vehicle.java new file mode 100644 index 0000000..c89649c --- /dev/null +++ b/zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/domain/Vehicle.java @@ -0,0 +1,37 @@ +//package com.zhilian.online.domain;/** +// * @version: +// * @Author: LiYuan +// * @description: +// * @date: 2024/3/29 21:44 +// */ +// +//import com.baomidou.mybatisplus.annotation.IdType; +//import com.baomidou.mybatisplus.annotation.TableId; +//import com.baomidou.mybatisplus.annotation.TableName; +//import com.zhilian.common.core.web.domain.BaseEntity; +//import lombok.*; +// +//import javax.validation.constraints.NotBlank; +//import javax.validation.constraints.NotNull; +//import java.util.Date; +// +///** +// *@BelongsProject: smart-cloud-server +// *@BelongsPackage: com.zhilian.online.domain +// *@Author: LiYuan +// *@CreateTime: 2024-03-29 21:44 +// *@Description: 汽车类,测试使用 +// *@Version: 1.0 +// */ +//@Data +////@AllArgsConstructor +////@NoArgsConstructor +//@Builder +//@ToString +//@EqualsAndHashCode(callSuper = true) +//@TableName("vehicle") +//public class Vehicle extends BaseEntity { +// +// +// +//} diff --git a/zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/domain/VehicleAccount.java b/zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/domain/VehicleAccount.java new file mode 100644 index 0000000..2fe49ab --- /dev/null +++ b/zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/domain/VehicleAccount.java @@ -0,0 +1,70 @@ +package com.zhilian.online.domain;/** + * @version: + * @Author: LiYuan + * @description: + * @date: 2024/3/29 21:49 + */ + +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableName; +import com.zhilian.common.core.web.domain.BaseEntity; +import lombok.*; + +import javax.validation.constraints.NotBlank; +import javax.validation.constraints.NotNull; +import java.util.Date; + +/** + *@BelongsProject: smart-cloud-server + *@BelongsPackage: com.zhilian.online.domain + *@Author: LiYuan + *@CreateTime: 2024-03-29 21:49 + *@Description: 车辆申请注册成功后返回的一次性账户数据 + *@Version: 1.0 + */ + +@Data +@AllArgsConstructor +@NotBlank +@ToString +@EqualsAndHashCode(callSuper = true) +@TableName("vehicle_account") +public class VehicleAccount extends BaseEntity{ + + + /** + * 车辆VIN + */ + @TableId(type = IdType.INPUT) + private String vin; + + + /** + * 申请时间 + */ + @NotNull + private Date applyTime; + + /** + * 申请唯一标识 + */ + @NotBlank + private String applyCode; + + /** + * 一次性用户名 + */ + private String username; + + /** + * 一次性密码 + */ + private String password; + + /** + * 可以进行连接的收集节点id + */ + private String clientId; + +} diff --git a/zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/domain/model/MqttServerModel.java b/zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/domain/model/MqttServerModel.java new file mode 100644 index 0000000..78cc718 --- /dev/null +++ b/zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/domain/model/MqttServerModel.java @@ -0,0 +1,37 @@ +package com.zhilian.online.domain.model;/** + * @version: + * @Author: LiYuan + * @description: + * @date: 2024/3/30 11:19 + */ + +import lombok.AllArgsConstructor; +import lombok.Builder; +import lombok.Data; +import lombok.NoArgsConstructor; + +/** + *@BelongsProject: smart-cloud-server + *@BelongsPackage: com.zhilian.online.domain.model + *@Author: LiYuan + *@CreateTime: 2024-03-30 11:19 + *@Description: Mqtt服务模型 + *@Version: 1.0 + */ +@Data +@Builder +@NoArgsConstructor +@AllArgsConstructor +public class MqttServerModel { + + /** + * Mqtt服务节点 + */ + private String broker; + + /** + * Mqtt订阅主题 + */ + private String topic; + +} diff --git a/zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/domain/req/GatherRegReq.java b/zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/domain/req/GatherRegReq.java new file mode 100644 index 0000000..b568938 --- /dev/null +++ b/zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/domain/req/GatherRegReq.java @@ -0,0 +1,34 @@ +package com.zhilian.online.domain.req; + +import lombok.*; + +import javax.validation.constraints.NotBlank; + +/** + * @BelongsProject: smart-cloud-server + * @BelongsPackage: com.zhilian.online.domain.req + * @Author: LiYuan + * @CreateTime: 2024-03-31 09:03 + * @Description: 节点申请注册请求体 + * @Version: 1.0 + */ +@Data +@AllArgsConstructor +@NoArgsConstructor +@ToString +@Builder +public class GatherRegReq { + + /** + * 客户端ID + */ + @NotBlank + private String clientId; + + /** + * 令牌 + */ + private String token; + + +} diff --git a/zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/mapper/OnlineGatherMapper.java b/zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/mapper/OnlineGatherMapper.java new file mode 100644 index 0000000..d7e5e62 --- /dev/null +++ b/zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/mapper/OnlineGatherMapper.java @@ -0,0 +1,17 @@ +package com.zhilian.online.mapper; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import org.apache.ibatis.annotations.Mapper; + +/** + * @version: + * @Author: LiYuan + * @description: 车辆收集节点数据层 + * @date: 2024/3/29 20:48 + */ +@Mapper +public interface OnlineGatherMapper{ + + + +} diff --git a/zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/mapper/OnlineLoadCenterMapper.java b/zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/mapper/OnlineLoadCenterMapper.java new file mode 100644 index 0000000..b1df908 --- /dev/null +++ b/zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/mapper/OnlineLoadCenterMapper.java @@ -0,0 +1,18 @@ +package com.zhilian.online.mapper; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.zhilian.online.domain.VehicleAccount; +import org.apache.ibatis.annotations.Mapper; + +/** + * @version: + * @Author: LiYuan + * @description: 车辆负载中心数据层 + * @date: 2024/3/29 20:45 + */ +@Mapper +public interface OnlineLoadCenterMapper extends BaseMapper { + + + +} diff --git a/zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/service/OnlineGatherService.java b/zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/service/OnlineGatherService.java new file mode 100644 index 0000000..60ae8e3 --- /dev/null +++ b/zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/service/OnlineGatherService.java @@ -0,0 +1,14 @@ +package com.zhilian.online.service; + +import com.baomidou.mybatisplus.extension.service.IService; +import com.zhilian.common.core.domain.Result; + + +/** + * @version: + * @Author: LiYuan + * @description: 车辆收集节点Service接口 + * @date: 2024/3/29 20:48 + */ +public interface OnlineGatherService{ +} diff --git a/zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/service/OnlineLoadCenterService.java b/zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/service/OnlineLoadCenterService.java new file mode 100644 index 0000000..b1a3e35 --- /dev/null +++ b/zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/service/OnlineLoadCenterService.java @@ -0,0 +1,32 @@ +package com.zhilian.online.service; + +import com.baomidou.mybatisplus.extension.service.IService; +import com.zhilian.common.core.domain.Result; +import com.zhilian.online.domain.Gather; +import com.zhilian.online.domain.VehicleAccount; +import com.zhilian.online.domain.req.GatherRegReq; + +/** + * @version: + * @Author: LiYuan + * @description: 车辆负载中心服务接口 + * @date: 2024/3/29 20:42 + */ +public interface OnlineLoadCenterService extends IService { + + /** + * @description: 车辆申请注解令牌接口,仅限内网访问 + * @author: LiYuan + * @param: vehicle + * @return: Result + **/ + Result applyForReg(); + + /** + * @description: 车辆使用申请的一次性账户连接收集节点 + * @author: LiYuan + * @param: + * @return: Result + **/ + Result regGather(Gather gather); +} diff --git a/zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/service/impl/OnlineGatherServiceImpl.java b/zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/service/impl/OnlineGatherServiceImpl.java new file mode 100644 index 0000000..6f2bd7f --- /dev/null +++ b/zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/service/impl/OnlineGatherServiceImpl.java @@ -0,0 +1,22 @@ +package com.zhilian.online.service.impl; + +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.zhilian.common.core.domain.Result; +import com.zhilian.online.mapper.OnlineGatherMapper; +import com.zhilian.online.service.OnlineGatherService; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; + +/** + * @version: + * @Author: LiYuan + * @description: 车辆收集节点服务层 + * @date: 2024/3/29 20:48 + */ +@Service +public class OnlineGatherServiceImpl implements OnlineGatherService { + + @Autowired + private OnlineGatherMapper onlineGatherMapper; + +} diff --git a/zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/service/impl/OnlineLoadCenterServiceImpl.java b/zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/service/impl/OnlineLoadCenterServiceImpl.java new file mode 100644 index 0000000..4872f89 --- /dev/null +++ b/zhilian-modules/zhilian-online/src/main/java/com/zhilian/online/service/impl/OnlineLoadCenterServiceImpl.java @@ -0,0 +1,96 @@ +package com.zhilian.online.service.impl; + +import com.alibaba.fastjson.JSON; +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.zhilian.common.core.domain.Result; +import com.zhilian.common.core.utils.uuid.IdUtils; +import com.zhilian.common.redis.service.RedisService; +import com.zhilian.online.config.RabbitConfig; +import com.zhilian.online.constans.OnlineConstants; +import com.zhilian.online.domain.Gather; +import com.zhilian.online.domain.VehicleAccount; +import com.zhilian.online.domain.req.GatherRegReq; +import com.zhilian.online.mapper.OnlineLoadCenterMapper; +import com.zhilian.online.service.OnlineLoadCenterService; +import lombok.extern.slf4j.Slf4j; +import org.springframework.amqp.rabbit.core.RabbitTemplate; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; + +import java.util.concurrent.TimeUnit; + +/** + * @version 1.0 + * @Author LiYuan + * @description 车辆负载中心服务层 + * @date 2024/3/29 20:42 + */ +@Service +@Slf4j +public class OnlineLoadCenterServiceImpl extends ServiceImpl implements OnlineLoadCenterService { + + /** + * 车辆负载中心数据层 + */ + @Autowired + private OnlineLoadCenterMapper onlineLoadCenterMapper; + + /** + * Redis服务 + */ + @Autowired + private RedisService redisService; + + /** + * RabbitMQ服务 + */ + @Autowired + private RabbitTemplate rabbitTemplate; + + /** + * @description: 车辆申请注解令牌接口, 仅限内网访问 + * @author: LiYuan + * @param: vehicle + * @return: Result + **/ + @Override + public Result applyForReg() { + + //生成一次性令牌 + String token = IdUtils.fastSimpleUUID(); + + //将令牌信息缓存到Redis中 + redisService.setCacheObject(OnlineConstants.ONLINE_TOKEN_PREFIX , token, OnlineConstants.ONLINE_TOKEN_EXPIRE, TimeUnit.MINUTES); + + //将账户信息返回客户端 + return Result.success(token); + } + + + /** + * @description: 节点上线成功 + * @author: LiYuan + * @param: Gather + * @return: Result + **/ + @Override + public Result regGather(Gather gather) { +// //判断登录令牌是否过期,一致 +// if (redisService.hasKey(OnlineConstants.ONLINE_TOKEN_PREFIX + gather.getClientId())) { +// return Result.error("令牌已过期"); +// } + + //为该节点创建负载均衡缓存 + if (redisService.hasKey(OnlineConstants.ONLINE_TOKEN_PREFIX + gather.getClientId())) { + redisService.deleteObject(OnlineConstants.ONLINE_TOKEN_PREFIX + gather.getClientId()); + } + redisService.setCacheZsetValue(OnlineConstants.ONLINE_TOKEN_PREFIX + gather.getClientId(), gather, 0.0); + +// //向RabbitMQ||RocketMQ发送30s延迟消息,确保后续节点上线 +// rabbitTemplate.convertAndSend(RabbitConfig.DELAY_EXCHANGE_NAME, RabbitConfig.DELAY_ROUTING_KEY, JSON.toJSONString(gather)); + + return Result.success("节点上线"); + } + + +} diff --git a/zhilian-modules/zhilian-online/src/main/resources/banner.txt b/zhilian-modules/zhilian-online/src/main/resources/banner.txt index 0dd5eee..1ed50ba 100644 --- a/zhilian-modules/zhilian-online/src/main/resources/banner.txt +++ b/zhilian-modules/zhilian-online/src/main/resources/banner.txt @@ -1,2 +1,25 @@ Spring Boot Version: ${spring-boot.version} Spring Application Name: ${spring.application.name} + /* + * God Bless No Bugs! + * + * _ooOoo_ + * o8888888o + * 88" . "88 + * (| -_- |) + * O\ = /O + * ____/`---'\____ + * .' \\| |// `. + * / \\||| : |||// \ + * / _||||| -:- |||||- \ + * | | \\\ - /// | | + * | \_| ''\---/'' | | + * \ .-\__ `-` ___/-. / + * ___`. .' /--.--\ `. . __ + * ."" '< `.___\_<|>_/___.' >'"". + * | | : `- \`.;`\ _ /`;.`/ - ` : | | + * \ \ `-. \_ __\ /__ _/ .-` / / + * ======`-.____`-.___\_____/___.-`____.-'====== + * `=---=' + * ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ +*/ diff --git a/zhilian-modules/zhilian-online/src/main/resources/mapper/online/OnlineGatherMapper.xml b/zhilian-modules/zhilian-online/src/main/resources/mapper/online/OnlineGatherMapper.xml new file mode 100644 index 0000000..a9fbb43 --- /dev/null +++ b/zhilian-modules/zhilian-online/src/main/resources/mapper/online/OnlineGatherMapper.xml @@ -0,0 +1,7 @@ + + + + + \ No newline at end of file diff --git a/zhilian-modules/zhilian-online/src/main/resources/mapper/online/OnlineLoadCenterMapper.xml b/zhilian-modules/zhilian-online/src/main/resources/mapper/online/OnlineLoadCenterMapper.xml new file mode 100644 index 0000000..cd710a6 --- /dev/null +++ b/zhilian-modules/zhilian-online/src/main/resources/mapper/online/OnlineLoadCenterMapper.xml @@ -0,0 +1,7 @@ + + + + + \ No newline at end of file diff --git a/zhilian-modules/zhilian-resolver/src/main/java/com/zhilian/resolver/ZhilianResolverApplication.java b/zhilian-modules/zhilian-resolver/src/main/java/com/zhilian/resolver/ZhilianResolverApplication.java new file mode 100644 index 0000000..041108b --- /dev/null +++ b/zhilian-modules/zhilian-resolver/src/main/java/com/zhilian/resolver/ZhilianResolverApplication.java @@ -0,0 +1,19 @@ +package com.zhilian.resolver; + +import org.springframework.boot.SpringApplication; +import org.springframework.boot.autoconfigure.SpringBootApplication; + +/** + * @BelongsProject: smart-cloud-server + * @BelongsPackage: com.zhilian.resolver + * @Author: LiYuan + * @CreateTime: 2024-03-31 10:11 + * @Description: TODO + * @Version: 1.0 + */ +@SpringBootApplication +public class ZhilianResolverApplication { + public static void main(String[] args) { + SpringApplication.run(ZhilianResolverApplication.class,args); + } +} -- 2.40.1