玩玩微信公众号Java版之二：接收、处理及返回微信消息

前面已经配置了微信服务器，那么先开始最简单的接收微信消息吧~

 

可以用我们的微信号来直接进行测试，下面先看测试效果图：

 

这是最基本的文本消息的接收、处理及返回，来看看是怎么实现的吧！

 

首先可以参考微信消息相关的接口文档：https://mp.weixin.qq.com/wiki?t=resource/res_main&id=mp1421140453

 

具体实现如下：

第一步，接收微信发送的文本消息入口：

 

/**
     * 处理微信服务器发来的消息
     */
    public void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException
    {
        // TODO 消息的接收、处理、响应
        System.out.println("接口调用了一次");

        String ret = IOUtils.toString(request.getInputStream(), "utf-8").toString();
        System.out.println(ret);

        WeChatMsgBL tWeChatMsgBL = new WeChatMsgBL();
        String result = tWeChatMsgBL.dealWechatMsg(ret);

        response.setCharacterEncoding("UTF-8");

        // 返回文本消息，将处理结果返回
        PrintWriter out = response.getWriter();

        System.out.println(result);

        out.print(result);

        out.close();

    }

可以先输出接收到的xml信息：

 

第二步，解析及处理接收到数据的内容：

从微信提供的接口文档上，我们可以发现，不论是文本消息还是语音、图片等消息，在xml报文中，有部分节点信息的一致的，因此可以创建一个父类在处理（变量名要与xml中节点名一致，大小写也一样，这样后面返回消息结果时很方便）：

/**
 * 微信消息主要类
 * @author user
 */
public class WechatMsg
{
    // 开发者微信号
    private String ToUserName = "";

    // 发送方帐号（一个OpenID）
    private String FromUserName = "";

    // 消息创建时间 （整型）
    private String CreateTime = "";

    // 消息类型
    private String MsgType = "";

    // 消息id，64位整型
    private String MsgId = "";

    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 String getCreateTime()
    {
        return CreateTime;
    }

    public void setCreateTime(String createTime)
    {
        CreateTime = createTime;
    }

    public String getMsgType()
    {
        return MsgType;
    }

    public void setMsgType(String msgType)
    {
        MsgType = msgType;
    }

    public String getMsgId()
    {
        return MsgId;
    }

    public void setMsgId(String msgId)
    {
        MsgId = msgId;
    }



}

然后对应的基本信息子类为（只用多一个变量）：

/**
 * 普通消息类
 * @author Damon
 */
public class WechatTextMsg extends WechatMsg
{

    // 文本内容
    private String Content = "";

    public String getContent()
    {
        return Content;
    }

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

下面来看具体的处理，涉及新增jar包：dom4j-1.6.1.jar  

    /**
     * 处理微信信息
     * @param reqInfo xml信息数据
     * @return 处理结果
     */
    public String dealWechatMsg(String reqInfo)
    {

        String ret = reqInfo;

        String result = "";

        WechatTextMsg tReturnMsg = new WechatTextMsg();

        try
        {
            Document returndoc = DocumentHelper.parseText(ret);

            Element rootElement = returndoc.getRootElement();

            String tMsgType = rootElement.elementText("MsgType");

            // 根据MsgType 返回具体的消息类

            if (SysCon.TEXT_MSG_TYPE.equals(tMsgType))
            {
                result = dealTextMsg(rootElement);
            }

            // 封装返回信息
            tReturnMsg.setCreateTime(new Date().getTime() + "");
            tReturnMsg.setToUserName(rootElement.elementText("FromUserName"));
            tReturnMsg.setFromUserName(rootElement.elementText("ToUserName"));
            tReturnMsg.setContent(result);
            tReturnMsg.setMsgType(SysCon.TEXT_MSG_TYPE);
            // 将返回结果封装成文本消息
            result = WeChatUtil.textToXML(tReturnMsg);
        }
        catch (DocumentException e)
        {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }

        return result;
    }

    /**
     * 处理文本消息
     * @param msg
     * @return
     */
    private String dealTextMsg(Element rootElement)
    {

        WechatTextMsg tWechatTextMsg = new WechatTextMsg();
        // 依次赋值
        tWechatTextMsg.setCreateTime(rootElement.elementText("CreateTime"));
        tWechatTextMsg.setFromUserName(rootElement.elementText("FromUserName"));
        tWechatTextMsg.setToUserName(rootElement.elementText("ToUserName"));
        tWechatTextMsg.setMsgType(rootElement.elementText("MsgType"));
        tWechatTextMsg.setMsgId(rootElement.elementText("MsgId"));
        tWechatTextMsg.setContent(rootElement.elementText("Content"));

        System.out.println("传入的消息是：" + tWechatTextMsg.getContent());

        // 后续可处理保存到数据库及数据分析等，现在直接返回结果

        // 将数据转存至数据库
        // Connection conn = DBConnPool.getConnection();

        return "传入的文本消息处理完毕";
    }

其中对于参数类型判断，可以在SysCon类中添加基本参数

 

    // 定义微信消息类型--文本
    public static final String TEXT_MSG_TYPE = "text";

第三步，处理消息的返回

消息处理完成后，返回文本（可返回不同类型，仅以文本为例）处理结果

这里用到了工具类中 的方法如下：

    /**
     * 将对象转为XML输出
     * @param textMsg
     * @return
     */
    public static String textToXML(WechatTextMsg textMsg)
    {
        xstream.alias("xml", textMsg.getClass());
        return xstream.toXML(textMsg);

    }

    
    /**
     * 扩展xstream使其支持CDATA
     */
    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);
                    }
                }
            };
        }
    });

涉及到新增jar包：xstream-1.3.1.jar

可以在最后返回前输出处理的结果：

微信上可接收到消息：传入的文本消息处理完毕。

 

 到这，本节内容就结束了，可以自己去扩展语音消息的接收和处理哦~