a_bazu
/
cloud-server-8
5
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Compare commits

base: a_bazu:e6e7e58f953d943c46ac7b18ca85e4010c2ca3bb
Branches Tags
a_bazu:dev.wei
a_bazu:dev
a_bazu:dev.carData
a_bazu:xxy
a_bazu:dev.cargateway
a_bazu:dev.yang
a_bazu:master
a_bazu:psr
a_bazu:dev.xxy
a_bazu:dev.zhang
a_bazu:dev.peng
..
compare: a_bazu:0d82041676cde4c3a8e61d579c964421dfae44aa
Branches Tags
a_bazu:dev.wei
a_bazu:dev
a_bazu:dev.carData
a_bazu:xxy
a_bazu:dev.cargateway
a_bazu:dev.yang
a_bazu:master
a_bazu:psr
a_bazu:dev.xxy
a_bazu:dev.zhang
a_bazu:dev.peng

No commits in common. "e6e7e58f953d943c46ac7b18ca85e4010c2ca3bb" and "0d82041676cde4c3a8e61d579c964421dfae44aa" have entirely different histories.
e6e7e58f95 ... 0d82041676

52 changed files with 306 additions and 1465 deletions
Show Stats Expand all files Collapse all files

0
JavaSample-tcp150158332341883/.lck
View File

2
cloud-auth/src/main/resources/bootstrap.yml
View File

@ -7,7 +7,7 @@ nacos:
addr: 159.75.188.178:8848
user-name: nacos
password: nacos
namespace: xxy
namespace: eight
# Spring
spring:
application:

33
cloud-common/cloud-common-kafka/pom.xml
View File

@ -1,33 +0,0 @@
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>com.muyu</groupId>
<artifactId>cloud-common</artifactId>
<version>3.6.3</version>
</parent>
<artifactId>cloud-common-kafka</artifactId>
<properties>
<maven.compiler.source>17</maven.compiler.source>
<maven.compiler.target>17</maven.compiler.target>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
<dependencies>
<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka-clients</artifactId>
<version>3.0.0</version>
</dependency>
<!-- 项目公共核心 -->
<dependency>
<groupId>com.muyu</groupId>
<artifactId>cloud-common-core</artifactId>
</dependency>
</dependencies>
</project>

1
cloud-common/cloud-common-kafka/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports
View File

@ -1 +0,0 @@
com.muyu.kafkaconfig.KafkaConfig

2
cloud-gateway/src/main/resources/bootstrap.yml
View File

@ -7,7 +7,7 @@ nacos:
addr: 159.75.188.178:8848
user-name: nacos
password: nacos
namespace: xxy
namespace: eight
# Spring
spring:

9
cloud-modules/cloud-modules-carData/pom.xml
View File

@ -11,10 +11,6 @@
<artifactId>cloud-modules-carData</artifactId>
<description>
数据处理模块
</description>
<properties>
<maven.compiler.source>17</maven.compiler.source>
<maven.compiler.target>17</maven.compiler.target>
@ -87,8 +83,9 @@
<version>2.9.3</version>
</dependency>
<dependency>
<groupId>com.muyu</groupId>
<artifactId>cloud-common-kafka</artifactId>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka-clients</artifactId>
<version>3.0.0</version>
</dependency>
<dependency>
<groupId>org.apache.iotdb</groupId>

3
cloud-modules/cloud-modules-carData/src/main/java/com/muyu/carData/CarDataApplication.java
View File

@ -4,6 +4,9 @@ import com.muyu.carData.listener.MyListener;
import com.muyu.common.security.annotation.EnableMyFeignClients;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.openfeign.EnableFeignClients;
import javax.swing.*;
/**
* @Author：张腾

18
cloud-modules/cloud-modules-carData/src/main/java/com/muyu/carData/annotation/IoTTableName.java 100644
View File

@ -0,0 +1,18 @@
package com.muyu.carData.annotation;
import java.lang.annotation.*;
/**
* @Author：张腾
* @Package：com.muyu.carData.annotation
* @Project：cloud-server-8
* @name：IoTTableName
* @Date：2024/9/27 19:29
*/
@Documented
@Retention(RetentionPolicy.RUNTIME)
@Target({ElementType.TYPE, ElementType.ANNOTATION_TYPE})
public @interface IoTTableName {
String value() default "";
}

5
cloud-common/cloud-common-kafka/src/main/java/com/muyu/kafkaconfig/KafkaConfig.java → cloud-modules/cloud-modules-carData/src/main/java/com/muyu/carData/config/kafkaconfig/KafkaConfig.java
View File

