微信小程序订阅消息开发指南(java)

微信小程序订阅消息开发指南(java)

第一步 准备阶段

1、你得有一个小程序，并且认证了，个人的也行
2、开通订阅消息

小程序后台->功能->订阅消息

3、公共模板库选择一个模板

选择的时候，选择你需要的字段，因为字段有限制

4、我的模板点击详情

详情内容，模板 id 都是需要提供个服务端开发人员的

第二步 编码阶段

小程序端

小程序消息订阅，需要用户确认

1、首先小程序授权登陆获取 code

官网示例：https://developers.weixin.qq.com/miniprogram/dev/api/open-api/login/wx.login.html

1. wx.login({
2.   success (res) {
3.     if (res.code) {
4.       //发起网络请求
5.       wx.request({
6.         url: 'https://example.com/onLogin',
7.         data: {
8.           code: res.code
9.         }
10.       })
11.     } else {
12.       console.log('登录失败！' + res.errMsg)
13.     }
14.   }
15. })
16. // 结果 {errMsg: "login:ok", code: "0a3kK4Ga10Gk3F0oBAHa1mGyRl3kK4Gd"}

复制代码

uni-App 示例：https://uniapp.dcloud.net.cn/api/plugins/login.html#login

1. uni.login({
2.     provider: 'weixin', //使用微信登录
3.     success: function (loginRes) {
4.         console.log(loginRes)
5.     }
6. });
7. // 结果 {errMsg: "login:ok", code: "0a3kK4Ga10Gk3F0oBAHa1mGyRl3kK4Gd"}

复制代码

2、将 code 传给服务端 获取用户唯一标识 openId
3、通过代码起小程序消息订阅界面、用户点击确定ok，小程序工作结束
官方示例：https://developers.weixin.qq.com/miniprogram/dev/api/open-api/subscribe-message/wx.requestSubscribeMessage.html
tmplIds 填写模板 id 即可，最多三个

1. wx.requestSubscribeMessage({
2.   tmplIds: [''],
3.   success (res) {
4.       console.log(res)
5.   }
6. })

复制代码

4、注意事项：

避免重复拉起用户订阅通知，可以通过微信提供的 getSetting 判断用户是否订阅了，如果没有就拉起。
注意下面是用uniapp写的，方法前缀是uni 如果你小程序代码记得修改 wx 以及提示组件
到此小程序工作结束

1. getSetting() {
2.     uni.getSetting({
3.         withSubscriptions: true, // 获取用户订阅状态
4.         success(res) {
5.             // false 表示用户未订阅改消息
6.             if (!res.subscriptionsSetting.mainSwitch) {
7.                 this.subscribeMessage();
8.             } else {
9.                 uni.showToast({
10.                     title: '已订阅',
11.                     icon: 'none'
12.                 })
13.             }
14.         }
15.     })
16. },
17. subscribeMessage() {
18.     uni.requestSubscribeMessage({
19.         tmplIds: ['模板id'],
20.         success(res) {
21.             if (res.errMsg === 'requestSubscribeMessage:ok') {
22.                 uni.showToast({
23.                     title: '订阅成功',
24.                     icon: 'none'
25.                 })
26.             }
27.         }
28.     })
29. }   

复制代码

服务端

微信小程序的 appid 和  secret 小程序后台->开发->开发管理->开发设置->开发者 ID

注意事项：

• http 请求这里使用 apache 的工具类，你也可以使用别的
  
• 微信消息模板字段 thing 字段有长度限制20，超过会失败
  
• 以下演示代码，生产环境还需进行优化
  

1、通过 code 获取用户 open id 官网文档

