Java微信公眾號開發

　　微信公眾平台是騰訊為了讓用戶申請和管理微信公眾賬號而推出的一個web平台。微信公眾賬號的種類可以分為3種，並且一旦選定不可更改。按照功能的限制從小到大依次為：訂閱號、服務號、企業號。個人只能注冊訂閱號。注冊地址：https://mp.weixin.qq.com/。

開發環境的准備

• 微信公眾號
• 外網映射工具（開發調試）

　　與微信的對接的URL應該滿足以下的條件：

• 在公網上能夠訪問
• 只支持80端口

　　映射工具有很多，例如花生殼，ngrok可以將內網映射到公網上面，這樣就可以使用公網訪問本機的網絡服務。下載鏈接: http://pan.baidu.com/s/1i3u26St 密碼: v4e8（里面有簡明的教程）。

微信公眾號的數據交互原理

　　我們的主要開發就是微信公眾號服務器的開發。

開發模式的接入

　　進入微信公眾號平台之后進入開發者中心，在開發者中心中找到開發者文檔，在新手指南中有接入的相關步驟。依據接入文檔有以下的實現：

package org.gpf.servlet;

import java.io.IOException;
import java.io.PrintWriter;

import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import org.gpf.util.CheckUtil;
/**
 * 接收微信服務器發送的4個參數並返回echostr
 */
public class WeixinServlet extends HttpServlet {

    public void doGet(HttpServletRequest request, HttpServletResponse response)
            throws ServletException, IOException {

        // 接收微信服務器以Get請求發送的4個參數
        String signature = request.getParameter("signature");
        String timestamp = request.getParameter("timestamp");
        String nonce = request.getParameter("nonce");
        String echostr = request.getParameter("echostr");
        
        PrintWriter out = response.getWriter();
        if (CheckUtil.checkSignature(signature, timestamp, nonce)) {
            out.print(echostr);        // 校驗通過，原樣返回echostr參數內容
        }
    }

    public void doPost(HttpServletRequest request, HttpServletResponse response)
            throws ServletException, IOException {

        doGet(request, response);
    }

}

　　校驗工具類：

package org.gpf.util;

import java.util.Arrays;

import org.apache.commons.codec.digest.DigestUtils;

/**
 * 校驗的工具類
 */
public class CheckUtil {

    private static final String token = "weixin";
    public static boolean checkSignature(String signature,String timestamp,String nonce){
        
        String[] arr = new String[] { token, timestamp, nonce };
        
        // 排序
        Arrays.sort(arr);
        // 生成字符串
        StringBuilder content = new StringBuilder();
        for (int i = 0; i < arr.length; i++) {
            content.append(arr[i]);
        }
        
        // sha1加密
        String temp = getSHA1String(content.toString());
        
        return temp.equals(signature); // 與微信傳遞過來的簽名進行比較
    }
    
    private static String getSHA1String(String data){
        return DigestUtils.sha1Hex(data);    // 使用commons codec生成sha1字符串
    }
}

　　Servlet配置：

servlet>
<servlet-name>WeixinServlet</servlet-name>
<servlet-class>org.gpf.servlet.WeixinServlet</servlet-class>
</servlet>

<servlet-mapping>
<servlet-name>WeixinServlet</servlet-name>
<url-pattern>/wx.do</url-pattern>
</servlet-mapping>

　　接下來通過映射工具將本地的服務器映射到公網，從公網訪問Servlet。

　　開發模式和編輯模式是互斥的，如果啟動了開發模式，則自定義菜單和自動回復將失效！

消息的接收和響應

　　參照文檔，當普通微信用戶向公眾賬號發消息時，微信服務器將POST消息的XML數據包到開發者填寫的URL上。所以我們需要更改我們的Servlet中的doPost方法，因為微信服務器與我們的服務器之間是通過XML傳遞數據的，因此我們需要實現消息實體與XML之間的互相轉換。可以采用第三方jar包XStream完成。

　　處理微信服務器與本機服務器進行交互的Servlet：

package org.gpf.servlet;

import java.io.IOException;
import java.io.PrintWriter;
import java.util.Date;
import java.util.Map;

import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import org.dom4j.DocumentException;
import org.gpf.po.TextMeaasge;
import org.gpf.util.CheckUtil;
import org.gpf.util.MessageUtil;
/**
 * 微信消息的接收和響應
 */
public class WeixinServlet extends HttpServlet {

