Java微信二次開發（五）

消息加密

需要到入庫：commons-io-2.4.jar，commons-codec-1.9.jar（在官網的Java微信加密demo下）

第一步：訪問https://mp.weixin.qq.com/wiki，下載AES加密的示例代碼

 

 

第二步：新建com.wtz.aes包，把實例代碼中的8個AES加密類復制進去，將這些類的包名改為com.wtz.aes，導入庫commons-codec-1.9.jar,選上面的Project下的Properties，點擊Java Build Path,Libraries，Add Library,選Junit 4，Next,Finish,OK,AES加密導入完成

 

第三步：找到包com.wtz.util，新建類Parameter.java類，存放參數token,encodingAESKey(隨機戳),corpId(AppID)，這些在基本配置處可以得到

package com.wtz.util;

/**
 *     @author wangtianze QQ:864620012
 *    @date 2017年4月21日 下午9:27:50
 *  <p>version:1.0</p>
 *     <p>description:參數api</p>
 */
public class Parameter {
    //token
    public static String token = "wangtianze";
    //隨機戳
    public static String encodingAESKey = "X78dYU3MXpijKArRbiozTRq0jZZnjxxvuB4n8KJwRH1";
    //應用AppID
    public static String corpId = "wx9621c31e147dfdf9";
}

 

第四步：找到包com.wtz.util下的MessageUtil.java類，修改parseXml方法

package com.wtz.util;

import java.io.ByteArrayInputStream;
import java.io.IOException;
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.DocumentException;
import org.dom4j.Element;
import org.dom4j.io.SAXReader;

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;
import com.wtz.message.response.ImageMessage;
import com.wtz.message.response.MusicMessage;
import com.wtz.message.response.NewsMessage;
import com.wtz.message.response.TextMessage;
import com.wtz.message.response.VideoMessage;
import com.wtz.message.response.VoiceMessage;

/**
 *     @author wangtianze QQ:864620012
 *    @date 2017年4月19日 下午3:29:58
 *  <p>version:1.0</p>
 *     <p>description:消息處理工具類</p>
 */
public class MessageUtil {
    //請求消息類型：文本
    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_VOICE = "voice";
    //請求消息類型：視頻
    public static final String REQ_MESSAGE_TYPE_VIDEO = "video";
    //請求消息類型：地理位置
    public static final String REQ_MESSAGE_TYPE_LOCATION = "location";
    //請求消息類型：鏈接
    public static final String REQ_MESSAGE_TYPE_LINK = "link";
    //請求消息類型：事件推送
    public static final String REQ_MESSAGE_TYPE_EVENT = "event";
    
    //---------------------------------------------------------------
    
    //事件類型：subscribe(訂閱)
    public static final String EVENT_TYPE_SUBSCRIBE = "subscribe";
    //事件類型：unsubscribe(取消訂閱)
    public static final String EVENT_TYPE_UNSUBSCRIBE = "unsubscribe";
    //事件類型：scan(用戶已關注時的掃描帶參數的二維碼)
    public static final String EVENT_TYPE_SCAN = "scan";
    //事件類型：LOCATION(上報地理位置)
    public static final String EVENT_TYPE_LOCATION = "LOCATION";
    //事件類型：CLICK(自定義菜單)
    public static final String EVENT_TYPE_CLICK = "CLICK";
    
    //---------------------------------------------------------------
    
    //響應消息類型：文本
    public static final String RESP_MESSAGE_TYPE_TEXT = "text";
    //響應詳細類型：圖片
    public static final String RESP_MESSAGE_TYPE_IMAGE = "image";
    //響應消息類型：語音
    public static final String RESP_MESSAGE_TYPE_VOICE = "voice";
    //響應消息類型：視頻
    public static final String RESP_MESSAGE_TYPE_VIDEO = "video";
    //響應詳細類型：音樂
    public static final String RESP_MESSAGE_TYPE_MUSIC = "music";
    //響應消息類型：圖文
    public static final String RESP_MESSAGE_TYPE_NEWS = "news";
    
    //---------------------------------------------------------------
    