@ -1,4 +1,4 @@
package com.muyu.kafkaconfig;
package com.muyu.carData.config.kafkaconfig;
import org.apache.kafka.clients.consumer.KafkaConsumer;
import org.apache.kafka.clients.producer.KafkaProducer;
@ -17,8 +17,7 @@ import java.util.HashMap;
* @Date：2024/9/28 12:19
*/
@Configuration
public class
KafkaConfig {
public class KafkaConfig {
@Bean
public KafkaProducer kafkaProducer(){

13
cloud-modules/cloud-modules-carData/src/main/java/com/muyu/carData/constract/IoTDBTableParam.java 100644
View File

@ -0,0 +1,13 @@
package com.muyu.carData.constract;
/**
* @Author：张腾
* @Package：com.muyu.carData.constract
* @Project：cloud-server-8
* @name：IoTDBTableParam
* @Date：2024/9/27 20:02
*/
public class IoTDBTableParam {
public static final String SYSLOG_IOT_TABLE = "student";
}

11
cloud-modules/cloud-modules-carData/src/main/java/com/muyu/carData/consumer/MyKafkaConsumer.java
View File

@ -29,7 +29,7 @@ public class MyKafkaConsumer implements InitializingBean {
@Autowired
private KafkaConsumer kafkaConsumer;
private final String topicName = "carJsons";
private final String topicName = "test";
@Override
public void afterPropertiesSet() throws Exception {
@ -43,14 +43,13 @@ public class MyKafkaConsumer implements InitializingBean {
for (ConsumerRecord<String, String> consumerRecord : consumerRecords) {
//从consumerRecord中获取消费数据
String value = consumerRecord.value();
log.info("从Kafka中消费的原始数据===============>>：{}",value);
log.info("从Kafka中消费的原始数据：{}",value);
//转换为java对象
Student stu = JSONUtil.toBean(value, Student.class);
log.info("消费数据转换为Java对象：{}",stu);
}
}
});
thread.start();
log.info("启动线程结束监听topic:{}",topicName);
}
}

47
cloud-modules/cloud-modules-carData/src/main/java/com/muyu/carData/domain/IoTDBRecord.java 100644
View File

@ -0,0 +1,47 @@
package com.muyu.carData.domain;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.util.List;
/**
* @Author：张腾
* @Package：com.muyu.carData.domain
* @Project：cloud-server-8
* @name：IoTDBRecord
* @Date：2024/9/27 19:25
*/
@Data
@Builder
@AllArgsConstructor
@NoArgsConstructor
public class IoTDBRecord {
/**
* 节点路径
*/
private String deviceId;
/**
* 时间戳
*/
private long time = System.currentTimeMillis();
/**
* 属性
*/
private List<String> measurementList;
/**
* 属性值
*/
private List<Object> valueList;
/**
* 数据类型
*/
private List<String> typeList;
}

53
cloud-modules/cloud-modules-carData/src/main/java/com/muyu/carData/interfaces/IoTDBRecordable.java 100644
View File

@ -0,0 +1,53 @@
package com.muyu.carData.interfaces;
import com.muyu.carData.annotation.IoTTableName;
import com.muyu.carData.domain.IoTDBRecord;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.lang.reflect.Field;
import java.lang.reflect.Method;
import java.util.ArrayList;
/**
* @Author：张腾
* @Package：com.muyu.carData.interfaces
* @Project：cloud-server-8
* @name：IoTDBRecordable
* @Date：2024/9/27 19:22
* iot基类
*/
public interface IoTDBRecordable {
Logger logger = LoggerFactory.getLogger(IoTDBRecordable.class);
/**
* 数据载入方法
* @return Record
*/
default IoTDBRecord toRecord() throws Exception {
IoTDBRecord ioTDBRecord = new IoTDBRecord();
Object getIoTDBTime = this.getClass().getMethod("getIoTDBTime").invoke(this);
if (null != getIoTDBTime){
ioTDBRecord.setTime((Long) getIoTDBTime);
}
Class aClass = this.getClass();
IoTTableName name = this.getClass().getAnnotation(IoTTableName.class);
ioTDBRecord.setDeviceId(name.value());
Field[] declaredFields = aClass.getDeclaredFields();
ArrayList<String> measurements = new ArrayList<>();
ArrayList<Object> records = new ArrayList<>();
ArrayList<String> types = new ArrayList<>();
for (Field declaredField : declaredFields) {
measurements.add(declaredField.getName());
String methodNamePro = declaredField.getName().substring(0, 1).toUpperCase() + declaredField.getName().substring(1);
Method methodName = this.getClass().getMethod("get" + methodNamePro);
records.add(methodName.invoke(this));
types.add(methodName.getReturnType().getName());
}
ioTDBRecord.setMeasurementList(measurements);
ioTDBRecord.setValueList(records);
ioTDBRecord.setTypeList(types);
return ioTDBRecord;
}
}

10
cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-common/src/main/java/com/muyu/domain/CarMessage.java
View File

@ -11,7 +11,6 @@ import java.util.function.Supplier;
/**
* 车辆报文模板实体类
*
* @author 17353
*/
@Data
@ -19,7 +18,7 @@ import java.util.function.Supplier;
@NoArgsConstructor
@Builder
@Tag(name = "车辆报文模板实体类")
@TableName(value = "car_message", autoResultMap = true)
@TableName(value = "car_message",autoResultMap = true)
public class CarMessage {
//报文类型模块表
/**
@ -69,11 +68,8 @@ public class CarMessage {
*/
private Integer carMessageState;
private String carMessageName;
/**
* 修改方法
*
* @param carMessage
* @param supplier
* @return
@ -96,7 +92,6 @@ public class CarMessage {
/**
* 添加方法
*
* @param carMessage
* @return
*/
@ -132,4 +127,7 @@ public class CarMessage {
*/
}

17
cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-common/src/main/java/com/muyu/domain/KafKaData.java
View File

@ -1,17 +0,0 @@
package com.muyu.domain;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
@Data
@AllArgsConstructor
@NoArgsConstructor
@Builder
public class KafKaData {
private String key;
private String type;
private String label;
private String value;
}

18
cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-server/pom.xml
View File

@ -28,12 +28,6 @@
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
</dependency>
<!-- mqttv3 -->
<dependency>
<groupId>org.eclipse.paho</groupId>
<artifactId>org.eclipse.paho.client.mqttv3</artifactId>
<version>1.2.2</version>
</dependency>
<!-- SpringCloud Alibaba Nacos Config -->
<dependency>
<groupId>com.alibaba.cloud</groupId>
@ -44,6 +38,17 @@
<groupId>org.apache.kafka</groupId>
<artifactId>kafka-clients</artifactId>
</dependency>
<!--远调端Feign-->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>
<!-- mqttv3 -->
<dependency>
<groupId>org.eclipse.paho</groupId>
<artifactId>org.eclipse.paho.client.mqttv3</artifactId>
<version>1.2.2</version>
</dependency>
<!-- SpringCloud Alibaba Sentinel -->
<dependency>
<groupId>com.alibaba.cloud</groupId>
@ -98,6 +103,7 @@
<groupId>com.muyu</groupId>
<artifactId>cloud-common-kafka</artifactId>
<version>3.6.3</version>
<scope>compile</scope>
</dependency>
</dependencies>
<build>

18
cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-server/src/main/java/com/muyu/server/feign/KafkaClient.java 100644
View File

@ -0,0 +1,18 @@
//package com.muyu.server.feign;
//
//import org.springframework.cloud.openfeign.FeignClient;
//import org.springframework.web.bind.annotation.GetMapping;
//
//@FeignClient(name = "cloud-modules-carData",value = "KafkaProducerController")
//public abstract class KafkaClient {
// /**
// * 处理"/produceTest"的GET请求，用于执行特定的测试任务
// * 此方法的具体实现将在子类中定义
// * @return 返回类型为String，表示该方法的执行结果
// * @return
// */
// @GetMapping("/produceTest")
// public abstract String produceTest();
//
//
//}

105
cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-server/src/main/java/com/muyu/server/mqtt/Demo.java 100644
View File

@ -0,0 +1,105 @@
package com.muyu.server.mqtt;
import com.alibaba.fastjson.JSONObject;
import com.muyu.common.kafka.constants.KafkaConstants;
import com.muyu.domain.CarMessage;
import com.muyu.server.service.CarMessageService;
import jakarta.annotation.PostConstruct;
import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.clients.producer.ProducerRecord;
import org.eclipse.paho.client.mqttv3.*;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.CompletableFuture;
@Component
public class Demo {
@Resource
private CarMessageService service;
@Resource
private KafkaProducer<String, String> kafkaProducer;
@PostConstruct
public void test() {
String topic = "vehicle";
String content = "Message from MqttPublishSample";
int qos = 2;
String broker = "tcp://106.15.136.7:1883";
String clientId = "JavaSample";
try {
// 第三个参数为空，默认持久化策略
MqttClient sampleClient = new MqttClient(broker, clientId);
MqttConnectOptions connOpts = new MqttConnectOptions();
connOpts.setCleanSession(true);
System.out.println("Connecting to broker: "+broker);
sampleClient.connect(connOpts);
sampleClient.subscribe(topic,0);
sampleClient.setCallback(new MqttCallback() {
// 连接丢失
@Override
public void connectionLost(Throwable throwable) {
}
// 连接成功
@Override
public void messageArrived(String s, MqttMessage mqttMessage) throws Exception {
List<CarMessage> list= service.selectCarMessageList(1,2);
String str = new String( mqttMessage.getPayload() );
System.out.println(str);
String[] test = str.split(" ");
String[] results = new String[list.size()];
List<CompletableFuture<String>> futures = new ArrayList<>();
for (CarMessage carmsg : list) {
futures.add(CompletableFuture.supplyAsync(() -> {
int startIndex = Integer.parseInt(String.valueOf(carmsg.getCarMessageStartIndex())) - 1;
int endIndex = Integer.parseInt(String.valueOf(carmsg.getCarMessageEndIndex()));
StringBuilder hexBuilder = new StringBuilder();
for (int j = startIndex; j < endIndex; j++) {
hexBuilder.append(test[j]);
}
// 创建16进制的对象
String hex = hexBuilder.toString();
// 转橙字符数组
char[] result = new char[hex.length() / 2];
for (int x = 0; x < hex.length(); x += 2) {
// 先转十进制
int high = Character.digit(hex.charAt(x), 16);
// 转二进制
int low = Character.digit(hex.charAt(x + 1), 16);
// 转字符
result[x / 2] = (char) ((high << 4) + low);
}
return new String(result);
}));
}
for (int i = 0; i < futures.size(); i++) {
results[i] = futures.get(i).get();
}
String jsonString = JSONObject.toJSONString( results );
ProducerRecord<String, String> producerRecord = new ProducerRecord<>( KafkaConstants.KafkaTopic, jsonString);
kafkaProducer.send(producerRecord);
}
// 接收信息
@Override
public void deliveryComplete(IMqttDeliveryToken iMqttDeliveryToken) {
}
});
} catch(MqttException me) {
System.out.println("reason "+me.getReasonCode());
System.out.println("msg "+me.getMessage());
System.out.println("loc "+me.getLocalizedMessage());
System.out.println("cause "+me.getCause());
System.out.println("excep "+me);
me.printStackTrace();
}
}
}

7
cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-server/src/main/java/com/muyu/server/service/CarMessageService.java
View File

@ -53,4 +53,11 @@ public interface CarMessageService extends IService<CarMessage> {
* 获取报文最终信息
*/
JSONObject inciseCarMessage(String testString);
List<CarMessage> selectCarMessageList(int i, int i1);
}

8
cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-server/src/main/java/com/muyu/server/service/impl/CarMessageServiceImpl.java
View File

@ -110,6 +110,14 @@ public class CarMessageServiceImpl
return null;
}
@Override
public List<CarMessage> selectCarMessageList(int id, int modelCode) {
LambdaQueryWrapper<CarMessage> queryWrapper = new LambdaQueryWrapper<>();
queryWrapper.eq(CarMessage::getCarMessageId, id);
queryWrapper.eq(CarMessage::getCarMessageType, modelCode);
return this.list(queryWrapper);
}
//报文处理

2
cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-server/src/main/java/com/muyu/server/service/message/MessageDao.java
View File

@ -26,7 +26,7 @@ public class MessageDao {
}
public void sendMessage(Message message) throws Exception{
String sql="INSERT INTO `xxy`.`car_fault_message` (`id`, `sender`, `receiver`, `content`, `status`, `create_time`, `user_id`) " +
String sql="INSERT INTO `eight`.`car_fault_message` (`id`, `sender`, `receiver`, `content`, `status`, `create_time`, `user_id`) " +
"VALUES (NULL, NULL, NULL, NULL, NULL, NULL, NULL)";
try(PreparedStatement pstmt=connection.prepareStatement(sql)){
pstmt.setString(1, message.getContent());

2
cloud-modules/cloud-modules-file/src/main/resources/bootstrap.yml
View File

@ -7,7 +7,7 @@ nacos:
addr: 159.75.188.178:8848
user-name: nacos
password: nacos
namespace: xxy
namespace: eight
# Spring
spring:

2
cloud-modules/cloud-modules-gen/src/main/resources/bootstrap.yml
View File

@ -7,7 +7,7 @@ nacos:
addr: 159.75.188.178:8848
user-name: nacos
password: nacos
namespace: xxy
namespace: eight
# Spring
spring:

108
cloud-modules/cloud-modules-protocolparsing/pom.xml
View File

@ -1,108 +0,0 @@
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>com.muyu</groupId>
<artifactId>cloud-modules</artifactId>
<version>3.6.3</version>
</parent>
<artifactId>cloud-modules-protocolparsing</artifactId>
<dependencies>
<!--远调端Feign-->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>
<!-- mqttv3 -->
<dependency>
<groupId>org.eclipse.paho</groupId>
<artifactId>org.eclipse.paho.client.mqttv3</artifactId>
<version>1.2.2</version>
</dependency>
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
</dependency>
<!-- SpringCloud Alibaba Nacos Config -->
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
</dependency>
<!--apache.kafka<-->
<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka-clients</artifactId>
</dependency>
<!-- SpringCloud Alibaba Sentinel -->
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
</dependency>
<!-- SpringBoot Actuator -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
<!-- Mysql Connector -->
<dependency>
<groupId>com.mysql</groupId>
<artifactId>mysql-connector-j</artifactId>
</dependency>
<!-- MuYu Common DataSource -->
<dependency>
<groupId>com.muyu</groupId>
<artifactId>cloud-common-datasource</artifactId>
</dependency>
<!-- MuYu Common DataScope -->
<dependency>
<groupId>com.muyu</groupId>
<artifactId>cloud-common-datascope</artifactId>
</dependency>
<!-- MuYu Common Log -->
<dependency>
<groupId>com.muyu</groupId>
<artifactId>cloud-common-log</artifactId>
</dependency>
<!-- 接口模块 -->
<dependency>
<groupId>com.muyu</groupId>
<artifactId>cloud-common-api-doc</artifactId>
</dependency>
<dependency>
<groupId>com.muyu</groupId>
<artifactId>cloud-modules-enterprise-common</artifactId>
<version>1.0.0</version>
</dependency>
<dependency>
<groupId>com.github.yulichang</groupId>
<artifactId>mybatis-plus-join-boot-starter</artifactId>
<version>1.4.13</version>
</dependency>
<dependency>
<groupId>com.github.pagehelper</groupId>
<artifactId>pagehelper</artifactId>
<version>6.0.0</version>
</dependency>
<dependency>
<groupId>com.muyu</groupId>
<artifactId>cloud-common-kafka</artifactId>
<version>3.6.3</version>
</dependency>
<!--caffeine-->
<dependency>
<groupId>com.github.ben-manes.caffeine</groupId>
<artifactId>caffeine</artifactId>
<version>2.9.3</version>
</dependency>
</dependencies>
<properties>
<maven.compiler.source>17</maven.compiler.source>
<maven.compiler.target>17</maven.compiler.target>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
</project>

19
cloud-modules/cloud-modules-protocolparsing/src/main/java/com/muyu/ProtocolApplication.java
View File

@ -1,19 +0,0 @@
package com.muyu;
import cn.hutool.json.JSONUtil;
import com.muyu.common.security.annotation.EnableMyFeignClients;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@EnableMyFeignClients
@SpringBootApplication
public class ProtocolApplication {
public static void main(String[] args) {
System.out.println("");
SpringApplication.run(ProtocolApplication.class, args);
}
}

29
cloud-modules/cloud-modules-protocolparsing/src/main/java/com/muyu/cache/bean/MyCache.java vendored
View File

@ -1,29 +0,0 @@
package com.muyu.cache.bean;
import lombok.Data;
@Data
public class MyCache {
/**
* 缓存key --键
*/
private String key;
/**
* 缓存value --值
*/
private Object value;
/**
* 缓存过期时间 --单位秒
*/
private Long expireTime;
}

93
cloud-modules/cloud-modules-protocolparsing/src/main/java/com/muyu/cache/utill/CacheUtill.java vendored
View File

@ -1,93 +0,0 @@
package com.muyu.cache.utill;
import com.muyu.cache.bean.MyCache;
import java.time.Duration;
import java.util.Iterator;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
/**
* 自定义本地缓存工具类
*/
public class CacheUtill {
/**
* 缓存数据Map
*/
private static final Map<String , MyCache> CACHE_MAP = new ConcurrentHashMap<>();
/**
* 定时器线程池 用于清理过期缓存
*/
private static final ScheduledExecutorService executorService = Executors.newSingleThreadScheduledExecutor();
static {
// 注册一个定时小鹌鹑线程任务,当服务启动了1秒之后,每隔500毫秒执行一次定时任务
//定时清理过期缓存
executorService.scheduleAtFixedRate(CacheUtill::clearCache,1000,500,TimeUnit.MILLISECONDS);
}
/**
* 添加缓存
* @param key 缓存建
* @param value
* @param expire
*/
public static void put(String key ,Object value,long expire){
MyCache myCache = new MyCache();
myCache.setKey(key);
myCache.setValue(value);
if (expire > 0 ){
long expireTime = System.currentTimeMillis() + Duration.ofSeconds(expire).toMillis();
myCache.setExpireTime(expireTime);
}
CACHE_MAP.put(key ,myCache);
}
/**
* 获取缓存
* @param key 缓存键
* @return 缓存的数据
*/
public static Object get(String key){
if(CACHE_MAP.containsKey(key)){
return CACHE_MAP.get(key).getValue();
}
return null;
}
/**
* 移除缓存
* @param key
*/
public static void remove(String key){
CACHE_MAP.remove(key);
}
/**
* 清理过期的缓存数据
*/
private static void clearCache(){
if(CACHE_MAP.size() <= 0){
return;
}
//判断是否过期,过期的话从缓存MAP中删除这个元素
CACHE_MAP.entrySet().removeIf(entry -> entry.getValue().getExpireTime() != null && entry.getValue().getExpireTime() > System.currentTimeMillis());
}
}

38
cloud-modules/cloud-modules-protocolparsing/src/main/java/com/muyu/controller/CarMessageController.java
View File

@ -1,38 +0,0 @@
package com.muyu.controller;
import com.muyu.common.core.domain.Result;
import com.muyu.domain.CarMessage;
import com.muyu.service.CarMessageService;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.extern.log4j.Log4j2;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource;
import java.util.List;
/**
* 报文模板展示列表控制层
*/
@Log4j2
@RestController
@RequestMapping("/carMessage")
@Tag(name = "信息报文模块" )
public class CarMessageController {
/**
* 测试分割字符
*/
}

135
cloud-modules/cloud-modules-protocolparsing/src/main/java/com/muyu/domain/CarMessage.java
View File

@ -1,135 +0,0 @@
package com.muyu.domain;
import com.baomidou.mybatisplus.annotation.TableName;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.util.function.Supplier;
/**
* 车辆报文模板实体类
*
* @author 17353
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@Builder
@Tag(name = "车辆报文模板实体类")
@TableName(value = "car_message", autoResultMap = true)
public class CarMessage {
//报文类型模块表
/**
* 自增主键
*/
private Long messageTypeId;
/**
* 报文编码
*/
private String messageTypeCode;
/**
* 报文名称
*/
private String messageTypeName;
/**
* 报文所属类别
*/
private String messageTypeBelongs;
//报文拆分位置主表
/**
* 自增主键
*/
private Long carMessageId;
/**
* 车辆类型外键
*/
private Integer carMessageCartype;
/**
* 车辆报文类型外键
*/
private Integer carMessageType;
/**
* 开始位下标
*/
private Integer carMessageStartIndex;
/**
* 结束位下标
*/
private Integer carMessageEndIndex;
/**
* 报文数据类型 (固定值 区间随机值)
*/
private String messageTypeClass;
/**
* 报文是否开启故障检测(0默认未开启 1开启)
*/
private Integer carMessageState;
private String carMessageName;
/**
* 修改方法
*
* @param carMessage
* @param supplier
* @return
*/
public static CarMessage carMessageUpdBuilder(CarMessage carMessage, Supplier<Long> supplier) {
return CarMessage.builder()
.messageTypeId(supplier.get())
.messageTypeCode(carMessage.messageTypeCode)
.messageTypeName(carMessage.messageTypeName)
.messageTypeBelongs(carMessage.messageTypeBelongs)
.carMessageId(carMessage.carMessageId)
.carMessageCartype(carMessage.carMessageCartype)
.carMessageType(carMessage.carMessageType)
.carMessageStartIndex(carMessage.carMessageStartIndex)
.carMessageEndIndex(carMessage.carMessageEndIndex)
.messageTypeClass(carMessage.messageTypeClass)
.carMessageState(carMessage.carMessageState)
.build();
}
/**
* 添加方法
*
* @param carMessage
* @return
*/
public static CarMessage carMessageAddBuilder(CarMessage carMessage) {
return CarMessage.builder()
.messageTypeCode(carMessage.messageTypeCode)
.messageTypeName(carMessage.messageTypeName)
.messageTypeBelongs(carMessage.messageTypeBelongs)
.carMessageId(carMessage.carMessageId)
.carMessageCartype(carMessage.carMessageCartype)
.carMessageType(carMessage.carMessageType)
.carMessageStartIndex(carMessage.carMessageStartIndex)
.carMessageEndIndex(carMessage.carMessageEndIndex)
.messageTypeClass(carMessage.messageTypeClass)
.carMessageState(carMessage.carMessageState)
.build();
}
/*
private Long messageTypeId ;
private String messageTypeCode ;
private String messageTypeName ;
private String messageTypeBelongs ;
private String messageTypeClass ;
private Long carMessageId ;
private Integer carMessageCartype ;
private Integer carMessageType ;
private Integer carMessageStartIndex ;
private Integer carMessageEndIndex ;
private Integer carMessageState ;
*/
}

38
cloud-modules/cloud-modules-protocolparsing/src/main/java/com/muyu/domain/CarMessageType.java
View File

@ -1,38 +0,0 @@
package com.muyu.domain;
import com.baomidou.mybatisplus.annotation.TableName;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
* 车辆报文所属类型
*/
@Data
@Builder
@AllArgsConstructor
@NoArgsConstructor
@Tag(name = "车辆报文所属类型")
@TableName(value = "car_message_type",autoResultMap = true)
public class CarMessageType {
/**
* 自增主键
*/
private Integer messageTypeId ;
/**
* 报文编码
*/
private String messageTypeCode ;
/**
* 报文名称
*/
private String messageTypeName ;
/**
* 报文所属类别
*/
private String messageTypeBelongs ;
}

17
cloud-modules/cloud-modules-protocolparsing/src/main/java/com/muyu/domain/KafKaData.java
View File

@ -1,17 +0,0 @@
package com.muyu.domain;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
@Data
@AllArgsConstructor
@NoArgsConstructor
@Builder
public class KafKaData {
private String key;
private String type;
private String label;
private String value;
}

57
cloud-modules/cloud-modules-protocolparsing/src/main/java/com/muyu/domain/resp/CarMessageResp.java
View File

@ -1,57 +0,0 @@
package com.muyu.domain.resp;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
* 车辆报文信息(预警)响应对象
* @Author：蓬叁
* @Package：com.muyu.warn.domain.car
* @Project：cloud-server-8
* @name：resp
* @Date：2024/9/22 下午7:12
*/
@Data
@Builder
@AllArgsConstructor
@NoArgsConstructor
@Tag(name = "车辆报文信息")
public class CarMessageResp {
/**
* 自增主键
*/
private Integer carMessageId ;
/**
* 车辆类型外键
*/
private Integer carMessageCartype ;
/**
* 车辆报文外键
*/
private Integer carMessageType ;
/**
* 报文名称
*/
private String messageTypeName ;
/**
* 开始位下标
*/
private Integer carMessageStartIndex ;
/**
* 结束位下标
*/
private Integer carMessageEndIndex ;
/**
* 报文数据类型 (固定值 区间随机值)
*/
private String messageTypeClass ;
/**
* 报文是否开启故障检测(0默认未开启 1开启)
*/
private Integer carMessageState ;
}

19
cloud-modules/cloud-modules-protocolparsing/src/main/java/com/muyu/feign/KafkaClient.java
View File

@ -1,19 +0,0 @@
package com.muyu.feign;
import com.alibaba.fastjson2.JSONObject;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;
@FeignClient(name = "cloud-modules-carData")
public interface KafkaClient {
/**
* 处理"/produceTest"的GET请求，用于执行特定的测试任务
* 此方法的具体实现将在子类中定义
* @return 返回类型为String，表示该方法的执行结果
* @return
*/
@GetMapping("/produce/producer")
public abstract String producerKafka(JSONObject data);
}

24
cloud-modules/cloud-modules-protocolparsing/src/main/java/com/muyu/mapper/CarInformationMapper.java
View File

@ -1,24 +0,0 @@
package com.muyu.mapper;
import com.github.yulichang.base.MPJBaseMapper;
import com.muyu.domain.CarInformation;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import org.apache.ibatis.annotations.Select;
/**
* 车辆信息管理持久层
*/
@Mapper
public interface CarInformationMapper extends MPJBaseMapper<CarInformation> {
/**
* 根据车辆VIN码获取车辆类型(报文模板分类用的值)
* @param carInformationVIN
* @return
*/
@Select("SELECT `car_information`.car_Information_Type FROM `car_information` WHERE `car_information`.car_information_VIN = #{carInformationVIN}")
Long selectcarMessageCartype(@Param("carInformationVIN") String carInformationVIN);
}

17
cloud-modules/cloud-modules-protocolparsing/src/main/java/com/muyu/mapper/CarMessageMapper.java
View File

@ -1,17 +0,0 @@
package com.muyu.mapper;
import com.github.yulichang.base.MPJBaseMapper;
import com.muyu.domain.CarMessage;
import org.apache.ibatis.annotations.Mapper;
import java.util.List;
/**
* 报文模板展示列表持久层
*/
@Mapper
public interface CarMessageMapper extends MPJBaseMapper<CarMessage> {
}

12
cloud-modules/cloud-modules-protocolparsing/src/main/java/com/muyu/mapper/CarMessagePlusMapper.java
View File

@ -1,12 +0,0 @@
package com.muyu.mapper;
import com.muyu.domain.CarMessage;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import java.util.List;
@Mapper
public interface CarMessagePlusMapper {
List<CarMessage> selectCarMessageList(@Param("carMessageCartype") Integer carMessageCartype);
}

8
cloud-modules/cloud-modules-protocolparsing/src/main/java/com/muyu/mapper/CarMessageTypeMapper.java
View File

@ -1,8 +0,0 @@
package com.muyu.mapper;
import com.github.yulichang.base.MPJBaseMapper;
import com.muyu.domain.CarMessageType;
public interface CarMessageTypeMapper extends MPJBaseMapper<CarMessageType> {
}

117
cloud-modules/cloud-modules-protocolparsing/src/main/java/com/muyu/mqtt/MqttTest.java
View File

@ -1,117 +0,0 @@
package com.muyu.mqtt;
import com.alibaba.fastjson2.JSONObject;
import com.muyu.domain.CarMessage;
import com.muyu.domain.KafKaData;
import com.muyu.service.CarMessageService;
import lombok.extern.slf4j.Slf4j;
import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.clients.producer.ProducerRecord;
import org.eclipse.paho.client.mqttv3.*;
import org.springframework.stereotype.Component;
import javax.annotation.PostConstruct;
import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.List;
/**
* mqtt
*
* @ClassName MqttTest
*/
@Slf4j
@Component
public class MqttTest {
private static final Integer ID = 1;
private static final Integer CODE = 1;
@Resource
private KafkaProducer<String, String> kafkaProducer;
@Resource
private CarMessageService sysCarMessageService;
@PostConstruct
public void Test() {
String topic = "vehicle";
String content = "Message from MqttPublishSample";
int qos = 2;
String broker = "tcp://60.204.221.52:1883";
String clientId = "JavaSample";
try {
// 第三个参数为空，默认持久化策略
MqttClient sampleClient = new MqttClient(broker, clientId);
MqttConnectOptions connOpts = new MqttConnectOptions();
connOpts.setCleanSession(true);
System.out.println("Connecting to broker: " + broker);
sampleClient.connect(connOpts);
sampleClient.subscribe(topic, 0);
sampleClient.setCallback(new MqttCallback() {
// 连接丢失
@Override
public void connectionLost(Throwable throwable) {
}
// 连接成功
@Override
public void messageArrived(String s, MqttMessage mqttMessage) throws Exception {
List<CarMessage> list = sysCarMessageService.selectCarMessage(1);
String string = new String(mqttMessage.getPayload());
log.info(new String(mqttMessage.getPayload()));
List<KafKaData> kafKaDataList = new ArrayList<>();
String[] test = string.split(" ");
// String[] results = new String[list.size()];
for (CarMessage carMessage : list) {
int startIndex = Integer.parseInt(String.valueOf(carMessage.getCarMessageStartIndex())) - 1;
int endIndex = Integer.parseInt(String.valueOf(carMessage.getCarMessageEndIndex()));
StringBuilder hexBuilder = new StringBuilder();
for (int i = startIndex; i < endIndex; i++) {
hexBuilder.append(test[i]);
}
String hex = hexBuilder.toString();
char[] result = new char[hex.length() / 2];
for (int x = 0; x < hex.length(); x += 2) {
int high = Character.digit(hex.charAt(x), 16);
int low = Character.digit(hex.charAt(x + 1), 16);
result[x / 2] = (char) ((high << 4) + low);
}
String value = new String(result);
kafKaDataList.add(KafKaData.builder()
.key(carMessage.getMessageTypeCode())
.label(carMessage.getMessageTypeCode())
.value(value)
.type("String")
.build());
}
String jsonString = JSONObject.toJSONString(kafKaDataList);
ProducerRecord<String, String> producerRecord = new ProducerRecord<>("carJsons",jsonString);
kafkaProducer.send(producerRecord);
log.info("kafka投产：{}", jsonString);
// HashMap<String, String> stringStringHashMap = new HashMap<>();
// kafKaDataList.forEach(data -> stringStringHashMap.put(data.getKey(), data.getValue()));
// jsonString = JSONObject.toJSONString(stringStringHashMap);
// System.out.println(jsonString);
}
// 接收信息
@Override
public void deliveryComplete(IMqttDeliveryToken iMqttDeliveryToken) {
}
});
} catch (MqttException me) {
System.out.println("reason " + me.getReasonCode());
System.out.println("msg " + me.getMessage());
System.out.println("loc " + me.getLocalizedMessage());
System.out.println("cause " + me.getCause());
System.out.println("excep " + me);
me.printStackTrace();
}
}
}

166
cloud-modules/cloud-modules-protocolparsing/src/main/java/com/muyu/mqtt/ParsingMQTT.java
View File

@ -1,166 +0,0 @@
package com.muyu.mqtt;//package com.muyu.server.mqtt;
//
//import com.muyu.analysis.parsing.remote.RemoteClientService;
//import com.muyu.common.core.constant.KafkaConstants;
//import com.muyu.common.core.constant.RedisConstants;
//import com.muyu.common.core.domain.Result;
//import com.muyu.enterprise.domain.resp.car.MessageValueListResp;
//import com.muyu.server.feign.KafkaClient;
//import jakarta.annotation.PostConstruct;
//import jakarta.annotation.Resource;
//import cn.hutool.json.JSONObject;
//import com.alibaba.fastjson.JSON;
//import lombok.extern.log4j.Log4j2;
//import org.apache.kafka.clients.producer.KafkaProducer;
//import org.apache.kafka.clients.producer.ProducerRecord;
//import org.eclipse.paho.client.mqttv3.*;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.data.redis.core.RedisTemplate;
//import org.springframework.stereotype.Component;
//
//import java.util.List;
//
///**
// * 协议解析处理数据发送传送到队列
// * @Author：李庆帅
// * @Package：com.muyu.analysis.parsing.MQTT
// * @Project：cloud-server
// * @name：ParsingMQTT
// * @Date：2024/9/29 16:08
// */
//@Log4j2
//@Component
//public class ParsingMQTT {
//
// @Resource
// private RedisTemplate<String, Object> redisTemplate;
//
// @Autowired
// private KafkaClient remoteServiceClient;
//
// @Resource
// private KafkaProducer<String, String> kafkaProducer;
//
// /**
// * 协议解析
// */
// @PostConstruct
// public void mqttClient() {
// String topic = "vehicle";
// String broker = "tcp://106.15.136.7:1883";
// String clientId = "JavaSample";
//
// try {
// // 第三个参数为空，默认持久化策略
// MqttClient sampleClient = new MqttClient(broker, clientId);
// MqttConnectOptions connOpts = new MqttConnectOptions();
// connOpts.setCleanSession(true);
// System.out.println("Connecting to broker: " + broker);
// sampleClient.connect(connOpts);
// sampleClient.subscribe(topic, 0);
// sampleClient.setCallback(new MqttCallback() {
// // 连接丢失
// @Override
// public void connectionLost(Throwable throwable) {
//
// }
//
// // 连接成功
// @Override
// public void messageArrived(String s, MqttMessage mqttMessage) throws Exception {
// System.out.println(new String(mqttMessage.getPayload()));
// JSONObject entries = this.protocolParsing(new String(mqttMessage.getPayload()));
//
// ProducerRecord<String, String> producerRecord = new ProducerRecord<>(KafkaConstants.MESSAGE_PARSING,
// entries.toString() );
// kafkaProducer.send(producerRecord);
// log.info("解析之后的数据"+entries);
//
// }
//
// /**
// * 协议解析
// * @param messageStr
// * @return
// */
// public JSONObject protocolParsing(String messageStr) {
// //根据空格切割数据
// String[] hexArray = messageStr.split(" ");
// StringBuilder result = new StringBuilder();
// //遍历十六进制数据转换为字符
// for (String hex : hexArray) {
// int decimal = Integer.parseInt(hex, 16);
// result.append((char) decimal);
// }
// //取出车辆VIN码
// String vehicleVin = result.substring(1, 18);
// log.info("车辆VIN码: " + vehicleVin);
// //根据车辆VIN码查询报文模板ID
// Result<Long> byVehicleVin = remoteServiceClient.findByVehicleVin(vehicleVin);
// Long templateId = byVehicleVin.getData();
// List<MessageValueListResp> templateList;
// //从redis缓存中获取报文模板数据
// try {
// String redisKey = RedisConstants.MESSAGE_TEMPLATE + templateId;
// if (redisTemplate.hasKey(redisKey)) {
// List<Object> list = redisTemplate.opsForList().range(redisKey, 0, -1);
// templateList = list.stream()
// .map(obj -> JSON.parseObject(obj.toString(), MessageValueListResp.class))
// .toList();
// log.info("Redis缓存查询成功");
// } else {
// Result<List<MessageValueListResp>> byTemplateId = remoteServiceClient.producerKafka(templateId);
// templateList = byTemplateId.getData();
// templateList.forEach(
// listResp ->
// redisTemplate.opsForList().rightPush(
// redisKey, JSON.toJSONString(listResp)
// )
// );
// log.info("数据库查询成功："+byTemplateId);
// }
// } catch (Exception e) {
// log.info("获取报文模板失败");
// throw new RuntimeException("获取报文模板失败");
// }
// //判断报文模板列表不为空
// if (templateList.isEmpty()) {
// log.info("报文模版为空");
// throw new RuntimeException("报文模版为空");
// }
// //存储报文模版解析后的数据
// JSONObject jsonObject = new JSONObject();
// for (MessageValueListResp messageValue : templateList) {
// //起始位下标
// Integer startIndex = messageValue.getMessageStartIndex() - 1;
// //结束位下标
// Integer endIndex = messageValue.getMessageEndIndex();
// //根据报文模版截取数据
// String value = result.substring(startIndex, endIndex);
// //存入数据
// jsonObject.put(messageValue.getMessageLabel(), value);
// }
// return jsonObject;
// }
//
// // 接收信息
// @Override
// public void deliveryComplete(IMqttDeliveryToken iMqttDeliveryToken) {
//
// }
// });
// } catch (MqttException me) {
// log.info("reason " + me.getReasonCode());
// log.info("msg " + me.getMessage());
// log.info("loc " + me.getLocalizedMessage());
// log.info("cause " + me.getCause());
// log.info("excep " + me);
// me.printStackTrace();
// }
// }
//
//
//
//
//
//}

35
cloud-modules/cloud-modules-protocolparsing/src/main/java/com/muyu/service/CarMessageService.java
View File

@ -1,35 +0,0 @@
package com.muyu.service;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.extension.service.IService;
import com.muyu.domain.CarMessage;
import com.muyu.domain.resp.CarMessageResp;
import org.apache.ibatis.annotations.Param;
import java.util.List;
/**
* 报文模板展示列表业务层
*/
public interface CarMessageService extends IService<CarMessage> {
//报文切割
/**
* 分割字符串
* 解析字符
* 获取报文最终信息
*/
JSONObject inciseCarMessage(String testString);
List<CarMessage> selectCarMessageList(int modelCode);
List<CarMessage> selectCarMessage(@Param("carMessageCartype") Integer carMessageCartype);
List<CarMessage> selectCarMessageListAll(int i);
}

137
cloud-modules/cloud-modules-protocolparsing/src/main/java/com/muyu/service/impl/CarMessageServiceImpl.java
View File

@ -1,137 +0,0 @@
package com.muyu.service.impl;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.github.yulichang.wrapper.MPJLambdaWrapper;
import com.muyu.common.core.utils.StringUtils;
import com.muyu.domain.CarMessage;
import com.muyu.domain.resp.CarMessageResp;
import com.muyu.mapper.CarInformationMapper;
import com.muyu.mapper.CarMessageMapper;
import com.muyu.mapper.CarMessagePlusMapper;
import com.muyu.service.CarMessageService;
import lombok.extern.log4j.Log4j2;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.util.List;
import java.util.Objects;
/**
* 报文模板展示列表业务实现层
*/
@Log4j2
@Service
public class CarMessageServiceImpl
extends ServiceImpl<CarMessageMapper, CarMessage>
implements CarMessageService {
@Resource
private CarMessageMapper carMessageMapper;
@Resource
private CarMessagePlusMapper carMessagePlusMapper;
@Resource
private CarInformationMapper carInformationMapper;
@Override
public List<CarMessage> selectCarMessageList(int modelCode) {
LambdaQueryWrapper<CarMessage> queryWrapper = new LambdaQueryWrapper<>();
queryWrapper.eq(CarMessage::getCarMessageCartype, modelCode);
return this.list(queryWrapper);
}
@Override
public List<CarMessage> selectCarMessage(Integer carMessageCartype) {
return carMessagePlusMapper.selectCarMessageList(carMessageCartype);
}
@Override
public List<CarMessage> selectCarMessageListAll(int i) {
LambdaQueryWrapper<CarMessage> queryWrapper = new LambdaQueryWrapper<>();
queryWrapper.eq(CarMessage::getCarMessageCartype, i);
return this.list(queryWrapper);
}
@Override
public JSONObject inciseCarMessage(String testString) {
return null;
}
//报文处理
// @Resource
// private RedisTemplate<String , Objects> redisTemplate;
// /**
// * 报文解析
// * @param testString
// * @return
// */
// @Override
// public JSONObject inciseCarMessage(String testString) {
// //根据空格拆分切割数据字符串
// String[] split = testString.split(" ");
// StringBuilder stringBuilder = new StringBuilder();
// for (String conversion : split) {
// //将16进制字符串转换为对应的10进制
// int inciseindex = Integer.parseInt(conversion, 16);
// // 将10进制转换为对应的字符
// stringBuilder.append((char) inciseindex);
// }
// //切取车辆VIN
// String substring = stringBuilder.substring(1, 18);
// log.info("车辆的VIN码:" + substring);
// //根据给定的vehicleVin（车辆VIN号）获取对应的模板车辆分类carMessageCartype
// String selectcared = carInformationMapper.selectcarMessageCartype(substring);
// //创建接受数据的数组
// List<CarMessage> messagesList ;
//
// try{
// String redisKey = "carMessageList" + selectcared;
//
// if (redisTemplate.hasKey(redisKey)){
// List<Objects> list = redisTemplate.opsForList().range(redisKey , 0, -1);
// messagesList = list.stream()
// .map(objects -> JSON.parseObject(objects.toString(), CarMessage.class))
// .toList();
// log.info("Redis缓存查询成功");
// }else {
// messagesList = carInformationMapper.selectcarMessageCartype(selectcared);
//
// messagesList.forEach(
// listReq -> redisTemplate.opsForList().rightPushAll(redisKey, JSON.toString(listReq) )
// );
// log.info("数据库查询成功");
// }
// }catch(Exception e){
// throw new RuntimeException("获取报文模板失败");
// }
// //判断报文模板 列表 不为空
// if(messagesList.isEmpty()){
// throw new RuntimeException("报文模版为空");
// }
// //存储报文模板解析后的数据
// JSONObject jsonObject = new JSONObject();
// for (CarMessage carMessage : messagesList) {
// //起始位下标
// Integer startIndex = carMessage.getCarMessageStartIndex();
// //结束位下标
// Integer endIndex = carMessage.getCarMessageEndIndex();
// //根据报文模板获取保温截取位置
// String value = stringBuilder.substring(startIndex, endIndex);
// //存入数据
// jsonObject.put(carMessage.getMessageTypeName(), value);
//
// }
// return jsonObject;
//
// }
}

1
cloud-modules/cloud-modules-protocolparsing/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports
View File

@ -1 +0,0 @@

2
cloud-modules/cloud-modules-protocolparsing/src/main/resources/banner.txt
View File

@ -1,2 +0,0 @@
Spring Boot Version: ${spring-boot.version}
Spring Application Name: ${spring.application.name}

47
cloud-modules/cloud-modules-protocolparsing/src/main/resources/bootstrap.yml
View File

@ -1,47 +0,0 @@
# Tomcat
server:
port: 9112
# nacos线上地址
nacos:
addr: 159.75.188.178:8848
user-name: nacos
password: nacos
namespace: xxy
# Spring
spring:
application:
# 应用名称
name: cloud-electronic
profiles:
# 环境配置
active: dev
cloud:
nacos:
discovery:
# 服务注册地址
server-addr: ${nacos.addr}
# nacos用户名
username: ${nacos.user-name}
# nacos密码
password: ${nacos.password}
# 命名空间
namespace: ${nacos.namespace}
config:
# 服务注册地址
server-addr: ${nacos.addr}
# nacos用户名
username: ${nacos.user-name}
# nacos密码
password: ${nacos.password}
# 命名空间
namespace: ${nacos.namespace}
# 配置文件格式
file-extension: yml
# 共享配置
shared-configs:
# 系统共享配置
- application-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension}
# 系统环境Config共享配置
- application-config-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension}

