Java微信公众平台开发(八)

我们上一篇写了关注出发图片的回复。想着在发送一次音乐，最后基于回复消息分类情况下，实现一个简单的只能话回复。先附一张大致效果图。

下面我们进入代码阶段。

(一)修改消息转发器MsgDispatcher类，增加识别用户发出消息功能，这里实现了回复数字1，2，3，按内容分类回复，大致代码如下。

1 1         String openid = map.get("FromUserName"); // 用户openid
2 2         String mpid = map.get("ToUserName"); // 公众号原始ID
3 3         // 普通文本消息
4 4         TextMessage txtmsg = new TextMessage();
5 5         txtmsg.setToUserName(openid);
6 6         txtmsg.setFromUserName(mpid);
7 7         txtmsg.setCreateTime(new Date().getTime());
8 8         txtmsg.setMsgType(MessageUtil.RESP_MESSAGE_TYPE_TEXT);
9 9 
1010         if (map.get("MsgType").equals(MessageUtil.REQ_MESSAGE_TYPE_TEXT)) { // 文本消息
1111             StringBuffer sb = new StringBuffer();
1212             String content = map.get("Content");
1313             sb.append("欢迎关注史上最帅公众号：\n\n ");
1414             sb.append("1、歌德你好   \n\n ");
1515             sb.append("2、听首歌吧   \n\n ");
1616             sb.append("3、语音回复   \n\n ");
1717             sb.append("回复?调出主菜单哦哦   \n ");
1818             String context = sb.toString();
1919             txtmsg.setContent(context);
2020 
2121             if ("1".equals(content)) {
2222                 txtmsg.setContent("歌德你好！");
2323             } else if ("2".equals(content)) {
2424                 // Test test=new Test();
2525                 // test.image();
2626                 MusicMessage mucmsg = new MusicMessage();
2727                 mucmsg.setToUserName(openid);
2828                 mucmsg.setFromUserName(mpid);
2929                 mucmsg.setCreateTime(new Date().getTime());
3030                 mucmsg.setMsgType(MessageUtil.RESP_MESSAGE_TYPE_MUSIC);
3131 
3232                 Music music = new Music();
3333                 HttpPostUploadUtil util = new HttpPostUploadUtil("thumb");
3434                 String filepath = "H:\\1.jpg";
3535                 Map<String, String> textMap = new HashMap<String, String>();
3636                 textMap.put("name", "testname");
3737                 Map<String, String> fileMap = new HashMap<String, String>();
3838                 fileMap.put("userfile", filepath);
3939                 String mediaidrs = util.formUpload(textMap, fileMap);
4040                 System.out.println(mediaidrs);
4141                 String mediaid = JSONObject.fromObject(mediaidrs).getString("thumb_media_id");
4242                 System.out.println(mediaid);
4343                 music.setTitle("十年");
4444                 music.setThumbMediaId(mediaid);
4545                 music.setDescription("十年——陈奕迅");
4646                 music.setMusicUrl("http://music.163.com/#/song?id=31877628");
4747                 music.setHQMusicUrl("http://music.163.com/#/song?id=31877628");
4848                 mucmsg.setMusic(music);
4949                 return MessageUtil.musicMessageToXml(mucmsg);
5050             } else if ("3".equals(content)) {
5151                 txtmsg.setContent("语音回复！");
5252             } else if ("？".equals(content)) {
5353                 txtmsg.setContent(context);
5454             } else {
5555                 txtmsg.setContent("你好，欢迎来到gede博客！");
5656             }
5757             return MessageUtil.textMessageToXml(txtmsg);
5858         }

简单的来说就是对music类的封装。开发过程中，HttpPostUploadUtil util = new HttpPostUploadUtil("thumb");是我后来重写过的，需要什么类型就将类型以字符串的方式插入。代码如下：

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

但是在后来的测试中发现，当类型不是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 1 public String formUpload(String filePath,String type) throws IOException {
2 2         File file = new File(filePath);// 判断文件是否存在
3 3         if (!file.exists() || !file.isFile()) {
4 4             throw new IOException("文件不存在");
5 5         }
6 6         System.out.println(urlStr);
7 7         URL urlobj = new URL(urlStr);
8 8         // 使用HttpURLConnection连接
9 9         HttpURLConnection con = (HttpURLConnection) urlobj.openConnection();
1010         con.setRequestMethod("POST");
1111         con.setDoInput(true);
1212         con.setDoOutput(true);
1313         con.setUseCaches(false); // 使用post提交需 要设置忽略缓存
1414         // 设置请求头信息
1515         con.setRequestProperty("Connection", "Keep- Alive");
1616         con.setRequestProperty("Charset", "UTF-8");
1717         // 设置边界
1818         long currentTime = System.currentTimeMillis();
1919         String BOUNDARY = "---------" + currentTime;
2020         con.setRequestProperty("Content -Type", "multipart/ form-data; boundary=" + BOUNDARY);
2121         StringBuilder sb = new StringBuilder();
2222         sb.append("--");
2323         sb.append(BOUNDARY);
2424         sb.append("\r\n");
2525         sb.append("Content -Di sposition: form-data ;name=\"file\";filename=\"" + file.getName() + "\"\r\n");
2626         sb.append("Content - Type:applicat ion/octet-stream\r\n\r\n");
2727         byte[] head = sb.toString().getBytes("utf-8");
2828         // 获得输出流
2929         OutputStream out = new DataOutputStream(con.getOutputStream());// 输出表头
3030         out.write(head);
3131         // 文件正文部分
3232         // 把文件已流文件的方式推入到ur1中
3333         DataInputStream in = new DataInputStream(new FileInputStream(file));
3434         int bytes = 0;
3535         byte[] bufferOut = new byte[1024];
3636         while ((bytes = in.read(bufferOut)) != -1) {
3737             out.write(bufferOut, 0, bytes);
3838         }
3939         in.close();
4040         // 结尾部分
4141         byte[] foot = ("\r\n--" + BOUNDARY + "--\r\n").getBytes("utf-8");// 定义最后数据分隔线
4242         out.write(foot);
4343         out.flush();
4444         out.close();
4545         StringBuffer buffer = new StringBuffer();
4646         BufferedReader reader = null;
4747         String result = null;
4848         try {
4949             reader = new BufferedReader(new InputStreamReader(con.getInputStream()));
5050             String line = null;
5151             while ((line = reader.readLine()) != null) {
5252                 buffer.append(line);
5353             }
5454             if (result == null) {
5555                 result = buffer.toString();
5656             }
5757         } catch (Exception e) {
5858             // TODO: handle exception
5959             e.printStackTrace();
6060         } finally {
6161             // TODO: handle finally clause
6262             if (reader != null) {
6363                 reader.close();
6464             }
6565         }
6666         JSONObject jsonObj = JSONObject.fromObject(result);
6767         System.out.println(jsonObj);
6868         String typeName = "media_id";
6969         if (!"image".equals(type)) {
7070             typeName = type + "_mediaid";
7171         }
7272         String mediaId = jsonObj.getString(typeName);// 从json中获取media_id
7373         return mediaId;
7474 
7575     }

重写后的方法，直接反回我们需要的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次数上限了。中午睡觉忘了关项目。

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