    //-----------------------------------------老的，加密前---------------------------------------------
//    //從流中解析出每個節點的內容
//    public static Map<String,String> parseXml(HttpServletRequest request) throws IOException{
//        Map<String,String> map = new HashMap<String,String>();
//        
//        //從輸入流中獲取流對象
//        InputStream in = request.getInputStream();
//        
//        //構建SAX閱讀器對象
//        SAXReader reader = new SAXReader();
//        try {
//            //從流中獲得文檔對象
//            Document doc = reader.read(in);
//            
//            //獲得根節點
//            Element root = doc.getRootElement();
//            
//            //獲取根節點下的所有子節點
//            List<Element> children = root.elements();
//            
//            for(Element e:children){
//                //遍歷每一個節點，並按照節點名--節點值放入map中
//                map.put(e.getName(), e.getText());
//                System.out.println("用戶發送的消息XML解析為：" + e.getName() + e.getText());
//            }
//            
//            //關閉流
//            in.close();
//            in = null;
//        } catch (DocumentException e) {
//            // TODO Auto-generated catch block
//            e.printStackTrace();
//        }
//        
//        return map;
//    }
    //-----------------------------------------新的，加密后--------------------------------------------
  //從流中解析出每個節點的內容
    public static Map<String,String> parseXml(String request) throws IOException{
        Map<String,String> map = new HashMap<String,String>();
        
        //從request中獲取流對象
        InputStream in = new ByteArrayInputStream(request.getBytes("UTF-8"));
        
        //構建SAX閱讀器對象
        SAXReader reader = new SAXReader();
        try {
            //從流中獲得文檔對象
            Document doc = reader.read(in);
            
            //獲得根節點
            Element root = doc.getRootElement();
            
            //獲取根節點下的所有子節點
            List<Element> children = root.elements();
            
            for(Element e:children){
                //遍歷每一個節點，並按照節點名--節點值放入map中
                map.put(e.getName(), e.getText());
                System.out.println("用戶發送的消息XML解析為：" + e.getName() + e.getText());
            }
            
            //關閉流
            in.close();
            in = null;
        } catch (DocumentException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        
        return map;
    }
    //----------------------------------------------------------------------------------------------
    
    /**
     * 用於擴展節點數據按照<ToUserName><![CDATA[toUser]]></ToUserName>，中間加了CDATA段
     */
    private static XStream xstream = new XStream(new XppDriver(){
        public HierarchicalStreamWriter createWriter(Writer out){
            return new PrettyPrintWriter(out){
                boolean cdata = true;
                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);
                    }
                }
            };
        }
    });
    
    /**
     * 將文本消息對象轉換成XML格式
     * params:textMessage 文本消息對象
     * return:xml
     */
    public static String messageToXml(TextMessage textMessage){
        xstream.alias("xml",textMessage.getClass());
        return xstream.toXML(textMessage);
    }
    
    /**
     * 將圖片消息對象轉換成XML格式
     * params:imageMessage
     * return:xml
     */
    public static String messageToXml(ImageMessage imageMessage){
        xstream.alias("xml", imageMessage.getClass());
        return xstream.toXML(imageMessage);
    }
    
    /**
     * 將語音消息對象轉換成XML格式
     * params:voiceMessage
     * return:xml
     */
    public static String messageToXml(VoiceMessage voiceMessage){
        xstream.alias("xml",voiceMessage.getClass());
        return xstream.toXML(voiceMessage);
    }
    
    /**
     * 將視頻消息對象轉換成XML格式
     * params:videoMessage
     * return:xml
     */
    public static String messageToXml(VideoMessage videoMessage){
        xstream.alias("xml",videoMessage.getClass());
        return xstream.toXML(videoMessage);
    }
    
    /**
     * 將音樂消息對象轉換成XML格式
     * params:musicMessage
     * return:xml
     */
    public static String messageToXml(MusicMessage musicMessage){
        xstream.alias("xml",musicMessage.getClass());
        return xstream.toXML(musicMessage);
    }
    
    /**
     * 將圖文消息對象轉換成XML格式
     * params:newsMessage
     * return:xml
     */
    public static String messageToXml(NewsMessage newsMessage){
        xstream.alias("xml",newsMessage.getClass());
        return xstream.toXML(newsMessage);
    }
}

 

第五步：找到包com.wtz.util下的ProcessService.java類，修改dealRequest方法

package com.wtz.util;

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

import javax.servlet.http.HttpServletRequest;

import com.wtz.dao.PostCodeDao;
import com.wtz.message.response.TextMessage;

/**
 *     @author wangtianze QQ:864620012
 *    @date 2017年4月19日 下午8:04:14
 *  <p>version:1.0</p>
 *     <p>description:核心服務類</p>
 */
