Demande et envoi de messages texte de développement secondaire WeChat

Cet article présente principalement en détail la deuxième partie du développement secondaire de Java WeChat, les fonctions de demande et d'envoi de l'interface de message texte Java WeChat, qui a une certaine valeur de référence. Les amis intéressés peuvent s'y référer

Le deuxième article, lors de la demande et de l'envoi de l'interface de message texte WeChat, le contenu spécifique est le suivant

Besoin d'importer des bibliothèques : dom4j-1.6.1.jar, xstream-1.3.1.jar

La première étape : Créer un nouveau package com.wtz.message.response et une nouvelle classe BaseMessage.java

package com.wtz.message.response;

/**
 * @author wangtianze QQ:864620012
 * @date 2017年4月19日 下午3:12:40
 * <p>version:1.0</p>
 * <p>description:基础消息类</p>
 */
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;
 }
}

La deuxième étape : Trouver le package com.wtz .message .response, créez une nouvelle classe TextMessage.java

package com.wtz.message.response;

/**
 *  @author wangtianze QQ:864620012
 * @date 2017年4月19日 下午3:22:33
 * <p>version:1.0</p>
 *  <p>description:文本消息类</p>
 */
public class TextMessage extends BaseMessage{
 //消息内容
 private String Content;
 
 public String getContent() {
  return Content;
 }
 public void setContent(String content) {
  Content = content;
 }
}

Étape 3 : Trouvez le package com.wtz.util, créez une nouvelle classe 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
 * <p>version:1.0</p>
 *  <p>description:消息处理工具类</p>
 */
public class MessageUtil {
 //定义了消息类型（常量：文本类型）
 public static final String RESP_MESSAGE_TYPE_TEXT = "text";
 
 //从流中解析出每个节点的内容
 public static Map<String,String> parseXml(HttpServletRequest request) throws IOException{
  Map<String,String> map = new HashMap<String,String>();
  
  //从输入流中获取流对象
  InputStream in = request.getInputStream();
  
  //构建SAX阅读器对象
  SAXReader reader = new SAXReader();
  try {
   //从流中获得文档对象
   Document doc = reader.read(in);
   
   //获得根节点
   Element root = doc.getRootElement();
   
   //获取根节点下的所有子节点
   List<Element> 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;
 }
 
 /**
  * 用于扩展节点数据按照<ToUserName><![CDATA[toUser]]></ToUserName>，中间加了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("<![CDATA[");
      writer.write(text);
      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;
 }
}

Étape 4 : Trouvez le package com.wtz.service et créez une nouvelle classe 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
 * <p>version:1.0</p>
 *  <p>description:核心服务类</p>
 */
public class ProcessService {
 public static String dealRequest(HttpServletRequest request) throws IOException{
  //响应的XML串
  String respXml = "";
  
  //要响应的文本内容
  String respContent = "未知的消息类型";
  Map<String,String> 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;
 }
}

Étape 5 : Trouvez le package com.wtz.service LoginServlet class, remplacez la méthode 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
 * <p>version:1.0</p>
 *  <p>description:微信请求验证类</p>
 */
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;
 }
}

pour terminer la demande et l'envoi de l'interface de message texte WeChat.

[Recommandations associées]

1. Téléchargement du code source de la plateforme de compte public WeChat

2. Code source de vote WeChat

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!