增加服务端config与event相关类
This commit is contained in:
luolianxin
parent
f804b0eea5
commit
54df592222
|
|
@ -0,0 +1,53 @@
|
|||
package com.aisino.iles.lawenforcement.config;
|
||||
|
||||
import org.springframework.context.annotation.Bean;
|
||||
import org.springframework.context.annotation.Configuration;
|
||||
import org.springframework.scheduling.annotation.EnableAsync;
|
||||
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
|
||||
|
||||
import java.util.concurrent.Executor;
|
||||
import java.util.concurrent.ThreadPoolExecutor;
|
||||
|
||||
@Configuration
|
||||
@EnableAsync
|
||||
public class AsyncConfig {
|
||||
|
||||
/**
|
||||
* 定义一个专用于@Async任务的线程池Bean。
|
||||
* Spring Boot会自动检测到这个Bean，并用它来执行所有@Async方法。
|
||||
*/
|
||||
@Bean
|
||||
public Executor asyncTaskExecutor() {
|
||||
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
|
||||
|
||||
// 核心线程数：线程池中保持的最小线程数，即使它们处于空闲状态。
|
||||
// 通常设置为CPU核心数，以充分利用CPU资源。
|
||||
int corePoolSize = Runtime.getRuntime().availableProcessors();
|
||||
executor.setCorePoolSize(corePoolSize);
|
||||
|
||||
// 最大线程数：线程池允许创建的最大线程数。
|
||||
// 对于I/O密集型任务（如我们的数据同步），可以设置得比核心数大很多。
|
||||
executor.setMaxPoolSize(corePoolSize * 2);
|
||||
|
||||
// 队列容量：当所有核心线程都在忙时，新任务会进入这个队列等待。
|
||||
// 设置一个合理的队列容量可以应对突发流量。
|
||||
executor.setQueueCapacity(200);
|
||||
|
||||
// 线程名称前缀：为线程池中的线程设置一个有意义的前缀。
|
||||
// 这对于日志分析和问题排查至关重要。
|
||||
executor.setThreadNamePrefix("async-task-");
|
||||
|
||||
// 拒绝策略：当线程池和队列都满了之后，如何处理新来的任务。
|
||||
// CallerRunsPolicy：由提交任务的线程自己来执行这个任务。这是一种有效的"反压"策略，
|
||||
// 可以减慢任务提交方的速度，防止系统被压垮。
|
||||
executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
|
||||
|
||||
// 空闲线程存活时间：当线程数超过核心数时，多余的空闲线程在终止前等待新任务的最长时间。
|
||||
executor.setKeepAliveSeconds(60);
|
||||
|
||||
// 初始化线程池
|
||||
executor.initialize();
|
||||
|
||||
return executor;
|
||||
}
|
||||
}
|
||||
|
|
@ -0,0 +1,34 @@
|
|||
package com.aisino.iles.lawenforcement.config;
|
||||
|
||||
import lombok.Data;
|
||||
import org.springframework.boot.context.properties.ConfigurationProperties;
|
||||
import org.springframework.stereotype.Component;
|
||||
|
||||
import java.util.Map;
|
||||
|
||||
/**
|
||||
* 数据同步API配置属性。
|
||||
* <p>
|
||||
* 用于从 application.yml 文件中加载与第三方系统同步数据相关的API端点配置。
|
||||
* </p>
|
||||
*/
|
||||
@Data
|
||||
@Component
|
||||
@ConfigurationProperties(prefix = "iles.sync.api")
|
||||
public class SyncApiProperties {
|
||||
|
||||
/**
|
||||
* API基础URL。
|
||||
*/
|
||||
private String baseUrl;
|
||||
|
||||
/**
|
||||
* API端点映射。
|
||||
* <p>
|
||||
* Key是完全限定的DTO类名 (e.g., "com.aisino.iles.lawenforcement.model.dto.DjbZfajxxRequestDto"),
|
||||
* Value是对应的相对API路径 (e.g., "/djbZfajxx/save").
|
||||
* </p>
|
||||
*/
|
||||
private Map<String, String> endpoints;
|
||||
private Map<String, String> dtoConverters;
|
||||
}
|
||||
|
|
@ -0,0 +1,52 @@
|
|||
package com.aisino.iles.lawenforcement.config;
|
||||
|
||||
import lombok.Data;
|
||||
import org.springframework.boot.context.properties.ConfigurationProperties;
|
||||
import org.springframework.stereotype.Component;
|
||||
|
||||
import java.util.Collections;
|
||||
import java.util.List;
|
||||
|
||||
/**
|
||||
* @author Cascade
|
||||
* @description 用于映射所有 third-party.* 配置的统一属性类
|
||||
* @date 2025/07/03
|
||||
*/
|
||||
@Component
|
||||
@ConfigurationProperties(prefix = "third-party")
|
||||
@Data
|
||||
public class ThirdPartyProperties {
|
||||
|
||||
private Person person = new Person();
|
||||
private Enterprise enterprise = new Enterprise();
|
||||
|
||||
/**
|
||||
* 人员相关配置
|
||||
*/
|
||||
@Data
|
||||
public static class Person {
|
||||
/**
|
||||
* 人员查询URL
|
||||
*/
|
||||
private String query = "";
|
||||
|
||||
/**
|
||||
* 人员角色列表
|
||||
*/
|
||||
private List<String> roles = Collections.emptyList();
|
||||
|
||||
}
|
||||
|
||||
/**
|
||||
* 企业相关配置
|
||||
*/
|
||||
@Data
|
||||
public static class Enterprise {
|
||||
/**
|
||||
* 用于获取令牌的移动电话号码
|
||||
*/
|
||||
private String yddh;
|
||||
|
||||
}
|
||||
|
||||
}
|
||||
|
|
@ -0,0 +1,17 @@
|
|||
package com.aisino.iles.lawenforcement.event;
|
||||
|
||||
/**
|
||||
* 数据变更操作类型枚举
|
||||
* @author hx
|
||||
*/
|
||||
public enum DataChangeAction {
|
||||
|
||||
/**
|
||||
* 保存
|
||||
*/
|
||||
SAVE,
|
||||
/**
|
||||
* 删除
|
||||
*/
|
||||
DELETE
|
||||
}
|
||||
|
|
@ -0,0 +1,39 @@
|
|||
package com.aisino.iles.lawenforcement.event;
|
||||
|
||||
import lombok.Getter;
|
||||
import org.springframework.context.ApplicationEvent;
|
||||
|
||||
/**
|
||||
* 通用数据变更事件
|
||||
* @param <T> 变更的数据实体类型
|
||||
* @author hx
|
||||
*/
|
||||
@Getter
|
||||
public class DataChangeEvent<T> extends ApplicationEvent {
|
||||
|
||||
private final T data;
|
||||
private final DataChangeAction action;
|
||||
private final Class<T> entityType;
|
||||
|
||||
/**
|
||||
* 创建一个新的 DataChangeEvent.
|
||||
*
|
||||
* @param source 事件源对象
|
||||
* @param data 变更的数据实体
|
||||
* @param action 数据变更的动作类型 (CREATE, UPDATE, DELETE)
|
||||
*/
|
||||
public DataChangeEvent(Object source, T data, DataChangeAction action) {
|
||||
super(source);
|
||||
this.data = data;
|
||||
this.action = action;
|
||||
entityType = null;
|
||||
}
|
||||
|
||||
public DataChangeEvent(Object source, T data, DataChangeAction action, Class<T> entityType) {
|
||||
super(source);
|
||||
this.data = data;
|
||||
this.action = action;
|
||||
this.entityType = entityType;
|
||||
}
|
||||
|
||||
}
|
||||
|
|
@ -0,0 +1,123 @@
|
|||
package com.aisino.iles.lawenforcement.event.aop;
|
||||
|
||||
import com.aisino.iles.lawenforcement.config.SyncApiProperties;
|
||||
import com.aisino.iles.lawenforcement.model.dto.DataDtoConverter;
|
||||
import com.aisino.iles.lawenforcement.event.DataChangeEvent;
|
||||
import lombok.RequiredArgsConstructor;
|
||||
import lombok.SneakyThrows;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.aspectj.lang.JoinPoint;
|
||||
import org.aspectj.lang.annotation.AfterReturning;
|
||||
import org.aspectj.lang.annotation.Aspect;
|
||||
import org.springframework.context.ApplicationEventPublisher;
|
||||
import org.springframework.stereotype.Component;
|
||||
|
||||
import java.util.Collection;
|
||||
|
||||
/**
|
||||
* 数据变更事件发布的AOP切面。
|
||||
* 拦截所有被 @PublishDataChange 注解标记的方法，并在方法成功返回后发布事件。
|
||||
* @author hx
|
||||
*/
|
||||
@Slf4j
|
||||
@Aspect
|
||||
@Component
|
||||
@RequiredArgsConstructor
|
||||
public class DataChangeAspect {
|
||||
|
||||
private final ApplicationEventPublisher eventPublisher;
|
||||
private final SyncApiProperties syncApiProperties;
|
||||
|
||||
/**
|
||||
* 在被 @PublishDataChange 注解标记的方法成功返回后执行。
|
||||
*
|
||||
* @param joinPoint 连接点，包含方法信息
|
||||
* @param annotation 注解实例，用于获取action类型
|
||||
* @param returnedValue 方法的返回值，即被操作的数据实体
|
||||
*/
|
||||
@SneakyThrows
|
||||
@AfterReturning(pointcut = "@annotation(annotation)", returning = "returnedValue")
|
||||
public void publishEventOnSuccess(JoinPoint joinPoint, PublishDataChange annotation, Object returnedValue) {
|
||||
if (returnedValue == null) {
|
||||
log.warn("AOP切面: 方法 {} 返回值为null，无法发布数据变更事件。", joinPoint.getSignature().toShortString());
|
||||
return;
|
||||
}
|
||||
|
||||
log.info("AOP切面: 拦截到方法 {} 成功返回, 准备发布 {} 事件。", joinPoint.getSignature().toShortString(), annotation.action());
|
||||
|
||||
if (returnedValue instanceof Collection) {
|
||||
@SuppressWarnings("unchecked") // Safe cast after instanceof check
|
||||
Collection<Object> returnedCollection = (Collection<Object>) returnedValue;
|
||||
if (returnedCollection.isEmpty()) {
|
||||
log.warn("AOP切面: 方法 {} 返回的集合为空，不发布事件。", joinPoint.getSignature().toShortString());
|
||||
return;
|
||||
}
|
||||
log.info("AOP切面: 方法 {} 返回集合，将为集合中 {} 个元素分别发布事件。", joinPoint.getSignature().toShortString(), returnedCollection.size());
|
||||
for (Object item : returnedCollection) {
|
||||
if (item != null) {
|
||||
try {
|
||||
String converterClassName = syncApiProperties.getDtoConverters().get(item.getClass().getName());
|
||||
if (converterClassName == null || converterClassName.isEmpty()) {
|
||||
log.warn("AOP切面: 未找到类型 {} 的转换器配置。", item.getClass().getName());
|
||||
continue;
|
||||
}
|
||||
|
||||
Class<?> converterClass = Class.forName(converterClassName);
|
||||
if (!DataDtoConverter.class.isAssignableFrom(converterClass)) {
|
||||
continue;
|
||||
}
|
||||
|
||||
@SuppressWarnings("unchecked")
|
||||
DataDtoConverter<Object, Object> converter = (DataDtoConverter<Object, Object>) converterClass.getConstructor().newInstance();
|
||||
Object convertedItem = converter.convert(item);
|
||||
|
||||
if (convertedItem == null) {
|
||||
log.warn("AOP切面: 转换后的对象为null。原始对象: {}", item);
|
||||
return;
|
||||
}
|
||||
|
||||
DataChangeEvent<?> event = new DataChangeEvent<>(joinPoint.getTarget(), convertedItem, annotation.action());
|
||||
eventPublisher.publishEvent(event);
|
||||
log.info("AOP切面: {} 事件已成功发布 (来自集合), 数据: {}", annotation.action(), item);
|
||||
} catch (ClassNotFoundException e) {
|
||||
log.error("AOP切面: 找不到转换器类。错误: {}", e.getMessage());
|
||||
} catch (Exception e) {
|
||||
log.error("AOP切面: 创建或使用转换器时发生错误。错误: {}", e.getMessage());
|
||||
}
|
||||
} else {
|
||||
log.warn("AOP切面: 集合中的一个元素为null，跳过该元素的事件发布。方法: {}", joinPoint.getSignature().toShortString());
|
||||
}
|
||||
}
|
||||
} else {
|
||||
try {
|
||||
String converterClassName = syncApiProperties.getDtoConverters().get(returnedValue.getClass().getName());
|
||||
if (converterClassName == null || converterClassName.isEmpty()) {
|
||||
log.warn("AOP切面: 未找到类型 {} 的转换器配置。", returnedValue.getClass().getName());
|
||||
return;
|
||||
}
|
||||
|
||||
Class<?> converterClass = Class.forName(converterClassName);
|
||||
if (!DataDtoConverter.class.isAssignableFrom(converterClass)) {
|
||||
return;
|
||||
}
|
||||
|
||||
@SuppressWarnings("unchecked")
|
||||
DataDtoConverter<Object, Object> converter = (DataDtoConverter<Object, Object>) converterClass.getConstructor().newInstance();
|
||||
Object convertedItem = converter.convert(returnedValue);
|
||||
|
||||
if (convertedItem == null) {
|
||||
log.warn("AOP切面: 转换后的对象为null。原始对象: {}", returnedValue);
|
||||
return;
|
||||
}
|
||||
|
||||
DataChangeEvent<?> event = new DataChangeEvent<>(joinPoint.getTarget(), convertedItem, annotation.action());
|
||||
eventPublisher.publishEvent(event);
|
||||
log.info("AOP切面: {} 事件已成功发布, 数据: {}", annotation.action(), returnedValue);
|
||||
} catch (ClassNotFoundException e) {
|
||||
log.error("AOP切面: 找不到转换器类。错误: {}", e.getMessage());
|
||||
} catch (Exception e) {
|
||||
log.error("AOP切面: 创建或使用转换器时发生错误。错误: {}", e.getMessage());
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
@ -0,0 +1,24 @@
|
|||
package com.aisino.iles.lawenforcement.event.aop;
|
||||
|
||||
import com.aisino.iles.lawenforcement.event.DataChangeAction;
|
||||
|
||||
import java.lang.annotation.ElementType;
|
||||
import java.lang.annotation.Retention;
|
||||
import java.lang.annotation.RetentionPolicy;
|
||||
import java.lang.annotation.Target;
|
||||
|
||||
/**
|
||||
* 自定义注解，用于标记需要发布数据变更事件的方法。
|
||||
* 当方法成功返回时，AOP切面将自动发布一个DataChangeEvent。
|
||||
* @author hx
|
||||
*/
|
||||
@Target(ElementType.METHOD)
|
||||
@Retention(RetentionPolicy.RUNTIME)
|
||||
public @interface PublishDataChange {
|
||||
|
||||
/**
|
||||
* 定义数据变更的操作类型 (CREATE, UPDATE, etc.)
|
||||
* @return 数据变更操作类型
|
||||
*/
|
||||
DataChangeAction action();
|
||||
}
|
||||
|
|
@ -0,0 +1,79 @@
|
|||
package com.aisino.iles.lawenforcement.event.listener;
|
||||
|
||||
import com.aisino.iles.lawenforcement.event.DataChangeEvent;
|
||||
import com.aisino.iles.lawenforcement.service.DataSyncService;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.context.event.EventListener;
|
||||
import org.springframework.scheduling.annotation.Async;
|
||||
import org.springframework.stereotype.Component;
|
||||
|
||||
/**
|
||||
* 数据变更事件监听器，负责将数据同步到第三方应用。
|
||||
* @author hx
|
||||
*/
|
||||
@Slf4j
|
||||
@Component
|
||||
public class DataSyncListener {
|
||||
|
||||
private final DataSyncService dataSyncService;
|
||||
|
||||
@Autowired
|
||||
public DataSyncListener(DataSyncService dataSyncService) {
|
||||
this.dataSyncService = dataSyncService;
|
||||
}
|
||||
|
||||
/**
|
||||
* 异步监听数据变更事件。
|
||||
*
|
||||
* @param event 数据变更事件
|
||||
* @param <T> 数据类型
|
||||
*/
|
||||
@Async
|
||||
@EventListener
|
||||
public <T> void onDataChangeEvent(DataChangeEvent<T> event) {
|
||||
T data = event.getData();
|
||||
if (data == null) {
|
||||
log.warn("接收到数据为空的事件，已忽略。");
|
||||
return;
|
||||
}
|
||||
|
||||
Class<?> dataType = determineDataType(event);
|
||||
if (dataType != null) {
|
||||
log.info("接收到数据变更事件，类型: {}", dataType.getSimpleName());
|
||||
try {
|
||||
dataSyncService.sendData(data, dataType);
|
||||
} catch (Exception e) {
|
||||
// 异常已在DataSyncService的恢复方法中记录，此处无需重复处理
|
||||
log.trace("数据类型 {} 的同步在重试后最终失败，此为预期行为。", dataType.getSimpleName());
|
||||
}
|
||||
} else {
|
||||
log.warn("无法确定事件中的数据类型，已忽略。事件: {}", event);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 从数据变更事件中确定关键的数据类型。
|
||||
*/
|
||||
private <T> Class<?> determineDataType(DataChangeEvent<T> event) {
|
||||
T data = event.getData();
|
||||
if (data == null) return null;
|
||||
|
||||
// 优先使用事件中明确指定的实体类型
|
||||
if (event.getEntityType() != null) {
|
||||
return event.getEntityType();
|
||||
}
|
||||
|
||||
// 如果是集合类型，尝试获取第一个元素的类型
|
||||
if (data instanceof Iterable) {
|
||||
Iterable<?> iterable = (Iterable<?>) data;
|
||||
if (iterable.iterator().hasNext()) {
|
||||
return iterable.iterator().next().getClass();
|
||||
}
|
||||
return null; // 空集合无法确定类型
|
||||
}
|
||||
|
||||
// 对于单个对象，直接返回其类型
|
||||
return data.getClass();
|
||||
}
|
||||
}
|
||||
Loading…
Reference in New Issue