lsm/weixin-java-tools
1
0
Fork 0
mirror of https://gitee.com/binary/weixin-java-tools.git synced 2025-04-05 08:37:32 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

🆕 添加 solon-plugins 下的两个新模块

Browse Source
This commit is contained in:
西东 2024-10-09 12:33:11 +08:00 committed by GitHub
parent 17399b59f5
commit 42621285fb
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
36 changed files with 1737 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
solon-plugins/pom.xml
View File

@ -14,10 +14,11 @@
<description>WxJava 各个模块的 Solon Plugin</description>
<properties>
<solon.version>2.9.2</solon.version>
<solon.version>3.0.1</solon.version>
</properties>
<modules>
<module>wx-java-miniapp-multi-solon-plugin</module>
<module>wx-java-miniapp-solon-plugin</module>
<module>wx-java-mp-multi-solon-plugin</module>
<module>wx-java-mp-solon-plugin</module>
@ -27,6 +28,7 @@
<module>wx-java-cp-multi-solon-plugin</module>
<module>wx-java-cp-solon-plugin</module>
<module>wx-java-channel-solon-plugin</module>
<module>wx-java-channel-multi-solon-plugin</module>
</modules>
<dependencies>

111
solon-plugins/wx-java-channel-multi-solon-plugin/README.md Normal file
View File

@ -0,0 +1,111 @@
# wx-java-channel-multi-solon-plugin
## 快速开始
1. 引入依赖
```xml
<dependencies>
<dependency>
<groupId>com.github.binarywang</groupId>
<artifactId>wx-java-channel-multi-solon-plugin</artifactId>
<version>${version}</version>
</dependency>
<!-- 配置存储方式为jedis 则引入jedis -->
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>${jedis.version}</version>
</dependency>
<!-- 配置存储方式为redisson 则引入redisson -->
<dependency>
<groupId>org.redisson</groupId>
<artifactId>redisson</artifactId>
<version>${redisson.version}</version>
</dependency>
</dependencies>
```
2. 添加配置(app.properties)
```properties
# 视频号配置
## 应用 1 配置(必填)
wx.channel.apps.tenantId1.app-id=@appId
wx.channel.apps.tenantId1.secret=@secret
## 选填
wx.channel.apps.tenantId1.use-stable-access-token=false
wx.channel.apps.tenantId1.token=
wx.channel.apps.tenantId1.aes-key=
## 应用 2 配置(必填)
wx.channel.apps.tenantId2.app-id=@appId
wx.channel.apps.tenantId2.secret=@secret
## 选填
wx.channel.apps.tenantId2.use-stable-access-token=false
wx.channel.apps.tenantId2.token=
wx.channel.apps.tenantId2.aes-key=
# ConfigStorage 配置（选填）
## 配置类型: memory(默认), jedis, redisson, redis_template
wx.channel.config-storage.type=memory
## 相关redis前缀配置: wx:channel:multi(默认)
wx.channel.config-storage.key-prefix=wx:channel:multi
wx.channel.config-storage.redis.host=127.0.0.1
wx.channel.config-storage.redis.port=6379
wx.channel.config-storage.redis.password=123456
# http 客户端配置（选填）
## # http客户端类型: http_client(默认)
wx.channel.config-storage.http-client-type=http_client
wx.channel.config-storage.http-proxy-host=
wx.channel.config-storage.http-proxy-port=
wx.channel.config-storage.http-proxy-username=
wx.channel.config-storage.http-proxy-password=
## 最大重试次数，默认：5 次，如果小于 0，则为 0
wx.channel.config-storage.max-retry-times=5
## 重试时间间隔步进，默认：1000 毫秒，如果小于 0，则为 1000
wx.channel.config-storage.retry-sleep-millis=1000
```
3. 自动注入的类型：`WxChannelMultiServices`
4. 使用样例
```java
import com.binarywang.solon.wxjava.channel.service.WxChannelMultiServices;
import me.chanjar.weixin.channel.api.WxChannelService;
import me.chanjar.weixin.channel.api.WxFinderLiveService;
import me.chanjar.weixin.channel.bean.lead.component.response.FinderAttrResponse;
import me.chanjar.weixin.common.error.WxErrorException;
import org.noear.solon.annotation.Component;
import org.noear.solon.annotation.Inject;
@Component
public class DemoService {
@Inject
private WxChannelMultiServices wxChannelMultiServices;
public void test() throws WxErrorException {
// 应用 1 的 WxChannelService
WxChannelService wxChannelService1 = wxChannelMultiServices.getWxChannelService("tenantId1");
WxFinderLiveService finderLiveService = wxChannelService1.getFinderLiveService();
FinderAttrResponse response1 = finderLiveService.getFinderAttrByAppid();
// todo ...
// 应用 2 的 WxChannelService
WxChannelService wxChannelService2 = wxChannelMultiServices.getWxChannelService("tenantId2");
WxFinderLiveService finderLiveService2 = wxChannelService2.getFinderLiveService();
FinderAttrResponse response2 = finderLiveService2.getFinderAttrByAppid();
// todo ...
// 应用 3 的 WxChannelService
WxChannelService wxChannelService3 = wxChannelMultiServices.getWxChannelService("tenantId3");
// 判断是否为空
if (wxChannelService3 == null) {
// todo wxChannelService3 为空，请先配置 tenantId3 微信视频号应用参数
return;
}
WxFinderLiveService finderLiveService3 = wxChannelService3.getFinderLiveService();
FinderAttrResponse response3 = finderLiveService3.getFinderAttrByAppid();
// todo ...
}
}
```

43
solon-plugins/wx-java-channel-multi-solon-plugin/pom.xml Normal file
View File

@ -0,0 +1,43 @@
<?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-solon-plugins</artifactId>
<groupId>com.github.binarywang</groupId>
<version>4.6.5.B</version>
</parent>
<modelVersion>4.0.0</modelVersion>
<artifactId>wx-java-channel-multi-solon-plugin</artifactId>
<name>WxJava - Solon Plugin for Channel::支持多账号配置</name>
<description>微信视频号开发的 Solon Plugin::支持多账号配置</description>
<dependencies>
<dependency>
<groupId>com.github.binarywang</groupId>
<artifactId>weixin-java-channel</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.jodd</groupId>
<artifactId>jodd-http</artifactId>
<scope>provided</scope>
</dependency>
<dependency>
<groupId>com.squareup.okhttp3</groupId>
<artifactId>okhttp</artifactId>
<scope>provided</scope>
</dependency>
</dependencies>
</project>

140
solon-plugins/wx-java-channel-multi-solon-plugin/src/main/java/com/binarywang/solon/wxjava/channel/configuration/services/AbstractWxChannelConfiguration.java Normal file
View File

