Java企业微信开发_05_消息推送之被动回复消息

一、本节要点

1.消息的加解密

微信加解密包 下载地址：http://qydev.weixin.qq.com/java.zip      ，此包中封装好了AES加解密方法，直接调用方法即可。

其中，解密方法为：

            //2.获取消息明文：对加密的请求消息进行解密获得明文  
            WXBizMsgCrypt wxcpt=new WXBizMsgCrypt(WeiXinParamesUtil.token,WeiXinParamesUtil.encodingAESKey,WeiXinParamesUtil.corpId);
            result = wxcpt.DecryptMsg(msg_signature, timestamp, nonce, postData);

加密方法为:

            //6.加密
            WXBizMsgCrypt wxcpt=new WXBizMsgCrypt(WeiXinParamesUtil.token,WeiXinParamesUtil.encodingAESKey,WeiXinParamesUtil.corpId);
            respMessage = wxcpt.EncryptMsg(respMessage, timestamp, msgType);
            

2.被动回复消息的流程

用户发送消息之后，微信服务器将消息传递给 第三方服务器，第三方服务器接收到消息后，再对消息做出相应的回复消息。

接收消息：需先从request请求对象的输入流中获取请求参数和已加密的请求消息，再对已加密的请求消息进行解密操作，即可获得明文。

                  然后就行对明文消息的业务处理了。

回复消息：封装好回复消息后，需先对回复消息进行加密，获得已已加密消息，然后再通过http请求调用被动回复消息的接口，来发送消息。

二、接收消息服务器配置

见  Java企业微信开发_02_接收消息服务器配置

接受消息服务器配置好后，用户发送消息时，微信服务器会将消息转发到配置的接受消息服务器url上，即以POST方式转发到 CoreServlet 上。

三、接收消息实体类的封装(req)

参见官方文档的说明

3.1 消息基类——BaseMessage

package com.ray.pojo.message.req;  
  
/**
 * 消息基类（普通用户 -> 企业微信） 
 * @author shirayner
 *
 */
public class BaseMessage {  
    // 开发者微信号  
    private String ToUserName;  
    // 发送方帐号（一个OpenID）  
    private String FromUserName;  
    // 消息创建时间 （整型）  
    private long CreateTime;  
    // 消息类型（text/image/location/link）  
    private String MsgType;  
    // 消息id，64位整型  
    private long MsgId;  
    //企业应用的id，整型。可在应用的设置页面查看
    private int AgentID;
  
    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;  
    }

    public int getAgentID() {
        return AgentID;
    }

    public void setAgentID(int agentID) {
        AgentID = agentID;
    }

    
    
}  

3.2 文本消息——TextMessage

package com.ray.pojo.message.req;  
  
/**
 * 文本消息
 * @author shirayner
 *
 */
public class TextMessage extends BaseMessage {  
    // 消息内容  
    private String Content;  
  
    public String getContent() {  
        return Content;  
    }  
  
    public void setContent(String content) {  
        Content = content;  
    }  
}  

3.3图片消息——ImageMessage

package com.ray.pojo.message.req;  

/**
 *  图片消息 
 * @author shirayner
 *
 */
public class ImageMessage extends BaseMessage {  
    // 图片链接  
    private String PicUrl;  
    // 图片媒体文件id，可以调用获取媒体文件接口拉取
    private String MediaId;  

    public String getPicUrl() {  
        return PicUrl;  
    }  

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

    public String getMediaId() {
        return MediaId;
    }

    public void setMediaId(String mediaId) {
        MediaId = mediaId;
    }  

}  

3.4 语音消息——VoiceMessage

package com.ray.pojo.message.req;  
  
/**
 * 语音消息 
 * @author shirayner
 *
 */
public class VoiceMessage extends BaseMessage {  
    // 语音媒体文件id，可以调用获取媒体文件接口拉取数据 
    private String MediaId;  
    // 语音格式，如amr，speex等
    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;  
    }  
}  

3.5 视频消息——Video、VideoMessage

Video.java

package com.ray.pojo.message.resp;

/**
 * @desc  : 视频
 * 
 * @author: shirayner
 * @date  : 2017-8-17 下午2:00:22
 */
public class Video {