1. public String getOpenId(String code) throws IOException {
2.         CloseableHttpClient httpClient = HttpClientBuilder.create().build();
3.         Map<String, Object> params = new HashMap<>();
4.         params.put("appid", Constants.APPLET_APP_ID);
5.         params.put("secret", Constants.APPLET_SECRET);
6.         params.put("js_code", code);
7.         params.put("grant_type", "authorization_code");
9.         String url = handleParams("https://api.weixin.qq.com/sns/jscode2session", params);
10.         HttpGet httpGet = new HttpGet(url);
12.         CloseableHttpResponse response = httpClient.execute(httpGet);
13.         HttpEntity entity = response.getEntity(); // 响应结果
14.         return EntityUtils.toString(entity, CharSetType.UTF8.getType());
15. }
17. public static void main(String[] args) throws IOException {
18.         HttpUtils httpUtils = new HttpUtils();
19.         String token = httpUtils.getToken();
20.         System.out.println(token);
21. }

复制代码

响应结果：

1. {"access_token":"67_u22CQaWq22222222Q4griDE6kiT5hwg7jVxedn8J9te17Az1oWGGxPgB22222229Y4Wm6h_Yzci7-FSDjeH8YG6DsCOYrQXJCWsPXhT6nWbKIWCXfABACID","expires_in":7200}

复制代码

2、通过 appid 和  secret 获取 token 超时 7200 秒 可 redis 缓存 官方文档

1. public String getToken() throws IOException {
2.         CloseableHttpClient httpClient = HttpClientBuilder.create().build();
3.         Map<String, Object> params = new HashMap<>();
4.         params.put("appid", Constants.APPLET_APP_ID);
5.         params.put("secret", Constants.APPLET_SECRET);
6.         params.put("grant_type", "client_credential");
8.         String url = handleParams("https://api.weixin.qq.com/cgi-bin/token", params);
9.         HttpGet httpGet = new HttpGet(url);
11.         CloseableHttpResponse response = httpClient.execute(httpGet);
12.         HttpEntity entity = response.getEntity(); // 响应结果
14.         return EntityUtils.toString(entity, CharSetType.UTF8.getType());
15. }

复制代码

3、指定用户推送消息结束 官方文档

1. public String pushMsg(String token) throws IOException {
3.         CloseableHttpClient httpClient = HttpClientBuilder.create().build();
4.         Map<String, Object> params = new HashMap<>();
6.         // 处理微信推送数据结构
7.         JSONObject mapData = new JSONObject();
8.         Map<String, Object> map1 = new HashMap<>();
9.         map1.put("value", "任务名称");
10.         mapData.put("thing2", map1);
12.         Map<String, Object> map2 = new HashMap<>();
13.         map2.put("value", "2022-04-03 10:00:00");
14.         mapData.put("time3", map2);
16.         Map<String, Object> map3 = new HashMap<>();
17.         map3.put("value", "描述信息");
18.         mapData.put("thing4", map3);
20.         Map<String, Object> map4 = new HashMap<>();
21.         map4.put("value", "备注信息");
22.         mapData.put("thing10", map4);
24.         Map<String, Object> map5 = new HashMap<>();
25.         map5.put("value", "任务来源");
26.         mapData.put("thing11", map5);
28.         params.put("template_id", "templateId");// 模板 id
29.         params.put("touser", "openId"); // open id
30.         params.put("data", mapData); // 数据
31.         params.put("page", "page"); // 点击模板卡片后的跳转页面，仅限本小程序内的页面。支持带参数,（示例index?foo=bar）。该字段不填则模板无跳转
32.         params.put("miniprogram_state", "trial"); //developer为开发版；trial为体验版；formal为正式版；默认为正式版
33.         params.put("lang", "zh_CN"); //
35.         HttpPost httpPost = new HttpPost("https://api.weixin.qq.com/cgi-bin/message/subscribe/send?access_token=" + token);
36.         httpPost.addHeader("ContentTyp", "application/json");
38.         // 参数转 JSON 格式
39.         String json = objToStr(params);
40.         StringEntity stringEntity = new StringEntity(json, CharSetType.UTF8.getType());
41.         stringEntity.setContentEncoding(CharSetType.UTF8.getType());
42.         httpPost.setEntity(stringEntity);
44.         CloseableHttpResponse response = httpClient.execute(httpPost);
45.         HttpEntity entity = response.getEntity(); // 响应结果
46.         return EntityUtils.toString(entity, CharSetType.UTF8.getType());
47.     }

