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

Java后端发送微信小程序模板订阅消息_微信小程序发送订阅消息使用java

作者：在线问答5 | 2024-07-19 04:30:18

赞

踩

微信小程序发送订阅消息使用java

申请注册账号

第一步：首先你需要在微信公众平台 (qq.com)注册一个小程序个人测试账号，然后在首页发布一个小程序成功后如图：

然后就会产生一个小程序的appId和密钥，这两个东西是产生AccessToken和openId的关键点击开发中的开发管理，然后如图查看自己小程序的appId和密钥，密钥的话重置一下就看到了:

 第二步：点击你的订阅消息然后里面有添加模板然然后根据自己的业务需求添加模板或者使用现成的模板就可以产生一模板ID这这个ID发送消息的时候需要，如图：

Java后端发送

第三步：后端代码附上：

myHttpRequesUtil是微信发送工具

  1. package com.longdatech.decryptcode.utils;
  2.  
  3. import java.io.*;
  4. import java.net.URL;
  5. import java.net.URLConnection;
  6. import java.net.URLEncoder;
  7. import java.util.List;
  8. import java.util.Map;
  9.  
  10. /**
  11.  * @author: qiaolu
  12.  * @date 2023/4/7 12:51
  13.  */
  14. public class MyHttpRequestUtil {
  15.  
  16.  
  17.     /**
  18.      * 向指定URL发送GET方法的请求
  19.      *
  20.      * @param url   发送请求的URL
  21.      * @param param 请求参数，请求参数应该是 name1=value1&name2=value2 的形式。
  22.      * @return URL 所代表远程资源的响应结果
  23.      */
  24.     public static String sendGet(String url, String param) {
  25.         String result = "";
  26.         BufferedReader in = null;
  27.         try {
  28.             String urlNameString = url + "?" + param;
  29.             URL realUrl = new URL(urlNameString);
  30.             System.out.println(realUrl);
  31.             // 打开和URL之间的连接
  32.             URLConnection connection = realUrl.openConnection();
  33.             // 设置通用的请求属性
  34.             connection.setRequestProperty("accept", "*/*");
  35.             connection.setRequestProperty("connection", "Keep-Alive");
  36.             connection.setRequestProperty("user-agent",
  37.                     "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)");
  38.             // 建立实际的连接
  39.             connection.connect();
  40.             // 获取所有响应头字段
  41.             Map<String, List<String>> map = connection.getHeaderFields();
  42.             // 遍历所有的响应头字段
  43.            /* for (String key : map.keySet()) {
  44.                 System.out.println(key + "--->" + map.get(key));
  45.             }*/
  46.             // 定义 BufferedReader输入流来读取URL的响应
  47.             in = new BufferedReader(new InputStreamReader(
  48.                     connection.getInputStream()));
  49.             String line;
  50.             while ((line = in.readLine()) != null) {
  51.                 result += line;
  52.             }
  53.         } catch (Exception e) {
  54.             System.out.println("发送GET请求出现异常！" + e);
  55.             e.printStackTrace();
  56.         }
  57.         // 使用finally块来关闭输入流
  58.         finally {
  59.             try {
  60.                 if (in != null) {
  61.                     in.close();
  62.                 }
  63.             } catch (Exception e2) {
  64.                 e2.printStackTrace();
  65.             }
  66.         }
  67.         return result;
  68.     }
  69.  
  70.     /**
  71.      * @description
  72.      * @author: qiaolu
  73.      * @date 2023/4/7 12:51
  74.      * @param url
  75.      * @return
  76.      */
  77.     public static String sendGet(String url) {
  78.         String result = "";
  79.         BufferedReader in = null;
  80.         try {
  81.             String urlNameString = url;
  82.             URL realUrl = new URL(urlNameString);
  83.             System.out.println(realUrl);
  84.             // 打开和URL之间的连接
  85.             URLConnection connection = realUrl.openConnection();
  86.             // 设置通用的请求属性
  87.             connection.setRequestProperty("accept", "*/*");
  88.             connection.setRequestProperty("connection", "Keep-Alive");
  89.             connection.setRequestProperty("user-agent",
  90.                     "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)");
  91.             // 建立实际的连接
  92.             connection.connect();
  93.             // 获取所有响应头字段
  94.             Map<String, List<String>> map = connection.getHeaderFields();
  95.             // 遍历所有的响应头字段
  96.            /* for (String key : map.keySet()) {
  97.                 System.out.println(key + "--->" + map.get(key));
  98.             }*/
  99.             // 定义 BufferedReader输入流来读取URL的响应
  100.             in = new BufferedReader(new InputStreamReader(
  101.                     connection.getInputStream()));
  102.             String line;
  103.             while ((line = in.readLine()) != null) {
  104.                 result += line;
  105.             }
  106.         } catch (Exception e) {
  107.             System.out.println("发送GET请求出现异常！" + e);
  108.             e.printStackTrace();
  109.         }
  110.         // 使用finally块来关闭输入流
  111.         finally {
  112.             try {
  113.                 if (in != null) {
  114.                     in.close();
  115.                 }
  116.             } catch (Exception e2) {
  117.                 e2.printStackTrace();
  118.             }
  119.         }
  120.         return result;
  121.     }
  122.  
  123.     /**
  124.      * 向指定 URL 发送POST方法的请求
  125.      *
  126.      * @param url   发送请求的 URL
  127.      * @param param 请求参数，请求参数应该是 name1=value1&name2=value2 的形式。
  128.      * @return 所代表远程资源的响应结果
  129.      */
  130.     public static String sendPost(String url, String param) {
  131.         PrintWriter out = null;
  132.         BufferedReader in = null;
  133.         String result = "";
  134.         try {
  135.             URL realUrl = new URL(url);
  136.             // 打开和URL之间的连接
  137.             URLConnection conn = realUrl.openConnection();
  138.             // 设置通用的请求属性
  139.             conn.setRequestProperty("accept", "*/*");
  140.             conn.setRequestProperty("connection", "Keep-Alive");
  141.             conn.setRequestProperty("user-agent",
  142.                     "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)");
  143.             // 发送POST请求必须设置如下两行
  144.             conn.setDoOutput(true);
  145.             conn.setDoInput(true);
  146.             // 获取URLConnection对象对应的输出流
  147.             out = new PrintWriter(conn.getOutputStream());
  148.             // 发送请求参数
  149.             out.print(param);
  150.             // flush输出流的缓冲
  151.             out.flush();
  152.             // 定义BufferedReader输入流来读取URL的响应
  153.             in = new BufferedReader(
  154.                     new InputStreamReader(conn.getInputStream()));
  155.             String line;
  156.             while ((line = in.readLine()) != null) {
  157.                 result += line;
  158.             }
  159.         } catch (Exception e) {
  160.             System.out.println("发送 POST 请求出现异常！" + e);
  161.             e.printStackTrace();
  162.         }
  163.         //使用finally块来关闭输出流、输入流
  164.         finally {
  165.             try {
  166.                 if (out != null) {
  167.                     out.close();
  168.                 }
  169.                 if (in != null) {
  170.                     in.close();
  171.                 }
  172.             } catch (IOException ex) {
  173.                 ex.printStackTrace();
  174.             }
  175.         }
  176.         return result;
  177.     }
  178.     public static String getUserUathUrl(String appid, String redirectUrl) throws UnsupportedEncodingException {
  179.         StringBuffer getcodeUrl = new StringBuffer()
  180.                 .append("https://open.weixin.qq.com/connect/oauth2/authorize")
  181.                 .append("?appid=" + appid)
  182.                 .append("&redirect_uri=" + URLEncoder.encode(redirectUrl, "utf-8"))
  183.                 .append("&response_type=code")
  184.                 .append("&scope=snsapi_userinfo")
  185.                 .append("&state=" + System.currentTimeMillis())
  186.                 .append("#wechat_redirect");
  187.  
  188.         return getcodeUrl.toString();
  189.     }
  190. }

 WxVo类是根据微信api模板消息发送需要参数的实体类

  1. package com.longdatech.decryptcode.utils;
  2.  
  3. import com.alibaba.fastjson.JSONObject;
  4. import lombok.Data;
  5.  
  6. /**
  7.  * @author qiaolu
  8.  * @date 2023/4/7 12:51
  9.  */
  10. @Data
  11. public class WxVo {
  12.     private String touser;
  13.     private String template_id;
  14.     private String page;
  15.     private String access_token;
  16.     private String request_url;
  17.     private String miniprogram_stat;
  18.     private String lang;
  19.     private JSONObject data;
  20.  
  21. }
  1. package com.longdatech.decryptcode.utils;
  2.  
  3. import com.alibaba.fastjson.JSONObject;
  4. import lombok.extern.slf4j.Slf4j;
  5. import org.springframework.stereotype.Component;
  6. import org.springframework.web.client.RestTemplate;
  7.  
  8. import java.io.BufferedReader;
  9. import java.io.IOException;
  10. import java.io.InputStreamReader;
  11. import java.io.PrintWriter;
  12. import java.net.URL;
  13. import java.net.URLConnection;
  14.  
  15. /**
  16.  * @author qiaolu
  17.  * @date 2023/4/7 12:51
  18.  */
  19. @Slf4j(topic = "WxchatSendUtil")
  20. @Component
  21. public class WxchatSendUtil {
  22.  
  23. //    @Value("${bussiness.appId}")
  24.     private static String appId = "你自己的appId";
  25. //    @Value("${bussiness.secret}")
  26.     private static String secret = "你自己的密钥";
  27. //    @Value("${bussiness.orderPlacementNoticeTemplateId}")
  28.     private static String orderPlacementNoticeTemplateId = "你自己的模板Id";
  29.  
  30.     /**
  31.      * 获取小程序token
  32.      *
  33.      * @return
  34.      */
  35.     public static String getAccessToken() {
  36.         String url = "https://api.weixin.qq.com/cgi-bin/token?" +
  37.                 "appid=" + appId + "&secret=" + secret + "&grant_type=client_credential";
  38.         PrintWriter out = null;
  39.         BufferedReader in = null;
  40.         String line;
  41.         StringBuffer stringBuffer = new StringBuffer();
  42.         try {
  43.             URL realUrl = new URL(url);
  44.             // 打开和URL之间的连接
  45.             URLConnection conn = realUrl.openConnection();
  46.  
  47.             // 设置通用的请求属性 设置请求格式
  48.             //设置返回类型
  49.             conn.setRequestProperty("contentType", "text/plain");
  50.             //设置请求类型
  51.             conn.setRequestProperty("content-type", "application/x-www-form-urlencoded");
  52.             //设置超时时间
  53.             conn.setConnectTimeout(1000);
  54.             conn.setReadTimeout(1000);
  55.             conn.setDoOutput(true);
  56.             conn.connect();
  57.             // 获取URLConnection对象对应的输出流
  58.             out = new PrintWriter(conn.getOutputStream());
  59.             // flush输出流的缓冲
  60.             out.flush();
  61.             // 定义BufferedReader输入流来读取URL的响应    设置接收格式
  62.             in = new BufferedReader(
  63.                     new InputStreamReader(conn.getInputStream(), "UTF-8"));
  64.             while ((line = in.readLine()) != null) {
  65.                 stringBuffer.append(line);
  66.             }
  67.             JSONObject jsonObject = JSONObject.parseObject(stringBuffer.toString());
  68.             return jsonObject.getString("access_token");
  69.  
  70.         } catch (Exception e) {
  71.             e.printStackTrace();
  72.         }
  73.         //使用finally块来关闭输出流、输入流
  74.         finally {
  75.             try {
  76.                 if (out != null) {
  77.                     out.close();
  78.                 }
  79.                 if (in != null) {
  80.                     in.close();
  81.                 }
  82.             } catch (IOException ex) {
  83.                 ex.printStackTrace();
  84.             }
  85.         }
  86.         return null;
  87.     }
  88.  
  89.     public static final String SEND_INFO_URL = "https://api.weixin.qq.com/cgi-bin/message/subscribe/send?access_token=";
  90.  
  91.     public static void main(String[] args) throws IOException {
  92.         // 1、获取 接口调用凭证
  93.         RestTemplate restTemplate = new RestTemplate();
  94.         String url = SEND_INFO_URL + WxchatSendUtil.getAccessToken();
  95.         System.out.println("s:" + WxchatSendUtil.getAccessToken());
  96.         //拼接推送的模版
  97.         WxVo wxMssVo = new WxVo();
  98.         //用户的openId
  99.         wxMssVo.setTouser("osCmN4mokDtVkfcipnhaRC1J3_qY");
  100.         //订阅消息模板id
  101.         wxMssVo.setTemplate_id(orderPlacementNoticeTemplateId);
  102.         wxMssVo.setPage("index");
  103.         wxMssVo.setMiniprogram_stat("developer");
  104.         wxMssVo.setLang("zh_CN");
  105.         JSONObject m = new JSONObject();
  106.         JSONObject object1 = new JSONObject();
  107.         JSONObject object2 = new JSONObject();
  108.         JSONObject object3 = new JSONObject();
  109.         JSONObject object4 = new JSONObject();
  110. //下面的key是固定的就是"value"自己看接口api然后下面的val值就是发送的内容
  111.         object1.put("value", "154956559599");
  112.         object2.put("value", "eri0g9i9");
  113.         object3.put("value", "30");
  114.         object4.put("value", "30");
  115. //自己看自己小程序中生成的模板参数然后然后替换我写的key值
  116.         m.put("number2", object1);
  117.         m.put("thing1", object2);
  118.         m.put("amount3", object3);
  119.         m.put("amount4", object4);
  120.         wxMssVo.setData(m);
  121.         MyHttpRequestUtil.sendPost(url, JSONObject.toJSONString(wxMssVo));
  122.         System.out.println(MyHttpRequestUtil.sendPost(url, JSONObject.toJSONString(wxMssVo)));
  123.     }
  124. }
  125.