    //视频文件id，可以调用获取媒体文件接口拉取
    private String MediaId;
    //视频消息的标题
    private String Title;
    //视频消息的描述
    private String Description;
    public String getMediaId() {
        return MediaId;
    }
    public void setMediaId(String mediaId) {
        MediaId = mediaId;
    }
    public String getTitle() {
        return Title;
    }
    public void setTitle(String title) {
        Title = title;
    }
    public String getDescription() {
        return Description;
    }
    public void setDescription(String description) {
        Description = description;
    }
   
    
}

VideoMessage.java

package com.ray.pojo.message.resp;

/**
 * @desc  : 视频消息
 * 
 * @author: shirayner
 * @date  : 2017-8-21 上午10:36:33
 */
public class VideoMessage extends BaseMessage {
    // 视频
    private Video Video;

    public Video getVideo() {
        return Video;
    }

    public void setVideo(Video video) {
        Video = video;
    }
}

3.6 位置消息——LocationMessage

package com.ray.pojo.message.req;  
  
/**
 * 位置消息 
 * @author shirayner
 *
 */
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;  
    }  
}  

3.7 链接消息——LinkMessage

package com.ray.pojo.message.req;  

/**
 * 链接消息 
 * @author shirayner
 *
 */
public class LinkMessage extends BaseMessage {  
    // 消息标题  
    private String Title;  
    // 消息描述  
    private String Description;  
    // 封面缩略图的url
    private String PicUrl;  

    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;
    }  


}  

四、被动回复消息的封装（resp）

4.1 消息基类——BaseMessage

package com.ray.pojo.message.resp;

/**
 * 消息基类（企业微信 -> 普通用户）
 * @author shirayner
 *
 */
public class BaseMessage {
    // 成员UserID
    private String ToUserName;
    // 企业微信CorpID
    private String FromUserName;
    // 消息创建时间 （整型）
    private long CreateTime;
    // 消息类型
    private String MsgType;

    
    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;
    }
}

4.2 文本消息——TextMessage

package com.ray.pojo.message.resp;

/**
 * 文本消息
 * @author shirayner
 *
 */
public class TextMessage extends BaseMessage {
    // 回复的消息内容
    private String Content;

    public String getContent() {
        return Content;
    }

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

4.3 图片类、语音类——Media

package com.ray.pojo.message.resp;

/**
 * @desc  : 图片、语音
 * 
 * @author: shirayner
 * @date  : 2017-8-17 下午1:52:19
 */
public class Media {
    
    private String MediaId;

    public String getMediaId() {
        return MediaId;
    }

    public void setMediaId(String mediaId) {
        MediaId = mediaId;
    }
}

4.3.1 图片消息——ImageMessage

package com.ray.pojo.message.resp;

/**
 * @desc  : 图片消息
 * 
 * @author: shirayner
 * @date  : 2017-8-17 下午1:53:28
 */
public class ImageMessage extends BaseMessage {
    
    private Media Image;

    public Media getImage() {
        return Image;
    }

    public void setImage(Media image) {
        Image = image;
    }
}

4.3.2 语音消息——VoiceMessage

package com.ray.pojo.message.resp;

/**
 * @desc  : 语音消息
 * 
 * @author: shirayner
 * @date  : 2017-8-17 下午1:57:42
 */
public class VoiceMessage extends BaseMessage {
    // 语音
    private Media Voice;

    public Media getVoice() {
        return Voice;
    }

    public void setVoice(Media voice) {
        Voice = voice;
    }

   
}

4.4 视频消息——VoiceMessage

package com.ray.pojo.message.resp;

/**
 * @desc  : 语音消息
 * 
 * @author: shirayner
 * @date  : 2017-8-17 下午1:57:42
 */
public class VoiceMessage extends BaseMessage {
    // 语音
    private Media Voice;

    public Media getVoice() {
        return Voice;
    }

    public void setVoice(Media voice) {
        Voice = voice;
    }

   
}

4.5 图文消息——Article、NewsMessage

Article.java

package com.ray.pojo.message.resp;

/**
 * @desc  : 图文
 * 
 * @author: shirayner
 * @date  : 2017-8-17 下午2:02:33
 */
public class Article {
    // 图文消息名称
    private String Title;
    // 图文消息描述
    private String Description;
    // 图片链接，支持JPG、PNG格式，较好的效果为大图640*320，小图80*80
    private String PicUrl;
    // 点击图文消息跳转链接
    private String Url;

    public String getTitle() {
        return Title;
    }

    public void setTitle(String title) {
        Title = title;
    }

    public String getDescription() {
        return null == Description ? "" : Description;
    }

