🆕 【公众号】新增多公众号配置 wx-java-mp-multi-spring-boot-starter

2025-04-05 17:38:05 +08:00 · 2024-01-30 10:19:04 +08:00 · 2024-01-30 10:19:04 +08:00 · 3590de139c
commit 3590de139c
parent b86144c198
17 changed files with 906 additions and 0 deletions
--- a/spring-boot-starters/pom.xml
+++ b/spring-boot-starters/pom.xml
@ -19,6 +19,7 @@

  <modules>
    <module>wx-java-miniapp-spring-boot-starter</module>
+    <module>wx-java-mp-multi-spring-boot-starter</module>
    <module>wx-java-mp-spring-boot-starter</module>
    <module>wx-java-pay-spring-boot-starter</module>
    <module>wx-java-open-spring-boot-starter</module>
--- a/spring-boot-starters/wx-java-mp-multi-spring-boot-starter/README.md
+++ b/spring-boot-starters/wx-java-mp-multi-spring-boot-starter/README.md
@ -0,0 +1,98 @@
+# wx-java-mp-spring-boot-starter
+
+## 快速开始
+
+1. 引入依赖
+    ```xml
+    <dependency>
+        <groupId>com.github.binarywang</groupId>
+        <artifactId>wx-java-mp-multi-spring-boot-starter</artifactId>
+        <version>${version}</version>
+    </dependency>
+    ```
+2. 添加配置(application.properties)
+    ```properties
+    # 公众号配置
+    ## 应用 1 配置(必填)
+    wx.mp.tenantId1.app-id=appId
+    wx.mp.tenantId1.app-secret=@secret
+    ## 选填
+    wx.mp.tenantId1.token=@token
+    wx.mp.tenantId1.aes-key=@aesKey
+    ## 应用 2 配置(必填)
+    wx.mp.tenantId2.app-id=@appId
+    wx.mp.tenantId2.app-secret =@secret
+    ## 选填
+    wx.mp.tenantId2.token=@token
+    wx.mp.tenantId2.aes-key=@aesKey
+   
+    # ConfigStorage 配置（选填）
+    ## 配置类型: memory(默认), jedis, redisson, redis_template
+    wx.mp.config-storage.type=memory
+    ## 相关redis前缀配置: wx:mp:multi(默认)
+    wx.mp.config-storage.key-prefix=wx:mp:multi
+    wx.mp.config-storage.redis.host=127.0.0.1
+    wx.mp.config-storage.redis.port=6379
+	  ## 单机和 sentinel 同时存在时，优先使用sentinel配置
+	  # wx.mp.config-storage.redis.sentinel-ips=127.0.0.1:16379,127.0.0.1:26379
+	  # wx.mp.config-storage.redis.sentinel-name=mymaster 
+   
+    # http 客户端配置（选填）
+    ## # http客户端类型: http_client(默认), ok_http, jodd_http
+    wx.mp.config-storage.http-client-type=http_client
+    wx.mp.config-storage.http-proxy-host=
+    wx.mp.config-storage.http-proxy-port=
+    wx.mp.config-storage.http-proxy-username=
+    wx.mp.config-storage.http-proxy-password=
+    ## 最大重试次数，默认：5 次，如果小于 0，则为 0
+    wx.mp.config-storage.max-retry-times=5
+    ## 重试时间间隔步进，默认：1000 毫秒，如果小于 0，则为 1000
+    wx.mp.config-storage.retry-sleep-millis=1000
+   
+	  # 公众号地址 host 配置
+	  # wx.mp.hosts.api-host=http://proxy.com/
+	  # wx.mp.hosts.open-host=http://proxy.com/
+	  # wx.mp.hosts.mp-host=http://proxy.com/
+    ```
+3. 自动注入的类型：`WxMpMultiServices`
+
+4. 使用样例
+
+```java
+import com.binarywang.spring.starter.wxjava.mp.service.WxMpMultiServices;
+import me.chanjar.weixin.mp.api.WxMpService;
+import me.chanjar.weixin.mp.api.WxMpUserService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+@Service
+public class DemoService {
+  @Autowired
+  private WxMpMultiServices wxMpMultiServices;
+
+  public void test() {
+    // 应用 1 的 WxMpService
+    WxMpService wxMpService1 = wxMpMultiServices.getWxMpService("tenantId1");
+    WxMpUserService userService1 = wxMpService1.getUserService();
+    userService1.userInfo("xxx");
+    // todo ...
+
+    // 应用 2 的 WxMpService
+    WxMpService wxMpService2 = wxMpMultiServices.getWxMpService("tenantId2");
+    WxMpUserService userService2 = wxMpService2.getUserService();
+    userService2.userInfo("xxx");
+    // todo ...
+
+    // 应用 3 的 WxMpService
+    WxMpService wxMpService3 = wxMpMultiServices.getWxMpService("tenantId3");
+    // 判断是否为空
+    if (wxMpService3 == null) {
+      // todo wxMpService3 为空，请先配置 tenantId3 微信公众号应用参数
+      return;
+    }
+    WxMpUserService userService3 = wxMpService3.getUserService();
+    userService3.userInfo("xxx");
+    // todo ...
+  }
+}
+```
--- a/spring-boot-starters/wx-java-mp-multi-spring-boot-starter/pom.xml
+++ b/spring-boot-starters/wx-java-mp-multi-spring-boot-starter/pom.xml
@ -0,0 +1,72 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+  <parent>
+    <artifactId>wx-java-spring-boot-starters</artifactId>
+    <groupId>com.github.binarywang</groupId>
+    <version>4.6.0</version>
+  </parent>
+  <modelVersion>4.0.0</modelVersion>
+
+  <artifactId>wx-java-mp-multi-spring-boot-starter</artifactId>
+  <name>WxJava - Spring Boot Starter for MP::支持多账号配置</name>
+  <description>微信公众号开发的 Spring Boot Starter::支持多账号配置</description>
+
+  <dependencies>
+    <dependency>
+      <groupId>com.github.binarywang</groupId>
+      <artifactId>weixin-java-mp</artifactId>
+      <version>${project.version}</version>
+    </dependency>
+    <dependency>
+      <groupId>redis.clients</groupId>
+      <artifactId>jedis</artifactId>
+      <scope>provided</scope>
+    </dependency>
+    <dependency>
+      <groupId>org.redisson</groupId>
+      <artifactId>redisson</artifactId>
+      <scope>provided</scope>
+    </dependency>
+    <dependency>
+      <groupId>org.springframework.data</groupId>
+      <artifactId>spring-data-redis</artifactId>
+      <scope>provided</scope>
+    </dependency>
+    <dependency>
+      <groupId>org.jodd</groupId>
+      <artifactId>jodd-http</artifactId>
+      <scope>provided</scope>
+    </dependency>
+    <dependency>
+      <groupId>com.squareup.okhttp3</groupId>
+      <artifactId>okhttp</artifactId>
+      <scope>provided</scope>
+    </dependency>
+  </dependencies>
+
+  <build>
+    <plugins>
+      <plugin>
+        <groupId>org.springframework.boot</groupId>
+        <artifactId>spring-boot-maven-plugin</artifactId>
+        <version>${spring.boot.version}</version>
+      </plugin>
+      <plugin>
+        <groupId>org.apache.maven.plugins</groupId>
+        <artifactId>maven-source-plugin</artifactId>
+        <version>2.2.1</version>
+        <executions>
+          <execution>
+            <id>attach-sources</id>
+            <goals>
+              <goal>jar-no-fork</goal>
+            </goals>
+          </execution>
+        </executions>
+      </plugin>
+    </plugins>
+  </build>
+
+</project>
--- a/spring-boot-starters/wx-java-mp-multi-spring-boot-starter/src/main/java/com/binarywang/spring/starter/wxjava/mp/autoconfigure/WxMpMultiAutoConfiguration.java
+++ b/spring-boot-starters/wx-java-mp-multi-spring-boot-starter/src/main/java/com/binarywang/spring/starter/wxjava/mp/autoconfigure/WxMpMultiAutoConfiguration.java
@ -0,0 +1,14 @@
+package com.binarywang.spring.starter.wxjava.mp.autoconfigure;
+
+import com.binarywang.spring.starter.wxjava.mp.configuration.WxMpMultiServiceConfiguration;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Import;
+
+/**
+ * @author yl
+ * created on 2024/1/23
+ */
+@Configuration
+@Import(WxMpMultiServiceConfiguration.class)
+public class WxMpMultiAutoConfiguration {
+}
--- a/spring-boot-starters/wx-java-mp-multi-spring-boot-starter/src/main/java/com/binarywang/spring/starter/wxjava/mp/configuration/WxMpMultiServiceConfiguration.java
+++ b/spring-boot-starters/wx-java-mp-multi-spring-boot-starter/src/main/java/com/binarywang/spring/starter/wxjava/mp/configuration/WxMpMultiServiceConfiguration.java
@ -0,0 +1,27 @@
+package com.binarywang.spring.starter.wxjava.mp.configuration;
+
+import com.binarywang.spring.starter.wxjava.mp.configuration.services.WxMpInJedisConfiguration;
+import com.binarywang.spring.starter.wxjava.mp.configuration.services.WxMpInMemoryConfiguration;
+import com.binarywang.spring.starter.wxjava.mp.configuration.services.WxMpInRedisTemplateConfiguration;
+import com.binarywang.spring.starter.wxjava.mp.configuration.services.WxMpInRedissonConfiguration;
+import com.binarywang.spring.starter.wxjava.mp.properties.WxMpMultiProperties;
+import org.springframework.boot.context.properties.EnableConfigurationProperties;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Import;
+
+/**
+ * 微信公众号相关服务自动注册
+ *
+ * @author yl
+ * created on 2024/1/23
+ */
+@Configuration
+@EnableConfigurationProperties(WxMpMultiProperties.class)
+@Import({
+  WxMpInJedisConfiguration.class,
+  WxMpInMemoryConfiguration.class,
+  WxMpInRedissonConfiguration.class,
+  WxMpInRedisTemplateConfiguration.class
+})
+public class WxMpMultiServiceConfiguration {
+}
--- a/spring-boot-starters/wx-java-mp-multi-spring-boot-starter/src/main/java/com/binarywang/spring/starter/wxjava/mp/configuration/services/AbstractWxMpConfiguration.java
+++ b/spring-boot-starters/wx-java-mp-multi-spring-boot-starter/src/main/java/com/binarywang/spring/starter/wxjava/mp/configuration/services/AbstractWxMpConfiguration.java
@ -0,0 +1,163 @@
+package com.binarywang.spring.starter.wxjava.mp.configuration.services;
+
+import com.binarywang.spring.starter.wxjava.mp.properties.WxMpMultiProperties;
+import com.binarywang.spring.starter.wxjava.mp.properties.WxMpSingleProperties;
+import com.binarywang.spring.starter.wxjava.mp.service.WxMpMultiServices;
+import com.binarywang.spring.starter.wxjava.mp.service.WxMpMultiServicesImpl;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import me.chanjar.weixin.mp.api.WxMpService;
+import me.chanjar.weixin.mp.api.impl.WxMpServiceHttpClientImpl;
+import me.chanjar.weixin.mp.api.impl.WxMpServiceImpl;
+import me.chanjar.weixin.mp.api.impl.WxMpServiceJoddHttpImpl;
+import me.chanjar.weixin.mp.api.impl.WxMpServiceOkHttpImpl;
+import me.chanjar.weixin.mp.config.WxMpConfigStorage;
+import me.chanjar.weixin.mp.config.WxMpHostConfig;
+import me.chanjar.weixin.mp.config.impl.WxMpDefaultConfigImpl;
+import org.apache.commons.lang3.StringUtils;
+
+import java.util.Collection;
+import java.util.Map;
+import java.util.Set;
+import java.util.stream.Collectors;
+
+/**
+ * WxMpConfigStorage 抽象配置类
+ *
+ * @author yl
+ * created on 2024/1/23
+ */
+@RequiredArgsConstructor
+@Slf4j
+public abstract class AbstractWxMpConfiguration {
+
+  protected WxMpMultiServices wxMpMultiServices(WxMpMultiProperties wxCpMultiProperties) {
+    Map<String, WxMpSingleProperties> appsMap = wxCpMultiProperties.getApps();
+    if (appsMap == null || appsMap.isEmpty()) {
+      log.warn("微信公众号应用参数未配置，通过 WxMpMultiServices#getWxMpService(\"tenantId\")获取实例将返回空");
+      return new WxMpMultiServicesImpl();
+    }
+    /**
+     * 校验 appId 是否唯一，避免使用 redis 缓存 token、ticket 时错乱。
+     *
+     * 查看 {@link me.chanjar.weixin.mp.config.impl.WxMpRedisConfigImpl#setAppId(String)}
+     */
+    Collection<WxMpSingleProperties> apps = appsMap.values();
+    if (apps.size() > 1) {
+      // 校验 appId 是否唯一
+      boolean multi = apps.stream()
+        // 没有 appId，如果不判断是否为空，这里会报 NPE 异常
+        .collect(Collectors.groupingBy(c -> c.getAppId() == null ? 0 : c.getAppId(), Collectors.counting()))
+        .entrySet().stream().anyMatch(e -> e.getValue() > 1);
+      if (multi) {
+        throw new RuntimeException("请确保微信公众号配置 appId 的唯一性");
+      }
+    }
+    WxMpMultiServicesImpl services = new WxMpMultiServicesImpl();
+
+    Set<Map.Entry<String, WxMpSingleProperties>> entries = appsMap.entrySet();
+    for (Map.Entry<String, WxMpSingleProperties> entry : entries) {
+      String tenantId = entry.getKey();
+      WxMpSingleProperties wxMpSingleProperties = entry.getValue();
+      WxMpDefaultConfigImpl storage = this.wxMpConfigStorage(wxCpMultiProperties);
+      this.configApp(storage, wxMpSingleProperties);
+      this.configHttp(storage, wxCpMultiProperties.getConfigStorage());
+      this.configHost(storage, wxCpMultiProperties.getHosts());
+      WxMpService wxCpService = this.wxMpService(storage, wxCpMultiProperties);
+      services.addWxMpService(tenantId, wxCpService);
+    }
+    return services;
+  }
+
+  /**
+   * 配置 WxMpDefaultConfigImpl
+   *
+   * @param wxMpMultiProperties 参数
+   * @return WxMpDefaultConfigImpl
+   */
+  protected abstract WxMpDefaultConfigImpl wxMpConfigStorage(WxMpMultiProperties wxMpMultiProperties);
+
+  public WxMpService wxMpService(WxMpConfigStorage configStorage, WxMpMultiProperties wxMpMultiProperties) {
+    WxMpMultiProperties.ConfigStorage storage = wxMpMultiProperties.getConfigStorage();
+    WxMpMultiProperties.HttpClientType httpClientType = storage.getHttpClientType();
+    WxMpService wxMpService;
+    switch (httpClientType) {
+      case OK_HTTP:
+        wxMpService = new WxMpServiceOkHttpImpl();
+        break;
+      case JODD_HTTP:
+        wxMpService = new WxMpServiceJoddHttpImpl();
+        break;
+      case HTTP_CLIENT:
+        wxMpService = new WxMpServiceHttpClientImpl();
+        break;
+      default:
+        wxMpService = new WxMpServiceImpl();
+        break;
+    }
+
+    wxMpService.setWxMpConfigStorage(configStorage);
+    int maxRetryTimes = storage.getMaxRetryTimes();
+    if (maxRetryTimes < 0) {
+      maxRetryTimes = 0;
+    }
+    int retrySleepMillis = storage.getRetrySleepMillis();
+    if (retrySleepMillis < 0) {
+      retrySleepMillis = 1000;
+    }
+    wxMpService.setRetrySleepMillis(retrySleepMillis);
+    wxMpService.setMaxRetryTimes(maxRetryTimes);
+    return wxMpService;
+  }
+
+  private void configApp(WxMpDefaultConfigImpl config, WxMpSingleProperties corpProperties) {
+    String appId = corpProperties.getAppId();
+    String appSecret = corpProperties.getAppSecret();
+    String token = corpProperties.getToken();
+    String aesKey = corpProperties.getAesKey();
+
+    config.setAppId(appId);
+    config.setSecret(appSecret);
+    if (StringUtils.isNotBlank(token)) {
+      config.setToken(token);
+    }
+    if (StringUtils.isNotBlank(aesKey)) {
+      config.setAesKey(aesKey);
+    }
+  }
+
+  private void configHttp(WxMpDefaultConfigImpl config, WxMpMultiProperties.ConfigStorage storage) {
+    String httpProxyHost = storage.getHttpProxyHost();
+    Integer httpProxyPort = storage.getHttpProxyPort();
+    String httpProxyUsername = storage.getHttpProxyUsername();
+    String httpProxyPassword = storage.getHttpProxyPassword();
+    if (StringUtils.isNotBlank(httpProxyHost)) {
+      config.setHttpProxyHost(httpProxyHost);
+      if (httpProxyPort != null) {
+        config.setHttpProxyPort(httpProxyPort);
+      }
+      if (StringUtils.isNotBlank(httpProxyUsername)) {
+        config.setHttpProxyUsername(httpProxyUsername);
+      }
+      if (StringUtils.isNotBlank(httpProxyPassword)) {
+        config.setHttpProxyPassword(httpProxyPassword);
+      }
+    }
+  }
+
+  /**
+   * wx host config
+   */
+  private void configHost(WxMpDefaultConfigImpl config, WxMpMultiProperties.HostConfig hostConfig) {
+    if (hostConfig != null) {
+      String apiHost = hostConfig.getApiHost();
+      String mpHost = hostConfig.getMpHost();
+      String openHost = hostConfig.getOpenHost();
+      WxMpHostConfig wxMpHostConfig = new WxMpHostConfig();
+      wxMpHostConfig.setApiHost(StringUtils.isNotBlank(apiHost) ? apiHost : null);
+      wxMpHostConfig.setMpHost(StringUtils.isNotBlank(mpHost) ? mpHost : null);
+      wxMpHostConfig.setOpenHost(StringUtils.isNotBlank(openHost) ? openHost : null);
+      config.setHostConfig(wxMpHostConfig);
+    }
+  }
+}
--- a/spring-boot-starters/wx-java-mp-multi-spring-boot-starter/src/main/java/com/binarywang/spring/starter/wxjava/mp/configuration/services/WxMpInJedisConfiguration.java
+++ b/spring-boot-starters/wx-java-mp-multi-spring-boot-starter/src/main/java/com/binarywang/spring/starter/wxjava/mp/configuration/services/WxMpInJedisConfiguration.java
@ -0,0 +1,77 @@
+package com.binarywang.spring.starter.wxjava.mp.configuration.services;
+
+import com.binarywang.spring.starter.wxjava.mp.properties.WxMpMultiProperties;
+import com.binarywang.spring.starter.wxjava.mp.properties.WxMpMultiRedisProperties;
+import com.binarywang.spring.starter.wxjava.mp.service.WxMpMultiServices;
+import lombok.RequiredArgsConstructor;
+import me.chanjar.weixin.common.redis.JedisWxRedisOps;
+import me.chanjar.weixin.mp.config.impl.WxMpDefaultConfigImpl;
+import me.chanjar.weixin.mp.config.impl.WxMpRedisConfigImpl;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
+import org.springframework.context.ApplicationContext;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import redis.clients.jedis.JedisPool;
+import redis.clients.jedis.JedisPoolConfig;
+
+/**
+ * 自动装配基于 jedis 策略配置
+ *
+ * @author yl
+ * created on 2024/1/23
+ */
+@Configuration
+@ConditionalOnProperty(
+  prefix = WxMpMultiProperties.PREFIX + ".config-storage", name = "type", havingValue = "jedis"
+)
+@RequiredArgsConstructor
+public class WxMpInJedisConfiguration extends AbstractWxMpConfiguration {
+  private final WxMpMultiProperties wxCpMultiProperties;
+  private final ApplicationContext applicationContext;
+
+  @Bean
+  public WxMpMultiServices wxMpMultiServices() {
+    return this.wxMpMultiServices(wxCpMultiProperties);
+  }
+
+  @Override
+  protected WxMpDefaultConfigImpl wxMpConfigStorage(WxMpMultiProperties wxCpMultiProperties) {
+    return this.configRedis(wxCpMultiProperties);
+  }
+
+  private WxMpDefaultConfigImpl configRedis(WxMpMultiProperties wxCpMultiProperties) {
+    WxMpMultiRedisProperties wxCpMultiRedisProperties = wxCpMultiProperties.getConfigStorage().getRedis();
+    JedisPool jedisPool;
+    if (wxCpMultiRedisProperties != null && StringUtils.isNotEmpty(wxCpMultiRedisProperties.getHost())) {
+      jedisPool = getJedisPool(wxCpMultiProperties);
+    } else {
+      jedisPool = applicationContext.getBean(JedisPool.class);
+    }
+    return new WxMpRedisConfigImpl(new JedisWxRedisOps(jedisPool), wxCpMultiProperties.getConfigStorage().getKeyPrefix());
+  }
+
+  private JedisPool getJedisPool(WxMpMultiProperties wxCpMultiProperties) {
+    WxMpMultiProperties.ConfigStorage storage = wxCpMultiProperties.getConfigStorage();
+    WxMpMultiRedisProperties redis = storage.getRedis();
+
+    JedisPoolConfig config = new JedisPoolConfig();
+    if (redis.getMaxActive() != null) {
+      config.setMaxTotal(redis.getMaxActive());
+    }
+    if (redis.getMaxIdle() != null) {
+      config.setMaxIdle(redis.getMaxIdle());
+    }
+    if (redis.getMaxWaitMillis() != null) {
+      config.setMaxWaitMillis(redis.getMaxWaitMillis());
+    }
+    if (redis.getMinIdle() != null) {
+      config.setMinIdle(redis.getMinIdle());
+    }
+    config.setTestOnBorrow(true);
+    config.setTestWhileIdle(true);
+
+    return new JedisPool(config, redis.getHost(), redis.getPort(),
+      redis.getTimeout(), redis.getPassword(), redis.getDatabase());
+  }
+}
--- a/spring-boot-starters/wx-java-mp-multi-spring-boot-starter/src/main/java/com/binarywang/spring/starter/wxjava/mp/configuration/services/WxMpInMemoryConfiguration.java
+++ b/spring-boot-starters/wx-java-mp-multi-spring-boot-starter/src/main/java/com/binarywang/spring/starter/wxjava/mp/configuration/services/WxMpInMemoryConfiguration.java
@ -0,0 +1,40 @@
+package com.binarywang.spring.starter.wxjava.mp.configuration.services;
+
+import com.binarywang.spring.starter.wxjava.mp.properties.WxMpMultiProperties;
+import com.binarywang.spring.starter.wxjava.mp.service.WxMpMultiServices;
+import lombok.RequiredArgsConstructor;
+import me.chanjar.weixin.mp.config.impl.WxMpDefaultConfigImpl;
+import me.chanjar.weixin.mp.config.impl.WxMpMapConfigImpl;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+/**
+ * 自动装配基于内存策略配置
+ *
+ * @author yl
+ * created on 2024/1/23
+ */
+@Configuration
+@ConditionalOnProperty(
+  prefix = WxMpMultiProperties.PREFIX + ".config-storage", name = "type", havingValue = "memory", matchIfMissing = true
+)
+@RequiredArgsConstructor
+public class WxMpInMemoryConfiguration extends AbstractWxMpConfiguration {
+  private final WxMpMultiProperties wxCpMultiProperties;
+
+  @Bean
+  public WxMpMultiServices wxCpMultiServices() {
+    return this.wxMpMultiServices(wxCpMultiProperties);
+  }
+
+  @Override
+  protected WxMpDefaultConfigImpl wxMpConfigStorage(WxMpMultiProperties wxCpMultiProperties) {
+    return this.configInMemory();
+  }
+
+  private WxMpDefaultConfigImpl configInMemory() {
+    return new WxMpMapConfigImpl();
+    // return new WxMpDefaultConfigImpl();
+  }
+}
--- a/spring-boot-starters/wx-java-mp-multi-spring-boot-starter/src/main/java/com/binarywang/spring/starter/wxjava/mp/configuration/services/WxMpInRedisTemplateConfiguration.java
+++ b/spring-boot-starters/wx-java-mp-multi-spring-boot-starter/src/main/java/com/binarywang/spring/starter/wxjava/mp/configuration/services/WxMpInRedisTemplateConfiguration.java
@ -0,0 +1,45 @@
+package com.binarywang.spring.starter.wxjava.mp.configuration.services;
+
+import com.binarywang.spring.starter.wxjava.mp.properties.WxMpMultiProperties;
+import com.binarywang.spring.starter.wxjava.mp.service.WxMpMultiServices;
+import lombok.RequiredArgsConstructor;
+import me.chanjar.weixin.common.redis.RedisTemplateWxRedisOps;
+import me.chanjar.weixin.mp.config.impl.WxMpDefaultConfigImpl;
+import me.chanjar.weixin.mp.config.impl.WxMpRedisConfigImpl;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
+import org.springframework.context.ApplicationContext;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.data.redis.core.StringRedisTemplate;
+
+/**
+ * 自动装配基于 redisTemplate 策略配置
+ *
+ * @author yl
+ * created on 2024/1/23
+ */
+@Configuration
+@ConditionalOnProperty(
+  prefix = WxMpMultiProperties.PREFIX + ".config-storage", name = "type", havingValue = "redis_template"
+)
+@RequiredArgsConstructor
+public class WxMpInRedisTemplateConfiguration extends AbstractWxMpConfiguration {
+  private final WxMpMultiProperties WxMpMultiProperties;
+  private final ApplicationContext applicationContext;
+
+  @Bean
+  public WxMpMultiServices wxMpMultiServices() {
+    return this.wxMpMultiServices(WxMpMultiProperties);
+  }
+
+  @Override
+  protected WxMpDefaultConfigImpl wxMpConfigStorage(WxMpMultiProperties wxMpMultiProperties) {
+    return this.configRedisTemplate(WxMpMultiProperties);
+  }
+
+  private WxMpDefaultConfigImpl configRedisTemplate(WxMpMultiProperties wxMpMultiProperties) {
+    StringRedisTemplate redisTemplate = applicationContext.getBean(StringRedisTemplate.class);
+    return new WxMpRedisConfigImpl(new RedisTemplateWxRedisOps(redisTemplate),
+      wxMpMultiProperties.getConfigStorage().getKeyPrefix());
+  }
+}
--- a/spring-boot-starters/wx-java-mp-multi-spring-boot-starter/src/main/java/com/binarywang/spring/starter/wxjava/mp/configuration/services/WxMpInRedissonConfiguration.java
+++ b/spring-boot-starters/wx-java-mp-multi-spring-boot-starter/src/main/java/com/binarywang/spring/starter/wxjava/mp/configuration/services/WxMpInRedissonConfiguration.java
@ -0,0 +1,67 @@
+package com.binarywang.spring.starter.wxjava.mp.configuration.services;
+
+import com.binarywang.spring.starter.wxjava.mp.properties.WxMpMultiProperties;
+import com.binarywang.spring.starter.wxjava.mp.properties.WxMpMultiRedisProperties;
+import com.binarywang.spring.starter.wxjava.mp.service.WxMpMultiServices;
+import lombok.RequiredArgsConstructor;
+import me.chanjar.weixin.mp.config.impl.WxMpDefaultConfigImpl;
+import me.chanjar.weixin.mp.config.impl.WxMpRedissonConfigImpl;
+import org.apache.commons.lang3.StringUtils;
+import org.redisson.Redisson;
+import org.redisson.api.RedissonClient;
+import org.redisson.config.Config;
+import org.redisson.config.TransportMode;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
+import org.springframework.context.ApplicationContext;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+/**
+ * 自动装配基于 redisson 策略配置
+ *
+ * @author yl
+ * created on 2024/1/23
+ */
+@Configuration
+@ConditionalOnProperty(
+  prefix = WxMpMultiProperties.PREFIX + ".config-storage", name = "type", havingValue = "redisson"
+)
+@RequiredArgsConstructor
+public class WxMpInRedissonConfiguration extends AbstractWxMpConfiguration {
+  private final WxMpMultiProperties wxCpMultiProperties;
+  private final ApplicationContext applicationContext;
+
+  @Bean
+  public WxMpMultiServices wxMpMultiServices() {
+    return this.wxMpMultiServices(wxCpMultiProperties);
+  }
+
+  @Override
+  protected WxMpDefaultConfigImpl wxMpConfigStorage(WxMpMultiProperties wxCpMultiProperties) {
+    return this.configRedisson(wxCpMultiProperties);
+  }
+
+  private WxMpDefaultConfigImpl configRedisson(WxMpMultiProperties wxCpMultiProperties) {
+    WxMpMultiRedisProperties redisProperties = wxCpMultiProperties.getConfigStorage().getRedis();
+    RedissonClient redissonClient;
+    if (redisProperties != null && StringUtils.isNotEmpty(redisProperties.getHost())) {
+      redissonClient = getRedissonClient(wxCpMultiProperties);
+    } else {
+      redissonClient = applicationContext.getBean(RedissonClient.class);
+    }
+    return new WxMpRedissonConfigImpl(redissonClient, wxCpMultiProperties.getConfigStorage().getKeyPrefix());
+  }
+
+  private RedissonClient getRedissonClient(WxMpMultiProperties wxCpMultiProperties) {
+    WxMpMultiProperties.ConfigStorage storage = wxCpMultiProperties.getConfigStorage();
+    WxMpMultiRedisProperties redis = storage.getRedis();
+
+    Config config = new Config();
+    config.useSingleServer()
+      .setAddress("redis://" + redis.getHost() + ":" + redis.getPort())
+      .setDatabase(redis.getDatabase())
+      .setPassword(redis.getPassword());
+    config.setTransportMode(TransportMode.NIO);
+    return Redisson.create(config);
+  }
+}
--- a/spring-boot-starters/wx-java-mp-multi-spring-boot-starter/src/main/java/com/binarywang/spring/starter/wxjava/mp/properties/WxMpMultiProperties.java
+++ b/spring-boot-starters/wx-java-mp-multi-spring-boot-starter/src/main/java/com/binarywang/spring/starter/wxjava/mp/properties/WxMpMultiProperties.java
@ -0,0 +1,145 @@
+package com.binarywang.spring.starter.wxjava.mp.properties;
+
+import lombok.Data;
+import lombok.NoArgsConstructor;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.boot.context.properties.NestedConfigurationProperty;
+
+import java.io.Serializable;
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * @author yl
+ * created on 2024/1/23
+ */
+@Data
+@NoArgsConstructor
+@ConfigurationProperties(WxMpMultiProperties.PREFIX)
+public class WxMpMultiProperties implements Serializable {
+  private static final long serialVersionUID = -5358245184407791011L;
+  public static final String PREFIX = "wx.mp";
+
+  private Map<String, WxMpSingleProperties> apps = new HashMap<>();
+
+  /**
+   * 自定义host配置
+   */
+  private HostConfig hosts;
+
+  /**
+   * 存储策略
+   */
+  private final ConfigStorage configStorage = new ConfigStorage();
+
+  @Data
+  @NoArgsConstructor
+  public static class HostConfig implements Serializable {
+    private static final long serialVersionUID = -4172767630740346001L;
+
+    private String apiHost;
+
+    private String openHost;
+
+    private String mpHost;
+  }
+
+  @Data
+  @NoArgsConstructor
+  public static class ConfigStorage implements Serializable {
+    private static final long serialVersionUID = 4815731027000065434L;
+
+    /**
+     * 存储类型.
+     */
+    private StorageType type = StorageType.MEMORY;
+
+    /**
+     * 指定key前缀.
+     */
+    private String keyPrefix = "wx:mp:multi";
+
+    /**
+     * redis连接配置.
+     */
+    @NestedConfigurationProperty
+    private final WxMpMultiRedisProperties redis = new WxMpMultiRedisProperties();
+
+    /**
+     * http客户端类型.
+     */
+    private HttpClientType httpClientType = HttpClientType.HTTP_CLIENT;
+
+    /**
+     * http代理主机.
+     */
+    private String httpProxyHost;
+
+    /**
+     * http代理端口.
+     */
+    private Integer httpProxyPort;
+
+    /**
+     * http代理用户名.
+     */
+    private String httpProxyUsername;
+
+    /**
+     * http代理密码.
+     */
+    private String httpProxyPassword;
+
+    /**
+     * http 请求最大重试次数
+     * <pre>
+     *   {@link me.chanjar.weixin.mp.api.WxMpService#setMaxRetryTimes(int)}
+     *   {@link me.chanjar.weixin.mp.api.impl.BaseWxMpServiceImpl#setMaxRetryTimes(int)}
+     * </pre>
+     */
+    private int maxRetryTimes = 5;
+
+    /**
+     * http 请求重试间隔
+     * <pre>
+     *   {@link me.chanjar.weixin.mp.api.WxMpService#setRetrySleepMillis(int)}
+     *   {@link me.chanjar.weixin.mp.api.impl.BaseWxMpServiceImpl#setRetrySleepMillis(int)}
+     * </pre>
+     */
+    private int retrySleepMillis = 1000;
+  }
+
+  public enum StorageType {
+    /**
+     * 内存
+     */
+    MEMORY,
+    /**
+     * jedis
+     */
+    JEDIS,
+    /**
+     * redisson
+     */
+    REDISSON,
+    /**
+     * redisTemplate
+     */
+    REDIS_TEMPLATE
+  }
+
+  public enum HttpClientType {
+    /**
+     * HttpClient
+     */
+    HTTP_CLIENT,
+    /**
+     * OkHttp
+     */
+    OK_HTTP,
+    /**
+     * JoddHttp
+     */
+    JODD_HTTP
+  }
+}
--- a/spring-boot-starters/wx-java-mp-multi-spring-boot-starter/src/main/java/com/binarywang/spring/starter/wxjava/mp/properties/WxMpMultiRedisProperties.java
+++ b/spring-boot-starters/wx-java-mp-multi-spring-boot-starter/src/main/java/com/binarywang/spring/starter/wxjava/mp/properties/WxMpMultiRedisProperties.java
@ -0,0 +1,56 @@
+package com.binarywang.spring.starter.wxjava.mp.properties;
+
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.io.Serializable;
+
+/**
+ * @author yl
+ * created on 2024/1/23
+ */
+@Data
+@NoArgsConstructor
+public class WxMpMultiRedisProperties implements Serializable {
+  private static final long serialVersionUID = -5924815351660074401L;
+
+  /**
+   * 主机地址.
+   */
+  private String host = "127.0.0.1";
+
+  /**
+   * 端口号.
+   */
+  private int port = 6379;
+
+  /**
+   * 密码.
+   */
+  private String password;
+
+  /**
+   * 超时.
+   */
+  private int timeout = 2000;
+
+  /**
+   * 数据库.
+   */
+  private int database = 0;
+
+  /**
+   * sentinel ips
+   */
+  private String sentinelIps;
+
+  /**
+   * sentinel name
+   */
+  private String sentinelName;
+
+  private Integer maxActive;
+  private Integer maxIdle;
+  private Integer maxWaitMillis;
+  private Integer minIdle;
+}
--- a/spring-boot-starters/wx-java-mp-multi-spring-boot-starter/src/main/java/com/binarywang/spring/starter/wxjava/mp/properties/WxMpSingleProperties.java
+++ b/spring-boot-starters/wx-java-mp-multi-spring-boot-starter/src/main/java/com/binarywang/spring/starter/wxjava/mp/properties/WxMpSingleProperties.java
@ -0,0 +1,35 @@
+package com.binarywang.spring.starter.wxjava.mp.properties;
+
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.io.Serializable;
+
+/**
+ * @author yl
+ * created on 2024/1/23
+ */
+@Data
+@NoArgsConstructor
+public class WxMpSingleProperties implements Serializable {
+  private static final long serialVersionUID = 1980986361098922525L;
+  /**
+   * 设置微信公众号的 appid.
+   */
+  private String appId;
+
+  /**
+   * 设置微信公众号的 app secret.
+   */
+  private String appSecret;
+
+  /**
+   * 设置微信公众号的 token.
+   */
+  private String token;
+
+  /**
+   * 设置微信公众号的 EncodingAESKey.
+   */
+  private String aesKey;
+}
--- a/spring-boot-starters/wx-java-mp-multi-spring-boot-starter/src/main/java/com/binarywang/spring/starter/wxjava/mp/service/WxMpMultiServices.java
+++ b/spring-boot-starters/wx-java-mp-multi-spring-boot-starter/src/main/java/com/binarywang/spring/starter/wxjava/mp/service/WxMpMultiServices.java
@ -0,0 +1,27 @@
+package com.binarywang.spring.starter.wxjava.mp.service;
+
+
+import me.chanjar.weixin.mp.api.WxMpService;
+
+/**
+ * 企业微信 {@link WxMpService} 所有实例存放类.
+ *
+ * @author yl
+ * created on 2024/1/23
+ */
+public interface WxMpMultiServices {
+  /**
+   * 通过租户 Id 获取 WxMpService
+   *
+   * @param tenantId 租户 Id
+   * @return WxMpService
+   */
+  WxMpService getWxMpService(String tenantId);
+
+  /**
+   * 根据租户 Id，从列表中移除一个 WxMpService 实例
+   *
+   * @param tenantId 租户 Id
+   */
+  void removeWxMpService(String tenantId);
+}
--- a/spring-boot-starters/wx-java-mp-multi-spring-boot-starter/src/main/java/com/binarywang/spring/starter/wxjava/mp/service/WxMpMultiServicesImpl.java
+++ b/spring-boot-starters/wx-java-mp-multi-spring-boot-starter/src/main/java/com/binarywang/spring/starter/wxjava/mp/service/WxMpMultiServicesImpl.java
@ -0,0 +1,36 @@
+package com.binarywang.spring.starter.wxjava.mp.service;
+
+import me.chanjar.weixin.mp.api.WxMpService;
+
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
+
+/**
+ * 企业微信 {@link WxMpMultiServices} 默认实现
+ *
+ * @author yl
+ * created on 2024/1/23
+ */
+public class WxMpMultiServicesImpl implements WxMpMultiServices {
+  private final Map<String, WxMpService> services = new ConcurrentHashMap<>();
+
+  @Override
+  public WxMpService getWxMpService(String tenantId) {
+    return this.services.get(tenantId);
+  }
+
+  /**
+   * 根据租户 Id，添加一个 WxMpService 到列表
+   *
+   * @param tenantId    租户 Id
+   * @param wxMpService WxMpService 实例
+   */
+  public void addWxMpService(String tenantId, WxMpService wxMpService) {
+    this.services.put(tenantId, wxMpService);
+  }
+
+  @Override
+  public void removeWxMpService(String tenantId) {
+    this.services.remove(tenantId);
+  }
+}
--- a/spring-boot-starters/wx-java-mp-multi-spring-boot-starter/src/main/resources/META-INF/spring.factories
+++ b/spring-boot-starters/wx-java-mp-multi-spring-boot-starter/src/main/resources/META-INF/spring.factories
@ -0,0 +1,2 @@
+org.springframework.boot.autoconfigure.EnableAutoConfiguration=\
+com.binarywang.spring.starter.wxjava.mp.autoconfigure.WxMpMultiAutoConfiguration
--- a/spring-boot-starters/wx-java-mp-multi-spring-boot-starter/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports
+++ b/spring-boot-starters/wx-java-mp-multi-spring-boot-starter/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports
@ -0,0 +1 @@
+com.binarywang.spring.starter.wxjava.mp.autoconfigure.WxMpMultiAutoConfiguration
				`@ -0,0 +1 @@`
				`com.binarywang.spring.starter.wxjava.mp.autoconfigure.WxMpMultiAutoConfiguration`