• WxJava使用lettuce的redis实现access_token的共享

    使用WxJava微信开发时，调用接口获取access_token，如果多个服务部署，就需要使用到缓存来保存access_token以达到重复利用，WxJava 也提供了相关的实现类WxMaRedisConfigImpl，但是这个是基于jedis客户端的实现，最新版本的springboot-redis都开始采用lettuce客户端进行连接了，所以我们只能自己手动实现一个类似于WxMaRedisConfigImpl的类

    使用的版本

    
    com.github.binarywang
    weixin-java-miniapp
    3.5.0

     WxMaLettuceRedisConfigImpl基于lettuce的工具类

    1. package cn.shiyue.config.ma;
    2.  
    3. import cn.binarywang.wx.miniapp.config.impl.WxMaDefaultConfigImpl;
    4. import org.apache.commons.lang3.ObjectUtils;
    5. import org.springframework.data.redis.core.StringRedisTemplate;
    6.  
    7. import java.util.concurrent.TimeUnit;
    8.  
    9. public class WxMaLettuceRedisConfigImpl extends WxMaDefaultConfigImpl {
    10.  
    11.     private StringRedisTemplate stringRedisTemplate;
    12.  
    13.     private static final String ACCESS_TOKEN_KEY = "wa:access_token:";
    14.  
    15.     private String accessTokenKey;
    16.  
    17.     public WxMaLettuceRedisConfigImpl(StringRedisTemplate stringRedisTemplate){
    18.         this.stringRedisTemplate = stringRedisTemplate;
    19.     }
    20.  
    21.     /**
    22.      * 每个公众号生成独有的存储key.
    23.      */
    24.     @Override
    25.     public void setAppid(String appId) {
    26.         super.setAppid(appId);
    27.         this.accessTokenKey = ACCESS_TOKEN_KEY.concat(appId);
    28.     }
    29.  
    30.     @Override
    31.     public String getAccessToken() {
    32.         return stringRedisTemplate.opsForValue().get(accessTokenKey);
    33.     }
    34.  
    35.     @Override
    36.     public boolean isAccessTokenExpired() {
    37.         Long expireTime = stringRedisTemplate.getExpire(accessTokenKey);
    38.         if (ObjectUtils.isEmpty(expireTime)) {
    39.             return true;
    40.         }
    41.         // 到期时间小于2秒就算作过期了，就重新调用接口获取
    42.         return expireTime < 2;
    43.     }
    44.  
    45.     @Override
    46.     public synchronized void updateAccessToken(String accessToken, int expiresInSeconds) {
    47.         stringRedisTemplate.opsForValue().set(accessTokenKey, accessToken, expiresInSeconds - 200, TimeUnit.SECONDS);
    48.     }
    49.  
    50.     @Override
    51.     public void expireAccessToken() {
    52.         stringRedisTemplate.expire(accessTokenKey, 0, TimeUnit.SECONDS);
    53.     }
    54.  
    55.  
    56.     @Override
    57.     public long getExpiresTime() {
    58.         Long expire = stringRedisTemplate.getExpire(accessTokenKey);
    59.         return expire == null ? 0 : expire;
    60.     }
    61.  
    62.     @Override
    63.     public void setExpiresTime(long expiresTime) {
    64.         stringRedisTemplate.expire(accessTokenKey, expiresTime, TimeUnit.SECONDS);
    65.     }
    66. }
    WxMaConfiguration配置
    1. package cn.shiyue.config.ma;
    2.  
    3. import cn.binarywang.wx.miniapp.api.WxMaService;
    4. import cn.binarywang.wx.miniapp.api.impl.WxMaServiceImpl;
    5. import cn.binarywang.wx.miniapp.bean.WxMaKefuMessage;
    6. import cn.binarywang.wx.miniapp.bean.WxMaTemplateData;
    7. import cn.binarywang.wx.miniapp.bean.WxMaTemplateMessage;
    8. import cn.binarywang.wx.miniapp.config.impl.WxMaDefaultConfigImpl;
    9. import cn.binarywang.wx.miniapp.message.WxMaMessageHandler;
    10. import cn.binarywang.wx.miniapp.message.WxMaMessageRouter;
    11. import com.google.common.collect.Lists;
    12. import com.google.common.collect.Maps;
    13. import me.chanjar.weixin.common.bean.result.WxMediaUploadResult;
    14. import me.chanjar.weixin.common.error.WxErrorException;
    15. import org.springframework.beans.factory.annotation.Autowired;
    16. import org.springframework.boot.context.properties.EnableConfigurationProperties;
    17. import org.springframework.context.annotation.Configuration;
    18. import org.springframework.data.redis.core.StringRedisTemplate;
    19.  
    20. import javax.annotation.PostConstruct;
    21. import java.io.File;
    22. import java.util.List;
    23. import java.util.Map;
    24. import java.util.stream.Collectors;
    25.  
    26. @Configuration
    27. @EnableConfigurationProperties(WxMaProperties.class)
    28. public class WxMaConfiguration {
    29.     private WxMaProperties properties;
    30.  
    31.     private static Map routers = Maps.newHashMap();
    32.     private static Map maServices = Maps.newHashMap();
    33.  
    34.     // 注入StringRedisTemplate 
    35.     @Autowired
    36.     private StringRedisTemplate stringRedisTemplate;
    37.  
    38.     @Autowired
    39.     public WxMaConfiguration(WxMaProperties properties) {
    40.         this.properties = properties;
    41.     }
    42.  
    43.     public static WxMaService getMaService(String appid) {
    44.         WxMaService wxService = maServices.get(appid);
    45.         if (wxService == null) {
    46.             throw new IllegalArgumentException(String.format("未找到对应appid=[%s]的配置，请核实！", appid));
    47.         }
    48.  
    49.         return wxService;
    50.     }
    51.  
    52.     public static WxMaMessageRouter getRouter(String appid) {
    53.         return routers.get(appid);
    54.     }
    55.  
    56.     @PostConstruct
    57.     public void init() {
    58.         List configs = this.properties.getConfigs();
    59.         if (configs == null) {
    60.             throw new RuntimeException("大哥，拜托先看下项目首页的说明（readme文件），添加下相关配置，注意别配错了！");
    61.         }
    62.  
    63.         maServices = configs.stream()
    64.             .map(a -> {
    65.                 // 在当前引用
    66.                 WxMaDefaultConfigImpl config = new WxMaLettuceRedisConfigImpl(stringRedisTemplate);
    67.                 //WxMaDefaultConfigImpl config = new WxMaDefaultConfigImpl ();
    68.                 config.setAppid(a.getAppid());
    69.                 config.setSecret(a.getSecret());
    70.                 config.setToken(a.getToken());
    71.                 config.setAesKey(a.getAesKey());
    72.                 config.setMsgDataFormat(a.getMsgDataFormat());
    73.  
    74.                 WxMaService service = new WxMaServiceImpl();
    75.                 service.setWxMaConfig(config);
    76.                 routers.put(a.getAppid(), this.newRouter(service));
    77.                 return service;
    78.             }).collect(Collectors.toMap(s -> s.getWxMaConfig().getAppid(), a -> a));
    79.     }
    80.  
    81.     private WxMaMessageRouter newRouter(WxMaService service) {
    82.         final WxMaMessageRouter router = new WxMaMessageRouter(service);
    83.         router
    84.             .rule().handler(logHandler).next()
    85.             .rule().async(false).content("模板").handler(templateMsgHandler).end()
    86.             .rule().async(false).content("文本").handler(textHandler).end()
    87.             .rule().async(false).content("图片").handler(picHandler).end()
    88.             .rule().async(false).content("二维码").handler(qrcodeHandler).end();
    89.         return router;
    90.     }
    91.  
    92.     private final WxMaMessageHandler templateMsgHandler = (wxMessage, context, service, sessionManager) ->{
    93.         service.getMsgService().sendTemplateMsg(WxMaTemplateMessage.builder()
    94.                 .templateId("此处更换为自己的模板id")
    95.                 .formId("自己替换可用的formid")
    96.                 .data(Lists.newArrayList(
    97.                         new WxMaTemplateData("keyword1", "339208499", "#173177")))
    98.                 .toUser(wxMessage.getFromUser())
    99.                 .build());
    100.         return null;
    101.     };
    102.  
    103.     private final WxMaMessageHandler logHandler = (wxMessage, context, service, sessionManager) -> {
    104.         System.out.println("收到消息：" + wxMessage.toString());
    105.         service.getMsgService().sendKefuMsg(WxMaKefuMessage.newTextBuilder().content("收到信息为：" + wxMessage.toJson())
    106.             .toUser(wxMessage.getFromUser()).build());
    107.         return null;
    108.     };
    109.  
    110.     private final WxMaMessageHandler textHandler = (wxMessage, context, service, sessionManager) ->{
    111.         service.getMsgService().sendKefuMsg(WxMaKefuMessage.newTextBuilder().content("回复文本消息")
    112.                 .toUser(wxMessage.getFromUser()).build());
    113.         return null;
    114.     };
    115.  
    116.     private final WxMaMessageHandler picHandler = (wxMessage, context, service, sessionManager) -> {
    117.         try {
    118.             WxMediaUploadResult uploadResult = service.getMediaService()
    119.                 .uploadMedia("image", "png",
    120.                     ClassLoader.getSystemResourceAsStream("tmp.png"));
    121.             service.getMsgService().sendKefuMsg(
    122.                 WxMaKefuMessage
    123.                     .newImageBuilder()
    124.                     .mediaId(uploadResult.getMediaId())
    125.                     .toUser(wxMessage.getFromUser())
    126.                     .build());
    127.         } catch (WxErrorException e) {
    128.             e.printStackTrace();
    129.         }
    130.         return null;
    131.     };
    132.  
    133.     private final WxMaMessageHandler qrcodeHandler = (wxMessage, context, service, sessionManager) -> {
    134.         try {
    135.             final File file = service.getQrcodeService().createQrcode("123", 430);
    136.             WxMediaUploadResult uploadResult = service.getMediaService().uploadMedia("image", file);
    137.             service.getMsgService().sendKefuMsg(
    138.                 WxMaKefuMessage
    139.                     .newImageBuilder()
    140.                     .mediaId(uploadResult.getMediaId())
    141.                     .toUser(wxMessage.getFromUser())
    142.                     .build());
    143.         } catch (WxErrorException e) {
    144.             e.printStackTrace();
    145.         }
    146.         return null;
    147.     };
    148.  
    149. }
    WxMaProperties文件
    1. package cn.shiyue.config.ma;
    2.  
    3. import org.springframework.boot.context.properties.ConfigurationProperties;
    4.  
    5. import java.util.List;
    6.  
    7. @ConfigurationProperties(prefix = "wx.miniapp")
    8. public class WxMaProperties {
    9.  
    10.     private List configs;
    11.  
    12.     public static class Config {
    13.         /**
    14.          * 设置微信小程序的appid
    15.          */
    16.         private String appid;
    17.  
    18.         /**
    19.          * 设置微信小程序的Secret
    20.          */
    21.         private String secret;
    22.  
    23.         /**
    24.          * 设置微信小程序消息服务器配置的token
    25.          */
    26.         private String token;
    27.  
    28.         /**
    29.          * 设置微信小程序消息服务器配置的EncodingAESKey
    30.          */
    31.         private String aesKey;
    32.  
    33.         /**
    34.          * 消息格式，XML或者JSON
    35.          */
    36.         private String msgDataFormat;
    37.  
    38.         public String getAppid() {
    39.             return appid;
    40.         }
    41.  
    42.         public void setAppid(String appid) {
    43.             this.appid = appid;
    44.         }
    45.  
    46.         public String getSecret() {
    47.             return secret;
    48.         }
    49.  
    50.         public void setSecret(String secret) {
    51.             this.secret = secret;
    52.         }
    53.  
    54.         public String getToken() {
    55.             return token;
    56.         }
    57.  
    58.         public void setToken(String token) {
    59.             this.token = token;
    60.         }
    61.  
    62.         public String getAesKey() {
    63.             return aesKey;
    64.         }
    65.  
    66.         public void setAesKey(String aesKey) {
    67.             this.aesKey = aesKey;
    68.         }
    69.  
    70.         public String getMsgDataFormat() {
    71.             return msgDataFormat;
    72.         }
    73.  
    74.         public void setMsgDataFormat(String msgDataFormat) {
    75.             this.msgDataFormat = msgDataFormat;
    76.         }
    77.     }
    78.  
    79.     public List getConfigs() {
    80.         return configs;
    81.     }
    82.  
    83.     public void setConfigs(List configs) {
    84.         this.configs = configs;
    85.     }
    86. }

     还有一种方式在WxMaConfiguration 文件中配置，这个WxMaRedisBetterConfigImpl类需要高版本的weixin-java-miniapp的jar

    @Autowired

    private StringRedisTemplate stringRedisTemplate;

    // 方式二才需要用上

    @Bean

    public WxRedisOps getWxRedisOps() {

    return new RedisTemplateWxRedisOps(stringRedisTemplate);

    }

    // 方式一：自己实现一个lettuce的redis配置对象

    WxMaDefaultConfigImpl config = new WxMaLettuceRedisConfigImpl(stringRedisTemplate);

    // 方式二: 使用wxRedisOps对象来包装redis连接

    // WxMaDefaultConfigImpl config = new WxMaRedisBetterConfigImpl(getWxRedisOps(), "wa:access_token:");

  • 相关阅读:
    自学Python 60 socketserver编程
    喷码机如何与封箱机配合？
    Node.js 安装配置
    Git入门详解
    软体机器人空间感知技术综述
    深度学习 Day 16——利用卷神经网络实现咖啡豆的识别
    【Android开发】Android请求出现网络请求失败，HTTP请求，安全网络通信与权限管理
    ue4使用Niagara粒子实现下雨效果，使用蓝图调节雨量
    能带你起飞的【数据结构】成王第十篇:二叉树4
    含重复元素取不重复子集[如何取子集？如何去重？]
  • 原文地址：https://blog.csdn.net/SDJN_ONE/article/details/134326361