小程序订阅消息推送（含源码）java实现小程序推送，springboot实现微信消息推送

前面写过一篇云开发实现小程序订阅消息（模板消息）推送的文章，《借助云开发实现小程序订阅消息和模板消息的推送功能》是有好多同窗用的是Java写后台，因此今天就再来写一篇Java后台实现小程序订阅消息推送的文章。

老规矩先看效果图

至于如何建立模板消息，若是获取模板id我这节就再也不讲解，不知道的同窗能够查看我上篇文章《借助云开发实现小程序订阅消息和模板消息的推送功能》里面有详细的讲解。

今天呢就来重点讲下如何在Java后台编写小程序订阅消息推送的知识。

其实我很早以前有写过一篇Java实现模板消息推送的，可是小程序后面用订阅消息替换了模板推送，因此我也会根据最新的知识点不按期的更新文章的。

发送订阅消息三步走

• 1，拿到用户的openid
• 2，获取access_token
• 3，调用小程序消息推送的接口

一，获取用户的openid

关于用户openid的获取，我写过不少篇文章了，也有录过视频出来的，还不知道怎么获取的同窗，能够取翻看下我以前的文章，或者看下我录制的零基础入门小程序的视频：《5小时零基础入门小程序云开发》 因此这一步不是今天的重点。

二，获取access_token

首先来看下access_token是什么，下图是官方给出的

其实通俗的讲，access_token就是小程序官方给咱们提供的一个凭证，你要调用小程序官方的接口，就必须先拿到access_token。因此下面先讲下若是获取access_token

• 看下官方文档，能够知道咱们须要用到下面的几个参数
  
  grant_type是一个固定的值，只有appid和secret是须要咱们填入的，这两个值在咱们的小程序后台就能够拿到，我也有录视频教你们如何拿到，若是不知道怎么获取的同窗能够取看下个人视频。

下面就是Java代码的编写了

咱们这里用的是springboot，这里涉及到一个请求小程序官方接口，因此咱们这里用了springboot自带的RestTemplate来作网络请求。具体代码以下。

能够看出代码很简单，就是用RestTemplate来实现一个get请求，这样咱们就能够轻松的获取到了access_token。

注意点

关于这个access_token，是存在有效期的，来看下官方给出的提示

因此我要在获取到access_token的时候，把access_token存到数据库，或者存到本地缓存，而且还要记录当前时间，后面再用的时候先判断这个access_token有没有超过2个小时，若是超过2个小时的话，就要从新获取了。因为这里不是本节的重点，我这里只给你们说下原理。

三，发送消息到小程序

咱们经过上面第二步，成功的获取到了access_token。下面就要调用小程序官方为咱们提供的发送消息的接口了。先看下官方文档。

上面的参数都是咱们发送消息时须要的。这些参数的定义和设置我在前面的文章里也都讲过了，不知道的同窗能够去看下我前面写的这篇文章 《借助云开发实现小程序订阅消息和模板消息的推送功能》

这里须要注意的一点是，咱们要给用户发送消息，就必须引导用户受权，就是下面这个图

由于用户不点击容许，你是没有办法给用户推送消息的。每一次受权只容许发送一条消息，因此若是你想尽可能多的发送消息，就得尽可能多的引导用户受权。

推送的Java代码以下

能够看到，咱们这里须要定义用户的openid，模板id，跳转路径，模板消息内容。。。

这些都定义好之后，咱们就能够提供一个服务给到Java的其余代码调用，或者提供一个接口供外界传入openid，而后给对应的用户推送消息了。

咱们在浏览器里调用上面接口，能够看到下图所示，这样就表明咱们消息推送成功了。

下面我把完整的代码贴出来给到你们。

package com.qcl.demo;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestClientException;
import org.springframework.web.client.RestTemplate;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

/**
 * 做者：编程小石头
 * 发送小程序订阅消息
 */
@RestController
public class SendWxMessage {

    /*
     * 发送订阅消息
     * */
    @GetMapping("/pushOneUser")
    public String pushOneUser() {
        return push("o3DoL0WEdzcJ20AVJg1crP96gbjM");
    }

    public String push(String openid) {
        RestTemplate restTemplate = new RestTemplate();
        //这里简单起见咱们每次都获取最新的access_token（时间开发中，应该在access_token快过时时再从新获取）
        String url = "https://api.weixin.qq.com/cgi-bin/message/subscribe/send?access_token=" + getAccessToken();
        //拼接推送的模版
        WxMssVo wxMssVo = new WxMssVo();
        wxMssVo.setTouser(openid);//用户的openid（要发送给那个用户，一般这里应该动态传进来的）
        wxMssVo.setTemplate_id("CFeSWarQLMPyPjwmiy6AV4eB-IZcipu48V8bFLkBzTU");//订阅消息模板id
        wxMssVo.setPage("pages/index/index");

        Map<String, TemplateData> m = new HashMap<>(3);
        m.put("thing1", new TemplateData("小程序入门课程"));
        m.put("thing6", new TemplateData("杭州浙江大学"));
        m.put("thing7", new TemplateData("第一章第一节"));
        wxMssVo.setData(m);
        ResponseEntity<String> responseEntity =
                restTemplate.postForEntity(url, wxMssVo, String.class);
        return responseEntity.getBody();
    }

    @GetMapping("/getAccessToken")
    public String getAccessToken() {
        RestTemplate restTemplate = new RestTemplate();
        Map<String, String> params = new HashMap<>();
        params.put("APPID", "wx7c54942dfc87f4d8");  //
        params.put("APPSECRET", "5873a729c365b65ab42bb5fc82d2ed49");  //
        ResponseEntity<String> responseEntity = restTemplate.getForEntity(
                "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid={APPID}&secret={APPSECRET}", String.class, params);
        String body = responseEntity.getBody();
        JSONObject object = JSON.parseObject(body);
        String Access_Token = object.getString("access_token");
        String expires_in = object.getString("expires_in");
        System.out.println("有效时长expires_in：" + expires_in);
        return Access_Token;
    }
}

对应的两个数据类以下
WxMssVo用来封装请求官方接口的参数

package com.qcl.demo;

import java.util.Map;

/*
 * 小程序推送所需数据
 * 编程小石头
 * */
public class WxMssVo {
    private String touser;//用户openid
    private String template_id;//订阅消息模版id
    private String page = "pages/index/index";//默认跳到小程序首页
    private Map<String, TemplateData> data;//推送文字

    public String getTouser() {
        return touser;
    }

    public void setTouser(String touser) {
        this.touser = touser;
    }

    public String getTemplate_id() {
        return template_id;
    }

    public void setTemplate_id(String template_id) {
        this.template_id = template_id;
    }

    public String getPage() {
        return page;
    }

    public void setPage(String page) {
        this.page = page;
    }

    public Map<String, TemplateData> getData() {
        return data;
    }

    public void setData(Map<String, TemplateData> data) {
        this.data = data;
    }
}

TemplateData 用来定义消息的内容

package com.qcl.demo;

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;
    }
}

到这里咱们就能够完整的实现Java发送小程序消息的功能了。完整代码也已经贴给你们了。

后面我会写更多Java和小程序相关的文章出来，敬请期待