@ -0,0 +1,140 @@
package com.binarywang.solon.wxjava.channel.configuration.services;
import com.binarywang.solon.wxjava.channel.enums.HttpClientType;
import com.binarywang.solon.wxjava.channel.properties.WxChannelMultiProperties;
import com.binarywang.solon.wxjava.channel.properties.WxChannelSingleProperties;
import com.binarywang.solon.wxjava.channel.service.WxChannelMultiServices;
import com.binarywang.solon.wxjava.channel.service.WxChannelMultiServicesImpl;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import me.chanjar.weixin.channel.api.WxChannelService;
import me.chanjar.weixin.channel.api.impl.WxChannelServiceHttpClientImpl;
import me.chanjar.weixin.channel.api.impl.WxChannelServiceImpl;
import me.chanjar.weixin.channel.config.WxChannelConfig;
import me.chanjar.weixin.channel.config.impl.WxChannelDefaultConfigImpl;
import org.apache.commons.lang3.StringUtils;
import java.util.Collection;
import java.util.Map;
import java.util.Set;
import java.util.stream.Collectors;
/**
* WxChannelConfigStorage 抽象配置类
*
* @author <a href="https://github.com/Winnie-by996">Winnie</a> 2024/9/13
* @author noear
*/
@RequiredArgsConstructor
@Slf4j
public abstract class AbstractWxChannelConfiguration {
protected WxChannelMultiServices wxChannelMultiServices(WxChannelMultiProperties wxChannelMultiProperties) {
Map<String, WxChannelSingleProperties> appsMap = wxChannelMultiProperties.getApps();
if (appsMap == null || appsMap.isEmpty()) {
log.warn("微信视频号应用参数未配置，通过 WxChannelMultiServices#getWxChannelService(\"tenantId\")获取实例将返回空");
return new WxChannelMultiServicesImpl();
}
/**
* 校验 appId 是否唯一，避免使用 redis 缓存 token、ticket 时错乱。
*
* 查看 {@link me.chanjar.weixin.channel.config.impl.WxChannelRedisConfigImpl#setAppid(String)}
*/
Collection<WxChannelSingleProperties> 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 的唯一性");
}
}
WxChannelMultiServicesImpl services = new WxChannelMultiServicesImpl();
Set<Map.Entry<String, WxChannelSingleProperties>> entries = appsMap.entrySet();
for (Map.Entry<String, WxChannelSingleProperties> entry : entries) {
String tenantId = entry.getKey();
WxChannelSingleProperties wxChannelSingleProperties = entry.getValue();
WxChannelDefaultConfigImpl storage = this.wxChannelConfigStorage(wxChannelMultiProperties);
this.configApp(storage, wxChannelSingleProperties);
this.configHttp(storage, wxChannelMultiProperties.getConfigStorage());
WxChannelService wxChannelService = this.wxChannelService(storage, wxChannelMultiProperties, wxChannelSingleProperties.isUseStableAccessToken());
services.addWxChannelService(tenantId, wxChannelService);
}
return services;
}
/**
* 配置 WxChannelDefaultConfigImpl
*
* @param wxChannelMultiProperties 参数
* @return WxChannelDefaultConfigImpl
*/
protected abstract WxChannelDefaultConfigImpl wxChannelConfigStorage(WxChannelMultiProperties wxChannelMultiProperties);
public WxChannelService wxChannelService(WxChannelConfig wxChannelConfig, WxChannelMultiProperties wxChannelMultiProperties, boolean useStableAccessToken) {
WxChannelMultiProperties.ConfigStorage storage = wxChannelMultiProperties.getConfigStorage();
HttpClientType httpClientType = storage.getHttpClientType();
WxChannelService wxChannelService;
switch (httpClientType) {
// case OK_HTTP:
// wxChannelService = new WxChannelServiceOkHttpImpl(false, false);
// break;
case HTTP_CLIENT:
wxChannelService = new WxChannelServiceHttpClientImpl(useStableAccessToken, false);
break;
default:
wxChannelService = new WxChannelServiceImpl();
break;
}
wxChannelService.setConfig(wxChannelConfig);
int maxRetryTimes = storage.getMaxRetryTimes();
if (maxRetryTimes < 0) {
maxRetryTimes = 0;
}
int retrySleepMillis = storage.getRetrySleepMillis();
if (retrySleepMillis < 0) {
retrySleepMillis = 1000;
}
wxChannelService.setRetrySleepMillis(retrySleepMillis);
wxChannelService.setMaxRetryTimes(maxRetryTimes);
return wxChannelService;
}
private void configApp(WxChannelDefaultConfigImpl config, WxChannelSingleProperties wxChannelSingleProperties) {
String appId = wxChannelSingleProperties.getAppId();
String appSecret = wxChannelSingleProperties.getSecret();
String token = wxChannelSingleProperties.getToken();
String aesKey = wxChannelSingleProperties.getAesKey();
config.setAppid(appId);
config.setSecret(appSecret);
if (StringUtils.isNotBlank(token)) {
config.setToken(token);
}
if (StringUtils.isNotBlank(aesKey)) {
config.setAesKey(aesKey);
}
}
private void configHttp(WxChannelDefaultConfigImpl config, WxChannelMultiProperties.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);
}
}
}
}

77
solon-plugins/wx-java-channel-multi-solon-plugin/src/main/java/com/binarywang/solon/wxjava/channel/configuration/services/WxChannelInJedisConfiguration.java Normal file
View File

@ -0,0 +1,77 @@
package com.binarywang.solon.wxjava.channel.configuration.services;
import com.binarywang.solon.wxjava.channel.properties.WxChannelMultiProperties;
import com.binarywang.solon.wxjava.channel.properties.WxChannelMultiRedisProperties;
import com.binarywang.solon.wxjava.channel.service.WxChannelMultiServices;
import lombok.RequiredArgsConstructor;
import me.chanjar.weixin.channel.config.impl.WxChannelDefaultConfigImpl;
import me.chanjar.weixin.channel.config.impl.WxChannelRedisConfigImpl;
import me.chanjar.weixin.common.redis.JedisWxRedisOps;
import org.apache.commons.lang3.StringUtils;
import org.noear.solon.annotation.Bean;
import org.noear.solon.annotation.Condition;
import org.noear.solon.annotation.Configuration;
import org.noear.solon.core.AppContext;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;
/**
* 自动装配基于 jedis 策略配置
*
* @author <a href="https://github.com/Winnie-by996">Winnie</a> 2024/9/13
* @author noear
*/
@Configuration
@Condition(
onProperty = "${"+WxChannelMultiProperties.PREFIX + ".configStorage.type} = jedis",
onClass = JedisPool.class
)
@RequiredArgsConstructor
public class WxChannelInJedisConfiguration extends AbstractWxChannelConfiguration {
private final WxChannelMultiProperties wxChannelMultiProperties;
private final AppContext applicationContext;
@Bean
public WxChannelMultiServices wxChannelMultiServices() {
return this.wxChannelMultiServices(wxChannelMultiProperties);
}
@Override
protected WxChannelDefaultConfigImpl wxChannelConfigStorage(WxChannelMultiProperties wxChannelMultiProperties) {
return this.configRedis(wxChannelMultiProperties);
}
private WxChannelDefaultConfigImpl configRedis(WxChannelMultiProperties wxChannelMultiProperties) {
WxChannelMultiRedisProperties wxChannelMultiRedisProperties = wxChannelMultiProperties.getConfigStorage().getRedis();
JedisPool jedisPool;
if (wxChannelMultiRedisProperties != null && StringUtils.isNotEmpty(wxChannelMultiRedisProperties.getHost())) {
jedisPool = getJedisPool(wxChannelMultiProperties);
} else {
jedisPool = applicationContext.getBean(JedisPool.class);
}
return new WxChannelRedisConfigImpl(new JedisWxRedisOps(jedisPool), wxChannelMultiProperties.getConfigStorage().getKeyPrefix());
}
private JedisPool getJedisPool(WxChannelMultiProperties wxChannelMultiProperties) {
WxChannelMultiProperties.ConfigStorage storage = wxChannelMultiProperties.getConfigStorage();
WxChannelMultiRedisProperties 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());
}
}

40
solon-plugins/wx-java-channel-multi-solon-plugin/src/main/java/com/binarywang/solon/wxjava/channel/configuration/services/WxChannelInMemoryConfiguration.java Normal file
View File

