@Controller
@RequestMapping("/wechat")
publicclass WechatController {
@Value("${DNBX_TOKEN}")
private String DNBX_TOKEN;
private static final Logger LOGGER = LoggerFactory.getLogger(WechatController.class);
@Resource
WechatService wechatService;
/**
* 微信接入
* @param wc
* @return
* @throws IOException 
*/
@RequestMapping(value="/connect",method = {RequestMethod.GET, RequestMethod.POST})
@ResponseBody
publicvoid connectWeixin(HttpServletRequest request, HttpServletResponse response) throws IOException{
// 將請(qǐng)求、響應(yīng)的編碼均設(shè)置為UTF-8（防止中文亂碼） 
request.setCharacterEncoding("UTF-8"); //微信服務(wù)器POST消息時(shí)用的是UTF-8編碼，在接收時(shí)也要用同樣的編碼，否則中文會(huì)亂碼；
response.setCharacterEncoding("UTF-8"); //在響應(yīng)消息（回復(fù)消息給用戶）時(shí)，也將編碼方式設(shè)置為UTF-8，原理同上；boolean isGet = request.getMethod().toLowerCase().equals("get"); 
PrintWriter out = response.getWriter();
try {
if (isGet) {
String signature = request.getParameter("signature");// 微信加密簽名 
String timestamp = request.getParameter("timestamp");// 時(shí)間戳 
String nonce = request.getParameter("nonce");// 隨機(jī)數(shù) 
String echostr = request.getParameter("echostr");//隨機(jī)字符串 
// 通過(guò)檢驗(yàn)signature對(duì)請(qǐng)求進(jìn)行校驗(yàn)，若校驗(yàn)成功則原樣返回echostr，表示接入成功，否則接入失敗 if (SignUtil.checkSignature(DNBX_TOKEN, signature, timestamp, nonce)) { 
LOGGER.info("Connect the weixin server is successful.");
response.getWriter().write(echostr); 
} else { 
LOGGER.error("Failed to verify the signature!"); 
}
}else{
String respMessage = "異常消息！";
try {
respMessage = wechatService.weixinPost(request);
out.write(respMessage);
LOGGER.info("The request completed successfully");
LOGGER.info("to weixin server "+respMessage);
} catch (Exception e) {
LOGGER.error("Failed to convert the message from weixin!"); 
}
}
} catch (Exception e) {
LOGGER.error("Connect the weixin server is error.");
}finally{
out.close();
}
}
}

public class SignUtil { 
/** 
* 驗(yàn)證簽名 
* 
* @param token 微信服務(wù)器token，在env.properties文件中配置的和在開(kāi)發(fā)者中心配置的必須一致 
* @param signature 微信服務(wù)器傳過(guò)來(lái)sha1加密的證書簽名
* @param timestamp 時(shí)間戳
* @param nonce 隨機(jī)數(shù) 
* @return 
*/ 
public static boolean checkSignature(String token,String signature, String timestamp, String nonce) { 
String[] arr = new String[] { token, timestamp, nonce }; 
// 將token、timestamp、nonce三個(gè)參數(shù)進(jìn)行字典序排序 
Arrays.sort(arr); 
// 將三個(gè)參數(shù)字符串拼接成一個(gè)字符串進(jìn)行sha1加密 
String tmpStr = SHA1.encode(arr[0] + arr[1] + arr[2]); 
// 將sha1加密后的字符串可與signature對(duì)比，標(biāo)識(shí)該請(qǐng)求來(lái)源于微信 
return tmpStr != null ? tmpStr.equals(signature.toUpperCase()) : false; 
} 
}

