微信開發（5）：公眾號消息與事件推送處理（轉）

1.0 開發背景
外包公司，所以各種各樣的項目都有接觸，有個需求，客戶要做不同的二維碼，通過二維碼關注以后，給用戶發送不同的消息，順便統計用戶來源，
本文用到了 微信帶參數二維碼接口和消息管理里的相關接口
注意 ：在微信公眾號后台，設置了服務器配置 URL 並啟用后，會導致 微信后台設置的回復規則，以及底部菜單都全部失效！直接清空了！因為這時候 微信已經把公眾號消息和事件 推送給開發者配置的url中，讓開發者進行處理了。
本文先講述微信官方后台設置帶參二維碼，后續更新使用第三方平台開發實現這個功能，從而保證了用戶微信公眾號官方設置底部菜單以及自定義回復沒有失效！

2.0 開發准備
2.1老樣子 官方文檔 來一波 帶參二維碼 接收事件
2.2 需要在微信后台 配置服務器配置 ，微信會在你修改這個配置的時候 給你填寫的URL發送數據，需要提前把項目上傳服務器

這個東西 配置好之后 可以點擊開啟了 ，開啟后啊，這個微信會把所有用戶發送的信息，給轉發給填寫的url 上。開發者必須在五秒內回復微信服務器。否則 微信會進行三次重試，重試均失敗后，會給用戶提示 該公眾號暫時無法提供服務。 而且在公眾平台還有告警通知。

下面看代碼

package com.ysh.wxtest.controller;

import org.apache.log4j.Logger;
import org.dom4j.Document;
import org.dom4j.Element;
import org.dom4j.io.SAXReader;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import weixin.popular.bean.xmlmessage.XMLMessage;
import weixin.popular.bean.xmlmessage.XMLTextMessage;
import weixin.popular.support.ExpireKey;
import weixin.popular.support.expirekey.DefaultExpireKey;
import weixin.popular.util.SignatureUtil;

import javax.servlet.ServletInputStream;
import javax.servlet.ServletOutputStream;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.*;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

/**
 * 消息接收控制層
 * @author YaoShiHang
 * @Date 15:15 2017-10-16
 */
@Controller
public class WxqrcodeController {

    private final String TOKEN="xxxxxxxxxx";                      //Wx 開發者設置的 token
    private Logger loger = Logger.getLogger(getClass());
    //重復通知過濾
    private static ExpireKey expireKey = new DefaultExpireKey();


    //微信推送事件 url
    @RequestMapping("/openwx/getticket")
    public void getTicket(HttpServletRequest request, HttpServletResponse response)
            throws Exception {
        ServletInputStream inputStream = request.getInputStream();
        ServletOutputStream outputStream = response.getOutputStream(); String signature = request.getParameter("signature");
        String timestamp = request.getParameter("timestamp");
        String nonce = request.getParameter("nonce");
        String echostr = request.getParameter("echostr");

        //首次請求申請驗證,返回echostr
        if(echostr!=null){
            outputStreamWrite(outputStream,echostr);
            return;
        }

        //驗證請求簽名
        if(!signature.equals(SignatureUtil.generateEventMessageSignature(TOKEN,timestamp,nonce))){
            System.out.println("The request signature is invalid");
            return;
        }

        boolean isreturn= false;
        loger.info("1.收到微信服務器消息");
        Map<String, String> wxdata=parseXml(request);
        if(wxdata.get("MsgType")!=null){
            if("event".equals(wxdata.get("MsgType"))){
                loger.info("2.1解析消息內容為：事件推送");
                if( "subscribe".equals(wxdata.get("Event"))){
                    loger.info("2.2用戶第一次關注 返回true哦");
                    isreturn=true;
                }
            }
        }

        if(isreturn == true){
            //轉換XML
            String key = wxdata.get("FromUserName")+ "__"
                    + wxdata.get("ToUserName")+ "__"
                    + wxdata.get("MsgId") + "__"
                    + wxdata.get("CreateTime");
            loger.info("3.0 進入回復 轉換對象："+key);

            if(expireKey.exists(key)){
                //重復通知不作處理
                loger.info("3.1  重復通知了");
                return;
            }else{
                loger.info("3.1  第一次通知");
                expireKey.add(key);
            }

            loger.info("3.2  回復你好");
            //創建回復
            XMLMessage xmlTextMessage = new XMLTextMessage(
                    wxdata.get("FromUserName"),
                    wxdata.get("ToUserName"),
                    "你好");
            //回復
            xmlTextMessage.outputStreamWrite(outputStream);
            return;
        }
        loger.info("3.2  回復空");
        outputStreamWrite(outputStream,"");
    }