@ -0,0 +1,40 @@
package com.binarywang.solon.wxjava.channel.configuration.services;
import com.binarywang.solon.wxjava.channel.properties.WxChannelMultiProperties;
import com.binarywang.solon.wxjava.channel.service.WxChannelMultiServices;
import lombok.RequiredArgsConstructor;
import me.chanjar.weixin.channel.config.impl.WxChannelDefaultConfigImpl;
import org.noear.solon.annotation.Bean;
import org.noear.solon.annotation.Condition;
import org.noear.solon.annotation.Configuration;
import redis.clients.jedis.JedisPool;
/**
* 自动装配基于内存策略配置
*
* @author <a href="https://github.com/Winnie-by996">Winnie</a> 2024/9/13
* @author noear
*/
@Configuration
@Condition(
onProperty = "${"+WxChannelMultiProperties.PREFIX + ".configStorage.type} = memory",
onClass = JedisPool.class
)
@RequiredArgsConstructor
public class WxChannelInMemoryConfiguration extends AbstractWxChannelConfiguration {
private final WxChannelMultiProperties wxChannelMultiProperties;
@Bean
public WxChannelMultiServices wxChannelMultiServices() {
return this.wxChannelMultiServices(wxChannelMultiProperties);
}
@Override
protected WxChannelDefaultConfigImpl wxChannelConfigStorage(WxChannelMultiProperties wxChannelMultiProperties) {
return this.configInMemory();
}
private WxChannelDefaultConfigImpl configInMemory() {
return new WxChannelDefaultConfigImpl();
}
}

65
solon-plugins/wx-java-channel-multi-solon-plugin/src/main/java/com/binarywang/solon/wxjava/channel/configuration/services/WxChannelInRedissonConfiguration.java Normal file
View File

@ -0,0 +1,65 @@
package com.binarywang.solon.wxjava.channel.configuration.services;
import com.binarywang.solon.wxjava.channel.properties.WxChannelMultiProperties;
import com.binarywang.solon.wxjava.channel.properties.WxChannelMultiRedisProperties;
import com.binarywang.solon.wxjava.channel.service.WxChannelMultiServices;
import lombok.RequiredArgsConstructor;
import me.chanjar.weixin.channel.config.impl.WxChannelDefaultConfigImpl;
import me.chanjar.weixin.channel.config.impl.WxChannelRedissonConfigImpl;
import org.apache.commons.lang3.StringUtils;
import org.noear.solon.annotation.Bean;
import org.noear.solon.annotation.Condition;
import org.noear.solon.annotation.Configuration;
import org.noear.solon.core.AppContext;
import org.redisson.Redisson;
import org.redisson.api.RedissonClient;
import org.redisson.config.Config;
import org.redisson.config.TransportMode;
/**
* 自动装配基于 redisson 策略配置
*
* @author <a href="https://github.com/Winnie-by996">Winnie</a> 2024/9/13
* @author noear
*/
@Configuration
@Condition(
onProperty = "${"+WxChannelMultiProperties.PREFIX + ".configStorage.type} = redisson",
onClass = Redisson.class
)
@RequiredArgsConstructor
public class WxChannelInRedissonConfiguration extends AbstractWxChannelConfiguration {
private final WxChannelMultiProperties wxChannelMultiProperties;
private final AppContext applicationContext;
@Bean
public WxChannelMultiServices wxChannelMultiServices() {
return this.wxChannelMultiServices(wxChannelMultiProperties);
}
@Override
protected WxChannelDefaultConfigImpl wxChannelConfigStorage(WxChannelMultiProperties wxChannelMultiProperties) {
return this.configRedisson(wxChannelMultiProperties);
}
private WxChannelDefaultConfigImpl configRedisson(WxChannelMultiProperties wxChannelMultiProperties) {
WxChannelMultiRedisProperties redisProperties = wxChannelMultiProperties.getConfigStorage().getRedis();
RedissonClient redissonClient;
if (redisProperties != null && StringUtils.isNotEmpty(redisProperties.getHost())) {
redissonClient = getRedissonClient(wxChannelMultiProperties);
} else {
redissonClient = applicationContext.getBean(RedissonClient.class);
}
return new WxChannelRedissonConfigImpl(redissonClient, wxChannelMultiProperties.getConfigStorage().getKeyPrefix());
}
private RedissonClient getRedissonClient(WxChannelMultiProperties wxChannelMultiProperties) {
WxChannelMultiProperties.ConfigStorage storage = wxChannelMultiProperties.getConfigStorage();
WxChannelMultiRedisProperties 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);
}
}

19
solon-plugins/wx-java-channel-multi-solon-plugin/src/main/java/com/binarywang/solon/wxjava/channel/enums/HttpClientType.java Normal file
View File

@ -0,0 +1,19 @@
package com.binarywang.solon.wxjava.channel.enums;
/**
* httpclient类型
*
* @author <a href="https://github.com/Winnie-by996">Winnie</a>
* @date 2024/9/13
*/
public enum HttpClientType {
/**
* HttpClient
*/
HTTP_CLIENT,
// WxChannelServiceOkHttpImpl 实现经测试无法正常完成业务固暂不支持OK_HTTP方式
// /**
// * OkHttp.
// */
// OK_HTTP,
}

26
solon-plugins/wx-java-channel-multi-solon-plugin/src/main/java/com/binarywang/solon/wxjava/channel/enums/StorageType.java Normal file
View File

@ -0,0 +1,26 @@
package com.binarywang.solon.wxjava.channel.enums;
/**
* storage类型
*
* @author <a href="https://github.com/Winnie-by996">Winnie</a>
* @date 2024/9/13
*/
public enum StorageType {
/**
* 内存
*/
MEMORY,
/**
* redis(JedisClient)
*/
JEDIS,
/**
* redis(Redisson)
*/
REDISSON,
/**
* redis(RedisTemplate)
*/
REDIS_TEMPLATE
}

25
solon-plugins/wx-java-channel-multi-solon-plugin/src/main/java/com/binarywang/solon/wxjava/channel/integration/WxChannelMultiPluginImpl.java Normal file
View File

@ -0,0 +1,25 @@
package com.binarywang.solon.wxjava.channel.integration;
import com.binarywang.solon.wxjava.channel.configuration.services.WxChannelInJedisConfiguration;
import com.binarywang.solon.wxjava.channel.configuration.services.WxChannelInMemoryConfiguration;
import com.binarywang.solon.wxjava.channel.configuration.services.WxChannelInRedissonConfiguration;
import com.binarywang.solon.wxjava.channel.properties.WxChannelMultiProperties;
import org.noear.solon.core.AppContext;
import org.noear.solon.core.Plugin;
/**
* 微信视频号自动注册
*
* @author <a href="https://github.com/Winnie-by996">Winnie</a> 2024/9/13
* @author noear 2024/10/9 created
*/
public class WxChannelMultiPluginImpl implements Plugin {
@Override
public void start(AppContext context) throws Throwable {
context.beanMake(WxChannelMultiProperties.class);
context.beanMake(WxChannelInJedisConfiguration.class);
context.beanMake(WxChannelInMemoryConfiguration.class);
context.beanMake(WxChannelInRedissonConfiguration.class);
}
}

96
solon-plugins/wx-java-channel-multi-solon-plugin/src/main/java/com/binarywang/solon/wxjava/channel/properties/WxChannelMultiProperties.java Normal file
View File

