程序员刘杨

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

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<String, MultiWxMpService> multiWxMpServiceCache = new Hashtable<String, MultiWxMpService>();

	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<String, Object> context,
			WxMpService wxMpService, WxSessionManager sessionManager) throws WxErrorException {
		MultiWxMpService mpService = (MultiWxMpService) wxMpService;
		return handle(wxMessage, context, mpService, sessionManager);
	}

	public abstract WxMpXmlOutMessage handle(WxMpXmlMessage wxMessage, Map<String, Object> 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<String, Object> context,
			MultiWxMpService mpService, WxSessionManager sessionManager) {
		logger.info("\n接收到 {} 请求消息，内容：{}", mpService.getCompanyId(), wxMessage);
		return null;
	}

}

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

赞 赏