【跟着博弈走，微信轻松有】企业号第三方Java环境搭建之二: 回调模式

前节【项目搭建】 讲述了如何搭建一个SpringMVC的Maven项目，这节我们将关注回调模式的相关事宜。

开启应用的回调模式

当你开启应用的回调模式时，企业号会要求你填写应用的URL、Token、EncodingAESKey三个参数。

URL是企业应用接收企业号推送请求的访问协议和地址，支持http或https协议。

Token可由企业任意填写，用于生成签名。

EncodingAESKey用于消息体的加密，是AES密钥的Base64编码。

登陆企业服务号之后，管理员可以添加企业应用：

点击添加按钮之后，按照提示创建一个WeChat的应用

点击进入WeChat配置

选中回调模式下面的进入按钮，
 

 选择右上角的开启按钮，将会弹出对话框，让你输入接口信息：

 
 URL 是第三方平台用来接收微信转发消息的地址，需要提供GET和POST两种方法，GET主要是用来验证URL有效性, POST主要用来接收消息。

Token 和 AESKey可以随便定义，也可以用他后面的随机获取。

我们这里定义 Token = “A8888888888888888888A”， EncodingAESKey = "A88888888888888888888888888888888888888888A"。 

URL我们要填写SpringMVC的crontroller的地址，比如 http://www.xxx.com/msg. 

这样我们就可以开始来设计Spring MVC中的Controller类。

创建包： com.boyi.wechat.controller

创建类： com.boyi.wechat.controller.MsgController

package com.boyi.wechat.controller;

import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.ResponseBody;

import com.boyi.wechat.utils.CommonUtils;
import com.boyi.wechat.wx.msg.in.model.InMsg;
import com.boyi.wechat.wx.msg.in.model.ReplyMsg;
import com.boyi.wechat.wx.msg.model.MsgType;
import com.boyi.wechat.wx.msg.parser.MsgParser;
import com.boyi.wechat.wx.utils.WXBizMsgCrypt;
import com.boyi.wechat.wx.utils.WXBizMsgCryptManager;

@Controller
@RequestMapping("/msg")
public class MsgController {

	@RequestMapping(method = RequestMethod.GET)
	public @ResponseBody
	String valid(@RequestParam(value = "msg_signature") String signature, 
			@RequestParam(value = "timestamp") String timestamp, 
			@RequestParam(value = "nonce") String nonce, 
			@RequestParam(value = "echostr") String echostr) throws Exception {
		
		String sEchoStr = "";
		WXBizMsgCrypt wxcpt = WXBizMsgCryptManager.getChatWXBizMsgCrypt();
		try {
			sEchoStr = wxcpt.VerifyURL(signature, timestamp, nonce, echostr);
			System.out.println("sEchoStr : " + sEchoStr);
		} catch (Exception e) {
			e.printStackTrace();
		}
		return sEchoStr;
	}

	@RequestMapping(method = RequestMethod.POST)
	public @ResponseBody String message(
			@RequestParam(value = "msg_signature") String signature, 
			@RequestParam(value = "timestamp") String timestamp, 
			@RequestParam(value = "nonce") String nonce, 
			@RequestBody String encryptMsg) throws Exception {
		String sEncryptMsg = null;
		WXBizMsgCrypt wxcpt = WXBizMsgCryptManager.getChatWXBizMsgCrypt();
		try {
			String msg = wxcpt.DecryptMsg(signature, timestamp, nonce, encryptMsg);
			System.out.println("decode msg = " + msg);
			//parse the xml message to InMsg object
			InMsg inMsg = MsgParser.parse(msg);
			if (inMsg != null) {
				System.out.println("msg id = " + inMsg.getMsgId());
				System.out.println("msg type = " + inMsg.getMsgType().name());
				String content = "你刚才发的是[" +  inMsg.getMsgType().name() + "]";
				
				//create the reply message
				ReplyMsg replyMsg = new ReplyMsg();
				replyMsg.setToUserName(inMsg.getFromUserName());
				replyMsg.setFromUserName(inMsg.getToUserName());
				replyMsg.setCreateTime(CommonUtils.getCurrentSecond());
				replyMsg.setMsgType(MsgType.text);
				replyMsg.setContent(content);
				//convert the reply msg object to xml
				String xmlString = MsgParser.convert(replyMsg);
				System.out.println("reply message = " + xmlString);
				
				//Encrypt the xml message
				sEncryptMsg = wxcpt.EncryptMsg(xmlString, CommonUtils.getCurrentSecond(), nonce);
				System.out.println("encrypt message = " + sEncryptMsg);
			}
		} catch (Exception e) {
			e.printStackTrace();
		}
		return sEncryptMsg;
	}
}

 在这个Controller里我们定义了2个方法，一个是RequestMethod 是GET的方法valid， 另外一个是POST的方法message， 由于我们在配置文件里面加入了JackSon的配置，所以就不需要去写其他的方法去获取POST发过来的数据了，直接通过@RequestBody就可以获取微信发过来的加密的消息。 

WXBizMsgCrypt 这个类可以从微信官方下载到，http://qydev.weixin.qq.com/java.zip

package com.boyi.wechat.wx.utils;

import java.util.HashMap;
import java.util.Map;

public class WXBizMsgCryptManager {

	public static final String sToken = "A8888888888888888888A";
	/**
	 * replace the sCorpID to your corp id
	 */
	public static final String sCorpID = "corpId";
	public static final String sEncodingAESKey = "A88888888888888888888888888888888888888888A";
	
	private static Map<String, WXBizMsgCrypt> crypts = new HashMap<String, WXBizMsgCrypt>();

	public static WXBizMsgCrypt getChatWXBizMsgCrypt(){
		return getWXBizMsgCrypt(sToken, sEncodingAESKey, sCorpID);
	}

	public static WXBizMsgCrypt getWXBizMsgCrypt(String token, String encodingAesKey, String corpId) {
		WXBizMsgCrypt wxcpt = null;
		String key = corpId + "-" + token;
		if (crypts.containsKey(key)) {
			wxcpt = crypts.get(key);
		} else {
			try {
				wxcpt = new WXBizMsgCrypt(token, encodingAesKey, corpId);	
			} catch (Exception e) {
				e.printStackTrace();
			}
		}
		return wxcpt;
	}
}

 为了测试回调模式，可以先把message方法注释掉。 然后打个包，部署到你们的云主机上面，再回到回调模式页面，测试一下.

 

 同时把下面几个选项都打开，特别是用户消息上报，如果关闭的话第三方将收不到任何消息。 

本节结束，下节讲述消息的解析和发送。