Java定时发布文章简单方案

简介: 没有需求,就没有折腾。首先,阐述一下背景。早上迷迷糊糊地开始了春节后的一天上班日程,脑袋还在噼里啪啦放烟花,项目管理部和SEO小伙伴就提了一桶凉水过来,往我头上一浇,瞬间烟花都湮灭了。

没有需求,就没有折腾。

首先,阐述一下背景。

早上迷迷糊糊地开始了春节后的一天上班日程,脑袋还在噼里啪啦放烟花,项目管理部和SEO小伙伴就提了一桶凉水过来,往我头上一浇,瞬间烟花都湮灭了。

“给官网加个定时发布文章的功能吧。”

“啥?”

“我们的官网,每次新增文章都是立即执行静态化并进行发布,现在周末也需要发布文章,SEO周末是不上班哒,所以,请给我们开发一个定时发布文章的功能吧。”

“啊?”

“评估一下时间,越快越好。”

“...”

“需求了解了吧,那就这样,尽快产出哦。”

“...”

脑袋还在宕机中。

喂喂喂,那你们浇灭了我的烟花,都不用赔一下吗,真不厚道。

虽然我不喜欢频繁需求变动,但是我爱折腾。

不过这么简单的功能,貌似也算不上折腾,但是记录下来也许能帮助到别人呢,Hard to say。

环境说明

1、centOS 服务器一台

2、基于SSM + 一些没必要在这里提到的第三方控件

3、Bootstrap前端框架

4、最最重要的是:帅比码农一枚

其实,上面前三点都没必要提及,主要是基于Java环境来实现定时任务。所以最重要的,请记住第四点,强调,是第四点。

思路

SEO通过管理后台新增文章,但是并不是立即发布,而是可以手动选择发布方式,包括立即发布定时发布,定时发布可以指定一个时间,交由系统自动实现发布功能。

说了跟没说似的,原谅我,帅比码农说话都比较高(zhuang)深(shen)莫(nong)测(gui)。

1、前端通过bootstrap-datepicker插件,在文章表单中新增一个发布时间的选择控件。具体使用方式请参考官网API或留言。

<!-- 页面元素 -->
<div class="input-append date form_datetime">
    <input id="pubTime" name="pubTime" size="16" type="text" value="" readonly>
    <span class="add-on"><i class="icon-th"></i></span>
</div>

<!-- Javascript -->
<script type="text/javascript">
    $(".form_datetime").datetimepicker({
            language:"zh-CN",
            showMeridian: true,
            todayBtn:true,
            startDate:new Date(),
            format: "yyyy-mm-dd hh:ii:ss"
        }).on('changeDate', function(ev){
            $('#pubTiming').attr('checked',true);//通过事件,实现[定时发布]单选按钮的联动选择
        });
</script> 
界面

2、后台新增文章的方法,新增入参[发布方式-pubType]和[发布时间-pubTime]来接收表单传递过来的值,当用户选择发布方式为定时发布时,要求发布时间必须选择。

由于这里是以实体的方式来接收表单的,只需要在Article实体中新增pubType和pubTime两个属性,并生成getter和setter即可接收表单值。

部分代码如下

    /**
     * 新增文章
     *
     * @param article 文章实体
     * @param request 请求
     * @return ResponseBean 响应实体
     */
    @RequestMapping("/add")
    @ResponseBody
    public ResponseBean add(Article article, HttpServletRequest request) {
        boolean success = articleService.add(article, request);
        ...
    }
    
    /**
     * 文章
     *
     * @author zoro
     * @version 1.0
     * @since 2018/02/23
     */
    public class Article implements Serializable {
        ...
        private Integer pubType;//发布方式,1立即,2定时
        @DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
        private Date pubTime;//定时发布的时间
        
        public Integer getPubType() {
            return pubType;
        }
    
        public void setPubType(Integer pubType) {
            this.pubType = pubType;
        }
    
        public Date getPubTime() {
            return pubTime;
        }
    
        public void setPubTime(Date pubTime) {
            this.pubTime = pubTime;
        }
        ...
    
    }

