🎨 优化redis配置

chen-collab · Aug 22, 2020 · 05d1ac1 · 05d1ac1
1 parent e5e14b6
commit 05d1ac1
Show file tree

Hide file tree

Showing 4 changed files with 49 additions and 8 deletions.
diff --git a/README.md b/README.md
@@ -43,15 +43,20 @@
 ```
 wx:
   mp:
+    useRedis: false
+    redisConfig:
+      host: 127.0.0.1
+      port: 6379
     configs:
-      - appId: 1111 （一个公众号的appid）
-        secret: 1111（公众号的appsecret）
-        token: 111 （接口配置里的Token值）
-        aesKey: 111 （接口配置里的EncodingAESKey值）
-      - appId: 2222 （另一个公众号的appid，以下同上）
+      - appId: 1111 # 第一个公众号的appid
+        secret: 1111 # 公众号的appsecret
+        token: 111 # 接口配置里的Token值
+        aesKey: 111 # 接口配置里的EncodingAESKey值
+      - appId: 2222 # 第二个公众号的appid，以下同上
         secret: 1111
         token: 111
         aesKey: 111
+
 ```
 3. 运行Java程序：`WxMpDemoApplication`；
 4. 配置微信公众号中的接口地址：http://公网可访问域名/wx/portal/xxxxx （注意，xxxxx为对应公众号的appid值）；

diff --git a/src/main/java/com/github/binarywang/demo/wx/mp/config/WxMpConfiguration.java b/src/main/java/com/github/binarywang/demo/wx/mp/config/WxMpConfiguration.java
@@ -56,9 +56,15 @@ public WxMpService wxMpService() {
         WxMpService service = new WxMpServiceImpl();
         service.setMultiConfigStorages(configs
             .stream().map(a -> {
-                // WxMpDefaultConfigImpl configStorage = new WxMpDefaultConfigImpl();
-                WxMpDefaultConfigImpl configStorage = new WxMpRedisConfigImpl(new JedisWxRedisOps(new JedisPool("redisServer")),
-                    a.getAppId());
+                WxMpDefaultConfigImpl configStorage;
+                if (this.properties.isUseRedis()) {
+                    final WxMpProperties.RedisConfig redisConfig = this.properties.getRedisConfig();
+                    JedisPool jedisPool = new JedisPool(redisConfig.getHost(), redisConfig.getPort());
+                    configStorage = new WxMpRedisConfigImpl(new JedisWxRedisOps(jedisPool), a.getAppId());
+                } else {
+                    configStorage = new WxMpDefaultConfigImpl();
+                }
+
                 configStorage.setAppId(a.getAppId());
                 configStorage.setSecret(a.getSecret());
                 configStorage.setToken(a.getToken());

diff --git a/src/main/java/com/github/binarywang/demo/wx/mp/config/WxMpProperties.java b/src/main/java/com/github/binarywang/demo/wx/mp/config/WxMpProperties.java
@@ -14,6 +14,32 @@
 @Data
 @ConfigurationProperties(prefix = "wx.mp")
 public class WxMpProperties {
+    /**
+     * 是否使用redis存储access token
+     */
+    private boolean useRedis;
+
+    /**
+     * redis 配置
+     */
+    private RedisConfig redisConfig;
+
+    @Data
+    public static class RedisConfig {
+        /**
+         * redis服务器 主机地址
+         */
+        private String host;
+
+        /**
+         * redis服务器 端口号
+         */
+        private Integer port;
+    }
+
+    /**
+     * 多个公众号配置信息
+     */
     private List<MpConfig> configs;
 
     @Data

diff --git a/src/main/resources/application.yml.template b/src/main/resources/application.yml.template
@@ -5,6 +5,10 @@ logging:
     me.chanjar.weixin: DEBUG
 wx:
   mp:
+    useRedis: false
+    redisConfig:
+      host: 127.0.0.1
+      port: 6379
     configs:
       - appId: 1111 # 第一个公众号的appid
         secret: 1111 # 公众号的appsecret