微信公众号开发
Posted super超人
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了微信公众号开发相关的知识，希望对你有一定的参考价值。
1.登录微信公众平台：https://mp.weixin.qq.com/debug/cgi-bin/sandbox?t=sandbox/login
登录测试账号。
2.对微信公众号测试账号进行相关配置：
url指向项目的controller或者servlet，例如：http://www.test.qer/demo/test.do，其中www.test.qer是映射地址，先把本地映射到外网，否则微信公众号发送消息进入不了本地项目中。映射工具使用ngrok。
3.代码：
web.xml中配置：
<servlet> <servlet-name>WeixinServlet</servlet-name> <servlet-class>com.test.www.servlet.WeixinServlet1</servlet-class> </servlet> <servlet-mapping> <servlet-name>WeixinServlet</servlet-name> <url-pattern>/wx.do</url-pattern> </servlet-mapping>
WeixinServlet1.java：
package com.test.www.servlet; import java.io.IOException; import java.io.PrintWriter; import java.util.ArrayList; import java.util.Date; import java.util.List; import java.util.Map; import javax.servlet.ServletConfig; import javax.servlet.ServletException; import javax.servlet.http.HttpServlet; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import org.apache.commons.lang3.StringUtils; import org.dom4j.DocumentException; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.context.support.SpringBeanAutowiringSupport; import com.fasterxml.jackson.databind.ObjectMapper; import com.test.www.entity.XmlParam; import com.test.www.enums.KeyEnum; import com.test.www.utils.CheckUtil; import com.test.www.utils.MessageUtil; import com.test.www.utils.encrypt.cus.AuthProcess; import com.test.www.web.controller.entity.Article; import com.test.www.web.controller.entity.ArticleMeaasge; import com.test.www.web.controller.entity.Image; import com.test.www.web.controller.entity.ImgMeaasge; import com.test.www.web.controller.entity.Music; import com.test.www.web.controller.entity.MusicMeaasge; import com.test.www.web.controller.entity.TextMeaasge; import com.test.www.web.controller.entity.Video; import com.test.www.web.controller.entity.VideoMeaasge; import com.test.www.web.controller.entity.Voice; import com.test.www.web.controller.entity.VoiceMeaasge; import com.test.www.web.service.GoodService; import com.thoughtworks.xstream.XStream; import com.thoughtworks.xstream.io.xml.DomDriver; /** * 微信公众号开发者模式开发 * @className WeixinServlet1 * @author liuyachao * @date 2018-5-7 */ public class WeixinServlet1 extends HttpServlet { /*@Resource GoodService goodService;*/ @Autowired private GoodService goodService; /** * 注入service需要执行此方法 */ @Override public void init(ServletConfig config) throws ServletException { SpringBeanAutowiringSupport.processInjectionBasedOnServletContext(this, config.getServletContext()); } /*@Resource private GoodService goodService;*/ public void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { // 接收微信服务器以Get请求发送的4个参数 String signature = request.getParameter("signature"); String timestamp = request.getParameter("timestamp"); String nonce = request.getParameter("nonce"); String echostr = request.getParameter("echostr"); PrintWriter out = response.getWriter(); if (CheckUtil.checkSignature(signature, timestamp, nonce)) { out.print(echostr); // 校验通过，原样返回echostr参数内容 } } public void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { //doGet(request, response); request.setCharacterEncoding("utf-8"); response.setContentType("text/xml;charset=utf-8"); PrintWriter out = response.getWriter(); try { Map<String, String> map; try { map = MessageUtil.xmlToMap(request); String toUserName = map.get("ToUserName"); String fromUserName = map.get("FromUserName"); String msgType = map.get("MsgType"); String content = map.get("Content"); String key = map.get("EventKey"); //消息处理 String message = messageProcessing(toUserName,fromUserName,msgType,content,key); //消息加解密 /*String message = ""; ObjectMapper objectMapper = new ObjectMapper(); //加密消息处理 String encrypt_type =request.getParameter("encrypt_type"); if (StringUtils.isBlank(encrypt_type) || encrypt_type.equals("raw")) {//不用加密 map = MessageUtil.xmlToMap(request); String toUserName = map.get("ToUserName"); String fromUserName = map.get("FromUserName"); String msgType = map.get("MsgType"); String content = map.get("Content"); String key = map.get("EventKey"); //消息处理 message = messageProcessing(toUserName,fromUserName,msgType,content,key); } else {//需走加解密流程 //先转map再转xml map = MessageUtil.xmlToMap(request); XmlParam xmlParam = new XmlParam(); xmlParam.setToUserName(map.get("ToUserName")); xmlParam.setEncrypt(map.get("Encrypt")); String xml = MessageUtil.messageToXML(xmlParam); //String xml = MessageUtil.xmlToMap3(request); //解密请求消息体 String nXmlString = AuthProcess.decryptMsg(request, xml); map = MessageUtil.xmlToMap2(nXmlString); //map = objectMapper.readValue(nXmlString, Map.class); String toUserName = map.get("ToUserName"); String fromUserName = map.get("FromUserName"); String msgType = map.get("MsgType"); String content = map.get("Content"); String key = map.get("EventKey"); //消息处理 message = messageProcessing(toUserName,fromUserName,msgType,content,key); //加密回复消息体 message = AuthProcess.encryptMsg(request, message); }*/ System.out.println(message); out.print(message); } catch (com.itextpdf.text.DocumentException e) { // TODO Auto-generated catch block e.printStackTrace(); } // 将回应发送给微信服务器 } catch (DocumentException e) { e.printStackTrace(); }finally{ out.close(); } } private String messageProcessing(String toUserName, String fromUserName, String msgType, String content, String key) { String message = null; if ("text".equals(msgType)) { // 对文本消息进行处理 /*TextMeaasge text = new TextMeaasge(); text.setFromUserName(toUserName); // 发送和回·复是反向的 text.setToUserName(fromUserName); text.setMsgType("text"); text.setCreateTime(new Date().getTime()); text.setContent("你发送的消息是：" + content);*/ TextMeaasge text = new TextMeaasge(); text = Handle(toUserName,fromUserName,msgType,content,text,key); message = MessageUtil.messageToXML(text); }else if("event".equals(msgType)){ if(KeyEnum.V1001_TODAY_MUSIC.getCode().equals(key)){ //url /*UrlMeaasge urlMeaasge = new UrlMeaasge(); urlMeaasge.setFromUserName(toUserName); urlMeaasge.setToUserName(fromUserName); urlMeaasge.setMsgType("link"); urlMeaasge.setUrl("http://www.baidu.com/link?url=rzDPtXKQB42V4aTkeM_09D5sEI9bVW5tQ9la8uaJH0tfSZ1rinLD2ppcPdMa-9V7ka3EJFIA4rBYoFde_EVTLq"); urlMeaasge.setTitle("女儿国-女儿情"); urlMeaasge.setCreateTime(new Date().getTime()); urlMeaasge.setDescription("女儿情"); message = MessageUtil.urlMessageToXML(urlMeaasge); System.out.println(message); */ //音乐 MusicMeaasge musicMeaasge = new MusicMeaasge(); musicMeaasge.setCreateTime(new Date().getTime()); musicMeaasge.setFromUserName(toUserName); musicMeaasge.setToUserName(fromUserName); musicMeaasge.setMsgType("music"); Music music = new Music(); music.setTitle("女儿情"); music.setHQMusicUrl("http://localhost:80/weixin/img/4214239130.mp3"); music.setMusicUrl("http://localhost:80/weixin/img/4214239130.mp3"); music.setThumbMediaId("eJT2a5F5fYl2FtSrhxWRRt4Qsjq-N8YTcOOZK8ntZpSxHaPR_Ui6rr9EsmWbGRxD"); music.setDescription("西游记插曲"); musicMeaasge.setMusic(music); message = MessageUtil.messageToXML(musicMeaasge); } if(KeyEnum.V1001_GOOD.getCode().equals(key)){ Map<String,Object> result = goodService.insert(); TextMeaasge textMeaasge = new TextMeaasge(); textMeaasge.setFromUserName(toUserName); // 发送和回复是反向的 textMeaasge.setToUserName(fromUserName); textMeaasge.setMsgType("text"); textMeaasge.setCreateTime(new Date().getTime()); textMeaasge.setContent("谢谢您的支持！您是第"+result.get("count")+"个点赞的人"); //textMeaasge.setContent("谢谢您的支持！您是第500个点赞的人"); message = MessageUtil.messageToXML(textMeaasge); } if(KeyEnum.V1001_text.getCode().equals(key)){ TextMeaasge text = new TextMeaasge(); text = Handle(toUserName,fromUserName,msgType,content,text,key); message = MessageUtil.messageToXML(text); } if(KeyEnum.V1001_image.getCode().equals(key)){ //图片 ImgMeaasge imgMeaasge = new ImgMeaasge(); imgMeaasge.setCreateTime(new Date().getTime()); imgMeaasge.setFromUserName(toUserName); Image image = new Image(); image.setMediaId("8UwRYzG6BE719fckUQb0C3tdnh11cToA_Kw0PflEcNMWXAqi975zkcCKZfHvu9d_"); imgMeaasge.setImage(image); //imgMeaasge.getsetMediaId("NngcTJ3Ch4in6Vb5lHFBmhI8RCH1l9fBP_1zi0XoZejcGqfVApw4l1A75ztkD61T"); imgMeaasge.setMsgType("image"); imgMeaasge.setToUserName(fromUserName); message = MessageUtil.imgMessageToXML(imgMeaasge); } if(KeyEnum.V1001_video.getCode().equals(key)){ //视频 VideoMeaasge videoMeaasge = new VideoMeaasge(); videoMeaasge.setFromUserName(toUserName); videoMeaasge.setToUserName(fromUserName); videoMeaasge.setCreateTime(new Date().getTime()); videoMeaasge.setMsgType("video"); Video video = new Video(); video.setTitle("环保小视频"); video.setDescription("希望大家保护环境，节约用水"); //video.setMediaId("UyiC8gAXlJIfwdPEB8-VDLfoKeaGYWy9761yWgYMpSnRTjqtFpLzmG9MLuzzMhya"); //video.setMediaId("TFFzdu0HVViNeg3HvrbakpgTqvoC8zHkEgRcAs8OyowiKACqzkvBdGaVhyo-eVzt"); video.setMediaId("5bYQTWcEVMaMIGOKACDfshkt7cyXmGJKGv0HzFenoxQIYV_2JSC7dULSUPxLBbqL"); videoMeaasge.setVideo(video); message = MessageUtil.messageToXML(videoMeaasge); } if(KeyEnum.V1001_music.getCode().equals(key)){ //音乐 MusicMeaasge musicMeaasge = new MusicMeaasge(); musicMeaasge.setCreateTime(new Date().getTime()); musicMeaasge.setFromUserName(toUserName); musicMeaasge.setToUserName(fromUserName); musicMeaasge.setMsgType("music"); Music music = new Music(); music.setTitle("女儿情"); music.setHQMusicUrl("http://localhost:80/weixin/img/4214239130.mp3"); music.setMusicUrl("http://localhost:80/weixin/img/4214239130.mp3"); music.setThumbMediaId("eJT2a5F5fYl2FtSrhxWRRt4Qsjq-N8YTcOOZK8ntZpSxHaPR_Ui6rr9EsmWbGRxD"); music.setDescription("西游记插曲"); musicMeaasge.setMusic(music); message = MessageUtil.messageToXML(musicMeaasge); } if(KeyEnum.V1001_voice.getCode().equals(key)){ //语音消息 VoiceMeaasge voiceMeaasge = new VoiceMeaasge(); Voice voice = new Voice(); voice.setMediaId("L9GPORex_dJr-AwWiZHvv-gSf5MrwoztqK20qzA9ooKtwQ3_07tiSxhNCB2ZfgMc"); voiceMeaasge.setFromUserName(toUserName); // 发送和回复是反向的 voiceMeaasge.setToUserName(fromUserName); voiceMeaasge.setMsgType("voice"); voiceMeaasge.setCreateTime(new Date().getTime()); voiceMeaasge.setVoice(voice); message = MessageUtil.messageToXML(voiceMeaasge); } if(KeyEnum.V1001_article.getCode().equals(key)){ //图文消息 ArticleMeaasge articleMeaasge = new ArticleMeaasge(); Article article = new Article(); List<Article> list = new ArrayList<Article>(); article.setDescription("图文testtesttesttesttesttesttesttesttest"); article.setPicUrl("http://liuyachao110.tunnel.qydev.com/weixin/img/wang.jpg"); article.setTitle("test"); article.setUrl("http://www.bybo.com.cn"); list.add(article); articleMeaasge.setFromUserName(toUserName); articleMeaasge.setToUserName(fromUserName); articleMeaasge.setCreateTime(new Date().getTime()); articleMeaasge.setMsgType("news"); articleMeaasge.setArticleCount(list.size()); articleMeaasge.setArticles(list); message = MessageUtil.newsMessageToXml(articleMeaasge); } } return message; } /** * 文本消息处理 * @param toUserName * @param fromUserName * @param msgType * @param content * @param text * @param key * @return */ private TextMeaasge Handle(String toUserName, String fromUserName, String msgType, String content, TextMeaasge text, String key) { StringBuffer sb = new StringBuffer(); if("电影".equals(content)){ sb.append("<a href=\'http://www.baidu.com/link?url=N756uq7MPY-JWLok6hvcU_VgbzksWEWLcJgOIehxw1dy7Pfaavr6pZljeHKFR0qv&wd=&eqid=bdf02a660001b4de000000035ae02acc\'>女儿国</a>\\n\\n"); sb.append("<a href=\'http://www.baidu.com/link?url=ykNZi2TClLyY6zuKfP-gbLnht9kJsnrVnNeksRm6gKBweWTbPHiBTw0WVXC1KNOa3ra937Um07Ux2gRZYxzmMK\'>红海行动</a>\\n\\n"); sb.append("<a href=\'http://www.baidu.com/link?url=6-9h3UA9CZ8owwaekZK2UhyM_-ghzi9G_y0Jkkdy0pXBkOXw9Z4SfowNrEv4Z6yJoC2PQTPyDRSk-dZqIHRk4zNtLt97mNrugmKPoCWg6XNnmO-JYpSn6MpbFoI1Mw04\'>缝纫机乐队</a>"); content = sb.toString(); msgType = "text"; text.setFromUserName(toUserName); text.setToUserName(fromUserName); text.setMsgType(msgType); text.setContent(content); } if(KeyEnum.V1001_text.getCode().equals(key)){ sb.append("<a href=\'http://www.baidu.com/link?url=N756uq7MPY-JWLok6hvcU_VgbzksWEWLcJgOIehxw1dy7Pfaavr6pZljeHKFR0qv&wd=&eqid=bdf02a660001b4de000000035ae02acc\'>女儿国</a>\\n\\n"); sb.append("<a href=\'http://www.baidu.com/link?url=ykNZi2TClLyY6zuKfP-gbLnht9kJsnrVnNeksRm6gKBweWTbPHiBTw0WVXC1KNOa3ra937Um07Ux2gRZYxzmMK\'>红海行动</a>\\n\\n"); sb.append("<a href=\'http://www.baidu.com/link?url=6-9h3UA9CZ8owwaekZK2UhyM_-ghzi9G_y0Jkkdy0pXBkOXw9Z4SfowNrEv4Z6yJoC2PQTPyDRSk-dZqIHRk4zNtLt97mNrugmKPoCWg6XNnmO-JYpSn6MpbFoI1Mw04\'>缝纫机乐队</a>"); content = sb.toString(); msgType = "text"; text.setFromUserName(toUserName); text.setToUserName(fromUserName); text.setMsgType(msgType); text.setContent(content); } return text; } }
CheckUtil.java：
package com.test.www.utils; import java.util.Arrays; import org.apache.commons.codec.digest.DigestUtils; public class CheckUtil { private static final String token = "weixinTest"; public static boolean checkSignature(String signature,String timestamp,String nonce){ String[] arr = new String[] { token, timestamp, nonce }; // 排序 Arrays.sort(arr); // 生成字符串 StringBuilder content = new StringBuilder(); for (int i = 0; i < arr.length; i++) { content.append(arr[i]); } // sha1加密 String temp = getSHA1String(content.toString()); return temp.equals(signature); // 与微信传递过来的签名进行比较 } private static String getSHA1String(String data){ return DigestUtils.sha1Hex(data); // 使用commons codec生成sha1字符串 } }
MessageUtil.java：
package com.test.www.utils; import java.io.IOException; import java.io.InputStream; import java.util.HashMap; import java.util.List; import java.util.Map; import javax.servlet.http.HttpServletRequest; import org.dom4j.Document; import org.dom4j.DocumentHelper; import org.dom4j.Element; import org.dom4j.io.SAXReader; import com.itextpdf.text.DocumentException; import com.test.www.web.controller.entity.Article; import com.test.www.web.controller.entity.ArticleMeaasge; import com.test.www.web.controller.entity.ImgMeaasge; import com.test.www.web.controller.entity.TextMeaasge; import com.test.www.web.controller.entity.UrlMeaasge; import com.test.www.web.controller.entity.VideoMeaasge; import com.thoughtworks.xstream.XStream; public class MessageUtil { /** * 将XML转换成Map集合 * @throws org.dom4j.DocumentException */ public static Map<String, String>xmlToMap(HttpServletRequest request) throws IOException, DocumentException, org.dom4j.DocumentException{ Map<String, String> map = new HashMap<String, String>(); SAXReader reader = new SAXReader(); // 使用dom4j解析xml InputStream ins = request.getInputStream(); // 从request中获取输入流 Document doc = reader.read(ins); Element root = doc.getRootElement(); // 获取根元素 List<Element> list = root.elements(); // 获取所有节点 for (Element e : list) { map.put(e.getName(), e.getText()); System.out.println(e.getName() + "--->" + e.getText()); } ins.close(); return map; } /** * xml字符串转换为map集合 * @throws org.dom4j.DocumentException */ public static Map<String, String>xmlToMap2(String xml) throws IOException, DocumentException, org.dom4j.DocumentException{ Map<String, String> map = new HashMap<String, String>(); SAXReader reader = new SAXReader(); // 使用dom4j解析xml Document doc = DocumentHelper.parseText(xml); Element root = doc.getRootElement(); // 获取根元素 List<Element> list = root.elements(); // 获取所有节点 for (Element e : list) { map.put(e.getName(), e.getText()); System.out.println(e.getName() + "--->" + e.getText()); } return map; } /** * document转换为xml字符串 * @throws org.dom4j.DocumentException */ public static String xmlToMap3(HttpServletRequest request) throws IOException, DocumentException, org.dom4j.DocumentException{ Map<String, String> map = new HashMap<String, String>(); SAXReader reader = new SAXReader(); // 使用dom4j解析xml InputStream ins = request.getInputStream(); // 从request中获取输入流 Document doc = reader.read(ins); String xml = doc.asXML(); ins.close(); return xml; } /** * 将文本消息对象转换成XML */ public static String textMessageToXML(TextMeaasge textMessage){ XStream xstream = new XStream(); // 使用XStream将实体类的实例转换成xml格式 xstream.alias("xml", textMessage.getClass()); // 将xml的默认根节点替换成“xml” return xstream.toXML(textMessage); } /** * 将文本消息对象转换成XML * @param urlMessage * @return */ public static String urlMessageToXML(UrlMeaasge urlMessage){ XStream xstream = new XStream(); // 使用XStream将实体类的实例转换成xml格式 xstream.alias("xml", urlMessage.getClass()); // 将xml的默认根节点替换成“xml” return xstream.toXML(urlMessage); } /** * 将图片消息对象转换成XML * @param imgMeaasge * @return */ public static String imgMessageToXML(ImgMeaasge imgMeaasge) { XStream xstream = new XStream(); // 使用XStream将实体类的实例转换成xml格式 xstream.alias("xml", imgMeaasge.getClass()); // 将xml的默认根节点替换成“xml” return xstream.toXML(imgMeaasge); } /** * 将视频消息对象转换成XML * @param videoMeaasge * @return */ public static String videoMessageToXML(VideoMeaasge videoMeaasge) { XStream xstream = new XStream(); // 使用XStream将实体类的实例转换成xml格式 xstream.alias("xml", videoMeaasge.getClass()); // 将xml的默认根节点替换成“xml” return xstream.toXML(videoMeaasge); } /** * 将消息对象转换成XML 泛型 * @param t * @return */ public static <T> String messageToXML(T t) { XStream xstream = new XStream(); // 使用XStream将实体类的实例转换成xml格式 xstream.alias("xml", t.getClass()); // 将xml的默认根节点替换成“xml” return xstream.toXML(t); } /** * 图文消息 * @param articleMeaasge * @return */ public static String newsMessageToXml(ArticleMeaasge articleMeaasge) { XStream xstream = new XStream(); xstream.alias("xml", articleMeaasge.getClass()); xstream.alias("item", new Article().getClass()); return xstream.toXML(articleMeaasge); } }
UploadUtils.java：
package com.test.www.utils; import java.io.BufferedInputStream; import java.io.BufferedReader; import java.io.DataInputStream; import java.io.DataOutputStream; import java.io.File; import java.io.FileInputStream; import java.io.FileOutputStream; import java.io.IOException; import java.io.InputStream; import java.io.InputStreamReader; import java.io.OutputStream; import java.net.HttpURLConnection; import java.net.URL; import javax.net.ssl.HttpsURLConnection; import net.sf.json.JSONObject; import com.test.www.constant.Constant; import com.test.www.web.controller.entity.WeixinMedia; public class UploadUtils { /** * 上传媒体文件 * @param accessToken 接口访问凭证 * @param type 媒体文件类型，分别有图片（image）、语音（voice）、视频（video），普通文件(file) * @param media form-data中媒体文件标识，有filename、filelength、content-type等信息 * @param mediaFileUrl 媒体文件的url * 上传的媒体文件限制 * 图片（image）:1MB，支持JPG格式 * 语音（voice）：2MB，播放长度不超过60s，支持AMR格式 * 视频（video）：10MB，支持MP4格式 * 普通文件（file）：10MB * */ /*public static WeixinMedia uploadMedia(String accessToken, String type, String mediaFileUrl) { WeixinMedia weixinMedia = null; // 拼装请求地址 //String uploadMediaUrl = "https://qyapi.weixin.qq.com/cgi-bin/media/upload?access_token=ACCESS_TOKEN&type=TYPE"; String uploadMediaUrl = "https://api.weixin.qq.com/cgi-bin/media/upload?access_token=ACCESS_TOKEN&type=TYPE"; uploadMediaUrl = uploadMediaUrl.replace("ACCESS_TOKEN", accessToken).replace("TYPE", type); // 定义数据分隔符 String boundary = "------------7da2e536604c8"; try { URL uploadUrl = new URL(uploadMediaUrl); HttpURLConnection uploadConn = (HttpURLConnection) uploadUrl.openConnection(); uploadConn.setDoOutput(true); uploadConn.setDoInput(true); uploadConn.setRequestMethod("POST"); // 设置请求头Content-Type uploadConn.setRequestProperty("Content-Type", "multipart/form-data;boundary=" + boundary); // 获取媒体文件上传的输出流（往微信服务器写数据） OutputStream outputStream = uploadConn.getOutputStream(); URL mediaUrl = new URL(mediaFileUrl); HttpURLConnection meidaConn = (HttpURLConnection) mediaUrl.openConnection(); meidaConn.setDoOutput(true); meidaConn.setRequestMethod("GET"); System.out.println(meidaConn.getContent()); // 从请求头中获取内容类型 String contentType = meidaConn.getHeaderField("Content-Type"); // 根据内容类型判断文件扩展名 String fileExt = getFileEndWitsh(contentType); // 请求体开始 outputStream.write(("--" + boundary + "\\r\\n").getBytes()); outputStream.write(String.format("Content-Disposition: form-data; name=\\"media\\"; filename=\\"file1%s\\"\\r\\n", fileExt).getBytes()); outputStream.write(String.format("Content-Type: %s\\r\\n\\r\\n", contentType).getBytes()); // 获取媒体文件的输入流（读取文件） BufferedInputStream bis = new BufferedInputStream(meidaConn.getInputStream()); byte[] buf = new byte[8096]; int size = 0; while ((size = bis.read(buf)) != -1) { // 将媒体文件写到输出流（往微信服务器写数据） outputStream.write(buf, 0, size); } // 请求体结束 outputStream.write(("\\r\\n--" + boundary + "--\\r\\n").getBytes()); outputStream.close(); bis.close(); meidaConn.disconnect(); // 获取媒体文件上传的输入流（从微信服务器读数据） InputStream inputStream = uploadConn.getInputStream(); InputStreamReader inputStreamReader = new InputStreamReader(inputStream, "utf-8"); BufferedReader bufferedReader = new BufferedReader(inputStreamReader); StringBuffer buffer = new StringBuffer(); String str = null; while ((str = bufferedReader.readLine()) != null) { buffer.append(str); } bufferedReader.close(); inputStreamReader.close(); // 释放资源 inputStream.close(); inputStream = null; uploadConn.disconnect(); // 使用JSON-lib解析返回结果 JSONObject jsonObject = JSONObject.fromObject(buffer.toString()); // 测试打印结果 System.out.println("打印测试结果"+jsonObject); weixinMedia = new WeixinMedia(); weixinMedia.setType(jsonObject.getString("type")); // type等于 缩略图（thumb） 时的返回结果和其它类型不一样 if ("thumb".equals(type)) weixinMedia.setMediaId(jsonObject.getString("thumb_media_id")); else weixinMedia.setMediaId(jsonObject.getString("media_id")); weixinMedia.setCreatedAt(jsonObject.getInt("created_at")); } catch (Exception e) { weixinMedia = null; String error = String.format("上传媒体文件失败：%s", e); System.out.println(error); } return weixinMedia; }*/ /** * 根据内容类型判断文件扩展名 * * @param contentType 内容类型 * @return */ public static String getFileEndWitsh(String contentType) { String fileEndWitsh = ""; //text/html if ("image/jpeg;charset=UTF-8".equals(contentType) || "image/jpeg".equals(contentType)) fileEndWitsh = ".jpg"; else if ("audio/mpeg".equals(contentType) || "audio/mpeg;charset=UTF-8".equals(contentType)) fileEndWitsh = ".mp3"; else if ("audio/amr".equals(contentType)) fileEndWitsh = ".amr"; else if ("video/mp4".equals(contentType) || "video/mp4;charset=UTF-8".equals(contentType)) fileEndWitsh = ".mp4"; else if ("video/mpeg4".equals(contentType)) fileEndWitsh = ".mp4"; else if ("audio/x-wav;charset=UTF-8".equals(contentType)) fileEndWitsh = ".wav"; return fileEndWitsh; } /** * 获取媒体文件 * @param accessToken 接口访问凭证 * @param media_id 媒体文件id * @param savePath 文件在服务器上的存储路径 * */ public static String downloadMedia(String accessToken, String mediaId, String savePath) { String filePath = null; 微信公众号开发