优化CacheSource

src/main/java/module-info.java

@@ -33,9 +33,10 @@ module redkale {
     exports org.redkale.util;
     exports org.redkale.watch;
     
-    uses org.redkale.mq.MessageAgent;
+    uses org.redkale.boot.PropertiesAgentProvider;
-    uses org.redkale.cluster.ClusterAgent;
+    uses org.redkale.cluster.ClusterAgentProvider;
     uses org.redkale.convert.ConvertProvider;
+    uses org.redkale.mq.MessageAgentProvider;
     uses org.redkale.source.CacheSourceProvider;
     uses org.redkale.source.DataSourceProvider;
     uses org.redkale.util.ResourceAnnotationProvider;

src/main/java/org/redkale/source/CacheMemorySource.java

@@ -1485,6 +1485,26 @@ public final class CacheMemorySource extends AbstractCacheSource {
         return CompletableFuture.runAsync(() -> setBytes(key, value), getExecutor()).whenComplete(futureCompleteConsumer);
     }
 
+    @Override
+    public void setnxBytes(final String key, final byte[] value) {
+        setnx(CacheEntryType.BYTES, key, value);
+    }
+
+    @Override
+    public CompletableFuture<Void> setnxBytesAsync(final String key, byte[] value) {
+        return CompletableFuture.runAsync(() -> setnxBytes(key, value), getExecutor()).whenComplete(futureCompleteConsumer);
+    }
+
+    @Override
+    public <T> void setnxBytes(final String key, final Convert convert, final Type type, final T value) {
+        setnx(CacheEntryType.BYTES, key, convert.convertToBytes(type, value));
+    }
+
+    @Override
+    public <T> CompletableFuture<Void> setnxBytesAsync(final String key, final Convert convert, final Type type, final T value) {
+        return CompletableFuture.runAsync(() -> setnxBytes(key, convert, type, value), getExecutor()).whenComplete(futureCompleteConsumer);
+    }
+
     @Override
     public void setexBytes(final String key, final int expireSeconds, final byte[] value) {
         set(CacheEntryType.BYTES, expireSeconds, key, value);

src/main/java/org/redkale/source/CacheSource.java

@@ -89,7 +89,9 @@ public interface CacheSource extends Resourcable {
 
     public void setnxLong(final String key, final long value);
 
-    public void setexLong(final String key, final int expireSeconds, final long value);
+    public void setnxBytes(final String key, final byte[] value);
+
+    public <T> void setnxBytes(final String key, final Convert convert, final Type type, final T value);
 
     //------------------------ setex ------------------------
     public <T> void setex(final String key, final int expireSeconds, final Convert convert, final T value);
@@ -100,6 +102,8 @@ public interface CacheSource extends Resourcable {
 
     public void setexString(final String key, final int expireSeconds, final String value);
 
+    public void setexLong(final String key, final int expireSeconds, final long value);
+
     public void setexBytes(final String key, final int expireSeconds, final byte[] value);
 
     public <T> void setexBytes(final String key, final int expireSeconds, final Convert convert, final Type type, final T value);
@@ -344,6 +348,10 @@ public interface CacheSource extends Resourcable {
 
     public CompletableFuture<Void> setnxLongAsync(final String key, long value);
 
+    public CompletableFuture<Void> setnxBytesAsync(final String key, final byte[] value);
+
+    public <T> CompletableFuture<Void> setnxBytesAsync(final String key, final Convert convert, final Type type, final T value);
+
     //------------------------ setexAsync ------------------------
     public <T> CompletableFuture<Void> setexAsync(final String key, final int expireSeconds, final Convert convert, final T value);