devbox
花生_TL007
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

正式开始使用springboot进行微信公众号开发_springboot 微信公众号开发

作者：花生_TL007 | 2024-03-20 14:53:04

赞

踩

springboot 微信公众号开发

对公众号还没有一定的了解的，请先阅读此博客 使用springboot进行微信公众号开发的准备！_码上编程的博客-CSDN博客_springboot微信公众号开发   之后再来阅读此博客

此博客将手把手教你从0开始用springboot进行微信公众号的开发。当然了，这里只是介绍初步的使用以及学习方法，详细使用或者更深层次的使用，则详细阅读微信公众号官方文档， 官方文档就是最好的教材！！

官方文档: 微信公众平台开发概述 | 微信开放文档 

本项目的源代码在gitee中，使用git clone https://gitee.com/liu-wenxin/gongzhonghao.git即可下载

1、读取流的方式接受用户消息 

公众号发送对应的消息，详细信息类型请看官方文档

目标结果    可以发现是xml数据包

代码实现

  1. public class WeixinService {
  2.     /**
  3.      * 读取公众号发送过来的消息
  4.      * @param request
  5.      * @return
  6.      * @throws IOException
  7.      */
  8.     public static String getWeixinMessage(HttpServletRequest request) throws IOException {
  9.         ServletInputStream is = request.getInputStream();
  10.         byte[] b=new byte[1024];
  11.         int len;
  12.         StringBuilder sb=new StringBuilder();
  13.         while((len=is.read(b))!=-1){
  14.             sb.append(new String(b,0,len));
  15.         }
  16.         return sb.toString();
  17.     }
  18. }
  1. @RestController
  2. public class TestweixinController {
  3.  
  4.     @RequestMapping(value="/testWeixin",method = {RequestMethod.POST,RequestMethod.GET})
  5.     public void testWeixin(HttpServletRequest request, HttpServletResponse response) throws IOException {
  6.  
  7.         request.setCharacterEncoding("utf-8");
  8.         response.setCharacterEncoding("utf-8");
  9.         PrintWriter out = response.getWriter();
  10.  
  11.         String signature = request.getParameter("signature");
  12.         String timestamp = request.getParameter("timestamp");
  13.         String nonce = request.getParameter("nonce");
  14.         String echostr = request.getParameter("echostr");
  15.  
  16.         if(Utils.check(timestamp,nonce,signature)){
  17.             //校验正确并返回echostr，才能正式成为一名公众号开发者，即填写的URL和TOKEN才能生效
  18.             //out.print(echostr);
  19.  
  20.             //查看用户从公众号发送过来的信息
  21.             String result = WeixinService.getWeixinMessage(request);
  22.             System.out.println(result);
  23.         }else{
  24.             //校验失败
  25.             out.print("---请到公众号执行相应操作---");
  26.         }
  27.         out.flush();
  28.         out.close();
  29.     }
  30. }

2、将读取的xml数据映射成map数据格式

上述方式读取公众号发送过来的信息也没毛病，但是， 当我想要获取某个节点的值就显得不是那么灵活了，并且也不方便，能不能将xml数据映射出map数据，通过操作map方式去操作xml数据

答案是：  可以的！！！

需要导入的依赖:

  1. 	<!--解析xml数据-->
  2. 		<dependency>
  3. 			<groupId>dom4j</groupId>
  4. 			<artifactId>dom4j</artifactId>
  5. 			<version>1.6.1</version>
  6. 		</dependency>