@ -0,0 +1,96 @@
package com.binarywang.solon.wxjava.channel.properties;
import com.binarywang.solon.wxjava.channel.enums.HttpClientType;
import com.binarywang.solon.wxjava.channel.enums.StorageType;
import lombok.Data;
import lombok.NoArgsConstructor;
import org.noear.solon.annotation.Configuration;
import org.noear.solon.annotation.Inject;
import java.io.Serializable;
import java.util.HashMap;
import java.util.Map;
/**
* 微信多视频号接入相关配置属性
*
* @author <a href="https://github.com/Winnie-by996">Winnie</a>
* @date 2024/9/13
*/
@Data
@NoArgsConstructor
@Configuration
@Inject("${" + WxChannelMultiProperties.PREFIX +"}")
public class WxChannelMultiProperties implements Serializable {
private static final long serialVersionUID = - 8361973118805546037L;
public static final String PREFIX = "wx.channel";
private Map<String, WxChannelSingleProperties> apps = new HashMap<>();
/**
* 存储策略
*/
private final ConfigStorage configStorage = new ConfigStorage();
@Data
@NoArgsConstructor
public static class ConfigStorage implements Serializable {
private static final long serialVersionUID = - 5152619132544179942L;
/**
* 存储类型.
*/
private StorageType type = StorageType.MEMORY;
/**
* 指定key前缀.
*/
private String keyPrefix = "wx:channel:multi";
/**
* redis连接配置.
*/
private final WxChannelMultiRedisProperties redis = new WxChannelMultiRedisProperties();
/**
* http客户端类型.
*/
private HttpClientType httpClientType = HttpClientType.HTTP_CLIENT;
/**
* http代理主机.
*/
private String httpProxyHost;
/**
* http代理端口.
*/
private Integer httpProxyPort;
/**
* http代理用户名.
*/
private String httpProxyUsername;
/**
* http代理密码.
*/
private String httpProxyPassword;
/**
* http 请求最大重试次数
*
* <p>{@link me.chanjar.weixin.channel.api.WxChannelService#setMaxRetryTimes(int)}</p>
* <p>{@link me.chanjar.weixin.channel.api.impl.BaseWxChannelServiceImpl#setMaxRetryTimes(int)}</p>
*/
private int maxRetryTimes = 5;
/**
* http 请求重试间隔
*
* <p>{@link me.chanjar.weixin.channel.api.WxChannelService#setRetrySleepMillis(int)}</p>
* <p>{@link me.chanjar.weixin.channel.api.impl.BaseWxChannelServiceImpl#setRetrySleepMillis(int)}</p>
*/
private int retrySleepMillis = 1000;
}
}

63
solon-plugins/wx-java-channel-multi-solon-plugin/src/main/java/com/binarywang/solon/wxjava/channel/properties/WxChannelMultiRedisProperties.java Normal file
View File

@ -0,0 +1,63 @@
package com.binarywang.solon.wxjava.channel.properties;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.io.Serializable;
/**
* Redis配置
*
* @author <a href="https://github.com/Winnie-by996">Winnie</a>
* @date 2024/9/13
*/
@Data
@NoArgsConstructor
public class WxChannelMultiRedisProperties implements Serializable {
private static final long serialVersionUID = 9061055444734277357L;
/**
* 主机地址.
*/
private String host = "127.0.0.1";
/**
* 端口号.
*/
private int port = 6379;
/**
* 密码.
*/
private String password;
/**
* 超时.
*/
private int timeout = 2000;
/**
* 数据库.
*/
private int database = 0;
/**
* 最大活动连接数
*/
private Integer maxActive;
/**
* 最大空闲连接数
*/
private Integer maxIdle;
/**
* 最小空闲连接数
*/
private Integer minIdle;
/**
* 最大等待时间
*/
private Integer maxWaitMillis;
}

43
solon-plugins/wx-java-channel-multi-solon-plugin/src/main/java/com/binarywang/solon/wxjava/channel/properties/WxChannelSingleProperties.java Normal file
View File

@ -0,0 +1,43 @@
package com.binarywang.solon.wxjava.channel.properties;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.io.Serializable;
/**
* 微信视频号相关配置属性
*
* @author <a href="https://github.com/Winnie-by996">Winnie</a>
* @date 2024/9/13
*/
@Data
@NoArgsConstructor
public class WxChannelSingleProperties implements Serializable {
private static final long serialVersionUID = 5306630351265124825L;
/**
* 设置微信视频号的 appid.
*/
private String appId;
/**
* 设置微信视频号的 secret.
*/
private String secret;
/**
* 设置微信视频号的 token.
*/
private String token;
/**
* 设置微信视频号的 EncodingAESKey.
*/
private String aesKey;
/**
* 是否使用稳定版 Access Token
*/
private boolean useStableAccessToken = false;
}

26
solon-plugins/wx-java-channel-multi-solon-plugin/src/main/java/com/binarywang/solon/wxjava/channel/service/WxChannelMultiServices.java Normal file
View File

@ -0,0 +1,26 @@
package com.binarywang.solon.wxjava.channel.service;
import me.chanjar.weixin.channel.api.WxChannelService;
/**
* 视频号 {@link WxChannelService} 所有实例存放类.
*
* @author <a href="https://github.com/Winnie-by996">Winnie</a>
* @date 2024/9/13
*/
public interface WxChannelMultiServices {
/**
* 通过租户 Id 获取 WxChannelService
*
* @param tenantId 租户 Id
* @return WxChannelService
*/
WxChannelService getWxChannelService(String tenantId);
/**
* 根据租户 Id，从列表中移除一个 WxChannelService 实例
*
* @param tenantId 租户 Id
*/
void removeWxChannelService(String tenantId);
}

36
solon-plugins/wx-java-channel-multi-solon-plugin/src/main/java/com/binarywang/solon/wxjava/channel/service/WxChannelMultiServicesImpl.java Normal file
View File

@ -0,0 +1,36 @@
package com.binarywang.solon.wxjava.channel.service;
import me.chanjar.weixin.channel.api.WxChannelService;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
/**
* 视频号 {@link WxChannelMultiServices} 实现
*
* @author <a href="https://github.com/Winnie-by996">Winnie</a>
* @date 2024/9/13
*/
public class WxChannelMultiServicesImpl implements WxChannelMultiServices {
private final Map<String, WxChannelService> services = new ConcurrentHashMap<>();
@Override
public WxChannelService getWxChannelService(String tenantId) {
return this.services.get(tenantId);
}
/**
* 根据租户 Id，添加一个 WxChannelService 到列表
*
* @param tenantId 租户 Id
* @param wxChannelService WxChannelService 实例
*/
public void addWxChannelService(String tenantId, WxChannelService wxChannelService) {
this.services.put(tenantId, wxChannelService);
}
@Override
public void removeWxChannelService(String tenantId) {
this.services.remove(tenantId);
}
}

2
solon-plugins/wx-java-channel-multi-solon-plugin/src/main/resources/META-INF/solon/wx-java-multi-channel-solon-plugin.properties Normal file
View File

@ -0,0 +1,2 @@
solon.plugin=com.binarywang.solon.wxjava.channel.integration.WxChannelMultiPluginImpl
solon.plugin.priority=10

15
solon-plugins/wx-java-channel-multi-solon-plugin/src/test/java/features/test/LoadTest.java Normal file
View File

@ -0,0 +1,15 @@
package features.test;
import org.junit.jupiter.api.Test;
import org.noear.solon.test.SolonTest;
/**
* @author noear 2024/9/4 created
*/
@SolonTest
public class LoadTest {
@Test
public void load(){
}
}

