Exemple de code Java pour recevoir le corps du message du serveur WeChat

Cet article présente principalement en détail la deuxième étape du développement de la plate-forme publique Java WeChat, la réception du corps du message du serveur WeChat, qui a une certaine valeur de référence. Les amis intéressés peuvent s'y référer

Dans le précédent. Dans cet article, nous avons décrit en détail comment connecter notre serveur d'applications au serveur WeChat Tencent. Enfin, la connexion a réussi. Je me demande si vous avez remarqué que j'ai défini le [contrôleur] dans l'article précédent. post, mais nous utilisons la méthode get lors de l'utilisation. Nous parlerons ici de l'utilisation de la méthode post que nous avons réservée !

Une fois la vérification du serveur terminée, chaque fois que l'utilisateur envoie un message au compte officiel ou génère un événement de clic de menu personnalisé, l'URL de configuration du serveur renseignée par le développeur sera poussée par WeChat. Messages et événements du serveur, puis les développeurs peuvent répondre selon leur propre logique métier, comme répondre aux messages, etc. ! À partir de cette phrase, nous pouvons savoir que toutes les communications ultérieures entre le serveur WeChat et notre serveur d'applications sont effectuées via le corps du message de publication, nous allons donc décrire ici comment accepter le corps du message de la publication WeChat !

(1) Type de message et format du message

Il est mentionné ci-dessus que toute notre communication avec le serveur WeChat se fait essentiellement via le corps du message. Jetons un coup d'œil aux types de corps de message. Il existe environ deux types :

Types de messages courants : Messages texte, messages photo, messages vocaux, messages vidéo. , courtes vidéos Messages, messages de localisation, messages de lien

Types de messages d'événement : Suivre/ne plus suivre les événements, scanner les événements de code QR avec des paramètres, signaler les événements de localisation, menu personnalisé événements, poussée d'événement lorsque vous cliquez sur le menu pour extraire des messages, poussée d'événement lorsque vous cliquez sur le lien de saut de menu
Type de message : le format de type de tous les corps de message poussés par le serveur WeChat est au format XML ;

(2) Mécanisme de nouvelle tentative de message

Si le serveur WeChat ne reçoit pas de réponse dans les cinq secondes, il déconnectera la connexion et relancera la demande, en réessayant trois fois au total. Si le serveur ne peut pas garantir le traitement et la réponse dans les cinq secondes, vous pouvez répondre directement avec une chaîne vide. Le serveur WeChat ne fera rien avec cela et ne lancera pas de nouvelle tentative. Cependant, vous pouvez utiliser l'[Interface de message du service client]. pour repousser le message plus tard.

(3) Réception et traitement des messages

Plus tôt, nous avons dit que le corps du message de WeChat est au format XML, j'ai donc écrit un MessageUtil ici. traitez le format du message, le code approximatif est le suivant :

package com.cuiyongzhi.wechat.util;
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.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;
  
/**
 * ClassName: MessageUtil
 * @Description: 消息工具类
 * @author dapengniao
 * @date 2016年3月7日 上午10:05:04
 */
public class MessageUtil { 
  
  /** 
   * 返回消息类型：文本 
   */ 
  public static final String RESP_MESSAGE_TYPE_TEXT = "text"; 
  
  /** 
   * 返回消息类型：音乐 
   */ 
  public static final String RESP_MESSAGE_TYPE_MUSIC = "music"; 
  
  /** 
   * 返回消息类型：图文 
   */ 
  public static final String RESP_MESSAGE_TYPE_NEWS = "news"; 
  
  /** 
   * 请求消息类型：文本 
   */ 
  public static final String REQ_MESSAGE_TYPE_TEXT = "text"; 
  
  /** 
   * 请求消息类型：图片 
   */ 
  public static final String REQ_MESSAGE_TYPE_IMAGE = "image"; 
  
  /** 
   * 请求消息类型：链接 
   */ 
  public static final String REQ_MESSAGE_TYPE_LINK = "link"; 
  
  /** 
   * 请求消息类型：地理位置 
   */ 
  public static final String REQ_MESSAGE_TYPE_LOCATION = "location"; 
  