    public void setDescription(String description) {
        Description = description;
    }

    public String getPicUrl() {
        return null == PicUrl ? "" : PicUrl;
    }

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

    public String getUrl() {
        return null == Url ? "" : Url;
    }

    public void setUrl(String url) {
        Url = url;
    }
}

NewsMessage.java

package com.ray.pojo.message.resp;

import java.util.List;

/**
 * @desc  : 图文消息
 * 
 * @author: shirayner
 * @date  : 2017-8-17 下午2:03:31
 */
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;
    }
}

五、消息工具类——MessageUtil

package com.ray.util;  
  
import java.io.InputStream;  
import java.io.Writer;  
import java.util.HashMap;  
import java.util.List;  
import java.util.Map;  
  
  
import org.dom4j.Document;  
import org.dom4j.DocumentHelper;
import org.dom4j.Element;  
import org.dom4j.io.SAXReader;  

import com.ray.pojo.message.resp.Article;
import com.ray.pojo.message.resp.NewsMessage;
import com.ray.pojo.message.resp.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 shirayner
 *
 */
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";  
    
    //事件类型：subscribe(订阅) 
    public static final String EVENT_TYPE_SUBSCRIBE = "subscribe";  
    //事件类型：unsubscribe(取消订阅) 
    public static final String EVENT_TYPE_UNSUBSCRIBE = "unsubscribe";  
    //事件类型：CLICK(自定义菜单点击事件)  
    public static final String EVENT_TYPE_CLICK = "click";  
  
    /**
     * @desc ：1.解析微信发来的请求（XML）,获取请求参数 
     *  
     * @param request
     * @return
     * @throws Exception Map<String,String>
     */
    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;  
    } 
    
    /**
     * @desc ：2.解析微信发来的请求（xmlStr）,获取请求参数 
     *  
     * @param xmlStr
     * @return
     * @throws Exception Map<String,String>
     */
    public static Map<String, String> parseXml(String xmlStr) throws Exception {  
        // 将解析结果存储在HashMap中  
        Map<String, String> map = new HashMap<String, String>();  
  

        //1.将字符串转为Document
        Document document = DocumentHelper.parseText(xmlStr);
        
        //2.获取根元素的所有子节点
        // 得到xml根元素  
        Element root = document.getRootElement();  
        // 得到根元素的所有子节点  
        List<Element> elementList = root.elements();  
  
        //3.遍历所有子节点 
        for (Element e : elementList)  
            map.put(e.getName(), e.getText());  
        
        return map;  
    }  
  
    /** 
     * 2.文本消息对象转换成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("unchecked")  
                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);  
                    }  
                }  
            };  
        }  
    });  
}  

六、消息业务类——MessageService

package com.ray.service;

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

import javax.servlet.ServletInputStream;
import javax.servlet.http.HttpServletRequest;


import com.qq.weixin.mp.aes.AesException;
import com.qq.weixin.mp.aes.WXBizMsgCrypt;
import com.ray.pojo.message.resp.TextMessage;
import com.ray.util.MessageUtil;
import com.ray.util.WeiXinParamesUtil;

/**
 * @desc  : 被动回复消息
 * 
 * @author: shirayner
 * @date  : 2017-8-17 下午3:37:17
 */
public class MessageService {

    private String msg_signature ; // 微信加密签名  
    private String timestamp ;    // 时间戳    
    private String nonce ;       // 随机数  