36
solon-plugins/wx-java-channel-multi-solon-plugin/src/test/resources/app.properties Normal file
View File

@ -0,0 +1,36 @@
# 视频号配置
## 应用 1 配置(必填)
wx.channel.apps.tenantId1.app-id=appId
wx.channel.apps.tenantId1.secret=secret
## 选填
wx.channel.apps.tenantId1.use-stable-access-token=false
wx.channel.apps.tenantId1.token=
wx.channel.apps.tenantId1.aes-key=
## 应用 2 配置(必填)
wx.channel.apps.tenantId2.app-id=@appId
wx.channel.apps.tenantId2.secret=@secret
## 选填
wx.channel.apps.tenantId2.use-stable-access-token=false
wx.channel.apps.tenantId2.token=
wx.channel.apps.tenantId2.aes-key=
# ConfigStorage 配置（选填）
## 配置类型: memory(默认), jedis, redisson, redis_template
wx.channel.config-storage.type=memory
## 相关redis前缀配置: wx:channel:multi(默认)
wx.channel.config-storage.key-prefix=wx:channel:multi
wx.channel.config-storage.redis.host=127.0.0.1
wx.channel.config-storage.redis.port=6379
wx.channel.config-storage.redis.password=123456
# http 客户端配置（选填）
## # http客户端类型: http_client(默认)
wx.channel.config-storage.http-client-type=http_client
wx.channel.config-storage.http-proxy-host=
wx.channel.config-storage.http-proxy-port=
wx.channel.config-storage.http-proxy-username=
wx.channel.config-storage.http-proxy-password=
## 最大重试次数，默认：5 次，如果小于 0，则为 0
wx.channel.config-storage.max-retry-times=5
## 重试时间间隔步进，默认：1000 毫秒，如果小于 0，则为 1000
wx.channel.config-storage.retry-sleep-millis=1000

2
solon-plugins/wx-java-cp-multi-solon-plugin/README.md
View File

@ -61,6 +61,8 @@
import com.binarywang.solon.wxjava.cp_multi.service.WxCpMultiServices;
import me.chanjar.weixin.cp.api.WxCpService;
import me.chanjar.weixin.cp.api.WxCpUserService;
import org.noear.solon.annotation.Component;
import org.noear.solon.annotation.Inject;
@Component
public class DemoService {

95
solon-plugins/wx-java-miniapp-multi-solon-plugin/README.md Normal file
View File

@ -0,0 +1,95 @@
# wx-java-miniapp-multi-solon-plugin
## 快速开始
1. 引入依赖
```xml
<dependency>
<groupId>com.github.binarywang</groupId>
<artifactId>wx-java-miniapp-multi-solon-plugin</artifactId>
<version>${version}</version>
</dependency>
```
2. 添加配置(app.properties)
```properties
# 公众号配置
## 应用 1 配置(必填)
wx.ma.apps.tenantId1.app-id=appId
wx.ma.apps.tenantId1.app-secret=@secret
## 选填
wx.ma.apps.tenantId1.token=@token
wx.ma.apps.tenantId1.aes-key=@aesKey
wx.ma.apps.tenantId1.use-stable-access-token=@useStableAccessToken
## 应用 2 配置(必填)
wx.ma.apps.tenantId2.app-id=@appId
wx.ma.apps.tenantId2.app-secret =@secret
## 选填
wx.ma.apps.tenantId2.token=@token
wx.ma.apps.tenantId2.aes-key=@aesKey
wx.ma.apps.tenantId2.use-stable-access-token=@useStableAccessToken
# ConfigStorage 配置（选填）
## 配置类型: memory(默认), jedis, redisson
wx.ma.config-storage.type=memory
## 相关redis前缀配置: wx:ma:multi(默认)
wx.ma.config-storage.key-prefix=wx:ma:multi
wx.ma.config-storage.redis.host=127.0.0.1
wx.ma.config-storage.redis.port=6379
## 单机和 sentinel 同时存在时，优先使用sentinel配置
# wx.ma.config-storage.redis.sentinel-ips=127.0.0.1:16379,127.0.0.1:26379
# wx.ma.config-storage.redis.sentinel-name=mymaster
# http 客户端配置（选填）
## # http客户端类型: http_client(默认), ok_http, jodd_http
wx.ma.config-storage.http-client-type=http_client
wx.ma.config-storage.http-proxy-host=
wx.ma.config-storage.http-proxy-port=
wx.ma.config-storage.http-proxy-username=
wx.ma.config-storage.http-proxy-password=
## 最大重试次数，默认：5 次，如果小于 0，则为 0
wx.ma.config-storage.max-retry-times=5
## 重试时间间隔步进，默认：1000 毫秒，如果小于 0，则为 1000
wx.ma.config-storage.retry-sleep-millis=1000
```
3. 自动注入的类型：`WxMaMultiServices`
4. 使用样例
```java
import com.binarywang.solon.wxjava.miniapp.service.WxMaMultiServices;
import cn.binarywang.wx.miniapp.api.WxMaService;
import cn.binarywang.wx.miniapp.api.WxMaUserService;
import org.noear.solon.annotation.Component;
import org.noear.solon.annotation.Inject;
@Component
public class DemoService {
@Inject
private WxMaMultiServices wxMaMultiServices;
public void test() {
// 应用 1 的 WxMaService
WxMaService wxMaService1 = wxMaMultiServices.getWxMaService("tenantId1");
WxMaUserService userService1 = wxMaService1.getUserService();
userService1.userInfo("xxx");
// todo ...
// 应用 2 的 WxMaService
WxMaService wxMaService2 = wxMaMultiServices.getWxMaService("tenantId2");
WxMaUserService userService2 = wxMaService2.getUserService();
userService2.userInfo("xxx");
// todo ...
// 应用 3 的 WxMaService
WxMaService wxMaService3 = wxMaMultiServices.getWxMaService("tenantId3");
// 判断是否为空
if (wxMaService3 == null) {
// todo wxMaService3 为空，请先配置 tenantId3 微信公众号应用参数
return;
}
WxMaUserService userService3 = wxMaService3.getUserService();
userService3.userInfo("xxx");
// todo ...
}
}
```

43
solon-plugins/wx-java-miniapp-multi-solon-plugin/pom.xml Normal file
View File

@ -0,0 +1,43 @@
<?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-solon-plugins</artifactId>
<groupId>com.github.binarywang</groupId>
<version>4.6.5.B</version>
</parent>
<modelVersion>4.0.0</modelVersion>
<artifactId>wx-java-miniapp-multi-solon-plugin</artifactId>
<name>WxJava - Solon Plugin for MiniApp::支持多账号配置</name>
<description>微信公众号开发的 Solon Plugin::支持多账号配置</description>
<dependencies>
<dependency>
<groupId>com.github.binarywang</groupId>
<artifactId>weixin-java-miniapp</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.jodd</groupId>
<artifactId>jodd-http</artifactId>
<scope>provided</scope>
</dependency>
<dependency>
<groupId>com.squareup.okhttp3</groupId>
<artifactId>okhttp</artifactId>
<scope>provided</scope>
</dependency>
</dependencies>
</project>

147
solon-plugins/wx-java-miniapp-multi-solon-plugin/src/main/java/com/binarywang/solon/wxjava/miniapp/configuration/services/AbstractWxMaConfiguration.java Normal file
View File

@ -0,0 +1,147 @@
package com.binarywang.solon.wxjava.miniapp.configuration.services;
import cn.binarywang.wx.miniapp.api.WxMaService;
import cn.binarywang.wx.miniapp.api.impl.WxMaServiceHttpClientImpl;
import cn.binarywang.wx.miniapp.api.impl.WxMaServiceImpl;
import cn.binarywang.wx.miniapp.api.impl.WxMaServiceJoddHttpImpl;
import cn.binarywang.wx.miniapp.api.impl.WxMaServiceOkHttpImpl;
import cn.binarywang.wx.miniapp.config.WxMaConfig;
import cn.binarywang.wx.miniapp.config.impl.WxMaDefaultConfigImpl;
import com.binarywang.solon.wxjava.miniapp.properties.WxMaMultiProperties;
import com.binarywang.solon.wxjava.miniapp.properties.WxMaSingleProperties;
import com.binarywang.solon.wxjava.miniapp.service.WxMaMultiServices;
import com.binarywang.solon.wxjava.miniapp.service.WxMaMultiServicesImpl;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import java.util.Collection;
import java.util.Map;
import java.util.Set;
import java.util.stream.Collectors;
/**
* WxMaConfigStorage 抽象配置类
*
* @author monch
* created on 2024/9/6
*/
@RequiredArgsConstructor
@Slf4j
public abstract class AbstractWxMaConfiguration {
protected WxMaMultiServices wxMaMultiServices(WxMaMultiProperties wxMaMultiProperties) {
Map<String, WxMaSingleProperties> appsMap = wxMaMultiProperties.getApps();
if (appsMap == null || appsMap.isEmpty()) {
log.warn("微信公众号应用参数未配置，通过 WxMaMultiServices#getWxMaService(\"tenantId\")获取实例将返回空");
return new WxMaMultiServicesImpl();
}
/**
* 校验 appId 是否唯一，避免使用 redis 缓存 token、ticket 时错乱。
*
* 查看 {@link cn.binarywang.wx.miniapp.config.impl.WxMaRedisConfigImpl#setAppId(String)}
*/
Collection<WxMaSingleProperties> 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 的唯一性");
}
}
WxMaMultiServicesImpl services = new WxMaMultiServicesImpl();
Set<Map.Entry<String, WxMaSingleProperties>> entries = appsMap.entrySet();
for (Map.Entry<String, WxMaSingleProperties> entry : entries) {
String tenantId = entry.getKey();
WxMaSingleProperties wxMaSingleProperties = entry.getValue();
WxMaDefaultConfigImpl storage = this.wxMaConfigStorage(wxMaMultiProperties);
this.configApp(storage, wxMaSingleProperties);
this.configHttp(storage, wxMaMultiProperties.getConfigStorage());
WxMaService wxMaService = this.wxMaService(storage, wxMaMultiProperties);
services.addWxMaService(tenantId, wxMaService);
}
return services;
}
/**
* 配置 WxMaDefaultConfigImpl
*
* @param wxMaMultiProperties 参数
* @return WxMaDefaultConfigImpl
*/
protected abstract WxMaDefaultConfigImpl wxMaConfigStorage(WxMaMultiProperties wxMaMultiProperties);
public WxMaService wxMaService(WxMaConfig wxMaConfig, WxMaMultiProperties wxMaMultiProperties) {
WxMaMultiProperties.ConfigStorage storage = wxMaMultiProperties.getConfigStorage();
WxMaMultiProperties.HttpClientType httpClientType = storage.getHttpClientType();
WxMaService wxMaService;
switch (httpClientType) {
case OK_HTTP:
wxMaService = new WxMaServiceOkHttpImpl();
break;
case JODD_HTTP:
wxMaService = new WxMaServiceJoddHttpImpl();
break;
case HTTP_CLIENT:
wxMaService = new WxMaServiceHttpClientImpl();
break;
default:
wxMaService = new WxMaServiceImpl();
break;
}
wxMaService.setWxMaConfig(wxMaConfig);
int maxRetryTimes = storage.getMaxRetryTimes();
if (maxRetryTimes < 0) {
maxRetryTimes = 0;
}
int retrySleepMillis = storage.getRetrySleepMillis();
if (retrySleepMillis < 0) {
retrySleepMillis = 1000;
}
wxMaService.setRetrySleepMillis(retrySleepMillis);
wxMaService.setMaxRetryTimes(maxRetryTimes);
return wxMaService;
}
private void configApp(WxMaDefaultConfigImpl config, WxMaSingleProperties corpProperties) {
String appId = corpProperties.getAppId();
String appSecret = corpProperties.getAppSecret();
String token = corpProperties.getToken();
String aesKey = corpProperties.getAesKey();
boolean useStableAccessToken = corpProperties.isUseStableAccessToken();
config.setAppid(appId);
config.setSecret(appSecret);
if (StringUtils.isNotBlank(token)) {
config.setToken(token);
}
if (StringUtils.isNotBlank(aesKey)) {
config.setAesKey(aesKey);
}
config.useStableAccessToken(useStableAccessToken);
}
private void configHttp(WxMaDefaultConfigImpl config, WxMaMultiProperties.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);
}
}
}
}

