Dans le billet de blog précédent sur le développement WeChat (01) Comment devenir développeur, nous avons activé le mode développeur WeChat. Dans ce billet de blog, nous traitons simplement les messages envoyés par les abonnés WeChat à notre compte officiel.

Lors de l'activation du mode développeur WeChat, nous avons configuré une adresse URL. Lorsque nous soumettons l'activation du mode développeur WeChat, le serveur WeChat de Tencent enverra une demande d'obtention à l'adresse URL et comportera certains paramètres. . Lorsqu'il s'agit d'obtenir des demandes, nous devons parler de demandes de publication. Pour les messages envoyés par les fans de WeChat qui suivent notre compte officiel, le serveur WeChat de Tencent enverra une demande de publication à l'adresse URL, et le contenu de la demande se présente sous la forme de une cha?ne de document XML dans le formulaire.

Ainsi, la méthode de traitement de la demande d'obtention de cette adresse URL est spécialement utilisée pour activer le mode développeur WeChat tandis que la demande de publication est utilisée pour traiter les messages qui nous sont envoyés par les fans de WeChat, ou les événements déclenchés, alors ce que nous ferons plus tard Le point de départ du travail de développement de WeChat est la méthode de post-traitement de l'adresse URL.

Ci-dessous nous traitons de l'exemple le plus simple : un fan nous envoie n'importe quel SMS, et nous lui répondons par un message : "Bonjour, son openId WeChat"

Collez le code directement ci-dessous :

Le servlet de traitement correspondant à l'URL?:

public class CoreServlet extends HttpServlet 
{
	private static final long serialVersionUID = 4440739483644821986L;

	/**
	 * 請求校驗（確認請求來自微信服務(wù)器）
	 */
	public void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException 
	{
		// 微信服務(wù)端發(fā)來的加密簽名
		String signature = request.getParameter("signature");
		// 時間戳
		String timestamp = request.getParameter("timestamp");
		// 隨機數(shù)
		String nonce = request.getParameter("nonce");
		// 隨機字符串
		String echostr = request.getParameter("echostr");
		
		PrintWriter out = response.getWriter();
		// 請求校驗，若校驗成功則原樣返回echostr，表示接入成功，否則接入失敗
		if (SignUtil.checkSignature(signature, timestamp, nonce)) {
			out.print(echostr);
		}
		out.close();
		out = null;
	}

	/**
	 * 請求校驗與處理
	 */
	public void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException 
	{
		// 將請求、響應(yīng)的編碼均設(shè)置為UTF-8（防止中文亂碼）
		request.setCharacterEncoding("UTF-8");
		response.setCharacterEncoding("UTF-8");
		
		// 接收參數(shù)微信加密簽名、 時間戳、隨機數(shù)
		String signature = request.getParameter("signature");
		String timestamp = request.getParameter("timestamp");
		String nonce = request.getParameter("nonce");

		PrintWriter out = response.getWriter();
		// 請求校驗
		if (SignUtil.checkSignature(signature, timestamp, nonce)) {
			Message msgObj = XMLUtil.getMessageObject(request);	// 讀取微信客戶端發(fā)來的消息(xml字符串)，并將其轉(zhuǎn)換為消息對象
			if(msgObj != null){
				String xml = "<xml>" +
						 "<ToUserName><![CDATA[" + msgObj.getFromUserName() + "]]></ToUserName>" +	// 接收方帳號（收到的OpenID）
						 "<FromUserName><![CDATA[" + msgObj.getToUserName() + "]]></FromUserName>" +	// 開發(fā)者微信號
						 "<CreateTime>12345678</CreateTime>" +
						 "<MsgType><![CDATA[text]]></MsgType>" +
						 "<Content><![CDATA[你好，"+ msgObj.getFromUserName() +"]]></Content>" +
						 "</xml>";
				out.write(xml);	// 回復(fù)微信客戶端的消息(xml字符串)
				out.close();
				return;
			}
		}
		out.write("");
		out.close();
	}
}

Classe d'outil de traitement de cha?ne XML pour réaliser la conversion d'un message XML en objet message ：

