微信公衆平臺開發

微信公衆號除了後臺編輯模式，還提供了高級開發模式，容許開發者接入本身的服務器，代替微信服務器與用戶通信。

那麼，開發的第一步，就是配置。

 

一.基本設置

    如圖：

   

    URL：服務器接入地址，也就是你的程序入口。

    token：簽名驗證用，至關於私有祕鑰，要與程序中的token保持一致

  

二.程序接入

      接入部分代碼由兩部分組成：

      get方法：是負責驗證簽名，確保消息是否來源於微信  

      post方法：請求消息，響應消息

package com.ever.qthh.servlet;

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

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

import com.ever.qthh.service.GatewayService;
import com.ever.qthh.utils.wx.SignUtil;

/**
 * 網關控制層
 * @author 51452
 *
 */
@WebServlet("/gateway")
public class GatewayServlet extends HttpServlet {    
    private static final long serialVersionUID = 1L;
        
    
    /**
     * 驗證信息是否來自微信
     */
    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        
         String signature = request.getParameter("signature");// 微信加密簽名  
         String timestamp = request.getParameter("timestamp");// 時間戳  
         String nonce = request.getParameter("nonce");// 隨機數  
         String echostr = request.getParameter("echostr");// 隨機字符串    
         
         PrintWriter out = response.getWriter();
         //經過檢驗signature對請求進行校驗，若校驗成功則原樣返回echostr，表示接入成功，不然接入失敗
         if (SignUtil.checkSignature(signature, timestamp, nonce)) {
             out.print(echostr);  
         }
         out.close();
         out =  null;
    }

    
    /**
     * 處理微信服務器發來的消息
     */
    protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        
        request.setCharacterEncoding("UTF-8");  
        response.setCharacterEncoding("UTF-8"); 
        
        // 調用核心業務類接收消息、處理消息  
        String respMessage = GatewayService.processRequest(request);
        
        // 響應消息  
        PrintWriter out = response.getWriter();  
        out.print(respMessage);  
        out.close();
        
    }

}

 

      簽名驗證時咱們須要sign工具，代碼以下 

package com.ever.qthh.utils.wx;

import java.security.MessageDigest;
import java.security.NoSuchAlgorithmException;
import java.util.Arrays;

public class SignUtil {
    
    private static String token = "qthh";
    
    /** 
     * 驗證簽名 
     *  
     * @param signature 
     * @param timestamp 
     * @param nonce 
     * @return 
     */  
    public static boolean checkSignature(String signature, String timestamp, String nonce) {  
        String[] arr = new String[] { token, timestamp, nonce };  
        // 將token、timestamp、nonce三個參數進行字典序排序  
        Arrays.sort(arr);  
        StringBuilder content = new StringBuilder();  
        for (int i = 0; i < arr.length; i++) {  
            content.append(arr[i]);  
        }  
        MessageDigest md = null;  
        String tmpStr = null;  
  
        try {  
            md = MessageDigest.getInstance("SHA-1");  
            // 將三個參數字符串拼接成一個字符串進行sha1加密  
            byte[] digest = md.digest(content.toString().getBytes());  
            tmpStr = byteToStr(digest);  
        } catch (NoSuchAlgorithmException e) {  
            e.printStackTrace();  
        }  
  
        content = null;  
        // 將sha1加密後的字符串可與signature對比，標識該請求來源於微信  
        return tmpStr != null ? tmpStr.equals(signature.toUpperCase()) : false;  
    } 
    
    /** 
     * 將字節數組轉換爲十六進制字符串 
     *  
     * @param byteArray 
     * @return 
     */  
    private static String byteToStr(byte[] byteArray) {  
        String strDigest = "";  
        for (int i = 0; i < byteArray.length; i++) {  
            strDigest += byteToHexStr(byteArray[i]);  
        }  
        return strDigest;  
    }
    
    
    /** 
     * 將字節轉換爲十六進制字符串 
     *  
     * @param mByte 
     * @return 
     */  
    private static String byteToHexStr(byte mByte) {  
        char[] Digit = { '0', '1', '2', '3', '4', '5', '6', '7', '8', '9', 'A', 'B', 'C', 'D', 'E', 'F' };  
        char[] tempArr = new char[2];  
        tempArr[0] = Digit[(mByte >>> 4) & 0X0F];  
        tempArr[1] = Digit[mByte & 0X0F];  
  
        String s = new String(tempArr);  
        return s;  
    }  

}

 

三.消息工具封裝、消息處理

    微信收、發消息都用的xml格式進行傳輸的，爲了在程序中方便操做，咱們將須要處理的消息封裝成對象，包括請求（微信發個咱們的）和響應（咱們發給微信的）兩部分：

    1.請求部分：