74
cloud-modules/cloud-modules-protocolparsing/src/main/resources/logback/dev.xml
View File

@ -1,74 +0,0 @@
<?xml version="1.0" encoding="UTF-8"?>
<configuration scan="true" scanPeriod="60 seconds" debug="false">
<!-- 日志存放路径 -->
<property name="log.path" value="logs/cloud-electronic"/>
<!-- 日志输出格式 -->
<property name="log.pattern" value="%d{HH:mm:ss.SSS} [%thread] %-5level %logger{20} - [%method,%line] - %msg%n"/>
<!-- 控制台输出 -->
<appender name="console" class="ch.qos.logback.core.ConsoleAppender">
<encoder>
<pattern>${log.pattern}</pattern>
</encoder>
</appender>
<!-- 系统日志输出 -->
<appender name="file_info" class="ch.qos.logback.core.rolling.RollingFileAppender">
<file>${log.path}/info.log</file>
<!-- 循环政策：基于时间创建日志文件 -->
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
<!-- 日志文件名格式 -->
<fileNamePattern>${log.path}/info.%d{yyyy-MM-dd}.log</fileNamePattern>
<!-- 日志最大的历史 60天 -->
<maxHistory>60</maxHistory>
</rollingPolicy>
<encoder>
<pattern>${log.pattern}</pattern>
</encoder>
<filter class="ch.qos.logback.classic.filter.LevelFilter">
<!-- 过滤的级别 -->
<level>INFO</level>
<!-- 匹配时的操作：接收（记录） -->
<onMatch>ACCEPT</onMatch>
<!-- 不匹配时的操作：拒绝（不记录） -->
<onMismatch>DENY</onMismatch>
</filter>
</appender>
<appender name="file_error" class="ch.qos.logback.core.rolling.RollingFileAppender">
<file>${log.path}/error.log</file>
<!-- 循环政策：基于时间创建日志文件 -->
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
<!-- 日志文件名格式 -->
<fileNamePattern>${log.path}/error.%d{yyyy-MM-dd}.log</fileNamePattern>
<!-- 日志最大的历史 60天 -->
<maxHistory>60</maxHistory>
</rollingPolicy>
<encoder>
<pattern>${log.pattern}</pattern>
</encoder>
<filter class="ch.qos.logback.classic.filter.LevelFilter">
<!-- 过滤的级别 -->
<level>ERROR</level>
<!-- 匹配时的操作：接收（记录） -->
<onMatch>ACCEPT</onMatch>
<!-- 不匹配时的操作：拒绝（不记录） -->
<onMismatch>DENY</onMismatch>
</filter>
</appender>
<!-- 系统模块日志级别控制 -->
<logger name="com.muyu" level="info"/>
<!-- Spring日志级别控制 -->
<logger name="org.springframework" level="warn"/>
<root level="info">
<appender-ref ref="console"/>
</root>
<!--系统操作日志-->
<root level="info">
<appender-ref ref="file_info"/>
<appender-ref ref="file_error"/>
</root>
</configuration>