    /**
     * @desc ：获取加密后的回复消息
     *  
     * @param request
     * @return String  返回加密后的回复消息
     */
    public String getEncryptRespMessage(HttpServletRequest request){
        String respMessage = null; 

        try {
            //1.解密微信发过来的消息
            String xmlMsg=this.getDecryptMsg(request);

            //2.解析微信发来的请求,解析xml字符串
            Map<String, String> requestMap= MessageUtil.parseXml(xmlMsg);    

            //3.获取请求参数
            //3.1 企业微信CorpID  
            String fromUserName = requestMap.get("FromUserName");  
            //3.2 成员UserID
            String toUserName = requestMap.get("ToUserName");  
            //3.3 消息类型与事件 
            String msgType = requestMap.get("MsgType"); 
            String eventType = requestMap.get("Event");  
            String eventKey = requestMap.get("EventKey"); 
            System.out.println("msgType:"+msgType);
            System.out.println("Event:"+eventType+"  eventKey:"+eventKey);
            

            //4.组装 回复文本消息  
            TextMessage textMessage = new TextMessage();  
            textMessage.setToUserName(fromUserName);  
            textMessage.setFromUserName(toUserName);  
            textMessage.setCreateTime(new Date().getTime());  
            textMessage.setMsgType(MessageUtil.RESP_MESSAGE_TYPE_TEXT);  
            //4.1.获取回复消息的内容 ：消息的分类处理
            String respContent=this.getRespContentByMsgType(msgType, eventType, eventKey);
            textMessage.setContent(respContent);  
            System.out.println("respContent："+respContent);

            //5.获取xml字符串： 将（被动回复消息型的）文本消息对象 转成  xml字符串
            respMessage = MessageUtil.textMessageToXml(textMessage); 
            

            //6.加密
            WXBizMsgCrypt wxcpt=new WXBizMsgCrypt(WeiXinParamesUtil.token,WeiXinParamesUtil.encodingAESKey,WeiXinParamesUtil.corpId);
            respMessage = wxcpt.EncryptMsg(respMessage, timestamp, msgType);
            

        } catch (Exception e) {
            e.printStackTrace();
        }  

        return respMessage;
    }


    /**
     * @desc ：2.从request中获取消息明文
     *  
     * @param request
     * @return String   消息明文
     */
    public String getDecryptMsg(HttpServletRequest request) {

        String postData="";   // 密文，对应POST请求的数据
        String result="";     // 明文，解密之后的结果

        this.msg_signature = request.getParameter("msg_signature"); // 微信加密签名  
        this.timestamp = request.getParameter("timestamp");   // 时间戳    
        this.nonce = request.getParameter("nonce");          // 随机数  

        try {
            //1.获取加密的请求消息：使用输入流获得加密请求消息postData
            ServletInputStream in = request.getInputStream();
            BufferedReader reader =new BufferedReader(new InputStreamReader(in));  

            String tempStr="";   //作为输出字符串的临时串，用于判断是否读取完毕  
            while(null!=(tempStr=reader.readLine())){  
                postData+=tempStr;  
            }  

            //2.获取消息明文：对加密的请求消息进行解密获得明文  
            WXBizMsgCrypt wxcpt=new WXBizMsgCrypt(WeiXinParamesUtil.token,WeiXinParamesUtil.encodingAESKey,WeiXinParamesUtil.corpId);
            result = wxcpt.DecryptMsg(msg_signature, timestamp, nonce, postData);

        } catch (IOException e) {
            e.printStackTrace();
        } catch (AesException e) {
            e.printStackTrace();
        }  

        return result;
    }

    /**
     * @desc ：3.处理消息：根据消息类型获取回复内容
     *  
     * @param msgType
     * @return String
     */
    public String getRespContentByMsgType(String msgType,String eventType,String eventKey){
        String respContent="";
        //1.文本消息  
        if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_TEXT)) {  
            respContent = "您发送的是文本消息！";  

        }  
        //2.图片消息  
        else if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_IMAGE)) {  
            respContent = "您发送的是图片消息！";  
        }  
        //3.地理位置消息  
        else if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_LOCATION)) { 
            System.out.println("消息类型：定位");
        }  
        //4.链接消息  
        else if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_LINK)) {  
            respContent = "您发送的是链接消息！";  
        }  
        //5.音频消息  
        else if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_VOICE)) {  
            respContent = "您发送的是音频消息！";  
        }
        //6.事件推送  
        else if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_EVENT)) { 
            respContent=this.processEevent(eventType, eventKey);
        }
        //7.请求异常
        else {
            respContent="请求处理异常，请稍候尝试！";
        }  

        return respContent;
    }

    public String processEevent(String eventType,String eventKey){
        
        String respContent="";
        // 订阅  
        if (eventType.equals(MessageUtil.EVENT_TYPE_SUBSCRIBE)) {  
            respContent = "欢迎关注！";  
        }  
        // 取消订阅  
        else if (eventType.equals(MessageUtil.EVENT_TYPE_UNSUBSCRIBE)) {  
            // TODO 取消订阅后用户再收不到公众号发送的消息，因此不需要回复消息  
        } 
        //上报地理位置事件
        else if(eventType.equals("LOCATION")){
            
        }
        // 自定义菜单点击事件  
        else if (eventType.equals(MessageUtil.EVENT_TYPE_CLICK)) {  

            if (eventKey.equals("12")) {  
                // TODO  help
            } else if (eventKey.equals("13")) {  
                respContent = "周边搜索菜单项被点击！";  
            } else if (eventKey.equals("14")) {  
                respContent = "历史上的今天菜单项被点击！";  
            } else if (eventKey.equals("21")) {  
                respContent = "歌曲点播菜单项被点击！";  
            } else if (eventKey.equals("22")) {  

                respContent = "经典游戏菜单项被点击！";  
            } else if (eventKey.equals("23")) {  
                respContent = "美女电台菜单项被点击！";  
            } else if (eventKey.equals("24")) {  
                respContent = "人脸识别菜单项被点击！";  
            } else if (eventKey.equals("25")) {  
                respContent = "聊天唠嗑菜单项被点击！";  
            } else if (eventKey.equals("31")) {  
                respContent = "Q友圈菜单项被点击！";  
            } else if (eventKey.equals("32")) {  
                respContent = "电影排行榜菜单项被点击！";  
            } else if (eventKey.equals("33")) {  
                respContent = "幽默笑话菜单项被点击！";  
            }  
        } 
        return respContent;
    }  
  
    
    
    
    
}