public class XMLUtil 
{
	/**
	 * 從request中讀取用戶發(fā)給公眾號的消息內(nèi)容
	 * @param request
	 * @return 用戶發(fā)給公眾號的消息內(nèi)容
	 * @throws IOException
	 */
	public static String readRequestContent(HttpServletRequest request) throws IOException
	{
		// 從輸入流讀取返回內(nèi)容
		InputStream inputStream = request.getInputStream();
		InputStreamReader inputStreamReader = new InputStreamReader(inputStream, "utf-8");
		BufferedReader bufferedReader = new BufferedReader(inputStreamReader);
		String str = null;
		StringBuilder buffer = new StringBuilder();
		
		while ((str = bufferedReader.readLine()) != null) {
			buffer.append(str);
		}
		
		// 釋放資源
		bufferedReader.close();
		inputStreamReader.close();
		inputStream.close();
		
		return buffer.toString();
	}
	
	/**
	 * 將xml文檔的內(nèi)容轉(zhuǎn)換成map
	 * @param xmlDoc
	 * @return map
	 */
	public static Map<String, String> xmlToMap(String xmlDoc)
	{
		//創(chuàng)建一個新的字符串
        StringReader read = new StringReader(xmlDoc);
        //創(chuàng)建新的輸入源SAX 解析器將使用 InputSource 對象來確定如何讀取 XML 輸入
        InputSource source = new InputSource(read);
        //創(chuàng)建一個新的SAXBuilder
        SAXBuilder sb = new SAXBuilder();
        
        Map<String, String> xmlMap = new HashMap<String, String>();
        try {
            Document doc = sb.build(source);	//通過輸入源構(gòu)造一個Document
            Element root = doc.getRootElement();	//取的根元素
            
            List<Element> cNodes = root.getChildren();	//得到根元素所有子元素的集合(根元素的子節(jié)點，不包括孫子節(jié)點)
            Element et = null;
            for(int i=0;i<cNodes.size();i++){
                et = (Element) cNodes.get(i);	//循環(huán)依次得到子元素
                xmlMap.put(et.getName(), et.getText());
            }
        } catch (JDOMException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }
        return xmlMap;
	}
	
	/**
	 * 將保存xml內(nèi)容的map轉(zhuǎn)換成對象
	 * @param map
	 * @return
	 */
	public static Message getMessageObject(Map<String, String> map)
	{
		if(map != null){
			String MsgType = map.get("MsgType");
			
			// 消息類型(文本消息:text, 圖片消息:image, 語音消息:voice, 視頻消息:video, 
			// 地理位置消息:location, 鏈接消息:link)
			if("text".equals(MsgType)){
				TextMessage msg = new TextMessage();
				XMLUtil.initCommonMsg(msg, map);
				
				msg.setContent(map.get("Content"));
				return msg;
			}
			if("ImageMessage".equals(MsgType)){
				ImageMessage msg = new ImageMessage();
				XMLUtil.initCommonMsg(msg, map);
				
				msg.setPicUrl(map.get("PicUrl"));
				msg.setMediaId(map.get("MediaId"));
				return msg;
			}
			if("video".equals(MsgType)){
				VideoMessage msg = new VideoMessage();
				XMLUtil.initCommonMsg(msg, map);
				
				msg.setMediaId(map.get("MediaId"));
				msg.setThumbMediaId(map.get("ThumbMediaId"));
				return msg;
			}
			if("voice".equals(MsgType)){
				VoiceMessage msg = new VoiceMessage();
				XMLUtil.initCommonMsg(msg, map);
				
				msg.setMediaId(map.get("MediaId"));
				msg.setFormat(map.get("Format"));
				return msg;
			}
			if("location".equals(MsgType)){
				LocationMessage msg = new LocationMessage();

				msg.setLocation_X(map.get("Location_X"));
				msg.setLocation_Y(map.get("Location_Y"));
				msg.setScale(map.get("Scale"));
				msg.setLabel(map.get("Label"));
				return msg;
			}
			if("link".equals(MsgType)){
				LinkMessage msg = new LinkMessage();
				XMLUtil.initCommonMsg(msg, map);
				
				msg.setTitle(map.get("Title"));
				msg.setDescription(map.get("Description"));
				msg.setUrl(map.get("Url"));
				return msg;
			}
		}
		return null;
	}
	
