祝大家新年快乐，有任何问题可与我联系：

一般的项目中只使用到一个公众号，这个按照开发文档就可以实现了。但是很多平台型的项目，需要同时支持多个公众号。我也参与过几个平台型的项目，但是总觉得这些项目中多公众号的实现方式用着不顺手，总结了一下各个项目中的优缺点，便有了下面的实现方式。代码简单，直接上代码。

package cn.yyjjssnn.wxmp;

import java.util.Hashtable;

import java.util.Map;

import org.springframework.util.Assert;

/**

* 支持多企业多公众号的使用

*

* @author LiuYang

* @date 2018年2月10日 上午10:11:40

* @version V1.0

*/

public class WxMpUtil {

/**

* 缓存MultiWxMpService，方便下次使用。

* 这里为演示采用MAP，可以根据业务的需要使用其他单机缓存或分布式缓存。

*/

private static Map multiWxMpServiceCache = new Hashtable();

private WxMpUtil() {

}

/**

* 根据ID获取对应的MultiWxMpService

* @param companyId 企业ID

* @return

*/

public static synchronized MultiWxMpService get(String companyId) {

Assert.hasText(companyId, "企业ID不能为空");

MultiWxMpService wxMpService = multiWxMpServiceCache.get(companyId);

if (wxMpService == null) {

wxMpService = new MultiWxMpService(companyId);

multiWxMpServiceCache.put(companyId, wxMpService);

}

return wxMpService;

}

}

package cn.yyjjssnn.wxmp;

import me.chanjar.weixin.mp.api.WxMpInMemoryConfigStorage;

import me.chanjar.weixin.mp.api.WxMpMessageRouter;

import me.chanjar.weixin.mp.api.impl.WxMpServiceImpl;

/**

* 微信公众号支持多帐号版本的实现

*

* @author LiuYang

* @date 2018年2月10日 下午4:39:25

* @version V1.0

*/

public class MultiWxMpService extends WxMpServiceImpl {

/**

* 区分微信公众号多帐号的唯一ID，我这里用的企业ID

*/

private String companyId = null;

private WxMpMessageRouter router = null;

public MultiWxMpService(String companyId) {

this(companyId, null);

}

public MultiWxMpService(String companyId, WxMpMessageRouter router) {

this.companyId = companyId;

setWxMpConfigStorage();

if (router == null) {

setWxMpMessageRouterRule();

} else {

this.router = router;

}

}

public String getCompanyId() {

return companyId;

}

public WxMpMessageRouter getMessageRouter() {

return router;

}

private void setWxMpConfigStorage() {

//TODO 根据companyId读取公众号参数配置 这里可以从配置文件、数据库、缓存任意一个源读取

String appId = "";

String secret = "";

String token = "";

String aesKey = "";

// 设置公众号参数

WxMpInMemoryConfigStorage config = new WxMpInMemoryConfigStorage();

config.setAppId(appId); // 设置微信公众号的appid

config.setSecret(secret); // 设置微信公众号的app corpSecret

config.setToken(token); // 设置微信公众号的token

config.setAesKey(aesKey); // 设置微信公众号的EncodingAESKey

this.setWxMpConfigStorage(config);

}

private void setWxMpMessageRouterRule() {

router = new WxMpMessageRouter(this);

// 记录所有事件的日志

router.rule().handler(new LogHandler()).next();

}

}

package cn.yyjjssnn.wxmp;

import java.util.Map;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import me.chanjar.weixin.common.exception.WxErrorException;

import me.chanjar.weixin.common.session.WxSessionManager;

import me.chanjar.weixin.mp.api.WxMpMessageHandler;

import me.chanjar.weixin.mp.api.WxMpService;

import me.chanjar.weixin.mp.bean.message.WxMpXmlMessage;

import me.chanjar.weixin.mp.bean.message.WxMpXmlOutMessage;

/**

* 消息路由基类 这里主要重载了一下handle方法，将参数WxMpService转换成MultiWxMpService方便其他路由使用

*

* @author LiuYang

* @date 2018年2月10日 上午11:38:46

* @version V1.0

*/

public abstract class BaseHandler implements WxMpMessageHandler {

protected Logger logger = LoggerFactory.getLogger(getClass());

@Override

public WxMpXmlOutMessage handle(WxMpXmlMessage wxMessage, Map context,

WxMpService wxMpService, WxSessionManager sessionManager) throws WxErrorException {

MultiWxMpService mpService = (MultiWxMpService) wxMpService;

return handle(wxMessage, context, mpService, sessionManager);

}

public abstract WxMpXmlOutMessage handle(WxMpXmlMessage wxMessage, Map context,

MultiWxMpService mpService, WxSessionManager sessionManager) throws WxErrorException;

}

package cn.yyjjssnn.wxmp;

import java.util.Map;

import me.chanjar.weixin.common.session.WxSessionManager;

import me.chanjar.weixin.mp.bean.message.WxMpXmlMessage;

import me.chanjar.weixin.mp.bean.message.WxMpXmlOutMessage;

/**

* 记录所有事件的日志

*

* @author LiuYang

* @date 2018年2月10日 下午4:12:30

* @version V1.0

*/

public class LogHandler extends BaseHandler {

@Override

public WxMpXmlOutMessage handle(WxMpXmlMessage wxMessage, Map context,

MultiWxMpService mpService, WxSessionManager sessionManager) {

logger.info("\n接收到 {} 请求消息，内容：{}", mpService.getCompanyId(), wxMessage);

return null;

}

}

~谢谢打赏~手机请长按图片~

赞 赏