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

本文涉及的产品
RDS MySQL Serverless 基础系列,0.5-2RCU 50GB
RDS MySQL Serverless 高可用系列,价值2615元额度,1个月
云数据库 RDS MySQL,高可用系列 2核4GB
简介: 标题:ejb3中的@Schedule中的persistent属性的深入探索 1 实验环境:     应用服务器:glassfish4.0     数据库服务器: MYSQL Target Server Version : 50614     开发工具: netbeans8.0 2 我思考的问题:当我开发好了一个@Schedule定时任务之后,我开始思考这样一种场景,如果我的应用服务器(glassfish4)是集群,那么我的定时任务会怎么执行,因为在你发布一个项目到glassfish集群中,每一台jvm中都会运行相同的程序。

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


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







相关实践学习
每个IT人都想学的“Web应用上云经典架构”实战
本实验从Web应用上云这个最基本的、最普遍的需求出发,帮助IT从业者们通过“阿里云Web应用上云解决方案”,了解一个企业级Web应用上云的常见架构,了解如何构建一个高可用、可扩展的企业级应用架构。
MySQL数据库入门学习
本课程通过最流行的开源数据库MySQL带你了解数据库的世界。 &nbsp; 相关的阿里云产品:云数据库RDS MySQL 版 阿里云关系型数据库RDS(Relational Database Service)是一种稳定可靠、可弹性伸缩的在线数据库服务,提供容灾、备份、恢复、迁移等方面的全套解决方案,彻底解决数据库运维的烦恼。 了解产品详情:&nbsp;https://www.aliyun.com/product/rds/mysql&nbsp;
目录
相关文章
|
安全 Java 编译器
阿里巴巴Dragonwell
阿里巴巴Dragonwell
|
10月前
|
缓存 监控 Linux
Linux性能分析利器:全面掌握perf工具
【10月更文挑战第18天】 在Linux系统中,性能分析是确保软件运行效率的关键步骤。`perf`工具,作为Linux内核自带的性能分析工具,为开发者提供了强大的性能监控和分析能力。本文将全面介绍`perf`工具的使用,帮助你成为性能优化的高手。
536 1
|
数据采集 SQL 关系型数据库
在 Postgres 中使用 Intersection
【8月更文挑战第11天】
170 0
在 Postgres 中使用 Intersection
|
运维 数据挖掘 Serverless
深度解析阿里云EMR Serverless StarRocks在OLAP数据分析中的应用场景
阿里云EMR Serverless StarRocks作为一款高性能、全场景覆盖、全托管免运维的OLAP分析引擎,在企业数据分析领域展现出了强大的竞争力和广泛的应用前景。通过其卓越的技术特点、丰富的应用场景以及完善的生态体系支持,EMR Serverless StarRocks正逐步成为企业数字化转型和智能化升级的重要推手。未来随着技术的不断进步和应用场景的不断拓展我们有理由相信EMR Serverless StarRocks将在更多领域发挥重要作用为企业创造更大的价值。
|
消息中间件 关系型数据库 MySQL
Maxwell 概述、安装、数据同步【一篇搞定】!
Maxwell 是一个由 Zendesk 开源的用于 MySQL 数据库实时数据捕获和同步的工具,支持多种数据库系统,以 JSON 格式输出变更数据。它实时监控数据库中的更新,将变化传递给其他系统,常用于实时数据管道、数据仓库和事件驱动架构。Maxwell 具有实时性、可配置性和高性能等特点。其工作流程包括 Binlog 解析、数据解析、重构、发布到消息队列(如 Kafka)以及事件处理。安装时需注意 JDK 版本,并配置 MySQL、Zookeeper 和 Kafka。此外,Maxwell 支持定向监听特定库表,并能进行历史和增量数据同步。
2172 1
|
存储 自然语言处理 算法
【第十届“泰迪杯”数据挖掘挑战赛】C题:疫情背景下的周边游需求图谱分析 问题二方案及Python实现
第十届“泰迪杯”数据挖掘挑战赛C题的解决方案,专注于疫情背景下的周边游需求图谱分析,具体针对问题二“周边游产品热度分析”,介绍了从OTA和UGC数据中提取旅游产品、计算产品热度得分、判断产品类型的方法,并给出了Python实现步骤和代码。
193 1
|
存储 安全 Java
Java.security包中的KeyStore类详解
Java.security包中的KeyStore类详解
675 0
|
Ubuntu 网络协议 应用服务中间件
免费泛域名申请以及无限续期
在Ubuntu 20.04上,使用certbot和snapd安装Let&#39;s Encrypt证书以实现免费泛域名(如`*.example.com`)的无限续期。首先安装snapd,然后卸载并安装certbot,创建certbot软连接。设置trust-plugin-with-root,安装certbot-dns-cloudflare插件,配置Cloudflare API token。通过certbot certonly命令获取证书,包括子域名,并设置自动续期。将证书导入nginx并验证。最后,创建post-renewal hook以在续期后自动重启nginx。
816 0
|
数据采集 Java 程序员
【JavaEE进阶】 Spring AOP快速上手
【JavaEE进阶】 Spring AOP快速上手