public class ProcessService {
    //定義數據訪問的dao
    private static PostCodeDao dao = new PostCodeDao();
    
    //-----------------------------------老的，加密前--------------------------------------------------
//    public static String dealRequest(HttpServletRequest request){
//        //XML格式的消息數據
//        String respXml = "";
//        //默認返回的文本消息內容
//        String respContent = "未知的消息類型";
//        //調用parseXml方法解析請求消息
//        Map<String, String> requestMap;
//        try {
//            requestMap = MessageUtil.parseXml(request);
//            //發送方賬號
//            String fromUserName = requestMap.get("FromUserName");
//            //開發者微信號
//            String toUserName = requestMap.get("ToUserName");
//            //消息類型
//            String MsgType = requestMap.get("MsgType");
//            //消息內容
//            String content = requestMap.get("Content");
//            
//            //回復文本消息
//            TextMessage textMessage = new TextMessage();
//            textMessage.setToUserName(fromUserName);
//            textMessage.setFromUserName(toUserName);
//            textMessage.setCreateTime(new Date().getTime());
//            textMessage.setMsgType(MessageUtil.RESP_MESSAGE_TYPE_TEXT);
//            
//            if(MsgType.equals(MessageUtil.REQ_MESSAGE_TYPE_TEXT)){
//                respContent = "感謝您關注【王天澤的服務號】\n" + "微信號:wangtianze1\n" + "請回復序號:\n" + "1.查郵政編碼\n" + "2.查電話區號\n" + "?.返回幫助菜單\n";
//                if(content.equals("1")){
//                    respContent = "請按照格式輸入地區名，例如輸入 郵編:東城";
//                }
//                if(content.equals("2")){
//                    respContent = "請按照格式輸入地區名，例如輸入 區號:東城";
//                }
//                if(content.equals("?")){
//                    respContent = "感謝您關注【王天澤的服務號】\n" + "微信號:wangtianze1\n" + "請回復序號:\n" + "1.查郵政編碼\n" + "2.查電話區號\n" + "?.返回幫助菜單\n";
//                }
//                if(content.startsWith("郵編:")){
//                    int pos = content.indexOf(":");
//                    String cityName = content.substring(pos + 1);
//                    respContent = dao.findPostCodeByCityName(cityName);
//                    System.out.println("郵編:respContent:" + respContent);
//                }
//                if(content.startsWith("區號:")){
//                    int pos = content.indexOf(":");
//                    String cityName = content.substring(pos + 1);
//                    respContent = dao.findTelCodeByCityName(cityName);
//                    System.out.println("區號:respContent:" + respContent);
//                }
//            }else if(MsgType.equals(MessageUtil.REQ_MESSAGE_TYPE_IMAGE)){
//                respContent = "您發送的是圖片消息";
//            }else if(MsgType.equals(MessageUtil.REQ_MESSAGE_TYPE_VOICE)){
//                respContent = "您發送的是語音消息";
//            }else if(MsgType.equals(MessageUtil.REQ_MESSAGE_TYPE_VIDEO)){
//                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_EVENT)){
//                //事件類型
//                String eventType = requestMap.get("Event");
//                if(eventType.equals(MessageUtil.EVENT_TYPE_SUBSCRIBE)){
//                    respContent = "感謝您關注【王天澤的服務號】\n" + "微信號:wangtianze1\n" + "請回復序號:\n" + "1.查郵政編碼\n" + "2.查電話區號\n" + "?.返回幫助菜單\n";
//                }else if(eventType.equals(MessageUtil.EVENT_TYPE_UNSUBSCRIBE)){
//                    //TODO 取消訂閱后用戶不會再收到公眾號發送的消息，因此不需要回復
//                }else if(eventType.equals(MessageUtil.EVENT_TYPE_SCAN)){
//                    //TODO 處理掃描帶參數二維碼事件
//                }else if(eventType.equals(MessageUtil.EVENT_TYPE_LOCATION)){
//                    //TODO 處理上報地理位置事件
//                }else if(eventType.equals(MessageUtil.EVENT_TYPE_CLICK)){
//                    //TODO 處理菜單點擊事件
//                }
//            }
//            //設置文本消息的內容
//            textMessage.setContent(respContent);
//            //將文本消息對象轉換成xml
//            respXml = MessageUtil.messageToXml(textMessage);
//        } catch (IOException e) {
//            // TODO Auto-generated catch block
//            e.printStackTrace();
//        }
//        
//        return respXml;
//    }
    
