微信开发之处理微信客户端发来的消息

在开启微信开发者模式时，我们配置了一个URL地址，当我们提交开启微信开发者模式，腾讯的微信服务器会向该URL地址发送一个get请求，并且携带一些参数，让我们来验证。说到get请求，就必须说到post请求，关注我们公众号的微信粉丝发来的消息，触发的事件，腾讯的微信服务器则会像该URL地址发送一个post请求，请求的内容就是以xml文档形式的字符串。

所以该URL地址的get请求的处理方法，专门用于开启微信开发者模式；而post请求则用于处理微信粉丝发给我们的消息，或者触发的事件，所以我们后面的微信开发工作的起点就是该URL地址的post处理方法。

下面我们处理一个最简单的例子：粉丝发送任意一个文本信息给我们，我们给他回复一个消息：“你好，+ 他微信的openId”

下面直接贴代码：

URL对应的处理servlet:

public class CoreServlet extends HttpServlet   {  	private static final long serialVersionUID = 4440739483644821986L;    	/**  	 * 请求校验（确认请求来自微信服务器）  	 */  	public void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException   	{  		// 微信服务端发来的加密签名  		String signature = request.getParameter("signature");  		// 时间戳  		String timestamp = request.getParameter("timestamp");  		// 随机数  		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   	{  		// 将请求、响应的编码均设置为UTF-8（防止中文乱码）  		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 (SignUtil.checkSignature(signature, timestamp, nonce)) {  			Message msgObj = XMLUtil.getMessageObject(request);	// 读取微信客户端发来的消息(xml字符串)，并将其转换为消息对象  			if(msgObj != null){  				String xml = "<xml>" +  						 "<ToUserName><![CDATA[" + msgObj.getFromUserName() + "]]></ToUserName>" +	// 接收方帐号（收到的OpenID）  						 "<FromUserName><![CDATA[" + msgObj.getToUserName() + "]]></FromUserName>" +	// 开发者微信号  						 "<CreateTime>12345678</CreateTime>" +  						 "<MsgType><![CDATA[text]]></MsgType>" +  						 "<Content><![CDATA[你好，"+ msgObj.getFromUserName() +"]]></Content>" +  						 "</xml>";  				out.write(xml);	// 回复微信客户端的消息(xml字符串)  				out.close();  				return;  			}  		}  		out.write("");  		out.close();  	}  }

xml字符串的处理工具类，实现xml消息到消息对象的转换：

public class XMLUtil   {  	/**  	 * 从request中读取用户发给公众号的消息内容  	 * @param request  	 * @return 用户发给公众号的消息内容  	 * @throws IOException  	 */  	public static String readRequestContent(HttpServletRequest request) throws IOException  	{  		// 从输入流读取返回内容  		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文档的内容转换成map  	 * @param xmlDoc  	 * @return map  	 */  	public static Map<String, String> xmlToMap(String xmlDoc)  	{  		//创建一个新的字符串          StringReader read = new StringReader(xmlDoc);          //创建新的输入源SAX 解析器将使用 InputSource 对象来确定如何读取 XML 输入          InputSource source = new InputSource(read);          //创建一个新的SAXBuilder          SAXBuilder sb = new SAXBuilder();                    Map<String, String> xmlMap = new HashMap<String, String>();          try {              Document doc = sb.build(source);	//通过输入源构造一个Document              Element root = doc.getRootElement();	//取的根元素                            List<Element> cNodes = root.getChildren();	//得到根元素所有子元素的集合(根元素的子节点，不包括孙子节点)              Element et = null;              for(int i=0;i<cNodes.size();i++){                  et = (Element) cNodes.get(i);	//循环依次得到子元素                  xmlMap.put(et.getName(), et.getText());              }          } catch (JDOMException e) {              e.printStackTrace();          } catch (IOException e) {              e.printStackTrace();          }          return xmlMap;  	}  	  	/**  	 * 将保存xml内容的map转换成对象  	 * @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内容的map转换成对象  	 * @param map  	 * @return  	 * @throws IOException   	 */  	public static Message getMessageObject(HttpServletRequest request) throws IOException  	{  		String xmlDoc = XMLUtil.readRequestContent(request);	// 读取微信客户端发了的消息(xml)  		Map<String, String> map = XMLUtil.xmlToMap(xmlDoc);		// 将客户端发来的xml转换成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"));  	}  }

粉丝发来的消息分为了6中类型(文本消息, 图片消息, 语音消息, 视频消息, 地理位置消息, 链接消息)：

/**   * 微信消息基类   * @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;	//开发者微信号  	private String FromUserName; // 发送方帐号（一个OpenID）  	private String CreateTime;	// 消息创建时间 （整型）  	  	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;  	}  	  }

文本消息类：

package com.sinaapp.wx.msg;    public class TextMessage extends Message   {  	private String Content;	// 文本消息内容    	public String getContent() {  		return Content;  	}    	public void setContent(String content) {  		Content = content;  	}  	  }

OK，对粉丝发送给我们公众号的任意的文本消息的最简单处理就完成，我们简单的回复他：你好，然后加上他微信的openId，类似于：你好，orJydljfkg3-r0_dj3rkdfvjl

更多微信开发之处理微信客户端发来的消息相关文章请关注PHP中文网！