/** 
* 微信公眾平臺(tái)(JAVA) SDK 
* 
* SHA1算法
* 
* @author helijun 2016/06/15 19:49
*/ 
public final class SHA1 { 
private static final char[] HEX_DIGITS = {'0', '1', '2', '3', '4', '5', 
'6', '7', '8', '9', 'A', 'B', 'C', 'D', 'E', 'F' }; 
/** 
* Takes the raw bytes from the digest and formats them correct. 
* 
* @param bytes the raw bytes from the digest. 
* @return the formatted bytes. 
*/ 
private static String getFormattedText(byte[] bytes) { 
int len = bytes.length; 
StringBuilder buf = new StringBuilder(len * 2); 
// 把密文轉(zhuǎn)換成十六進(jìn)制的字符串形式 
for (int j = 0; j < len; j++) { 
buf.append(HEX_DIGITS[(bytes[j] >> 4) & 0x0f]); 
buf.append(HEX_DIGITS[bytes[j] & 0x0f]); 
} 
return buf.toString(); 
} 
public static String encode(String str) { 
if (str == null) { 
return null; 
} 
try { 
MessageDigest messageDigest = MessageDigest.getInstance("SHA1"); 
messageDigest.update(str.getBytes()); 
return getFormattedText(messageDigest.digest()); 
} catch (Exception e) { 
throw new RuntimeException(e); 
} 
} 
}

/**
* 處理微信發(fā)來(lái)的請(qǐng)求
* 
* @param request
* @return
*/
public String weixinPost(HttpServletRequest request) {
String respMessage = null;
try {
// xml請(qǐng)求解析
Map<String, String> requestMap = MessageUtil.xmlToMap(request);
// 發(fā)送方帳號(hào)（open_id）
String fromUserName = requestMap.get("FromUserName");
// 公眾帳號(hào)
String toUserName = requestMap.get("ToUserName");
// 消息類型
String msgType = requestMap.get("MsgType");
// 消息內(nèi)容
String content = requestMap.get("Content");
LOGGER.info("FromUserName is:" + fromUserName + ", ToUserName is:" + toUserName + ", MsgType is:" + msgType);
// 文本消息
if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_TEXT)) {
//這里根據(jù)關(guān)鍵字執(zhí)行相應(yīng)的邏輯，只有你想不到的，沒(méi)有做不到的
if(content.equals("xxx")){
}
//自動(dòng)回復(fù)
TextMessage text = new TextMessage();
text.setContent("the text is" + content);
text.setToUserName(fromUserName);
text.setFromUserName(toUserName);
text.setCreateTime(new Date().getTime() + "");
text.setMsgType(msgType);
respMessage = MessageUtil.textMessageToXml(text);
} /*else if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_EVENT)) {// 事件推送
String eventType = requestMap.get("Event");// 事件類型
if (eventType.equals(MessageUtil.EVENT_TYPE_SUBSCRIBE)) {// 訂閱
respContent = "歡迎關(guān)注xxx公眾號(hào)！";
return MessageResponse.getTextMessage(fromUserName , toUserName , respContent);
} else if (eventType.equals(MessageUtil.EVENT_TYPE_CLICK)) {// 自定義菜單點(diǎn)擊事件
String eventKey = requestMap.get("EventKey");// 事件KEY值，與創(chuàng)建自定義菜單時(shí)指定的KEY值對(duì)應(yīng)
logger.info("eventKey is:" +eventKey);
return xxx;
}
}
//開(kāi)啟微信聲音識(shí)別測(cè)試 2015-3-30
else if(msgType.equals("voice"))
{
String recvMessage = requestMap.get("Recognition");
//respContent = "收到的語(yǔ)音解析結(jié)果："+recvMessage;
if(recvMessage!=null){
respContent = TulingApiProcess.getTulingResult(recvMessage);
}else{
respContent = "您說(shuō)的太模糊了，能不能重新說(shuō)下呢？";
}
return MessageResponse.getTextMessage(fromUserName , toUserName , respContent); 
}
//拍照功能
else if(msgType.equals("pic_sysphoto"))
{
}
else
{
return MessageResponse.getTextMessage(fromUserName , toUserName , "返回為空"); 
}*/
// 事件推送
else if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_EVENT)) {
String eventType = requestMap.get("Event");// 事件類型
// 訂閱
if (eventType.equals(MessageUtil.EVENT_TYPE_SUBSCRIBE)) {
TextMessage text = new TextMessage();
text.setContent("歡迎關(guān)注，xxx");
text.setToUserName(fromUserName);
text.setFromUserName(toUserName);
text.setCreateTime(new Date().getTime() + "");
text.setMsgType(MessageUtil.RESP_MESSAGE_TYPE_TEXT);
respMessage = MessageUtil.textMessageToXml(text);
} 
// TODO 取消訂閱后用戶再收不到公眾號(hào)發(fā)送的消息，因此不需要回復(fù)消息
else if (eventType.equals(MessageUtil.EVENT_TYPE_UNSUBSCRIBE)) {// 取消訂閱
} 
// 自定義菜單點(diǎn)擊事件
else if (eventType.equals(MessageUtil.EVENT_TYPE_CLICK)) {
String eventKey = requestMap.get("EventKey");// 事件KEY值，與創(chuàng)建自定義菜單時(shí)指定的KEY值對(duì)應(yīng)
if (eventKey.equals("customer_telephone")) {
TextMessage text = new TextMessage();
text.setContent("0755-86671980");
text.setToUserName(fromUserName);
text.setFromUserName(toUserName);
text.setCreateTime(new Date().getTime() + "");
text.setMsgType(MessageUtil.RESP_MESSAGE_TYPE_TEXT);
respMessage = MessageUtil.textMessageToXml(text);
}
}
}
}
catch (Exception e) {
Logger.error("error......")
}
return respMessage;
}

