【跟着博弈走,微信轻松有】企业号第三方Java环境搭建之二: 回调模式_JAVA_编程开发_程序员俱乐部

中国优秀的程序员网站程序员频道CXYCLUB技术地图
热搜:
更多>>
 
您所在的位置: 程序员俱乐部 > 编程开发 > JAVA > 【跟着博弈走,微信轻松有】企业号第三方Java环境搭建之二: 回调模式

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

 2014/11/23 21:29:22  boyitech  程序员俱乐部  我要评论(0)
  • 摘要:前节【项目搭建】讲述了如何搭建一个SpringMVC的Maven项目,这节我们将关注回调模式的相关事宜。开启应用的回调模式当你开启应用的回调模式时,企业号会要求你填写应用的URL、Token、EncodingAESKey三个参数。URL是企业应用接收企业号推送请求的访问协议和地址,支持http或https协议。Token可由企业任意填写,用于生成签名。EncodingAESKey用于消息体的加密,是AES密钥的Base64编码。登陆企业服务号之后,管理员可以添加企业应用:点击添加按钮之后
  • 标签:环境搭建 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

?

class="java">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方法注释掉。 然后打个包,部署到你们的云主机上面,再回到回调模式页面,测试一下.

?

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

?

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

?

  • 大小: 70.9 KB
  • 大小: 38.5 KB
  • 大小: 53.5 KB
  • 大小: 80.7 KB
  • 大小: 42.6 KB
  • 大小: 99 KB
  • 查看图片附件
发表评论
用户名: 匿名