  /** 
   * 请求消息类型：音频 
   */ 
  public static final String REQ_MESSAGE_TYPE_VOICE = "voice"; 
  
  /** 
   * 请求消息类型：推送 
   */ 
  public static final String REQ_MESSAGE_TYPE_EVENT = "event"; 
  
  /** 
   * 事件类型：subscribe(订阅) 
   */ 
  public static final String EVENT_TYPE_SUBSCRIBE = "subscribe"; 
  
  /** 
   * 事件类型：unsubscribe(取消订阅) 
   */ 
  public static final String EVENT_TYPE_UNSUBSCRIBE = "unsubscribe"; 
  
  /** 
   * 事件类型：CLICK(自定义菜单点击事件) 
   */ 
  public static final String EVENT_TYPE_CLICK = "CLICK"; 
  
  /**
   * @Description: 解析微信发来的请求（XML） 
   * @param @param request
   * @param @return
   * @param @throws Exception  
   * @author dapengniao
   * @date 2016年3月7日 上午10:04:02
   */
  @SuppressWarnings("unchecked")
  public static Map<String, String> parseXml(HttpServletRequest request) throws Exception { 
    // 将解析结果存储在HashMap中  
    Map<String, String> map = new HashMap<String, String>(); 
  
    // 从request中取得输入流  
    InputStream inputStream = request.getInputStream(); 
    // 读取输入流  
    SAXReader reader = new SAXReader(); 
    Document document = reader.read(inputStream); 
    // 得到xml根元素  
    Element root = document.getRootElement(); 
    // 得到根元素的所有子节点  
    List<Element> elementList = root.elements(); 
  
    // 遍历所有子节点  
    for (Element e : elementList) 
      map.put(e.getName(), e.getText()); 
  
    // 释放资源  
    inputStream.close(); 
    inputStream = null; 
  
    return map; 
  } 
  
  @SuppressWarnings("unused")
  private static XStream xstream = new XStream(new XppDriver() { 
    public HierarchicalStreamWriter createWriter(Writer out) { 
      return new PrettyPrintWriter(out) { 
        // 对所有xml节点的转换都增加CDATA标记  
        boolean cdata = true; 
        @SuppressWarnings("rawtypes")
        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); 
          } 
        } 
      }; 
    } 
  }); 
}

Certaines dépendances doivent être utilisées dans ce corps de méthode, et les parties suivantes doivent être ajoutées au fichier pom :

<!-- xml -->
<dependency>
  <groupId>org.apache.directory.studio</groupId>
  <artifactId>org.dom4j.dom4j</artifactId>
  <version>1.6.1</version>
</dependency>
 
<dependency>
  <groupId>com.thoughtworks.xstream</groupId>
  <artifactId>xstream</artifactId>
  <version>1.4.8</version>
</dependency>

Ensuite, ajoutez-nous La méthode post dans le contrôleur de sécurité Wechat est modifiée comme suit, utilisée pour recevoir et traiter les messages :

@RequestMapping(value = "security", method = RequestMethod.POST)
  // post方法用于接收微信服务端消息
  public void DoPost(HttpServletRequest request,HttpServletResponse response) {
    System.out.println("这是post方法！");
    try{
    Map<String, String> map=MessageUtil.parseXml(request);
    System.out.println("============================="+map.get("Content"));
    }catch(Exception e){
      logger.error(e,e);
    }
  }

Parce que nous avons activé notre mode développeur plus tôt, alors lorsque nous publions notre code ici Après avoir envoyé un message sur le compte officiel, vous pouvez voir en arrière-plan que le corps de notre message a été saisi et analysé avec succès. Ici, j'affiche l'[ID original] de WeChat. La capture d'écran est à peu près la suivante :

<.>

Ici, j'ai seulement reçu et converti le corps du message en Map, mais je n'ai pas créé le message. Dans le prochain article, nous parlerons de la classification et du traitement des messages ! Merci d'avoir lu. Si vous avez des questions, veuillez laisser un message pour en discuter !

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!