七、CoreServlet

package com.ray.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 com.qq.weixin.mp.aes.AesException;
import com.qq.weixin.mp.aes.WXBizMsgCrypt;
import com.ray.service.MessageService;
import com.ray.util.WeiXinParamesUtil;

  

  
/**
 * 核心请求处理类 
 * @author shirayner
 *
 */
public class CoreServlet extends HttpServlet {  
    private static final long serialVersionUID = 4440739483644821986L;  
  
    /** 
     * 确认请求来自微信服务器 
     */  
    public void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {      
        
            // 微信加密签名  
            String msg_signature = request.getParameter("msg_signature");  
            // 时间戳  
            String timestamp = request.getParameter("timestamp");  
            // 随机数  
            String nonce = request.getParameter("nonce");  
            // 随机字符串   
            String echostr = request.getParameter("echostr");  
      
            System.out.println("request=" + request.getRequestURL());  
      
            PrintWriter out = response.getWriter();  
            // 通过检验msg_signature对请求进行校验，若校验成功则原样返回echostr，表示接入成功，否则接入失败  
            String result = null;  
            try {
                WXBizMsgCrypt wxcpt = new WXBizMsgCrypt(WeiXinParamesUtil.token, WeiXinParamesUtil.encodingAESKey, WeiXinParamesUtil.corpId);  
                result = wxcpt.VerifyURL(msg_signature, timestamp, nonce, echostr);  
            } catch (AesException e) {  
                e.printStackTrace();  
            }  
            if (result == null) {  
                result = WeiXinParamesUtil.token;  
            }  
            out.print(result);  
            out.close();  
            out = null;  
    }  
  
    /** 
     * 处理微信服务器发来的消息 
     */  
    public void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {  
        //1.将请求、响应的编码均设置为UTF-8（防止中文乱码）  
        request.setCharacterEncoding("UTF-8");  
        response.setCharacterEncoding("UTF-8");  
        
        //2.调用消息业务类接收消息、处理消息  
        MessageService msgsv=new MessageService();
        String respMessage = msgsv.getEncryptRespMessage(request);  
     
        //处理表情
        // String respMessage = CoreService.processRequest_emoj(request);
        //处理图文消息
        //String respMessage = Test_NewsService.processRequest(request);

        
        //3.响应消息  
        PrintWriter out = response.getWriter();  
        out.print(respMessage);  
        out.close(); 
    }  
  
}  

八、web.xml

注册servlet

<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://java.sun.com/xml/ns/javaee" xmlns:web="http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd" xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd" version="2.5">
  <welcome-file-list>
  <welcome-file>index.jsp</welcome-file>
  </welcome-file-list>
    
  <servlet>
    <servlet-name>coreServlet</servlet-name>
    <servlet-class>  
            com.ray.servlet.CoreServlet
    </servlet-class>
  </servlet>
    
  <servlet>
    <servlet-name>uploadTempMaterialServlet</servlet-name>
    <servlet-class>  
            com.ray.servlet.UploadTempMaterialServlet
    </servlet-class>
  </servlet>
    
  <servlet-mapping>
    <servlet-name>uploadTempMaterialServlet</servlet-name>
    <url-pattern>/uploadTempMaterialServlet</url-pattern>
  </servlet-mapping>
    

</web-app>