81
cloud-modules/cloud-modules-protocolparsing/src/main/resources/logback/prod.xml
View File

@ -1,81 +0,0 @@
<?xml version="1.0" encoding="UTF-8"?>
<configuration scan="true" scanPeriod="60 seconds" debug="false">
<!-- 日志存放路径 -->
<property name="log.path" value="logs/cloud-electronic"/>
<!-- 日志输出格式 -->
<property name="log.pattern" value="%d{HH:mm:ss.SSS} [%thread] %-5level %logger{20} - [%method,%line] - %msg%n"/>
<property name="log.sky.pattern" value="%d{HH:mm:ss.SSS} %yellow([%tid]) [%thread] %-5level %logger{20} - [%method,%line] - %msg%n"/>
<!-- 控制台输出 -->
<appender name="console" class="ch.qos.logback.core.ConsoleAppender">
<encoder>
<pattern>${log.sky.pattern}</pattern>
</encoder>
</appender>
<!-- 系统日志输出 -->
<appender name="file_info" class="ch.qos.logback.core.rolling.RollingFileAppender">
<file>${log.path}/info.log</file>
<!-- 循环政策：基于时间创建日志文件 -->
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
<!-- 日志文件名格式 -->
<fileNamePattern>${log.path}/info.%d{yyyy-MM-dd}.log</fileNamePattern>
<!-- 日志最大的历史 60天 -->
<maxHistory>60</maxHistory>
</rollingPolicy>
<filter class="ch.qos.logback.classic.filter.LevelFilter">
<!-- 过滤的级别 -->
<level>INFO</level>
<!-- 匹配时的操作：接收（记录） -->
<onMatch>ACCEPT</onMatch>
<!-- 不匹配时的操作：拒绝（不记录） -->
<onMismatch>DENY</onMismatch>
</filter>
</appender>
<appender name="file_error" class="ch.qos.logback.core.rolling.RollingFileAppender">
<file>${log.path}/error.log</file>
<!-- 循环政策：基于时间创建日志文件 -->
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
<!-- 日志文件名格式 -->
<fileNamePattern>${log.path}/error.%d{yyyy-MM-dd}.log</fileNamePattern>
<!-- 日志最大的历史 60天 -->
<maxHistory>60</maxHistory>
</rollingPolicy>
<filter class="ch.qos.logback.classic.filter.LevelFilter">
<!-- 过滤的级别 -->
<level>ERROR</level>
<!-- 匹配时的操作：接收（记录） -->
<onMatch>ACCEPT</onMatch>
<!-- 不匹配时的操作：拒绝（不记录） -->
<onMismatch>DENY</onMismatch>
</filter>
</appender>
<!-- 使用gRpc将日志发送到skywalking服务端 -->
<appender name="GRPC_LOG" class="org.apache.skywalking.apm.toolkit.log.logback.v1.x.log.GRPCLogClientAppender">
<encoder class="ch.qos.logback.core.encoder.LayoutWrappingEncoder">
<layout class="org.apache.skywalking.apm.toolkit.log.logback.v1.x.TraceIdPatternLogbackLayout">
<Pattern>${log.sky.pattern}</Pattern>
</layout>
</encoder>
</appender>
<!-- 系统模块日志级别控制 -->
<logger name="com.muyu" level="info"/>
<!-- Spring日志级别控制 -->
<logger name="org.springframework" level="warn"/>
<root level="info">
<appender-ref ref="GRPC_LOG"/>
<appender-ref ref="console"/>
</root>
<!--系统操作日志-->
<root level="info">
<appender-ref ref="file_info"/>
<appender-ref ref="file_error"/>
</root>
</configuration>

