support select databases

Author: ipipman

.flattened-pom.xml

@@ -14,6 +14,7 @@
 
     <name>cache-core</name>
     <description>cache-core</description>
+    <packaging>jar</packaging>
 
     <dependencies>
         <dependency>

cache-core/.flattened-pom.xml

@@ -27,6 +27,7 @@ public class Commands {
     private static void initCommands() {
 
         // common
+        register(new SelectCommand());
         register(new CmdCommand());
         register(new PingCommand());
         register(new InfoCommand());

cache-core/pom.xml

@@ -0,0 +1,25 @@
+package cn.ipman.cache.core.command.common;
+
+import cn.ipman.cache.core.command.Command;
+import cn.ipman.cache.core.core.IMCache;
+import cn.ipman.cache.core.core.Reply;
+
+/**
+ * Description for this class
+ *
+ * @Author IpMan
+ * @Date 2024/6/22 13:27
+ */
+public class SelectCommand implements Command {
+
+    @Override
+    public String name() {
+        // SELECT ===>  *2,$6,select,$1,0
+        return "SELECT";
+    }
+
+    @Override
+    public Reply<?> exec(IMCache cache, String[] args) {
+        return Reply.string(OK); // 暂不实现select
+    }
+}

cache-core/src/main/java/cn/ipman/cache/core/command/Commands.java

@@ -17,13 +17,14 @@
     <description>cache-server</description>
 
     <dependencies>
+
         <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter</artifactId>
         </dependency>
 
         <dependency>
-            <groupId>cn.ipman</groupId>
+            <groupId>io.github.ipipman</groupId>
             <artifactId>cache-core</artifactId>
             <version>${cache.version}</version>
         </dependency>
@@ -66,6 +67,19 @@
             <version>3.0.1</version>
             <scope>test</scope>
         </dependency>
+
+        <dependency>
+            <groupId>redis.clients</groupId>
+            <artifactId>jedis</artifactId>
+            <version>2.6.2</version>
+        </dependency>
+
+        <dependency>
+            <groupId>org.apache.commons</groupId>
+            <artifactId>commons-pool2</artifactId>
+            <version>2.6.2</version>
+        </dependency>
+
     </dependencies>
 
     <build>

cache-core/src/main/java/cn/ipman/cache/core/command/common/SelectCommand.java

@@ -1,5 +1,6 @@
 package cn.ipman.cache.server.config;
 
+import cn.ipman.cache.server.jedis.JedisUtil;
 import cn.ipman.cache.server.server.IMServerPlugin;
 import lombok.NonNull;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -27,6 +28,9 @@ public class IMApplicationListener implements ApplicationListener<ApplicationEve
     List<IMServerPlugin> plugins;
 
 
+    @Autowired
+    JedisUtil jedisUtil;
+
     @Override
     public void onApplicationEvent(@NonNull ApplicationEvent event) {
 
@@ -48,6 +52,11 @@ public void onApplicationEvent(@NonNull ApplicationEvent event) {
             executor.scheduleWithFixedDelay(() -> {
                 System.out.println("Netty redis起动后, 定时任务进程ID为 "
                         + Thread.currentThread().getId() + ", 父线程ID为 " + inheritableThreadLocal.get());
+
+                System.out.println(jedisUtil.set("a", "1", 0));
+                System.out.println(jedisUtil.get("a", 0));
+
+
             }, 2, 2, TimeUnit.SECONDS);
 
 

cache-core/src/main/resources/application.properties

@@ -0,0 +1,42 @@
+package cn.ipman.cache.server.config;
+
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import redis.clients.jedis.JedisPool;
+import redis.clients.jedis.JedisPoolConfig;
+
+
+/**
+ * Created by ipipman on 2021/1/6.
+ *
+ * @version V1.0
+ * @Package com.ipman.springboot.redis.jedis.sample.config
+ * @Description: (用一句话描述该文件做什么)
+ * @date 2021/1/6 10:11 下午
+ */
+@Configuration
+public class JedisConfig {
+
+    @Value("${spring.data.redis.host}")
+    private String host;
+
+    @Value("${spring.data.redis.port}")
+    private int port;
+
+    @Value("${spring.data.redis.timeout}")
+    private int timeout;
+
+    @Bean
+    @ConfigurationProperties("spring.data.redis")
+    public JedisPoolConfig jedisPoolConfig() {
+        System.out.println("jedisPoolConfig staring...");
+        return new JedisPoolConfig();
+    }
+
+    @Bean(destroyMethod = "close")
+    public JedisPool jedisPool() {
+        return new JedisPool(jedisPoolConfig(), host, port, timeout * 1000);
+    }
+}