public class MessageUtil {
/** 
* 返回消息類型：文本 
*/ 
public static final String RESP_MESSAGE_TYPE_TEXT = "text"; 
/** 
* 返回消息類型：音樂(lè) 
*/ 
public static final String RESP_MESSAGE_TYPE_MUSIC = "music"; 
/** 
* 返回消息類型：圖文 
*/ 
public static final String RESP_MESSAGE_TYPE_NEWS = "news"; 
/** 
* 請(qǐng)求消息類型：文本 
*/ 
public static final String REQ_MESSAGE_TYPE_TEXT = "text"; 
/** 
* 請(qǐng)求消息類型：圖片 
*/ 
public static final String REQ_MESSAGE_TYPE_IMAGE = "image"; 
/** 
* 請(qǐng)求消息類型：鏈接 
*/ 
public static final String REQ_MESSAGE_TYPE_LINK = "link"; 
/** 
* 請(qǐng)求消息類型：地理位置 
*/ 
public static final String REQ_MESSAGE_TYPE_LOCATION = "location"; 
/** 
* 請(qǐng)求消息類型：音頻 
*/ 
public static final String REQ_MESSAGE_TYPE_VOICE = "voice"; 
/** 
* 請(qǐng)求消息類型：推送 
*/ 
public static final String REQ_MESSAGE_TYPE_EVENT = "event"; 
/** 
* 事件類型：subscribe(訂閱) 
*/ 
public static final String EVENT_TYPE_SUBSCRIBE = "subscribe"; 
/** 
* 事件類型：unsubscribe(取消訂閱) 
*/ 
public static final String EVENT_TYPE_UNSUBSCRIBE = "unsubscribe"; 
/** 
* 事件類型：CLICK(自定義菜單點(diǎn)擊事件) 
*/ 
public static final String EVENT_TYPE_CLICK = "CLICK"; 
}

<!-- 解析xml -->
<dependency>
<groupId>dom4j</groupId>
<artifactId>dom4j</artifactId>
<version>1.6.1</version>
</dependency>
<dependency>
<groupId>com.thoughtworks.xstream</groupId>
<artifactId>xstream</artifactId>
<version>1.4.9</version>
</dependency>

/**
* xml轉(zhuǎn)換為map
* @param request
* @return
* @throws IOException
*/
@SuppressWarnings("unchecked")
public static Map<String, String> xmlToMap(HttpServletRequest request) throws IOException{
Map<String, String> map = new HashMap<String, String>();
SAXReader reader = new SAXReader();
InputStream ins = null;
try {
ins = request.getInputStream();
} catch (IOException e1) {
e1.printStackTrace();
}
Document doc = null;
try {
doc = reader.read(ins);
Element root = doc.getRootElement();
List<Element> list = root.elements();
for (Element e : list) {
map.put(e.getName(), e.getText());
}
return map;
} catch (DocumentException e1) {
e1.printStackTrace();
}finally{
ins.close();
}
return null;
}

/** 
* 文本消息對(duì)象轉(zhuǎn)換成xml 
* 
* @param textMessage 文本消息對(duì)象 
* @return xml 
*/ 
public static String textMessageToXml(TextMessage textMessage){
XStream xstream = new XStream();
xstream.alias("xml", textMessage.getClass());
return xstream.toXML(textMessage);
}