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

🐛 #2999【小程序/公众号】修复异步消息路由报错的问题

Browse Source
This commit is contained in:
heiheihei 2023-05-04 16:34:48 +08:00 committed by GitHub
parent 6e93062104
commit de0266b5e1
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
weixin-java-miniapp/src/main/java/cn/binarywang/wx/miniapp/message/WxMaMessageRouter.java
View File

@ -128,16 +128,20 @@ public class WxMaMessageRouter {
if (matchRules.size() == 0) { if (matchRules.size() == 0) {
return null; return null;
} }
String miniAppId = WxMaConfigHolder.get();
final List<Future<?>> futures = new ArrayList<>(); final List<Future<?>> futures = new ArrayList<>();
WxMaXmlOutMessage result = null; WxMaXmlOutMessage result = null;
for (final WxMaMessageRouterRule rule : matchRules) { for (final WxMaMessageRouterRule rule : matchRules) {
// 返回最后一个非异步的rule的执行结果 // 返回最后一个非异步的rule的执行结果
if (rule.isAsync()) { if (rule.isAsync()) {
//获取当前线程使用的实际appId，兼容只有一个appId，且未显式设置当前使用的appId的情况
String miniAppId = this.wxMaService.getWxMaConfig().getAppid();
futures.add( futures.add(
this.executorService.submit(() -> { this.executorService.submit(() -> {
//子线程中设置实际的appId
this.wxMaService.switchoverTo(miniAppId); this.wxMaService.switchoverTo(miniAppId);
rule.service(wxMessage, context, WxMaMessageRouter.this.wxMaService, WxMaMessageRouter.this.sessionManager, WxMaMessageRouter.this.exceptionHandler); rule.service(wxMessage, context, WxMaMessageRouter.this.wxMaService, WxMaMessageRouter.this.sessionManager, WxMaMessageRouter.this.exceptionHandler);
WxMaConfigHolder.remove();
}) })
); );
} else { } else {

5
weixin-java-mp/src/main/java/me/chanjar/weixin/mp/api/WxMpMessageRouter.java
View File

@ -248,16 +248,19 @@ public class WxMpMessageRouter {
WxMpXmlOutMessage res = null; WxMpXmlOutMessage res = null;
final List<Future<?>> futures = new ArrayList<>(); final List<Future<?>> futures = new ArrayList<>();
String appId = WxMpConfigStorageHolder.get();
for (final WxMpMessageRouterRule rule : matchRules) { for (final WxMpMessageRouterRule rule : matchRules) {
// 返回最后一个非异步的rule的执行结果 // 返回最后一个非异步的rule的执行结果
if (rule.isAsync()) { if (rule.isAsync()) {
//获取当前线程使用的实际appId。兼容只有一个appId，且未显式设置当前使用的appId的情况
String appId = this.wxMpService.getWxMpConfigStorage().getAppId();
futures.add( futures.add(
this.executorService.submit(() -> { this.executorService.submit(() -> {
//传入父线程的appId //传入父线程的appId
this.wxMpService.switchoverTo(appId); this.wxMpService.switchoverTo(appId);
rule.service(wxMessage, context, mpService, WxMpMessageRouter.this.sessionManager, rule.service(wxMessage, context, mpService, WxMpMessageRouter.this.sessionManager,
WxMpMessageRouter.this.exceptionHandler); WxMpMessageRouter.this.exceptionHandler);
WxMpConfigStorageHolder.remove();
}) })
); );
} else { } else {