微信解析并响应数据

/**
     * 将微信服务器返回过来的数据转换为xml
     * @param request
     * @return
     */
    public static String readXMLFromRequestBody(HttpServletRequest request) {
        StringBuffer xml = new StringBuffer();
        xml.append("<?xml version="1.0" encoding="UTF-8"?>");
        String line = null;
        try {
            BufferedReader reader = request.getReader();
            while ((line = reader.readLine()) != null) {
                xml.append(line);
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
        return xml.toString();
    }

微信XML解析器

package com.util;

import java.io.ByteArrayInputStream;
import java.io.UnsupportedEncodingException;
import java.util.regex.Pattern;

import javax.xml.parsers.DocumentBuilderFactory;

import org.w3c.dom.DOMException;
import org.w3c.dom.Document;
import org.w3c.dom.Element;
import org.w3c.dom.NodeList;

/**
 * 微信返回XML的解析器
 * @author chuanyuBai
 *
 */
public class XMLParser {
    
    protected String mXMLContent;
    protected String mEncodeType;
    protected Document mXmlDoc = null;
    protected NodeList mXmlNodeList = null;
    protected Element mXmlNode = null;    
    public XMLParser(String xmlContent,String encodeType){
        mXMLContent = xmlContent;
        mEncodeType = encodeType;
        LoadXMLDocument();
    }
    
    public String getMsgType(){
        return mXmlNode.getElementsByTagName("MsgType").item(0).getFirstChild().getNodeValue();
    }
    
    public String getSessionID(){
        return mXmlNode.getElementsByTagName("FromUserName").item(0).getFirstChild().getNodeValue();
    }
    
    public String getUserName(){
        return mXmlNode.getElementsByTagName("ToUserName").item(0).getFirstChild().getNodeValue();
    }
    
    public String getCreateTime(){
        return mXmlNode.getElementsByTagName("CreateTime").item(0).getFirstChild().getNodeValue();
    }
    
    public double[] getLocation(){
        double[] location = new double[2];
        String slongitude = mXmlNode.getElementsByTagName("Location_Y").item(0).getFirstChild().getNodeValue();
        String slatitude = mXmlNode.getElementsByTagName("Location_X").item(0).getFirstChild().getNodeValue();
        location[0] = Double.parseDouble(slongitude);
        location[1] = Double.parseDouble(slatitude);
        return location;
    }
    public String getMsgText()
    {
        String question = "";
        if(mEncodeType == null || (mEncodeType!=null && !mEncodeType.equals("UTF-8"))){
            try {
                question = new String(mXmlNode.getElementsByTagName("Content").item(0).getFirstChild().getNodeValue().getBytes("iso-8859-1"), "UTF-8");
            } 
            catch (UnsupportedEncodingException | DOMException e) {
                e.printStackTrace();
            }
        }
        else{
            question = mXmlNode.getElementsByTagName("Content").item(0).getFirstChild().getNodeValue();
        }
        if(question.startsWith("/"))
            question="你好";
        return question;
    }
    
    public String getMsgRecognization(){
        String question = "";
        if(mEncodeType == null || (mEncodeType!=null && !mEncodeType.equals("UTF-8"))){
            try{
                question = new String(mXmlNode.getElementsByTagName("Recognition").item(0).getFirstChild().getNodeValue().getBytes("iso-8859-1"), "UTF-8");
            } 
            catch (UnsupportedEncodingException | DOMException e) {
                e.printStackTrace();
            }
        }
        else{
            question = mXmlNode.getElementsByTagName("Recognition").item(0).getFirstChild().getNodeValue();
        }
        return question;
    }
    
    public String getEventType(){
        return mXmlNode.getElementsByTagName("Event").item(0).getFirstChild().getNodeValue();
    }
    
    public String getEventKey(){            
        return mXmlNode.getElementsByTagName("EventKey").item(0).getFirstChild().getNodeValue();
    }
    
    public double[] getGlobalLocation(){
        double[] location = new double[2];
        String slongitude = mXmlNode.getElementsByTagName("Longitude").item(0).getFirstChild().getNodeValue();
        String slatitude = mXmlNode.getElementsByTagName("Latitude").item(0).getFirstChild().getNodeValue();
        location[0] = Double.parseDouble(slongitude);
        location[1] = Double.parseDouble(slatitude);
        return location;
    }
    public String getMsgImage(){
        String question = "";
        question="你好";
        return question;
    }
    public String getMsgVideo(){
        String question = "";
        question="你好";
        return question;
    }
    public String getMsgLink(){
        String question = "";
        question="你好";
        return question;
    }    
    protected void LoadXMLDocument(){
        try 
        {               
            mXmlDoc = DocumentBuilderFactory.newInstance().newDocumentBuilder().parse(new ByteArrayInputStream(mXMLContent.getBytes("UTF-8")));
        }catch(Exception e){
            e.printStackTrace(); 
        }
        mXmlNodeList = mXmlDoc.getElementsByTagName("xml");
        mXmlNode = (Element)mXmlNodeList.item(0);
    }    
    
    /**
     * 根据微信用户请求信息获取返回信息
     * @param xmlParser 微信用户请求xml
     * @return 返回给微信服务器的xml字符串
     */
    public static  String getResponseResult(XMLParser xmlParser) {
        StringBuffer sb = new StringBuffer();
        // 获取用户的问题
        try {
            String userAsk = "";
            
            switch(xmlParser.getMsgType().toLowerCase()) {
                case "text":
                    userAsk = xmlParser.getMsgText();
                    sb.append("大家好");
                    break;
                case "location":
                    double[] location = xmlParser.getLocation();

                    sb.append("精度:"+location[0]+" weidu:"+location[1]);
                    // 将当前信息发送给服务器
                    break;
                case "voice":
                    userAsk = xmlParser.getMsgRecognization();
                    sb.append("你上传的是voice"+userAsk);
                    break;
                case "image":
                    userAsk = xmlParser.getMsgImage();
                    sb.append("你上传的是image"+userAsk);
                    break;
                case "video":
                    userAsk = xmlParser.getMsgVideo();
                    sb.append("你上传的是video"+userAsk);
                    break;
                case "event":
                    String eventType = xmlParser.getEventType();
                    if ("click".equalsIgnoreCase(eventType)) {
                        String eventKey = xmlParser.getEventKey();
                        if (CommonUtil.isNotNull(eventKey)) {
                            userAsk = eventKey.trim();
                        } else {
                        }
                    } else if ("location".equalsIgnoreCase(eventType)) {
                    // 订阅
                    } else if ("subscribe".equalsIgnoreCase(eventType)) {
                        sb.append("nihao");
                    // 取消订阅
                    } else if ("unsubscribe".equalsIgnoreCase(eventType)) {
                    }
                    break;
                default:
            }
        } catch (Exception e) {
            
        }
        String textTpl = "<MsgType><![CDATA[%s]]></MsgType>" +
                "<Content><![CDATA[%s]]></Content>" +
                "<FuncFlag>0</FuncFlag>";
        String content = String.format(textTpl,"text",sb.toString().replaceAll(Pattern.quote("<br/>"), "
").replaceAll(Pattern.quote("<br>"), "
"));
        String wechatXML = "<xml>" +
                "<ToUserName><![CDATA[%s]]></ToUserName>" +
                "<FromUserName><![CDATA[%s]]></FromUserName>" +
                "<CreateTime>%s</CreateTime>" +
                "%s"+
                "</xml>";
        return String.format(wechatXML, xmlParser.getSessionID(),xmlParser.getUserName(),System.currentTimeMillis(),content);
    }
}

@Override
    public String execute() throws Exception {
        HttpServletRequest request = ServletActionContext.getRequest();
        StringBuffer sb = new StringBuffer();
        if ("get".equalsIgnoreCase(request.getMethod())) {
            // 从数据库找到该token或者设置token为 固定值
            String token = "baichuanyu";
            //1. 将token、timestamp、nonce三个参数进行字典序排序
            //2. 将三个参数字符串拼接成一个字符串进行sha1加密
            //3. 开发者获得加密后的字符串可与signature对比，标识该请求来源于微信
            //若确认此次GET请求来自微信服务器，请原样返回echostr参数内容，则接入生效，成为开发者成功，否则接入失败。
            String signature = request.getParameter("signature");
            String timestamp = request.getParameter("timestamp");
            String nonce = request.getParameter("nonce");
            String echostr = request.getParameter("echostr");    
            if(!checkSignature(signature,token,timestamp,nonce))
            {
                echostr = "";            
            }        
            sb.append(echostr);
            this.inputStream = new ByteArrayInputStream(sb.toString().getBytes("UTF-8"));
        } else if("POST".equals(request.getMethod())){
            String msg = readXMLFromRequestBody(request);
            XMLParser xmlParser = new XMLParser(msg, request.getCharacterEncoding());
            // 获取答案
            String answer = XMLParser.getResponseResult(xmlParser);
            sb.append(answer);
            this.inputStream = new ByteArrayInputStream(sb.toString().getBytes("UTF-8"));
        }
        
        return SUCCESS;
    }