@Bean(name = "jedisPoolConfigCustom")
    public JedisPoolConfig jedisPoolConfig(@Value("${spring.redis.jedis.pool.max-total:100}") int maxTotal,
                                           @Value("${spring.redis.jedis.pool.max-wait:5000}") int maxWaitMillis,
                                           @Value("${spring.redis.jedis.pool.max-idle:10}") int maxIdle) {
        JedisPoolConfig config = new JedisPoolConfig();
        // 最大连接数
        config.setMaxTotal(maxTotal);
        // 最小空闲连接数
        config.setMaxIdle(maxIdle);
        // 当池内没有可用的连接时，最大等待时间
        config.setMaxWaitMillis(maxWaitMillis);
        return config;
    }


@Bean(name = "redisConnectionFactory")
    public RedisConnectionFactory connectionFactory(@Qualifier("jedisPoolConfigCustom") @Autowired JedisPoolConfig jedisPoolConfig,
                                                    RedisProperties properties) {
        // 获得默认的连接池构造
        //修改我们的连接池配置
        // 这里需要注意的是，edisConnectionFactoryJ对于Standalone模式的没有（RedisStandaloneConfiguration，JedisPoolConfig）的构造函数，对此
        // 我们用JedisClientConfiguration接口的builder方法实例化一个构造器，还得类型转换
        JedisClientConfiguration.JedisPoolingClientConfigurationBuilder jpcf = (JedisClientConfiguration.JedisPoolingClientConfigurationBuilder) JedisClientConfiguration.builder();
        jpcf.poolConfig(jedisPoolConfig);
        //通过构造器来构造jedis客户端配置
        JedisClientConfiguration jedisClientConfiguration = jpcf.build();
        //Jedis连接工厂 JedisConnectionFactory是RedisConnectionFactory子类
        JedisConnectionFactory factory;
        //RedisSentinelConfiguration 是 RedisConfiguration 的子类
        RedisSentinelConfiguration sentinelConfig = getSentinelConfiguration(properties);
        RedisClusterConfiguration clusterConfiguration = getClusterConfiguration(properties);
        if (sentinelConfig != null) {
            log.info("Redis Sentinel 集群配置...");
            factory = new JedisConnectionFactory(sentinelConfig, jedisClientConfiguration);
        } else if (clusterConfiguration != null) {
            log.info("Redis Cluster 集群配置...");
            factory = new JedisConnectionFactory(clusterConfiguration, jedisClientConfiguration);
        } else {
            log.info("Redis Standalone单节点配置...");
            RedisStandaloneConfiguration configuration = getRedisStandaloneConfiguration(properties);
            factory = new JedisConnectionFactory(configuration, jedisClientConfiguration);
        }

        return factory;
    }
    @Bean
    public StringRedisTemplate stringRedisTemplate(@Qualifier("redisConnectionFactory") RedisConnectionFactory factory) {
        StringRedisTemplate stringRedisTemplate = new StringRedisTemplate();
        stringRedisTemplate.setConnectionFactory(factory);
        return stringRedisTemplate;
    }

@Configuration
public class WechatMpConfig {
    @Autowired
    private WechatMpProperties wechatMpProperties;
    @Autowired
    private StringRedisTemplate stringRedisTemplateCustom;

    @Bean
    public WxMpService wxMpService() {
        WxMpService wxMpService = new WxMpServiceImpl();
        wxMpService.setWxMpConfigStorage(wxMpConfigStorage());
        return wxMpService;
    }

    @Bean
    public WxMpConfigStorage wxMpConfigStorage() {
        RedisTemplateWxRedisOps wxRedisOps = new RedisTemplateWxRedisOps(stringRedisTemplateCustom);
        WxMpRedisConfigImpl wxMpRedisConfig = new WxMpRedisConfigImpl(wxRedisOps, "wxmp");
        wxMpRedisConfig.setAppId(wechatMpProperties.getAppId());
        wxMpRedisConfig.setSecret(wechatMpProperties.getAppSecret());
        wxMpRedisConfig.setToken(wechatMpProperties.getToken());
        wxMpRedisConfig.setAesKey(wechatMpProperties.getAesKey());
        return wxMpRedisConfig;
    }

}

    @Resource
 
    @Override
    public WxMpXmlOutMessage handle(WxMpXmlMessage wxMessage, Map<String, Object> context,
                                    WxMpService wxMpService, WxSessionManager sessionManager) {
        this.logger.info("新关注用户 OPENID: " + wxMessage.getFromUser());
        // 下面方法执行时报错了  Pipeline is currently not supported for JedisClusterConnection
        WxMpUser wxMpUser = wechatMpCoreService.getUserInfo(wxMessage.getFromUser(), "zh_CN");