代码实现:

  1. public class WeixinService {
  2.    
  3.     //以Map形式读取公众号的所有消息
  4.     public static Map<String, String> parseRequest(InputStream is) throws IOException {
  5.         //将输入流解析成Map
  6.         Map<String, String> map = new HashMap<>();
  7.         try {
  8.             //读取输入流获取文档对象
  9.             SAXReader reader = new SAXReader();
  10.             Document document = reader.read(is);
  11.  
  12.             //根据文档对象获取根节点
  13.             Element root = document.getRootElement();
  14.             //获取所有的子节点
  15.             List<Element> elements = root.elements();
  16.             for (Element e : elements) {
  17.                 map.put(e.getName(), e.getStringValue());
  18.             }
  19.  
  20.         } catch (DocumentException e) {
  21.             e.printStackTrace();
  22.         }
  23.         return map;
  24.     }
  25. }
  1. @RestController
  2. public class TestweixinController {
  3.  
  4.     @RequestMapping(value="/testWeixin",method = {RequestMethod.POST,RequestMethod.GET})
  5.     public void testWeixin(HttpServletRequest request, HttpServletResponse response) throws IOException {
  6.  
  7.         request.setCharacterEncoding("utf-8");
  8.         response.setCharacterEncoding("utf-8");
  9.         PrintWriter out = response.getWriter();
  10.  
  11.         String signature = request.getParameter("signature");
  12.         String timestamp = request.getParameter("timestamp");
  13.         String nonce = request.getParameter("nonce");
  14.         String echostr = request.getParameter("echostr");
  15.  
  16.         if(Utils.check(timestamp,nonce,signature)){
  17.             //校验正确并返回echostr，才能正式成为一名公众号开发者，即填写的URL和TOKEN才能生效
  18.             //out.print(echostr);
  19.  
  20.             //查看用户从公众号发送过来的信息
  21.             Map<String, String> requestMap=WeixinService.parseRequest(request.getInputStream());
  22.             System.out.println(requestMap);
  23.         }else{
  24.             //校验失败
  25.             out.print("---请到公众号执行相应操作---");
  26.         }
  27.         out.flush();
  28.         out.close();
  29.     }
  30. }

目标结果:

3、xml的字符串形式发送消息给用户

来而不往非礼也，用户发送信息了，可能焦急的等待公众号的回复！  通过阅读官方文档可得知，返回的数据类型也是xml数据包格式，每种类型都有严格的格式，比如:

回复文本消息

  1. <xml>
  2.   <ToUserName><![CDATA[toUser]]></ToUserName>
  3.   <FromUserName><![CDATA[fromUser]]></FromUserName>
  4.   <CreateTime>12345678</CreateTime>
  5.   <MsgType><![CDATA[text]]></MsgType>
  6.   <Content><![CDATA[你好]]></Content>
  7. </xml>

 回复图片消息

  1. <xml>
  2.   <ToUserName><![CDATA[toUser]]></ToUserName>
  3.   <FromUserName><![CDATA[fromUser]]></FromUserName>
  4.   <CreateTime>12345678</CreateTime>
  5.   <MsgType><![CDATA[image]]></MsgType>
  6.   <Image>
  7.     <MediaId><![CDATA[media_id]]></MediaId>
  8.   </Image>
  9. </xml>

代码实现

  1. public class WeixinService {
  2.  
  3.     //以Map形式读取公众号的所有消息
  4.     public static Map<String, String> parseRequest(InputStream is) throws IOException {
  5.         //将输入流解析成Map
  6.         Map<String, String> map = new HashMap<>();
  7.         try {
  8.             //读取输入流获取文档对象
  9.             SAXReader reader = new SAXReader();
  10.             Document document = reader.read(is);
  11.  
  12.             //根据文档对象获取根节点
  13.             Element root = document.getRootElement();
  14.             //获取所有的子节点
  15.             List<Element> elements = root.elements();
  16.             for (Element e : elements) {
  17.                 map.put(e.getName(), e.getStringValue());
  18.             }
  19.  
  20.         } catch (DocumentException e) {
  21.             e.printStackTrace();
  22.         }
  23.         return map;
  24.     }
  25. }

