zoukankan      html  css  js  c++  java
  • (转) Quartz学习——SSMM(Spring+SpringMVC+Mybatis+Mysql)和Quartz集成详解(四)

    http://blog.csdn.net/u010648555/article/details/60767633

    当任何时候觉你得难受了,其实你的大脑是在进化,当任何时候你觉得轻松,其实都在使用以前的坏习惯。

    通过前面的学习,你可能大致了解了Quartz,本篇博文为你打开学习SSMM+Quartz的旅程!欢迎上车,开始美好的旅程! 
    本篇是在SSM框架——spring+SpringMVC+Mybatis的搭建教程这篇为基础上进行的,如果不了解SSM搭建请先点击闪现到查看详情:闪现

    一:环境介绍

    工具:Eclipse+ MySQL 
    框架:Spring+SpringMVC+Mybatis 
    日志:logback 
    构建工具:Maven 
    单元测试:Junit4 
    Quartz版本:2.2.1

    二:SSMM+Quartz集成详解 
    1:概述 
    在之前SSM框架的基础集合Quartz写一个简单的Web项目,实现Quartz的动态添加,修改和删除功能!(这里只是对Cron类型的Trigger进行操作)

    2:项目结构 

    3:初始化 
    在项目中找到初始化sql——quartz_test.sql ,导入自己的数据库中!初始化的表信息如下:

    qrtz_blob_triggers,
    qrtz_calendars, 
    qrtz_fired_triggers, 
    qrtz_locks, 
    qrtz_paused_trigger_grps, 
    qrtz_scheduler_state, 
    qrtz_simple_triggers, 
    qrtz_simprop_triggers,
    qrtz_triggers, 
    user_t

    4:配置文件介绍 
    (1):在ApplicationContext.xml中添加下面的配置:

    <bean name="quartzScheduler" class="org.springframework.scheduling.quartz.SchedulerFactoryBean" >
            <property name="dataSource" ref ="dataSource" />       
            <property name="applicationContextSchedulerContextKey" value="applicationContextKey"/>
            <property name="configLocation" value="classpath:quartz.properties"/>           
        </bean>

    (2):添加quartz.properties配置文件

    # Default Properties file for use by StdSchedulerFactory
    # to create a Quartz Scheduler Instance, if a different
    # properties file is not explicitly specified.
    #
    
    #============================================================================
    # Configure Main Scheduler Properties
    #============================================================================
    org.quartz.scheduler.instanceName: quartzScheduler
    org.quartz.scheduler.instanceId = AUTO
    
    org.quartz.scheduler.rmi.export: false
    org.quartz.scheduler.rmi.proxy: false
    org.quartz.scheduler.wrapJobExecutionInUserTransaction: false
    #============================================================================
    # Configure ThreadPool
    #============================================================================
    org.quartz.threadPool.class: org.quartz.simpl.SimpleThreadPool
    org.quartz.threadPool.threadCount: 2
    org.quartz.threadPool.threadPriority: 5
    org.quartz.threadPool.threadsInheritContextClassLoaderOfInitializingThread: true
    
    org.quartz.jobStore.misfireThreshold: 60000
    #============================================================================
    # Configure JobStore
    #============================================================================
    
    #default config
    #org.quartz.jobStore.class: org.quartz.simpl.RAMJobStore
    #持久化配置
    org.quartz.jobStore.class:org.quartz.impl.jdbcjobstore.JobStoreTX
    org.quartz.jobStore.driverDelegateClass:org.quartz.impl.jdbcjobstore.StdJDBCDelegate
    org.quartz.jobStore.useProperties:true
    
    #============================================================================
    #havent cluster spring
    #============================================================================
    org.quartz.jobStore.isClustered = false  
    
    #数据库表前缀
    org.quartz.jobStore.tablePrefix:qrtz_
    #org.quartz.jobStore.dataSource:qzDS
    
    #============================================================================
    # Configure Datasources
    #============================================================================
    #JDBC驱动  Sping去管理dataSource ,这里不在配置数据源信息
    #org.quartz.dataSource.qzDS.driver:com.mysql.jdbc.Driver
    #org.quartz.dataSource.qzDS.URL:jdbc:mysql://localhost:3306/quartz_test
    #org.quartz.dataSource.qzDS.user:root
    #org.quartz.dataSource.qzDS.password:root
    #org.quartz.dataSource.qzDS.maxConnection:10

    5:关键代码简单介绍 
    (1):过滤器 
    添加过滤器拦截请求,若用户没有登录,则跳转到登录页面! 
    a. 新增LoginFilter.Java,核心代码如下:

        @Override
        public void doFilter(ServletRequest req, ServletResponse resp, FilterChain chain) throws IOException, ServletException {
            HttpServletRequest request = (HttpServletRequest) req;
            HttpServletResponse response = (HttpServletResponse) resp;
            HttpSession session = request.getSession();
            //判断Session中是否有登录用户信息
            String toke = (String) session.getAttribute(CommonConstant.LONGIN_TOKE);
            if(!StringUtils.isEmpty(toke)){
                chain.doFilter(req, resp);
            }else{
                //若没有则,跳转到登录页面
                response.sendRedirect(request.getContextPath() + "/user/toLogin");
            }
        }

    b.在web.xml配置过滤器:

     <filter>
        <filter-name>LoginFilter</filter-name>
        <filter-class>org.ssm.dufy.filter.LoginFilter</filter-class>
      </filter>
      <filter-mapping>
        <filter-name>LoginFilter</filter-name>
        <url-pattern>/</url-pattern>
      </filter-mapping>

    (2)BAO和Service接口 
    Dao主要是用户的一些操作!

    public interface IUserDao {
        int deleteByPrimaryKey(Integer id);
    
        int insert(User record);
    
        int insertSelective(User record);
    
        User selectByPrimaryKey(Integer id);
    
        int updateByPrimaryKeySelective(User record);
    
        int updateByPrimaryKey(User record);
    
        User findUser(User user);
    }

    Service主要是对定时任务的一些操作!

    package org.ssm.dufy.service;
    
    public interface QuartzService {
    
        /**
         * addJob(方法描述:添加一个定时任务) <br />
         * (方法适用条件描述: – 可选)
         * 
         * @param jobName
         *            作业名称
         * @param jobGroupName
         *            作业组名称
         * @param triggerName
         *            触发器名称
         * @param triggerGroupName
         *            触发器组名称
         * @param cls
         *            定时任务的class
         * @param cron
         *            时间表达式 void
         * @exception
         * @since 1.0.0
         */
        public void addJob(String jobName, String jobGroupName,String triggerName, String triggerGroupName, Class cls, String cron);
    
        /**
         * 
         * @param oldjobName 原job name
         * @param oldjobGroup 原job group
         * @param oldtriggerName 原 trigger name
         * @param oldtriggerGroup 原 trigger group
         * @param jobName
         * @param jobGroup
         * @param triggerName
         * @param triggerGroup
         * @param cron
         */
        public boolean modifyJobTime(String oldjobName,String oldjobGroup, String oldtriggerName, String oldtriggerGroup, String jobName, String jobGroup,String triggerName, String triggerGroup, String cron);
    
        /**
         * 修改触发器调度时间
         * @param triggerName  触发器名称
         * @param triggerGroupName  触发器组名称
         * @param cron cron表达式
         */
        public void modifyJobTime(String triggerName,
                String triggerGroupName, String cron);
    
    
        /**
         * 暂停指定的任务
         * @param jobName 任务名称
         * @param jobGroupName 任务组名称 
         * @return
         */
        public void pauseJob(String jobName,String jobGroupName);
    
        /**
         * 恢复指定的任务
         * @param jobName 任务名称
         * @param jobGroupName 任务组名称 
         * @return
         */
        public void resumeJob(String jobName,String jobGroupName);
    
        /**
         * 删除指定组任务
         * @param jobName 作业名称
         * @param jobGroupName 作业组名称
         * @param triggerName 触发器名称
         * @param triggerGroupName 触发器组名称
         */
        public void removeJob(String jobName, String jobGroupName,
                String triggerName, String triggerGroupName);
    
    
        /**
         * 开始所有定时任务。启动调度器
         */
        public void startSchedule();
    
        /**
         * 关闭调度器
         */
        public void shutdownSchedule();
    }
    

    操作用户通过Mybatis进行,操作定时器任务,使用的Quartz封装好的接口!

    主要的实现代码就不在这里展示!如需查看请看源码!

    (3)Controller 
    (1):UserController

    处理一些用户的请求操作!

    (2):QuartzController

    处理Quartz的请求操作!

    6:任务类

    package org.ssm.dufy.job;
    
    import java.util.Date;
    
    import org.quartz.Job;
    import org.quartz.JobExecutionContext;
    import org.quartz.JobExecutionException;
    
    public class HelloWorldJob implements Job{
    
    
        /**
         * "0/5 * * * * ?  五秒运行一次 
         */
        @Override
        public void execute(JobExecutionContext arg0) throws JobExecutionException {
            System.out.println("----hello world---" + new Date());
        }
    
    }
    

    7:待优化地方

    • 界面的美观性
    • 可以添加Simple类型的Trigger
    • 用户信息的管理
    • 抽象Job的Dao类 
      。。。。。。

    三:运行效果介绍 
    有两种方式启动本实例项目: 
    1:Tomcat方式,Tomcat方式不在讲解! 
    2:Jetty方式 
    在pom.xml中配置了Jetty的依赖的插件!

    <plugin>
                    <groupId>org.apache.maven.plugins</groupId>
                    <artifactId>maven-war-plugin</artifactId>
                    <version>2.4</version>
                </plugin>
                <plugin>
                    <groupId>org.mortbay.jetty</groupId>
                    <artifactId>jetty-maven-plugin</artifactId>
                    <version>8.1.15.v20140411</version>
    
                    <configuration>
                        <scanIntervalSeconds>10</scanIntervalSeconds>
                        <stopPort>9999</stopPort>
                        <reload>manual</reload>
                        <webAppConfig>
                            <contextPath>/ssm_quratz</contextPath>
                        </webAppConfig>
                        <connectors>
                            <connector implementation="org.eclipse.jetty.server.nio.SelectChannelConnector">
                                <port>8080</port>
                                <maxIdleTime>60000</maxIdleTime>
                            </connector>
                        </connectors>
                    </configuration>
                </plugin>

    在Eclipse运行步骤如在截图:

    配置的参数:

    -server -Xms1024m -Xmx2048m -XX:PermSize=512m -XX:MaxPermSize=512m -XX:+CMSClassUnloadingEnabled -XX:+PrintGCDetails -Xloggc:%M2_HOME%/gc.log -XX:+HeapDumpOnOutOfMemoryError -XX:HeapDumpPath=%M2_HOME%/java_pid.hproyuan
    • 1
    • 1

    配置好之后运行启动不报错就ok!

    最后打开浏览器,输入 http://localhost:8080/ssm_quratz

    3:运行结果图 
    (1)登录页面

    (2)任务列表页面

     
    (3)新增页面(编辑页面和此类似)

     
    (4)Eclipse控制台打印的信息

    四:源码

    SSMM(Spring+SpringMVC+Mybatis+Mysql)和Quartz集成 源码

  • 相关阅读:
    【python】虎牙直播爬虫项目
    【python】读取文件夹中所有文件名,os.walk( )
    【人工智能】使用百度api批量识别图片上的文字,进阶版
    【人工智能】使用百度api识别图片上的文字
    【python】词云图,超简单入门版
    【python】词云图,轮廓+着色,进阶版
    【python】词云图,进阶版
    【python】词云图,入门版
    【python】前程无忧51job岗位招聘信息爬虫程序,自动翻页,进阶版
    【HTML】使用百度地图api制作地图热力图,带控件,进阶版
  • 原文地址:https://www.cnblogs.com/telwanggs/p/7238248.html
Copyright © 2011-2022 走看看