到此返回的对象中code为0就是发送成功。

自己手机测试

如果想在自己手机上测试那就必须要下载微信开发工具：微信开放文档如图：

使用微信开发工具登录自己在注册的小程序账号然后生成appjs中复制下面一段代码，不过要在代码中更改自己的模板Id,代码附上

  1. // app.js
  2. App({
  3.     onLaunch() {
  4.     
  5.       // 展示本地存储能力
  6.       const logs = wx.getStorageSync('logs') || []
  7.       logs.unshift(Date.now())
  8.       wx.setStorageSync('logs', logs)
  9.        wx.showModal({
  10.               title: '提示',
  11.               content:'请授权开通服务通知',
  12.               showCancel: true,
  13.               success: function (ress) {
  14.                 if (ress.confirm) { 
  15.                   // console.log('用户点击确定')
  16.                   wx.requestSubscribeMessage({   // 调起消息订阅界面
  17.                     tmplIds: ['自己的模板Id'],
  18.                     success (res) { 
  19.                       console.log('订阅消息 成功 ');
  20.                       console.log(res);
  21.                     },
  22.                     fail (er){
  23.                       console.log("订阅消息 失败 ");
  24.                       console.log(er);
  25.                     }
  26.                   })     
  27.                        
  28.                 } else if (ress.cancel) {
  29.                   // console.log('用户点击取消')
  30.                 }
  31.               }
  32.             })
  33.       // 登录 
  34.       wx.login({
  35.         success: res => {
  36.           // 发送 res.code 到后台换取 openId, sessionKey, unionId
  37.          
  38.           console.log(res.code)
  39.         }
  40.       })
  41.     },
  42.     globalData: {
  43.       userInfo: null
  44.     }
  45.   })

 然后你就消息订阅成功，然后代码会返回一个code值如图：

最后拿着你的code值去生成当前小程序的openId就可以返回上面发送代码进行发送，生成openId代码附上：

  1.  public String decryptCode(@RequestParam String code){
  2.         log.info("1.0：解密code===>code:" + code);
  3.         String result = MyHttpRequestUtil.sendGet(WxConstant.getDesryptCodeUri(code));
  4.         JSONObject ojb = JSONObject.parseObject(result);
  5.         System.out.println("返回结果:" + ojb);
  6.         Set<String> keys = ojb.keySet();
  7.         keys.forEach(item->{
  8.             System.out.println(item + ":" + ojb.get(item));
  9.         });
  10.         System.out.println(ojb.getString("openid"));
  11.         return ojb.getString("openid");
  12.  
  13.     }

 就可以如图收到消息：

 

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

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

  

闽ICP备14008679号