微信公众号开发基础篇(六)

一、之前实现了关注后的消息回复,现在实现按照关键字回复

二、查看消息类型

       

三、关注微信号的时候，会出发关注事件

四、修改代码

       1、书写一些常量（修改MessageUtils ）

public class MessageUtils {

    // 书写一些常量(会经常用到)
    // 文本消息
    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";

          2、text换为MessageUtils.MESSAGE_TEXT常量（修改WeXinServlet）

if (MessageUtils.MESSAGE_TEXT.equals(msgType)) {

     //原来的消息代码

}// 事件推送的逻辑处理
            else if (MessageUtils.MESSAGE_EVENT.equals(msgType)) {

        // 获取事件
        String eventType = map.get("event");
        // 关注后的逻辑处理
        if (MessageUtils.MESSAGE_SUBSCRIBE.equals(eventType)) {

                    
        }
}

      3、修改MessageUtils，添加方法

/**
     * // 1.拼接一个主菜单(这个是消息菜单,在关注微信公众号后,自动回复一个消息)
     */
    public static String menuText() {
        StringBuffer stringBuffer = new StringBuffer();
        stringBuffer.append("欢迎您的关注,请按照菜单提示进行操作:

");
        stringBuffer.append("1、公司介绍 
");
        stringBuffer.append("2、主营产品介绍

");
        stringBuffer.append("**回复？调出此菜单。**");
        return stringBuffer.toString();
}

      4、添加另一个方法

/**
     * 2.拼接文本消息的
     */
    public static String initText(String toUserName, String fromUserName,
            String content) {
        TextMessage textMessage = new TextMessage();
        textMessage.setFromUserName(toUserName);
        textMessage.setToUserName(fromUserName);
        // 换成常量
        textMessage.setMsgType(MessageUtils.MESSAGE_TEXT);
        textMessage.setCreateTime(new Date().getTime());
        textMessage.setContent("您发送的消息是 :" + content);
        return textMessageToXml(textMessage);
}

     5、添加到WeXinServlet

// 关注后的逻辑处理
                if (MessageUtils.MESSAGE_SUBSCRIBE.equals(eventType)) {
3                     //消息的位置
4                     message = MessageUtils.initText(toUserName, fromUserName,
5                             MessageUtils.menuText());
}

    6、判断消息回复(规则设置，红色为添加部分)

// 如果是文本消息,就进行回复
            if (MessageUtils.MESSAGE_TEXT.equals(msgType)) {
 3 
 4                 // 判断消息回复(规则设置)
 5                 if ("1".equals(content)) {
 6                     message = MessageUtil.initText(toUserName, fromUserName,
 7                             MessageUtil.firstMenu());
 8                 } else if ("2".equals(content)) {
 9                     message = MessageUtil.initNewsMessage(toUserName,
10                             fromUserName);
11                 } else if (("?".equals(content)) || ("？".equals(content))) {
12                     message = MessageUtils.initText(toUserName, fromUserName,
13                             MessageUtils.menuText());
14                 }
15 
}

7、添加规则回复（MessageUtils中增加）

/**
     * 添加新的规则,当输入1的时候返回的数据
     */

    public static String firstMenu() {
        StringBuffer stringBuffer = new StringBuffer();
        stringBuffer
                .append("总部杭州。

");
        return stringBuffer.toString();
    }

    /**
     * 添加新的规则,当输入2的时候返回的数据
     * 
     * @return
     */
    public static String secondMenu() {
        StringBuffer stringBuffer = new StringBuffer();
        stringBuffer
                .append("公司主要产品为技术开发、技术服务等。

");
        return stringBuffer.toString();
    }

8、WeXinServlet中判断

// 如果是文本消息,就进行回复
            if (MessageUtils.MESSAGE_TEXT.equals(msgType)) {
 3 
 4                 // 判断消息回复(规则设置)
 5                 if ("1".equals(content)) {
 6                     message = MessageUtils.initText(toUserName, fromUserName,
 7                             MessageUtils.firstMenu());
 8                 } else if ("2".equals(content)) {
 9                     message = MessageUtils.initText(toUserName, fromUserName,
10                             MessageUtils.secondMenu());
11                 } else if (("?".equals(content)) || ("？".equals(content))) {
12                     message = MessageUtils.initText(toUserName, fromUserName,
13                             MessageUtils.menuText());
14                 }

            }
            // 事件推送的逻辑处理
            else if (MessageUtils.MESSAGE_EVENT.equals(msgType)) {

}

9、重新启动Tomcat

10、公众号测试

       （1）规则验证

               

     （2）取消关注，验证关注后消息自动回复

11、完全版WeXinServlet

              

package com.my.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 com.my.pojo.TextMessage;
import com.my.utils.CheckUtil;
import com.my.utils.MessageUtils;

/**
 * 
 * @author liuya
 * 
 * 
 *         //微信连接
 * 
 *         微信消息的接收与发送
 * 
 */

public class WeXinServlet extends HttpServlet {

    /**
     * 随机生成的版本id
     */
    private static final long serialVersionUID = 1L;

    /**
     * 开发文档第一部分与微信的连接方式代码
     */
    @Override
    protected void doGet(HttpServletRequest request,
            HttpServletResponse response) throws ServletException, IOException {

        System.out.println("request.getRequestURL()返回的结果："
                + request.getRequestURL());

        // 跟微信平台比较的参数
        String signature = request.getParameter("signature");
        String timestamp = request.getParameter("timestamp");
        String nonce = request.getParameter("nonce");
        String echostr = request.getParameter("echostr");

        PrintWriter pWriter = response.getWriter();
        // 微信get后进行比较
        if (CheckUtil.checkSignature(signature, timestamp, nonce)) {
            pWriter.print(echostr);
        }

    }

    /**
     * // 1、将XML转换成集合类型 (因为微信后台发过来的消息是一个XML类型,为了方便处理,需要把微信发来的消息,转化成集合类型)
     * 
     * 
     * // 2、对象类型转化成XML类型(因为我们这边发送消息,也需要把数据转化成XML类型给微信服务后台接收)
     * 
     * 
     * // 3、书写一个公共类型的类,进行消息类型的转换
     * 
     * 文本消息类型的接收与响应
     * 
     */

    @Override
    protected void doPost(HttpServletRequest requset,
            HttpServletResponse response) throws ServletException, IOException {

        // 设置消息发来的格式
        requset.setCharacterEncoding("UTF-8");
        // 设置接收的消息格式
        response.setCharacterEncoding("UTF-8");

        // 通过此方法进行消息返回
        PrintWriter outPrintWriter = response.getWriter();

        // 1.微信消息的接收 集合获取
        Map<String, String> map;
        try {
            map = MessageUtils.xmlToMap(requset);

            // 2.获取集合中的属性
            // 开发者微信号
            String toUserName = (String) map.get("ToUserName");
            // 发送方账号(一个OpenID)
            String fromUserName = (String) map.get("FromUserName");
            // 消息类型
            String msgType = (String) map.get("MsgType");
            // 文本消息内容
            String content = (String) map.get("Content");

            // 3.根据messageType判断消息是不是文本消息
            // 设置消息回复变量
            String message = null;

            // 如果是文本消息,就进行回复
            if (MessageUtils.MESSAGE_TEXT.equals(msgType)) {

                // 判断消息回复(规则设置)
                if ("1".equals(content)) {
                    message = MessageUtils.initText(toUserName, fromUserName,
                            MessageUtils.firstMenu());
                } else if ("2".equals(content)) {
                    message = MessageUtils.initText(toUserName, fromUserName,
                            MessageUtils.secondMenu());
                } else if (("?".equals(content)) || ("？".equals(content))) {
                    message = MessageUtils.initText(toUserName, fromUserName,
                            MessageUtils.menuText());
                }

            }
            // 事件推送的逻辑处理
            else if (MessageUtils.MESSAGE_EVENT.equals(msgType)) {

                // 获取事件
                String eventType = map.get("event");
                // 关注后的逻辑处理
                if (MessageUtils.MESSAGE_SUBSCRIBE.equals(eventType)) {
                    // 消息的位置
                    message = MessageUtils.initText(toUserName, fromUserName,
                            MessageUtils.menuText());
                }
            }

            // 打印消息到控制台
            System.out.print(message);
            
            // 消息返回
            outPrintWriter.print(message);

        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            // 关闭流
            outPrintWriter.close();
        }

    }

}

12、完全版MessageUtils

package com.my.utils;

import java.io.InputStream;
import java.util.Date;
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.my.pojo.TextMessage;
import com.thoughtworks.xstream.XStream;

/**
 * 
 * // @author liuya
 * 
 * // 后端接收,微信公众号发过来的消息功能
 * 
 * 
 * // 1、将XML转换成集合类型 (因为微信后台发过来的消息是一个XML类型,为了方便处理,需要把微信发来的消息,转化成集合类型)
 * 
 * // 2、对象类型转化成XML类型(因为我们这边发送消息,也需要把数据转化成XML类型给微信服务后台接收)
 */

public class MessageUtils {

    // 书写一些常量(会经常用到)
    // 文本消息
    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";

    /**
     * 需要导入dom4j---jar包 //
     * 
     * //1、将XML转换成集合类型 (因为微信后台发过来的消息是一个XML类型,为了方便处理,需要把微信发来的消息,转化成集合类型)//
     * 
     * @param request
     * @return
     * @throws Exception
     */
    @SuppressWarnings("unchecked")
    public static Map<String, String> xmlToMap(HttpServletRequest request)
            throws Exception {

        Map<String, String> map = new HashMap<String, String>();
        SAXReader sReader = new SAXReader();

        // 从request中获取输入流
        InputStream inStream = request.getInputStream();
        Document document = sReader.read(inStream);

        // 获取xml中的根元素
        Element rootElement = document.getRootElement();

        // 得到根元素的所有子节点,把它放在list的集合中
        List<Element> list = rootElement.elements();

        // 遍历list对象,获取单个元素的数据
        for (Element element : list) {

            // 遍历的结果保存到集合中
            map.put(element.getName(), element.getText());
        }

        // 关闭流
        inStream.close();

        return map;
    }

    /**
     * 导入xsream---jar包
     * 
     * // 2、对象类型转化成XML类型(因为我们这边发送消息,也需要把数据转化成XML类型给微信服务后台接收)
     * 
     * // 3、创建文本消息需要的实体类
     * 
     * @param textMessage
     * @return
     */
    public static String textMessageToXml(TextMessage textMessage) {
        XStream xstream = new XStream();

        // 打印出根节点的<xml>
        xstream.alias("xml", textMessage.getClass());
        // 返回发来的消息到控制台
        return xstream.toXML(textMessage);
    }

    /**
     * // 1.拼接一个主菜单(这个是消息菜单,在关注微信公众号后,自动回复一个消息)
     */
    public static String menuText() {
        StringBuffer stringBuffer = new StringBuffer();
        stringBuffer.append("欢迎您的关注,请按照菜单提示进行操作:

");
        stringBuffer.append("1、公司介绍 
");
        stringBuffer.append("2、主营产品介绍

");
        stringBuffer.append("**回复？调出此菜单。**");
        return stringBuffer.toString();
    }

    /**
     * 2.拼接文本消息的
     */
    public static String initText(String toUserName, String fromUserName,
            String content) {
        TextMessage textMessage = new TextMessage();
        textMessage.setFromUserName(toUserName);
        textMessage.setToUserName(fromUserName);
        // 换成常量
        textMessage.setMsgType(MessageUtils.MESSAGE_TEXT);
        textMessage.setCreateTime(new Date().getTime());
        textMessage.setContent("您发送的消息是 :" + content);
        return textMessageToXml(textMessage);
    }

    /**
     * 添加新的规则,当输入1的时候返回的数据
     */

    public static String firstMenu() {
        StringBuffer stringBuffer = new StringBuffer();
        stringBuffer
                .append("总部杭州。

"); 
return stringBuffer.toString(); 
 } 

/** 
 * 添加新的规则,当输入2的时候返回的数据 
 * 
 * @return 
*/ 
public static String secondMenu() { 
StringBuffer stringBuffer = new StringBuffer(); 
 stringBuffer 
.append("总部杭州。

"); 
return stringBuffer.toString(); 
 } 
}