这里有个坑，发送的xml数据不能有空格 ，  还有发送方与接收方的逻辑， 原来的发送方现在要变成接收方，原来的接收方要变成发送方

  1. @RestController
  2. public class TestweixinController {
  3.  
  4.     @RequestMapping(value="/testWeixin",method = {RequestMethod.POST,RequestMethod.GET})
  5.     public void testWeixin(HttpServletRequest request, HttpServletResponse response) throws IOException {
  6.  
  7.         request.setCharacterEncoding("utf-8");
  8.         response.setCharacterEncoding("utf-8");
  9.         PrintWriter out = response.getWriter();
  10.  
  11.         String signature = request.getParameter("signature");
  12.         String timestamp = request.getParameter("timestamp");
  13.         String nonce = request.getParameter("nonce");
  14.         String echostr = request.getParameter("echostr");
  15.  
  16.         if(Utils.check(timestamp,nonce,signature)){
  17.             //校验正确并返回echostr，才能正式成为一名公众号开发者，即填写的URL和TOKEN才能生效
  18.             //out.print(echostr);
  19.  
  20.             //查看用户从公众号发送过来的信息
  21.             Map<String, String> requestMap=WeixinService.parseRequest(request.getInputStream());
  22.             System.out.println(requestMap);
  23.  
  24.             //返回 收到了！！！给用户
  25.             String respXml="<xml>\n" +
  26.                     "<ToUserName><![CDATA["+requestMap.get("FromUserName")+"]]></ToUserName>\n" +
  27.                     "<FromUserName><![CDATA["+requestMap.get("ToUserName")+"]]></FromUserName>\n" +
  28.                     "<CreateTime>12345678</CreateTime>\n" +
  29.                     "<MsgType><![CDATA[text]]></MsgType>\n" +
  30.                     "<Content><![CDATA["+"收到了！！！"+"]]></Content>\n" +
  31.                     "</xml>\n";
  32.  
  33.             out.print(respXml);
  34.         }else{
  35.             //校验失败
  36.             out.print("---请到公众号执行相应操作---");
  37.         }
  38.         out.flush();
  39.         out.close();
  40.     }
  41. }

目标结果

4、 将发送的数据解析成xml数据格式，通过操作对象的方式操作xml待返回的数据

上述方式也可以实现发送数据给用户，就是不灵活还有不方便，如果能通过操作对象的方式操作xml数据，那该有多好呀，  答案是可以实现的！！

导入的依赖

  1.  <!--将信息封装成xml数据-->
  2.         <dependency>
  3.             <groupId>com.thoughtworks.xstream</groupId>
  4.             <artifactId>xstream</artifactId>
  5.             <version>1.4.8</version>
  6.         </dependency>
  7.         <dependency>
  8.             <groupId>xmlpull</groupId>
  9.             <artifactId>xmlpull</artifactId>
  10.             <version>1.1.3.1</version>
  11.         </dependency>
  12.         <dependency>
  13.             <groupId>xpp3</groupId>
  14.             <artifactId>xpp3_min</artifactId>
  15.             <version>1.1.4c</version>
  16.         </dependency>

每种消息类型都含有 <ToUserName> <FromUserName> <CreateTime> <MsgType>

BaseMessage.java , 让所有的衍生类继承它，@XStreamAlias("xml")和@XStreamAlias("ToUserName") 解决映射成对象小写的问题

  1. /*
  2. * 所有消息的父类
  3. * */
  4. @Data
  5. @NoArgsConstructor
  6. @XStreamAlias("xml")
  7. public class BaseMessage {
  8.     @XStreamAlias("ToUserName")
  9.     private String toUserName;
  10.  
  11.     @XStreamAlias("FromUserName")
  12.     private String fromUserName;
  13.  
  14.     @XStreamAlias("CreateTime")
  15.     private String createTime;
  16.  
  17.     @XStreamAlias("MsgType")
  18.     private String msgType;
  19.  
  20.     public BaseMessage(Map<String,String> requestMap){
  21.         this.toUserName= (String) requestMap.get("FromUserName");
  22.         this.fromUserName= (String) requestMap.get("ToUserName");
  23.         this.createTime=System.currentTimeMillis()/1000+"";
  24.     }
  25. }

TextMessage.java

  1. @Data
  2. @XStreamAlias("xml")
  3. public class TextMessage extends BaseMessage {
  4.     @XStreamAlias("Content")
  5.     private String content;
  6.  
  7.     public TextMessage(Map<String, String> requestMap, String content){
  8.         //调用父类构造方法
  9.         super(requestMap);
  10.         //设置类型为文本类型
  11.         this.setMsgType("text");
  12.         this.content=content;
  13.     }
  14. }

 ImageMessage.java

  1. @Data
  2. @XStreamAlias("xml")
  3. public class ImageMessage extends BaseMessage {
  4.     @XStreamAlias("Image")
  5.     private Image image;
  6.  
  7.     public ImageMessage(Map<String,String> requestMap,Image image){
  8.         super(requestMap);
  9.         this.setMsgType("image");
  10.         this.image=image;
  11.     }
  12. }

