tunnel server embedded redis support settgins. #1592

alibaba · Nov 26, 2020 · 7b2b383 · 7b2b383
1 parent 0aed289
commit 7b2b383
Show file tree

Hide file tree

Showing 3 changed files with 21 additions and 4 deletions.
diff --git a/...er/src/main/java/com/alibaba/arthas/tunnel/server/app/configuration/ArthasProperties.java b/...er/src/main/java/com/alibaba/arthas/tunnel/server/app/configuration/ArthasProperties.java
@@ -1,5 +1,8 @@
 package com.alibaba.arthas.tunnel.server.app.configuration;
 
+import java.util.ArrayList;
+import java.util.List;
+
 import org.springframework.boot.context.properties.ConfigurationProperties;
 import org.springframework.stereotype.Component;
 
@@ -114,6 +117,7 @@ public static class EmbeddedRedis {
         private boolean enabled = false;
         private String host = "127.0.0.1";
         private int port = 6379;
+        private List<String> settings = new ArrayList<String>();
 
         public boolean isEnabled() {
             return enabled;
@@ -138,6 +142,14 @@ public int getPort() {
         public void setPort(int port) {
             this.port = port;
         }
+
+        public List<String> getSettings() {
+            return settings;
+        }
+
+        public void setSettings(List<String> settings) {
+            this.settings = settings;
+        }
     }
 
 }
diff --git a/...n/java/com/alibaba/arthas/tunnel/server/app/configuration/EmbeddedRedisConfiguration.java b/...n/java/com/alibaba/arthas/tunnel/server/app/configuration/EmbeddedRedisConfiguration.java
@@ -9,6 +9,7 @@
 import com.alibaba.arthas.tunnel.server.app.configuration.ArthasProperties.EmbeddedRedis;
 
 import redis.embedded.RedisServer;
+import redis.embedded.RedisServerBuilder;
 
 /**
  * 
@@ -25,10 +26,13 @@ public class EmbeddedRedisConfiguration {
     public RedisServer embeddedRedisServer(ArthasProperties arthasProperties) {
         EmbeddedRedis embeddedRedis = arthasProperties.getEmbeddedRedis();
 
-        RedisServer redisServer = RedisServer.builder().port(embeddedRedis.getPort()).bind(embeddedRedis.getHost())
-                .build();
-        return redisServer;
+        RedisServerBuilder builder = RedisServer.builder().port(embeddedRedis.getPort()).bind(embeddedRedis.getHost());
 
+        for (String setting : embeddedRedis.getSettings()) {
+            builder.setting(setting);
+        }
+        RedisServer redisServer = builder.build();
+        return redisServer;
     }
 
     public static void main(String[] args) {

diff --git a/tunnel-server/src/main/resources/application.properties b/tunnel-server/src/main/resources/application.properties
@@ -12,4 +12,5 @@ spring.security.user.name=arthas
 
 #arthas.enable-detatil-pages=true
 #arthas.embedded-redis.enabled=true
-#spring.redis.host=127.0.0.1
+#arthas.embedded-redis.settings=maxmemory 128M
+#spring.redis.host=127.0.0.1