src/org/redkale/source/CacheMemorySource.java

@@ -747,11 +747,27 @@ public class CacheMemorySource<V extends Object> extends AbstractService impleme
         return map;
     }
 
+    @Override
+    public Long[] getLongArray(final String... keys) {
+        Long[] rs = new Long[keys.length];
+        int index = -1;
+        for (String key : keys) {
+            Number n = (Number) get(key);
+            rs[++index] = n == null ? null : n.longValue();
+        }
+        return rs;
+    }
+
     @Override
     public CompletableFuture<Map<String, Long>> getLongMapAsync(final String... keys) {
         return CompletableFuture.supplyAsync(() -> getLongMap(keys), getExecutor());
     }
 
+    @Override
+    public CompletableFuture<Long[]> getLongArrayAsync(final String... keys) {
+        return CompletableFuture.supplyAsync(() -> getLongArray(keys), getExecutor());
+    }
+
     @Override
     public Map<String, String> getStringMap(final String... keys) {
         Map<String, String> map = new LinkedHashMap<>();
@@ -762,11 +778,27 @@ public class CacheMemorySource<V extends Object> extends AbstractService impleme
         return map;
     }
 
+    @Override
+    public String[] getStringArray(final String... keys) {
+        String[] rs = new String[keys.length];
+        int index = -1;
+        for (String key : keys) {
+            Object n = get(key);
+            rs[++index] = n == null ? null : n.toString();
+        }
+        return rs;
+    }
+
     @Override
     public CompletableFuture<Map<String, String>> getStringMapAsync(final String... keys) {
         return CompletableFuture.supplyAsync(() -> getStringMap(keys), getExecutor());
     }
 
+    @Override
+    public CompletableFuture<String[]> getStringArrayAsync(final String... keys) {
+        return CompletableFuture.supplyAsync(() -> getStringArray(keys), getExecutor());
+    }
+
     @Override
     public <T> Map<String, T> getMap(final Type componentType, final String... keys) {
         Map<String, T> map = new LinkedHashMap<>();

src/org/redkale/source/CacheSource.java

@@ -153,6 +153,8 @@ public interface CacheSource<V extends Object> {
 
     public Map<String, String> getStringMap(final String... keys);
 
+    public String[] getStringArray(final String... keys);
+
     public Collection<String> getStringCollection(final String key);
 
     public Map<String, Collection<String>> getStringCollectionMap(final boolean set, final String... keys);
@@ -179,6 +181,8 @@ public interface CacheSource<V extends Object> {
 
     public Map<String, Long> getLongMap(final String... keys);
 
+    public Long[] getLongArray(final String... keys);
+
     public Collection<Long> getLongCollection(final String key);
 
     public Map<String, Collection<Long>> getLongCollectionMap(final boolean set, final String... keys);
@@ -316,6 +320,8 @@ public interface CacheSource<V extends Object> {
 
     public CompletableFuture<Map<String, String>> getStringMapAsync(final String... keys);
 
+    public CompletableFuture<String[]> getStringArrayAsync(final String... keys);
+
     public CompletableFuture<Collection<String>> getStringCollectionAsync(final String key);
 
     public CompletableFuture<Map<String, Collection<String>>> getStringCollectionMapAsync(final boolean set, final String... keys);
@@ -342,6 +348,8 @@ public interface CacheSource<V extends Object> {
 
     public CompletableFuture<Map<String, Long>> getLongMapAsync(final String... keys);
 
+    public CompletableFuture<Long[]> getLongArrayAsync(final String... keys);
+
     public CompletableFuture<Collection<Long>> getLongCollectionAsync(final String key);
 
     public CompletableFuture<Map<String, Collection<Long>>> getLongCollectionMapAsync(final boolean set, final String... keys);