Image.java 

  1. @XStreamAlias("Image")
  2. @AllArgsConstructor
  3. @Data
  4. public class Image {
  5.     @XStreamAlias("MediaId")
  6.     private String mediaId;
  7. }

  1. public class WeixinService {
  2.  
  3.     //以Map形式读取公众号的所有消息
  4.     public static Map<String, String> parseRequest(InputStream is) throws IOException {
  5.         //将输入流解析成Map
  6.         Map<String, String> map = new HashMap<>();
  7.         try {
  8.             //读取输入流获取文档对象
  9.             SAXReader reader = new SAXReader();
  10.             Document document = reader.read(is);
  11.  
  12.             //根据文档对象获取根节点
  13.             Element root = document.getRootElement();
  14.             //获取所有的子节点
  15.             List<Element> elements = root.elements();
  16.             for (Element e : elements) {
  17.                 map.put(e.getName(), e.getStringValue());
  18.             }
  19.  
  20.         } catch (DocumentException e) {
  21.             e.printStackTrace();
  22.         }
  23.         return map;
  24.     }
  25.  
  26.     /*
  27.    *封装公众号返回信息，用于处理所有的事件和消息的回复，返回的是xml数据包
  28.    * */
  29.     public static String getResponse(Map<String, String> requestMap) {
  30.         BaseMessage msg = null;
  31.         //获取用户发送消息的类型
  32.         String msgType = (String) requestMap.get("MsgType");
  33.         switch (msgType) {
  34.             case "text":
  35.                 //处理文本类型
  36.                 msg = dealTextMessage(requestMap);
  37.                 //将图文信息转成xml数据包
  38.                 //msg=dealNewsMessage(requestMap);
  39.                 //System.out.println("---返回文字类型数据---");
  40.                 break;
  41.             case "image":
  42.                 //处理图片信息
  43.                 msg = dealImageMessage(requestMap);
  44.                 break;
  45.             default:
  46.                 break;
  47.         }
  48.         if (msg != null) {
  49.             //将信息转成xml数据包
  50.             return beanToXml(msg);
  51.         }
  52.         return null;
  53.     }
  54.  
  55.     /*
  56.   * 把消息对象转成xml数据
  57.   * */
  58.     private static String beanToXml(BaseMessage msg) {
  59.         XStream stream = new XStream();
  60.         /*
  61.         * 使对应类上的注解生效
  62.         * */
  63.         stream.processAnnotations(BaseMessage.class);
  64.         stream.processAnnotations(TextMessage.class);
  65.         stream.processAnnotations(ImageMessage.class);
  66.         String xml = stream.toXML(msg);
  67.         return xml;
  68.     }
  69.  
  70.     /*
  71.    * 专门处理文本消息
  72.    * */
  73.     private static BaseMessage dealTextMessage(Map<String, String> requestMap) {
  74.         TextMessage textMessage=new TextMessage(requestMap,"成功获取消息!!!");
  75.        return textMessage;
  76.     }
  77.  
  78.     /*
  79.   *
  80.   *专门处理回复图片消息 requestMap是从用户从公众号发过来的数据
  81.   * */
  82.     private static BaseMessage dealImageMessage(Map<String, String> requestMap) {
  83.         return null;
  84.     }
  85.  
  86. }

  1. @RestController
  2. public class TestweixinController {
  3.  
  4.     @RequestMapping(value="/testWeixin",method = {RequestMethod.POST,RequestMethod.GET})
  5.     public void testWeixin(HttpServletRequest request, HttpServletResponse response) throws IOException {
  6.  
  7.         request.setCharacterEncoding("utf-8");
  8.         response.setCharacterEncoding("utf-8");
  9.         PrintWriter out = response.getWriter();
  10.  
  11.         String signature = request.getParameter("signature");
  12.         String timestamp = request.getParameter("timestamp");
  13.         String nonce = request.getParameter("nonce");
  14.         String echostr = request.getParameter("echostr");
  15.  
  16.         if(Utils.check(timestamp,nonce,signature)){
  17.             //校验正确并返回echostr，才能正式成为一名公众号开发者，即填写的URL和TOKEN才能生效
  18.             //out.print(echostr);
  19.  
  20.             //查看用户从公众号发送过来的信息
  21.             Map<String, String> requestMap=WeixinService.parseRequest(request.getInputStream());
  22.  
  23.             //返回信息给用户
  24.             String resXml = WeixinService.getResponse(requestMap);
  25.             out.print(resXml);
  26.         }else{
  27.             //校验失败
  28.             out.print("---请到公众号执行相应操作---");
  29.         }
  30.         out.flush();
  31.         out.close();
  32.     }
  33. }

