黑马程序员技术交流社区

标题: 【郑州校区】传智健康项目讲义第四章 十 [打印本页]

---

作者: 我是楠楠    时间: 2019-10-30 16:35
标题: 【郑州校区】传智健康项目讲义第四章 十

【郑州校区】传智健康项目讲义第四章 十

5. 定时清理垃圾图片
前面我们已经完成了体检套餐的管理，在新增套餐时套餐的基本信息和图片是分两次提交到后台进行操作的。也就是用户首先将图片上传到七牛云服务器，然后再提交新增窗口中录入的其他信息。如果用户只是上传了图片而没有提交录入的其他信息，此时的图片就变为了垃圾图片，因为在数据库中并没有记录它的存在。此时我们要如何处理这些垃圾图片呢？解决方案就是通过定时任务组件定时清理这些垃圾图片。为了能够区分出来哪些图片是垃圾图片，我们在文件上传成功后将图片保存到了一个redis集合中，当套餐数据插入到数据库后我们又将图片名称保存到了另一个redis集合中，通过计算这两个集合的差值就可以获得所有垃圾图片的名称。
本章节我们就会基于Quartz定时任务，通过计算redis两个集合的差值找出所有的垃圾图片，就可以将垃圾图片清理掉。
操作步骤：
（1）创建maven工程health_jobs，打包方式为war，导入Quartz等相关坐标

[AppleScript] 纯文本查看 复制代码

<?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

http://maven.apache.org/xsd/maven‐

4.0.0.xsd">

<parent>

<artifactId>health_parent</artifactId>

<groupId>com.itheima</groupId>

<version>1.0‐SNAPSHOT</version>

</parent>

<modelVersion>4.0.0</modelVersion>

<artifactId>health_jobs</artifactId>

<packaging>war</packaging>

<name>health_jobs Maven Webapp</name>

<url>http://www.example.com</url>

<properties>

<project.build.sourceEncoding>UTF‐

8</project.build.sourceEncoding>

<maven.compiler.source>1.8</maven.compiler.source>

<maven.compiler.target>1.8</maven.compiler.target>

</properties>

<dependencies>

<dependency>

<groupId>com.itheima</groupId>

<artifactId>health_interface</artifactId>

<version>1.0‐SNAPSHOT</version>

</dependency>

<dependency>

<groupId>org.quartz‐scheduler</groupId>

<artifactId>quartz</artifactId>

</dependency>

<dependency>

<groupId>org.quartz‐scheduler</groupId>

<artifactId>quartz‐jobs</artifactId>

</dependency>

</dependencies>

<build>

<plugins>

<plugin><groupId>org.apache.tomcat.maven</groupId>

<artifactId>tomcat7‐maven‐plugin</artifactId>

<configuration>

<!‐‐ 指定端口 ‐‐>

<port>83</port>

<!‐‐ 请求路径 ‐‐>

<path>/</path>

</configuration>

</plugin>

</plugins>

</build>

</project> 

（2）配置web.xml

[AppleScript] 纯文本查看 复制代码

 <!DOCTYPE web‐app PUBLIC

"‐//Sun Microsystems, Inc.//DTD Web Application 2.3//EN"

"http://java.sun.com/dtd/web‐app_2_3.dtd" >

<web‐app>

<display‐name>Archetype Created Web Application</display‐name>

<!‐‐ 加载spring容器 ‐‐>

<context‐param>

<param‐name>contextConfigLocation</param‐name>

<param‐value>classpath*:applicationContext*.xml</param‐value>

</context‐param>

<listener>

<listener‐

class>org.springframework.web.context.ContextLoaderListener</listener‐

class>

</listener>

</web‐app> 

（3）配置log4j.properties

[AppleScript] 纯文本查看 复制代码

### direct log messages to stdout ###

log4j.appender.stdout=org.apache.log4j.ConsoleAppender

log4j.appender.stdout.Target=System.err

log4j.appender.stdout.layout=org.apache.log4j.PatternLayout

log4j.appender.stdout.layout.ConversionPattern=%d{ABSOLUTE} %5p %c{1}:%L

‐ %m%n

### direct messages to file mylog.log ###

log4j.appender.file=org.apache.log4j.FileAppender

log4j.appender.file.File=c:\\mylog.log

log4j.appender.file.layout=org.apache.log4j.PatternLayout

log4j.appender.file.layout.ConversionPattern=%d{ABSOLUTE} %5p %c{1}:%L ‐

%m%n

### set log levels ‐ for more verbose logging change 'info' to 'debug'

###

log4j.rootLogger=info, stdout 

（4）配置applicationContext-redis.xml

[AppleScript] 纯文本查看 复制代码

<?xml version="1.0" encoding="UTF‐8"?>

<beans xmlns="http://www.springframework.org/schema/beans"

