EJB 3.0规范提供了注释，可以应用于字段或setter方法以注入依赖项. EJB容器使用全局JNDI注册表来定位依赖项.以下注释在EJB 3.0中用于依赖注入.
@EJB : 用于注入其他EJB引用.
@Resource : 用于注入数据源或单例服务，如sessionContext，timerService等.
@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.IT屋.stateless.LibraryPersistentBean")
public void setLibraryPersistentBean(
LibraryPersistentBeanRemote libraryBean)
{
this.libraryBean = libraryBean;
}
...
}@Resource通常用于注入EJB容器提供的单例.
public class LibraryMessageBean implements MessageListener {
@Resource
private MessageDrivenContext mdctx;
...
}让我们创建一个测试EJB应用程序在EJB中测试依赖注入服务.
| Step | 描述 |
|---|---|
| 1 | 在包 com.it1352.timer 下创建一个名为 EjbComponent 的项目，如 EJB中所述 - 创建申请章. |
| 2 | 使用在 EJB - 消息驱动Bean 章节中创建的Bean.保持其余文件不变. |
| 3 | 清理并构建应用程序以确保业务逻辑按照要求运行. |
| 4 | 最后，在JBoss Application Server上以jar文件的形式部署应用程序.如果JBoss应用服务器尚未启动，它将自动启动. |
| 5 | 现在创建EJB客户端，一个基于控制台的应用程序，其方式与主题创建 EJB - 创建应用程序章节中所述的相同客户端访问EJB . |
package com.tuturialspoint.messagebean;
import com.it1352.entity.Book;
import com.it1352.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();
}
}
}
package com.it1352.test;
import com.it1352.entity.Book;
import com.it1352.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()方法中，使用名称"/queue/BookQueue"完成jndi查找，以获取Jboss中可用队列的引用.然后使用队列会话创建发件人.
然后向用户显示库存储用户界面，并要求他/她输入选项.
如果用户输入1，系统会要求输入书名，发件人会将书名发送到队列.当JBoss容器在队列中收到此消息时，它会调用消息驱动bean的onMessage方法.我们的消息驱动bean然后使用有状态会话bean addBook()方法保存书.会话Bean通过EntityManager调用将数据库保存在数据库中.
如果用户输入2，则使用名称 - "LibraryStatefulSessionBean/remote"完成另一个jndi查找"再次获取远程业务对象(有状态EJB)并完成书籍列表.
在项目资源管理器中找到EJBTester.java.右键单击EJBTester类并选择运行文件.
在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正在使用LibraryPersistentBean使用@EJB注释注入它，如果是异常，MessageDrivenContext，object用于回滚事务.
