PersistenceEvent

王亮 · 王亮 · commit 1d3d2494a1e9 · 2022-01-09T21:56:53.000+08:00
diff --git a/springboot-example/src/main/java/com/codingapi/springboot/example/domain/Demo.java b/springboot-example/src/main/java/com/codingapi/springboot/example/domain/Demo.java
@@ -1,6 +1,7 @@
 package com.codingapi.springboot.example.domain;
 
 import com.codingapi.springboot.example.domain.event.DemoNameChangeEvent;
+import com.codingapi.springboot.framework.persistence.IPersistence;
 import com.codingapi.springboot.framework.event.EventPusher;
 import lombok.Getter;
 import lombok.NoArgsConstructor;
@@ -21,7 +22,7 @@
 @NoArgsConstructor
 @Entity
 @ToString
-public class Demo{
+public class Demo implements IPersistence {
 
     @Id
     @GeneratedValue(strategy = GenerationType.IDENTITY)
diff --git a/springboot-example/src/main/java/com/codingapi/springboot/example/domain/event/DemoNameChangeEvent.java b/springboot-example/src/main/java/com/codingapi/springboot/example/domain/event/DemoNameChangeEvent.java
@@ -1,6 +1,6 @@
 package com.codingapi.springboot.example.domain.event;
 
-import com.codingapi.springboot.framework.event.IEvent;
+import com.codingapi.springboot.framework.event.IAsyncEvent;
 import lombok.AllArgsConstructor;
 import lombok.Getter;
 import lombok.Setter;
@@ -12,7 +12,7 @@
 @Setter
 @Getter
 @AllArgsConstructor
-public class DemoNameChangeEvent implements IEvent {
+public class DemoNameChangeEvent implements IAsyncEvent {
 
     private String oldName;
 
diff --git a/springboot-example/src/main/java/com/codingapi/springboot/example/repository/DemoRepository.java b/springboot-example/src/main/java/com/codingapi/springboot/example/repository/DemoRepository.java
@@ -1,12 +1,17 @@
 package com.codingapi.springboot.example.repository;
 
 import com.codingapi.springboot.example.domain.Demo;
+import com.codingapi.springboot.framework.persistence.IPersistenceRepository;
 import org.springframework.data.jpa.repository.JpaRepository;
 
 /**
  * @author lorne
  * @since 1.0.0
  */
-public interface DemoRepository extends JpaRepository<Demo,Integer> {
+public interface DemoRepository extends JpaRepository<Demo,Integer>, IPersistenceRepository<Demo> {
 
+    @Override
+    default void persistenceHandler(Demo demo) {
+        save(demo);
+    }
 }
diff --git a/springboot-example/src/test/java/com/codingapi/springboot/example/ExampleApplicationTests.java b/springboot-example/src/test/java/com/codingapi/springboot/example/ExampleApplicationTests.java
@@ -2,27 +2,26 @@
 
 import com.codingapi.springboot.example.domain.Demo;
 import com.codingapi.springboot.example.domain.service.DemoSwapService;
-import com.codingapi.springboot.example.repository.DemoRepository;
 import lombok.extern.slf4j.Slf4j;
 import org.junit.jupiter.api.Test;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.test.context.SpringBootTest;
 import org.springframework.util.Assert;
 
+import javax.transaction.Transactional;
+
 @SpringBootTest
 @Slf4j
 class ExampleApplicationTests {
 
-	@Autowired
-	private DemoRepository demoRepository;
-
 	@Autowired
 	private DemoSwapService demoSwapService;
 
 	@Test
+	@Transactional
 	void save() {
 		Demo demo = new Demo("xiaoming");
-		demoRepository.save(demo);
+		demo.persistence();
 		Assert.isTrue(demo.getId()>0,"demoRepository save error.");
 	}
 
diff --git a/springboot-framework/src/main/java/com/codingapi/springboot/framework/event/IPersistenceEvent.java b/springboot-framework/src/main/java/com/codingapi/springboot/framework/event/IPersistenceEvent.java
diff --git a/springboot-framework/src/main/java/com/codingapi/springboot/framework/handler/ApplicationHandlerUtils.java b/springboot-framework/src/main/java/com/codingapi/springboot/framework/handler/ApplicationHandlerUtils.java
@@ -14,7 +14,7 @@ class ApplicationHandlerUtils implements IHandler<IEvent>{
     private static ApplicationHandlerUtils instance;
 
     private ApplicationHandlerUtils(){
-        this.handleres = new ArrayList<>();
+        this.handlers = new ArrayList<>();
     }
 
 
@@ -30,47 +30,55 @@ public static ApplicationHandlerUtils getInstance(){
     }
 
 
-    private List<IHandler<IEvent>> handleres;
+    private List<IHandler<IEvent>> handlers;
 
-    public void addHandlers(List<IHandler> handleres){
-        if(handleres!=null){
-            handleres.forEach(this::addHandler);
+    public void addHandlers(List<IHandler> handlers){
+        if(handlers!=null){
+            handlers.forEach(this::addHandler);
         }
     }
 
 
     public void addHandler(IHandler handler){
         if(handler!=null){
-            handleres.add(handler);
+            handlers.add(handler);
         }
     }
 
 
     @Override
     public void handler(IEvent event) {
-        for(IHandler<IEvent> handler:handleres){
+        for(IHandler<IEvent> handler: handlers){
+            String targetClassName = null;
             try{
                 Class<?> eventClass = event.getClass();
                 Class<?> targetClass =  getHandlerEventClass(handler);
                 if(eventClass.equals(targetClass)) {
+                    targetClassName = targetClass.getName();
                     handler.handler(event);
                 }
             }catch(Exception e){
+                //IPersistenceEvent 抛出异常
+                if("com.codingapi.springboot.framework.persistence.PersistenceEvent".equals(targetClassName)){
+                    throw e;
+                }
                 log.warn("handler exception", e);
                 handler.error(e);
+
             }
         }    
     }
 
     private Class<?> getHandlerEventClass(IHandler<IEvent> handler){
         Type[] types = handler.getClass().getGenericInterfaces();
         for(Type type:types){
-            ParameterizedType parameterizedType = (ParameterizedType) type;
-            Type[] actualTypeArguments =  parameterizedType.getActualTypeArguments();
-            if(actualTypeArguments!=null){
-                return (Class<?>) actualTypeArguments[0];
+            if(type instanceof ParameterizedType) {
+                ParameterizedType parameterizedType = (ParameterizedType) type;
+                Type[] actualTypeArguments = parameterizedType.getActualTypeArguments();
+                if (actualTypeArguments != null) {
+                    return (Class<?>) actualTypeArguments[0];
+                }
             }
-
         }
         return null;
     }
diff --git a/springboot-framework/src/main/java/com/codingapi/springboot/framework/persistence/IPersistence.java b/springboot-framework/src/main/java/com/codingapi/springboot/framework/persistence/IPersistence.java
@@ -0,0 +1,17 @@
+package com.codingapi.springboot.framework.persistence;
+
+import com.codingapi.springboot.framework.event.EventPusher;
+
+/**
+ * 可持久化的对象
+ */
+public interface IPersistence {
+
+    /**
+     * 持久化对象
+     * @see IPersistenceRepository
+     */
+    default void persistence(){
+        EventPusher.push(new PersistenceEvent(this));
+    }
+}
diff --git a/springboot-framework/src/main/java/com/codingapi/springboot/framework/persistence/IPersistenceEvent.java b/springboot-framework/src/main/java/com/codingapi/springboot/framework/persistence/IPersistenceEvent.java
@@ -0,0 +1,13 @@
+package com.codingapi.springboot.framework.persistence;
+
+import com.codingapi.springboot.framework.event.ISyncEvent;
+
+/**
+ *
+ * 持久化同步事件
+ * 相比于ISyncEvent在IPersistenceEvent执行出现异常的时候会直接抛出
+ * @see com.codingapi.springboot.framework.persistence.IPersistence
+ */
+interface IPersistenceEvent extends ISyncEvent {
+
+}
diff --git a/springboot-framework/src/main/java/com/codingapi/springboot/framework/persistence/IPersistenceRepository.java b/springboot-framework/src/main/java/com/codingapi/springboot/framework/persistence/IPersistenceRepository.java
@@ -0,0 +1,15 @@
+package com.codingapi.springboot.framework.persistence;
+
+/**
+ * 持久化 存储对象
+ * @param <T> 对象类型
+ */
+public interface IPersistenceRepository<T> {
+
+    /**
+     * 持久化回调函数
+     * @param t 对象
+     */
+    void persistenceHandler(T t);
+
+}
diff --git a/springboot-framework/src/main/java/com/codingapi/springboot/framework/persistence/PersistenceEvent.java b/springboot-framework/src/main/java/com/codingapi/springboot/framework/persistence/PersistenceEvent.java
@@ -0,0 +1,17 @@
+package com.codingapi.springboot.framework.persistence;
+
+import lombok.Getter;
+
+/**
+ * 持久化事件
+ * @param <T>
+ */
+class PersistenceEvent<T> implements IPersistenceEvent {
+
+    @Getter
+    private final T val;
+
+    public PersistenceEvent(T val) {
+        this.val = val;
+    }
+}
diff --git a/springboot-framework/src/main/java/com/codingapi/springboot/framework/persistence/PersistenceHandler.java b/springboot-framework/src/main/java/com/codingapi/springboot/framework/persistence/PersistenceHandler.java
@@ -0,0 +1,61 @@
+package com.codingapi.springboot.framework.persistence;
+
+import com.codingapi.springboot.framework.handler.IHandler;
+import lombok.extern.slf4j.Slf4j;
+
+import java.lang.reflect.ParameterizedType;
+import java.lang.reflect.Type;
+import java.util.ArrayList;
+import java.util.List;
+
+@Slf4j
+public class PersistenceHandler implements IHandler<PersistenceEvent> {
+
+    private List<IPersistenceRepository> persistenceList;
+
+    public PersistenceHandler(List<IPersistenceRepository> persistenceList) {
+        if(persistenceList==null) {
+            this.persistenceList = new ArrayList<>();
+        }else{
+            this.persistenceList = persistenceList;
+        }
+    }
+
+
+    private Class<?> persistenceType(Class<?> persistenceClazz){
+        Type[] types = persistenceClazz.getGenericInterfaces();
+        for (Type type : types) {
+            if(type instanceof Class){
+                return persistenceType((Class<?>) type);
+            }
+            ParameterizedType parameterizedType = (ParameterizedType) type;
+            Type[] actualTypeArguments = parameterizedType.getActualTypeArguments();
+            if (actualTypeArguments != null) {
+                Class<?> clazz =  (Class<?>) actualTypeArguments[0];
+                if(IPersistence.class.isAssignableFrom(clazz)){
+                    return clazz;
+                }
+            }
+        }
+        return null;
+    }
+
+
+    private void eachPersistence(Object obj){
+        for(IPersistenceRepository persistence:persistenceList) {
+            Class<?> clazz = persistenceType(persistence.getClass());
+            if (clazz!=null&&clazz.equals(obj.getClass())) {
+                persistence.persistenceHandler(obj);
+            }
+        }
+    }
+
+    @Override
+    public void handler(PersistenceEvent event) {
+        Object obj =  event.getVal();
+        log.debug("handler persistence event obj:{}",obj);
+        this.eachPersistence(obj);
+    }
+
+
+}
diff --git a/springboot-framework/src/main/java/com/codingapi/springboot/framework/persistence/SpringPersistenceConfiguration.java b/springboot-framework/src/main/java/com/codingapi/springboot/framework/persistence/SpringPersistenceConfiguration.java
@@ -0,0 +1,19 @@
+package com.codingapi.springboot.framework.persistence;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+import java.util.List;
+
+@Configuration
+public class SpringPersistenceConfiguration {
+
+
+    @Bean
+    public PersistenceHandler persistenceHandler(@Autowired(required = false) List<IPersistenceRepository> persistenceList){
+        return new PersistenceHandler(persistenceList);
+    }
+
+
+}
diff --git a/springboot-framework/src/main/resources/META-INF/spring.factories b/springboot-framework/src/main/resources/META-INF/spring.factories
@@ -2,5 +2,6 @@ org.springframework.boot.autoconfigure.EnableAutoConfiguration=\
 com.codingapi.springboot.framework.AutoConfiguration,\
 com.codingapi.springboot.framework.event.SpringEventConfiguration,\
 com.codingapi.springboot.framework.handler.HandlerBeanDefinitionRegistrar,\
-com.codingapi.springboot.framework.handler.SpringHandlerConfiguration
+com.codingapi.springboot.framework.handler.SpringHandlerConfiguration,\
+com.codingapi.springboot.framework.persistence.SpringPersistenceConfiguration
 

Original file line number	Diff line number	Diff line change
`@@ -14,7 +14,7 @@ class ApplicationHandlerUtils implements IHandler<IEvent>{`
`14`	`14`	`private static ApplicationHandlerUtils instance;`
`15`	`15`
`16`	`16`	`private ApplicationHandlerUtils(){`
`17`		`- this.handleres = new ArrayList<>();`
	`17`	`+ this.handlers = new ArrayList<>();`
`18`	`18`	`}`
`19`	`19`
`20`	`20`
`@@ -30,47 +30,55 @@ public static ApplicationHandlerUtils getInstance(){`
`30`	`30`	`}`
`31`	`31`
`32`	`32`
`33`		`- private List<IHandler<IEvent>> handleres;`
	`33`	`+ private List<IHandler<IEvent>> handlers;`
`34`	`34`
`35`		`- public void addHandlers(List<IHandler> handleres){`
`36`		`- if(handleres!=null){`
`37`		`- handleres.forEach(this::addHandler);`
	`35`	`+ public void addHandlers(List<IHandler> handlers){`
	`36`	`+ if(handlers!=null){`
	`37`	`+ handlers.forEach(this::addHandler);`
`38`	`38`	`}`
`39`	`39`	`}`
`40`	`40`
`41`	`41`
`42`	`42`	`public void addHandler(IHandler handler){`
`43`	`43`	`if(handler!=null){`
`44`		`- handleres.add(handler);`
	`44`	`+ handlers.add(handler);`
`45`	`45`	`}`
`46`	`46`	`}`
`47`	`47`
`48`	`48`
`49`	`49`	`@Override`
`50`	`50`	`public void handler(IEvent event) {`
`51`		`- for(IHandler<IEvent> handler:handleres){`
	`51`	`+ for(IHandler<IEvent> handler: handlers){`
	`52`	`+ String targetClassName = null;`
`52`	`53`	`try{`
`53`	`54`	`Class<?> eventClass = event.getClass();`
`54`	`55`	`Class<?> targetClass = getHandlerEventClass(handler);`
`55`	`56`	`if(eventClass.equals(targetClass)) {`
	`57`	`+ targetClassName = targetClass.getName();`
`56`	`58`	`handler.handler(event);`
`57`	`59`	`}`
`58`	`60`	`}catch(Exception e){`
	`61`	`+ //IPersistenceEvent 抛出异常`
	`62`	`+ if("com.codingapi.springboot.framework.persistence.PersistenceEvent".equals(targetClassName)){`
	`63`	`+ throw e;`
	`64`	`+ }`
`59`	`65`	`log.warn("handler exception", e);`
`60`	`66`	`handler.error(e);`
	`67`	`+`
`61`	`68`	`}`
`62`	`69`	`}`
`63`	`70`	`}`
`64`	`71`
`65`	`72`	`private Class<?> getHandlerEventClass(IHandler<IEvent> handler){`
`66`	`73`	`Type[] types = handler.getClass().getGenericInterfaces();`
`67`	`74`	`for(Type type:types){`
`68`		`- ParameterizedType parameterizedType = (ParameterizedType) type;`
`69`		`- Type[] actualTypeArguments = parameterizedType.getActualTypeArguments();`
`70`		`- if(actualTypeArguments!=null){`
`71`		`- return (Class<?>) actualTypeArguments[0];`
	`75`	`+ if(type instanceof ParameterizedType) {`
	`76`	`+ ParameterizedType parameterizedType = (ParameterizedType) type;`
	`77`	`+ Type[] actualTypeArguments = parameterizedType.getActualTypeArguments();`
	`78`	`+ if (actualTypeArguments != null) {`
	`79`	`+ return (Class<?>) actualTypeArguments[0];`
	`80`	`+ }`
`72`	`81`	`}`
`73`		`-`
`74`	`82`	`}`
`75`	`83`	`return null;`
`76`	`84`	`}`