資料流向

使用者<———–>微信端 <———–>後臺伺服器

成功接入微信端後
接受微信端傳送的xml訊息，解析為實體物件，處理後再轉成xml格式的資料傳送給微信端

servlet程式碼

public void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        // /** 請求獲取token*/
        // String token = new WechatUtil().getToken();
 

        // logger.error("----->獲取token------->"+token);
        // 設定utf-8編碼防止中文亂碼
        request.setCharacterEncoding("UTF-8");
        response.setCharacterEncoding("UTF-8");
        PrintWriter out = null;

        // 傳送給微信端的的xml資料
        String respXmlMsg = null;
        // 返回xml資料物件
        ResponseXml responseXml = new
 
 ResponseXml();
        // xml請求解析
        Map<String, String> requestMap;
        try {
            requestMap = MessageUtil.parseXml(request);// 解析xml物件
            String fromUserName = requestMap.get("FromUserName");// 傳送方帳號（open_id）
            String toUserName = requestMap.get("ToUserName");// 公眾帳號
 

            String creatTime = requestMap.get("CreateTime");
            String msgType = requestMap.get("MsgType");// 訊息型別
            String content = requestMap.get("Content");// text內容
            String event = requestMap.get("Event");// event內容
            String eventKey = requestMap.get("EventKey");
            logger.error("!-!-!-!-!:" + eventKey);
            // 輸出log日誌
            logger.error("----->req  msgType：" + msgType);
            logger.error("----->req  event：" + event);
            logger.error("----->req  content：" + content);

            String sql = "insert into receivetextMsg values('" + toUserName + "','" + fromUserName + "'," + creatTime + ",'" + msgType + "','" + content + "')";
            new DBUtil(sql);// 儲存到資料庫中
            // 根據使用者輸入回覆不同內容
            if (msgType.equals("text")) {
                if (content.equals("1")) {
                    respXmlMsg = responseXml.respTextXml(fromUserName, toUserName, "1是極好");
                } else if (content.equals("2")) {
                    respXmlMsg = responseXml.respTextXml(fromUserName, toUserName, "2nice");
                } else {
                    respXmlMsg = responseXml.respTextXml(fromUserName, toUserName, "既不是1也不是2/::D");
                }

            } else if (msgType.equals("image")) {
                respXmlMsg = responseXml.respNewsXml(fromUserName, toUserName);
            }
            if (msgType.equals("event")) {
                if (event.equals("subscribe")) {
                    // 訂閱時 返回訊息
                    respXmlMsg = responseXml.respTextXml(fromUserName, toUserName, "輸入1、2、3...試試看/::D\n或者發個圖片/::D");
                } else if (event.equals("CLICK")) {
                    if (eventKey.equals("V1001_GOOD")) {
                        logger.error("!-!-!-!-!-!-->click事件");
                        respXmlMsg = responseXml.respTextXml(fromUserName, toUserName, "謝謝支援/:rose");
                    }
                }

            }
            // 輸出日誌
            logger.error("logpost----respXmlMsg----->:" + respXmlMsg);
            out = response.getWriter();
            out.print(respXmlMsg);
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            out.close();
            out = null;
        }
    }

解析xml 及string轉xml方法
需導包 dom4j.jar xstream.jar(依賴xmlpull.jar)

/**
 * 解析微信發來的請求（XML）
 * 返回string轉成的xml
 * @author admin
 *
 */
public class MessageUtil {
    /**
     * 解析微信發來的請求（XML）
     * @param request
     * @return
     */
    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();
        // 得到根元素的所有子節點
        @SuppressWarnings("unchecked")
        List<Element> elementList = root.elements();

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

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