package com.ever.qthh.model.message.request;

/**
 * 請求消息基類
 * @author 51452
 *
 */
public class BaseMessage {
    
    private String ToUserName;//開發者微信號
    private String FromUserName;//發送方賬號（一個OpenID
    private long CreateTime;//消息建立時間 （整型
    private String MsgType; //消息類型（text/image/location/link
    private long MsgId;// 消息id，64位整型
    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 long getMsgId() {
        return MsgId;
    }
    public void setMsgId(long msgId) {
        MsgId = msgId;
    }
    
}

package com.ever.qthh.model.message.request;

/**
 * 文本消息
 * @author 51452
 *
 */
public class TextMessage extends BaseMessage {
    
    private String Content;//消息內容

    public String getContent() {
        return Content;
    }

    public void setContent(String content) {
        Content = content;
    }

}

package com.ever.qthh.model.message.request;

/**
 * 圖片消息
 * @author 51452
 *
 */
public class ImageMessage extends BaseMessage {
    
    private String PicUrl;//圖片連接

    public String getPicUrl() {
        return PicUrl;
    }

    public void setPicUrl(String picUrl) {
        PicUrl = picUrl;
    }

}

package com.ever.qthh.model.message.request;

/**
 * 連接消息
 * @author 51452
 *
 */
public class LinkMessage extends BaseMessage {
    
    private String Title;//消息標題
    private String Description;//消息描述
    private String Url;//消息連接
    
    public String getTitle() {
        return Title;
    }
    public void setTitle(String title) {
        Title = title;
    }
    public String getDescription() {
        return Description;
    }
    public void setDescription(String description) {
        Description = description;
    }
    public String getUrl() {
        return Url;
    }
    public void setUrl(String url) {
        Url = url;
    }

}

package com.ever.qthh.model.message.request;

/**
 * 語音消息
 * @author 51452
 *
 */
public class VoiceMessage extends BaseMessage {
    
    private String MediaId;//媒體ID
    private String Format;//語音格式
    
    public String getMediaId() {
        return MediaId;
    }
    public void setMediaId(String mediaId) {
        MediaId = mediaId;
    }
    public String getFormat() {
        return Format;
    }
    public void setFormat(String format) {
        Format = format;
    }

}

package com.ever.qthh.model.message.request;

/**
 * 地理位置消息
 * @author 51452
 *
 */
public class LocationMessage extends BaseMessage {
    
    private String Location_X;//地理位置維度
    private String Location_Y;//地理位置經度
    private String Scale;//地圖縮放大小
    private String Label;//地理位置信息
    
    public String getLocation_X() {
        return Location_X;
    }
    public void setLocation_X(String location_X) {
        Location_X = location_X;
    }
    public String getLocation_Y() {
        return Location_Y;
    }
    public void setLocation_Y(String location_Y) {
        Location_Y = location_Y;
    }
    public String getScale() {
        return Scale;
    }
    public void setScale(String scale) {
        Scale = scale;
    }
    public String getLabel() {
        return Label;
    }
    public void setLabel(String label) {
        Label = label;
    }

}

    2.響應部分
    

package com.ever.qthh.model.message.response;

/**
 * 響應消息基類
 * @author 51452
 *
 */
public class BaseMessage {
    
    private String ToUserName;//接收方賬號（收到的OpenID）
    private String FromUserName;//開發者微信號
    private long CreateTime;//消息建立時間 （整型）
    private String MsgType;//消息類型（text/music/news）
    private int FuncFlag;//位0x0001被標誌時，星標剛收到的消息
    
    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;
    }

}

package com.ever.qthh.model.message.response;

/**
 * 響應消息基類
 * @author 51452
 *
 */
public class BaseMessage {
    
    private String ToUserName;//接收方賬號（收到的OpenID）
    private String FromUserName;//開發者微信號
    private long CreateTime;//消息建立時間 （整型）
    private String MsgType;//消息類型（text/music/news）
    private int FuncFlag;//位0x0001被標誌時，星標剛收到的消息
    
    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;
    }

}

package com.ever.qthh.model.message.response;

/**
 * 響應消息基類
 * @author 51452
 *
 */
public class BaseMessage {
    
    private String ToUserName;//接收方賬號（收到的OpenID）
    private String FromUserName;//開發者微信號
    private long CreateTime;//消息建立時間 （整型）
    private String MsgType;//消息類型（text/music/news）
    private int FuncFlag;//位0x0001被標誌時，星標剛收到的消息
    
    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;
    }

}

