EJB - 快速指南

---

EJB - 概述

EJB 代表企业 Java Bean。EJB 是 J2EE 平台的重要组成部分。J2EE平台具有基于组件的体系结构，为企业级应用程序提供多层、分布式和高度事务性的功能。

EJB 提供了一种架构来开发和部署基于组件的企业应用程序，考虑到健壮性、高可伸缩性和高性能。EJB应用程序可以部署在任何符合J2EE 1.3标准规范的应用服务器上。

我们将在本教程中详细讨论 EJB 3.0。

类型

EJB主要分为三类：下表列出了它们的名称和简要说明 -

好处

以下是 EJB 的重要优点 -

• 简化大型企业级应用程序的开发。

• 应用服务器/EJB容器提供大部分系统级服务，如事务处理、日志记录、负载平衡、持久化机制、异常处理等。开发人员只需关注应用程序的业务逻辑。

• EJB容器管理EJB实例的生命周期，因此开发人员无需担心何时创建/删除EJB对象。

EJB - 环境设置

EJB是Java 的框架，因此第一个要求是在您的计算机中安装Java开发工具包(JDK)。

系统要求

第 1 步 - 验证系统中的 Java 安装

现在打开控制台并执行以下java命令。

让我们验证所有操作系统的输出 -

如果您尚未安装 Java，请从www.oracle.com安装 Java 软件开发工具包 (SDK) 。我们假设 Java 1.6.0_21 作为本教程的安装版本。

步骤2 – 设置JAVA环境

设置JAVA_HOME环境变量以指向系统上安装 Java 的基本目录位置。例如，

将 Java 编译器位置附加到系统路径。

使用上面解释的java -version命令验证 Java 安装。

步骤 3 – 下载并安装 NetBeans IDE

从netbeans.org下载最新版本的 NetBeans IDE 。在编写本教程时，我使用以下链接www.oracle.com下载了与 JDK 1.7 捆绑在一起的Netbeans 7.3

第 4 步 – 设置 JBoss 应用服务器

您可以从www.jboss.org下载最新版本的 JBoss Server 。根据平台下载存档。将 Jboss 解压缩到计算机上的任何位置。

第 5 步 - 配置 Netbeans 的 JEE 插件

使用工具 > 插件打开插件窗口。打开“可用插件”选项卡，然后选择“Java Web 和 EE”类别下的“Java EE Base”和“EJB 和 EAR”。单击安装按钮。Netbeans 将下载并安装相应的插件。使用“已安装”选项卡验证插件安装（如下图所示）。

第 6 步 - 在 Netbeans 中配置 JBoss 服务器

转到“服务”选项卡并右键单击服务器以添加新服务器。

添加服务器实例向导将打开。选择 JBoss，然后在下一步中输入相关详细信息以在 netbeans 中配置服务器。

配置完所有内容后，您将看到以下屏幕。

步骤 7 - 安装数据库服务器 (PostGreSql)

从www.postgresql.org下载最新版本的 PostGreSql 数据库服务器。在编写本教程时，我下载了PostGreSql 9.2

EJB - 创建应用程序

为了创建一个简单的 EJB 模块，我们将使用 NetBeans 的“新建项目”向导。在下面给出的示例中，我们将创建一个名为 Component 的 EJB 模块项目。

创建项目

在 NetBeans IDE 中，选择“文件”>“新建项目”>。您将看到以下屏幕

在类别Java EE下选择项目类型，项目类型为EJB Module。单击下一步 >按钮。您将看到以下屏幕。

输入项目名称和位置。单击下一步 >按钮。您将看到以下屏幕。

选择服务器作为JBoss 应用程序服务器。单击完成按钮。您将看到 NetBeans 创建的以下项目。

创建示例 EJB

为了创建一个简单的 EJB，我们将使用 NetBeans“新建”向导。在下面给出的示例中，我们将在 EjbComponent 项目下创建一个名为librarySessionBean 的无状态 EJB 类。

在项目资源管理器窗口中选择项目 EjbComponent 并右键单击它。选择新建 > 会话 Bean。您将看到新建会话 Bean向导。

输入会话 bean 名称和包名称。单击完成按钮。您将看到 NetBeans 创建的以下 EJB 类。

• LibrarySessionBean - 无状态会话 bean

• LibrarySessionBeanLocal - 会话 bean 的本地接口

我将本地接口更改为远程接口，因为我们将在基于控制台的应用程序中访问 EJB。远程/本地接口用于公开 EJB 必须实现的业务方法。