81
cloud-modules/cloud-modules-protocolparsing/src/main/resources/logback/test.xml
View File

@ -1,81 +0,0 @@
<?xml version="1.0" encoding="UTF-8"?>
<configuration scan="true" scanPeriod="60 seconds" debug="false">
<!-- 日志存放路径 -->
<property name="log.path" value="logs/cloud-electronic"/>
<!-- 日志输出格式 -->
<property name="log.pattern" value="%d{HH:mm:ss.SSS} [%thread] %-5level %logger{20} - [%method,%line] - %msg%n"/>
<property name="log.sky.pattern" value="%d{HH:mm:ss.SSS} %yellow([%tid]) [%thread] %-5level %logger{20} - [%method,%line] - %msg%n"/>
<!-- 控制台输出 -->
<appender name="console" class="ch.qos.logback.core.ConsoleAppender">
<encoder>
<pattern>${log.sky.pattern}</pattern>
</encoder>
</appender>
<!-- 系统日志输出 -->
<appender name="file_info" class="ch.qos.logback.core.rolling.RollingFileAppender">
<file>${log.path}/info.log</file>
<!-- 循环政策：基于时间创建日志文件 -->
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
<!-- 日志文件名格式 -->
<fileNamePattern>${log.path}/info.%d{yyyy-MM-dd}.log</fileNamePattern>
<!-- 日志最大的历史 60天 -->
<maxHistory>60</maxHistory>
</rollingPolicy>
<filter class="ch.qos.logback.classic.filter.LevelFilter">
<!-- 过滤的级别 -->
<level>INFO</level>
<!-- 匹配时的操作：接收（记录） -->
<onMatch>ACCEPT</onMatch>
<!-- 不匹配时的操作：拒绝（不记录） -->
<onMismatch>DENY</onMismatch>
</filter>
</appender>
<appender name="file_error" class="ch.qos.logback.core.rolling.RollingFileAppender">
<file>${log.path}/error.log</file>
<!-- 循环政策：基于时间创建日志文件 -->
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
<!-- 日志文件名格式 -->
<fileNamePattern>${log.path}/error.%d{yyyy-MM-dd}.log</fileNamePattern>
<!-- 日志最大的历史 60天 -->
<maxHistory>60</maxHistory>
</rollingPolicy>
<filter class="ch.qos.logback.classic.filter.LevelFilter">
<!-- 过滤的级别 -->
<level>ERROR</level>
<!-- 匹配时的操作：接收（记录） -->
<onMatch>ACCEPT</onMatch>
<!-- 不匹配时的操作：拒绝（不记录） -->
<onMismatch>DENY</onMismatch>
</filter>
</appender>
<!-- 使用gRpc将日志发送到skywalking服务端 -->
<appender name="GRPC_LOG" class="org.apache.skywalking.apm.toolkit.log.logback.v1.x.log.GRPCLogClientAppender">
<encoder class="ch.qos.logback.core.encoder.LayoutWrappingEncoder">
<layout class="org.apache.skywalking.apm.toolkit.log.logback.v1.x.TraceIdPatternLogbackLayout">
<Pattern>${log.sky.pattern}</Pattern>
</layout>
</encoder>
</appender>
<!-- 系统模块日志级别控制 -->
<logger name="com.muyu" level="info"/>
<!-- Spring日志级别控制 -->
<logger name="org.springframework" level="warn"/>
<root level="info">
<appender-ref ref="GRPC_LOG"/>
<appender-ref ref="console"/>
</root>
<!--系统操作日志-->
<root level="info">
<appender-ref ref="file_info"/>
<appender-ref ref="file_error"/>
</root>
</configuration>