package com.ever.qthh.model.message.response;

/**
 * 圖文
 * @author 51452
 *
 */
public class Article {    
    
    private String Title;//圖文消息名稱
    private String Description;//圖文消息描述
    private String PicUrl;//圖片連接，支持JPG、PNG格式，較好的效果爲大圖640*320，小圖80*80，限制圖片連接的域名須要與開發者填寫的基本資料中的Url一致
    private String Url;//點擊圖文消息跳轉連接
    
    public String getTitle() {
        return Title;
    }
    public void setTitle(String title) {
        Title = title;
    }
    public String getDescription() {
        return Description;
    }
    public void setDescription(String description) {
        Description = description;
    }
    public String getPicUrl() {
        return PicUrl;
    }
    public void setPicUrl(String picUrl) {
        PicUrl = picUrl;
    }
    public String getUrl() {
        return Url;
    }
    public void setUrl(String url) {
        Url = url;
    }
     
}

package com.ever.qthh.model.message.response;

/**
 * 音樂消息
 * @author 51452
 *
 */
public class MusicMessage extends BaseMessage {
    
    private Music Music;//音樂

    public Music getMusic() {
        return Music;
    }

    public void setMusic(Music music) {
        Music = music;
    }

}

package com.ever.qthh.model.message.response;

/**
 * 音樂
 * @author 51452
 *
 */
public class Music {
    
    private String Title;//音樂名稱
    private String Description;//音樂描述
    private String MusicUrl;//音樂連接 
    private String HQMusicUrl;//高質量音樂連接，WIFI環境優先使用該連接播放音樂
    
    public String getTitle() {
        return Title;
    }
    public void setTitle(String title) {
        Title = title;
    }
    public String getDescription() {
        return Description;
    }
    public void setDescription(String description) {
        Description = description;
    }
    public String getMusicUrl() {
        return MusicUrl;
    }
    public void setMusicUrl(String musicUrl) {
        MusicUrl = musicUrl;
    }
    public String getHQMusicUrl() {
        return HQMusicUrl;
    }
    public void setHQMusicUrl(String hQMusicUrl) {
        HQMusicUrl = hQMusicUrl;
    }
    
}

      經常使用的消息對象咱們封裝好了，接下來咱們須要使用dom4j和xstream這個兩個工具包對數據進行經常使用的處理：
      解析xml，將xml轉成消息對象，將消息對象轉xml，代碼以下：

    

package com.ever.qthh.utils.wx;

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

import javax.servlet.http.HttpServletRequest;

import org.dom4j.Document;
import org.dom4j.Element;
import org.dom4j.io.SAXReader;

import com.ever.qthh.model.message.response.Article;
import com.ever.qthh.model.message.response.MusicMessage;
import com.ever.qthh.model.message.response.NewsMessage;
import com.ever.qthh.model.message.response.TextMessage;
import com.thoughtworks.xstream.XStream;
import com.thoughtworks.xstream.core.util.QuickWriter;
import com.thoughtworks.xstream.io.HierarchicalStreamWriter;
import com.thoughtworks.xstream.io.xml.PrettyPrintWriter;
import com.thoughtworks.xstream.io.xml.XppDriver;


/**
 * 微信消息處理工具
 * @author 51452
 *
 */
public class MessageUtil {
    
    public static final String RESP_MESSAGE_TYPE_TEXT = "text";//返回消息類型：文本 
    
    public static final String RESP_MESSAGE_TYPE_MUSIC = "music";//返回消息類型：音樂 
    
    public static final String RESP_MESSAGE_TYPE_NEWS = "news";//返回消息類型：圖文 
    
    public static final String REQ_MESSAGE_TYPE_TEXT = "text";//請求消息類型：文本
   
    public static final String REQ_MESSAGE_TYPE_IMAGE = "image";//請求消息類型：圖片
    
    public static final String REQ_MESSAGE_TYPE_LINK = "link"; //請求消息類型：連接 
    
    public static final String REQ_MESSAGE_TYPE_LOCATION = "location";//請求消息類型：地理位置 
   
    public static final String REQ_MESSAGE_TYPE_VOICE = "voice";//請求消息類型：音頻
    
    public static final String REQ_MESSAGE_TYPE_EVENT = "event";//請求消息類型：推送   
  
    public static final String EVENT_TYPE_SUBSCRIBE = "subscribe";//事件類型：subscribe(訂閱)  
     
    public static final String EVENT_TYPE_UNSUBSCRIBE = "unsubscribe";//事件類型：unsubscribe(取消訂閱)  
    
