
- EJB 教程
- EJB - 主页
- EJB - 概述
- EJB - 环境设置
- EJB - 创建应用程序
- EJB - 无状态Bean
- EJB - 有状态Bean
- EJB - 持久性
- EJB - 消息驱动Bean
- EJB - 注解
- EJB - 回调
- EJB - 定时器服务
- EJB - 依赖注入
- EJB - 拦截器
- EJB - 可嵌入对象
- EJB - Blob/Clob
- EJB - 事务
- EJB - 安全性
- EJB - JNDI绑定
- EJB - 实体关系
- EJB - 访问数据库
- EJB - 查询语言
- EJB - 异常处理
- EJB - Web服务
- EJB - 打包应用程序
- EJB 有用资源
- EJB - 快速指南
- EJB - 有用资源
- EJB - 讨论
EJB - 回调
回调是一种机制,它可以拦截企业 Bean 的生命周期。EJB 3.0 规范指定了回调,为此创建了回调处理程序方法。EJB 容器调用这些回调。我们可以在 EJB 类本身或单独的类中定义回调方法。EJB 3.0 提供了许多用于回调的注解。
以下是无状态 Bean 的回调注解列表:
注解 | 描述 |
---|---|
@PostConstruct | 在第一次创建 Bean 时调用。 |
@PreDestroy | 在 Bean 从 Bean 池中移除或被销毁时调用。 |
以下是有状态 Bean 的回调注解列表:
注解 | 描述 |
---|---|
@PostConstruct | 在第一次创建 Bean 时调用。 |
@PreDestroy | 在 Bean 从 Bean 池中移除或被销毁时调用。 |
@PostActivate | 在加载 Bean 以供使用时调用。 |
@PrePassivate | 在将 Bean 放回 Bean 池时调用。 |
以下是消息驱动 Bean 的回调注解列表:
注解 | 描述 |
---|---|
@PostConstruct | 在第一次创建 Bean 时调用。 |
@PreDestroy | 在 Bean 从 Bean 池中移除或被销毁时调用。 |
以下是实体 Bean 的回调注解列表:
注解 | 描述 |
---|---|
@PrePersist | 在数据库中创建实体时调用。 |
@PostPersist | 在数据库中创建实体后调用。 |
@PreRemove | 在从数据库中删除实体时调用。 |
@PostRemove | 在从数据库中删除实体后调用。 |
@PreUpdate | 在更新数据库中的实体之前调用。 |
@PostLoad | 在从数据库中提取记录并加载到实体中时调用。 |
示例应用程序
让我们创建一个测试 EJB 应用程序来测试 EJB 中的各种回调。
步骤 | 描述 |
---|---|
1 | 根据EJB - 创建应用程序章节中所述,创建一个名为EjbComponent的项目,位于包com.tutorialspoint.stateless下。您也可以使用EJB - 持久性章节中创建的项目,在本节中向 EJB 添加各种回调。 |
2 | 根据EJB - 创建应用程序章节中所述,创建LibrarySessionBean.java和LibrarySessionBeanRemote。保持其余文件不变。 |
3 | 使用EJB - 持久性章节中创建的 Bean。添加如下所示的回调方法。保持其余文件不变。 |
4 | 在包com.tutorialspoint.callback下创建一个名为BookCallbackListener的 Java 类。此类将演示回调方法的分离。 |
5 | 清理并构建应用程序,以确保业务逻辑按要求工作。 |
6 | 最后,将应用程序以 jar 文件的形式部署到 JBoss 应用服务器上。如果 JBoss 应用服务器尚未启动,它将自动启动。 |
7 | 现在创建 EJB 客户端,一个基于控制台的应用程序,方法与EJB - 创建应用程序章节中创建访问 EJB 的客户端主题中所述相同。 |
EJBComponent(EJB 模块)
BookCallbackListener.java
package com.tutorialspoint.callback; import javax.persistence.PrePersist; import javax.persistence.PostLoad; import javax.persistence.PostPersist; import javax.persistence.PostRemove; import javax.persistence.PostUpdate; import javax.persistence.PreRemove; import javax.persistence.PreUpdate; import com.tutorialspoint.entity.Book; public class BookCallbackListener { @PrePersist public void prePersist(Book book) { System.out.println("BookCallbackListener.prePersist:" + "Book to be created with book id: "+book.getId()); } @PostPersist public void postPersist(Object book) { System.out.println("BookCallbackListener.postPersist::" + "Book created with book id: "+((Book)book).getId()); } @PreRemove public void preRemove(Book book) { System.out.println("BookCallbackListener.preRemove:" + " About to delete Book: " + book.getId()); } @PostRemove public void postRemove(Book book) { System.out.println("BookCallbackListener.postRemove::" + " Deleted Book: " + book.getId()); } @PreUpdate public void preUpdate(Book book) { System.out.println("BookCallbackListener.preUpdate::" + " About to update Book: " + book.getId()); } @PostUpdate public void postUpdate(Book book) { System.out.println("BookCallbackListener.postUpdate::" + " Updated Book: " + book.getId()); } @PostLoad public void postLoad(Book book) { System.out.println("BookCallbackListener.postLoad::" + " Loaded Book: " + book.getId()); } }
Book.java
package com.tutorialspoint.entity; import java.io.Serializable; import javax.persistence.Column; import javax.persistence.Entity; import javax.persistence.EntityListeners; import javax.persistence.GeneratedValue; import javax.persistence.GenerationType; import javax.persistence.Id; import javax.persistence.Table; @Entity @Table(name="books") public class Book implements Serializable{ private int id; private String name; public Book() { } @Id @GeneratedValue(strategy= GenerationType.IDENTITY) @Column(name="id") public int getId() { return id; } public void setId(int id) { this.id = id; } public String getName() { return name; } public void setName(String name) { this.name = name; } }
LibraryStatefulSessionBean.java
package com.tutorialspoint.stateful; import java.util.ArrayList; import java.util.List; import javax.annotation.PostConstruct; import javax.annotation.PreDestroy; import javax.ejb.PostActivate; import javax.ejb.PrePassivate; import javax.ejb.Stateful; @Stateful public class LibraryStatefulSessionBean implements LibraryStatefulSessionBeanRemote { List<String> bookShelf; public LibraryStatefulSessionBean() { bookShelf = new ArrayList<String>(); } public void addBook(String bookName) { bookShelf.add(bookName); } public List<String> getBooks() { return bookShelf; } @PostConstruct public void postConstruct() { System.out.println("LibraryStatefulSessionBean.postConstruct::" + " bean created."); } @PreDestroy public void preDestroy() { System.out.println("LibraryStatefulSessionBean.preDestroy:" + " bean removed."); } @PostActivate public void postActivate() { System.out.println("LibraryStatefulSessionBean.postActivate:" + " bean activated."); } @PrePassivate public void prePassivate() { System.out.println("LibraryStatefulSessionBean.prePassivate:" + " bean passivated."); } }
LibraryStatefulSessionBeanRemote.java
package com.tutorialspoint.stateful; import java.util.List; import javax.ejb.Remote; @Remote public interface LibraryStatefulSessionBeanRemote { void addBook(String bookName); List getBooks(); }
LibraryPersistentBean.java
package com.tutorialspoint.stateless; import com.tutorialspoint.entity.Book; import java.util.List; import javax.annotation.PostConstruct; import javax.annotation.PreDestroy; import javax.ejb.Stateless; import javax.persistence.EntityManager; import javax.persistence.PersistenceContext; @Stateless public class LibraryPersistentBean implements LibraryPersistentBeanRemote { public LibraryPersistentBean() {} @PersistenceContext(unitName="EntityEjbPU") private EntityManager entityManager; public void addBook(Book book) { entityManager.persist(book); } public List<Book> getBooks() { return entityManager.createQuery("From Book") .getResultList(); } @PostConstruct public void postConstruct() { System.out.println("postConstruct:: LibraryPersistentBean session bean" + " created with entity Manager object: "); } @PreDestroy public void preDestroy() { System.out.println("preDestroy: LibraryPersistentBean session" + " bean is removed "); } }
LibraryPersistentBeanRemote.java
package com.tutorialspoint.stateless; import com.tutorialspoint.entity.Book; import java.util.List; import javax.ejb.Remote; @Remote public interface LibraryPersistentBeanRemote { void addBook(Book bookName); List<Book> getBooks(); }
一旦您在 JBOSS 上部署 EjbComponent 项目,请注意 jboss 日志。
JBoss 自动为我们的会话 Bean 创建了一个 JNDI 条目 - LibraryPersistentBean/remote。
我们将使用此查找字符串来获取类型为 com.tutorialspoint.stateless.LibraryPersistentBeanRemote 的远程业务对象。
JBoss 应用服务器日志输出
... 16:30:01,401 INFO [JndiSessionRegistrarBase] Binding the following Entries in Global JNDI: LibraryPersistentBean/remote - EJB3.x Default Remote Business Interface LibraryPersistentBean/remote-com.tutorialspoint.stateless.LibraryPersistentBeanRemote - EJB3.x Remote Business Interface 16:30:02,723 INFO [SessionSpecContainer] Starting jboss.j2ee:jar=EjbComponent.jar,name=LibraryPersistentBean,service=EJB3 16:30:02,723 INFO [EJBContainer] STARTED EJB: com.tutorialspoint.stateless.LibrarySessionBeanRemote ejbName: LibraryPersistentBean ...
EJBTester(EJB 客户端)
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.LibrarySessionBeanRemote; 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.testEntityEjb(); } 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 testEntityEjb() { try { int choice = 1; LibraryPersistentBeanRemote libraryBean = (LibraryPersistentBeanRemote) ctx.lookup("LibraryPersistentBean/remote"); while (choice != 2) { String bookName; showGUI(); String strChoice = brConsoleReader.readLine(); choice = Integer.parseInt(strChoice); if (choice == 1) { System.out.print("Enter book name: "); bookName = brConsoleReader.readLine(); Book book = new Book(); book.setName(bookName); libraryBean.addBook(book); } else if (choice == 2) { break; } } List<Book> booksList = libraryBean.getBooks(); System.out.println("Book(s) entered so far: " + booksList.size()); int i = 0; for (Book book:booksList) { System.out.println((i+1)+". " + book.getName()); i++; } } catch (Exception e) { System.out.println(e.getMessage()); e.printStackTrace(); }finally { try { if(brConsoleReader !=null) { brConsoleReader.close(); } } catch (IOException ex) { System.out.println(ex.getMessage()); } } } }
EJBTester 执行以下任务:
从 jndi.properties 加载属性并初始化 InitialContext 对象。
在 testStatelessEjb() 方法中,使用名称“LibrarySessionBean/remote”进行 jndi 查找以获取远程业务对象(无状态 EJB)。
然后向用户显示一个图书馆商店用户界面,并要求他/她输入选择。
如果用户输入 1,系统将询问书名并使用无状态会话 Bean addBook() 方法保存书籍。会话 Bean 将书籍存储在数据库中。
如果用户输入 2,系统将使用无状态会话 Bean getBooks() 方法检索书籍并退出。
运行客户端以访问 EJB
在项目资源管理器中找到 EJBTester.java。右键单击 EJBTester 类并选择运行文件。
验证 Netbeans 控制台中的以下输出。
run: ********************** Welcome to Book Store ********************** Options 1. Add Book 2. Exit Enter Choice: 1 Enter book name: Learn Java ********************** Welcome to Book Store ********************** Options 1. Add Book 2. Exit Enter Choice: 2 Book(s) entered so far: 1 1. Learn Java BUILD SUCCESSFUL (total time: 13 seconds)
JBoss 应用服务器日志输出
您可以在 JBoss 日志中找到以下回调条目
14:08:34,293 INFO [STDOUT] postConstruct:: LibraryPersistentBean session bean created with entity Manager object ... 16:39:09,484 INFO [STDOUT] BookCallbackListener.prePersist:: Book to be created with book id: 0 16:39:09,531 INFO [STDOUT] BookCallbackListener.postPersist:: Book created with book id: 1 16:39:09,900 INFO [STDOUT] BookCallbackListener.postLoad:: Loaded Book: 1 ...