目标效果

5、获取access_token

有了access_token才能进行其它操作，比如素材管理、自定义菜单

记得将TOKEN、APPID、APPSECRET改成自己的值

代码部分

  1. public class Utils {
  2.  
  3.     public static final String TOKEN="aabbccdd";    //TOKEN就是自己填写的
  4.     public static final String APPID="wx18d322f947cdf313";
  5.     public static final String APPSECRET="addf7e78f784c940ce69557cbe58b31b";
  6.  
  7.     //用于存储access_token
  8.     private static AccessToken at;
  9.  
  10.     /*
  11.    * 获取accessToken，有效期2小时
  12.    * */
  13.     private static void getToken() {
  14.  
  15.         String url = " https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential";
  16.         String result = "";
  17.         BufferedReader in = null;
  18.         try {
  19.             String urlNameString = url + "&appid=" + APPID + "&secret=" + APPSECRET;
  20.             URL realUrl = new URL(urlNameString);
  21.  
  22.             // 打开和URL之间的连接
  23.             URLConnection connection = realUrl.openConnection();
  24.  
  25.             // 设置通用的请求属性
  26.             connection.setRequestProperty("accept", "*/*");
  27.             connection.setRequestProperty("connection", "Keep-Alive");
  28.             connection.setRequestProperty("Accept-Charset", "utf-8");
  29.             connection.setRequestProperty("user-agent", "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)");
  30.             // 建立实际的连接
  31.             connection.connect();
  32.  
  33.             // 获取所有响应头字段
  34.             Map<String, List<String>> map = connection.getHeaderFields();
  35.  
  36.             // 定义 BufferedReader输入流来读取URL的响应
  37.             in = new BufferedReader(new InputStreamReader(
  38.                     connection.getInputStream(),"utf-8"));
  39.             String line;
  40.             while ((line = in.readLine()) != null) {
  41.                 result += line;
  42.             }
  43.  
  44.         } catch (Exception e) {
  45.             System.out.println("发送GET请求出现异常！" + e);
  46.             e.printStackTrace();
  47.         }
  48.  
  49.         // 使用finally块来关闭输入流
  50.         finally {
  51.             try {
  52.                 if (in != null) {
  53.                     in.close();
  54.                 }
  55.             } catch (Exception e2) {
  56.                 e2.printStackTrace();
  57.             }
  58.         }
  59.  
  60.  
  61.         Gson gson = new Gson();
  62.         HashMap hashMap = gson.fromJson(result, HashMap.class);
  63.         String access_token = (String) hashMap.get("access_token");
  64.         Double expires_in = (Double) hashMap.get("expires_in");
  65.         //创建access_token，并存起来
  66.         at = new AccessToken(access_token, expires_in);
  67.     }
  68.  
  69.     /*
  70.     * 获取access_token的方法    直接HttpRequest.getAccessToken()即可返回access_token值
  71.     * */
  72.     public static String getAccessToken() {
  73.         if (at == null || at.isExpired()) {
  74.             //过期则创建新的access_token
  75.             getToken();
  76.         }
  77.         //返回access_token
  78.         return at.getAccess_token();
  79.     }
  80.  
  81.     /*
  82.    * 验证签名
  83.    * */
  84.     public static boolean check(String timestamp, String nonce, String signature) {
  85.  
  86.         //1、将token、timestamp、nonce进行字典排序
  87.         String[] strs = new String[]{TOKEN, timestamp, nonce};
  88.         Arrays.sort(strs);
  89.  
  90.         //2、将三个参数字符串拼接成一个字符串进行sha1加密
  91.         String str = strs[0] + strs[1] + strs[2];
  92.         String mysignature = sha1(str);
  93.  
  94.         //返回对比结果
  95.         return mysignature.equalsIgnoreCase(signature);
  96.     }
  97.  
  98.     /*
  99.      * 加密方法
  100.      * */
  101.     private static String sha1(String src) {
  102.  
  103.         try {
  104.             //获取一个加密对象
  105.             MessageDigest md = MessageDigest.getInstance("sha1");
  106.             //加密
  107.             byte[] digest = md.digest(src.getBytes());
  108.             char[] chars = {'0', '1', '2', '3', '4', '5', '6', '7', '8', '9', 'a', 'b', 'c', 'd', 'e', 'f'};
  109.             StringBuffer sb = new StringBuffer();
  110.             //处理结果集
  111.             for (byte b : digest) {
  112.                 sb.append(chars[(b >> 4) & 15]);
  113.                 sb.append(chars[b & 15]);
  114.             }
  115.             return sb.toString();
  116.         } catch (NoSuchAlgorithmException e) {
  117.             e.printStackTrace();
  118.         }
  119.         return null;
  120.     }
  121. }
  1. @SpringBootTest
  2. class GongzhonghaoApplicationTests {
  3.  
  4. 	@Test
  5. 	void contextLoads() {
  6.         System.out.println("---access_token---\n"+ Utils.getAccessToken());
  7.     }
  8.  
  9. }

