微信二次开发之文本消息请求与发送的示例分析
创始人
2024-11-22 22:21:23
0次

做微信文本消息接口请求与发送,具体内容如下

需要导入库:dom4j-1.6.1.jar,xstream-1.3.1.jar

第一步:新建包com.wtz.message.response,新建类BaseMessage.java

package com.wtz.message.response;

/**
 * @author wangtianze QQ:864620012
 * @date 2017年4月19日 下午3:12:40
 * 

version:1.0

 * 

description:基础消息类

 */ public class BaseMessage {  //接收方  private String ToUserName;  //发送方  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;  } }

第二步:找到包com.wtz.message.response,新建类TextMessage.java

package com.wtz.message.response;

/**
 *  @author wangtianze QQ:864620012
 * @date 2017年4月19日 下午3:22:33
 * 

version:1.0

 *  

description:文本消息类

 */ public class TextMessage extends BaseMessage{  //消息内容  private String Content;    public String getContent() {   return Content;  }  public void setContent(String content) {   Content = content;  } }

第三步:找到包com.wtz.util,新建类MessageUtil.java

package com.wtz.util;

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.TextMessage;

/**
 *  @author wangtianze QQ:864620012
 * @date 2017年4月19日 下午3:29:58
 * 

version:1.0

 *  

description:消息处理工具类

 */ public class MessageUtil {  //定义了消息类型(常量:文本类型)  public static final String RESP_MESSAGE_TYPE_TEXT = "text";    //从流中解析出每个节点的内容  public static Map parseXml(HttpServletRequest request) throws IOException{   Map map = new HashMap();      //从输入流中获取流对象   InputStream in = request.getInputStream();      //构建SAX阅读器对象   SAXReader reader = new SAXReader();   try {    //从流中获得文档对象    Document doc = reader.read(in);        //获得根节点    Element root = doc.getRootElement();        //获取根节点下的所有子节点    List 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;  }    /**   * 用于扩展节点数据按照,中间加了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("");      }else{       writer.write(text);      }     }    };   }  });    /**   * 将文本消息转换成XML格式   */  public static String messageToXml(TextMessage textMessage){   xstream.alias("xml",textMessage.getClass());   String xml = xstream.toXML(textMessage);   System.out.println("响应所转换的XML:"+xml);   return xml;  } }

第四步:找到包com.wtz.service,新建类ProcessService.java

package com.wtz.util;

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

import javax.servlet.http.HttpServletRequest;

import com.wtz.message.response.TextMessage;

/**
 *  @author wangtianze QQ:864620012
 * @date 2017年4月19日 下午8:04:14
 * 

version:1.0

 *  

description:核心服务类

 */ public class ProcessService {  public static String dealRequest(HttpServletRequest request) throws IOException{   //响应的XML串   String respXml = "";      //要响应的文本内容   String respContent = "未知的消息类型";   Map requestMap = MessageUtil.parseXml(request);   String fromUserName = requestMap.get("FromUserName");   String toUserName = requestMap.get("ToUserName");   String MsgType = requestMap.get("MsgType");   String Content = requestMap.get("Content");      System.out.println("用户给公众号发的消息为:" + 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.RESP_MESSAGE_TYPE_TEXT)){    respContent = "王天泽的公众号收到了您的一条文本消息:" + Content + ",时间戳是:" + (new Date().getTime());   }   textMessage.setContent(respContent);   respXml = MessageUtil.messageToXml(textMessage);      System.out.println("respXml:"+respXml);      return respXml;  } }

第五步:找到包com.wtz.service下的LoginServlet类,重写doPost方法

package com.wtz.service;

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.wtz.util.MessageUtil;
import com.wtz.util.ProcessService;
import com.wtz.util.ValidationUtil;

/**
 *  @author wangtianze QQ:864620012
 * @date 2017年4月17日 下午8:11:32
 * 

version:1.0

 *  

description:微信请求验证类

 */ 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 {      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;  } }

相关内容

热门资讯

空调连续工作多久需要停机休息 空调连续工作的时间取决于多个因素,包括空调的型号、功率、使用环境和维护情况等。一般来说,空调可以连续...
空调哪个符号是除湿的 空调除湿功能通常用一个水滴形状的符号表示。不同品牌和型号的空调遥控器可能会有所差异,但一般来说,除湿...
格力空调多长时间加一次氟利昂 1、一般情况下,空调对氟利昂的使用量是非常小的,所以在空调使用了四年左右的时候再考虑加也没问题。2、...
空调用多长时间需要加氟一次 一般情况下是五年。当出现以下这几种情况时,空调才需要加氟。1、空调的室内机和室外机各有两个接口,当接...
格调生活·C标思享荟:卡萨帝在... 9月12日的郑州龙湖金融岛,夜风轻拂,灯光璀璨。“C标时刻共传奇——卡萨帝思享荟暨20周年品牌盛典郑...
品牌价值破千亿、高端份额持续领... 9月12日,“C标时刻共传奇——卡萨帝思享荟暨20周年品牌盛典郑州站”在郑州龙湖金融岛举办。2026...
空调主板坏了修800还是换新的 空调主板坏了是修还是换新,需要考虑多个因素,以下是一些建议:1. 维修成本:如果维修费用较低,比如 ...
空调开多久需要休息多长时间 问题:空调开多久需要休息多长时间回答:1、在使用空调的过程中,一般空调开7~8个小时左右需要休息2~...
中央空调多长时间清洗一次 1、一般空调开机前清洗一次即可,空调开机中间时段再清洗一次,空调关机时清洗一次,这样比较合理。2、空...
中央空调氟利昂多久加一次 看空调制热和制冷程度,很多人的观点认为氟利昂必须一年放一次,其实这个观点是错误的,理解上面有点偏差,...