http://www.cnblogs.com/jackson-ou/archive/2008/12/30/1365382.html

Note: From Tibco EMS Server document

1. Message Model
Point-to-Point模式(queue)：每個Message僅有一個生產(chǎn)者和一個消費(fèi)者。每個Queue可以有多個生產(chǎn)者和多個消費(fèi)者。Queue可以被聲明具有排它性。具有排它性Queue中的消息只能被第一個消費(fèi)者獲取。不論是否具有排它性，消息被某個消費(fèi)者獲取后，會從Queue中刪除。

Publish and Subscribe模式(topic)：每個Message可以擁有若干生產(chǎn)者和若干個消費(fèi)者。消費(fèi)者根據(jù)訂閱關(guān)系獲取topic中的消息。EMS API允許持久性的訂閱者，消息會為這些持久性訂閱者所保存。

2. Destination
對Message Model功能的提升，主要特征包括：
a.通過secure模式提供queue, topic層面的訪問控制，參考secure mode and Destination Control
b.設(shè)置queue, topic占用內(nèi)存空間的約束，參考flowControl and overflowPolicy
c.路由消息到Destination，參考Working With Routes
d.通過在Destinatin之間創(chuàng)建bridge，建立混合型Message Model
e. 控制Message發(fā)送到Destination的速度，參考Flow Control
g. 與其他Message Service交換消息，如queue能夠從Tibco Rendezvous, SmartSockets接收消息，topic能夠與Tibco Rendezvous, SmartSockets雙向交換消息
h. queue可被設(shè)置為具有exclusive或者non-exclusive,參考exclusive
i. queue在可以設(shè)置redelivery policy,參考maxRedelivery
j. 跟蹤，日志消息到Destination的傳送過程，參考trace
k.在消息中包含user name,參考sender name and sender name enforced
l. 在Destination name上支持Wildcards
m.在topic, queue上設(shè)置failsafe屬性，用于把消息同步保存到硬盤上
n. 設(shè)置消費(fèi)者在后臺批量接受消息以提供性能，或者設(shè)置queue的消息一次只接收一個消息，參考prefetch

3. Client API
?提供基于java, .net,COBOL的API。示例代碼位于安裝目錄的samples子目錄。EMS同時提供了Java類用于純粹的Java TIBCO Rendezvous Application來連接EMS Server。

4. Administration
?EMS提供了針對Server Operation, Server Object(如ConnectionFactories, Destinations)的管理機(jī)制。這些管理功能可以通過Administration Tool的命令行工具實現(xiàn)，也可以通過管理API實現(xiàn)。EMS Client可以通過JNDI來獲取Server Object的引用。

管理Server功能：使用Configuration Files, EMS Administration Tool, Authentication and Permissions, Monitor Server Activity(包含Server Activity信息的日志文件，發(fā)布關(guān)于systemevent Message到Topic中便于對Server的監(jiān)控，對不同層次細(xì)節(jié)的統(tǒng)計分析)。

EMS提供對user, groups的本地化管理，也可以通過外部的LDAP來統(tǒng)一。TIBCO Hawk提供了對EMS Server的管理和監(jiān)控。EMS Server支持SSL協(xié)議，用于Client-Server，

Server-Server間的安全通信。支持backup EMS Server，實現(xiàn)了Fault Tolerance。EMS提供了Server-Server間的消息路由。Topic消息可以在任意多個hop間傳遞，Queue消息最多在一個hop間傳遞。EMS支持消息的存儲轉(zhuǎn)發(fā)。

=======

weblogic與MQ的集成方案大致有兩種：
一是將MQ配置為weblogic的外部JMS服務(wù)器(foreign JMS server)，第二種是weblogic的消息橋(messaging bridge)
http://www.360doc.com/content/10/1129/16/4810544_73459234.shtml

3.3.集成到Weblogic
其實這部分的工作，沒多少難度，就是配置比較繁瑣，開始吧：

3.3.1.創(chuàng)建外部JMS服務(wù)器(foreign JMS server)

啟動weblogic，登陸控制臺，展開domain->服務(wù)->消息傳遞->JMS模塊。
選擇新建一個JMS模塊JMSModule_MQ:

圖3.3.1：創(chuàng)建JMS模塊

選擇一個server：

圖3.3.2：創(chuàng)建JMS模塊2

在剛才的模塊創(chuàng)建一個資源，類型為外部服務(wù)器(foreign server)名為ForeignServer_JMS：

圖3.3.3：創(chuàng)建模塊資源--外部服務(wù)器


圖3.3.4：創(chuàng)建模塊資源--外部服務(wù)器2

外部服務(wù)器JND配置

圖3.3.5：JNDI參數(shù)

在外部服務(wù)器創(chuàng)建兩個目標(biāo)：

圖3.3.6：兩個目標(biāo)

及兩個連接工廠：

圖3.3.7：兩個連接工廠

配置完之后，當(dāng)然要寫一個MDB測試一下：
消息驅(qū)動bean代碼如下：
Java代碼