目标结果

6、自定义菜单

无论是点击菜单、二级菜单、视图菜单，都有一个name的属性, 菜单的刷新需要你先取消关注公众号，然后在重新关注才能看到效果

  1. @Data
  2. @AllArgsConstructor
  3. public abstract class AbstractButon {
  4.     private String name;
  5. }

官网要求的菜单类型数据

  1. {
  2.      "button":[
  3.      {	
  4.           "type":"click",
  5.           "name":"今日歌曲",
  6.           "key":"V1001_TODAY_MUSIC"
  7.       },
  8.       {
  9.            "name":"菜单",
  10.            "sub_button":[
  11.            {	
  12.                "type":"view",
  13.                "name":"搜索",
  14.                "url":"http://www.soso.com/"
  15.             },
  16.             {
  17.                  "type":"miniprogram",
  18.                  "name":"wxa",
  19.                  "url":"http://mp.weixin.qq.com",
  20.                  "appid":"wx286b93c14bbf93aa",
  21.                  "pagepath":"pages/lunar/index"
  22.              },
  23.             {
  24.                "type":"click",
  25.                "name":"赞一下我们",
  26.                "key":"V1001_GOOD"
  27.             }]
  28.        }]
  29.  }

  1.  
  2. @Data
  3. public class Button {
  4.     private List<AbstractButon> button=new ArrayList<>();
  5. }

点击菜单

  1. public class ClickButton extends AbstractButon {
  2.     private String type="click";
  3.     private String key;
  4.  
  5.     public ClickButton(String name,String key){
  6.         super(name);
  7.         this.key=key;
  8.     }
  9.  
  10.     public String getType() {
  11.         return type;
  12.     }
  13.  
  14.     public void setType(String type) {
  15.         this.type = type;
  16.     }
  17.  
  18.     public String getKey() {
  19.         return key;
  20.     }
  21.  
  22.     public void setKey(String key) {
  23.         this.key = key;
  24.     }
  25. }

二级菜单

  1. public class SubButton extends AbstractButon {
  2.     private List<AbstractButon> sub_button=new ArrayList<>();
  3.  
  4.     public SubButton(String name){
  5.         super(name);
  6.     }
  7.  
  8.     public List<AbstractButon> getSub_button() {
  9.         return sub_button;
  10.     }
  11.  
  12.     public void setSub_button(List<AbstractButon> sub_button) {
  13.         this.sub_button = sub_button;
  14.     }
  15. }