3、将文章内容和发布状态保存到数据库,如果是立即发布,则执行文章渲染,通过模板渲染成html文件,以供访问。

articleRender.rendering();

4、如果是定时发布的话,就需要建立定时任务。
这里有几种情况需要说明:

  • 新增文章
    直接保存文章,并建立定时任务。
  • 修改文章
    修改文章会存在不同时间点重复发布任务的可能性,所以需要特殊处理。

针对修改文章,每次新建定时任务的时候,先判断是否存在同一篇文章的定时任务,如果有,则标识该任务为取消状态(取消状态下的任务,任务体不会执行任何操作),并从id映射和缓存中移除

文章任务部分代码如下

package com.andatech.admin.service;

...
import com.andatech.tools.StringUtil;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.io.IOException;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.atomic.AtomicBoolean;

/**
 * 文章发布任务
 *
 * @author Zoro
 * @date 2018/2/23
 * @since 1.0
 */
public class ArticlePublishJob implements Runnable {

    /**logger*/
    private static final Logger LOGGER = LoggerFactory.getLogger(ArticlePublishJob.class);

    /**id映射*/
    private static volatile ConcurrentHashMap<String, String> idMapping = new ConcurrentHashMap<>();
    /**任务缓存*/
    private static volatile ConcurrentHashMap<String, ArticlePublishJob> cache = new ConcurrentHashMap<>();
    
    private volatile AtomicBoolean canceled = new AtomicBoolean(false);//任务取消状态
    private String jobId;//任务id
    private String articleUuid;//文章id
    private ArticleRender articleRender;//文章渲染器

    
    public ArticlePublishJob(ArticleRender articleRender) {
        this.jobId = IdGenerator.plainJdkUUID();
        this.articleRender = articleRender;
        this.articleUuid = articleRender.getArticle().getUuid();
        //取消并清除上一次任务
        cancelAndClearLastJobIfExist();
        //缓存本次任务
        cacheThisJob();
    }

    /**
     * 取消并清除上一次任务
     */
    private void cancelAndClearLastJobIfExist(){
        if (StringUtil.isNotEmpty(idMapping.get(articleUuid))) {
            ArticlePublishJob lastJob = cache.get(idMapping.get(articleUuid));
            if (null != lastJob) {
                lastJob.cancelJob();
                cache.remove(idMapping.get(articleUuid));
                idMapping.remove(articleUuid);
            }
        }
    }

    /**
     * 缓存本次任务
     */
    private void cacheThisJob(){
        //id映射
        idMapping.put(this.articleUuid, this.jobId);
        //文章发布任务缓存
        cache.put(this.jobId, this);
    }

    @Override
    public void run() {
        //判断任务是否被取消
        if (!canceled.get()) {
            ArticleService articleService = (ArticleService) SpringContextHolder.getBean("articleService");
            //渲染
            try {
                articleRender.rendering();
            } catch (IOException e) {
                LOGGER.error("render log err:" + e.getMessage(), e);
            }
            //更新文章状态
            Article updArticle = new Article();
            updArticle.setUuid(articleRender.getArticle().getUuid());
            updArticle.setStatus(Article.STATUS_NORMAL);
            articleService.edit(updArticle);

            //从缓存中清理本任务
            clear();
        }
    }

    /**
     * 取消任务
     */
    public void cancelJob() {
        this.canceled.set(true);
    }

    /**
     * 清理缓存
     */
    public void clear() {
        idMapping.remove(articleUuid);
        cache.remove(this.jobId);
    }

}

5、具体定时任务方式,包括以下几种

  • Thread方式:线程等待,不安全。
  • timer方式:线程资源没有复用。
  • 任务调度框架,比如Quartz等:需要继承框架。
  • ScheduledExecutorService方式:被相中了。

综上分析,选择了最后一种,也是较好的选择之一,下面给出最简单的用法,如有深入需要,建议查看JavaAPI。