    //----------------------------------------------新的，加密后---------------------------------------------
    public static String dealRequest(String request){
        //XML格式的消息數據
        String respXml = "";
        //默認返回的文本消息內容
        String respContent = "未知的消息類型";
        //調用parseXml方法解析請求消息
        Map<String, String> requestMap;
        try {
            requestMap = MessageUtil.parseXml(request);
            //發送方賬號
            String fromUserName = requestMap.get("FromUserName");
            //開發者微信號
            String toUserName = requestMap.get("ToUserName");
            //消息類型
            String MsgType = requestMap.get("MsgType");
            //消息內容
            String content = requestMap.get("Content");
            
            //回復文本消息
            TextMessage textMessage = new TextMessage();
            textMessage.setToUserName(fromUserName);
            textMessage.setFromUserName(toUserName);
            textMessage.setCreateTime(new Date().getTime());
            textMessage.setMsgType(MessageUtil.RESP_MESSAGE_TYPE_TEXT);
            
            if(MsgType.equals(MessageUtil.REQ_MESSAGE_TYPE_TEXT)){
                respContent = "感謝您關注【王天澤的服務號】\n" + "微信號:wangtianze1\n" + "請回復序號:\n" + "1.查郵政編碼\n" + "2.查電話區號\n" + "?.返回幫助菜單\n";
                if(content.equals("1")){
                    respContent = "請按照格式輸入地區名，例如輸入 郵編:東城";
                }
                if(content.equals("2")){
                    respContent = "請按照格式輸入地區名，例如輸入 區號:東城";
                }
                if(content.equals("?")){
                    respContent = "感謝您關注【王天澤的服務號】\n" + "微信號:wangtianze1\n" + "請回復序號:\n" + "1.查郵政編碼\n" + "2.查電話區號\n" + "?.返回幫助菜單\n";
                }
                if(content.startsWith("郵編:")){
                    int pos = content.indexOf(":");
                    String cityName = content.substring(pos + 1);
                    respContent = dao.findPostCodeByCityName(cityName);
                    System.out.println("郵編:respContent:" + respContent);
                }
                if(content.startsWith("區號:")){
                    int pos = content.indexOf(":");
                    String cityName = content.substring(pos + 1);
                    respContent = dao.findTelCodeByCityName(cityName);
                    System.out.println("區號:respContent:" + respContent);
                }
            }else if(MsgType.equals(MessageUtil.REQ_MESSAGE_TYPE_IMAGE)){
                respContent = "您發送的是圖片消息";
            }else if(MsgType.equals(MessageUtil.REQ_MESSAGE_TYPE_VOICE)){
                respContent = "您發送的是語音消息";
            }else if(MsgType.equals(MessageUtil.REQ_MESSAGE_TYPE_VIDEO)){
                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_EVENT)){
                //事件類型
                String eventType = requestMap.get("Event");
                if(eventType.equals(MessageUtil.EVENT_TYPE_SUBSCRIBE)){
                    respContent = "感謝您關注【王天澤的服務號】\n" + "微信號:wangtianze1\n" + "請回復序號:\n" + "1.查郵政編碼\n" + "2.查電話區號\n" + "?.返回幫助菜單\n";
                }else if(eventType.equals(MessageUtil.EVENT_TYPE_UNSUBSCRIBE)){
                    //TODO 取消訂閱后用戶不會再收到公眾號發送的消息，因此不需要回復
                }else if(eventType.equals(MessageUtil.EVENT_TYPE_SCAN)){
                    //TODO 處理掃描帶參數二維碼事件
                }else if(eventType.equals(MessageUtil.EVENT_TYPE_LOCATION)){
                    //TODO 處理上報地理位置事件
                }else if(eventType.equals(MessageUtil.EVENT_TYPE_CLICK)){
                    //TODO 處理菜單點擊事件
                }
            }
            //設置文本消息的內容
            textMessage.setContent(respContent);
            //將文本消息對象轉換成xml
            respXml = MessageUtil.messageToXml(textMessage);
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        
        return respXml;
    }
}

 

第六步：找到包com.wtz.service，修改LoginServlet.java類，修改doPost方法

package com.wtz.service;