LibrarySessionBeanLocal 重命名为 LibrarySessionBeanRemote，并且 LibrarySessionBean 实现了 LibrarySessionBeanRemote 接口。

LibrarySessionBeanRemote

package com.tutorialspoint.stateless;
 
import java.util.List;
import javax.ejb.Remote;
 
@Remote
public interface LibrarySessionBeanRemote {
   void addBook(String bookName);
   List getBooks();
}

库会话Bean

package com.tutorialspoint.stateless;
 
import java.util.ArrayList;
import java.util.List;
import javax.ejb.Stateless;
 
@Stateless
public class LibrarySessionBean implements LibrarySessionBeanRemote {
   
   List<String> bookShelf;    
   
   public LibrarySessionBean() {
      bookShelf = new ArrayList<String>();
   }
    
   public void addBook(String bookName) {
      bookShelf.add(bookName);
   }    
 
   public List<String> getBooks() {
      return bookShelf;
   }
}

构建项目

• 在 Project Explorer 窗口中选择 EjbComponent 项目。
• 右键单击它以打开上下文菜单。
• 选择清理并构建。

您将在 NetBeans 控制台输出中看到以下输出。

ant -f C:\\EJB\\EjbComponent clean dist
init:
undeploy-clean:
deps-clean:
Deleting directory C:\EJB\EjbComponent\build
Deleting directory C:\EJB\EjbComponent\dist
clean:
init:
deps-jar:
Created dir: C:\EJB\EjbComponent\build\classes
Copying 3 files to C:\EJB\EjbComponent\build\classes\META-INF
Created dir: C:\EJB\EjbComponent\build\empty
Created dir: C:\EJB\EjbComponent\build\generated-sources\ap-source-output
Compiling 2 source files to C:\EJB\EjbComponent\build\classes
warning: [options] bootstrap class path not set in conjunction with -source 1.6
Note: C:\EJB\EjbComponent\src\java\com\tutorialspoint\stateless
\LibraryPersistentBean.java uses unchecked or unsafe operations.
Note: Recompile with -Xlint:unchecked for details.
1 warning
compile:
library-inclusion-in-archive:
Created dir: C:\EJB\EjbComponent\dist
Building jar: C:\EJB\EjbComponent\dist\EjbComponent.jar
dist:
BUILD SUCCESSFUL (total time: 3 seconds)

启动应用程序服务器

• 在“服务”窗口中的“服务器”下选择 JBoss 应用程序服务器。
• 右键单击它以打开上下文菜单。
• 选择开始。

您将在 NetBeans 中看到以下输出，即 JBoss 应用程序服务器下的输出。

Calling C:\jboss-5.1.0.GA\bin\run.conf.bat
=========================================================================
 
   JBoss Bootstrap Environment
 
   JBOSS_HOME: C:\jboss-5.1.0.GA
 
   JAVA: C:\Program Files (x86)\Java\jdk1.6.0_21\bin\java
 
   JAVA_OPTS: -Dprogram.name=run.bat -Xms128m -Xmx512m -server
 
   CLASSPATH: C:\jboss-5.1.0.GA\bin\run.jar
 
=========================================================================
 
16:25:50,062 INFO  [ServerImpl] Starting JBoss (Microcontainer)...
16:25:50,062 INFO  [ServerImpl] Release ID: JBoss 
   [The Oracle] 5.1.0.GA (build: SVNTag=JBoss_5_1_0_GA date=200905221634)
...
 
16:26:40,420 INFO  [TomcatDeployment] deploy, ctxPath=/admin-console
16:26:40,485 INFO  [config] Initializing Mojarra (1.2_12-b01-FCS) for context '/admin-console'
16:26:42,362 INFO  [TomcatDeployment] deploy, ctxPath=/
16:26:42,406 INFO  [TomcatDeployment] deploy, ctxPath=/jmx-console
16:26:42,471 INFO  [Http11Protocol] Starting Coyote HTTP/1.1 on http-127.0.0.1-8080
16:26:42,487 INFO  [AjpProtocol] Starting Coyote AJP/1.3 on ajp-127.0.0.1-8009
16:26:42,493 INFO  [ServerImpl] JBoss (Microcontainer) 
   [5.1.0.GA (build: SVNTag=JBoss_5_1_0_GA date=200905221634)] Started in 52s:427ms

部署项目

