SSH框架网上商城项目第15战之线程、定时器同步首页数据

上一节我们做完了首页UI界面,但是有个问题:如果我在后台添加了一个商品,那么我必须重启一下服务器才能重新同步后台数据,然后刷新首页才能同步数据。这明显不是我们想要的效果,一般这种网上商城首页肯定不是人为手动同步数据的,那么如何解决呢?我们需要用到线程和定时器来定时自动同步首页数据。
1. Timer和TimerTask
我们需要用到Timer和TimerTask两个类。先来介绍下这两个类。
Timer是一种工具类,在java.util包中,线程用其安排以后在后台线程中执行的任务。可安排任务执行一次,或者定期重复执行。它有个构造函数:

Timer(boolean isDaemon)
//创建一个新计时器,可以指定其相关的线程作为守护程序运行。

守护线程即主线程结束后,该线程也结束,非守护线程即主线程结束后,该线程仍然继续执行。isDaemon为true时为守护线程。Timer类有个schedule方法可以创建一个任务,如下:

void schedule(TimerTask task, Date firstTime, long period)
//安排指定的任务在指定的时间开始进行重复的固定延迟执行。
//第一个参数是指定任务,即TimerTask对象;第二个参数为第一次开启任务时间;

第三个参数为时间间隔,即每隔多长时间执行一次

我们再来看看TimerTask,TimerTask是用来创建一个新的线程任务的,它实现了Runnable接口,如果我们要创建一个新的线程任务,只需要继承TimerTask,并重写run方法即可。

2. 创建一个新的线程任务
下面我们来创建一个新的线程任务,用来更新后台数据:

@Component //把该对象交给Spring管理
public class ProductTimerTask extends TimerTask { 

  @Resource
  private ProductService productService = null; //注入productService
  @Resource
  private CategoryService categoryService = null; //注入categoryService 

  private ServletContext application = null; //定义一个ServletContext对象,因为我们更新了后台数据后,需要存入application域里面 

  public void setApplication(ServletContext application) {
    this.application = application; //通过监听器将这个application对象set进来,因为这里是无法拿application对象的
  } 

  @Override
   //和监听器在项目启动的时候数据初始化的逻辑一样
  public void run() {
    System.out.println("----run----");
    List<List<Product>> bigList = new ArrayList<List<Product>>(); //bigList中存放一个装有Category类的list
     // 1. 查询出热点类别
    for(Category category : categoryService.queryByHot(true)) {
      //根据热点类别id获取推荐商品信息
      List<Product> lst = productService.querByCategoryId(category.getId());
      bigList.add(lst); //将装有category的list放到bigList中
    }
     // 2. 把查询的bigList交给application内置对象
     application.setAttribute("bigList", bigList); //假设我们已经拿到了application对象
  } 

}

接下来,我们修改项目启动时监听器里面的内容,原本上面的这个查询操作是放在监听器中,当项目启动时,监听器开始执行,获取后台数据,存到application域中,然后前台通过jstl标签从application域中拿到数据。现在我们把这些事情交给我们定义的ProductTimerTask去做,那么监听器中只要设置一下定时器,让ProductTimerTask定时去更新一下后台数据即可。看看监听器中修改后的代码:

3. 在监听器中启动定时器

//@Component //监听器是web层的组件,它是tomcat实例化的,不是Spring实例化的。不能放到Spring中
public class InitDataListener implements ServletContextListener { 

  private ProductTimerTask productTimerTask = null; //定义一个ProductTimerTask对象
  private ApplicationContext context = null; 

  @Override
  public void contextDestroyed(ServletContextEvent event) {
    // TODO Auto-generated method stub 

  } 

  @Override
  public void contextInitialized(ServletContextEvent event) { 

    context = WebApplicationContextUtils.getWebApplicationContext(event.getServletContext());
    productTimerTask = (ProductTimerTask) context.getBean("productTimerTask");//从配置文件中获取ProductTimerTask对象 

    //把内置对象交给productTimerTask,因为productTimerTask里面是拿不到application的,只能通过监听器set给它
    productTimerTask.setApplication(event.getServletContext()); 

    //通过设置定时器,让首页的数据每个一小时同步一次(配置为守护线程)
    new Timer(true).schedule(productTimerTask, 0, 1000*60*60);//每个一小时执行一次productTimerTask任务,即更新一下后台数据
  } 

} 

关于InitDataListener监听器中原来的操作代码,可以对比上一节中的内容,其实就是ProductTimerTask中的更新后台数据,只不过现在放到TimerTask中去做了而已。这样我们就完成了使用线程和定时器定期同步首页数据,这个时间间隔可以自己设定。
其实CSDN博客里的部分首页数据也不是实时更新的,每天晚上会有个时间更新一次,例如左侧栏目中的博客排名,阅读排行后的显示的阅读量等,这些都是每天晚上更新一次,应该就是在后台设置了每天更新一次,原理跟这里应该是一样的。这样也减轻了服务器的压力。

本文链接:http://blog.csdn.net/eson_15/article/details/51387378

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持我们。

(0)

