专栏首页g歌德aJava微信公众平台开发(八)--多媒体消息回复之音乐

Java微信公众平台开发(八)--多媒体消息回复之音乐

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

下面我们进入代码阶段。

(一)修改消息转发器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("欢迎关注史上最帅公众号:\n\n ");
14             sb.append("1、歌德你好   \n\n ");
15             sb.append("2、听首歌吧   \n\n ");
16             sb.append("3、语音回复   \n\n ");
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("\r\n");
25         sb.append("Content -Di sposition: form-data ;name=\"file\";filename=\"" + file.getName() + "\"\r\n");
26         sb.append("Content - Type:applicat ion/octet-stream\r\n\r\n");
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 = ("\r\n--" + BOUNDARY + "--\r\n").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)

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • 三足鼎立 —— GPM 到底是什么?(一)

    G、P、M 是 Go 调度器的三个核心组件,各司其职。在它们精密地配合下,Go 调度器得以高效运转,这也是 Go 天然支持高并发的内在动力。今天这篇文章我们来深...

    梦醒人间
  • ES6模板字符串详细介绍

    这种方式,经常会有引号、加号多或者少的问题出现。写法相当繁琐不方便,ES6 引入了模板字符串解决这个问题:

    Javanx
  • MIT升级版“机器船”舰队:自主变形搭建动态桥梁

    近日,麻省理工学院(MIT)宣布,它的机器船舰队“Roboat”已经升级,具备了“变形”的新能力!

    新智元
  • Linux fork那些隐藏的开销

    fork是一个拥有50年历史的陈年系统调用,它是一个传奇!时至今日,它依旧灿烂。

    Linux阅码场
  • 源码分析 RocketMQ DLedger 多副本存储实现

    RocketMQ DLedger 的存储实现思路与 RocketMQ 的存储实现思路相似,本文就不再从源码角度详细剖析其实现,只是点出其实现关键点。我们不妨简单...

    丁威
  • JavaScript中如何使用递归?

    在JavaScript程序中,函数直接或间接调用自己。通过某个条件判断跳出结构,有了跳出才有结果。

    Javanx
  • ES6的这些操作技巧,你会吗?

    ES6提供了默认参数值机制,允许你为参数设置默认值,防止在函数被调用时没有传入这些参数。 在下面的例子中,我们写了一个required()函数作为参数a和b的默...

    Javanx
  • JAVA面试解析(有赞二面)

    本文的题目出自博客 http://www.54tianzhisheng.cn/2018/07/12/youzan/ 但是作者没有给出答案,博主斗胆来制作答案版。

    Java3y
  • 腾讯云推出一站式 DevOps 解决方案 —— CODING DevOps

    ? ---- 在产业互联网的大背景下,如何将人工智能、大数据等前沿技术与实体产业相结合,推动传统企业转型升级,已经成为每一个企业不得不思考的问题。落后的软件研...

    腾讯云serverless团队
  • 158行代码!程序员复现DeepMind图像生成神器

    递归神经网络是一种用于图像生成的神经网络结构。Draw Networks 结合了一种新的空间注意机制,该机制模拟了人眼的中心位置,采用了一个顺序变化的自动编码框...

    新智元

扫码关注云+社区

领取腾讯云代金券