Java微信公眾平台開發(八)–多媒體消息回復之音樂

• 2019 年 10 月 5 日
• 筆記

我們上一篇寫了關注出發圖片的回復。想著在發送一次音樂，最後基於回復消息分類情況下，實現一個簡單的只能話回復。先附一張大致效果圖。

下面我們進入程式碼階段。

(一)修改消息轉發器MsgDispatcher類，增加識別用戶發出消息功能，這裡實現了回複數字1，2，3，按內容分類回復，大致程式碼如下。

 1         String openid = map.get("FromUserName"); // 用戶openid   2         String mpid = map.get("ToUserName"); // 公眾號原始ID   3         // 普通文本消息   4         TextMessage txtmsg = new TextMessage();   5         txtmsg.setToUserName(openid);   6         txtmsg.setFromUserName(mpid);   7         txtmsg.setCreateTime(new Date().getTime());   8         txtmsg.setMsgType(MessageUtil.RESP_MESSAGE_TYPE_TEXT);   9  10         if (map.get("MsgType").equals(MessageUtil.REQ_MESSAGE_TYPE_TEXT)) { // 文本消息  11             StringBuffer sb = new StringBuffer();  12             String content = map.get("Content");  13             sb.append("歡迎關注史上最帥公眾號：nn ");  14             sb.append("1、歌德你好   nn ");  15             sb.append("2、聽首歌吧   nn ");  16             sb.append("3、語音回復   nn ");  17             sb.append("回復?調出主菜單哦哦   n ");  18             String context = sb.toString();  19             txtmsg.setContent(context);  20  21             if ("1".equals(content)) {  22                 txtmsg.setContent("歌德你好！");  23             } else if ("2".equals(content)) {  24                 // Test test=new Test();  25                 // test.image();  26                 MusicMessage mucmsg = new MusicMessage();  27                 mucmsg.setToUserName(openid);  28                 mucmsg.setFromUserName(mpid);  29                 mucmsg.setCreateTime(new Date().getTime());  30                 mucmsg.setMsgType(MessageUtil.RESP_MESSAGE_TYPE_MUSIC);  31  32                 Music music = new Music();  33                 HttpPostUploadUtil util = new HttpPostUploadUtil("thumb");  34                 String filepath = "H:\1.jpg";  35                 Map<String, String> textMap = new HashMap<String, String>();  36                 textMap.put("name", "testname");  37                 Map<String, String> fileMap = new HashMap<String, String>();  38                 fileMap.put("userfile", filepath);  39                 String mediaidrs = util.formUpload(textMap, fileMap);  40                 System.out.println(mediaidrs);  41                 String mediaid = JSONObject.fromObject(mediaidrs).getString("thumb_media_id");  42                 System.out.println(mediaid);  43                 music.setTitle("十年");  44                 music.setThumbMediaId(mediaid);  45                 music.setDescription("十年——陳奕迅");  46                 music.setMusicUrl("http://music.163.com/#/song?id=31877628");  47                 music.setHQMusicUrl("http://music.163.com/#/song?id=31877628");  48                 mucmsg.setMusic(music);  49                 return MessageUtil.musicMessageToXml(mucmsg);  50             } else if ("3".equals(content)) {  51                 txtmsg.setContent("語音回復！");  52             } else if ("？".equals(content)) {  53                 txtmsg.setContent(context);  54             } else {  55                 txtmsg.setContent("你好，歡迎來到gede部落格！");  56             }  57             return MessageUtil.textMessageToXml(txtmsg);  58         }

簡單的來說就是對music類的封裝。開發過程中，HttpPostUploadUtil util = new HttpPostUploadUtil("thumb");是我後來重寫過的，需要什麼類型就將類型以字元串的方式插入。程式碼如下：

1 public HttpPostUploadUtil(String type) {  2         urlStr = "http://file.api.weixin.qq.com/cgi-bin/media/upload?access_token="  3                 + GlobalConstants.getInterfaceUrl("access_token") + "&type=" + type;  4 }

但是在後來的測試中發現，當類型不是image時，返回的不再是media_id這個屬性。而是將其類型作為前綴返回，我們直接看返回結果：

{"type":"thumb","thumb_media_id":"jooBl6SX9svP1rw4EA7ZnSX49QD4xoj_z59V8-dm3pXcSb-e4EXn-QnwL3jbf4nh","created_at":1558938915}

