您好,登錄后才能下訂單哦!
今天就跟大家聊聊有關(guān)微信二次開發(fā)中使用Java如何實(shí)現(xiàn)一個(gè)微信文本消息的請(qǐng)求與發(fā)送,可能很多人都不太了解,為了讓大家更加了解,小編給大家總結(jié)了以下內(nèi)容,希望大家根據(jù)這篇文章可以有所收獲。
第一步:新建包c(diǎn)om.wtz.message.response,新建類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:基礎(chǔ)消息類</p> */ public class BaseMessage { //接收方 private String ToUserName; //發(fā)送方 private String FromUserName; //消息的創(chuàng)建時(shí)間 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; } }
第二步:找到包c(diǎn)om.wtz.message.response,新建類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{ //消息內(nèi)容 private String Content; public String getContent() { return Content; } public void setContent(String content) { Content = content; } }
第三步:找到包c(diǎn)om.wtz.util,新建類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"; //從流中解析出每個(gè)節(jié)點(diǎn)的內(nèi)容 public static Map<String,String> parseXml(HttpServletRequest request) throws IOException{ Map<String,String> map = new HashMap<String,String>(); //從輸入流中獲取流對(duì)象 InputStream in = request.getInputStream(); //構(gòu)建SAX閱讀器對(duì)象 SAXReader reader = new SAXReader(); try { //從流中獲得文檔對(duì)象 Document doc = reader.read(in); //獲得根節(jié)點(diǎn) Element root = doc.getRootElement(); //獲取根節(jié)點(diǎn)下的所有子節(jié)點(diǎn) List<Element> children = root.elements(); for(Element e:children){ //遍歷每一個(gè)節(jié)點(diǎn),并按照節(jié)點(diǎn)名--節(jié)點(diǎn)值放入map中 map.put(e.getName(), e.getText()); System.out.println("用戶發(fā)送的消息XML解析為:" + e.getName() + e.getText()); } //關(guān)閉流 in.close(); in = null; } catch (DocumentException e) { // TODO Auto-generated catch block e.printStackTrace(); } return map; } /** * 用于擴(kuò)展節(jié)點(diǎn)數(shù)據(jù)按照<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); } } }; } }); /** * 將文本消息轉(zhuǎn)換成XML格式 */ public static String messageToXml(TextMessage textMessage){ xstream.alias("xml",textMessage.getClass()); String xml = xstream.toXML(textMessage); System.out.println("響應(yīng)所轉(zhuǎn)換的XML:"+xml); return xml; } }
第四步:找到包c(diǎn)om.wtz.service,新建類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:核心服務(wù)類</p> */ public class ProcessService { public static String dealRequest(HttpServletRequest request) throws IOException{ //響應(yīng)的XML串 String respXml = ""; //要響應(yīng)的文本內(nèi)容 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("用戶給公眾號(hào)發(fā)的消息為:" + Content); //構(gòu)建一條文本消息 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 = "王天澤的公眾號(hào)收到了您的一條文本消息:" + Content + ",時(shí)間戳是:" + (new Date().getTime()); } textMessage.setContent(respContent); respXml = MessageUtil.messageToXml(textMessage); System.out.println("respXml:"+respXml); return respXml; } }
第五步:找到包c(diǎn)om.wtz.service下的LoginServlet類,重寫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:微信請(qǐng)求驗(yàn)證類</p> */ public class LoginServlet extends HttpServlet { @Override protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { System.out.println("get請(qǐng)求。。。。。。"); //1.獲得微信簽名的加密字符串 String signature = request.getParameter("signature"); //2.獲得時(shí)間戳信息 String timestamp = request.getParameter("timestamp"); //3.獲得隨機(jī)數(shù) String nonce = request.getParameter("nonce"); //4.獲得隨機(jī)字符串 String echostr = request.getParameter("echostr"); System.out.println("獲得微信簽名的加密字符串:"+signature); System.out.println("獲得時(shí)間戳信息:"+timestamp); System.out.println("獲得隨機(jī)數(shù):"+nonce); System.out.println("獲得隨機(jī)字符串:"+echostr); PrintWriter out = response.getWriter(); //驗(yàn)證請(qǐng)求確認(rèn)成功原樣返回echostr參數(shù)內(nèi)容,則接入生效,成為開發(fā)者成功,否則失敗 if(ValidationUtil.checkSignature(signature, timestamp, nonce)){ out.print(echostr); } out.close(); out = null; } /** * 接受微信服務(wù)器發(fā)過來的XML數(shù)據(jù)包(通過post請(qǐng)求發(fā)送過來的) */ @Override protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { request.setCharacterEncoding("utf-8"); response.setCharacterEncoding("utf-8"); //獲取微信加密的簽名字符串 String signature = request.getParameter("signature"); //獲取時(shí)間戳 String timestamp = request.getParameter("timestamp"); //獲取隨機(jī)數(shù) 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; } }
完成微信文本消息接口請(qǐng)求與發(fā)送。
看完上述內(nèi)容,你們對(duì)微信二次開發(fā)中使用Java如何實(shí)現(xiàn)一個(gè)微信文本消息的請(qǐng)求與發(fā)送有進(jìn)一步的了解嗎?如果還想了解更多知識(shí)或者相關(guān)內(nèi)容,請(qǐng)關(guān)注億速云行業(yè)資訊頻道,感謝大家的支持。
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。