发送post请求的方法:

  1.  /**
  2.      * 发送post请求
  3.      * @param url 地址
  4.      * @param data 参数
  5.      * @return
  6.      */
  7.     public static String post(String url,String data){
  8.         BufferedReader in = null;
  9.         String result="";
  10.         try {
  11.             URL urlObj=new URL(url);
  12.             URLConnection connection=urlObj.openConnection();
  13.  
  14.             //设置可发送状态
  15.             connection.setDoOutput(true);
  16.             connection.setDoInput(true);
  17.             connection.setRequestProperty("connection", "Keep-Alive");
  18.             connection.setRequestProperty("Accept-Charset", "utf-8");
  19.             connection.setRequestProperty("user-agent", "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)");
  20.  
  21.             //获取输出流
  22.             OutputStream os=connection.getOutputStream();
  23.             //写出数据
  24.             os.write(data.getBytes("UTF-8"));
  25.             os.close();
  26.  
  27.             //获取输入流
  28.             in = new BufferedReader(new InputStreamReader(connection.getInputStream(), "UTF-8"));
  29.             String line;
  30.             while ((line = in.readLine()) != null) {
  31.                 result += line;
  32.             }
  33.             in.close();
  34.             os.close();
  35.             return result.toString();
  36.         } catch (Exception e) {
  37.             e.printStackTrace();
  38.         }
  39.  
  40.         return null;
  41.     }

测试

  1. @SpringBootTest
  2. class GongzhonghaoApplicationTests {
  3.  
  4. 	@Test
  5. 	void contextLoads() {
  6.  
  7.         //一级菜单
  8.         Button btn = new Button();
  9.         btn.getButton().add(new ClickButton("一级菜单","1"));
  10.  
  11.         //二级菜单
  12.         SubButton sb2=new SubButton("二级菜单");
  13.         sb2.getSub_button().add(new ClickButton("1","21"));
  14.         sb2.getSub_button().add(new ClickButton("2","22"));
  15.         btn.getButton().add(sb2);
  16.  
  17.  
  18.         Gson gson = new Gson();
  19.  
  20.         //向指定的url发送post请求，并携带上access_token和菜单数据
  21.         String url="https://api.weixin.qq.com/cgi-bin/menu/create?access_token=ACCESS_TOKEN";
  22.         url=url.replace("ACCESS_TOKEN",Utils.getAccessToken());
  23.  
  24.         //返回结果集
  25.         String result = Utils.post(url, gson.toJson(btn));
  26.         System.out.println("---result---\n"+result);
  27.     }
  28.  
  29. }

目标结果

 

 

7、菜单事件

上述菜单虽然有了，但是点击却没有任何响应，这时需要为它添上事件处理！  菜单事件类型有click(点击事件)、view(跳转链接事件)、scancode_push(扫码推事件)、view_miniprogram(跳转小程序事件)等等，详情请看官方文档。