import java.io.IOException;
import java.io.InputStream;
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.apache.commons.io.IOUtils;

import com.wtz.aes.AesException;
import com.wtz.aes.WXBizMsgCrypt;
import com.wtz.util.MessageUtil;
import com.wtz.util.Parameter;
import com.wtz.util.ProcessService;
import com.wtz.util.ValidationUtil;

/**
 *     @author wangtianze QQ:864620012
 *    @date 2017年4月17日 下午8:11:32
 *  <p>version:1.0</p>
 *     <p>description:微信請求驗證類</p>
 */
public class LoginServlet extends HttpServlet {

    @Override
    protected void doGet(HttpServletRequest request, HttpServletResponse response)
            throws ServletException, IOException {
        System.out.println("get請求。。。。。。");
        
        //1.獲得微信簽名的加密字符串
        String signature = request.getParameter("signature");
        
        //2.獲得時間戳信息
        String timestamp = request.getParameter("timestamp");
         
        //3.獲得隨機數
        String nonce = request.getParameter("nonce");
        
        //4.獲得隨機字符串
        String echostr = request.getParameter("echostr");
        
        System.out.println("獲得微信簽名的加密字符串："+signature);
        System.out.println("獲得時間戳信息："+timestamp);
        System.out.println("獲得隨機數："+nonce);
        System.out.println("獲得隨機字符串："+echostr);
        
        PrintWriter out = response.getWriter();
        
        //驗證請求確認成功原樣返回echostr參數內容，則接入生效，成為開發者成功，否則失敗
        if(ValidationUtil.checkSignature(signature, timestamp, nonce)){
            out.print(echostr);
        }
        
        out.close();
        out = null;
    }

    /**
     * 接受微信服務器發過來的XML數據包（通過post請求發送過來的）
     */
    @Override
    protected void doPost(HttpServletRequest request, HttpServletResponse response)
            throws ServletException, IOException {
        //將請求響應的編碼均設置為UTF-8，防止中文亂碼
        request.setCharacterEncoding("UTF-8");
        response.setCharacterEncoding("UTF-8");
        
        //------------------------老的,不加密----------------------------
//        //獲取微信加密的簽名字符串
//        String signature = request.getParameter("signature");
//        
//        //獲取時間戳
//        String timestamp = request.getParameter("timestamp");
//        
//        //獲取隨機數
//        String nonce = request.getParameter("nonce");
//        
//        PrintWriter out = response.getWriter();
//        
//        if(ValidationUtil.checkSignature(signature,timestamp,nonce)){
//            String respXml = "";
//            try {
//                respXml = ProcessService.dealRequest(request);
//            } catch (Exception e) {
//                // TODO Auto-generated catch block
//                e.printStackTrace();
//            }
//            out.print(respXml);
//        }
//        out.close();
//        out = null;
        //---------------------------新的,加密---------------------------
        //獲取微信加密的簽名字符串
        String signature = request.getParameter("msg_signature");
        
        //獲取時間戳
        String timestamp = request.getParameter("timestamp");
        
        //獲取隨機數
        String nonce = request.getParameter("nonce");
        
        //從請求中讀取整個post數據
        InputStream inputStream = request.getInputStream();
        
        //commons.io.jar方法，直接將流轉成字符串
        String Post = IOUtils.toString(inputStream,"UTF-8");
        
        System.out.println("Post:" + Post);
        
        String Msg = "";
        WXBizMsgCrypt wxcpt = null;
        try {
            wxcpt = new WXBizMsgCrypt(Parameter.token,Parameter.encodingAESKey,Parameter.corpId);
            //解密消息
            Msg = wxcpt.decryptMsg(signature,timestamp,nonce,Post);
        } catch (AesException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        //Msg打印結果
        System.out.println("Msg打印結果:" + Msg);
        
        //調用核心業務類接收消息，處理消息
        String respMessage = ProcessService.dealRequest(Msg);
        
        //respMessage打印結果
        System.out.println("respMessage打印結果：" + respMessage);
        
        String encryptMsg = "";
        try {
            //加密回復消息
            encryptMsg = wxcpt.encryptMsg(respMessage, timestamp, nonce);
            System.out.println("encryptMsg:" + encryptMsg);
        } catch (AesException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        
        //響應消息
        PrintWriter out = response.getWriter();
        out.print(encryptMsg);
        out.close();
    }
}

消息加密完成。