    /**
     * 數據流輸出
     * @param outputStream
     * @param text
     * @return
     */
    private boolean outputStreamWrite(OutputStream outputStream, String text){
        try {
            outputStream.write(text.getBytes("utf-8"));
        } catch (UnsupportedEncodingException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
            return false;
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
            return false;
        }
        return true;
    }

    /**
     * dom4j 解析 xml 轉換為 map
     * @param request
     * @return
     * @throws Exception
     */
    public static Map<String, String> parseXml(HttpServletRequest request) throws Exception {
        // 將解析結果存儲在HashMap中
        Map<String, String> map = new HashMap<String, String>();
        // 從request中取得輸入流
        InputStream inputStream = request.getInputStream();
        // 讀取輸入流
        SAXReader reader = new SAXReader();
        Document document = reader.read(inputStream);
        // 得到xml根元素
        Element root = document.getRootElement();
        // 得到根元素的所有子節點
        List<Element> elementList = root.elements();

        // 遍歷所有子節點
        for (Element e : elementList)
            map.put(e.getName(), e.getText());

        // 釋放資源
        inputStream.close();
        inputStream = null;
        return map;
    }

    /**
     * 回復微信服務器"文本消息"
     * @param response
     * @param returnvaleue
     */
    public void output(HttpServletResponse response, String returnvaleue) {
        try {
            PrintWriter pw = response.getWriter();
            pw.write(returnvaleue);
            loger.info("****************return valeue***************="+returnvaleue);
            pw.flush();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

提供一個大神的幫助類

package weixin.popular.bean.xmlmessage;

import java.io.IOException;
import java.io.OutputStream;
import java.io.UnsupportedEncodingException;
import java.util.UUID;

import com.qq.weixin.mp.aes.AesException;
import com.qq.weixin.mp.aes.WXBizMsgCrypt;

import weixin.popular.bean.message.message.Message;

public abstract class XMLMessage {

    protected String toUserName;
    protected String fromUserName;
    protected String msgType;

    protected XMLMessage(String toUserName, String fromUserName, String msgType) {
        super();
        this.toUserName = toUserName;
        this.fromUserName = fromUserName;
        this.msgType = msgType;
    }

    /**
     * 子類自定義XML
     * @return XML
     */
    public abstract String subXML();

    /**
     * 轉換為  Message 對象
     * @return Message
     */
    public abstract Message convert();

    public String toXML(){
        StringBuilder sb = new StringBuilder();
        sb.append("<xml>");
        sb.append("<ToUserName><![CDATA["+toUserName+"]]></ToUserName>");
        sb.append("<FromUserName><![CDATA["+fromUserName+"]]></FromUserName>");
        sb.append("<CreateTime>"+System.currentTimeMillis()/1000+"</CreateTime>");
        sb.append("<MsgType><![CDATA["+msgType+"]]></MsgType>");
        sb.append(subXML());
        sb.append("</xml>");
        return sb.toString();
    }

    public boolean outputStreamWrite(OutputStream outputStream){
        try {
            outputStream.write(toXML().getBytes("utf-8"));
            outputStream.flush();
        } catch (UnsupportedEncodingException e) {
            e.printStackTrace();
            return false;
        } catch (IOException e) {
            e.printStackTrace();
            return false;
        }
        return true;
    }

    public boolean outputStreamWrite(OutputStream outputStream,WXBizMsgCrypt bizMsgCrypt){
        if(bizMsgCrypt != null){
            try {
                String outputStr = bizMsgCrypt.encryptMsg(toXML(), System.currentTimeMillis()+"",UUID.randomUUID().toString());
                outputStream.write(outputStr.getBytes("utf-8"));
                outputStream.flush();
            } catch (UnsupportedEncodingException e) {
                e.printStackTrace();
                return false;
            } catch (IOException e) {
                e.printStackTrace();
                return false;
            } catch (AesException e) {
                e.printStackTrace();
                return false;
            }
            return true;
        }else{
            return outputStreamWrite(outputStream);
        }
    }

    public String getToUserName() {
        return toUserName;
    }

    public String getFromUserName() {
        return fromUserName;
    }

    public String getMsgType() {
        return msgType;
    }


}