优化demo

Author: binarywang

pom.xml

@@ -18,7 +18,7 @@
     <description>Spring Boot Demo with wechat miniapp</description>
 
     <properties>
-        <weixin-java-miniapp.version>3.9.0</weixin-java-miniapp.version>
+        <weixin-java-miniapp.version>3.9.4.B</weixin-java-miniapp.version>
 
         <maven.compiler.source>1.8</maven.compiler.source>
         <maven.compiler.target>1.8</maven.compiler.target>
@@ -67,6 +67,10 @@
             <artifactId>lombok</artifactId>
             <scope>provided</scope>
         </dependency>
+        <dependency>
+            <groupId>redis.clients</groupId>
+            <artifactId>jedis</artifactId>
+        </dependency>
     </dependencies>
 
     <build>

src/main/java/com/github/binarywang/demo/wx/miniapp/config/WxMaConfiguration.java

@@ -5,15 +5,19 @@
 import cn.binarywang.wx.miniapp.bean.WxMaKefuMessage;
 import cn.binarywang.wx.miniapp.bean.WxMaSubscribeMessage;
 import cn.binarywang.wx.miniapp.config.impl.WxMaDefaultConfigImpl;
+import cn.binarywang.wx.miniapp.config.impl.WxMaRedisConfigImpl;
 import cn.binarywang.wx.miniapp.message.WxMaMessageHandler;
 import cn.binarywang.wx.miniapp.message.WxMaMessageRouter;
 import com.google.common.collect.Lists;
 import com.google.common.collect.Maps;
+import lombok.extern.slf4j.Slf4j;
 import me.chanjar.weixin.common.bean.result.WxMediaUploadResult;
 import me.chanjar.weixin.common.error.WxErrorException;
+import me.chanjar.weixin.common.error.WxRuntimeException;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.context.properties.EnableConfigurationProperties;
 import org.springframework.context.annotation.Configuration;
+import redis.clients.jedis.JedisPool;
 
 import javax.annotation.PostConstruct;
 import java.io.File;
@@ -24,13 +28,14 @@
 /**
  * @author <a href="https://github.com/binarywang">Binary Wang</a>
  */
+@Slf4j
 @Configuration
 @EnableConfigurationProperties(WxMaProperties.class)
 public class WxMaConfiguration {
-    private WxMaProperties properties;
+    private final WxMaProperties properties;
 
-    private static Map<String, WxMaMessageRouter> routers = Maps.newHashMap();
-    private static Map<String, WxMaService> maServices = Maps.newHashMap();
+    private static final Map<String, WxMaMessageRouter> routers = Maps.newHashMap();
+    private static Map<String, WxMaService> maServices;
 
     @Autowired
     public WxMaConfiguration(WxMaProperties properties) {
@@ -54,12 +59,13 @@ public static WxMaMessageRouter getRouter(String appid) {
     public void init() {
         List<WxMaProperties.Config> configs = this.properties.getConfigs();
         if (configs == null) {
-            throw new RuntimeException("大哥，拜托先看下项目首页的说明（readme文件），添加下相关配置，注意别配错了！");
+            throw new WxRuntimeException("大哥，拜托先看下项目首页的说明（readme文件），添加下相关配置，注意别配错了！");
         }
 
         maServices = configs.stream()
             .map(a -> {
-                WxMaDefaultConfigImpl config = new WxMaDefaultConfigImpl();
+//                WxMaDefaultConfigImpl config = new WxMaDefaultConfigImpl();
+                WxMaDefaultConfigImpl config = new WxMaRedisConfigImpl(new JedisPool());
                 config.setAppid(a.getAppid());
                 config.setSecret(a.getSecret());
                 config.setToken(a.getToken());
@@ -95,7 +101,7 @@ private WxMaMessageRouter newRouter(WxMaService service) {
     };
 
     private final WxMaMessageHandler logHandler = (wxMessage, context, service, sessionManager) -> {
-        System.out.println("收到消息：" + wxMessage.toString());
+        log.info("收到消息：" + wxMessage.toString());
         service.getMsgService().sendKefuMsg(WxMaKefuMessage.newTextBuilder().content("收到信息为：" + wxMessage.toJson())
             .toUser(wxMessage.getFromUser()).build());
         return null;