当前位置: 首页 > news >正文

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

标题: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,结果如下


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







相关文章:

  • HDU-2389 Rain on your Parade(二分图之Hopcroft-Karp算法)
  • javascript实现 color颜色格式转换【 rgb和十六进制的转换】
  • HDU-4686 Arc of Dream(推公式+矩阵快速幂)
  • python之测试
  • Codeforces-557D Vitaly and Cycle(二分图染色)
  • POJ-1019 Number Sequence(思维题)
  • 【吾日三省吾身】2015.6.13-涅槃行动第二十六天
  • Codeforces Round #427 (Div. 2)-C. Star sky(二维前缀和)
  • sequioadb源码分析2
  • HDU-6058 Kanade's sum - 2017 Multi-University Training Contest - Team 3(思维+模拟链表)
  • PowerShell获取特定“描述”的虚拟机IP地址
  • HDU-6060 RXD and dividing - 2017 Multi-University Training Contest - Team 3(思维+最小斯坦纳树)
  • error while loading shared libraries错误处理
  • POJ-3270 Cow Sorting(贪心+置换)
  • php对gzip文件或者字符串解压实例参考
  • 【刷算法】求1+2+3+...+n
  • 5分钟即可掌握的前端高效利器:JavaScript 策略模式
  • Elasticsearch 参考指南(升级前重新索引)
  • golang 发送GET和POST示例
  • JavaScript/HTML5图表开发工具JavaScript Charts v3.19.6发布【附下载】
  • JS学习笔记——闭包
  • Linux各目录及每个目录的详细介绍
  • node 版本过低
  • node学习系列之简单文件上传
  • PyCharm搭建GO开发环境(GO语言学习第1课)
  • ReactNative开发常用的三方模块
  • SpringBoot几种定时任务的实现方式
  • spring学习第二天
  • 从地狱到天堂,Node 回调向 async/await 转变
  • 发布国内首个无服务器容器服务,运维效率从未如此高效
  • 工作手记之html2canvas使用概述
  • 开发基于以太坊智能合约的DApp
  • 看域名解析域名安全对SEO的影响
  • 网页视频流m3u8/ts视频下载
  •  一套莫尔斯电报听写、翻译系统
  • 怎样选择前端框架
  • 最近的计划
  • Python 之网络式编程
  • python最赚钱的4个方向,你最心动的是哪个?
  • 新海诚画集[秒速5センチメートル:樱花抄·春]
  • # 睡眠3秒_床上这样睡觉的人,睡眠质量多半不好
  • (175)FPGA门控时钟技术
  • (solr系列:一)使用tomcat部署solr服务
  • (离散数学)逻辑连接词
  • (求助)用傲游上csdn博客时标签栏和网址栏一直显示袁萌 的头像
  • (转)Groupon前传:从10个月的失败作品修改,1个月找到成功
  • .bat批处理(七):PC端从手机内复制文件到本地
  • .Net - 类的介绍
  • .net core MVC 通过 Filters 过滤器拦截请求及响应内容
  • .NET Micro Framework初体验(二)
  • .net on S60 ---- Net60 1.1发布 支持VS2008以及新的特性
  • .NET 中选择合适的文件打开模式(CreateNew, Create, Open, OpenOrCreate, Truncate, Append)
  • .NET/C# 在代码中测量代码执行耗时的建议(比较系统性能计数器和系统时间)
  • .net程序集学习心得
  • .NET学习全景图