77
solon-plugins/wx-java-miniapp-multi-solon-plugin/src/main/java/com/binarywang/solon/wxjava/miniapp/configuration/services/WxMaInJedisConfiguration.java Normal file
View File

@ -0,0 +1,77 @@
package com.binarywang.solon.wxjava.miniapp.configuration.services;
import cn.binarywang.wx.miniapp.config.impl.WxMaDefaultConfigImpl;
import cn.binarywang.wx.miniapp.config.impl.WxMaRedisConfigImpl;
import com.binarywang.solon.wxjava.miniapp.properties.WxMaMultiProperties;
import com.binarywang.solon.wxjava.miniapp.properties.WxMaMultiRedisProperties;
import com.binarywang.solon.wxjava.miniapp.service.WxMaMultiServices;
import lombok.RequiredArgsConstructor;
import org.apache.commons.lang3.StringUtils;
import org.noear.solon.annotation.Bean;
import org.noear.solon.annotation.Condition;
import org.noear.solon.annotation.Configuration;
import org.noear.solon.core.AppContext;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;
/**
* 自动装配基于 jedis 策略配置
*
* @author monch
* created on 2024/9/6
*/
@Configuration
@Condition(
onProperty = "${"+WxMaMultiProperties.PREFIX + ".configStorage.type} = jedis",
onClass = JedisPool.class
)
@RequiredArgsConstructor
public class WxMaInJedisConfiguration extends AbstractWxMaConfiguration {
private final WxMaMultiProperties wxMaMultiProperties;
private final AppContext applicationContext;
@Bean
public WxMaMultiServices wxMaMultiServices() {
return this.wxMaMultiServices(wxMaMultiProperties);
}
@Override
protected WxMaDefaultConfigImpl wxMaConfigStorage(WxMaMultiProperties wxMaMultiProperties) {
return this.configRedis(wxMaMultiProperties);
}
private WxMaDefaultConfigImpl configRedis(WxMaMultiProperties wxMaMultiProperties) {
WxMaMultiRedisProperties wxMaMultiRedisProperties = wxMaMultiProperties.getConfigStorage().getRedis();
JedisPool jedisPool;
if (wxMaMultiRedisProperties != null && StringUtils.isNotEmpty(wxMaMultiRedisProperties.getHost())) {
jedisPool = getJedisPool(wxMaMultiProperties);
} else {
jedisPool = applicationContext.getBean(JedisPool.class);
}
return new WxMaRedisConfigImpl(jedisPool);
}
private JedisPool getJedisPool(WxMaMultiProperties wxMaMultiProperties) {
WxMaMultiProperties.ConfigStorage storage = wxMaMultiProperties.getConfigStorage();
WxMaMultiRedisProperties 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());
}
}