package?mq; ??

??

import?javax.annotation.Resource; ??

import?javax.ejb.ActivationConfigProperty; ??

import?javax.ejb.MessageDriven; ??

import?javax.jms.Message; ??

import?javax.jms.MessageListener; ??

import?javax.jms.QueueConnection; ??

import?javax.jms.QueueSender; ??

import?javax.jms.QueueSession; ??

import?javax.jms.Session; ??

import?javax.jms.TextMessage; ??

??

/** ?

?*? ?

?*?@author?Justin ?

?*/??

@MessageDriven(name?=?"TestMDB2",?mappedName?=?"jms/applicationJMSQueue", ??

activationConfig?=?{ ??

????@ActivationConfigProperty(propertyName?=?"destinationType",?propertyValue?=?"javax.jms.Queue") ??

}) ??

public?class?MQTestBean2?implements?MessageListener?{ ??

??

????@Resource(mappedName?=?"jms/approvalJMSQueue") ??

????private?javax.jms.Queue?approvalJMSQueue; ??

????@Resource(mappedName?=?"jms/approvalFactory") ??

????private?javax.jms.QueueConnectionFactory?approvalFactory; ??

??

????public?void?onMessage(Message?message)?{ ??

??

????????try?{ ??

????????????String?msg?=?((TextMessage)?message).getText(); ??

????????????System.out.println("=>?收到申請:?"?+?msg); ??

????????????sendMessage("同意申請："?+?msg); ??

????????}?catch?(Exception?ex)?{ ??

????????????ex.printStackTrace(); ??

????????} ??

????} ??

??

????private?void?sendMessage(String?msg)?throws?Exception?{ ??

????????QueueConnection?conn?=?null; ??

????????QueueSession?session?=?null; ??

????????try?{ ??

????????????conn?=?approvalFactory.createQueueConnection(); ??

????????????session?=?conn.createQueueSession(false,?Session.AUTO_ACKNOWLEDGE); ??

????????????QueueSender?sender?=?session.createSender(approvalJMSQueue); ??

????????????Message?newMsg?=?session.createTextMessage(msg); ??

????????????sender.send(newMsg); ??

????????????System.out.println("=>?發(fā)送審批結(jié)果："?+?msg); ??

????????}?catch?(Exception?e)?{ ??

????????????e.printStackTrace(); ??

????????}?finally?{ ??

????????????try?{ ??

????????????????session.close(); ??

????????????????conn.close(); ??

????????????}?catch?(Exception?e)?{ ??

????????????????e.printStackTrace(); ??

????????????} ??

????????} ??

????} ??

}??

package mq; import javax.annotation.Resource; import javax.ejb.ActivationConfigProperty; import javax.ejb.MessageDriven; import javax.jms.Message; import javax.jms.MessageListener; import javax.jms.QueueConnection; import javax.jms.QueueSender; import javax.jms.QueueSession; import javax.jms.Session;

部署文件如下：
Xml代碼

<?xml?version="1.0"?encoding="UTF-8"?>??

<weblogic-ejb-jar?xmlns="http://www.bea.com/ns/weblogic/90">??

????<weblogic-enterprise-bean>??

????????<ejb-name>TestMDB2</ejb-name>??

????????<message-driven-descriptor>??

????????????<destination-jndi-name>??

????????????????jms/applicationJMSQueue ??

????????????</destination-jndi-name>??

????????????<connection-factory-jndi-name>??

????????????????jms/applicationFactory ??

????????????</connection-factory-jndi-name>??

????????</message-driven-descriptor>??

????</weblogic-enterprise-bean>??

</weblogic-ejb-jar>??

<?xml version="1.0" encoding="UTF-8"?> <weblogic-ejb-jar xmlns="http://www.bea.com/ns/weblogic/90"> <weblogic-enterprise-bean> <ejb-name>TestMDB2</ejb-name> <message-driven-descriptor> <destination-jndi-name> jms/applicationJMSQueue </destination-jndi-name> <connection-factory-jndi-name> jms/applicationFactory </connection-factory-jndi-name> </message-driven-descriptor> </weblogic-enterprise-bean> </weblogic-ejb-jar>

打包并發(fā)布到weblogic。

現(xiàn)在測試一下：
在MQ管理器中，在application隊列放入一個消息：

圖3.3.8.放入測試消息

如果所有配置正確，則MDB->MQTestBean2會接收到剛剛放入的消息，并進(jìn)行處理，然后放到approval隊列：



圖3.3.9.weblogic服務(wù)器輸出(netbeans控制臺)

之后我們可以再到MQ管理器查看approval隊列，可以看到MDB處理后的消息：



圖3.3.10.到approval隊列查看處理后的消息

OK，至此，我們成功地將MQ無縫地集成到了weblogic上，使部署在weblogic上的MDB可以像使用原生的JMS一樣操控MQ隊列了。

?

總結(jié)

以上是生活随笔為你收集整理的EMS server Tibco的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。