SpringBoot实现广州健康通疫苗预约提醒
一、前言
终于轮到了打第二针疫苗的时候,无奈每次打开“广州健康通”或“粤康通”小程序,每次都是被预约完的状态,广州人口众多,说不定有很多人一直守在小程序前等着放号,所以这篇文章就诞生了。
二、原理
这个程序说来简单,并不能直接帮助自己预约上号,而且提醒自己去小程序进行预约。利用定时任务,每隔5分钟或者10分钟,去调“广州健康通”的查询各区剩余人数的接口(相信这时候有人在说我是在搞垮服务器,怪不得每次打开小程序都很卡,额,按我5分钟调一次的频率,一个小时也才调12次,如果它连我一小时12次的访问次数都承载不了,那它怎么才能更好地为广大人民群众服务?)如果监控到大于50个人的剩余量,那么就通过发送QQ邮件的方式通知我,微信可以绑定到QQ邮件,所以如果有50个人以上的剩余量,那么我的微信和QQ就会同时收到邮件提醒。嗯,我最开始就觉得这很棒。
目标接口:https://m.r.umiaohealth.com/Home/GetTicketReport
当然这个接口也不是随便就能调的,需要添加鉴权,可以在手机上下载一个抓包工具,我使用的是HttpCanary这个软件,通过这个工具进行抓包可以获取所需要的Cookie鉴权值。
三、实现
搭建SpringBoot项目,我这里为了偷懒,引用了Hutool的邮件工具,pom依赖如下:
<?xml version=”1.0″ encoding=”UTF-8″?>
<project xmlns=”http://maven.apache.org/POM/4.0.0″
xmlns:xsi=”http://www.w3.org/2001/XMLSchema-instance”
xsi:schemaLocation=”http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd”>
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.5.1</version>
<relativePath /> <!– lookup parent from repository –>
</parent>
<groupId>com.chen</groupId>
<artifactId>AppointmentTask</artifactId>
<packaging>jar</packaging>
<version>0.0.1-SNAPSHOT</version>
<name>AppointmentTask</name>
<description>Demo project for Spring Boot</description>
<properties>
<java.version>1.8</java.version>
</properties>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>cn.hutool</groupId>
<artifactId>hutool-all</artifactId>
<version>5.6.7</version>
</dependency>
<dependency>
<groupId>com.sun.mail</groupId>
<artifactId>javax.mail</artifactId>
<version>1.6.2</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-mail</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
</dependencies>
<build>
<finalName>App</finalName>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
</project>
application.properties的配置如下,这里只有一个cron表达式的配置,我这里用的定时任务是最新的Spring Task,比quartz用起来更简洁方便,这个表达式表示每小时从零开始每5分钟
我在controller层写了两个接口,一个是启动定时任务的接口,一个是关闭定时任务的接口,代码如下:
package com.chen.controller;
import java.util.Date;
import java.util.concurrent.ScheduledFuture;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.scheduling.Trigger;
import org.springframework.scheduling.TriggerContext;
import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
import org.springframework.scheduling.support.CronTrigger;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import com.chen.entity.TaskConfiguration;
import com.chen.task.MyRunnableTask;
@RestController
@RequestMapping(“/quartz/task”)
public class DynamicTaskController {
@Autowired
private TaskConfiguration taskConfiguration;
@Autowired
private ThreadPoolTaskScheduler threadPoolTaskScheduler;
private ScheduledFuture<?> future1;
@Bean
public ThreadPoolTaskScheduler threadPoolTaskScheduler() {
return new ThreadPoolTaskScheduler();
}
@GetMapping(“/start”)
public String start() {
future1 = threadPoolTaskScheduler.schedule(new MyRunnableTask(),new Trigger(){
@Override
public Date nextExecutionTime(TriggerContext triggerContext){
return new CronTrigger(taskConfiguration.getCorn1()).nextExecutionTime(triggerContext);
}
});
System.out.println(“定时任务启动成功”);
return “success”;
}
@GetMapping(“/stop”)
public String stop() {
if (future1 != null) {
future1.cancel(true);
}
System.out.println(“停止定时任务”);
return “success”;
}
}
配置cron,关联上在配置文件写的表达式
关于调接口方面我用的是RestTemplate,简单粗暴。注意这里需要用到两个邮箱,一个是发送者邮箱,一个是接收者邮箱,发送者邮箱需要到该邮箱账号开启POP3/SMTP服务,并获得授权密码,在代码里需要用到,另外还有一个要注意,如果是写完代码后要将项目部署到阿里云服务器,则端口号不能像Hutool介绍的那样写上25端口,要和我一样改成465端口号,不然就去阿里云上申请解封25端口号,这是因为阿里云的一些安全策略导致的禁用(这个坑我踩过)。
还有一点,我这里限制了50人,表示只有剩余50人可预约的时候,才会发邮件通知我,毕竟小程序上面的数据有延时,明明显示的有好几个人剩余,但是就是一直找不到在哪个接种点。我猜这个小程序的后端应该是使用了消息中间件或者某些框架,应付这种大数据量并发进行“削峰”。
————————————————
版权声明:本文为CSDN博主「西瓜不甜柠檬不酸」的原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接及本声明。
原文链接:https://blog.csdn.net/qq_42109746/article/details/117928223