• 在 Project Explorer 窗口中选择 EjbComponent 项目。
• 右键单击它以打开上下文菜单。
• 选择部署。

您将在 NetBeans 控制台输出中看到以下输出。

ant -f C:\\EJB\\EjbComponent -DforceRedeploy=true -Ddirectory.deployment.supported=false -Dnb.wait.for.caches=true run
init:
deps-jar:
compile:
library-inclusion-in-archive:
Building jar: C:\EJB\EjbComponent\dist\EjbComponent.jar
dist-directory-deploy:
pre-run-deploy:
Checking data source definitions for missing JDBC drivers...
Distributing C:\EJB\EjbComponent\dist\EjbComponent.jar to [org.jboss.deployment.spi.LocalhostTarget@1e4f84ee]
Deploying C:\EJB\EjbComponent\dist\EjbComponent.jar
Application Deployed
Operation start started
Operation start completed
post-run-deploy:
run-deploy:
run:
BUILD SUCCESSFUL (total time: 2 seconds)

JBoss应用服务器日志输出

16:30:00,963 INFO  [DeployHandler] Begin start, [EjbComponent.jar]
...
16:30:01,233 INFO  [Ejb3DependenciesDeployer] Encountered deployment AbstractVFSDeploymentContext@12038795{vfszip:/C:/jboss-5.1.0.GA/server/default/deploy/EjbComponent.jar/}
...
16:30:01,281 INFO  [JBossASKernel]    jndi:LibrarySessionBean/remote-com.tutorialspoint.stateless.LibrarySessionBeanRemote
16:30:01,281 INFO  [JBossASKernel]    Class:com.tutorialspoint.stateless.LibrarySessionBeanRemote
16:30:01,281 INFO  [JBossASKernel]    jndi:LibrarySessionBean/remote
16:30:01,281 INFO  [JBossASKernel]  Added bean(jboss.j2ee:jar=EjbComponent.jar,name=
LibrarySessionBean,service=EJB3) to KernelDeployment of: EjbComponent.jar
16:30:01,282 INFO  [JBossASKernel] installing bean: jboss.j2ee:jar=EjbComponent.jar,name=BookMessageHandler,service=EJB3
16:30:01,282 INFO  [JBossASKernel]   with dependencies:
16:30:01,282 INFO  [JBossASKernel]   and demands:
16:30:01,282 INFO  [JBossASKernel]    jboss.ejb:service=EJBTimerService
...
16:30:01,283 INFO  [EJB3EndpointDeployer] Deploy 
AbstractBeanMetaData@5497cb{name=jboss.j2ee:jar=EjbComponent.jar, 
name=LibrarySessionBean, service=EJB3_endpoint bean=org.jboss.ejb3.endpoint.deployers.impl.EndpointImpl properties=[container] constructor=null autowireCandidate=true}
...
16:30:01,394 INFO  [SessionSpecContainer] Starting jboss.j2ee:jar=EjbComponent.jar,name=LibrarySessionBean,service=EJB3
16:30:01,395 INFO  [EJBContainer] STARTED EJB: com.tutorialspoint.stateless.LibrarySessionBean ejbName: LibrarySessionBean
16:30:01,401 INFO  [JndiSessionRegistrarBase] Binding the following Entries in Global JNDI:
   LibrarySessionBean/remote - EJB3.x Default Remote Business Interface
   LibrarySessionBean/remote-com.tutorialspoint.stateless.LibrarySessionBeanRemote - EJB3.x Remote Business Interface
16:30:02,723 INFO  [SessionSpecContainer] Starting jboss.j2ee:jar=EjbComponent.jar,name=LibrarySessionBean,service=EJB3
16:30:02,723 INFO  [EJBContainer] STARTED EJB: com.tutorialspoint.stateless.LibrarySessionBean ejbName: LibrarySessionBean
16:30:02,731 INFO  [JndiSessionRegistrarBase] Binding the following Entries in Global JNDI:
 
   LibrarySessionBean/remote - EJB3.x Default Remote Business Interface
   LibrarySessionBean/remote-com.tutorialspoint.stateless.LibrarySessionBeanRemote - EJB3.x Remote Business Interface

创建客户端来访问EJB

• 在 NetBeans IDE 中，选择“文件”>“新建项目”>。

• 在类别Java下选择项目类型，项目类型为Java 应用程序。单击下一步 > 按钮

• 输入项目名称和位置。单击完成 >按钮。我们选择名称为 EjbTester。