    /**
     * 接收微信服務器發送的4個參數並返回echostr
     */
    public void doGet(HttpServletRequest request, HttpServletResponse response)
            throws ServletException, IOException {

        // 接收微信服務器以Get請求發送的4個參數
        String signature = request.getParameter("signature");
        String timestamp = request.getParameter("timestamp");
        String nonce = request.getParameter("nonce");
        String echostr = request.getParameter("echostr");
        
        PrintWriter out = response.getWriter();
        if (CheckUtil.checkSignature(signature, timestamp, nonce)) {
            out.print(echostr);        // 校驗通過，原樣返回echostr參數內容
        }
    }

    /**
     * 接收並處理微信客戶端發送的請求
     */
    public void doPost(HttpServletRequest request, HttpServletResponse response)
            throws ServletException, IOException {

        request.setCharacterEncoding("utf-8");
        response.setContentType("text/xml;charset=utf-8");
        PrintWriter out = response.getWriter();
        try {
            Map<String, String> map = MessageUtil.xmlToMap(request);
            String toUserName = map.get("ToUserName");
            String fromUserName = map.get("FromUserName");
            String msgType = map.get("MsgType");
            String content = map.get("Content");
            
            String message = null;
            if ("text".equals(msgType)) {                // 對文本消息進行處理
                TextMeaasge text = new TextMeaasge();
                text.setFromUserName(toUserName);         // 發送和回復是反向的
                text.setToUserName(fromUserName);
                text.setMsgType("text");
                text.setCreateTime(new Date().getTime());
                text.setContent("你發送的消息是：" + content);
                message = MessageUtil.textMessageToXML(text);
                System.out.println(message);            
            }
            out.print(message);                            // 將回應發送給微信服務器
        } catch (DocumentException e) {
            e.printStackTrace();
        }finally{
            out.close();
        }
    }

}

　　按照微信的接口文檔編寫的文本消息實體類：

package org.gpf.po;
/**
 * 按照微信的接入文檔編寫的微信文本消息實體
 */
public class TextMeaasge {

    private String ToUserName;
    private String FromUserName;
    private long CreateTime;
    private String MsgType;
    private String Content;
    private String MsgId;
    
    public TextMeaasge() {
        
    }
    
    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 String getContent() {
        return Content;
    }
    public void setContent(String content) {
        Content = content;
    }
    public String getMsgId() {
        return MsgId;
    }
    public void setMsgId(String msgId) {
        MsgId = msgId;
    }
}

　　實現消息轉換的工具類

package org.gpf.util;

import java.io.IOException;
import java.io.InputStream;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import javax.servlet.http.HttpServletRequest;

import org.dom4j.Document;
import org.dom4j.DocumentException;
import org.dom4j.Element;
import org.dom4j.io.SAXReader;
import org.gpf.po.TextMeaasge;

import com.thoughtworks.xstream.XStream;

/**
 * 實現消息的格式轉換(Map類型和XML的互轉)
 */
public class MessageUtil {

    /**
     * 將XML轉換成Map集合
     */
    public static Map<String, String>xmlToMap(HttpServletRequest request) throws IOException, DocumentException{
        
        Map<String, String> map = new HashMap<String, String>();
        SAXReader reader = new SAXReader();            // 使用dom4j解析xml
        InputStream ins = request.getInputStream(); // 從request中獲取輸入流
        Document doc = reader.read(ins);
        
        Element root = doc.getRootElement();         // 獲取根元素
        List<Element> list = root.elements();        // 獲取所有節點
        
        for (Element e : list) {
            map.put(e.getName(), e.getText()); 
            System.out.println(e.getName() + "--->" + e.getText());
        }
        ins.close();
        return map;
    }
    
    /**
     * 將文本消息對象轉換成XML
     */
    public static String textMessageToXML(TextMeaasge textMessage){
        
        XStream xstream = new XStream();              // 使用XStream將實體類的實例轉換成xml格式    
        xstream.alias("xml", textMessage.getClass()); // 將xml的默認根節點替換成“xml”
        return xstream.toXML(textMessage);
        
    }
    
}

　　Xtream下載地址：http://xstream.codehaus.org/download.html。dom4j下載地址：http://git.oschina.net/gaopengfei/Java_XML/raw/master/lib/dom4j-1.6.1.jar

　　天氣預報項目的github地址：https://github.com/gao-pengfei/WeChat.git