1.配置消息模板,微信订阅消息需要固定的模板
小程序后台地址:点击进入
2.小程序前端订阅
大多数模板是一次订阅,永久订阅需要指定的机构或组织,具体可以参考官方文档.
用户在小程序内点击按钮触发消息订阅授权框,默一次授权可以发送一次订阅消息(次数可以累加)
如果用户勾选"下次自动授权",下次将不再弹出授权框,点击按钮直接拥有一次发送订阅消息的机会.
官方通道:
小程序前端:点击进入
小程序服务端:点击进入
3.代码实现(仅java后端)
(1).定义实体类
import lombok.Data;import java.util.Map;@Datapublic class WxMsgVo {private String touser;//用户openIdprivate String template_id;//模版idprivate Map<String , TemplateData> data;//推送文字private String page="pages/index/index";//跳转路径 ，默认跳转到小程序首页}
public class TemplateData {private String value;//public TemplateData(String value) {this.value = value;}public String getValue() {return value;}public void setValue(String value) {this.value = value;}}
(2).定义HttpUtil类
import java.io.IOException;import java.util.ArrayList;import java.util.List;import java.util.Map;import org.apache.http.Consts;import org.apache.http.HttpEntity;import org.apache.http.NameValuePair;import org.apache.http.client.entity.UrlEncodedFormEntity;import org.apache.http.client.methods.CloseableHttpResponse;import org.apache.http.client.methods.HttpGet;import org.apache.http.client.methods.HttpPost;import org.apache.http.impl.client.CloseableHttpClient;import org.apache.http.impl.client.HttpClients;import org.apache.http.message.BasicNameValuePair;import org.apache.http.util.EntityUtils;public class HttpUtil {private static final CloseableHttpClient httpclient = HttpClients.createDefault();/*** 发送HttpGet请求** @param url* @return*/public static String sendGet(String url) {HttpGet httpget = new HttpGet(url);CloseableHttpResponse response = null;try {response = httpclient.execute(httpget);} catch (IOException e1) {e1.printStackTrace();}String result = null;try {HttpEntity entity = response.getEntity();if (entity != null) {result = EntityUtils.toString(entity);}} catch (Exception e) {e.printStackTrace();} finally {try {response.close();} catch (IOException e) {e.printStackTrace();}}return result;}/*** 发送HttpPost请求，参数为map** @param url* @param map* @return*/public static String sendPost(String url, Map<String, String> map) {List<NameValuePair> formparams = new ArrayList<NameValuePair>();for (Map.Entry<String, String> entry : map.entrySet()) {formparams.add(new BasicNameValuePair(entry.getKey(), entry.getValue()));}UrlEncodedFormEntity entity = new UrlEncodedFormEntity(formparams, Consts.UTF_8);HttpPost httppost = new HttpPost(url);httppost.setEntity(entity);CloseableHttpResponse response = null;try {response = httpclient.execute(httppost);} catch (IOException e) {e.printStackTrace();}HttpEntity entity1 = response.getEntity();String result = null;try {result = EntityUtils.toString(entity1);} catch (Exception e) {e.printStackTrace();}return result;}/*** 发送不带参数的HttpPost请求** @param url* @return*/public static String sendPost(String url) {HttpPost httppost = new HttpPost(url);CloseableHttpResponse response = null;try {response = httpclient.execute(httppost);} catch (IOException e) {e.printStackTrace();}HttpEntity entity = response.getEntity();String result = null;try {result = EntityUtils.toString(entity);} catch (Exception e) {e.printStackTrace();}return result;}}
(3).调用微信请求
import com.alibaba.fastjson.JSON;import com.alibaba.fastjson.JSONObject;import com.metersbonwe.fxadserver.vo.ResultTemplateDate;import com.metersbonwe.fxadserver.vo.TemplateData;import com.metersbonwe.fxadserver.vo.WxMsgVo;import com.mon.vo.ResultVo;import lombok.extern.slf4j.Slf4j;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.http.ResponseEntity;import org.springframework.stereotype.Service;import org.springframework.web.client.RestTemplate;import java.util.HashMap;import java.util.Map;@Service@Slf4jpublic class SendTemplateServiceImpl{@Autowiredprivate RestTemplate restTemplate;/*** 订阅消息发送 调用微信请求* @param wxMsgVo* @return*/public ResultVo send(WxMsgVo wxMsgVo){String tepUrl="";tepUrl = "https://api./cgi-bin/message/subscribe/send?access_token=" + getAccessToken();ResponseEntity<String> str = restTemplate.postForEntity(tepUrl, wxMsgVo, String.class);ResultTemplateDate resultTemplateDate = JSONObject.parseObject(str.getBody(), ResultTemplateDate.class);String resultStr = "null";if (resultTemplateDate!=null) {resultStr = resultTemplateDate.getErrcode();}return new ResultVo(ResultVo.Status.OK, resultStr);}public String getAccessToken() {String url="https://api./cgi-bin/token?grant_type=client_credential&appid="+ "小程序的appid"+ "&secret="+ "小程序的Secret";String result = HttpUtil.sendGet(url);JSONObject object=JSON.parseObject(result);String Access_Token = object.getString("access_token");return Access_Token;}public void main(String[] args) {WxMsgVo wxMsgVo = new WxMsgVo();wxMsgVo.setTemplate_id("TemplateId");wxMsgVo.setTouser("OpenId");Map<String , TemplateData> data = new HashMap<>();data.put("name1",new TemplateData("活动名称"));//活动名称data.put("thing4",new TemplateData("用户昵称"));//用户昵称data.put("time3",new TemplateData("-01-01 11:11:11"));//完成时间data.put("thing5",new TemplateData("温馨提示"));//温馨提示wxMsgVo.setData(data);this.send(wxMsgVo);}
(4).引用依赖
<dependency><groupId>org.springframework</groupId><artifactId>spring-web</artifactId><version>5.1.8.RELEASE</version></dependency>
