一. 準備開發(fā)環(huán)境

JBoss IDE 1.5GA, JBoss IDE是JBoss公司對Eclipse的增強，包括EJB3.0,JBPM,JBoss AOP,FreeMaker等等插件，對于JBoss產品的開發(fā)，是非常方便的?？梢匀boss.org網站下載.

Ecliose WTP插件，這是開發(fā)Java EE項目插件，這里用來開發(fā)一個web項目，來測試Message Driven Bean.
JBoss 4.04GA,可以從Jboss.org網站下載，安裝版，zip版都可以.

二. 新建EJB3.0工程

選擇菜單New | Project...,在彈出對話框中，選擇EJB 3.0 Project，單擊[Next]按鈕，填寫工程名稱EJB3Demo2，單擊[Next]按鈕,選擇JBoss配置

我們這里還沒有配置，因此選擇[create a jboss configuration]按鈕，新建JBoss配置.選擇JBoss4.0.x,并單擊[New]按鈕，輸入配置名稱，JBoss 安裝目錄，Server Configuration選擇default，單擊[Apply]按鈕，然后單擊[Close]按鈕，單擊[Finish]按鈕，完成.

三.新建Message Driven Bean

單擊右鍵，選擇New | Other...。在彈出對話框中，選擇EJB3.0 | Message Driven Bean。單擊[Next]按鈕，輸入包名，類名等，單擊[Finish]按鈕完成.

四. 完成Message Driven Bean的代碼

4.1 設置ConnectionFactory和QueueConnectionFacoty使用JBoss默認的ConnectionFactory,因此不用設置。

設置Queue方式如下:

找到jbossmq-destinations-service.xml文件，該文件在jboss安裝目錄\server\default\deploy\jms下.在文件最后，加入下面代碼，新增一個Queue.

1. <mbean code="org.jboss.mq.server.jmx.Queue" 
2. name="jboss.mq.destination:service=Queue,name=myQueue"> 
3. <depends optional-attribute-name="DestinationManager"> 
4. jboss.mq:service=DestinationManager 
5. </depends> 
6. </mbean>  

4.2 完成代碼
設置好Queue后，編輯HelloMDB.java，加入Connection和Queue說明.

1. package demo;  
2. import javax.jms.JMSException;  
3. import javax.jms.Message;  
4. import javax.jms.MessageListener;  
5. import javax.jms.TextMessage;  
6. import javax.ejb.ActivationConfigProperty;  
7. import javax.ejb.MessageDriven;  
8. @MessageDriven(activationConfig = {  
9. @ActivationConfigProperty(propertyName = "destinationType",   
10. propertyValue = "javax.jms.Queue"),  
11. @ActivationConfigProperty(propertyName = "destination",   
12. propertyValue = "queue/myQueue") })  
13. public class HelloMDB implements MessageListener {  
14. public void onMessage(Message msg) {  
15. if (msg instanceof TextMessage) {  
16. TextMessage txtMsg = (TextMessage) msg;  
17. try {  
18. System.out.println("Hello " + txtMsg.getText() + ",MDB歡迎您!"); [Page]  
19. } catch (JMSException e) {  
20. e.printStackTrace();  
21. }  
22. }  
23. }  
24. }  

4.3導出jar包
選擇菜單File | Export,彈出對話框選擇JAR File，單擊[Next]按鈕.選擇jar包導出的位置，單擊[Finish]按鈕,完成導出

五. MDB的部署與測試

5.1 部署EJB
把我們剛才導出的jar文件.放到JBoss安裝目錄下的server\default\deploy下
ok,ejb部署好了.下面我們寫一個servlet測試一下

5.2 測試EJB

5.2.1新建動態(tài)web項目
選擇菜單 File | new | Project ,在彈出對話框中選擇web|Dynamic Web Project，單擊[Next]按鈕,填寫工程名稱，單擊{Finish]按鈕,完成.
5.2.2 新建Servlet
單擊右鍵.選擇New | Servlet，彈出對話框中,按下圖填寫，單擊[Finish]按鈕完成
5.2.3 在TestServlet的doGet方法中,編寫測試EJB的代碼
TestServlet.java內容如下

1. package test;  
2. import java.io.IOException;  
3. import javax.jms.JMSException;  
4. import javax.jms.Queue;  
5. import javax.jms.QueueConnection;  
6. import javax.jms.QueueConnectionFactory;  
7. import javax.jms.QueueSender;  
8. import javax.jms.QueueSession;  
9. import javax.jms.Session;  
10. import javax.jms.TextMessage;  
11. import javax.naming.Context;  
12. import javax.naming.InitialContext;  
13. import javax.naming.NamingException;  
14. import javax.servlet.ServletException;  
15. import javax.servlet.http.HttpServletRequest;  
16. import javax.servlet.http.HttpServletResponse;  
17. public class TestServlet extends javax.servlet.http.HttpServlet implements  
18. javax.servlet.Servlet {  
19. private static final long serialVersionUID = 1L;  
20. protected void doGet(HttpServletRequest request,  
21. HttpServletResponse response) throws ServletException, IOException {  
22. try {  
23. //得到上下文  
24. Context ctx=new InitialContext();  
25. //得到ConnectionFacory  
26. QueueConnectionFactory connFacotry=  
27. (QueueConnectionFactory)ctx.lookup("ConnectionFactory");   
28. //得到消息隊列  
29. Queue queue=(Queue)ctx.lookup("queue/testQueue");  
30. QueueConnection queueConn=connFacotry.createQueueConnection();  
31. QueueSession queueSession =  
32. queueConn.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);  
33. QueueSender queueSender =queueSession.createSender(queue);  
34. //組裝消息  
35. TextMessage txtMsg=queueSession.createTextMessage();  
36. txtMsg.setText("Luo Daijun");  
37. queueSender.send(txtMsg);  
38. //關閉資源  
39. queueSender.close();  
40. queueSession.close();  
41. queueConn.close();  
42. } catch (NamingException e) {  
43. e.printStackTrace();  
44. } catch (JMSException e) { [Page]  
45. e.printStackTrace();  
46. }  
47. }  
48. protected void doPost(HttpServletRequest request,  
49. HttpServletResponse response) throws ServletException, IOException {  
50. }  
51. }  

5.2.4 運行TestServlet,測試效果 ^_^
右鍵, 選擇 Run As | Run on server
選擇JBoss 4.0 for EJB3.0

單擊[Finish]按鈕。以上JBoss IDE開發(fā)完成

【編輯推薦】

1. JBoss-4.2修改端口
2. 在JBoss中Deploy下的一些程序秘訣
3. JBoss5迎來可配置時代
4. 全面講解OpenCRX+Mysql+JBoss 4.0.5
5. 將Jboss從4.0.5升級到4.2.0版本