微信小程序订阅消息-java服务端整合mq实现订阅消息延时发送

微信小程序订阅消息官方文档地址：https://developers.weixin.qq.com/miniprogram/dev/api-backend/open-api/subscribe-message/subscribeMessage.send.html

本文通过java代码整合小程序接口和rabbitMq,实现订阅消息延时发送。

一，微信小程序开发相关接口

（1）推荐一个小程序插件jar:

<dependency>
     <groupId>com.github.binarywang</groupId>
     <artifactId>weixin-java-miniapp</artifactId>
     <version>3.6.0</version>
</dependency>

(2)yml配置文件信息中添加小程序配置信息

wx:
  miniapp:
    appid: 小程序appid
    secret: 小程序secret
    msgDataFormat: JSON

(3)添加配置类properties

@Data
@ConfigurationProperties(prefix = "wx.miniapp")
public class WxMaProperties {
    /**
     * 设置微信小程序的appid.
     */
    private String appid;

    /**
     * 设置微信小程序的Secret.
     */
    private String secret;

    /**
     * 设置微信小程序消息服务器配置的token.
     */
    private String token;

    /**
     * 设置微信小程序消息服务器配置的EncodingAESKey.
     */
    private String aesKey;

    /**
     * 消息格式，XML或者JSON.
     */
    private String msgDataFormat;
}

（4）添加对应的config 加载初始化小程序配置信息

@AllArgsConstructor
@Configuration
@ConditionalOnClass(WxMaService.class)
@EnableConfigurationProperties(WxMaProperties.class)
@ConditionalOnProperty(prefix = "wx.miniapp", value = "enabled", matchIfMissing = true)
public class WxMaAutoConfiguration {
    private WxMaProperties properties;

    /**
     * 小程序service.
     *
     * @return 小程序service
     */
    @Bean
    @ConditionalOnMissingBean(WxMaService.class)
    public WxMaService service() {
        WxMaDefaultConfigImpl config = new WxMaDefaultConfigImpl();
        config.setAppid(StringUtils.trimToNull(this.properties.getAppid()));
        config.setSecret(StringUtils.trimToNull(this.properties.getSecret()));
        config.setToken(StringUtils.trimToNull(this.properties.getToken()));
        config.setAesKey(StringUtils.trimToNull(this.properties.getAesKey()));
        config.setMsgDataFormat(StringUtils.trimToNull(this.properties.getMsgDataFormat()));
        final WxMaServiceImpl service = new WxMaServiceImpl();
        service.setWxMaConfig(config);
        return service;
    }

}

二，添加rabbitMq相关接口

实现延时消息发送需要安装mq延时插件官网下载地址：https://www.rabbitmq.com/community-plugins.html

（1)添加mq jar

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-amqp</artifactId>
</dependency>

(2) yml 中配置mq

queue:
  subscribeMsg-delayExchange: com.chunmi.subscribeMsg.delayExchange.local
  subscribeMsg-delayQueue: com.chunmi.subscribeMsg.delayQueue.local
  subscribeMsg-delayRoutingKey: com.chunmi.subscribeMsg.delayRoutingKey.local

(3) 添加配置类

@Configuration
public class DelayMqConfig {

    @Value("${queue.subscribeMsg-delayExchange}")
    public String delayExchange;

    @Value("${queue.subscribeMsg-delayQueue}")
    public String delayQueue;

    @Value("${queue.subscribeMsg-delayRoutingKey}")
    public String delayRoutingKey;

    @Bean
    public CustomExchange delayExchange() {
        Map<String, Object> args = new HashMap<>(16);
        args.put("x-delayed-type", "direct");
        return new CustomExchange(delayExchange, "x-delayed-message", true, false, args);
    }

    @Bean
    public Queue queue() {
        return new Queue(delayQueue, true);
    }

    @Bean
    public Binding binding(Queue queue, CustomExchange delayExchange) {
        return BindingBuilder.bind(queue).to(delayExchange).with(delayRoutingKey).noargs();
    }

}

（4）添加发送消息类

@Slf4j
@Component
public class MsgPublishService {

    @Autowired
    private RabbitTemplate rabbitTemplate;

    @Value("${queue.subscribeMsg-delayExchange}")
    public String delayExchange;

    @Value("${queue.subscribeMsg-delayRoutingKey}")
    public String delayRoutingKey;

    public void sendSubscribeMsg(String str, long delayTimes) {
        try {
            rabbitTemplate.convertAndSend(delayExchange, delayRoutingKey, str, new MessagePostProcessor() {
                @Override
                public Message postProcessMessage(Message message) throws AmqpException {
                    message.getMessageProperties().setHeader("x-delay", delayTimes);
                    return message;
                }
            });
        } catch (Exception e) {
            log.error("发送订阅消息出错：{}", e.getMessage());
            e.printStackTrace();
        }
    }
}

（5）到这里基本配置信息已经搭建完成，在需要发送订阅消息的接口中封装信息例如订单未支付给用户发送消息

private void sendSubscrbeMsg(Order order) {
        try {
            TemplateVo templateVo = new TemplateVo();
            templateVo.setToUser("用户openid");
            Map<String, String> map = new HashMap<>(16);
            templateVo.setTemplateId("模板TemplateId");
            templateVo.setPage("消息卡片点击跳转的地址");
            //封装data 注意map 的key 和微信公众服务配置信息一致
            map.put("character_string1", order.getOrderNo());
            //联系人名称
            map.put("amount2", order.getTotalFee().toString());
            //订单金额
            map.put("thing3", "您有一笔等支付的订单，点击查看详情。");
            templateVo.setDataMap(map);
            //延时十分钟发送订阅消息
            msgPublishService.sendSubscribeMsg(JSON.toJSONString(templateVo), 10 * 60 * 1000);
           
        } catch (Exception e) {
            e.printStackTrace();
        }

    }

模板信息类：
@Data
public class TemplateVo implements Serializable {

   private static final long serialVersionUID = -1L;

   @ApiModelProperty("订阅模板id")
   private String templateId;

   @ApiModelProperty("接收者用户的openid")
   private String toUser;

   @ApiModelProperty("点击模板卡片后的跳转页面")
   private String page;

   @ApiModelProperty("模板内容")
   private Map<String, String> dataMap;

}

三：在mq服务处理生产者发送的消息

@Slf4j
@Service
public class SubscribeMsgConsumer {

    @Autowired
    private WxMaService wxService;

    @RabbitListener(queues = {"${queue.subscribeMsg-delayQueue}"})
    public void processMsg(String jsonStr) {
        log.info("接收订阅 时间：{},消息内容：{}", DateUtil.format(new Date(), "yyyy-MM-dd HH:mm:ss"), jsonStr);
        TemplateVo templateVo = JSONObject.parseObject(jsonStr, TemplateVo.class);
        WxMaSubscribeMessage subscribeMessage = new WxMaSubscribeMessage();
        subscribeMessage.setPage(templateVo.getPage());
        subscribeMessage.setTemplateId(templateVo.getTemplateId());
        subscribeMessage.setToUser(templateVo.getToUser());
        List<WxMaSubscribeData> wxMaSubscribeDataList = new ArrayList<>();
        if (!CollectionUtils.isEmpty(templateVo.getDataMap())) {
            templateVo.getDataMap().forEach((k, v) -> {
                WxMaSubscribeData data = new WxMaSubscribeData();
                data.setName(k);
                data.setValue(v);
                wxMaSubscribeDataList.add(data);
            });
        }
        subscribeMessage.setData(wxMaSubscribeDataList);
        try {
            wxService.getMsgService().sendSubscribeMsg(subscribeMessage);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

}