From d3a6f46c6c41bc48ef2d49ee8c72db3b2401dade Mon Sep 17 00:00:00 2001 From: redkale Date: Tue, 19 Dec 2023 00:07:40 +0800 Subject: [PATCH] spi --- src/main/java/module-info.java | 2 ++ src/main/java/org/redkale/boot/Application.java | 4 ++-- .../org/redkale/cache/{ => spi}/CacheAction.java | 2 +- .../org/redkale/cache/{ => spi}/CacheExpire.java | 2 +- .../CacheManagerService.java} | 14 +++++++------- .../redkale/cache/{ => spi}/CacheModuleEngine.java | 6 +++--- .../org/redkale/cache/{ => spi}/CacheValue.java | 2 +- .../redkale/schedule/{ => spi}/CronExpression.java | 2 +- .../ScheduleManagerService.java} | 12 ++++++------ .../schedule/{ => spi}/ScheduleModuleEngine.java | 6 +++--- .../java/org/redkale/util/RedkaleClassLoader.java | 2 ++ .../org/redkale/test/cache/CacheManagerTest.java | 6 +++--- .../org/redkale/test/schedule/SchedulingTest.java | 4 ++-- 13 files changed, 34 insertions(+), 30 deletions(-) rename src/main/java/org/redkale/cache/{ => spi}/CacheAction.java (95%) rename src/main/java/org/redkale/cache/{ => spi}/CacheExpire.java (95%) rename src/main/java/org/redkale/cache/{DefaultCacheManager.java => spi/CacheManagerService.java} (98%) rename src/main/java/org/redkale/cache/{ => spi}/CacheModuleEngine.java (92%) rename src/main/java/org/redkale/cache/{ => spi}/CacheValue.java (97%) rename src/main/java/org/redkale/schedule/{ => spi}/CronExpression.java (99%) rename src/main/java/org/redkale/schedule/{DefaultScheduleManager.java => spi/ScheduleManagerService.java} (97%) rename src/main/java/org/redkale/schedule/{ => spi}/ScheduleModuleEngine.java (93%) diff --git a/src/main/java/module-info.java b/src/main/java/module-info.java index 8af11c6af..772e0892b 100644 --- a/src/main/java/module-info.java +++ b/src/main/java/module-info.java @@ -18,6 +18,7 @@ module org.redkale { exports org.redkale.boot; exports org.redkale.boot.watch; exports org.redkale.cache; + exports org.redkale.cache.spi; exports org.redkale.cluster; exports org.redkale.convert; exports org.redkale.convert.bson; @@ -33,6 +34,7 @@ module org.redkale { exports org.redkale.net.sncp; exports org.redkale.persistence; exports org.redkale.schedule; + exports org.redkale.schedule.spi; exports org.redkale.service; exports org.redkale.source; exports org.redkale.util; diff --git a/src/main/java/org/redkale/boot/Application.java b/src/main/java/org/redkale/boot/Application.java index 9def91d9c..36ec3decf 100644 --- a/src/main/java/org/redkale/boot/Application.java +++ b/src/main/java/org/redkale/boot/Application.java @@ -22,7 +22,7 @@ import java.util.logging.*; import org.redkale.annotation.Nonnull; import org.redkale.annotation.Resource; import org.redkale.boot.ClassFilter.FilterEntry; -import org.redkale.cache.CacheModuleEngine; +import org.redkale.cache.spi.CacheModuleEngine; import org.redkale.cluster.*; import org.redkale.convert.Convert; import org.redkale.convert.bson.BsonFactory; @@ -35,7 +35,7 @@ import org.redkale.mq.*; import org.redkale.net.*; import org.redkale.net.http.*; import org.redkale.net.sncp.*; -import org.redkale.schedule.ScheduleModuleEngine; +import org.redkale.schedule.spi.ScheduleModuleEngine; import org.redkale.service.Service; import org.redkale.source.*; import org.redkale.util.*; diff --git a/src/main/java/org/redkale/cache/CacheAction.java b/src/main/java/org/redkale/cache/spi/CacheAction.java similarity index 95% rename from src/main/java/org/redkale/cache/CacheAction.java rename to src/main/java/org/redkale/cache/spi/CacheAction.java index 1459b31eb..8da03a2d4 100644 --- a/src/main/java/org/redkale/cache/CacheAction.java +++ b/src/main/java/org/redkale/cache/spi/CacheAction.java @@ -1,7 +1,7 @@ /* * */ -package org.redkale.cache; +package org.redkale.cache.spi; import java.lang.reflect.Method; import java.util.concurrent.ConcurrentHashMap; diff --git a/src/main/java/org/redkale/cache/CacheExpire.java b/src/main/java/org/redkale/cache/spi/CacheExpire.java similarity index 95% rename from src/main/java/org/redkale/cache/CacheExpire.java rename to src/main/java/org/redkale/cache/spi/CacheExpire.java index 794e08c82..050a8adff 100644 --- a/src/main/java/org/redkale/cache/CacheExpire.java +++ b/src/main/java/org/redkale/cache/spi/CacheExpire.java @@ -1,7 +1,7 @@ /* * */ -package org.redkale.cache; +package org.redkale.cache.spi; import org.redkale.convert.ConvertColumn; import org.redkale.convert.ConvertDisabled; diff --git a/src/main/java/org/redkale/cache/DefaultCacheManager.java b/src/main/java/org/redkale/cache/spi/CacheManagerService.java similarity index 98% rename from src/main/java/org/redkale/cache/DefaultCacheManager.java rename to src/main/java/org/redkale/cache/spi/CacheManagerService.java index 453e285a5..acbd7f36f 100644 --- a/src/main/java/org/redkale/cache/DefaultCacheManager.java +++ b/src/main/java/org/redkale/cache/spi/CacheManagerService.java @@ -1,7 +1,7 @@ /* * */ -package org.redkale.cache; +package org.redkale.cache.spi; import java.lang.reflect.Type; import java.time.Duration; @@ -40,7 +40,7 @@ import org.redkale.util.Utility; @Component @AutoLoad(false) @ResourceType(CacheManager.class) -public class DefaultCacheManager implements CacheManager, Service { +public class CacheManagerService implements CacheManager, Service { //是否开启缓存 protected boolean enabled = true; @@ -69,20 +69,20 @@ public class DefaultCacheManager implements CacheManager, Service { //远程缓存Source protected CacheSource remoteSource; - protected DefaultCacheManager(@Nullable CacheSource remoteSource) { + protected CacheManagerService(@Nullable CacheSource remoteSource) { this.remoteSource = remoteSource; } //一般用于独立组件 - public static DefaultCacheManager create(@Nullable CacheSource remoteSource) { - return new DefaultCacheManager(remoteSource); + public static CacheManagerService create(@Nullable CacheSource remoteSource) { + return new CacheManagerService(remoteSource); } public boolean enabled() { return this.enabled; } - public DefaultCacheManager enabled(boolean val) { + public CacheManagerService enabled(boolean val) { this.enabled = val; return this; } @@ -123,7 +123,7 @@ public class DefaultCacheManager implements CacheManager, Service { return enabled; } - public DefaultCacheManager addHash(String hash) { + public CacheManagerService addHash(String hash) { this.hashNames.add(hash); return this; } diff --git a/src/main/java/org/redkale/cache/CacheModuleEngine.java b/src/main/java/org/redkale/cache/spi/CacheModuleEngine.java similarity index 92% rename from src/main/java/org/redkale/cache/CacheModuleEngine.java rename to src/main/java/org/redkale/cache/spi/CacheModuleEngine.java index a2000438b..50c43cdb7 100644 --- a/src/main/java/org/redkale/cache/CacheModuleEngine.java +++ b/src/main/java/org/redkale/cache/spi/CacheModuleEngine.java @@ -1,7 +1,7 @@ /* * */ -package org.redkale.cache; +package org.redkale.cache.spi; import org.redkale.boot.Application; import org.redkale.boot.ModuleEngine; @@ -15,7 +15,7 @@ import org.redkale.util.AnyValue; public class CacheModuleEngine extends ModuleEngine { //全局缓存管理器 - private DefaultCacheManager cacheManager; + private CacheManagerService cacheManager; public CacheModuleEngine(Application application) { super(application); @@ -44,7 +44,7 @@ public class CacheModuleEngine extends ModuleEngine { */ public void onAppPostInit() { //设置缓存管理器 - this.cacheManager = DefaultCacheManager.create(null).enabled(false); + this.cacheManager = CacheManagerService.create(null).enabled(false); final AnyValue cacheConf = application.getAppConfig().getAnyValue("cache"); if (cacheConf != null && !application.isCompileMode()) { this.resourceFactory.inject(this.cacheManager); diff --git a/src/main/java/org/redkale/cache/CacheValue.java b/src/main/java/org/redkale/cache/spi/CacheValue.java similarity index 97% rename from src/main/java/org/redkale/cache/CacheValue.java rename to src/main/java/org/redkale/cache/spi/CacheValue.java index dc5b8f81e..04cf6044c 100644 --- a/src/main/java/org/redkale/cache/CacheValue.java +++ b/src/main/java/org/redkale/cache/spi/CacheValue.java @@ -1,7 +1,7 @@ /* * */ -package org.redkale.cache; +package org.redkale.cache.spi; import java.time.Duration; import org.redkale.convert.ConvertColumn; diff --git a/src/main/java/org/redkale/schedule/CronExpression.java b/src/main/java/org/redkale/schedule/spi/CronExpression.java similarity index 99% rename from src/main/java/org/redkale/schedule/CronExpression.java rename to src/main/java/org/redkale/schedule/spi/CronExpression.java index b5dbfe527..baa0607b7 100644 --- a/src/main/java/org/redkale/schedule/CronExpression.java +++ b/src/main/java/org/redkale/schedule/spi/CronExpression.java @@ -1,7 +1,7 @@ /* * */ -package org.redkale.schedule; +package org.redkale.schedule.spi; import java.time.DateTimeException; import java.time.temporal.ChronoField; diff --git a/src/main/java/org/redkale/schedule/DefaultScheduleManager.java b/src/main/java/org/redkale/schedule/spi/ScheduleManagerService.java similarity index 97% rename from src/main/java/org/redkale/schedule/DefaultScheduleManager.java rename to src/main/java/org/redkale/schedule/spi/ScheduleManagerService.java index 6d069df94..759b8da96 100644 --- a/src/main/java/org/redkale/schedule/DefaultScheduleManager.java +++ b/src/main/java/org/redkale/schedule/spi/ScheduleManagerService.java @@ -1,7 +1,7 @@ /* * */ -package org.redkale.schedule; +package org.redkale.schedule.spi; import java.lang.invoke.MethodHandle; import java.lang.invoke.MethodHandles; @@ -54,7 +54,7 @@ import org.redkale.util.Utility; @Component @AutoLoad(false) @ResourceType(ScheduleManager.class) -public class DefaultScheduleManager implements ScheduleManager, Service { +public class ScheduleManagerService implements ScheduleManager, Service { protected final Logger logger = Logger.getLogger(this.getClass().getSimpleName()); @@ -76,20 +76,20 @@ public class DefaultScheduleManager implements ScheduleManager, Service { private AnyValue config; - protected DefaultScheduleManager(UnaryOperator propertyFunc) { + protected ScheduleManagerService(UnaryOperator propertyFunc) { this.propertyFunc = propertyFunc; } //一般用于独立组件 - public static DefaultScheduleManager create(UnaryOperator propertyFunc) { - return new DefaultScheduleManager(propertyFunc); + public static ScheduleManagerService create(UnaryOperator propertyFunc) { + return new ScheduleManagerService(propertyFunc); } public boolean enabled() { return this.enabled; } - public DefaultScheduleManager enabled(boolean val) { + public ScheduleManagerService enabled(boolean val) { this.enabled = val; return this; } diff --git a/src/main/java/org/redkale/schedule/ScheduleModuleEngine.java b/src/main/java/org/redkale/schedule/spi/ScheduleModuleEngine.java similarity index 93% rename from src/main/java/org/redkale/schedule/ScheduleModuleEngine.java rename to src/main/java/org/redkale/schedule/spi/ScheduleModuleEngine.java index 848c2a695..d01920cdf 100644 --- a/src/main/java/org/redkale/schedule/ScheduleModuleEngine.java +++ b/src/main/java/org/redkale/schedule/spi/ScheduleModuleEngine.java @@ -1,7 +1,7 @@ /* * */ -package org.redkale.schedule; +package org.redkale.schedule.spi; import org.redkale.boot.Application; import org.redkale.boot.ModuleEngine; @@ -16,7 +16,7 @@ import org.redkale.util.AnyValue; public class ScheduleModuleEngine extends ModuleEngine { //全局定时任务管理器 - private DefaultScheduleManager scheduleManager; + private ScheduleManagerService scheduleManager; public ScheduleModuleEngine(Application application) { super(application); @@ -45,7 +45,7 @@ public class ScheduleModuleEngine extends ModuleEngine { */ public void onAppPostInit() { //设置定时管理器 - this.scheduleManager = DefaultScheduleManager.create(null).enabled(false); + this.scheduleManager = ScheduleManagerService.create(null).enabled(false); final AnyValue scheduleConf = application.getAppConfig().getAnyValue("schedule"); if (scheduleConf != null && !application.isCompileMode()) { this.resourceFactory.inject(this.scheduleManager); diff --git a/src/main/java/org/redkale/util/RedkaleClassLoader.java b/src/main/java/org/redkale/util/RedkaleClassLoader.java index a6372c32f..3d00dec3c 100644 --- a/src/main/java/org/redkale/util/RedkaleClassLoader.java +++ b/src/main/java/org/redkale/util/RedkaleClassLoader.java @@ -48,6 +48,7 @@ public class RedkaleClassLoader extends URLClassLoader { "org.redkale.boot", "org.redkale.boot.watch", "org.redkale.cache", + "org.redkale.cache.spi", "org.redkale.cluster", "org.redkale.convert", "org.redkale.convert.bson", @@ -63,6 +64,7 @@ public class RedkaleClassLoader extends URLClassLoader { "org.redkale.net.sncp", "org.redkale.persistence", "org.redkale.schedule", + "org.redkale.schedule.spi", "org.redkale.service", "org.redkale.source", "org.redkale.util", diff --git a/src/test/java/org/redkale/test/cache/CacheManagerTest.java b/src/test/java/org/redkale/test/cache/CacheManagerTest.java index e897fe61d..c067c2fea 100644 --- a/src/test/java/org/redkale/test/cache/CacheManagerTest.java +++ b/src/test/java/org/redkale/test/cache/CacheManagerTest.java @@ -7,7 +7,7 @@ import java.time.Duration; import java.util.concurrent.CountDownLatch; import java.util.concurrent.atomic.AtomicInteger; import org.junit.jupiter.api.*; -import org.redkale.cache.DefaultCacheManager; +import org.redkale.cache.spi.CacheManagerService; import org.redkale.convert.json.JsonConvert; import org.redkale.source.CacheMemorySource; import org.redkale.util.Utility; @@ -18,7 +18,7 @@ import org.redkale.util.Utility; */ public class CacheManagerTest { - private static DefaultCacheManager manager; + private static CacheManagerService manager; public static void main(String[] args) throws Throwable { CacheManagerTest test = new CacheManagerTest(); @@ -31,7 +31,7 @@ public class CacheManagerTest { public static void init() throws Exception { CacheMemorySource remoteSource = new CacheMemorySource("cache-remote"); remoteSource.init(null); - manager = DefaultCacheManager.create(remoteSource); + manager = CacheManagerService.create(remoteSource); manager.init(null); } diff --git a/src/test/java/org/redkale/test/schedule/SchedulingTest.java b/src/test/java/org/redkale/test/schedule/SchedulingTest.java index cd06d933d..57b72bd4a 100644 --- a/src/test/java/org/redkale/test/schedule/SchedulingTest.java +++ b/src/test/java/org/redkale/test/schedule/SchedulingTest.java @@ -4,7 +4,7 @@ package org.redkale.test.schedule; import org.junit.jupiter.api.Test; -import org.redkale.schedule.DefaultScheduleManager; +import org.redkale.schedule.spi.ScheduleManagerService; import org.redkale.util.Utility; /** @@ -20,7 +20,7 @@ public class SchedulingTest { @Test public void run() throws Exception { - DefaultScheduleManager manager = DefaultScheduleManager.create(null); + ScheduleManagerService manager = ScheduleManagerService.create(null); manager.init(null); ScheduleService service = new ScheduleService(); manager.schedule(service);