refactor: 部分类调整非公开、SpringEventHandlerFactory返回AggregateEventHandler

spring-extension-context/src/main/java/com/livk/core/disruptor/ClassPathDisruptorScanner.java

@@ -48,7 +48,7 @@
  *
  * @author livk
  */
-public class ClassPathDisruptorScanner extends ClassPathBeanDefinitionScanner {
+class ClassPathDisruptorScanner extends ClassPathBeanDefinitionScanner {
 
 	private final BeanNameGenerator beanNameGenerator;
 

spring-extension-context/src/main/java/com/livk/core/disruptor/DisruptorRegistrar.java

@@ -38,7 +38,7 @@
  * @author livk
  */
 @Slf4j
-public class DisruptorRegistrar implements ImportBeanDefinitionRegistrar {
+class DisruptorRegistrar implements ImportBeanDefinitionRegistrar {
 
 	@Override
 	public void registerBeanDefinitions(@NonNull AnnotationMetadata importingClassMetadata,

spring-extension-context/src/main/java/com/livk/core/disruptor/factory/DisruptorFactoryBean.java

@@ -18,7 +18,6 @@
 
 import com.livk.core.disruptor.support.DisruptorCustomizer;
 import com.livk.core.disruptor.support.SpringDisruptor;
-import com.livk.core.disruptor.support.SpringEventHandler;
 import com.lmax.disruptor.WaitStrategy;
 import com.lmax.disruptor.dsl.ProducerType;
 import java.util.concurrent.ThreadFactory;
@@ -89,12 +88,11 @@ private WaitStrategy createWaitStrategy() {
 	public void afterPropertiesSet() {
 		SpringEventFactory<T> factory = new SpringEventFactory<>();
 		ResolvableType disruptorCustomizerType = ResolvableType.forClassWithGenerics(DisruptorCustomizer.class, type);
-		SpringEventHandler<T> springEventHandler = new SpringEventHandler<>(beanFactory, type);
 		int bufferSize = attributes.getNumber("bufferSize").intValue();
 		ProducerType producerType = attributes.getEnum("type");
 		disruptor = new SpringDisruptor<>(factory, bufferSize, createThreadFactory(), producerType,
 				createWaitStrategy());
-		disruptor.handleEventsWith(springEventHandler);
+		disruptor.handleEventsWith(SpringEventHandlerFactory.create(beanFactory, type));
 		beanFactory.<DisruptorCustomizer<T>>getBeanProvider(disruptorCustomizerType)
 			.forEach(customizer -> customizer.customize(disruptor));
 		disruptor.start();

spring-extension-context/src/main/java/com/livk/core/disruptor/factory/SpringEventFactory.java

@@ -22,7 +22,7 @@
 /**
  * @author livk
  */
-public class SpringEventFactory<T> implements EventFactory<DisruptorEventWrapper<T>> {
+class SpringEventFactory<T> implements EventFactory<DisruptorEventWrapper<T>> {
 
 	public DisruptorEventWrapper<T> newInstance() {
 		return new DisruptorEventWrapper<>();

spring-extension-context/src/main/java/com/livk/core/disruptor/factory/SpringEventHandlerFactory.java

@@ -0,0 +1,40 @@
+/*
+ * Copyright 2021-2024 spring-boot-extension the original author or authors.
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *       https://www.apache.org/licenses/LICENSE-2.0
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.livk.core.disruptor.factory;
+
+import com.livk.core.disruptor.DisruptorEventConsumer;
+import com.livk.core.disruptor.support.DisruptorEventWrapper;
+import com.lmax.disruptor.AggregateEventHandler;
+import com.lmax.disruptor.EventHandler;
+import lombok.RequiredArgsConstructor;
+import org.apache.poi.ss.formula.functions.T;
+import org.springframework.beans.factory.BeanFactory;
+import org.springframework.beans.factory.ObjectProvider;
+import org.springframework.core.ResolvableType;
+
+/**
+ * The type Spring event handler.
+ *
+ * @author livk
+ */
+
+final class SpringEventHandlerFactory {
+
+	@SuppressWarnings("unchecked")
+	public static <T> EventHandler<DisruptorEventWrapper<T>> create(BeanFactory beanFactory, Class<T> type){
+		ResolvableType resolvableType = ResolvableType.forClassWithGenerics(DisruptorEventConsumer.class, type);
+		ObjectProvider<DisruptorEventConsumer<T>> disruptorEventConsumers = beanFactory.getBeanProvider(resolvableType);
+		return new AggregateEventHandler<>(disruptorEventConsumers.orderedStream().toArray(DisruptorEventConsumer[]::new));
+	}
+}