Ejb 简明教程
EJB - Timer Service
计时器服务是一种机制，可以使用它构建计划的应用程序。例如，每月 1 号生成工资单。EJB 3.0 规范指定了 @Timeout 注释，此注释有助于在无状态或消息驱动 Bean 中对 EJB 服务进行编程。EJB 容器调用由 @Timeout 注释的方法。
EJB Timer Service 是由 EJB 容器提供的服务，此服务有助于创建计时器并在计时器到期时计划回调。
Steps to Create Timer
在 Bean 中使用 @Resource 注解注入 SessionContext −
@Stateless
public class TimerSessionBean {
@Resource
private SessionContext context;
...
}使用 SessionContext 对象获取 TimerService 并创建定时器。以毫秒为单位传递时间和消息。
public void createTimer(long duration) {
context.getTimerService().createTimer(duration, "Hello World!");
}Steps to Use Timer
对方法使用 @Timeout 注解。返回类型应为 void 并传递 Timer 类型的一个参数。我们在第一次执行后取消了定时器，否则它将在固定间隔后持续运行。
@Timeout
public void timeOutHandler(Timer timer) {
System.out.println("timeoutHandler : " + timer.getInfo());
timer.cancel();
}Example Application
让我们创建一个测试 EJB 应用程序来测试 EJB 中的定时器服务。
Step |
Description |
1 |
按照 EJB - 创建应用程序章节中的说明，在包 com.tutorialspoint.timer 中创建一个名为 EjbComponent 的项目。 |
2 |
按照 EJB - 创建应用程序章节中的说明，创建 TimerSessionBean.java 和 TimerSessionBeanRemote。保持其他文件不变。 |
3 |
清理并构建应用程序以确保业务逻辑按需求工作。 |
4 |
最后，以 jar 文件的形式将应用程序部署在 JBoss 应用程序服务器上。如果 JBoss 应用程序服务器尚未启动，它会自动启动。 |
5 |
现在创建 EJB 客户端，这是一个控制台应用程序，创建方法与 EJB - 章节中主题 Create Client to access EJB 下所述相同。 |
EJBComponent (EJB Module)
TimerSessionBean.java
package com.tutorialspoint.timer;
import javax.annotation.Resource;
import javax.ejb.SessionContext;
import javax.ejb.Timer;
import javax.ejb.Stateless;
import javax.ejb.Timeout;
@Stateless
public class TimerSessionBean implements TimerSessionBeanRemote {
@Resource
private SessionContext context;
public void createTimer(long duration) {
context.getTimerService().createTimer(duration, "Hello World!");
}
@Timeout
public void timeOutHandler(Timer timer) {
System.out.println("timeoutHandler : " + timer.getInfo());
timer.cancel();
}
}TimerSessionBeanRemote.java
package com.tutorialspoint.timer;
import javax.ejb.Remote;
@Remote
public interface TimerSessionBeanRemote {
public void createTimer(long milliseconds);
}-
在 JBOSS 上部署 EjbComponent 项目后，请注意 jboss 日志。
-
JBoss 已自动为我们的会话 Bean 创建了一个 JNDI 条目 − TimerSessionBean/remote 。
-
我们将使用这个查找字符串获取类型为 − * com.tutorialspoint.timer.TimerSessionBeanRemote * 的远程业务对象
JBoss Application Server Log Output
...
16:30:01,401 INFO [JndiSessionRegistrarBase] Binding the following Entries in Global JNDI:
TimerSessionBean/remote - EJB3.x Default Remote Business Interface
TimerSessionBean/remote-com.tutorialspoint.timer.TimerSessionBeanRemote - EJB3.x Remote Business Interface
16:30:02,723 INFO [SessionSpecContainer] Starting jboss.j2ee:jar=EjbComponent.jar,name=TimerSessionBean,service=EJB3
16:30:02,723 INFO [EJBContainer] STARTED EJB: com.tutorialspoint.timer.TimerSessionBeanRemote ejbName: TimerSessionBean
...EJBTester (EJB Client)
jndi.properties
java.naming.factory.initial=org.jnp.interfaces.NamingContextFactory
java.naming.factory.url.pkgs=org.jboss.naming:org.jnp.interfaces
java.naming.provider.url=localhost-
这些属性被用于初始化java命名服务的InitialContext对象。
-
InitialContext对象将被用于查找无状态会话bean。
EJBTester.java
package com.tutorialspoint.test;
import com.tutorialspoint.stateful.TimerSessionBeanRemote;
import java.io.BufferedReader;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.util.List;
import java.util.Properties;
import javax.naming.InitialContext;
import javax.naming.NamingException;
public class EJBTester {
BufferedReader brConsoleReader = null;
Properties props;
InitialContext ctx;
{
props = new Properties();
try {
props.load(new FileInputStream("jndi.properties"));
} catch (IOException ex) {
ex.printStackTrace();
}
try {
ctx = new InitialContext(props);
} catch (NamingException ex) {
ex.printStackTrace();
}
brConsoleReader =
new BufferedReader(new InputStreamReader(System.in));
}
public static void main(String[] args) {
EJBTester ejbTester = new EJBTester();
ejbTester.testTimerService();
}
private void showGUI() {
System.out.println("**********************");
System.out.println("Welcome to Book Store");
System.out.println("**********************");
System.out.print("Options \n1. Add Book\n2. Exit \nEnter Choice: ");
}
private void testTimerService() {
try {
TimerSessionBeanRemote timerServiceBean = (TimerSessionBeanRemote)ctx.lookup("TimerSessionBean/remote");
System.out.println("["+(new Date()).toString()+ "]" + "timer created.");
timerServiceBean.createTimer(2000);
} catch (NamingException ex) {
ex.printStackTrace();
}
}
}EJBTester 正在执行以下任务。
-
从jndi.properties加载属性并初始化InitialContext对象。
-
在 testTimerService() 方法中，使用名称 - "TimerSessionBean/remote" 进行 jndi 查找以获取远程业务对象（定时器无状态 EJB）。
-
然后调用 createTimer 并传入 2000 毫秒作为计划时间。
-
EJB 容器在 2 秒后调用 timeoutHandler 方法。