39
solon-plugins/wx-java-miniapp-multi-solon-plugin/src/main/java/com/binarywang/solon/wxjava/miniapp/configuration/services/WxMaInMemoryConfiguration.java Normal file
View File

@ -0,0 +1,39 @@
package com.binarywang.solon.wxjava.miniapp.configuration.services;
import cn.binarywang.wx.miniapp.config.impl.WxMaDefaultConfigImpl;
import com.binarywang.solon.wxjava.miniapp.properties.WxMaMultiProperties;
import com.binarywang.solon.wxjava.miniapp.service.WxMaMultiServices;
import lombok.RequiredArgsConstructor;
import org.noear.solon.annotation.Bean;
import org.noear.solon.annotation.Condition;
import org.noear.solon.annotation.Configuration;
/**
* 自动装配基于内存策略配置
*
* @author monch
* created on 2024/9/6
*/
@Configuration
@Condition(
onProperty = "${"+WxMaMultiProperties.PREFIX + ".configStorage.type:memory} = memory"
)
@RequiredArgsConstructor
public class WxMaInMemoryConfiguration extends AbstractWxMaConfiguration {
private final WxMaMultiProperties wxMaMultiProperties;
@Bean
public WxMaMultiServices wxMaMultiServices() {
return this.wxMaMultiServices(wxMaMultiProperties);
}
@Override
protected WxMaDefaultConfigImpl wxMaConfigStorage(WxMaMultiProperties wxMaMultiProperties) {
return this.configInMemory();
}
private WxMaDefaultConfigImpl configInMemory() {
return new WxMaDefaultConfigImpl();
// return new WxMaDefaultConfigImpl();
}
}

68
solon-plugins/wx-java-miniapp-multi-solon-plugin/src/main/java/com/binarywang/solon/wxjava/miniapp/configuration/services/WxMaInRedissonConfiguration.java Normal file
View File

@ -0,0 +1,68 @@
package com.binarywang.solon.wxjava.miniapp.configuration.services;
import cn.binarywang.wx.miniapp.config.impl.WxMaDefaultConfigImpl;
import cn.binarywang.wx.miniapp.config.impl.WxMaRedissonConfigImpl;
import com.binarywang.solon.wxjava.miniapp.properties.WxMaMultiProperties;
import com.binarywang.solon.wxjava.miniapp.properties.WxMaMultiRedisProperties;
import com.binarywang.solon.wxjava.miniapp.service.WxMaMultiServices;
import lombok.RequiredArgsConstructor;
import org.apache.commons.lang3.StringUtils;
import org.noear.solon.annotation.Bean;
import org.noear.solon.annotation.Condition;
import org.noear.solon.annotation.Configuration;
import org.noear.solon.core.AppContext;
import org.redisson.Redisson;
import org.redisson.api.RedissonClient;
import org.redisson.config.Config;
import org.redisson.config.TransportMode;
/**
* 自动装配基于 redisson 策略配置
*
* @author monch
* created on 2024/9/6
*/
@Configuration
@Condition(
onProperty = "${"+WxMaMultiProperties.PREFIX + ".configStorage.type} = redisson",
onClass = Redisson.class
)
@RequiredArgsConstructor
public class WxMaInRedissonConfiguration extends AbstractWxMaConfiguration {
private final WxMaMultiProperties wxMaMultiProperties;
private final AppContext applicationContext;
@Bean
public WxMaMultiServices wxMaMultiServices() {
return this.wxMaMultiServices(wxMaMultiProperties);
}
@Override
protected WxMaDefaultConfigImpl wxMaConfigStorage(WxMaMultiProperties wxMaMultiProperties) {
return this.configRedisson(wxMaMultiProperties);
}
private WxMaDefaultConfigImpl configRedisson(WxMaMultiProperties wxMaMultiProperties) {
WxMaMultiRedisProperties redisProperties = wxMaMultiProperties.getConfigStorage().getRedis();
RedissonClient redissonClient;
if (redisProperties != null && StringUtils.isNotEmpty(redisProperties.getHost())) {
redissonClient = getRedissonClient(wxMaMultiProperties);
} else {
redissonClient = applicationContext.getBean(RedissonClient.class);
}
return new WxMaRedissonConfigImpl(redissonClient, wxMaMultiProperties.getConfigStorage().getKeyPrefix());
}
private RedissonClient getRedissonClient(WxMaMultiProperties wxMaMultiProperties) {
WxMaMultiProperties.ConfigStorage storage = wxMaMultiProperties.getConfigStorage();
WxMaMultiRedisProperties 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);
}
}

22
solon-plugins/wx-java-miniapp-multi-solon-plugin/src/main/java/com/binarywang/solon/wxjava/miniapp/integration/WxMiniappMultiPluginImpl.java Normal file
View File

@ -0,0 +1,22 @@
package com.binarywang.solon.wxjava.miniapp.integration;
import com.binarywang.solon.wxjava.miniapp.configuration.services.WxMaInJedisConfiguration;
import com.binarywang.solon.wxjava.miniapp.configuration.services.WxMaInMemoryConfiguration;
import com.binarywang.solon.wxjava.miniapp.configuration.services.WxMaInRedissonConfiguration;
import com.binarywang.solon.wxjava.miniapp.properties.WxMaMultiProperties;
import org.noear.solon.core.AppContext;
import org.noear.solon.core.Plugin;
/**
* @author noear 2024/10/9 created
*/
public class WxMiniappMultiPluginImpl implements Plugin {
@Override
public void start(AppContext context) throws Throwable {
context.beanMake(WxMaMultiProperties.class);
context.beanMake(WxMaInJedisConfiguration.class);
context.beanMake(WxMaInMemoryConfiguration.class);
context.beanMake(WxMaInRedissonConfiguration.class);
}
}

154
solon-plugins/wx-java-miniapp-multi-solon-plugin/src/main/java/com/binarywang/solon/wxjava/miniapp/properties/WxMaMultiProperties.java Normal file
View File

@ -0,0 +1,154 @@
package com.binarywang.solon.wxjava.miniapp.properties;
import lombok.Data;
import lombok.NoArgsConstructor;
import org.noear.solon.annotation.Configuration;
import org.noear.solon.annotation.Inject;
import java.io.Serializable;
import java.util.HashMap;
import java.util.Map;
/**
* @author monch created on 2024/9/6
* @author noear
*/
@Data
@NoArgsConstructor
@Configuration
@Inject("${" + WxMaMultiProperties.PREFIX + "}")
public class WxMaMultiProperties implements Serializable {
private static final long serialVersionUID = -5358245184407791011L;
public static final String PREFIX = "wx.ma";
private Map<String, WxMaSingleProperties> 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;
/**
* 对应于：https://api.weixin.qq.com
*/
private String apiHost;
/**
* 对应于：https://open.weixin.qq.com
*/
private String openHost;
/**
* 对应于：https://mp.weixin.qq.com
*/
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:ma:multi";
/**
* redis连接配置.
*/
private final WxMaMultiRedisProperties redis = new WxMaMultiRedisProperties();
/**
* 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 cn.binarywang.wx.miniapp.api.WxMaService#setMaxRetryTimes(int)}
* {@link cn.binarywang.wx.miniapp.api.impl.BaseWxMaServiceImpl#setMaxRetryTimes(int)}
* </pre>
*/
private int maxRetryTimes = 5;
/**
* http 请求重试间隔
* <pre>
* {@link cn.binarywang.wx.miniapp.api.WxMaService#setRetrySleepMillis(int)}
* {@link cn.binarywang.wx.miniapp.api.impl.BaseWxMaServiceImpl#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
}
}

56
solon-plugins/wx-java-miniapp-multi-solon-plugin/src/main/java/com/binarywang/solon/wxjava/miniapp/properties/WxMaMultiRedisProperties.java Normal file
View File

@ -0,0 +1,56 @@
package com.binarywang.solon.wxjava.miniapp.properties;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.io.Serializable;
/**
* @author monch
* created on 2024/9/6
*/
@Data
@NoArgsConstructor
public class WxMaMultiRedisProperties 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;
}