代码部分

  1. public class WeixinService {
  2.  
  3.     //以Map形式读取公众号的所有消息
  4.     public static Map<String, String> parseRequest(InputStream is) throws IOException {
  5.         //将输入流解析成Map
  6.         Map<String, String> map = new HashMap<>();
  7.         try {
  8.             //读取输入流获取文档对象
  9.             SAXReader reader = new SAXReader();
  10.             Document document = reader.read(is);
  11.  
  12.             //根据文档对象获取根节点
  13.             Element root = document.getRootElement();
  14.             //获取所有的子节点
  15.             List<Element> elements = root.elements();
  16.             for (Element e : elements) {
  17.                 map.put(e.getName(), e.getStringValue());
  18.             }
  19.  
  20.         } catch (DocumentException e) {
  21.             e.printStackTrace();
  22.         }
  23.         return map;
  24.     }
  25.  
  26.     /*
  27.    *封装公众号返回信息，用于处理所有的事件和消息的回复，返回的是xml数据包
  28.    * */
  29.     public static String getResponse(Map<String, String> requestMap) {
  30.         BaseMessage msg = null;
  31.         //获取用户发送消息的类型
  32.         String msgType = (String) requestMap.get("MsgType");
  33.         switch (msgType) {
  34.             case "text":
  35.                 //处理文本类型
  36.                 msg = dealTextMessage(requestMap);
  37.                 //将图文信息转成xml数据包
  38.                 //msg=dealNewsMessage(requestMap);
  39.                 //System.out.println("---返回文字类型数据---");
  40.                 break;
  41.             case "image":
  42.                 //处理图片信息
  43.                 msg = dealImageMessage(requestMap);
  44.                 break;
  45.             case "event":
  46.                 //处理事件
  47.                 msg = dealEvent(requestMap);
  48.                 break;
  49.             default:
  50.                 break;
  51.         }
  52.         if (msg != null) {
  53.             //将信息转成xml数据包
  54.             return beanToXml(msg);
  55.         }
  56.         return null;
  57.     }
  58.  
  59.     /**
  60.      * 判断菜单栏事件
  61.      * @param requestMap
  62.      * @return
  63.      */
  64.     private static BaseMessage dealEvent(Map<String, String> requestMap) {
  65.         //判断什么事件
  66.         String event = requestMap.get("Event");
  67.         switch (event){
  68.             case "CLICK":
  69.                 //详细处理点击事件
  70.                 return dealClick(requestMap);
  71.             default:
  72.                 //其它事件
  73.                 break;
  74.         }
  75.         return null;
  76.     }
  77.  
  78.     /**
  79.      * 专门处理点击事件
  80.      * @param requestMap
  81.      * @return
  82.      */
  83.     private static BaseMessage dealClick(Map<String, String> requestMap) {
  84.         //获取创建菜单时填的key值
  85.         String key = requestMap.get("EventKey");
  86.         switch (key){
  87.             case "1":
  88.                 //点击一级菜单
  89.                 return new TextMessage(requestMap,"点击了一级菜单");
  90.             case "21":
  91.                 //点击二级菜单的1
  92.                 return new TextMessage(requestMap,"点击二级菜单的1");
  93.             case "22":
  94.                 //点击二级菜单的2
  95.                 return new TextMessage(requestMap,"点击二级菜单的2");
  96.             default:
  97.                 break;
  98.         }
  99.         return null;
  100.     }
  101.  
  102.     /*
  103.   * 把消息对象转成xml数据
  104.   * */
  105.     private static String beanToXml(BaseMessage msg) {
  106.         XStream stream = new XStream();
  107.         /*
  108.         * 使对应类上的注解生效
  109.         * */
  110.         stream.processAnnotations(BaseMessage.class);
  111.         stream.processAnnotations(TextMessage.class);
  112.         stream.processAnnotations(ImageMessage.class);
  113.         String xml = stream.toXML(msg);
  114.         return xml;
  115.     }
  116.  
  117.     /*
  118.    * 专门处理文本消息
  119.    * */
  120.     private static BaseMessage dealTextMessage(Map<String, String> requestMap) {
  121.         TextMessage textMessage=new TextMessage(requestMap,"成功获取消息!!!");
  122.        return textMessage;
  123.     }
  124.  
  125.     /*
  126.   *
  127.   *专门处理回复图片消息 requestMap是从用户从公众号发过来的数据
  128.   * */
  129.     private static BaseMessage dealImageMessage(Map<String, String> requestMap) {
  130.         return null;
  131.     }
  132.  
  133. }
  1. @RestController
  2. public class TestweixinController {
  3.  
  4.     @RequestMapping(value="/testWeixin",method = {RequestMethod.POST,RequestMethod.GET})
  5.     public void testWeixin(HttpServletRequest request, HttpServletResponse response) throws IOException {
  6.  
  7.         request.setCharacterEncoding("utf-8");
  8.         response.setCharacterEncoding("utf-8");
  9.         PrintWriter out = response.getWriter();
  10.  
  11.         String signature = request.getParameter("signature");
  12.         String timestamp = request.getParameter("timestamp");
  13.         String nonce = request.getParameter("nonce");
  14.         String echostr = request.getParameter("echostr");
  15.  
  16.         if(Utils.check(timestamp,nonce,signature)){
  17.             //校验正确并返回echostr，才能正式成为一名公众号开发者，即填写的URL和TOKEN才能生效
  18.             //out.print(echostr);
  19.  
  20.             //查看用户从公众号发送过来的信息
  21.             Map<String, String> requestMap=WeixinService.parseRequest(request.getInputStream());
  22.  
  23.             //返回信息给用户
  24.             String resXml = WeixinService.getResponse(requestMap);
  25.             out.print(resXml);
  26.         }else{
  27.             //校验失败
  28.             out.print("---请到公众号执行相应操作---");
  29.         }
  30.         out.flush();
  31.         out.close();
  32.     }
  33. }

目标结果

微信公众号基础开发已经结束了！！！   不要光看，需要多练多看官方文档！！

 本项目的源代码在gitee中，使用git clone https://gitee.com/liu-wenxin/gongzhonghao.git即可下载

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/花生_TL007/article/detail/274291
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号