在我們上面的程式碼中，我直接將thumb_media_id設置成了定值，String mediaid = JSONObject.fromObject(mediaidrs).getString("thumb_media_id");為了j加強程式碼的寵用性，我在這裡重寫了HttpPostUploadUtil中的formUpload方法，大致程式碼如下：

 1 public String formUpload(String filePath,String type) throws IOException {   2         File file = new File(filePath);// 判斷文件是否存在   3         if (!file.exists() || !file.isFile()) {   4             throw new IOException("文件不存在");   5         }   6         System.out.println(urlStr);   7         URL urlobj = new URL(urlStr);   8         // 使用HttpURLConnection連接   9         HttpURLConnection con = (HttpURLConnection) urlobj.openConnection();  10         con.setRequestMethod("POST");  11         con.setDoInput(true);  12         con.setDoOutput(true);  13         con.setUseCaches(false); // 使用post提交需 要設置忽略快取  14         // 設置請求頭資訊  15         con.setRequestProperty("Connection", "Keep- Alive");  16         con.setRequestProperty("Charset", "UTF-8");  17         // 設置邊界  18         long currentTime = System.currentTimeMillis();  19         String BOUNDARY = "---------" + currentTime;  20         con.setRequestProperty("Content -Type", "multipart/ form-data; boundary=" + BOUNDARY);  21         StringBuilder sb = new StringBuilder();  22         sb.append("--");  23         sb.append(BOUNDARY);  24         sb.append("rn");  25         sb.append("Content -Di sposition: form-data ;name="file";filename="" + file.getName() + ""rn");  26         sb.append("Content - Type:applicat ion/octet-streamrnrn");  27         byte[] head = sb.toString().getBytes("utf-8");  28         // 獲得輸出流  29         OutputStream out = new DataOutputStream(con.getOutputStream());// 輸出表頭  30         out.write(head);  31         // 文件正文部分  32         // 把文件已流文件的方式推入到ur1中  33         DataInputStream in = new DataInputStream(new FileInputStream(file));  34         int bytes = 0;  35         byte[] bufferOut = new byte[1024];  36         while ((bytes = in.read(bufferOut)) != -1) {  37             out.write(bufferOut, 0, bytes);  38         }  39         in.close();  40         // 結尾部分  41         byte[] foot = ("rn--" + BOUNDARY + "--rn").getBytes("utf-8");// 定義最後數據分隔線  42         out.write(foot);  43         out.flush();  44         out.close();  45         StringBuffer buffer = new StringBuffer();  46         BufferedReader reader = null;  47         String result = null;  48         try {  49             reader = new BufferedReader(new InputStreamReader(con.getInputStream()));  50             String line = null;  51             while ((line = reader.readLine()) != null) {  52                 buffer.append(line);  53             }  54             if (result == null) {  55                 result = buffer.toString();  56             }  57         } catch (Exception e) {  58             // TODO: handle exception  59             e.printStackTrace();  60         } finally {  61             // TODO: handle finally clause  62             if (reader != null) {  63                 reader.close();  64             }  65         }  66         JSONObject jsonObj = JSONObject.fromObject(result);  67         System.out.println(jsonObj);  68         String typeName = "media_id";  69         if (!"image".equals(type)) {  70             typeName = type + "_mediaid";  71         }  72         String mediaId = jsonObj.getString(typeName);// 從json中獲取media_id  73         return mediaId;  74  75     }

重寫後的方法，直接反回我們需要的media_id。

最後今天開發中遇到的一些莫名的bug記錄一下：

1、一開始我的項目啟動直接初始化失敗，quartz連接超時。搞了半天沒有發現為什麼，因為配置和jar包都沒有修改過，所以我最後刪除了tomcat，反覆清理伺服器，最終跑起來了。以後再遇到補充完整錯誤吧。只找到這一條錯誤搜索記錄。

parsing XML document from class path resource [spring-quartz.xml]; nested ex

2、微信伺服器允許上傳最大的thumb文件好像時32k，我沒有找到官方給出的大小。當圖片過大時，報以下錯誤。

40006錯誤程式碼

 {"errcode":40006,"errmsg":"invalid meida size hint: [nHa_JA0174e298]"} 

3、一個比較穩定的音樂解析網站給大家

地址:https://music.liuzhijin.cn/

4、程式碼又抽風了

報了不知道什麼的錯，個人感覺應該是access_token次數上限了。中午睡覺忘了關項目。

[ERROR][2019-05-27 15:09:00,495][com.gede.wechat.quartz.QuartzJob]net.sf.json.JSONException: JSONObject["access_token"] not found.  net.sf.json.JSONException: JSONObject["access_token"] not found.  	at net.sf.json.JSONObject.getString(JSONObject.java:2092)  	at com.gede.wechat.common.WeChatTask.getToken_getTicket(WeChatTask.java:30)  	at com.gede.wechat.quartz.QuartzJob.workForToken(QuartzJob.java:19)  	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)  	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)  	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)  	at java.lang.reflect.Method.invoke(Method.java:497)  	at org.springframework.util.MethodInvoker.invoke(MethodInvoker.java:269)  	at org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean$MethodInvokingJob.executeInternal(MethodInvokingJobDetailFactoryBean.java:311)  	at org.springframework.scheduling.quartz.QuartzJobBean.execute(QuartzJobBean.java:113)  	at org.quartz.core.JobRunShell.run(JobRunShell.java:223)  	at org.quartz.simpl.SimpleThreadPool$WorkerThread.run(SimpleThreadPool.java:549)