<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-strict.dtd"> <html><head><meta http-equiv="Cont-阿里云开发者社区

<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-strict.dtd"> <html><head><meta http-equiv="Cont

2019-06-01 1506

版权

本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

本文涉及的产品

RDS MySQL Serverless 基础系列，0.5-2RCU 50GB

云数据库 RDS MySQL，集群版 2核4GB 100GB

云数据库 RDS MySQL，高可用版 2核4GB 50GB

简介： 标题：ejb3中的@Schedule中的persistent属性的深入探索1 实验环境：应用服务器：glassfish4.

标题：ejb3中的@Schedule中的persistent属性的深入探索

1 实验环境：

    应用服务器：glassfish4.0

    数据库服务器： MYSQL Target Server Version : 50614

    开发工具: netbeans8.0

2 我思考的问题：当我开发好了一个@Schedule定时任务之后，我开始思考这样一种场景，如果我的应用服务器(glassfish4)是集群，那么我的定时任务会怎么执行，因为在你发布一个项目到glassfish集群中，每一台jvm中都会运行相同的程序。那定时器也必然存在多份。那么我的定时器组件会在同一时间点执行多次吗(执行在多个jvm中)？

如果不会,是什么机制控制定时器的统一性，如果会，那么我们又改怎么解决呢？

3 在编写一个定时器任务时，代码如下：
 @Schedule(second = "*/5", minute = "*", hour = "*", persistent = true,info = "我是定时器")
    public void doWork() {
	System.out.println("timer: " + System.currentTimeMillis());
 }
(1 ) persistent 值官方给出的说明是 Specifies whether the timer that is created is persistent.指定在创建该定时器是否需要持久化.

(2 )时间格式的参数你可以参考的别的文章，我本文中主要介绍persistent这个值的情况，该值的默认值是true，也就说定时器的数据信息室会保存到数据库去的，那么他保存到那个数据去了呢? 其实如果你设置了persistent等于true或者不设置，定时器的数据信息都会保存到内存数据库中。

对应的物理路径如下：D:\AppServer\my-glassfish4\glassfish\domains\domain1\lib\databases 你可以尝试删除该文件夹的内容试一试，看看变动后的效果。

4 那么既然是可以保存到数据库，那么是否也可以保存到mysql数据库呢。而不是内存数据库呢，答案是可以的。

在mysql中配置GlassFish中使用EJBTimer，需要有一个独立的数据源，和数据表EJB__TIMER__TBL，建表语句可在[glassfish安装目录]\glassfish\lib\install\databases中找到。对于developer模式，GlassFish默认使用内置的__TimerPool，不需要你手工创建datasource和表；对于cluster模式，Admin Server会默认使用__TimerPool，Cluster则需要单独配置。如果让Admin Server和Cluster同时使用手工创建的datasource，则可能导致Cluster配置中的timer datasource在server重启后丢失，TimerService会出现异常，这应该是GlassFish的BUG，目前的解决方案就是Admin Server用默认的Timer配置，Cluster用另外的配置。

建表语句如下：
CREATE TABLE EJB__TIMER__TBL (
    `CREATIONTIMERAW`      BIGINT        NOT NULL,
    `BLOB`                 BLOB,
    `TIMERID`              VARCHAR(255)  NOT NULL,
    `CONTAINERID`          BIGINT        NOT NULL,
    `OWNERID`              VARCHAR(255)  NULL,
    `STATE`                INTEGER       NOT NULL,
    `PKHASHCODE`           INTEGER       NOT NULL,
    `INTERVALDURATION`     BIGINT        NOT NULL,
    `INITIALEXPIRATIONRAW` BIGINT        NOT NULL,
    `LASTEXPIRATIONRAW`    BIGINT        NOT NULL,
    `SCHEDULE`             VARCHAR(255)  NULL,
    `APPLICATIONID`        BIGINT        NOT NULL,
    CONSTRAINT `PK_EJB__TIMER__TBL` PRIMARY KEY (`TIMERID`) 
);
把该ejbtimer_mysql.sql放到数据中执行，然后配置一个数据库连接池，我这里就直接修改默认的数据连接池__TimerPool。
<jdbc-resource pool-name="__TimerPool" jndi-name="jdbc/__TimerPool" object-type="system-admin"></jdbc-resource>
    <jdbc-resource pool-name="DerbyPool" jndi-name="jdbc/__default" object-type="system-all"></jdbc-resource>
    <jdbc-connection-pool max-pool-size="100" 
	datasource-classname="com.mysql.jdbc.jdbc2.optional.MysqlXADataSource" 
	res-type="javax.sql.XADataSource" 
	steady-pool-size="32" name="__TimerPool">
      <property name="password" value="Passw0rd"></property>
      <property name="user" value="root"></property>
      <property name="url" value="jdbc:mysql://127.0.0.1:3306/test?characterEncoding=GBK"></property>
      <property name="URL" value="jdbc:mysql://localhost:3306/test?characterEncoding=GBK"></property>
      <property name="Password" value="Passw0rd"></property>
      <property name="User" value="root"></property>
    </jdbc-connection-pool>
建表语句是在test库中执行的，这样配置之后你的ejb定时器使用的就是你自定义的数据库了。然后重新启动glassfish服务器，并把你定时器任务程序发布到glassfish上去。若果发布中提示EJB__TIMER__TBL表找不到，那你应该是忘记执行建表sql了。好了当我定时应用程序启动后：

这是我的代码程序：
/**
 * 测试定时器的持久化状态
 * @author 845885222@qq.com
 */
@Singleton
public class NewSessionBean {

    @Schedule(second = "*/5", minute = "*", hour = "*", persistent = true, info = "我是定时器")
    public void doWork() {
	System.out.println("timer: " + System.currentTimeMillis());
    }

    @Schedule(second = "*/6", minute = "*", hour = "*", persistent = true, info = "doWork2")
    public void doWork2() {
	System.out.println("doWork2: " + System.currentTimeMillis());
    }
}
控制台输出结果如下：
信息:   Redirecting to /common/index.jsf
信息:   Admin Console: Initializing Session Attributes...
信息:   timer: 1433846450001
信息:   doWork2: 1433846454001
观察我mysql数据test下的EJB__TIMER__TBL,结果如下

以后集群就不在担心定时器不同步的问题了。