• 右键单击项目资源管理器窗口中的项目名称。选择属性。

• 使用编译选项卡中的“添加项目”按钮添加之前在库下创建的 EJB 组件项目。

• 使用编译选项卡中的“添加 jar/文件夹”按钮添加 jboss 库。Jboss 库可以位于<jboss 安装文件夹>> 客户端文件夹。

在 EjbTester 项目下创建 jndi.properties。

jndi.属性

java.naming.factory.initial=org.jnp.interfaces.NamingContextFactory
java.naming.factory.url.pkgs=org.jboss.naming:org.jnp.interfaces
java.naming.provider.url=localhost

在其下创建包 com.tutorialspoint.test 和 EJBTester.java 类。

EJBTester.java

package com.tutorialspoint.test;
 
import com.tutorialspoint.stateless.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.testStatelessEjb();
   }
   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 testStatelessEjb() {
      try {
         int choice = 1; 
         LibrarySessionBeanRemote libraryBean = 
         (LibrarySessionBeanRemote)ctx.lookup("LibrarySessionBean/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();                    
               libraryBean.addBook(bookName);          
            }else if (choice == 2) {
               break;
            }
         }
         List<String> booksList = libraryBean.getBooks();
         System.out.println("Book(s) entered so far: " + booksList.size());
         for (int i = 0; i < booksList.size(); ++i) {
            System.out.println((i+1)+". " + booksList.get(i));
         }
         LibrarySessionBeanRemote libraryBean1 = 
         (LibrarySessionBeanRemote)ctx.lookup("LibrarySessionBean/remote");
         List<String> booksList1 = libraryBean1.getBooks();
         System.out.println(
            "***Using second lookup to get library stateless object***");
         System.out.println(
            "Book(s) entered so far: " + booksList1.size());
         for (int i = 0; i < booksList1.size(); ++i) {
            System.out.println((i+1)+". " + booksList1.get(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());
         }
      }
   }  
}

运行客户端访问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
***Using second lookup to get library stateless object***
Book(s) entered so far: 0
BUILD SUCCESSFUL (total time: 13 seconds)

在接下来的章节中，我们将介绍这个完整的 EJB 应用程序的多个方面。

EJB-无状态Bean

无状态会话 Bean 是企业 Bean 的一种，通常用于执行独立操作。无状态会话 bean 根据其名称没有任何关联的客户端状态，但它可以保留其实例状态。EJB容器通常创建一个由少量无状态bean对象组成的池，并使用这些对象来处理客户端的请求。由于池的原因，不能保证实例变量值在查找/方法调用中相同。

创建无状态 EJB 的步骤

以下是创建无状态 EJB 所需的步骤 -

• 创建公开业务方法的远程/本地接口。

• 该接口将由 EJB 客户端应用程序使用。

• 如果 EJB 客户端与要部署 EJB 会话 bean 的环境相同，请使用 @Local 注释。

• 如果 EJB 客户端位于要部署 EJB 会话 bean 的不同环境中，请使用 @Remote 注释。

• 创建一个无状态会话bean，实现上述接口。

• 使用 @Stateless 注释来表示它是无状态 bean。EJB Container 在部署时通过读取此注解自动创建所需的相关配置或接口。

远程接口

import javax.ejb.Remote;
 
@Remote
public interface LibrarySessionBeanRemote {
   //add business method declarations
}

无状态EJB

@Stateless
public class LibrarySessionBean implements LibrarySessionBeanRemote {
   //implement business method 
}

应用示例

让我们创建一个测试 EJB 应用程序来测试无状态 EJB。

EJB组件（EJB模块）

LibrarySessionBeanRemote.java

package com.tutorialspoint.stateless;
 
import java.util.List;
import javax.ejb.Remote;
 
@Remote
public interface LibrarySessionBeanRemote {
   void addBook(String bookName);
   List getBooks();
}

LibrarySessionBean.java

 
package com.tutorialspoint.stateless;
 
import java.util.ArrayList;
import java.util.List;
import javax.ejb.Stateless;
 
@Stateless
public class LibrarySessionBean implements LibrarySessionBeanRemote {
    
   List<String> bookShelf;    
 
   public LibrarySessionBean() {
      bookShelf = new ArrayList<String>();
   }
 
   public void addBook(String bookName) {
      bookShelf.add(bookName);
   }    
 
   public List<String> getBooks() {
      return bookShelf;
   }
}

• 在 JBOSS 上部署 EjbComponent 项目后，请注意 jboss 日志。

