Ejb 简明教程
EJB - Dependency Injection
EJB 3.0 规范提供了注解,可以应用于字段或 setter 方法来注入依赖项。EJB 容器使用全局 JNDI 注册表来定位依赖项。EJB 3.0 中用于依赖项注入的注解如下。
-
@EJB − 用于注入其他 EJB 引用。
-
@Resource − 用于注入数据源或单例服务,如 sessionContext、timerService 等。
Steps to Use @EJB
@EJB 可以按以下方式在字段或方法中使用 −
public class LibraryMessageBean implements MessageListener {
//dependency injection on field.
@EJB
LibraryPersistentBeanRemote libraryBean;
...
}
public class LibraryMessageBean implements MessageListener {
LibraryPersistentBeanRemote libraryBean;
//dependency injection on method.
@EJB(beanName="com.tutorialspoint.stateless.LibraryPersistentBean")
public void setLibraryPersistentBean(
LibraryPersistentBeanRemote libraryBean)
{
this.libraryBean = libraryBean;
}
...
}
Steps to use @Resource
@Resource 通常用于注入 EJB 容器提供的单例。
public class LibraryMessageBean implements MessageListener {
@Resource
private MessageDrivenContext mdctx;
...
}
Example Application
让我们创建一个测试 EJB 应用程序来测试 EJB 中的依赖项注入服务。
Step |
Description |
1 |
按照 EJB - 创建应用程序章节中的说明,在包 com.tutorialspoint.timer 中创建一个名为 EjbComponent 的项目。 |
2 |
使用在 EJB - 消息驱动 Bean 章节中创建的 Bean。保持其他文件不变。 |
3 |
清理并构建应用程序以确保业务逻辑按需求工作。 |
4 |
最后,以 jar 文件的形式将应用程序部署在 JBoss 应用程序服务器上。如果 JBoss 应用程序服务器尚未启动,它会自动启动。 |
5 |
现在创建 EJB 客户端,这是一个控制台应用程序,创建方法与 EJB - 章节中主题 Create Client to access EJB 下所述相同。 |
EJBComponent (EJB Module)
LibraryMessageBean.java
package com.tuturialspoint.messagebean;
import com.tutorialspoint.entity.Book;
import com.tutorialspoint.stateless.LibraryPersistentBeanRemote;
import javax.annotation.Resource;
import javax.ejb.ActivationConfigProperty;
import javax.ejb.EJB;
import javax.ejb.MessageDriven;
import javax.ejb.MessageDrivenContext;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.ObjectMessage;
@MessageDriven(
name = "BookMessageHandler",
activationConfig = {
@ActivationConfigProperty( propertyName = "destinationType",
propertyValue = "javax.jms.Queue"),
@ActivationConfigProperty( propertyName = "destination",
propertyValue ="/queue/BookQueue")
}
)
public class LibraryMessageBean implements MessageListener {
@Resource
private MessageDrivenContext mdctx;
@EJB
LibraryPersistentBeanRemote libraryBean;
public LibraryMessageBean() {
}
public void onMessage(Message message) {
ObjectMessage objectMessage = null;
try {
objectMessage = (ObjectMessage) message;
Book book = (Book) objectMessage.getObject();
libraryBean.addBook(book);
}catch (JMSException ex) {
mdctx.setRollbackOnly();
}
}
}
EJBTester (EJB Client)
EJBTester.java
package com.tutorialspoint.test;
import com.tutorialspoint.entity.Book;
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.jms.ObjectMessage;
import javax.jms.Queue;
import javax.jms.QueueConnection;
import javax.jms.QueueConnectionFactory;
import javax.jms.QueueSender;
import javax.jms.QueueSession;
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.testMessageBeanEjb();
}
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 testMessageBeanEjb() {
try {
int choice = 1;
Queue queue = (Queue) ctx.lookup("/queue/BookQueue");
QueueConnectionFactory factory =
(QueueConnectionFactory) ctx.lookup("ConnectionFactory");
QueueConnection connection = factory.createQueueConnection();
QueueSession session = connection.createQueueSession(
false, QueueSession.AUTO_ACKNOWLEDGE);
QueueSender sender = session.createSender(queue);
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);
ObjectMessage objectMessage =
session.createObjectMessage(book);
sender.send(objectMessage);
} else if (choice == 2) {
break;
}
}
LibraryPersistentBeanRemote libraryBean =
(LibraryPersistentBeanRemote)
ctx.lookup("LibraryPersistentBean/remote");
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() 方法中,jndi 查找使用名称“/queue/BookQueue”完成,以获取 Jboss 中可用的队列引用。然后使用队列会话创建发送者。
-
然后向用户显示一个图书库用户界面,并询问他/她输入一个选择。
-
如果用户输入 1,系统会询问书名,然后发送者将书名发送到队列。当 JBoss 容器在队列中收到此消息时,它将调用我们的消息驱动的 Bean 的 onMessage 方法。然后我们的消息驱动的 Bean 使用有状态会话 Bean 的 addBook() 方法保存图书。会话 Bean 通过 EntityManager 调用将图书保存在数据库中。
-
如果用户输入 2,则使用名称“LibraryStatefulSessionBean/remote”执行另一个 jndi 查找,以再次获取远程业务对象(有状态 EJB)并列出图书。
Run Client to Access EJB
在项目浏览器中找到EJBTester.java。右键单击EJBTester类并选择 run file 。
在Netbeans控制台中验证以下输出。
run:
**********************
Welcome to Book Store
**********************
Options
1. Add Book
2. Exit
Enter Choice: 1
Enter book name: Learn EJB
**********************
Welcome to Book Store
**********************
Options
1. Add Book
2. Exit
Enter Choice: 2
Book(s) entered so far: 2
1. learn java
1. learn EJB
BUILD SUCCESSFUL (total time: 15 seconds)
上面显示的输出表明,我们的消息驱动的 Bean 正在接收消息并将图书存储在持久性存储中,并且从数据库中检索图书。
我们的消息驱动的 Bean 使用使用 @EJB 注解注入的 LibraryPersistentBean,并且在异常情况下,使用 MessageDrivenContext 对象回滚事务。