部分代码如下

/**创建线程池*/
public static ScheduledExecutorService service = Executors.newScheduledThreadPool(50);


/**新建任务,并设定执行时间*/
ArticlePublishJob job = new ArticlePublishJob(articleRender);
long delay = article.getPubTime().getTime() - System.currentTimeMillis();
service.schedule(job, delay, TimeUnit.MILLISECONDS);

测试,大功告成。

总结
不结合业务来说,定时任务的创建无非就"第5点"中的几种方式,熟悉API并熟练使用即可。
结合业务情况下,需要考虑任务是否会重复,重复了怎么处理等问题。

目录
相关文章
|
18天前
|
Java 调度
Java实现定时启动,且只执行一次,如何实现?
【10月更文挑战第18天】Java实现定时启动,且只执行一次,如何实现?
106 3
|
18天前
|
存储 安全 Java
从入门到精通:Java Map全攻略,一篇文章就够了!
【10月更文挑战第17天】本文详细介绍了Java编程中Map的使用,涵盖Map的基本概念、创建、访问与修改、遍历方法、常用实现类(如HashMap、TreeMap、LinkedHashMap)及其特点,以及Map在多线程环境下的并发处理和性能优化技巧,适合初学者和进阶者学习。
34 3
|
3月前
|
前端开发 Java 编译器
【前端学java】java基础练习缺少项目?看这篇文章就够了!(完结)
【8月更文挑战第11天】java基础练习缺少项目?看这篇文章就够了!(完结)
39 0
|
4月前
|
安全 Java 数据安全/隐私保护
在Java项目中集成单点登录(SSO)方案
在Java项目中集成单点登录(SSO)方案
|
16天前
|
存储 安全 Java
从入门到精通:Java Map全攻略,一篇文章就够了!
【10月更文挑战第19天】本文介绍了Java编程中重要的数据结构——Map,通过问答形式讲解了Map的基本概念、创建、访问与修改、遍历方法、常用实现类(如HashMap、TreeMap、LinkedHashMap)及其特点,以及Map在多线程环境下的使用和性能优化技巧,适合初学者和进阶者学习。
39 4
|
22天前
|
监控 Java
Java定时扫码一个文件夹下的文件,如何保证文件写入完成后才进行处理?
【10月更文挑战第13天】Java定时扫码一个文件夹下的文件,如何保证文件写入完成后才进行处理?
68 1
|
3月前
|
存储 前端开发 JavaScript
【前端学java】一篇文章带你精通java 中的数组(10)
【8月更文挑战第10天】一篇文章带你精通java 中的数组
16 3
【前端学java】一篇文章带你精通java 中的数组(10)
|
3月前
|
存储 NoSQL Java
一天五道Java面试题----第十一天(分布式架构下,Session共享有什么方案--------->分布式事务解决方案)
这篇文章是关于Java面试中的分布式架构问题的笔记,包括分布式架构下的Session共享方案、RPC和RMI的理解、分布式ID生成方案、分布式锁解决方案以及分布式事务解决方案。
一天五道Java面试题----第十一天(分布式架构下,Session共享有什么方案--------->分布式事务解决方案)
|
4月前
|
Java 关系型数据库 MySQL
GraalVM 静态编译下 OTel Java Agent 的自动增强方案与实现
在 2024 OpenTelemetry Community Day 会议中,阿里云可观测工程师张乎兴(望陶)和饶子昊(铖朴)为大家带来了《GraalVM 静态编译下 OTel Java Agent 的自动增强方案与实现》的演讲分享,介绍阿里云在相关领域的探索方案,本文是相关分享对应的中文整理。
248 17
|
3月前
|
JavaScript 前端开发 Java
java高质量数据流概念讲解,保证一篇文章帮助你搞懂概念!
【8月更文挑战第11天】java高质量数据流概念讲解,保证一篇文章帮助你搞懂概念!
30 0
java高质量数据流概念讲解,保证一篇文章帮助你搞懂概念!
下一篇
无影云桌面