In diesem Artikel wird hauptsächlich der zweite Schritt der Entwicklung der öffentlichen Java-WeChat-Plattform ausführlich vorgestellt, der Empfang des Nachrichtentexts des WeChat-Servers, der einen gewissen Referenzwert hat.
Im vorherigen Artikel In diesem Artikel haben wir ausführlich beschrieben, wie wir unseren Anwendungsserver mit dem WeChat-Tencent-Server verbinden. Ich frage mich, ob Ihnen aufgefallen ist, dass es im vorherigen Artikel eine get-Methode gibt Post-Methode, aber wir verwenden während der Verwendung die Get-Methode. Hier werden wir über die Verwendung der Post-Methode sprechen, die wir reserviert haben!
Nachdem wir die Serverüberprüfung abgeschlossen haben, wird jedes Mal, wenn der Benutzer eine Nachricht an das offizielle Konto sendet oder ein benutzerdefiniertes Menüklickereignis generiert, die vom Entwickler eingegebene Serverkonfigurations-URL von WeChat übertragen Server Nachrichten und Ereignisse, und dann können Entwickler gemäß ihrer eigenen Geschäftslogik reagieren, z. B. auf Nachrichten antworten usw.! Aus diesem Satz können wir erkennen, dass die gesamte nachfolgende Kommunikation zwischen dem WeChat-Server und unserem Anwendungsserver über den Post-Nachrichtentext abgeschlossen wird. Daher beschreiben wir hier, wie der Nachrichtentext des WeChat-Posts akzeptiert wird!
(1) Nachrichtentyp und Nachrichtenformat
Oben wurde gesagt, dass unsere gesamte Kommunikation mit dem WeChat-Server im Wesentlichen über den Post-Nachrichtentext abgeschlossen wird Werfen wir einen Blick auf die Arten von Nachrichtentexten. Es gibt grob zwei Arten:
Gängige Nachrichtentypen: Textnachrichten, Bildnachrichten, Sprachnachrichten, Videonachrichten , kurze Videos Nachrichten, geografische Standortnachrichten, Linknachrichten
Ereignisnachrichtentypen: Ereignisse verfolgen/entfolgen, QR-Code-Ereignisse mit Parametern scannen, geografische Standortereignisse melden, Benutzerdefinierte Menüereignisse, Ereignis-Push beim Klicken auf das Menü zum Abrufen von Nachrichten, Ereignis-Push beim Klicken auf den Menüsprung-Link
Nachrichtentyp: Das Typformat aller vom WeChat-Server übertragenen Nachrichtentexte ist XML-Format;
(2) Nachrichtenwiederholungsmechanismus
Wenn der WeChat-Server innerhalb von fünf Sekunden keine Antwort erhält, trennt er die Verbindung und initiiert die Anfrage erneut, wobei es insgesamt dreimal erneut versucht wird. Wenn der Server die Verarbeitung und Antwort nicht innerhalb von fünf Sekunden garantieren kann, können Sie direkt mit einer leeren Zeichenfolge antworten. Der WeChat-Server wird damit nichts anfangen und keinen erneuten Versuch einleiten. Sie können jedoch die [Kundendienst-Nachrichtenschnittstelle] verwenden. um die Nachricht später noch einmal zu pushen.
(3) Nachrichtenempfang und -verarbeitung
Zuvor haben wir gesagt, dass der Nachrichtentext von WeChat im XML-Format vorliegt, also habe ich hier ein MessageUtil an To geschrieben Verarbeiten Sie das Nachrichtenformat. Der ungefähre Code lautet wie folgt:
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);
}
}
};
}
});
}In diesem Methodenkörper müssen einige Abhängigkeiten verwendet werden, und die folgenden Teile müssen der POM-Datei hinzugefügt werden:
<!-- 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>
Dann fügen Sie uns hinzu. Die Post-Methode im WechatSecurity Controller wird wie folgt geändert und zum Empfangen und Verarbeiten von Nachrichten verwendet:
@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);
}
}Weil wir unseren Entwicklermodus früher aktiviert haben, als wir unsere veröffentlichen Code hier Nachdem Sie eine Nachricht an das offizielle Konto gesendet haben, können Sie im Hintergrund sehen, dass unser Nachrichtentext erfolgreich eingegeben und analysiert wurde. Hier gebe ich die [Original-ID] von WeChat aus. Der Screenshot sieht ungefähr wie folgt aus 🎜>
Hier habe ich nur den Nachrichtentext empfangen und in eine Karte umgewandelt, die Nachricht jedoch nicht verarbeitet. Im nächsten Artikel werden wir über die Klassifizierung und Verarbeitung von Nachrichten sprechen! Vielen Dank fürs Lesen. Wenn Sie Fragen haben, hinterlassen Sie bitte eine Nachricht zur Diskussion!
Das obige ist der detaillierte Inhalt vonJava-Codebeispiel für den Empfang des Postnachrichtentexts des WeChat-Servers. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!