	/**
	 * 將保存xml內(nèi)容的map轉(zhuǎn)換成對象
	 * @param map
	 * @return
	 * @throws IOException 
	 */
	public static Message getMessageObject(HttpServletRequest request) throws IOException
	{
		String xmlDoc = XMLUtil.readRequestContent(request);	// 讀取微信客戶端發(fā)了的消息(xml)
		Map<String, String> map = XMLUtil.xmlToMap(xmlDoc);		// 將客戶端發(fā)來的xml轉(zhuǎn)換成Map
		if(map != null){
			String MsgType = map.get("MsgType");
			
			// 消息類型(文本消息:text, 圖片消息:image, 語音消息:voice, 視頻消息:video, 
			// 地理位置消息:location, 鏈接消息:link)
			if("text".equals(MsgType)){
				TextMessage msg = new TextMessage();
				XMLUtil.initCommonMsg(msg, map);
				
				msg.setContent(map.get("Content"));
				return msg;
			}
			/*if("ImageMessage".equals(MsgType)){
				ImageMessage msg = new ImageMessage();
				XMLUtil.initCommonMsg(msg, map);
				
				msg.setPicUrl(map.get("PicUrl"));
				msg.setMediaId(map.get("MediaId"));
				return msg;
			}
			if("video".equals(MsgType)){
				VideoMessage msg = new VideoMessage();
				XMLUtil.initCommonMsg(msg, map);
				
				msg.setMediaId(map.get("MediaId"));
				msg.setThumbMediaId(map.get("ThumbMediaId"));
				return msg;
			}
			if("voice".equals(MsgType)){
				VoiceMessage msg = new VoiceMessage();
				XMLUtil.initCommonMsg(msg, map);
				
				msg.setMediaId(map.get("MediaId"));
				msg.setFormat(map.get("Format"));
				return msg;
			}
			if("location".equals(MsgType)){
				LocationMessage msg = new LocationMessage();

				msg.setLocation_X(map.get("Location_X"));
				msg.setLocation_Y(map.get("Location_Y"));
				msg.setScale(map.get("Scale"));
				msg.setLabel(map.get("Label"));
				return msg;
			}
			if("link".equals(MsgType)){
				LinkMessage msg = new LinkMessage();
				XMLUtil.initCommonMsg(msg, map);
				
				msg.setTitle(map.get("Title"));
				msg.setDescription(map.get("Description"));
				msg.setUrl(map.get("Url"));
				return msg;
			}*/
		}
		return null;
	}
	
	public static void initCommonMsg(Message msg, Map<String, String> map)
	{
		msg.setMsgId(map.get("MsgId"));
		msg.setMsgType(map.get("MsgType"));
		msg.setToUserName(map.get("ToUserName"));
		msg.setFromUserName(map.get("FromUserName"));
		msg.setCreateTime(map.get("CreateTime"));
	}
}

Les messages envoyés par les fans sont divisés en 6 types (messages texte, messages photo, messages vocaux, messages vidéo, messages de localisation géographique, liens Message ) :

/**
 * 微信消息基類
 * @author yuanfang
 * @date 2015-03-23
 */
public class Message 
{
	private String MsgId;	// 消息id，64位整型
	private String MsgType;	// 消息類型(文本消息:text, 圖片消息:image, 語音消息:voice, 視頻消息:video, 地理位置消息:location, 鏈接消息:link)
	private String ToUserName;	//開發(fā)者微信號
	private String FromUserName; // 發(fā)送方帳號（一個OpenID）
	private String CreateTime;	// 消息創(chuàng)建時間 （整型）
	
	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;
	}
	
}

Type de message texte :

package com.sinaapp.wx.msg;

public class TextMessage extends Message 
{
	private String Content;	// 文本消息內(nèi)容

	public String getContent() {
		return Content;
	}

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

OK , le traitement le plus simple de tout message texte envoyé par les fans à notre compte officiel est terminé. Nous lui répondons simplement : Bonjour, puis ajoutons son openId WeChat, similaire à : Bonjour, ouJydljfkg3-r0_dj3rkdfvjl

Pour plus d'articles liés. Pour le développement et le traitement de WeChat, les messages envoyés par les clients WeChat, veuillez faire attention au site Web PHP chinois?!