xmlns:xsi="http://www.w3.org/2001/XMLSchema‐instance"

xmlns:p="http://www.springframework.org/schema/p"

xmlns:context="http://www.springframework.org/schema/context"

xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"

xmlns:mvc="http://www.springframework.org/schema/mvc"

xsi:schemaLocation="http://www.springframework.org/schema/beans

http://www.springframework.org/schema/beans/spring‐beans.xsd

http://www.springframework.org/schema/mvc

http://www.springframework.org/schema/mvc/spring‐mvc.xsd

http://code.alibabatech.com/schema/dubbo

http://code.alibabatech.com/schema/dubbo/dubbo.xsd

http://www.springframework.org/schema/context

http://www.springframework.org/schema/context/spring‐context.xsd">

<!‐‐Jedis连接池的相关配置‐‐>

<bean id="jedisPoolConfig"

class="redis.clients.jedis.JedisPoolConfig">

<property name="maxTotal">

<value>200</value>

</property>

<property name="maxIdle">

<value>50</value>

</property>

<property name="testOnBorrow" value="true"/>

<property name="testOnReturn" value="true"/>

</bean>

<bean id="jedisPool" class="redis.clients.jedis.JedisPool">

<constructor‐arg name="poolConfig" ref="jedisPoolConfig" />

<constructor‐arg name="host" value="127.0.0.1" />

<constructor‐arg name="port" value="6379" type="int" />

<constructor‐arg name="timeout" value="30000" type="int" />

</bean>

</beans>

（5）配置applicationContext-jobs.xml

[AppleScript] 纯文本查看 复制代码

<?xml version="1.0" encoding="UTF‐8"?>

<beans xmlns="http://www.springframework.org/schema/beans"

xmlns:xsi="http://www.w3.org/2001/XMLSchema‐instance"

xmlns:context="http://www.springframework.org/schema/context"

xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"

xmlns:mvc="http://www.springframework.org/schema/mvc"

xsi:schemaLocation="http://www.springframework.org/schema/beans

http://www.springframework.org/schema/beans/spring‐beans.xsd

http://www.springframework.org/schema/mvc

http://www.springframework.org/schema/mvc/spring‐mvc.xsd

http://code.alibabatech.com/schema/dubbo

http://code.alibabatech.com/schema/dubbo/dubbo.xsd

http://www.springframework.org/schema/context

http://www.springframework.org/schema/context/spring‐context.xsd">

<context:annotation‐config></context:annotation‐config>

<bean id="clearImgJob" class="com.itheima.jobs.ClearImgJob"></bean>

<bean id="jobDetail"

class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFacto

ryBean">

<!‐‐ 注入目标对象 ‐‐>

<property name="targetObject" ref="clearImgJob"/>

<!‐‐ 注入目标方法 ‐‐>

<property name="targetMethod" value="clearImg"/>

</bean>

<!‐‐ 注册一个触发器，指定任务触发的时间 ‐‐>

<bean id="myTrigger"

class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">

<!‐‐ 注入JobDetail ‐‐>

<property name="jobDetail" ref="jobDetail"/>

<!‐‐ 指定触发的时间，基于Cron表达式 ‐‐>

<property name="cronExpression">

<value>0 0 2 * * ?</value>

</property>

</bean>

<!‐‐ 注册一个统一的调度工厂，通过这个调度工厂调度任务 ‐‐>

<bean id="scheduler"<bean id="scheduler"

class="org.springframework.scheduling.quartz.SchedulerFactoryBean">

<!‐‐ 注入多个触发器 ‐‐>

<property name="triggers">

<list>

<ref bean="myTrigger"/>

</list>

</property>

</bean>

</beans> 

（6）创建ClearImgJob定时任务类

[AppleScript] 纯文本查看 复制代码

package com.itheima.jobs;

import com.itheima.constant.RedisConstant;

import com.itheima.utils.QiniuUtils;

import org.springframework.beans.factory.annotation.Autowired;

import redis.clients.jedis.JedisPool;

import java.util.Set;

/**

* 自定义Job，实现定时清理垃圾图片

*/

public class ClearImgJob {

@Autowired

private JedisPool jedisPool;

public void clearImg(){

//根据Redis中保存的两个set集合进行差值计算，获得垃圾图片名称集合

Set<String> set =

jedisPool.getResource().sdiff(RedisConstant.SETMEAL_PIC_RESOURCES,

RedisConstant.SETMEAL_PIC_DB_RESOURCES);

if(set != null){

for (String picName : set) {

//删除七牛云服务器上的图片

QiniuUtils.deleteFileFromQiniu(picName);

//从Redis集合中删除图片名称

jedisPool.getResource().

srem(RedisConstant.SETMEAL_PIC_RESOURCES,picName);

}

}

}

}

---

欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/)

黑马程序员IT技术论坛 X3.2