    public static final String EVENT_TYPE_CLICK = "CLICK";//事件類型：CLICK(自定義菜單點擊事件) 
     
    
    /** 
     * 解析微信發來的請求（XML） 
     *  
     * @param request 
     * @return 
     * @throws Exception 
     */  
    @SuppressWarnings("unchecked")  
    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;  
    }  
    
    
    /** 
     * 文本消息對象轉換成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塊 
     *  
     * @date 2013-05-19 
     */  
    private static XStream xstream = new XStream(new XppDriver() {  
        public HierarchicalStreamWriter createWriter(Writer out) {  
            return new PrettyPrintWriter(out) {  
                // 對全部xml節點的轉換都增長CDATA標記  
                boolean cdata = true;  
       
                @SuppressWarnings("rawtypes")
                public void startNode(String name, Class clazz) {  
                    super.startNode(name, clazz);  
                }  
      
                protected void writeText(QuickWriter writer, String text) {  
                    if (cdata) {  
                        writer.write("<![CDATA[");  
                        writer.write(text);  
                        writer.write("]]>");  
                    } else {  
                        writer.write(text);  
                    }  
                }  
            };  
        }  
    });  

}

 

下面就是GatewayService類的編寫

package com.ever.qthh.service;

import java.util.Date;
import java.util.Map;

import javax.servlet.http.HttpServletRequest;

import com.ever.qthh.model.message.response.TextMessage;
import com.ever.qthh.utils.wx.MessageUtil;

/**
 * 網關業務層
 * @author 51452
 *
 */
public class GatewayService {
    
    
    /** 
     * 處理微信發來的請求 
     *  
     * @param request 
     * @return 
     */  
    public static String processRequest(HttpServletRequest request) {  
        String respMessage = null;  
        try {  
            // 默認返回的文本消息內容  
            String respContent = "請求處理異常，請稍候嘗試！";  
  
            // xml請求解析  
            Map<String, String> requestMap = MessageUtil.parseXml(request);  
  
            // 發送方賬號（open_id）  
            String fromUserName = requestMap.get("FromUserName");  
            // 公衆賬號  
            String toUserName = requestMap.get("ToUserName");  
            // 消息類型  
            String msgType = requestMap.get("MsgType");  
  
            // 回覆文本消息  
            TextMessage textMessage = new TextMessage();  
            textMessage.setToUserName(fromUserName);  
            textMessage.setFromUserName(toUserName);  
            textMessage.setCreateTime(new Date().getTime());  
            textMessage.setMsgType(MessageUtil.RESP_MESSAGE_TYPE_TEXT);  
            textMessage.setFuncFlag(0);  
  
            // 文本消息  
            if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_TEXT)) {  
                respContent = "您發送的是文本消息！";  
            }  
            // 圖片消息  
            else if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_IMAGE)) {  
                respContent = "您發送的是圖片消息！";  
            }  
            // 地理位置消息  
            else if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_LOCATION)) {  
                respContent = "您發送的是地理位置消息！";  
            }  
            // 連接消息  
            else if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_LINK)) {  
                respContent = "您發送的是連接消息！";  
            }  
            // 音頻消息  
            else if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_VOICE)) {  
                respContent = "您發送的是音頻消息！";  
            }  
            // 事件推送  
            else if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_EVENT)) {  
                // 事件類型  
                String eventType = requestMap.get("Event");  
                // 訂閱  
                if (eventType.equals(MessageUtil.EVENT_TYPE_SUBSCRIBE)) {  
                    respContent = "謝謝您的關注！";  
                }  
                // 取消訂閱  
                else if (eventType.equals(MessageUtil.EVENT_TYPE_UNSUBSCRIBE)) {  
                    // 取消訂閱後用戶再收不到公衆號發送的消息，所以不須要回復消息  
                }  
                // 自定義菜單點擊事件  
                else if (eventType.equals(MessageUtil.EVENT_TYPE_CLICK)) {  
                    //事件KEY值，與建立自定義菜單時指定的KEY值對應  
                    String eventKey = requestMap.get("EventKey");
                    respContent = "點擊菜單："+eventKey; 
                }  
            }  
  
            textMessage.setContent(respContent);  
            respMessage = MessageUtil.textMessageToXml(textMessage);  
        } catch (Exception e) {  
            e.printStackTrace();  
        }  
  
        return respMessage;  
    }  

}

　　以上，微信公衆號開發的基本框架就完成了。 

 

四。其餘

      應用完成後，須要一個服務器去部署。

      若是你沒用本身的服務器，可使用百度的BAE或者新浪的SAE。