        return map;
    }

    /**
     * 文字訊息物件轉換成xml
     * @param textMessage 文字訊息物件
     * @return xml
     */
    public static String textMessageToXml(TextMessage textMessage) {
        xstream.alias("xml", textMessage.getClass());
        return xstream.toXML(textMessage);
    }

     /** 
     * 音樂訊息物件轉換成xml 
     *  
     * @param musicMessage 音樂訊息物件 
     * @return xml 
     */  
    public static String musicMessageToXml(MusicMessage musicMessage) {  
        xstream.alias("xml", musicMessage.getClass());  
        return xstream.toXML(musicMessage);  
    }  

    /** 
     * 圖文訊息物件轉換成xml 
     *  
     * @param newsMessage 圖文訊息物件 
     * @return xml 
     */  
    public static String newsMessageToXml(NewsMessage newsMessage) {  
        xstream.alias("xml", newsMessage.getClass());  
        xstream.alias("item", new Article().getClass());  
        return xstream.toXML(newsMessage);  
    }  
    /** 
     * 擴充套件xstream，使其支援CDATA塊 
     * xstream 還依賴xmlpull_1_0_5.jar許引入
     */  
    private static XStream xstream = new XStream(new XppDriver() {  
        public HierarchicalStreamWriter createWriter(Writer out) {  
            return new PrettyPrintWriter(out) {  
                // 對所有xml節點的轉換都增加CDATA標記  
                boolean cdata = true;  
                protected void writeText(QuickWriter writer, String text) {  
                    if (cdata) {  
                        writer.write("<![CDATA[");  
                        writer.write(text);  
                        writer.write("]]>");  
                    } else {  
                        writer.write(text);  
                    }  
                }  
            };  
        }  
    });  
}

響應的實體物件類

public class BaseMessage {
    /**
     * 接收方帳號（收到的OpenID）
     */
    private String ToUserName;
    /**
     * 開發者微訊號
     */
    private String FromUserName;
    /**
     * 訊息建立時間 （整型）
     */
    private long CreateTime;

    /**
     * 訊息型別
     */
    private String MsgType;

    /**
     * 位0x0001被標誌時，星標剛收到的訊息
     */
    private int FuncFlag;

    public String getToUserName() {
        return ToUserName;
    }

    public void setToUserName(String toUserName) {
        ToUserName = toUserName;
    }

    public String getFromUserName() {
        return FromUserName;
    }

    public void setFromUserName(String fromUserName) {
        FromUserName = fromUserName;
    }

    public long getCreateTime() {
        return CreateTime;
    }

    public void setCreateTime(long createTime) {
        CreateTime = createTime;
    }

    public String getMsgType() {
        return MsgType;
    }

    public void setMsgType(String msgType) {
        MsgType = msgType;
    }

    public int getFuncFlag() {
        return FuncFlag;
    }

    public void setFuncFlag(int funcFlag) {
        FuncFlag = funcFlag;
    }

    @Override
    public String toString() {
        return "BaseMessage [ToUserName=" + ToUserName + ", FromUserName="
                + FromUserName + ", CreateTime=" + CreateTime + ", MsgType="
                + MsgType + ", FuncFlag=" + FuncFlag + "]";
    }
}

public class TextMessage extends BaseMessage {
    /**
     * 回覆的訊息內容
     */
    private String Content;

    public String getContent() {
        return Content;
    }

    public void setContent(String content) {
        Content = content;
    }
    @Override
    public String toString() {
        // TODO Auto-generated method stub
        return super.toString()+"[Content:"+this.Content+"]";
    }
}

public class NewsMessage extends BaseMessage {
    // 圖文訊息個數，限制為10條以內
    private int ArticleCount;
    // 多條圖文訊息資訊，預設第一個item為大圖
    private List<Article> Articles;

    public int getArticleCount() {
        return ArticleCount;
    }

    public void setArticleCount(int articleCount) {
        ArticleCount = articleCount;
    }

    public List<Article> getArticles() {
        return Articles;
    }

    public void setArticles(List<Article> articles) {
        Articles = articles;
    }

    @Override
    public String toString() {
        return "NewsMessage [ArticleCount=" + ArticleCount + ", Articles="
                + Articles + "]";
    }

}