微信开发(三)消息的自动回复和关注后自动回复

1.前置与微信接口对接成功后。

3.创建一个实体类消息类。里面设置的变量和属性参照微信开发者文档，https://mp.weixin.qq.com/wiki。

2.修改Servlet中dopost方法。

3.在消息操作类中增加方法，添加主菜单的方法，拼接字符串的方法，回复弹出信息的方法（1-5）。

参考代码：消息操作类中的代码

package com.util;
import java.io.IOException;
import java.io.InputStream;
import java.util.Date;
import java.util.HashMap;
import java.util.Map;


import javax.servlet.http.HttpServletRequest;
import org.dom4j.DocumentException;
import org.dom4j.Element;
import org.dom4j.io.SAXReader;

import com.po.TextMessage;
import com.thoughtworks.xstream.XStream;

/*
 * 创建一个方法 进行xml->map集合的转换
 * 
 */
public class MessagesUitl {
    //消息类型的常量
        public static final String MESSAGE_TEXT="text";
        public static final String MESSAGE_IMAGE="image";
        public static final String MESSAGE_VOICE="voice";
        public static final String MESSAGE_VIDEO="video";
        public static final String MESSAGE_LINK="link";
        public static final String MESSAGE_LOCATION="location";
        public static final String MESSAGE_EVENT="event";
        public static final String MESSAGE_SUBSCRIBE="subscribe";
        public static final String MESSAGE_UNSUBSCRIBE="unsubscribe";
        public static final String MESSAGE_CLICK="CLICK";
        public static final String MESSAGE_VIEW="VIEW";
public static Map<String,String>xmlToMap(HttpServletRequest request) throws IOException, DocumentException{
    //创建一个集合
    Map<String, String> map=new HashMap<String, String>();
    SAXReader reader=new SAXReader();
    
    InputStream ins=request.getInputStream();
    org.dom4j.Document doc=reader.read(ins);
    
    Element root=doc.getRootElement();
    
    java.util.List<Element> list=root.elements();
    for (Element e:list) {
        map.put(e.getName(), e.getText());
    }
    ins.close();
    return map;
    
    
}
//将文本消息转化为xml文件
public static String textMessageToXml(TextMessage textMessage){
    XStream xstream=new XStream();
    xstream.alias("xml", textMessage.getClass()) ;
    return xstream.toXML(textMessage);
    }
/*
 * 主菜单
 */
public static String menuText(){
    StringBuffer sb=new StringBuffer();
    sb.append("      欢迎您的关注！
");
    sb.append(" 请按照菜单提示进行操作

");
    sb.append("     1.账号介绍          
");
    sb.append("     2.美剧推荐          
");
    sb.append("     3.超级英雄          
");
    sb.append("     4.美剧时间表      
");
    sb.append("     ?.回复？调出此菜单

");
    sb.append("     更多功能尚在开发中  
");
    return sb.toString();
}
/*
 * 拼接文本消息
 */
public static String initText(String toUserName,String fromUserName,String content ){
    TextMessage text=new TextMessage();
    text.setFromUserName(toUserName);
    text.setToUserName(fromUserName);
    text.setMsgType(MessagesUitl.MESSAGE_TEXT);
    text.setCreateTime(new Date().getTime());
    text.setContent(content);
    return textMessageToXml(text);
}
/*
 * 回复“1”弹出信息
 */
public static String firstMenu(){
    StringBuffer sb=new StringBuffer();
    sb.append("本账号属于测试账号，正在开发中，主要发布与美剧相关信息！");
    
    return sb.toString();
}
/*
 * 回复“2”弹出信息
 */
public static String secondMenu(){
    StringBuffer sb=new StringBuffer();
    sb.append("美剧推荐功能正在开发中！");
    
    return sb.toString();
}
/*
 * 回复“3”弹出信息
 */
public static String thirdMenu(){
    StringBuffer sb=new StringBuffer();
    sb.append("超级英雄功能正在开发中！");
    
    return sb.toString();
}
/*
 * 回复“1”弹出信息
 */
public static String fourtMenu(){
    StringBuffer sb=new StringBuffer();
    sb.append("美剧时间表功能正在开发中！");
    
    return sb.toString();
}
public static String wenMenu(){
    StringBuffer sb=new StringBuffer();
    sb.append("美剧时间表功能正在开发中！");
    
    return sb.toString();
}
}
参考代码：Servlet

package com.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 com.po.TextMessage;
import com.util.MessagesUitl;

import sun.misc.MessageUtils;



public class WeixinServlet extends HttpServlet{
@Override
protected void doGet(HttpServletRequest req, HttpServletResponse resp)
        throws ServletException, IOException {
    String signature=req.getParameter("signature");
    String timestamp=req.getParameter("timestamp");
    String nonce=req.getParameter("nonce");
    String echostr=req.getParameter("echostr");
    PrintWriter out=resp.getWriter();
    if (com.util.CheckUtil.checkSignature(signature, timestamp, nonce)) {
        System.out.println();
        out.print(echostr);
    }else{
        System.out.println("不匹配");
    }
}
@Override
    protected void doPost(HttpServletRequest req, HttpServletResponse resp)
            throws ServletException, IOException {
    resp.setCharacterEncoding("utf-8");
    req.setCharacterEncoding("utf-8");
        // TODO Auto-generated method stub
    PrintWriter out=resp.getWriter();
        try {
            
            Map<String, String>map=MessagesUitl.xmlToMap(req);
            String fromUserName=map.get("FromUserName");
            String toUserName=map.get("ToUserName");
            //String createTime=map.get("CreateTime");
            String msgType=map.get("MsgType");
            String content=map.get("Content");
            //String msgId=map.get("MsgId");
            String message=null;
            if (MessagesUitl.MESSAGE_TEXT.equals(msgType)) {
                if ("1".equals(content)) {
                    message=MessagesUitl.initText(toUserName, fromUserName, MessagesUitl.firstMenu());
                }else if ("2".equals(content)) {
                    message=MessagesUitl.initText(toUserName, fromUserName, MessagesUitl.secondMenu());
                }else if ("3".equals(content)) {
                    message=MessagesUitl.initText(toUserName, fromUserName, MessagesUitl.thirdMenu());
                }else if ("4".equals(content)) {
                    message=MessagesUitl.initText(toUserName, fromUserName, MessagesUitl.fourtMenu());
                }else if ("?".equals(content)||"？".equals(content)) {
                    message=MessagesUitl.initText(toUserName, fromUserName, MessagesUitl.menuText());
                }
//测试代码 无用                
//                TextMessage text=new TextMessage();
//                text.setFromUserName(toUserName);
//                text.setToUserName(fromUserName);
//                text.setMsgType("text");
//                text.setCreateTime(new Date().getTime());
//                text.setContent("您发送的消息是："+content);
//                message=MessagesUitl.textMessageToXml(text);
            }else if(MessagesUitl.MESSAGE_EVENT.equals(msgType)){//事件推送逻辑
                String evenType=map.get("Event");//从集合中获取Event具体获取是哪一推送事件
                //获取关注后的事件
                if (MessagesUitl.MESSAGE_SUBSCRIBE.equals(evenType)) {
                    message=MessagesUitl.initText(toUserName, fromUserName, MessagesUitl.menuText());
                }
                
                
            }
            out.print(message);
        } catch (DocumentException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }finally{
            out.close();
        }
        
        
    }
}

参考代码：消息实体类

package com.po;

public class TextMessage {
    
    
    private String ToUserName;    //开发者微信号
    private String FromUserName;    //发送方帐号（一个OpenID）
    private long CreateTime;    //消息创建时间 （整型）
    private String MsgType    ;//text
    private String Content;//文本消息内容
    private String 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 String getContent() {
        return Content;
    }
    public void setContent(String content) {
        Content = content;
    }
    public String getMsgId() {
        return MsgId;
    }
    public void setMsgId(String msgId) {
        MsgId = msgId;
    }
}