• JBoss 已经自动为我们的会话 bean 创建了一个 JNDI 条目 - LibrarySessionBean/remote。

• 我们将使用此查找字符串来获取类型为com.tutorialspoint.stateless.LibrarySessionBeanRemote的远程业务对象

JBoss应用服务器日志输出

...
16:30:01,401 INFO  [JndiSessionRegistrarBase] Binding the following Entries in Global JNDI:
   LibrarySessionBean/remote - EJB3.x Default Remote Business Interface
   LibrarySessionBean/remote-com.tutorialspoint.stateless.LibrarySessionBeanRemote - EJB3.x Remote Business Interface
16:30:02,723 INFO  [SessionSpecContainer] Starting jboss.j2ee:jar=EjbComponent.jar,name=LibrarySessionBean,service=EJB3
16:30:02,723 INFO  [EJBContainer] STARTED EJB: com.tutorialspoint.stateless.LibrarySessionBeanRemote ejbName: LibrarySessionBean
16:30:02,731 INFO  [JndiSessionRegistrarBase] Binding the following Entries in Global JNDI:
 
   LibrarySessionBean/remote - EJB3.x Default Remote Business Interface
   LibrarySessionBean/remote-com.tutorialspoint.stateless.LibrarySessionBeanRemote - EJB3.x Remote Business Interface
...   

EJBTester（EJB 客户端）