15
cloud-modules/cloud-modules-protocolparsing/src/main/resources/mapper/CarMessageMapper.xml
View File

@ -1,15 +0,0 @@
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper
PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<!-- 1.在mybats的开发中namespace有特殊的意思，一定要是对应接口的全限定名通过namespace可以简历mapper.xml和接口之间的关系(名字不重要，位置不重要)-->
<mapper namespace="com.muyu.mapper.CarMessagePlusMapper">
<select id="selectCarMessageList" resultType="com.muyu.domain.CarMessage">
select * from `car_message` where car_message_cartype = #{carMessageCartype}
</select>
</mapper>

2
cloud-modules/cloud-modules-system/src/main/resources/bootstrap.yml
View File

@ -7,7 +7,7 @@ nacos:
addr: 159.75.188.178:8848
user-name: nacos
password: nacos
namespace: xxy
namespace: eight
# SPRING_AMQP_DESERIALIZATION_TRUST_ALL=true spring.amqp.deserialization.trust.all
# Spring
spring:

1
cloud-modules/pom.xml
View File

@ -14,7 +14,6 @@
<module>cloud-modules-gen</module>
<module>cloud-modules-file</module>
<module>cloud-modules-carData</module>
<module>cloud-modules-protocolparsing</module>
</modules>
<artifactId>cloud-modules</artifactId>

2
cloud-visual/cloud-visual-monitor/src/main/resources/bootstrap.yml
View File

@ -7,7 +7,7 @@ nacos:
addr: 159.75.188.178:8848
user-name: nacos
password: nacos
namespace: xxy
namespace: eight
# Spring
spring:

10
pom.xml
View File

@ -10,7 +10,7 @@
<name>muyu</name>
<url>http://www.muyu.vip</url>
<description>智能车联系统</description>
<description>若依微服务系统</description>
<properties>
<muyu.version>3.6.3</muyu.version>
@ -42,7 +42,6 @@
<hutool.version>5.8.27</hutool.version>
<knife4j-openapi3.version>4.1.0</knife4j-openapi3.version>
<xxl-job-core.version>2.4.1</xxl-job-core.version>
<kafka.version>3.6.3</kafka.version>
</properties>
<!-- 依赖声明 -->
@ -219,13 +218,6 @@
<version>${muyu.version}</version>
</dependency>
<!--kafka-->
<dependency>
<groupId>com.muyu</groupId>
<artifactId>cloud-common-kafka</artifactId>
<version>${kafka.version}</version>
</dependency>
<!-- 分布式事务 -->
<dependency>
<groupId>com.muyu</groupId>