相关推荐

  • Java读取邮件的方法

    本文实例讲述了Java读取邮件的方法.分享给大家供大家参考.具体实现方法如下: 复制代码 代码如下: public void receive() throws Exception { Log.e(tag, "receive()"); // sharedpreference读取数据,用split()方法,分开字符串. SharedPreferences pre = getSharedPreferences("SAVE_INFORMATION",MODE_WORLD_R

  • java mail使用qq邮箱发邮件的配置方法

    程序入口:Test_Email_N.java 复制代码 代码如下: import java.io.IOException;import java.util.Date;import java.util.Properties; import javax.mail.Authenticator;import javax.mail.BodyPart;import javax.mail.Message;import javax.mail.MessagingException;import javax.mai

  • SSH框架网上商城项目第25战之使用java email给用户发送邮件

    当用户购买完商品后,我们应该向用户发送一封邮件,告诉他订单已生成之类的信息,邮箱地址是从用户的基本信息中获取,好了,首先我们来看一下java中发送邮件的方法. 1. java中发送email的方法 在完善这个项目之前,先来回顾一下java中是如何发送邮件的,首先肯定需要发送邮件的jar包:mail.jar,导入到lib目录下,好了,下面我们先写一个普通的java程序来回顾一下java email的知识点: public class SendEmailDemo { public static vo

  • Java Mail与Apache Mail发送邮件示例

    一.邮件简介 一封邮件由很多信息构成,主要的信息如下,其他的暂时不考虑,例如抄送等: 1.收件人:收件人的邮箱地址,例如xxx@xx.com 2.收件人姓名:大部分的邮件显示时都会显示,例如loadfate 779554589@qq.com 3.发件人:发件人的邮箱地址 4.发件人姓名: 5.主题:邮件的标题 6.内容及附件:邮件的主要内容 二.使用Java发邮件的通用步骤 一般的项目中没有单独的邮件服务器,一般情况下都是使用别人的服务器. 1.设置smtp服务器:不同的邮件服务器有不同的地址,

  • SSH框架网上商城项目第12战之添加和更新商品功能

    添加商品部分原理和添加商品类别是一样的,参考文章:添加和更新商品类别,不过要比商品类别复杂,因为商品的属性有很多,对应的数据库中的字段也就多了,添加商品还有个选项是上传图片,这一小块内容会在下一篇文章中单独说明,因为这涉及到一个知识点,就是Struts2实现文件上传功能.其他废话不多说了,现在开始完善添加商品部分的代码: 1. 添加商品 1.1 添加商品的UI实现 首先完成query.jsp中添加商品部分的代码: 接下来我们看save.jsp中的具体实现: <%@ page language=&qu

  • Java邮件发送程序(可以同时发给多个地址、可以带附件)

    发送邮件的主程序 import java.util.Properties; import common.util.Email_Autherticatorbean; import javax.mail.Authenticator; import javax.mail.internet.InternetAddress; import org.apache.commons.lang.StringUtils; import javax.mail.internet.MimeBodyPart; import

  • java中javamail发送带附件的邮件实现方法

    本文实例讲述了java中javamail发送带附件的邮件实现方法.分享给大家供大家参考.具体分析如下: JavaMail,顾名思义,提供给开发者处理电子邮件相关的编程接口.它是Sun发布的用来处理email的API.它可以方便地执行一些常用的邮件传输,JavaMail是可选包,因此如果需要使用的话你需要首先从java官网上下载.目前最新版本是JavaMail1.5.0,下面我们来看看javamail发送带附件的邮件实例 mail.java 代码: 复制代码 代码如下: package mail;

  • SSH框架网上商城项目第17战之购物车基本功能

    上一节我们将商品的详细页面做完了,并使用了Hibernate的二级缓存加载详细页面来提高系统的性能,点击文章查看:.这节我们开始做购物车部分. 1. 添加新的表 首先我们向数据库中添加几张表:用户表.订单状态表.订单表(购物车表)以及购物项表.用户表中存有用户的基本信息,订单状态表中主要存储订单的状态,比如已发货这种,订单表主要存储用户的信息和订单的状态,所以跟用户表和订单状态表关联,购物项表存储某个商品以及所属的订单,所以跟商品表和订单表相关联.具体的表信息见下面的sql语句: /*=====

  • java发送邮件的具体实现

    首先是继承自javax.mail.Authenticator的一个具体类.getPasswordAuthentication()方法也就是构建一个PasswordAuthentication对象并返回,有点费解JAVA Mail这样的设计意图,可能javax.mail.Authenticator为我们提供了附加的保证安全的验证措施吧. 复制代码 代码如下: package com.mzule.simplemail; import javax.mail.Authenticator;import j

  • java 发送邮件的实例代码(可移植)

    以一个web项目为例,代码是可以移植的 首先要导入mail.jar包,然后创建自己的类 1:HTMLSender类 复制代码 代码如下: package com.txq.mail; import java.util.Properties; import javax.mail.Message; import javax.mail.MessagingException; import javax.mail.NoSuchProviderException; import javax.mail.Sess

随机推荐