40
solon-plugins/wx-java-miniapp-multi-solon-plugin/src/main/java/com/binarywang/solon/wxjava/miniapp/properties/WxMaSingleProperties.java Normal file
View File

@ -0,0 +1,40 @@
package com.binarywang.solon.wxjava.miniapp.properties;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.io.Serializable;
/**
* @author monch
* created on 2024/9/6
*/
@Data
@NoArgsConstructor
public class WxMaSingleProperties 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;
/**
* 是否使用稳定版 Access Token
*/
private boolean useStableAccessToken = false;
}

27
solon-plugins/wx-java-miniapp-multi-solon-plugin/src/main/java/com/binarywang/solon/wxjava/miniapp/service/WxMaMultiServices.java Normal file
View File

@ -0,0 +1,27 @@
package com.binarywang.solon.wxjava.miniapp.service;
import cn.binarywang.wx.miniapp.api.WxMaService;
/**
* 微信小程序 {@link WxMaService} 所有实例存放类.
*
* @author monch
* created on 2024/9/6
*/
public interface WxMaMultiServices {
/**
* 通过租户 Id 获取 WxMaService
*
* @param tenantId 租户 Id
* @return WxMaService
*/
WxMaService getWxMaService(String tenantId);
/**
* 根据租户 Id，从列表中移除一个 WxMaService 实例
*
* @param tenantId 租户 Id
*/
void removeWxMaService(String tenantId);
}

36
solon-plugins/wx-java-miniapp-multi-solon-plugin/src/main/java/com/binarywang/solon/wxjava/miniapp/service/WxMaMultiServicesImpl.java Normal file
View File

@ -0,0 +1,36 @@
package com.binarywang.solon.wxjava.miniapp.service;
import cn.binarywang.wx.miniapp.api.WxMaService;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
/**
* 微信小程序 {@link WxMaMultiServices} 默认实现
*
* @author monch
* created on 2024/9/6
*/
public class WxMaMultiServicesImpl implements WxMaMultiServices {
private final Map<String, WxMaService> services = new ConcurrentHashMap<>();
@Override
public WxMaService getWxMaService(String tenantId) {
return this.services.get(tenantId);
}
/**
* 根据租户 Id，添加一个 WxMaService 到列表
*
* @param tenantId 租户 Id
* @param wxMaService WxMaService 实例
*/
public void addWxMaService(String tenantId, WxMaService wxMaService) {
this.services.put(tenantId, wxMaService);
}
@Override
public void removeWxMaService(String tenantId) {
this.services.remove(tenantId);
}
}

2
solon-plugins/wx-java-miniapp-multi-solon-plugin/src/main/resources/META-INF/solon/wx-java-miniapp-multi-solon-plugin.properties Normal file
View File

@ -0,0 +1,2 @@
solon.plugin=com.binarywang.solon.wxjava.miniapp.integration.WxMiniappMultiPluginImpl
solon.plugin.priority=10

15
solon-plugins/wx-java-miniapp-multi-solon-plugin/src/test/java/features/test/LoadTest.java Normal file
View File

@ -0,0 +1,15 @@
package features.test;
import org.junit.jupiter.api.Test;
import org.noear.solon.test.SolonTest;
/**
* @author noear 2024/9/4 created
*/
@SolonTest
public class LoadTest {
@Test
public void load(){
}
}

38
solon-plugins/wx-java-miniapp-multi-solon-plugin/src/test/resources/app.properties Normal file
View File

@ -0,0 +1,38 @@
# 公众号配置
## 应用 1 配置(必填)
wx.ma.apps.tenantId1.app-id=appId
wx.ma.apps.tenantId1.app-secret=@secret
## 选填
wx.ma.apps.tenantId1.token=@token
wx.ma.apps.tenantId1.aes-key=@aesKey
wx.ma.apps.tenantId1.use-stable-access-token=@useStableAccessToken
## 应用 2 配置(必填)
wx.ma.apps.tenantId2.app-id=@appId
wx.ma.apps.tenantId2.app-secret =@secret
## 选填
wx.ma.apps.tenantId2.token=@token
wx.ma.apps.tenantId2.aes-key=@aesKey
wx.ma.apps.tenantId2.use-stable-access-token=@useStableAccessToken
# ConfigStorage 配置（选填）
## 配置类型: memory(默认), jedis, redisson
wx.ma.config-storage.type=memory
## 相关redis前缀配置: wx:ma:multi(默认)
wx.ma.config-storage.key-prefix=wx:ma:multi
wx.ma.config-storage.redis.host=127.0.0.1
wx.ma.config-storage.redis.port=6379
## 单机和 sentinel 同时存在时，优先使用sentinel配置
# wx.ma.config-storage.redis.sentinel-ips=127.0.0.1:16379,127.0.0.1:26379
# wx.ma.config-storage.redis.sentinel-name=mymaster
# http 客户端配置（选填）
## # http客户端类型: http_client(默认), ok_http, jodd_http
wx.ma.config-storage.http-client-type=http_client
wx.ma.config-storage.http-proxy-host=
wx.ma.config-storage.http-proxy-port=
wx.ma.config-storage.http-proxy-username=
wx.ma.config-storage.http-proxy-password=
## 最大重试次数，默认：5 次，如果小于 0，则为 0
wx.ma.config-storage.max-retry-times=5
## 重试时间间隔步进，默认：1000 毫秒，如果小于 0，则为 1000
wx.ma.config-storage.retry-sleep-millis=1000

14
solon-plugins/wx-java-mp-solon-plugin/README.md
View File

@ -23,19 +23,19 @@
wx.mp.config-storage.key-prefix=wx # 相关redis前缀配置: wx(默认)
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
#单机和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客户端配置
wx.mp.config-storage.http-client-type=httpclient # http客户端类型: HttpClient(默认), OkHttp, JoddHttp
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=
# 公众号地址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/
# 公众号地址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. 自动注入的类型

6
solon-plugins/wx-java-mp-solon-plugin/src/test/resources/app.properties
View File

@ -4,8 +4,8 @@ wx.mp.secret=@secret
wx.mp.token=@token
wx.mp.aes-key=@aesKey
wx.mp.use-stable-access-token=@useStableAccessToken
# ????redis(??)
wx.mp.config-storage.type= edis # ????: Memory(??), Jedis, RedisTemplate
wx.mp.config-storage.key-prefix=wx # ??redis????: wx(??)
# ????redis(??) # ????: Memory(??), Jedis, RedisTemplate
wx.mp.config-storage.type=memory
wx.mp.config-storage.key-prefix=wx
wx.mp.config-storage.redis.host=127.0.0.1
wx.mp.config-storage.redis.port=6379