jndi.属性

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.testStatelessEjb();
   }
   
   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 testStatelessEjb() {
 
      try {
         int choice = 1; 
 
         LibrarySessionBeanRemote libraryBean =
         LibrarySessionBeanRemote)ctx.lookup("LibrarySessionBean/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++;
         }       
         LibrarySessionBeanRemote libraryBean1 = 
            (LibrarySessionBeanRemote)ctx.lookup("LibrarySessionBean/remote");
         List<String> booksList1 = libraryBean1.getBooks();
         System.out.println(
            "***Using second lookup to get library stateless object***");
         System.out.println(
            "Book(s) entered so far: " + booksList1.size());
         for (int i = 0; i < booksList1.size(); ++i) {
            System.out.println((i+1)+". " + booksList1.get(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() 方法检索书籍并退出。

• 然后，使用名称“LibrarySessionBean/remote”进行另一个 jndi 查找，以再次获取远程业务对象（无状态 EJB），并完成书籍列表。

运行客户端访问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
***Using second lookup to get library stateless object***
Book(s) entered so far: 0
BUILD SUCCESSFUL (total time: 13 seconds)

再次运行客户端访问EJB

在项目资源管理器中找到 EJBTester.java。右键单击 EJBTester 类并选择运行文件。

在 Netbeans 控制台中验证以下输出。

run:
**********************
Welcome to Book Store
**********************
Options 
1. Add Book
2. Exit 
Enter Choice: 2
Book(s) entered so far: 0
***Using second lookup to get library stateless object***
Book(s) entered so far: 1
1. Learn Java
BUILD SUCCESSFUL (total time: 12 seconds)

• 上面显示的输出可能会有所不同，具体取决于 JBoss 维护的无状态 EJB 对象的数量。

• 如果维护单个无状态 EJB 对象，则每次查找后您可能会看到相同的书籍列表。

• EJB 容器可能会为每次查找返回相同的无状态 EJB 对象。

• 无状态 EJB bean 会保留实例变量的值，直到服务器未重新启动为止。

EJB - 有状态 Bean

有状态会话 Bean 是企业 Bean 的一种，它保留与客户端的会话状态。有状态会话 Bean 根据其名称将关联的客户端状态保存在其实例变量中。EJB容器创建一个单独的有状态会话bean来处理客户端的每个请求。一旦请求范围结束，有状态会话 bean 就会被销毁。

创建有状态 EJB 的步骤

以下是创建有状态 EJB 所需的步骤 -

• 创建公开业务方法的远程/本地接口。

• 该接口将由 EJB 客户端应用程序使用。

• 如果 EJB 客户端与需要部署 EJB 会话 bean 的环境相同，请使用 @Local 注释。

• 如果EJB客户端处于需要部署EJB会话bean的不同环境中，请使用@Remote注释。

• 创建一个有状态会话bean，实现上述接口。

• 使用@Stateful注释来表示它是一个有状态的bean。EJB Container 在部署时通过读取此注解自动创建所需的相关配置或接口。

远程接口

import javax.ejb.Remote;
 
@Remote
public interface LibraryStatefulSessionBeanRemote {
   //add business method declarations
}

有状态EJB

@Stateful
public class LibraryStatefulSessionBean implements LibraryStatefulSessionBeanRemote {
   //implement business method 
}

应用示例

让我们创建一个测试 EJB 应用程序来测试有状态 EJB。

EJB组件（EJB模块）

LibraryStatefulSessionBeanRemote.java

package com.tutorialspoint.stateful;
 
import java.util.List;
import javax.ejb.Remote;
 
@Remote
public interface LibraryStatefulSessionBeanRemote {
   void addBook(String bookName);
   List getBooks();
}

LibraryStatefulSessionBean.java

package com.tutorialspoint.stateful;
 
import java.util.ArrayList;
import java.util.List;
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;
   }
}

• 在 JBOSS 上部署 EjbComponent 项目后，请注意 jboss 日志。

• JBoss 已经自动为我们的会话 bean 创建了一个 JNDI 条目 - LibraryStatefulSessionBean/remote。

• 我们将使用此查找字符串来获取类型为com.tutorialspoint.stateful.LibraryStatefulSessionBeanRemote的远程业务对象

JBoss应用服务器日志输出

...
16:30:01,401 INFO  [JndiSessionRegistrarBase] Binding the following Entries in Global JNDI:
   LibraryStatefulSessionBean/remote - EJB3.x Default Remote Business Interface
   LibraryStatefulSessionBean/remote-com.tutorialspoint.stateful.LibraryStatefulSessionBeanRemote - EJB3.x Remote Business Interface
16:30:02,723 INFO  [SessionSpecContainer] Starting jboss.j2ee:jar=EjbComponent.jar,name=LibraryStatefulSessionBean,service=EJB3
16:30:02,723 INFO  [EJBContainer] STARTED EJB: com.tutorialspoint.stateful.LibraryStatefulSessionBeanRemote ejbName: LibraryStatefulSessionBean
16:30:02,731 INFO  [JndiSessionRegistrarBase] Binding the following Entries in Global JNDI:
 
   LibraryStatefulSessionBean/remote - EJB3.x Default Remote Business Interface
   LibraryStatefulSessionBean/remote-com.tutorialspoint.stateful.LibraryStatefulSessionBeanRemote - EJB3.x Remote Business Interface
...   

EJBTester（EJB 客户端）

jndi.属性

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.LibraryStatefulSessionBeanRemote;
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.testStatelessEjb();
   }
   
   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 testStatelessEjb() {
 
      try {
         int choice = 1; 
 
         LibraryStatefulSessionBeanRemote libraryBean =
         LibraryStatefulSessionBeanRemote)ctx.lookup("LibraryStatefulSessionBean/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++;
         }       
         LibraryStatefulSessionBeanRemote libraryBean1 = 
            (LibraryStatefulSessionBeanRemote)ctx.lookup("LibraryStatefulSessionBean/remote");
         List<String> booksList1 = libraryBean1.getBooks();
         System.out.println(
            "***Using second lookup to get library stateful object***");
         System.out.println(
            "Book(s) entered so far: " + booksList1.size());
         for (int i = 0; i < booksList1.size(); ++i) {
            System.out.println((i+1)+". " + booksList1.get(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 对象。

• 在 testStatefulEjb() 方法中，使用名称“LibraryStatefulSessionBean/remote”进行 jndi 查找，以获取远程业务对象（有状态 ejb）。

• 然后，向用户显示图书馆商店用户界面，并要求他/她输入选择。

• 如果用户输入 1，系统会询问书籍名称并使用有状态会话 bean addBook() 方法保存书籍。会话 Bean 将书存储在其实例变量中。

• 如果用户输入 2，系统将使用有状态会话 bean getBooks() 方法检索书籍并退出。

• 然后，使用名称“LibraryStatefulSessionBean/remote”进行另一个 jndi 查找，以再次获取远程业务对象（有状态 EJB），并完成书籍列表。

运行客户端访问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
***Using second lookup to get library stateful object***
Book(s) entered so far: 0
BUILD SUCCESSFUL (total time: 13 seconds)

再次运行客户端访问EJB

在项目资源管理器中找到 EJBTester.java。右键单击 EJBTester 类并选择运行文件。

在 Netbeans 控制台中验证以下输出。

run:
**********************
Welcome to Book Store
**********************
Options 
1. Add Book
2. Exit 
Enter Choice: 2
Book(s) entered so far: 0
***Using second lookup to get library stateful object***
Book(s) entered so far: 0
BUILD SUCCESSFUL (total time: 12 seconds)

• 上面显示的输出表明，对于每次查找，都会返回一个不同的有状态 EJB 实例。

• 有状态 EJB 对象仅保留单个会话的值。与第二轮一样，我们没有得到任何有价值的书籍。

EJB-持久性

EJB 3.0中，EJB 2.0中使用的实体bean很大程度上被持久化机制所取代。现在实体bean是一个简单的POJO，具有与表的映射。

以下是持久性 API 的关键参与者 -

• 实体- 表示数据存储记录的持久对象。可序列化是件好事。

• EntityManager - 持久化接口，用于在持久化对象（实体）上执行添加/删除/更新/查找等数据操作。它还有助于使用查询接口执行查询。

• 持久化单元 (persistence.xml) - 持久化单元描述持久化机制的属性。

• 数据源 (*ds.xml) - 数据源描述了数据存储相关的属性，例如连接 url。用户名、密码等

为了演示 EJB 持久化机制，我们需要执行以下任务 -

• 步骤 1 - 在数据库中创建表。

• 步骤 2 - 创建与表对应的实体类。

• 步骤 3 - 创建数据源和持久性单元。

• 步骤 4 - 创建具有 EntityManager 实例的无状态 EJB。

• 步骤 5 - 更新无状态 EJB。添加通过实体管理器添加记录和从数据库获取记录的方法。

• 步骤 6 - 基于控制台的应用程序客户端将访问无状态 EJB 以将数据保存在数据库中。

创建表

在默认数据库postgres中创建一个表books。

CREATE TABLE books (
   id     integer PRIMARY KEY,
   name   varchar(50)
);

创建实体类

//mark it entity using Entity annotation 
//map table name using Table annotation
@Entity
@Table(name="books")
public class Book implements Serializable{
    
   private int id;
   private String name;

   public Book() {        
   }

   //mark id as primary key with autogenerated value
   //map database column id with id field
   @Id
   @GeneratedValue(strategy= GenerationType.IDENTITY)
   @Column(name="id")
   public int getId() {
      return id;
   }
   ...
}

创建数据源和持久化单元

数据源（jboss-ds.xml）

<?xml version = "1.0" encoding = "UTF-8"?>
<datasources>
   <local-tx-datasource>
      <jndi-name>PostgresDS</jndi-name>
      <connection-url>jdbc:postgresql://localhost:5432/postgres</connection-url>
      <driver-class>org.postgresql.driver</driver-class>
      <user-name>sa</user-name>
      <password>sa</password>
      <min-pool-size>5</min-pool-size>
      <max-pool-size>20</max-pool-size>
      <idle-timeout-minutes>5</idle-timeout-minutes>
   </local-tx-datasource>
</datasources>

持久性单元（persistence.xml）

<persistence version = "1.0" xmlns = "http://java.sun.com/xml/ns/persistence" xmlns:xsi = "http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://java.sun.com/xml/ns/persistence http://java.sun.com/xml/ns/persistence/persistence_1_0.xsd">

   <persistence-unit name = "EjbComponentPU" transaction-type = "JTA">
      <jta-data-source>java:/PostgresDS</jta-data-source>
      <exclude-unlisted-classes>false</exclude-unlisted-classes>
      <properties/>
   </persistence-unit>
   
   <persistence-unit name = "EjbComponentPU2" transaction-type = "JTA">
      <provider>org.hibernate.ejb.HibernatePersistence</provider>
      <jta-data-source>java:/PostgresDS</jta-data-source>
      <exclude-unlisted-classes>false</exclude-unlisted-classes>
	  
      <properties>
         <property name="hibernate.hbm2ddl.auto" value="update"/>
      </properties>
   </persistence-unit>
   
</persistence>

创建具有 EntityManager 实例的无状态 EJB

@Stateless
public class LibraryPersistentBean implements LibraryPersistentBeanRemote {
	
   //pass persistence unit to entityManager.
   @PersistenceContext(unitName="EjbComponentPU")
   private EntityManager entityManager;         

   public void addBook(Book book) {
      entityManager.persist(book);
   }    

   public List<Book> getBooks() {        
      return entityManager.createQuery("From Books").getResultList();
   }
   ...
}

构建 EJB 模块后，我们需要一个客户端来访问无状态 bean，我们将在下一节中创建它。

应用示例

让我们创建一个测试 EJB 应用程序来测试 EJB 持久性机制。

EJB组件（EJB模块）

书本.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;
   }    
}

库PersistentBeanRemote.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();
    
}

库PersistentBean.java

package com.tutorialspoint.stateless;

import com.tutorialspoint.entity.Book;
import java.util.List;
import javax.ejb.Stateless;
import javax.persistence.EntityManager;
import javax.persistence.PersistenceContext;

@Stateless
public class LibraryPersistentBean implements LibraryPersistentBeanRemote {
    
   public LibraryPersistentBean() {
   }

   @PersistenceContext(unitName="EjbComponentPU")
   private EntityManager entityManager;         

   public void addBook(Book book) {
      entityManager.persist(book);
   }    

   public List<Book> getBooks() {
      return entityManager.createQuery("From Book").getResultList();
   }
}

• 在 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=LibraryPersistentBeanRemote,service=EJB3
16:30:02,723 INFO  [EJBContainer] STARTED EJB: com.tutorialspoint.stateless.LibraryPersistentBeanRemote ejbName: LibraryPersistentBean
16:30:02,731 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
...   

EJBTester（EJB 客户端）

jndi.属性

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.stateless.LibraryPersistentBeanRemote;
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 对象。

• 在 testStatefulEjb() 方法中，使用名称“LibraryStatefulSessionBean/remote”进行 jndi 查找，以获取远程业务对象（有状态 ejb）。

• 然后，向用户显示图书馆商店用户界面，并要求他/她输入选择。

• 如果用户输入 1，系统会询问书籍名称并使用无状态会话 bean addBook() 方法保存书籍。Session Bean 通过 EntityManager 调用将书籍保存在数据库中。

• 如果用户输入 2，系统将使用有状态会话 bean getBooks() 方法检索书籍并退出。

• 然后，使用名称“LibraryStatelessSessionBean/remote”完成另一个 jndi 查找，以再次获取远程业务对象（无状态 EJB），并完成书籍列表。

运行客户端访问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: 15 seconds)

再次运行客户端访问EJB

在访问 EJB 之前重新启动 JBoss。

在项目资源管理器中找到 EJBTester.java。右键单击 EJBTester 类并选择运行文件。

在 Netbeans 控制台中验证以下输出。

run:
**********************
Welcome to Book Store
**********************
Options 
1. Add Book
2. Exit 
Enter Choice: 1
Enter book name: Learn Spring
**********************
Welcome to Book Store
**********************
Options 
1. Add Book
2. Exit 
Enter Choice: 2
Book(s) entered so far: 2
1. learn java
2. Learn Spring
BUILD SUCCESSFUL (total time: 15 seconds)

上面显示的输出表明书籍正在存储在持久存储中并从数据库中检索。

EJB - 消息驱动 Bean

消息驱动 Bean 是一种企业 Bean，当 EJB 容器从队列或主题接收消息时会调用它。消息驱动 bean 是一种无状态 bean，用于异步执行任务。

为了演示消息驱动 bean 的使用，我们将利用 EJB 持久性章节，并且需要执行以下任务 -

• 步骤 1 - 在数据库中创建表（请参阅EJB-持久性章节）。

• 步骤 2 - 创建与表相对应的实体类（请参阅EJB-持久性章节）。

• 步骤 3 - 创建数据源和持久性单元（请参阅EJB-持久性章节）。

• 步骤 4 - 创建具有 EntityManager 实例的无状态 EJB（请参阅EJB-持久性章节）。

• 步骤 5 - 更新无状态 ejb.Add 方法以通过实体管理器添加记录并从数据库获取记录（请参阅EJB-持久性章节）。

• 步骤 6 -在 JBoss默认应用程序目录中创建一个名为BookQueue的队列。

• 步骤 7 - 基于控制台的应用程序客户端将向该队列发送消息。

• 步骤 8 - 创建一个消息驱动 bean，它将使用无状态 bean 来保存客户端数据。

• 步骤 9 - jboss 的 EJB 容器将调用上述消息驱动 bean 并将客户端将发送到的消息传递给它。

创建队列

如果<JBoss 安装文件夹> > 服务器 > 默认 > 部署文件夹中不存在名为 jbossmq-destinations-service.xml 的文件，则创建一个文件。

这里我们创建一个名为 BookQueue 的队列 -

jbossmq-destinations-service.xml

<mbean code="org.