复制代码

4、完整代码

1. import com.alibaba.fastjson.JSONObject;
2. import com.fasterxml.jackson.core.JsonProcessingException;
3. import com.fasterxml.jackson.databind.ObjectMapper;
4. import com.github.chenlijia1111.utils.core.enums.CharSetType;
5. import org.apache.http.HttpEntity;
6. import org.apache.http.client.methods.CloseableHttpResponse;
7. import org.apache.http.client.methods.HttpGet;
8. import org.apache.http.client.methods.HttpPost;
9. import org.apache.http.entity.StringEntity;
10. import org.apache.http.impl.client.CloseableHttpClient;
11. import org.apache.http.impl.client.HttpClientBuilder;
12. import org.apache.http.util.EntityUtils;
13. import org.jeecg.modules.video.utitls.Constants;
15. import java.io.IOException;
16. import java.io.UnsupportedEncodingException;
17. import java.net.URLEncoder;
18. import java.util.HashMap;
19. import java.util.Map;
20. import java.util.Objects;
21. import java.util.Set;
22. import java.util.stream.Collectors;
24. /**
25. * @description:
26. * @author: Mr.Fang
27. * @create: 2023-04-03 17:06
28. **/
30. public class HttpUtils {
32.     /**
33.      * description: 获取token，返回结果为 JSON 自行转 map
34.      * create by: Mr.Fang
35.      *
36.      * @return: java.lang.String
37.      * @date: 2023/4/3 17:46
38.      */
39.     public String getToken() throws IOException {
40.         CloseableHttpClient httpClient = HttpClientBuilder.create().build();
41.         Map<String, Object> params = new HashMap<>();
42.         params.put("appid", Constants.APPLET_APP_ID);
43.         params.put("secret", Constants.APPLET_SECRET);
44.         params.put("grant_type", "client_credential");
46.         String url = handleParams("https://api.weixin.qq.com/cgi-bin/token", params);
47.         HttpGet httpGet = new HttpGet(url);
49.         CloseableHttpResponse response = httpClient.execute(httpGet);
50.         HttpEntity entity = response.getEntity(); // 响应结果
52.         return EntityUtils.toString(entity, CharSetType.UTF8.getType());
53.     }
55.     /**
56.      * description: 获取 open id，返回结果为 JSON 自行转 map
57.      * create by: Mr.Fang
58.      *
59.      * @param: [code]
60.      * @return: java.lang.String
61.      * @date: 2023/4/3 17:46
62.      */
63.     public String getOpenId(String code) throws IOException {
64.         CloseableHttpClient httpClient = HttpClientBuilder.create().build();
65.         Map<String, Object> params = new HashMap<>();
66.         params.put("appid", Constants.APPLET_APP_ID);
67.         params.put("secret", Constants.APPLET_SECRET);
68.         params.put("js_code", code);
69.         params.put("grant_type", "authorization_code");
71.         String url = handleParams("https://api.weixin.qq.com/sns/jscode2session", params);
72.         HttpGet httpGet = new HttpGet(url);
74.         CloseableHttpResponse response = httpClient.execute(httpGet);
75.         HttpEntity entity = response.getEntity(); // 响应结果
76.         return EntityUtils.toString(entity, CharSetType.UTF8.getType());
77.     }
79.     /**
80.      * description: 消息推送 返回结果为 JSON 自行转 map；token 调用 getToken获取
81.      * create by: Mr.Fang
82.      *
83.      * @param: [token]
84.      * @return: java.lang.String
85.      * @date: 2023/4/3 17:46
86.      */
87.     public String pushMsg(String token) throws IOException {
89.         CloseableHttpClient httpClient = HttpClientBuilder.create().build();
90.         Map<String, Object> params = new HashMap<>();
92.         // 处理微信推送数据结构
93.         JSONObject mapData = new JSONObject();
94.         Map<String, Object> map1 = new HashMap<>();
95.         map1.put("value", "任务名称");
96.         mapData.put("thing2", map1);
98.         Map<String, Object> map2 = new HashMap<>();
99.         map2.put("value", "2023-04-03 12:00:00");
100.         mapData.put("time3", map2);
102.         Map<String, Object> map3 = new HashMap<>();
103.         map3.put("value", "描述信息");
104.         mapData.put("thing4", map3);
106.         Map<String, Object> map4 = new HashMap<>();
107.         map4.put("value", "备注系信息");
108.         mapData.put("thing10", map4);
110.         Map<String, Object> map5 = new HashMap<>();
111.         map5.put("value", "抖音");
112.         mapData.put("thing11", map5);
114.         params.put("template_id", "templateId");// 模板 id
115.         params.put("touser", "openId"); // open id
116.         params.put("data", mapData); // 数据
117.         params.put("page", "page"); // 点击模板卡片后的跳转页面，仅限本小程序内的页面。支持带参数,（示例index?foo=bar）。该字段不填则模板无跳转
118.         params.put("miniprogram_state", "trial"); //developer为开发版；trial为体验版；formal为正式版；默认为正式版
119.         params.put("lang", "zh_CN"); //
121.         HttpPost httpPost = new HttpPost("https://api.weixin.qq.com/cgi-bin/message/subscribe/send?access_token=" + token);
122.         httpPost.addHeader("ContentTyp", "application/json");
124.         // 参数转 JSON 格式
125.         String json = objToStr(params);
126.         StringEntity stringEntity = new StringEntity(json, CharSetType.UTF8.getType());
127.         stringEntity.setContentEncoding(CharSetType.UTF8.getType());
128.         httpPost.setEntity(stringEntity);
130.         CloseableHttpResponse response = httpClient.execute(httpPost);
131.         HttpEntity entity = response.getEntity(); // 响应结果
132.         return EntityUtils.toString(entity, CharSetType.UTF8.getType());
133.     }
136.     /**
137.      * description: 对象转 字符串
138.      * create by: Mr.Fang
139.      *
140.      * @param: [obj]
141.      * @return: java.lang.String
142.      * @date: 2023/4/3 17:45
143.      */
144.     public static String objToStr(Object obj) {
146.         ObjectMapper objectMapper = new ObjectMapper();
147.         if (Objects.nonNull(obj)) {
148.             try {
149.                 String jsonStr = objectMapper.writeValueAsString(obj);
150.                 return jsonStr;
151.             } catch (JsonProcessingException var2) {
152.                 var2.printStackTrace();
153.             }
154.         }
156.         return null;
157.     }
159.     /**
160.      * description: map 转 URL 地址拼接
161.      * create by: Mr.Fang
162.      *
163.      * @param: [url, params]
164.      * @return: java.lang.String
165.      * @date: 2023/4/3 17:45
166.      */
167.     public String handleParams(String url, Map<String, Object> params) {
168.         if (params.size() != 0) {
169.             Set<Map.Entry<String, Object>> entries = params.entrySet();
170.             String paramsString = entries.stream().map((e) -> {
171.                 try {
172.                     StringBuilder sb = new StringBuilder();
173.                     sb.append(URLEncoder.encode(e.getKey(), CharSetType.UTF8.getType()));
174.                     sb.append("=");
175.                     if (Objects.nonNull(e.getValue())) {
176.                         sb.append(URLEncoder.encode(e.getValue().toString(), CharSetType.UTF8.getType()));
177.                     }
179.                     return sb.toString();
180.                 } catch (UnsupportedEncodingException var2) {
181.                     var2.printStackTrace();
182.                     return null;
183.                 }
184.             }).collect(Collectors.joining("&"));
185.             return url + "?" + paramsString;
186.         }
187.         return url;
188.     }
191. }

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！