|
2006年8月24日
當前,CORBA、DCOM、RMI等RPC中間件技術(shù)已廣泛應(yīng)用于各個領(lǐng)域。但是面對規(guī)模和復(fù)雜度都越來越高的分布式系統(tǒng),這些技術(shù)也顯示出其局限性:(1)同步通信:客戶發(fā)出調(diào)用后,必須等待服務(wù)對象完成處理并返回結(jié)果后才能繼續(xù)執(zhí)行;(2)客戶和服務(wù)對象的生命周期緊密耦合:客戶進程和服務(wù)對象進程都必須正常運行;如果由于服務(wù)對象崩潰或者網(wǎng)絡(luò)故障導(dǎo)致客戶的請求不可達,客戶會接收到異常;(3)點對點通信:客戶的一次調(diào)用只發(fā)送給某個單獨的目標對象。 面向消息的中間件(Message Oriented Middleware,MOM)較好的解決了以上問題。發(fā)送者將消息發(fā)送給消息服務(wù)器,消息服務(wù)器將消息存放在若干隊列中,在合適的時候再將消息轉(zhuǎn)發(fā)給接收者。這種模式下,發(fā)送和接收是異步的,發(fā)送者無需等待;二者的生命周期未必相同:發(fā)送消息的時候接收者不一定運行,接收消息的時候發(fā)送者也不一定運行;一對多通信:對于一個消息可以有多個接收者。 已有的MOM系統(tǒng)包括IBM的MQSeries、Microsoft的MSMQ和BEA的MessageQ等。由于沒有一個通用的標準,這些系統(tǒng)很難實現(xiàn)互操作和無縫連接。Java Message Service(JMS)是SUN提出的旨在統(tǒng)一各種MOM系統(tǒng)接口的規(guī)范,它包含點對點(Point to Point,PTP)和發(fā)布/訂閱(Publish/Subscribe,pub/sub)兩種消息模型,提供可靠消息傳輸、事務(wù)和消息過濾等機制。
1.JMS JAVA 消息服務(wù)(JMS)定義了Java 中訪問消息中間件的接口。JMS 只是接口,并沒有給予實現(xiàn),實現(xiàn)JMS 接口的消息中間件稱為JMS Provider,iLink實現(xiàn)了JMS接口,用戶可以通過使用JMS接口,在iLink中進行JMS編程。 iLink支持JMS1.0.2版本。
2.JMS接口描述 JMS 支持兩種消息類型PTP 和Pub/Sub,分別稱作:PTP Domain 和Pub/Sub Domain,這兩種接口都繼承統(tǒng)一的JMS父接口,JMS 主要接口如下所示:
MS父接口
|
PTP
|
Pub/Sub
|
ConnectionFactory
|
QueueConnectionFactory
|
TopicConnectionFactory
|
Connection
|
QueueConnection
|
TopicConnection
|
Destination
|
Queue
|
Topic
|
Session
|
QueueSession
|
TopicSession
|
MessageProducer
|
QueueSender
|
TopicPublisher
|
MessageConsumer
|
QueueReceiver,QueueBrowse r
|
TopicSubscriber
|
|
ConnectionFactory :連接工廠,JMS 用它創(chuàng)建連接 Connection :JMS 客戶端到JMS Provider 的連接 Destination :消息的目的地 Session: 一個發(fā)送或接收消息的線程 MessageProducer: 由Session 對象創(chuàng)建的用來發(fā)送消息的對象 MessageConsumer: 由Session 對象創(chuàng)建的用來接收消息的對象
3.JMS消息模型 JMS 消息由以下幾部分組成:消息頭,屬性,消息體。 3.1 消息頭(Header) - 消息頭包含消息的識別信息和路由信息,消息頭包含一些標準的屬性如:JMSDestination,JMSMessageID 等。
消息頭
|
由誰設(shè)置
|
JMSDestination
|
send 或 publish 方法
|
JMSDeliveryMode
|
send 或 publish 方法
|
JMSExpiration
|
send 或 publish 方法
|
JMSPriority
|
send 或 publish 方法
|
JMSMessageID
|
send 或 publish 方法
|
JMSTimestamp
|
send 或 publish 方法
|
JMSCorrelationID
|
客戶
|
JMSReplyTo
|
客戶
|
JMSType
|
客戶
|
JMSRedelivered
|
JMS Provider
|
|
3.2 屬性(Properties) - 除了消息頭中定義好的標準屬性外,JMS 提供一種機制增加新屬性到消息頭 中,這種新屬性包含以下幾種: 1. 應(yīng)用需要用到的屬性; 2. 消息頭中原有的一些可選屬性; 3. JMS Provider 需要用到的屬性。 標準的JMS 消息頭包含以下屬性:
JMSDestination
|
消息發(fā)送的目的地
|
JMSDeliveryMode
|
傳遞模式, 有兩種模式: PERSISTENT 和NON_PERSISTENT,PERSISTENT 表示該消息一定要被送到目的地,否則會導(dǎo)致應(yīng)用錯誤。NON_PERSISTENT 表示偶然丟失該消息是被允許的,這兩種模式使開發(fā)者可以在消息傳遞的可靠性和吞吐量之間找到平衡點。
|
JMSMessageID
|
唯一識別每個消息的標識,由JMS Provider 產(chǎn)生。
|
JMSTimestamp
|
一個消息被提交給JMS Provider 到消息被發(fā)出的時間。
|
JMSCorrelationID
|
用來連接到另外一個消息,典型的應(yīng)用是在回復(fù)消息中連接到原消息。
|
JMSReplyTo
|
提供本消息回復(fù)消息的目的地址
|
JMSRedelivered
|
如果一個客戶端收到一個設(shè)置了JMSRedelivered 屬性的消息,則表示可能該客戶端曾經(jīng)在早些時候收到過該消息,但并沒有簽收(acknowledged)。
|
JMSType
|
消息類型的識別符。
|
JMSExpiration
|
消息過期時間,等于QueueSender 的send 方法中的timeToLive 值或TopicPublisher 的publish 方法中的timeToLive 值加上發(fā)送時刻的GMT 時間值。如果timeToLive值等于零,則JMSExpiration 被設(shè)為零,表示該消息永不過期。如果發(fā)送后,在消息過期時間之后消息還沒有被發(fā)送到目的地,則該消息被清除。
|
JMSPriority
|
消息優(yōu)先級,從0-9 十個級別,0-4 是普通消息,5-9 是加急消息。JMS 不要求JMS Provider 嚴格按照這十個優(yōu)先級發(fā)送消息,但必須保證加急消息要先于普通消息到達。
|
|
3.3 消息體(Body) - JMS API 定義了5種消息體格式,也叫消息類型,你可以使用不同形式發(fā)送接收 數(shù)據(jù)并可以兼容現(xiàn)有的消息格式,下面描述這5種類型:
消息類型
|
消息體
|
TextMessage
|
java.lang.String對象,如xml文件內(nèi)容
|
MapMessage
|
名/值對的集合,名是String對象,值類型可以是Java任何基本類型
|
BytesMessage
|
字節(jié)流
|
StreamMessage
|
Java中的輸入輸出流
|
ObjectMessage
|
Java中的可序列化對象
|
Message
|
沒有消息體,只有消息頭和屬性
|
|
下例演示創(chuàng)建并發(fā)送一個TextMessage到一個隊列: TextMessage message = queueSession.createTextMessage(); message.setText(msg_text); // msg_text is a String queueSender.send(message);
下例演示接收消息并轉(zhuǎn)換為合適的消息類型: Message m = queueReceiver.receive(); if (m instanceof TextMessage) { TextMessage message = (TextMessage) m; System.out.println("Reading message: " + message.getText()); } else { // Handle error }
4. 消息的同步異步接收 消息的同步接收是指客戶端主動去接收消息,JMS 客戶端可以采用MessageConsumer 的receive方法去接收下一個消息。 消息的異步接收是指當消息到達時,主動通知客戶端。JMS 客戶端可以通過注冊一個實 現(xiàn)MessageListener 接口的對象到MessageConsumer,這樣,每當消息到達時,JMS Provider 會調(diào)用MessageListener中的onMessage 方法。
5. PTP模型 PTP(Point-to-Point)模型是基于隊列的,發(fā)送方發(fā)消息到隊列,接收方從隊列接收消息,隊列的存在使得消息的異步傳輸成為可能。和郵件系統(tǒng)中的郵箱一樣,隊列可以包含各種消息,JMS Provider 提 供工具管理隊列的創(chuàng)建、刪除。JMS PTP 模型定義了客戶端如何向隊列發(fā)送消息,從隊列接收消息,瀏覽隊列中的消息。 下面描述JMS PTP 模型中的主要概念和對象:
名稱
|
描述
|
Queue
|
由JMS Provider 管理,隊列由隊列名識別,客戶端可以通過JNDI 接口用隊列名得到一個隊列對象。
|
TemporaryQueue
|
由QueueConnection 創(chuàng)建,而且只能由創(chuàng)建它的QueueConnection 使用。
|
QueueConnectionFactory
|
客戶端用QueueConnectionFactory 創(chuàng)建QueueConnection 對象。
|
QueueConnection
|
一個到JMS PTP provider 的連接,客戶端可以用QueueConnection 創(chuàng)建QueueSession 來發(fā)送和接收消息。
|
QueueSession
|
提供一些方法創(chuàng)建QueueReceiver 、QueueSender、QueueBrowser 和TemporaryQueue。如果在QueueSession 關(guān)閉時,有一些消息已經(jīng)被收到,但還沒有被簽收(acknowledged),那么,當接收者下次連接到相同的隊列時,這些消息還會被再次接收。
|
QueueReceiver
|
客戶端用QueueReceiver 接收隊列中的消息,如果用戶在QueueReceiver 中設(shè)定了消息選擇條件,那么不符合條件的消息會留在隊列中,不會被接收到。
|
QueueSender
|
客戶端用QueueSender 發(fā)送消息到隊列。
|
QueueBrowser
|
客戶端可以QueueBrowser 瀏覽隊列中的消息,但不會收走消息。
|
QueueRequestor
|
JMS 提供QueueRequestor 類簡化消息的收發(fā)過程。QueueRequestor 的構(gòu)造函數(shù)有兩個參數(shù):QueueSession 和queue,QueueRequestor 通過創(chuàng)建一個臨時隊列來完成最終的收發(fā)消息請求。
|
可靠性(Reliability)
|
隊列可以長久地保存消息直到接收者收到消息。接收者不需要因為擔(dān)心消息會丟失而時刻和隊列保持激活的連接狀態(tài),充分體現(xiàn)了異步傳輸模式的優(yōu)勢。
|
|
6. PUB/SUB模型 JMS Pub/Sub 模型定義了如何向一個內(nèi)容節(jié)點發(fā)布和訂閱消息,這些節(jié)點被稱作主題(topic)。 主題可以被認為是消息的傳輸中介,發(fā)布者(publisher)發(fā)布消息到主題,訂閱者(subscribe)從主題訂閱消息。主題使得消息訂閱者和消息發(fā)布者保持互相獨立,不需要接觸即可保證消息的傳送。 下面描述JMS Pub/Sub 模型中的主要概念和對象:
名稱
|
描述
|
訂閱(subscription)
|
消息訂閱分為非持久訂閱(non-durable subscription)和持久訂閱(durable subscrip-tion),非持久訂閱只有當客戶端處于激活狀態(tài),也就是和JMS Provider 保持連接狀態(tài)才能收到發(fā)送到某個主題的消息,而當客戶端處于離線狀態(tài),這個時間段發(fā)到主題的消息將會丟失,永遠不會收到。持久訂閱時,客戶端向JMS 注冊一個識別自己身份的ID,當這個客戶端處于離線時,JMS Provider 會為這個ID 保存所有發(fā)送到主題的消息,當客戶再次連接到JMS Provider時,會根據(jù)自己的ID 得到所有當自己處于離線時發(fā)送到主題的消息。
|
Topic
|
主題由JMS Provider 管理,主題由主題名識別,客戶端可以通過JNDI 接口用主題名得到一個主題對象。JMS 沒有給出主題的組織和層次結(jié)構(gòu)的定義,由JMS Provider 自己定義。
|
TemporaryTopic
|
臨時主題由TopicConnection 創(chuàng)建,而且只能由創(chuàng)建它的TopicConnection 使用。臨時主題不能提供持久訂閱功能。
|
TopicConnectionFactory
|
客戶端用TopicConnectionFactory 創(chuàng)建TopicConnection 對象。
|
TopicConnection
|
TopicConnection 是一個到JMS Pub/Sub provider 的連接,客戶端可以用TopicConnection創(chuàng)建TopicSession 來發(fā)布和訂閱消息。
|
TopicSession
|
TopicSession 提供一些方法創(chuàng)建TopicPublisher、TopicSubscriber、TemporaryTopic 。它還提供unsubscribe 方法取消消息的持久訂閱。
|
TopicPublisher
|
客戶端用TopicPublisher 發(fā)布消息到主題。
|
TopicSubscriber
|
客戶端用TopicSubscriber 接收發(fā)布到主題上的消息。可以在TopicSubscriber 中設(shè)置消息過濾功能,這樣,不符合要求的消息不會被接收。
|
Durable TopicSubscriber
|
如果一個客戶端需要持久訂閱消息,可以使用Durable TopicSubscriber,TopSession 提供一個方法createDurableSubscriber創(chuàng)建Durable TopicSubscriber 對象。
|
恢復(fù)和重新派送(Recovery and Redelivery)
|
非持久訂閱狀態(tài)下,不能恢復(fù)或重新派送一個未簽收的消息。只有持久訂閱才能恢復(fù)或重新派送一個未簽收的消息。
|
TopicRequestor
|
JMS 提供TopicRequestor 類簡化消息的收發(fā)過程。TopicRequestor 的構(gòu)造函數(shù)有兩個參數(shù):TopicSession 和topic。TopicRequestor 通過創(chuàng)建一個臨時主題來完成最終的發(fā)布和接收消息請求。
|
可靠性(Reliability)
|
當所有的消息必須被接收,則用持久訂閱模式。當丟失消息能夠被容忍,則用非持久訂閱模式。
|
|
7. 開發(fā)JMS的步驟 廣義上說,一個JMS 應(yīng)用是幾個JMS 客戶端交換消息,開發(fā)JMS 客戶端應(yīng)用由以下幾步構(gòu)成: 用JNDI 得到ConnectionFactory 對象; 用JNDI 得到目標隊列或主題對象,即Destination 對象; 用ConnectionFactory 創(chuàng)建Connection 對象; 用Connection 對象創(chuàng)建一個或多個JMS Session; 用Session 和Destination 創(chuàng)建MessageProducer 和MessageConsumer; 通知Connection 開始傳遞消息。
Some XA JDBC drivers do not support local transaction operations, which can cause an error similar to the following when optimistic concurrency is used with such a driver:
SQL operations are not allowed with no global transaction by default for XA drivers.
In other words, the error will occur when
SupportsLocalTransactions="true"
is specified for the JDBCConnectionPool.
This problem occurs because optimistic concurrency suspends a global transaction and does reads in a local transaction when the database is not Oracle. (When using Oracle, you can avoid this problem by explicitly setting
<database-type>Oracle</database-type>
in your CMP deployment descriptor.)
Workaround
: Use the "RollbackLocalTxUponConnClose" on the JDBCConnection.
在談到
XA
規(guī)范之前,必須首先了解分布式事務(wù)處理(
Distributed Transaction Processing
,
DTP
)的概念。
Transaction
,即事務(wù),又稱之為交易,指一個程序或程序段,在一個或多個資源如
數(shù)據(jù)庫
或文件上為完成某些功能的執(zhí)行過程的集合。
LU
人的博客
)vqfhOBA
分布式事務(wù)處理是指一個事務(wù)可能涉及多個數(shù)據(jù)庫操作,分布式事務(wù)處理的關(guān)鍵是必須有一種方法可以知道事務(wù)在任何地方所做的所有動作,提交或回滾事務(wù)的決定必須產(chǎn)生統(tǒng)一的結(jié)果(全部提交或全部回滾)。
X/Open
組織(即現(xiàn)在的
Open Group
)定義了分布式事務(wù)處理模型。
X/Open DTP
模型(
1994
)包括應(yīng)用程序(
AP
)、事務(wù)管理器(
TM
)、資源管理器(
RM
)、通信資源管理器(
CRM
)四部分。一般,常見的事務(wù)管理器(
TM
)是交易中間件,常見的資源管理器(
RM
)是數(shù)據(jù)庫,常見的通信資源管理器(
CRM
)是消息中間件。
通常把一個數(shù)據(jù)庫內(nèi)部的事務(wù)處理,如對多個表的操作,作為本地事務(wù)看待。數(shù)據(jù)庫的事務(wù)處理對象是本地事務(wù),而分布式事務(wù)處理的對象是全局事務(wù)。
所謂全局事務(wù),是指分布式事務(wù)處理環(huán)境中,多個數(shù)據(jù)庫可能需要共同完成一個工作,這個工作即是一個全局事務(wù),例如,一個事務(wù)中可能更新幾個不同的數(shù)據(jù)庫。對數(shù)據(jù)庫的操作發(fā)生在系統(tǒng)的各處但必須全部被提交或回滾。此時一個數(shù)據(jù)庫對自己內(nèi)部所做操作的提交不僅依賴本身操作是否成功,還要依賴與全局事務(wù)相關(guān)的其它數(shù)據(jù)庫的操作是否成功,如果任一數(shù)據(jù)庫的任一操作失敗,則參與此事務(wù)的所有數(shù)據(jù)庫所做的所有操作都必須回滾。
LU
人的博客
8v:d?(~;~$A-Q9V D
一般情況下,某一數(shù)據(jù)庫無法知道其它數(shù)據(jù)庫在做什么,因此,在一個
DTP
環(huán)境中,交易中間件是必需的,由它通知和協(xié)調(diào)相關(guān)數(shù)據(jù)庫的提交或回滾。而一個數(shù)據(jù)庫只將其自己所做的操作(可恢復(fù))影射到全局事務(wù)中。
XA
就是
X/Open DTP
定義的交易中間件與數(shù)據(jù)庫之間的接口規(guī)范(即接口函數(shù)),交易中間件用它來通知數(shù)據(jù)庫事務(wù)的開始、結(jié)束以及提交、回滾等。
XA
接口函數(shù)由數(shù)據(jù)庫廠商提供。
XA
與兩階段提交協(xié)議
通常情況下,交易中間件與數(shù)據(jù)庫通過
XA
接口規(guī)范,使用兩階段提交來完成一個全局事務(wù),
XA
規(guī)范的基礎(chǔ)是兩階段提交協(xié)議。
在第一階段,交易中間件請求所有相關(guān)數(shù)據(jù)庫準備提交(預(yù)提交)各自的事務(wù)分支,以確認是否所有相關(guān)數(shù)據(jù)庫都可以提交各自的事務(wù)分支。當某一數(shù)據(jù)庫收到預(yù)提交后,如果可以提交屬于自己的事務(wù)分支,則將自己在該事務(wù)分支中所做的操作固定記錄下來,并給交易中間件一個同意提交的應(yīng)答,此時數(shù)據(jù)庫將不能再在該事務(wù)分支中加入任何操作,但此時數(shù)據(jù)庫并沒有真正提交該事務(wù),數(shù)據(jù)庫對共享資源的操作還未釋放(處于上鎖狀態(tài))。如果由于某種原因數(shù)據(jù)庫無法提交屬于自己的事務(wù)分支,它將回滾自己的所有操作,釋放對共享資源上的鎖,并返回給交易中間件失敗應(yīng)答。
在第二階段,交易中間件審查所有數(shù)據(jù)庫返回的預(yù)提交結(jié)果,如所有數(shù)據(jù)庫都可以提交,交易中間件將要求所有數(shù)據(jù)庫做正式提交,這樣該全局事務(wù)被提交。而如果有任一數(shù)據(jù)庫預(yù)提交返回失敗,交易中間件將要求所有其它數(shù)據(jù)庫回滾其操作,這樣該全局事務(wù)被回滾。
以一個全局事務(wù)為例,
AP
首先通知交易中間件開始一個全局事務(wù),交易中間件通過
XA
接口函數(shù)通知數(shù)據(jù)庫開始事務(wù),然后
AP
可以對數(shù)據(jù)庫管理的資源進行操作,數(shù)據(jù)庫系統(tǒng)記錄事務(wù)對本地資源的所有操作。操作完成后交易中間件通過
XA
接口函數(shù)通知數(shù)據(jù)庫操作完成。交易中間件負責(zé)記錄
AP
操作過哪些數(shù)據(jù)庫(事務(wù)分支)。
AP
根據(jù)情況通知交易中間件提交該全局事務(wù),交易中間件會通過
XA
接口函數(shù)要求各個數(shù)據(jù)庫做預(yù)提交,所有數(shù)據(jù)庫返回成功后要求各個數(shù)據(jù)庫做正式提交,此時一筆全局事務(wù)結(jié)束。
XA
規(guī)范對應(yīng)用來說,最大好處在于事務(wù)的完整性由交易中間件和數(shù)據(jù)庫通過
XA
接口控制,
AP
只需要關(guān)注與數(shù)據(jù)庫的應(yīng)用邏輯的處理,而無需過多關(guān)心事務(wù)的完整性,應(yīng)用設(shè)計開發(fā)會簡化很多。
具體來說,如果沒有交易中間件,應(yīng)用系統(tǒng)需要在程序內(nèi)部直接通知數(shù)據(jù)庫開始、結(jié)束和提交事務(wù),當出現(xiàn)異常情況時必須由專門的程序?qū)?shù)據(jù)庫進行反向操作才能完成回滾。如果是有很多事務(wù)分支的全局事務(wù),回滾時情況將變得異常復(fù)雜。而使用
XA
接口,則全局事務(wù)的提交是由交易中間件控制,應(yīng)用程序只需通知交易中間件提交或回滾事務(wù),就可以控制整個事務(wù)(可能涉及多個異地的數(shù)據(jù)庫)的全部提交或回滾,應(yīng)用程序完全不用考慮沖正邏輯。
在一個涉及多個數(shù)據(jù)庫的全局事務(wù)中,為保證全局事務(wù)的完整性,由交易中間件控制數(shù)據(jù)庫做兩階段提交是必要的。但典型的兩階段提交,對數(shù)據(jù)庫來說事務(wù)從開始到結(jié)束(提交或回滾)時間相對較長,在事務(wù)處理期間數(shù)據(jù)庫使用的資源(如邏輯日志、各種鎖),直到事務(wù)結(jié)束時才會釋放。因此,使用典型的兩階段提交相對來說會占用更多的資源,在網(wǎng)絡(luò)條件不是很好,如低速網(wǎng)、網(wǎng)絡(luò)顛簸頻繁,情況會更為嚴重。
當一個全局事務(wù)只涉及一個數(shù)據(jù)庫時,有一種優(yōu)化方式,即一階段提交。當
AP
通知交易中間件提交事務(wù)時,交易中間件直接要求數(shù)據(jù)庫提交事務(wù),省去兩階段提交中的第一階段,可以縮短處理一個事務(wù)的時間,以提高事務(wù)處理的效率。作為兩階段提交的一種特例,與兩階段一樣,一階段提交也是標準的。
If you encountered “
Cannot call Connection.commit in distributed transaction
” error, should check the weblogic connection pool and the datasource
?
If the connection pool is XA,
you should make sure that when you create the datasource to make it XA by select the check from "Honor Global Transaction" from the weblogic console.(default is selected)
If the connection pool is non-XA
you should make sure that when you create the datasource to make it non-XA by remove the check from "Honor Global Transaction" from the weblogic console.
問題描述:
<[ServletContext(id=18489944,name=EBLGWeb,context-path=/)]: Deployment descriptor "/WEB-INF/bhr-tags-pagination.tld" is malformed. Check against the DTD: Content is not allowed in prolog. (line 1, column 1).>
<[ServletContext(id=18489944,name=EBLGWeb,context-path=/)]: Error while parsing the Tag Library Descriptor at "/WEB-INF/bhr-tags-pagination.tld".
org.xml.sax.SAXException: [HTTP:101248][ServletContext(id=18489944,name=EBLGWeb,context-path=/)]: Deployment descriptor "/WEB-INF/bhr-tags-pagination.tld" is malformed. Check against the DTD: Content is not allowed in prolog. (line 1, column 1).
at weblogic.apache.xerces.parsers.DOMParser.parse(DOMParser.java:285)
at weblogic.apache.xerces.jaxp.DocumentBuilderImpl.parse(DocumentBuilderImpl.java:201)
at weblogic.servlet.jsp.dd.JSPEntityResolver.load(JSPEntityResolver.java:81)
at weblogic.servlet.jsp.dd.JSPEntityResolver.load(JSPEntityResolver.java:96)
at weblogic.servlet.internal.WebAppHelper.registerTagLibListeners(WebAppHelper.java:293)
at weblogic.servlet.internal.WebAppServletContext.activateFromDescriptors(WebAppServletContext.java:2530)
at weblogic.servlet.internal.WebAppServletContext.activate(WebAppServletContext.java:6163)
at weblogic.servlet.internal.WebAppServletContext.setActive(WebAppServletContext.java:6141)
at weblogic.servlet.internal.WebAppModule.activate(WebAppModule.java:836)
at weblogic.j2ee.J2EEApplicationContainer.activateModule(J2EEApplicationContainer.java:3322)
at weblogic.j2ee.J2EEApplicationContainer.activate(J2EEApplicationContainer.java:2201)
at weblogic.j2ee.J2EEApplicationContainer.activate(J2EEApplicationContainer.java:2174)
at weblogic.j2ee.J2EEApplicationContainer.activate(J2EEApplicationContainer.java:2122)
at weblogic.management.deploy.slave.SlaveDeployer$Application.setActivation(SlaveDeployer.java:3099)
at weblogic.management.deploy.slave.SlaveDeployer.setActivationStateForAllApplications(SlaveDeployer.java:1768)
at weblogic.management.deploy.slave.SlaveDeployer.resume(SlaveDeployer.java:351)
at weblogic.management.deploy.DeploymentManagerServerLifeCycleImpl.resume(DeploymentManagerServerLifeCycleImpl.java:229)
at weblogic.t3.srvr.SubsystemManager.resume(SubsystemManager.java:136)
at weblogic.t3.srvr.T3Srvr.resume(T3Srvr.java:965)
at weblogic.t3.srvr.T3Srvr.run(T3Srvr.java:360)
at weblogic.Server.main(Server.java:32)
>
原因分析和解決方法:
是由于某些文本編輯器(UltraEdit)存文本的時候產(chǎn)生的問題。可以使用text pad, word pad編輯XML格式的文件。
問題描述:
通過HTTP提交EDI請求,當EDI處理時間超過了20分鐘后,就會看到在另一個weblogic server也接收到了這個EDI請求,重新處理這個報文.
如果報文處理時間更長,比如超過了50分鐘,就會發(fā)現(xiàn)這個報文被處理了3遍或5遍.
原因分析和解決方法:
When the Apache HTTP Server Plug-In attempts to connect to WebLogic Server, the plug-in uses several configuration
parameters to determine how long to wait for connections to the WebLogic Server host and, after a connection is
established, how long the plug-in waits for a response. If the plug-in cannot connect or does not receive a response,
the plug-in attempts to connect and send the request to other WebLogic Server instances in the cluster. If the
connection fails or there is no response from any WebLogic Server in the cluster, an error message is sent.
響應(yīng)等待時間參數(shù)WLIOTimeoutSecs (http://e-docs.bea.com/wls/docs81/plugins/plugin_params.html#1149781.
按照BEA 推薦的,這個值應(yīng)該設(shè)得大一些, 這個參數(shù)的缺省值為300s. 見下面:
<Location /EDIHandler>
SetHandler weblogic-handler
WebLogicCluster apc_app1wls1:7011,apc_app1wls2:7011
KeepAliveEnabled ON
WLIOTimeoutSecs 7200
</Location>
有時候使用的mq jar文件的版本不對給出現(xiàn)一些末名奇妙的問題,本文則是能接收消息但不能發(fā)送消息的一個問題.碰到這樣的問題一定要記得double-check你使用的mq jar文件的版本
問題描述:
MQJMS200713 Oct 2006 16:47:15,484 ERROR MessagingUtilServlet [ExecuteThread: '14' for queue: 'weblogic.kernel.Default'][]: **********EXCEPTION TRACE START*************
13 Oct 2006 16:47:15,484 ERROR MessagingUtilServlet [ExecuteThread: '14' for queue: 'weblogic.kernel.Default'][]: produce error
com.bhr.infra.messaging.exception.PMException: JMSException
at com.bhr.infra.messaging.PMHandler.send(PMHandler.java:419)
at com.bhr.epc.infra.messaging.util.MessagingUtilServlet.produce(MessagingUtilServlet.java:312)
at com.bhr.epc.infra.messaging.util.MessagingUtilServlet.service(MessagingUtilServlet.java:74)
at javax.servlet.http.HttpServlet.service(HttpServlet.java:853)
at weblogic.servlet.internal.ServletStubImpl$ServletInvocationAction.run(ServletStubImpl.java:1072)
at weblogic.servlet.internal.ServletStubImpl.invokeServlet(ServletStubImpl.java:465)
at weblogic.servlet.internal.ServletStubImpl.invokeServlet(ServletStubImpl.java:348)
at weblogic.servlet.internal.WebAppServletContext$ServletInvocationAction.run(WebAppServletContext.java:6981)
at weblogic.security.acl.internal.AuthenticatedSubject.doAs(AuthenticatedSubject.java:321)
at weblogic.security.service.SecurityManager.runAs(SecurityManager.java:121)
at weblogic.servlet.internal.WebAppServletContext.invokeServlet(WebAppServletContext.java:3892)
at weblogic.servlet.internal.ServletRequestImpl.execute(ServletRequestImpl.java:2766)
at weblogic.kernel.ExecuteThread.execute(ExecuteThread.java:224)
at weblogic.kernel.ExecuteThread.run(ExecuteThread.java:183)
Caused by: javax.jms.JMSException: MQJMS2007: failed to send message to MQ queue
at com.ibm.mq.jms.services.ConfigEnvironment.newException(ConfigEnvironment.java:553)
at com.ibm.mq.jms.MQMessageProducer.sendInternal(MQMessageProducer.java:1589)
at com.ibm.mq.jms.MQMessageProducer.send(MQMessageProducer.java:1012)
at com.ibm.mq.jms.MQMessageProducer.send(MQMessageProducer.java:1046)
at com.bhr.infra.messaging.PMQueueSender.send(PMQueueSender.java:57)
at com.bhr.infra.messaging.PMHandler.send(PMHandler.java:410)
... 13 more
13 Oct 2006 16:47:15,486 ERROR MessagingUtilServlet [ExecuteThread: '14' for queue: 'weblogic.kernel.Default'][]: **********EXCEPTION TRACE END**************
原因分析和解決方法:
It may be caused by use of old version MQ jar. It can receive message, but cannot send message.
如果你碰到"Cannot Forward a Response that is Already Committed"這樣的錯誤信息,一定是應(yīng)用對一次http請求做了多次頁面跳轉(zhuǎn)或?qū)esponse對象做過close后,又去寫響應(yīng).
這個問題的根本原因由于響應(yīng)本次請求的Response對象的狀態(tài)是已提交狀態(tài)造成的, 它不允許響應(yīng)提交多次。
什么時候Response對象的狀態(tài)變成已提交狀態(tài):當你的應(yīng)用已經(jīng)實現(xiàn)了頁面跳轉(zhuǎn)邏輯。
通常原因:
1. 如果你使用了community的話, community的安全認證和授權(quán)如果沒有通過,community內(nèi)部會進行頁面跳轉(zhuǎn)。但你的應(yīng)用(對于workshop應(yīng)用的話,指的是action)又試圖進行頁面跳轉(zhuǎn),就會出現(xiàn)這樣的問題。
/**
* @jpf:action
* @jpf:forward name="page" path="page.jsp"
*/
protected Forward actionMethod()
{
//如果已經(jīng)提交了響應(yīng),你仍然試圖再次進行頁面跳轉(zhuǎn),即再次提交響應(yīng),可能出現(xiàn)問題
//通常可以加一個判斷
if (!getResponse().isCommitted()) {
return new Forward("success");
} else {
return null;
}
}
protected void beforeAction() {
SecurityManager.checkAuthorization(getRequest(), getResponse(), config.getString(
CDConstants.CREATE_TERM_ACTION_NAME, ""));
//這個調(diào)用可能實現(xiàn)了頁面跳轉(zhuǎn),即提交響應(yīng)
}
注意JSP中實現(xiàn)頁面跳轉(zhuǎn)后,加return 語句防止繼續(xù)提交響應(yīng):
<%
SecurityManager.checkAuthorization(getRequest(), getResponse(), config.getString(
CDConstants.CREATE_TERM_ACTION_NAME, ""));
{
//可能有實現(xiàn)頁面跳轉(zhuǎn)邏輯
……………forward();
return;//記得加retrun.
}
%>
2. .如果沒有使用community的話,下面情景也會出現(xiàn)這個問題
/**
* @jpf:action
* @jpf:forward name="page" path="page.jsp"
*/
protected Forward actionMethod()
//直接操作Response對象寫響應(yīng)
getResponse().getPrintWriter().println();
…
/
// 又執(zhí)行的頁面跳轉(zhuǎn),也可能出現(xiàn)問題
return new Forward("index");
}
一個頁面流在第一次使用時,內(nèi)部屬性currentpage并沒有指定頁面,所以避免在begin方法里使用return-to: current page用法.同時在用的時候注意頁面流的工作方式
問題描述:
Error message like below in Web Page is displayed:
Page Flow:
/com/xxxx/xxx/xxx.jpf
Action:
update
Page Flow Error - No Relevant Page
You have tried to return to a recent page in the current page flow through return-to="currentPage",
but there is no appropriate page.
Exception's stack trace:
Exception: No previous page for return-to="currentPage" on action create in page flow
/com/gems/mt/web/CreateReleaseCntr/CreateReleaseCntrController.jpf.
com.bea.wlw.netui.pageflow.NoPreviousPageException: No relevant page for return-to="currentPage"
on action create in page flow /com/gems/mt/web/CreateReleaseCntr/CreateReleaseCntrController.jpf.
at com.bea.wlw.netui.pageflow.FlowController.doReturnToPage(FlowController.java:1328)
at com.bea.wlw.netui.pageflow.FlowController.forwardTo(FlowController.java:1023)
at com.bea.wlw.netui.pageflow.PageFlowController.forwardTo(PageFlowController.java:606)
at com.bea.wlw.netui.pageflow.FlowController.internalExecute(FlowController.java:765)
...
原因分析和解決方法:
When a new page flow is created and its current page is null (it mean you visit at the fist time),
so such an exception like NoPreviousPageException occur if you use return-to="currentPage".
if a new page flow finish a successful forward, it will treat last page as current page
so that we can use current page to display error message conveniently.
Solution:
ensure page flow finish a successful forward and use current page again.
You can also use path="specificPage.jsp" instead of return-to="currentPage"
if your original return-to is just one specific page.
We have known, the ListCellRenderer interface has only one method public Component getListCellRendererComponent(), and it returns a Component. When a JList needs to compute its dimension or paint its cell item, this method will be called. So it will be called frequently, and we have a best practice, try to reuse object, avoid time-consumed computation and unnecessary operation in this method.
?
Recently found, there is a memory leak bug for list cell renderer in both JDK 1.4.x and JDK 5 (don’t know whether has the same bug in earlier JDK). The component returned from getListCellRendererComponent() method could not be GC, and all its referenced objects also could not be GC. Unfortunately, this bug is only fixed in JDK 6.
?
So currently, if a JList use the ListCellRenderer, but only holds a little resource (eg: the JList only has little items, and the component is returned from ListCellRenderer is a simple JLable), you may not care about the memory leak.
?
But if a JList use the ListCellRenderer, and holds a large resource, you should remember to use the following way to avoid memory leak.
?
Work Around: Subclass JList and invoke removeAll after painting is done:
?????? public class xxxList extends JList {
??????????? private CellRendererPane renderer;
??????????? private CellRendererPane getRenderer() {
??????????????? if (renderer == null) {
??????????????????? for (int i=0; i<getComponents().length; i++) {
????????????????????????????????????????? Component c? = getComponents()[i];
??????????????????????? if (c instanceof CellRendererPane) {
??????????????????????????? renderer = (CellRendererPane)c;
??????????????????????????? break;
??????????????????????? }
??????????????????? }
??????????????? }
??????????????? return renderer;
??????????? }
??????????? protected void paintComponent(Graphics g) {
??????????????? super.paintComponent(g);
??????????????? CellRendererPane renderer = getRenderer();
??????????????? if (renderer != null) {
??????????????????? renderer.removeAll();
??????????????? }
??????????? }
??????? }
Please refer to http://bugs.sun.com/bugdatabase/view_bug.do?bug_id=5044798 for more details.
The logic to change state is only inside one method (initVesselView(…)) inside GrVessel.java.?
if (viewType == VIEW_STOWAGE) { ??????????? vslView_ = new VesselStowageView(leftPoint, bow2Left, leftCenter, ???????????????????????????????????????????? rightCenter, shipWidth_); ??????? } ??????? else if (viewType == VIEW_SIDE) { ??????????? vslView_ = new VesselSideView(leftPoint, bow2Left, leftCenter, ????????????????????????????????????????? rightCenter, shipWidth_); ??????? } ??????? else if (viewType == VIEW_PLAN) { ??????????? vslView_ = new VesselPlanView(leftPoint, bow2Left, leftCenter, ????????????????????????????????????????? rightCenter, shipWidth_); ??????? } ??????? else { ??????????? throw new IllegalArgumentException( ??????????????? "GrVessel::initVesselView-->Invalid view type!"); ??????? }
We do not need to repeat this logic of changing view in many other method.
This is the benefit of State design pattern.
The 3 state classes here are VesselPlanView.java, VesselSideView.java and VesselStowageView.java
Please note that in the state classes, if a method is supported by stateA and not supported by stateB.?
Then, in stateB, the method body will throw an exception (IllegalArgumentException) to indicate that coder call the wrong method in the wrong state.
Example, in VesselPlanView.java, public boolean addStowage(...).? This method is only meaningful to stowageView.
public boolean addStowage(IlvManager manager, List transformList, IlvGraphic stowage, String stadBayN, ????????????????????????????? boolean isSelect) { ??????? throw new IllegalArgumentException( ??????????????? "GrVessel::addStowage-->be sure the vessel at stowage view!"); ??? }
Hence, in PlanView, the method body will throw exception.
Just to share with you a better way to code.
摘要: 本文討論模型過濾技術(shù)。您可將這一技術(shù)用于 Swing 組件集,這樣即可在不改變底層數(shù)據(jù)的條件下提供模型數(shù)據(jù)的不同視圖。過濾器可以改變數(shù)據(jù)元素的外在內(nèi)容,將數(shù)據(jù)排除在視圖之外、將外部元素包含進數(shù)據(jù)集中、或者以不同的順序呈現(xiàn)元素。過濾器既可應(yīng)用于數(shù)據(jù)模型,也可應(yīng)用于狀態(tài)模型。您還可以疊用過濾器,以將它們的效果組合起來。 閱讀全文
有時運行ANT 時會拋出 java.lang.InstantiationException: org.apache.tools.ant.Main 異常 原因之一是在機器中存在2種不同版本的ANT,我碰到的情況是classpath 中即有weblogic.jar,又有1.6.5的ANT, 刪除weblogic.jar后運行就正常了
public class GroupableHeaderExample extends JFrame {
? GroupableHeaderExample() { ??? super( "Groupable Header Example" );
??? DefaultTableModel dm = new DefaultTableModel(); ??? dm.setDataVector(new Object[][]{ ????? {"119","foo","bar","ja","ko","zh"}, ????? {"911","bar","foo","en","fr","pt"}}, ??? new Object[]{"SNo.","1","2","Native","2","3"});
??? JTable table = new JTable( dm ) { ????? protected JTableHeader createDefaultTableHeader() { ? return new GroupableTableHeader(columnModel); ????? } ??? }; ??? TableColumnModel cm = table.getColumnModel(); ??? ColumnGroup g_name = new ColumnGroup("Name"); ??? g_name.add(cm.getColumn(1)); ??? g_name.add(cm.getColumn(2)); ??? ColumnGroup g_lang = new ColumnGroup("Language"); ??? g_lang.add(cm.getColumn(3)); ??? ColumnGroup g_other = new ColumnGroup("Others"); ??? g_other.add(cm.getColumn(4)); ??? g_other.add(cm.getColumn(5)); ??? g_lang.add(g_other); ??? GroupableTableHeader header = (GroupableTableHeader)table.getTableHeader(); ??? header.addColumnGroup(g_name); ??? header.addColumnGroup(g_lang);
??? TableCellRenderer renderer =? new DefaultTableCellRenderer() { ??????? public Component getTableCellRendererComponent(JTable table, Object value, ???????????????????????? boolean isSelected, boolean hasFocus, int row, int column) { ????????? JTableHeader header = table.getTableHeader(); ????????? if (header != null) { ??????????? setForeground(header.getForeground()); ??????????? setBackground(header.getBackground()); ??????????? setFont(header.getFont()); ????????? } ????????? setHorizontalAlignment(JLabel.CENTER); ????????? setText((value == null) ? "" : value.toString()); ????????? setBorder(UIManager.getBorder("TableHeader.cellBorder")); ????????? return this; ??????? } ????? };
??? TableColumnModel model = table.getColumnModel(); ??? for (int i=0;i<model.getColumnCount();i++) { ????? model.getColumn(i).setHeaderRenderer(renderer); ??? } ??? JScrollPane scroll = new JScrollPane( table ); ??? getContentPane().add( scroll ); ??? setSize( 400, 120 ); ? }
? public static void main(String[] args) { ??? GroupableHeaderExample frame = new GroupableHeaderExample(); ??? frame.addWindowListener( new WindowAdapter() { ????? public void windowClosing( WindowEvent e ) { ? System.exit(0); ????? } ??? }); ??? frame.setVisible(true); ? } }
============================================= public void paint(Graphics g, JComponent c) { ??? Rectangle clipBounds = g.getClipBounds(); ??? if (header.getColumnModel() == null) return; //??? ((GroupableTableHeader)header).setColumnMargin(); ??? int column = 0; ??? Dimension size = header.getSize(); ??? Rectangle cellRect? = new Rectangle(0, 0, size.width, size.height); ??? Hashtable h = new Hashtable(); //??? int columnMargin = header.getColumnModel().getColumnMargin();
??? Enumeration enumeration = header.getColumnModel().getColumns(); ??? while (enumeration.hasMoreElements()) { ????? cellRect.height = size.height; ????? cellRect.y????? = 0; ????? TableColumn aColumn = (TableColumn)enumeration.nextElement(); ????? Enumeration cGroups = ((GroupableTableHeader)header).getColumnGroups(aColumn); ????? if (cGroups != null) { ??????? int groupHeight = 0; ??????? while (cGroups.hasMoreElements()) { ????????? ColumnGroup cGroup = (ColumnGroup)cGroups.nextElement(); ????????? Rectangle groupRect = (Rectangle)h.get(cGroup); ????????? if (groupRect == null) { ??????????? groupRect = new Rectangle(cellRect); ??????????? Dimension d = cGroup.getSize(header.getTable()); ??????????? groupRect.width? = d.width; ??????????? groupRect.height = d.height; ??????????? h.put(cGroup, groupRect); ????????? } ????????? paintCell(g, groupRect, cGroup); ????????? groupHeight += groupRect.height; ????????? cellRect.height = size.height - groupHeight; ????????? cellRect.y????? = groupHeight; ??????? } ????? } ????? cellRect.width = aColumn.getWidth() ;//+ columnMargin; ????? if (cellRect.intersects(clipBounds)) { ??????? paintCell(g, cellRect, column); ????? } ????? cellRect.x += cellRect.width; ????? column++; ??? } ? }
使用
IlvToolTipManager
創(chuàng)建一個多行的
tooltip
:
?
1)
首先需要注冊
view (IlvManagerView)I
lvToolTipManager.registerView(view);
?
2)
創(chuàng)建需要顯示的信息的數(shù)組,即每行的信息為數(shù)組中的一個元素:
new String[] tooltipArray ;
?
3)
創(chuàng)建
tooltip,
第一個參數(shù)是上面創(chuàng)建的數(shù)組,第二個參數(shù)是顯示位置,必須是
SwingConstants.LEFT
,
RIGHT
, or
CENTER
String tooltip = IlvToolTipManager.createMultiLineToolTipText(tooltipArray, SwingConstants.LEFT);
?
4)
設(shè)置
tooltip
:
IlvGraphic.setToolTipText(tooltip);
public static String createMultiLineToolTipText(String as[], int i) ??? { ??????? String s; ??????? switch(i) ??????? { ??????? case 2: // '\002' ??????????? s = "left"; ??????????? break;
??????? case 4: // '\004' ??????????? s = "right"; ??????????? break;
??????? case 0: // '\0' ??????????? s = "center"; ??????????? break;
??????? case 1: // '\001' ??????? case 3: // '\003' ??????? default: ??????????? throw new IllegalArgumentException("Alignment must be LEFT, RIGHT, or CENTER"); ??????? } ??????? Font font = UIManager.getFont("ToolTip.font"); ??????? StringBuffer stringbuffer = new StringBuffer("<p align=\""); ??????? stringbuffer.append(s); ??????? stringbuffer.append("\" style=\"font-family:"); ??????? stringbuffer.append(font.getName()); ??????? stringbuffer.append(";font-size:"); ??????? stringbuffer.append(font.getSize()); ??????? stringbuffer.append("pt\">"); ??????? String s1 = stringbuffer.toString(); ??????? StringBuffer stringbuffer1 = new StringBuffer("<html>"); ??????? for(int j = 0; j < as.length; j++) ??????? { ??????????? stringbuffer1.append(s1); ??????????? stringbuffer1.append(as[j]); ??????????? stringbuffer1.append("</p>"); ??????? }
??????? stringbuffer1.append("</html>"); ??????? return stringbuffer1.toString(); ??? }
?
下面這個異常是因為沒有找到EJB, JNDI NAME 本來是 'ejb/ppp/sss/Resource' ,? 可找的卻是'ejb.ppp.sss/Resource' , 后來查到是因為EJB 的REMOTE 接口中的方法在BEAN中沒有定義. 不知道還有沒有其他什么原因可以導(dǎo)致這種情況.
Caused by: javax.naming.NameNotFoundException: While trying to lookup 'ejb.ppp.sss/Resource' didn't find subcontext 'ppp' Resolved ejb ?at weblogic.jndi.internal.BasicNamingNode.newNameNotFoundException(BasicNamingNode.java:924) ?at weblogic.jndi.internal.BasicNamingNode.lookupHere(BasicNamingNode.java:225) ?at weblogic.jndi.internal.ServerNamingNode.lookupHere(ServerNamingNode.java:154) ?at weblogic.jndi.internal.BasicNamingNode.lookup(BasicNamingNode.java:188) ?at weblogic.jndi.internal.BasicNamingNode.lookup(BasicNamingNode.java:196) ?at weblogic.jndi.internal.RootNamingNode_WLSkel.invoke(Unknown Source) ?at weblogic.rmi.internal.BasicServerRef.invoke(BasicServerRef.java:492) ?at weblogic.rmi.cluster.ReplicaAwareServerRef.invoke(ReplicaAwareServerRef.java:108) ?at weblogic.rmi.internal.BasicServerRef$1.run(BasicServerRef.java:435) ?at weblogic.security.acl.internal.AuthenticatedSubject.doAs(AuthenticatedSubject.java:363) ?at weblogic.security.service.SecurityManager.runAs(SecurityManager.java:147) ?at weblogic.rmi.internal.BasicServerRef.handleRequest(BasicServerRef.java:430) ?at weblogic.rmi.internal.BasicExecuteRequest.execute(BasicExecuteRequest.java:35) ?at weblogic.kernel.ExecuteThread.execute(ExecuteThread.java:224) ?at weblogic.kernel.ExecuteThread.run(ExecuteThread.java:183)
摘要: 我們期待自己成為一個優(yōu)秀的軟件模型設(shè)計者,但是,要怎樣做,又從哪里開始呢?
將下列原則應(yīng)用到你的軟件工程中,你會獲得立桿見影的成果 閱讀全文
Eclipse插件下載列表 MyEclipse:J2EE開發(fā)插件,支持JSP、EJB、數(shù)據(jù)庫等操作。 下載站點: www.myeclipseide.comLomboz:和MyEclipse的同類型插件且免費。 下載站點: http://forge.objectweb.org/project/showfiles.php?group_id=97XMLBuddy:xml文件編輯器 下載站點: www.xmlbuddy.comFat Jar:項目打包插件,可以將項目支持包和項目本身打成一個包。 下載站點: http://fjep.sourceforge.net/Jinto:國際化插件 下載站點: http://www.guh-software.de/Jasper Assistant:報表插件 下載站點: http://www.jasperassistant.com/Log4E Log4j插件,提供Log4j的快速操作。Log4j專用于為程序輸入調(diào)試信息。 下載站點: http://log4e.jayefem.de/index.php/Main_PageVSSplugin: VSS客戶端插件,VSS是一個和CVS齊名的版本管理系統(tǒng)。 下載站點: http://sourcefore.net/projects/vsspluginImplementors: 當追蹤方法代碼時,Eclipse默認是轉(zhuǎn)到方法的接口類,而接口中是只有方法名稱沒有代碼的。此插件提供了追蹤到方法的實現(xiàn)代碼功能。 下載頁面: http://eclipse-tools.sourceforge.net/implementors/Call Hierarchy: 顯示一個方法的調(diào)用層次,可以從中看到它被哪些方法調(diào)用了,以及它調(diào)用了哪些方法,是代碼追蹤比較實用的工具。 下載站點: http://eclipse-tools.sourceforge.net/ccall-hierarchy/Hebernate Synchronizer: Hibernate插件,提供Hibernate的自動映射等操作。 下載站點: http://www.binamics.com/hibernatesync/Profiler: 性能跟蹤、測量工具,能跟蹤、測試B/S模式開發(fā)的程序。 下載站點: http://sourceforge.net/projects/eclipsecolorer/myeclipse http://www.myeclipseide.com/ContentExpress-display-ceid-10.htmlWindowBuilder Pro - SWT/Swing Designer http://www.swt-designer.com/
WLS 9.1與MQ v5.3 通過JMS Bridge通信配置
最近參與一個系統(tǒng)的原型開發(fā),原型要求演示W(wǎng)ebLogic Server9.1與其他第三方產(chǎn)品的通信支持,包括與IBM MQSeries的雙向交互、與Tuxedo的雙向交互、支持與.NET的通過Web Service交互等。我負責(zé)完成與IBM MQSeries的雙向交互這部分,在網(wǎng)上找了不少文章,發(fā)現(xiàn)其中基本都是基于WebLogic Server 8.1實現(xiàn)的。因為WebLogic Server 9.1在JMS上有很大的增強,所以我參考以前的文章,自己實現(xiàn)了WebLogic Server 9.1與IBM MQSeries 5.3的雙向交互并且進行了測試。想必很多同行會遇到跟我一樣的問題,特此撰文一片跟大家分享。本文配置在window xp上測試成功。
概述
目標是實現(xiàn)WebLogic Server 9.1和IBM MQSeries5.3之間的的雙向交互,包括:
- WebLogic Server 9.1消息轉(zhuǎn)發(fā)給IBM MQSeries5.3
- IBM MQSeries 5.3消息轉(zhuǎn)發(fā)給WebLogic Server 9.1
具體地,將WebLogic Server9.1隊列WLSSendQueue的消息轉(zhuǎn)發(fā)到IBM MQSeries 5.3隊列MQReceiveQueue,同時將IBM MQSeries 5.3隊列MQSendQueue的消息轉(zhuǎn)發(fā)到WebLogic Server 9.1隊列WLSSendQueue。
WebLogic Server包含一個完整的、有豐富特性的消息服務(wù)器。第三方的消息服務(wù)器(如IBM MQSeries),只要其提供了JMS API的實現(xiàn),也可以在其中運行。Messaging Bridge是一種由WebLogic Server提供的J2EE設(shè)備,用于轉(zhuǎn)發(fā)兩個消息提供者的消息。你可以使用Messaging Bridge將消息從一個消息提供者的目的地(隊列或者主題)移至另外一個消息提供者的目的地。因此,當WebLogic應(yīng)用程序需要與第三方消息提供者 (比如IBM MQSeries)進行交互時,Messaging Bridge就可以承擔(dān)這個中間角色。我們需要做如下配置:
- 通過WebLogic控制臺建立兩個WebLogic隊列:發(fā)送隊列WLSSendQueue和接收隊列WLSReceiveQueue。
- 類似地,通過MQ資源管理器建立兩個MQ本地隊列:發(fā)送隊列MQSendQueue和接收隊列MQReceiveQueue。
- 為 了實現(xiàn)消息轉(zhuǎn)發(fā)需要建立兩個Messaging Bridge:WLS2MQBridge 和MQ2WLSBridge 。WLS2MQBridge:將WebLogic發(fā)送隊列WLSSendQueue的消息轉(zhuǎn)發(fā)到MQ接收隊列MQReceiveQueue; MQ2WLSBridge:將MQ發(fā)送隊列MQSendQueue的消息轉(zhuǎn)發(fā)到WebLogic接收隊列WLSReceiveQueue。
- 為 了實現(xiàn)事務(wù)性消息轉(zhuǎn)發(fā), WebLogic需要使用XAQueueConnectionFactory,而MQ需要使用MQXAQueueConnectionFactory。這 就確定了WebLogic需要使用支持XA的連接工廠,MQ必須采用綁定的模式,并且WebLogic和MQ必須安裝在同一臺機器上。
WLS配置
WebLogic Server 9.1在WebLogic JMS的配置、部署和動態(tài)管理方面引入了重要的改進。它對JMS 1.1規(guī)范提供官方支持。此外,在系統(tǒng)中添加了人們期待已久的消息排序高級特性。XML API的XML消息處理功能得到了增強。在WebLogic 9.1平臺上使用JMS非常輕松有趣、可靠且迅速。下面是現(xiàn)有新特性中的一些亮點。
- 自動化的 JMS 故障恢復(fù)
自動化的JMS故障恢復(fù)是業(yè)內(nèi)期待已久的特性。JMS利用“Automatic WebLogic Server Migration”特性來提供自動化的JMS故障恢復(fù)。在整個WebLogic Server實例進行故障恢復(fù)時,JMS也將自動從故障中恢復(fù)過來。盡管其他的一些JMS服務(wù)器提供商已經(jīng)利用一些復(fù)雜裝置提供了這樣的功能,但 WebLogic 9.1的實現(xiàn)是最直觀而清晰的。
- 排序單元
消息排序是大多數(shù)消息處理應(yīng)用程序的一項基本要求。WebLogic Server JMS即使在集群環(huán)境中也能確保消息的順序處理。它甚至可以定義多個組來將消息分組,這樣每個組都擁有自己的處理順序(如圖1所示)。 
- 存儲轉(zhuǎn)發(fā) (SAF)
WebLogic存儲轉(zhuǎn)發(fā)(store and forward, SAF)服務(wù)使WebLogic Server能在通過WebLogic Server實例部署的應(yīng)用程序間可靠地交付信息。SAF的強大功能使得我們可以很容易地將多個消息服務(wù)鏈接在一起(如圖2所示)。 
- Messaging Bridge具有如下優(yōu)點:
- 不需要編碼,純配置,加速你的開發(fā);
- 靈活的體系結(jié)構(gòu),容易配置多個Messaging Bridges,并且而且可以動態(tài)的啟動和停止單個Messaging Bridge;
- 采用即取即用的MQ 適配器,實現(xiàn)全面的MQ JMS 支持,能夠設(shè)定MQ 主題查詢;
- 充分利用WebLogic容器進行服務(wù)管理,并且集中所有的Bridges資源在一個線程池;
- 全面的事務(wù)處理能力,兩階段事務(wù)處理;
- 全面的JCA 支持;
- 確保服務(wù)質(zhì)量和連接管理,實實在在的一次性服務(wù);
- 控制臺監(jiān)視能力;
- 集成BEA WebLogic應(yīng)用與外部消息提供商,以便將新的應(yīng)用與現(xiàn)有的投資連接起來。
創(chuàng)建Server域
創(chuàng)建Server Domain, domain名稱jms_domain
修改啟動文件
修改WebLogic的啟動文件startWebLogic.cmd。將IBM MQSeries和IBM MQSeries Java的安裝目錄加到WebLogic path下,同時將MQ JMS Java類包加入到WebLogic classpath下:
@rem added the following to configure messaging bridge with local MQSeries installation
set MQ_INSTALL_PATH=D:\installed\MQ
set MQ_JAVA_INSTALL_PATH=D:\installed\MQ\Java
set MQ_JAVA_LIB=%MQ_JAVA_INSTALL_PATH%\lib
set MQ_CLASSPATH=%MQ_JAVA_LIB%\com.ibm.mq.jar
set MQ_CLASSPATH=%MQ_CLASSPATH%;%MQ_JAVA_LIB%\com.ibm.mqbind.jar
set MQ_CLASSPATH=%MQ_CLASSPATH%;%MQ_JAVA_LIB%\com.ibm.mqjms.jar
set MQ_CLASSPATH=%MQ_CLASSPATH%;%MQ_JAVA_LIB%\fscontext.jar
set MQ_CLASSPATH=%MQ_CLASSPATH%;%MQ_JAVA_LIB%\jms.jar
set MQ_CLASSPATH=%MQ_CLASSPATH%;%MQ_JAVA_LIB%\jndi.jar
set MQ_CLASSPATH=%MQ_CLASSPATH%;%MQ_JAVA_LIB%\jta.jar
set MQ_CLASSPATH=%MQ_CLASSPATH%;%MQ_JAVA_LIB%\ldap.jar
set MQ_CLASSPATH=%MQ_CLASSPATH%;%MQ_JAVA_LIB%\providerutil.jar
set MQ_PATH=%MQ_INSTALL_PATH%\in;%MQ_JAVA_INSTALL_PATH%\in;
%MQ_JAVA_INSTALL_PATH%\lib
set PATH=%MQ_PATH%;%PATH%
set CLASSPATH=%MQ_CLASSPATH%;%WEBLOGIC_CLASSPATH%;
%POINTBASE_CLASSPATH%;%JAVA_HOME%\jre\lib\rt.jar;
%WL_HOME%\server\lib\webservices.jar;%CLASSPATH%
配置JMS
注意WLS91的連接工廠和隊列要到JMS Modules下面設(shè)置:
- 創(chuàng)建文件后備存儲BridgeFileStore
- 創(chuàng)建JMS服務(wù)器BridgeJMSServer,和Paging Store設(shè)為" BridgeFileStore" ,Target為adminServer
- 創(chuàng)建支持XA的連接工廠WLSCFXA,JNDI Name為bridge.wlsCFXA
- 創(chuàng)建JMS發(fā)送隊列WLSSendQueue,JNDI名稱為bridge.wlsSendQueue,Target為BridgeJMSServer
- 創(chuàng)建JMS接收隊列WLSReceiveQueue,JNDI名稱為bridge.wlsReceiveQueue,Target為BridgeJMSServer

配置Messaging Bridge Destination
- JMS Bridge Destination名稱為MQReceiveBridgeDestination
- Adapter JNDI Name: eis.jms.WLSConnectionFactoryJNDIXA
- Connection URL為file:/D:/installed/MQ/Queues,
- Initial Context Factory為com.sun.jndi.fscontext.RefFSContextFactory,
- Connection Factory JNDI Name為bridge.mqQCFXA,
- Destination JNDI Name為bridge.mqReceiveQueue
- Destination Type: Queue
- JMS Bridge Destination名稱為MQSendBridgeDestination
- Adapter JNDI Name: eis.jms.WLSConnectionFactoryJNDIXA
- Connection URL為file:/D:/installed/MQ/Queues,
- Initial Context Factory為com.sun.jndi.fscontext.RefFSContextFactory,
- Connection Factory JNDI Name為bridge.mqQCFXA,
- Destination JNDI Name為bridge.mqSendQueue
- Destination Type: Queue
- JMS Bridge Destination名稱為WLSReceiveBridgeDestination
- Adapter JNDI Name: eis.jms.WLSConnectionFactoryJNDIXA
- Connection URL為t3://localhost:7001,
- Initial Context Factory為weblogic.jndi.WLInitialContextFactory,
- Connection Factory JNDI Name為bridge.wlsCFXA,
- Destination JNDI Name為bridge.wlsReceiveQueue
- Destination Type: Queue
- User Name: weblogic(域配置時指定的)
- User Password: weblogic(域配置時指定的)
- JMS Bridge Destination名稱為WLSSendBridgeDestination
- Adapter JNDI Name: eis.jms.WLSConnectionFactoryJNDIXA
- Connection URL為t3://localhost:7001,
- Initial Context Factory為weblogic.jndi.WLInitialContextFactory,
- Connection Factory JNDI Name為bridge.wlsCFXA,
- Destination JNDI Name為bridge.wlsSendQueue,
- Destination Type: Queue
- User Name: weblogic(域配置時指定的)
- User Password: weblogic(域配置時指定的)
配置Messaging Bridge
- JMS Bridge名稱為MQ2WLSBridge
- Source Bridge Destination: MQSendBridgeDestination
- Target Bridge Destination: WLSReceiveBridgeDestination
- Quality Of Service: Exactly-Once
- Started: Yes
- JMS Bridge名稱為WLS2MQBridge
- Source Bridge Destination: WLSSendBridgeDestination
- Target Bridge Destination: MQReceiveBridgeDestination
- Quality Of Service: Exactly-Once
- Started: Yes

MQ 配置
IBM MQSeries是IBM的商業(yè)通訊中間件(Commercial Messaging Middleware)。IBM MQSeries提供一個具有工業(yè)標準,安全,可靠的信息傳輸系統(tǒng)。它的功能是控制和管理一個集成的商業(yè)應(yīng)用,使得組成這個商業(yè)應(yīng)用的多個分支程序(模塊)之間通過傳遞信息完成整個工作流程。IBM MQSeries具有特殊的技術(shù)防止信息重復(fù)傳送,確保信息一次且僅一次(once-and-only-once)傳遞,保證傳輸?shù)目煽啃浴1疚氖褂玫?MQ版本為IBM MQSeries 5.3。
IBM MQSeries基本由一個消息傳輸系統(tǒng)和一個應(yīng)用程序接口組成,其資源是消息和隊列(Messaging and Queuing)。
隊列管理器(Queue Manager):管理隊列的系統(tǒng),實現(xiàn)網(wǎng)絡(luò)通信,保證消息安全可靠地傳輸?shù)侥康牡亍S糜诖_保隊列之間的信息提供,包括網(wǎng)絡(luò)中不同系統(tǒng)上的的遠程隊列之間的信息提供。并保證網(wǎng)絡(luò)故障或關(guān)閉后的恢復(fù)。
隊列:一個安全的信息存儲區(qū)。因為信息存放在隊列中,所以應(yīng)用程序可以相互獨立的運行,以不同的速度,在不同的時間,在不同的地點。
本地隊列:對程序而言,本地隊列屬于該程序所連接的隊列管理器。
遠程隊列:該隊列不屬于該程序所連接的隊列管理器,而只是遠端隊列管理器的隊列在本地的定義。
傳輸隊列:它是一個本地隊列,保存了指定要發(fā)送到遠端的消息。
死信隊列:它是一個本地隊列,用于存放無法傳遞的消息。
通道:在兩個隊列管理器之間建立起來的數(shù)據(jù)傳輸鏈路。
應(yīng)用程序接口:應(yīng)用程序和信息系統(tǒng)之間通過MQSeries API實現(xiàn)的接口。
Install MQ
- 安裝過程中選擇自定義安裝模式,并確保安裝JMS所需的Java jar包支持如下圖:
(缺省安裝未包含)
確認MQ服務(wù)已啟動。
可通過MicroSoft windows控制面板中管理工具下的服務(wù)控制臺確認。如下圖:
從程序菜單啟動MQ 資源管理器
如果程序提示試用版過期,可以通過修改系統(tǒng)時間搞定.我就是修改到了2004年。
通過MQ資源管理器創(chuàng)建一個通道
建立名為BRIDGE.CHANNEL的通道,其他參數(shù)缺省設(shè)置。
通過MQ資源管理器創(chuàng)建兩個本地隊列
建立兩個本地隊名為MQReceiveQueue, MQSendQueue,其他參數(shù)缺省設(shè)置。
更新MQ安裝目錄下與JMS配置相關(guān)的文件
JMSAdmin.config文件位于%MQ_INSTALLL_HOME_PATH%\Java\bin,主要定義JNDI服務(wù)的提供商,即JMS Server Factory和URL。%MQ_INSTALLL_HOME_PATH%\Java\bin目錄下新建目錄bridgeconfig,將JMSAdmin.config文件拷貝到bridgeconfig。
使用Sun的文件JNDI服務(wù)Factory,故定義
?
INITIAL_CONTEXT_FACTORY=com.sun.jndi.fscontext.RefFSContextFactory
PROVIDER_URL=file:/D:/installed/MQ/Queues
SECURITY_AUTHENTICATION=none
(例子中,MQ安裝目錄%MQ_INSTALLL_HOME_PATH%為:D:/installed/MQ/)
JMSAdmin.bat文件也位于%MQ_INSTALLL_HOME_PATH%\Java\bin,此文件用于啟動MQ的JMS命令行管理界面,要設(shè)置啟動JMS命令行管理界面所需環(huán)境變量。在JMSAdmin.bat中添加如下環(huán)境變量:
set MQ_JAVA_INSTALL_PATH=D:\installed\MQ\Java
set MQ_JAVA_LIB=%MQ_JAVA_INSTALL_PATH%lib
set MQ_CLASSPATH=%MQ_JAVA_LIB%com.ibm.mq.jar
set MQ_CLASSPATH=%MQ_CLASSPATH%;%MQ_JAVA_LIB%com.ibm.mqbind.jar
set MQ_CLASSPATH=%MQ_CLASSPATH%;%MQ_JAVA_LIB%com.ibm.mqjms.jar
set MQ_CLASSPATH=%MQ_CLASSPATH%;%MQ_JAVA_LIB%fscontext.jar
set MQ_CLASSPATH=%MQ_CLASSPATH%;%MQ_JAVA_LIB%jms.jar
set MQ_CLASSPATH=%MQ_CLASSPATH%;%MQ_JAVA_LIB%jta.jar
set MQ_CLASSPATH=%MQ_CLASSPATH%;%MQ_JAVA_LIB%ldap.jar
set MQ_CLASSPATH=%MQ_CLASSPATH%;%MQ_JAVA_LIB%providerutil.jar
進入MQ的JMS命令行管理界面綁定MQ的JMS Factory以及JMS本地隊列
- 如上圖所示界面,生成一個MQXAQueueConnectionFactory對象,Messaging Bridge將使用這個工廠對象建立MQ的XA連接,使用命令DEFINE XAQCF,起名:bridge.mqQCFXA。
- 生成JMSQueue對象來綁定MQ隊列MQReceiveQueue。
- 生成JMSQueue對象來綁定MQ隊列MQSendQueue。
- 使用dis ctx命令,查看目前已有的對象和綁定,可以看到XA連接工廠和隊列都已綁定。
測試
MQ發(fā)送,WLS接收
- MQ發(fā)送隊列放入測試消息

- 在WLS控制臺監(jiān)測消息到達

WLS發(fā)送,MQ接收
- WLS發(fā)送隊列放入測試消息
執(zhí)行下面的代碼,給WLS發(fā)送隊列放入測試消息 ? package com.bea;
import javax.naming.InitialContext;
import javax.naming.Context;
import javax.naming.NamingException;
import javax.jms.*;
import java.util.Hashtable;
/**
* Created by IntelliJ IDEA.
* User: pmeng
* Date: 2006-6-3
* Time: 14:54:08
*/
public class SendMessageTest {
public static void main(String[] args) {
try {
Hashtable env = new Hashtable();
env.put(Context.INITIAL_CONTEXT_FACTORY, "weblogic.jndi.WLInitialContextFactory");
env.put(Context.PROVIDER_URL, "t3://localhost:7001");
InitialContext ctx = new InitialContext(env);
QueueConnectionFactory factory = (QueueConnectionFactory) ctx.lookup("bridge.wlsCFXA");
QueueConnection connection = factory.createQueueConnection();
QueueSession session = connection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
Queue queue = (Queue) ctx.lookup("bridge.wlsSendQueue");
connection.start();
QueueSender queueSender = session.createSender(queue);
TextMessage msg = session.createTextMessage();
msg.setText("Menghe.");
queueSender.send(msg);
}
catch (NamingException e) {
System.out.println("NamingException:" + e.getMessage());
e.printStackTrace();
}
catch (JMSException e) {
System.out.println("JMSException:" + e.getMessage());
e.printStackTrace();
}
}
}
- MQ資源管理器查看接收到的消息

參考資料
- BEA WebLogic Server 8.1 JMS與 IBM MQSeries 集成方案,周海根,
http://dev2dev.bea.com.cn/techdoc/20040411784.html
- BEA WebLogic 8.1 JMS 與IBM MQ v5.3 通過JMS Message Bridge通信配置,陳仁祥
http://e-docs.bea.com/wls/docs91/messaging.html
轉(zhuǎn)自http://www.lrsolution.com/docs/MQvsWLJMS.html
比較IBM MQSeries和BEA WebLogic JMS Server
劉睿 2005年7月
在面向消息的中間件(MOM)這個領(lǐng)域,IBM MQSeries (又稱WebSphere MQ)一直是當仁不讓的超級大哥,其它還有一些小兄弟,比如SwiftMQ、SonicMQ之類。但近年來隨著J2EE中的JMS規(guī)范的建立,完備地支持JMS的服務(wù)器如雨后春筍般地出現(xiàn),比如BEA WebLogic Server的JMS Server就是其中一個佼佼者。
僅僅就JMS規(guī)范來說,MQSeries與WebLogic JMS沒有什么不同之處。但JMS規(guī)范僅僅定義了消息服務(wù)器的一個開發(fā)接口,而且還忽略了許多細節(jié),所以不同之處就在JMS規(guī)范之外的這些內(nèi)容,很多也是非常重要的。總的來說,MQSeries的功能和性能方面明顯占優(yōu),而WebLogic JMS的某些JMS配置更加簡單易行。
在本文中,我盡量試圖從客觀的角度分析兩種產(chǎn)品的差異,如有不妥之處,請讀者不吝賜教。
1. 產(chǎn)品體系架構(gòu)不同造成的差異
WebLogic JMS是一個純Java實現(xiàn)的支持C-S架構(gòu)的實現(xiàn)JMS規(guī)范的服務(wù)器產(chǎn)品;而MQSeries是使用本地語言(比如在UNIX和Windows上的C語言)編寫的既支持C-S架構(gòu),又支持對等訪問的實現(xiàn)完備MOM(包括JMS規(guī)范)的產(chǎn)品。于是就產(chǎn)生出以下的不同點:
1.1 MQSeries支持真正的異步數(shù)據(jù)傳輸;而WebLogic JMS不支持。
異步發(fā)送數(shù)據(jù)到遠端的消息服務(wù)器,是MQSeries等完備的MOM的特色。JMS規(guī)范規(guī)定了一個C-S架構(gòu),定義了JMS客戶機與JMS服務(wù)器的開發(fā)接口,并沒有定義JMS服務(wù)器與JMS服務(wù)器的規(guī)范,而客戶機方面沒有任何隊列,所以只能說是規(guī)范了消息的存取,而沒有規(guī)范消息數(shù)據(jù)的傳輸。因為JMS客戶機并不擁有存放數(shù)據(jù)的隊列,所以所有發(fā)送的操作都要由應(yīng)用程序來控制,JMS服務(wù)器本身并不代理傳輸,也不保證數(shù)據(jù)在遠程隊列間傳輸?shù)目煽啃浴ebLogic JMS就是這樣的體系。
這種體系結(jié)構(gòu)有時候是不能直接滿足應(yīng)用的要求的。首先,為了充分利用資源和提高效率,許多應(yīng)用需要采用異步消息的機制。其次,許多需要快速返回的應(yīng)用也必須使用異步傳輸。比如電話自動語音應(yīng)答(IVR)的程序,某個操作需要把數(shù)據(jù)傳輸?shù)竭h程的服務(wù)器上,但是必須立即返回,接受客戶的下一個按鍵。
MQSeries通過通道與傳輸隊列和遠程隊列來完成這一任務(wù)。能充分利用網(wǎng)絡(luò)的帶寬,甚至支持斷網(wǎng)續(xù)傳,保證數(shù)據(jù)傳輸?shù)目煽啃浴.斎唬m然應(yīng)用程序不必作任何工作,但配置方面確實還要多學(xué)一些概念。
1.2 MQSeries支持多種語言的開發(fā);而WebLogic JMS基本上只支持JAVA
MQSeries支持的語言包括C, C++, COBOL, JAVA, PL/1, REXX, RPG, Visual Basic (使用COM/ActiveX)等。老板本的MQSeries支持JAVA是通過一個叫MA88的SupportPac來實現(xiàn),雖然經(jīng)過廣泛的使用和驗證,但給人的感覺是不太方便。好在從5.3版起(目前最新的是6.0版),JAVA支持已經(jīng)內(nèi)置在MQSeries中。
WebLogic JMS一般只支持JAVA開發(fā)。但BEA也在dev2dev.bea.com網(wǎng)站上提供了一套免費的C的支持,稱作“JMS C API”。參見http://dev2dev.bea.com/utilitiestools/environment.html?highlight=utilitiestools。但這個工具與老的MA88也是不能相提并論的,因為BEA并不真正支持它,因此也基本沒有什么用戶。參見BEA網(wǎng)站上關(guān)于“JMS C API”的警告:
1.3 純JAVA實現(xiàn)的利與弊
MQSeries是用本地語言實現(xiàn)的,因此帶來的好處是高性能和高并發(fā)的支持能力。MQSeries相對WebLogic JMS等產(chǎn)品的性能優(yōu)勢是非常明顯的,所以MQSeries非常適于企業(yè)級的大數(shù)據(jù)量和高并發(fā)的數(shù)據(jù)傳輸業(yè)務(wù)。誰也無法想象一個企業(yè)級的數(shù)據(jù)應(yīng)用會采用一個純Java實現(xiàn)的數(shù)據(jù)庫,因為其性能無法滿足要求,對較大的數(shù)據(jù)傳輸應(yīng)用也是一樣的,純Java實現(xiàn)的JMS服務(wù)器例如WebLogic JMS無法滿足其性能的要求。
純JAVA實現(xiàn)的JMS服務(wù)器也有其好處,就是與其它的J2EE服務(wù)完美地集成在一起。所以WebLogic的JMS配置顯得更簡潔。WebSphere+MQSeries也配合得很好,但總是能感覺到是這兩個產(chǎn)品。WebLogic JMS的對象體系完全符合JMS的概念體系。而MQSeries要通過WebSphere Application Server或者一個叫JMSAdmin的工具,借助于目錄服務(wù)來完成MQSeries概念體系到JMS概念體系的映射。應(yīng)該是看到了這件事造成的麻煩,所以IBM在WebSphere v6也提供了一套純JAVA實現(xiàn)的、與MQSeries可以互操作的JMS服務(wù)器。另外一點是WebLogic不需要WebSphere以及MQSeries那樣的冗長的CLASSPATH等環(huán)境變量的設(shè)置,這點對開發(fā)人員有吸引力。
1.4 MQSeries的通信功能更加強大,WebLogic JMS也有自己的一些特色
JMS對通信功能的要求很少,所以對二者對通信支持能力還是有很大的差別的。總的來說,歷史更悠久的MQSeries占優(yōu),但WebLogic JMS也有自己的特色。
- MQSeries支持支持真正的遠程異步數(shù)據(jù)傳輸,甚至支持消息的路由,可以“多級跳”;WebLogic JMS不支持。
- MQSeries支持消息的分組和分段傳輸,對于大消息傳輸和不穩(wěn)定的網(wǎng)絡(luò)非常有意義。WebLogic JMS沒有這方面的功能。
- 二者都支持SSL、持久性、優(yōu)先級、超時等功能。除了完備的SSL實現(xiàn)之外,MQSeries的安全體系 遭到了一些批評,使用通道的安全出口程序顯得很麻煩,而使用用戶名稱但無須口令保護的遠程數(shù)據(jù)通信,如何能令人滿意?但在這一點上WebLogic JMS也很難說就好一些,因為WebLogic JMS僅僅支持C-S的操作,系統(tǒng)本身并不支持遠程的數(shù)據(jù)傳輸(需要應(yīng)用實現(xiàn))。
- WebLogic JMS支持IP多播會話,能顯著地提高 局域網(wǎng)內(nèi)廣播通信的性能,但這種方式不保證數(shù)據(jù)接收的可靠性,只適于某些特定的應(yīng)用。MQSeries本身不提供此功能,但在Event Broker和Message Broker等MQSeries的升級產(chǎn)品中提供IP多播的支持。
1.5 MQSeries的管理功能更加強大
JMS對管理功能的要求很少,在這方面MQSeries也有比較明顯的優(yōu)勢。
- JMS對事務(wù)處理的支持包括的對XASession和XAConnection實現(xiàn),這一點對MQSeries和WebLogic JMS是相同的。MQSeries本身還可以作為事務(wù)管理器,協(xié)調(diào)兩階段提交。
- MQSeries和WebLogic JMS都支持Message Driven Bean作為觸發(fā)新的應(yīng)用的一種方式。WebLogic JMS還支持一種稱作Session Pool的類似的觸發(fā)機制。但這類觸發(fā)機制過于簡化,也就是每個消息都觸發(fā)一個新的線程的應(yīng)用。MQSeries的觸發(fā)機制更豐富,不但包括這種被稱作Every的方式,還包括First和Depth等方式。另外MQSeries還可以觸發(fā)各種執(zhí)行程序或者MQSeries的通道。
- MQSeries擁有一套完備的日志系統(tǒng),可以進行獨立的系統(tǒng)備份和恢復(fù),因此適于高規(guī)格的數(shù)據(jù)/消息傳輸?shù)膽?yīng)用。WebLogic JMS沒有這方面的支持。
2. 產(chǎn)品歷史的不同造成的差異
MQSeries是個歷史悠久的產(chǎn)品,而WebLogic JMS是個新兵,因此會有以下的差異:
2.1 MQSeries支持更多的系統(tǒng)平臺
支持30多種系統(tǒng)平臺。當然值得注意的是某些平臺的MQSeries是由合作伙伴實現(xiàn)的。
WebLogic JMS是個新產(chǎn)品,支持的平臺數(shù)與WebLogic Server一樣,只有常用的幾個。有人說所有支持JDK的平臺都能跑WebLogic JMS的客戶機,這是不正確的說法。因為JMS是J2EE規(guī)范的一種,J2SE的SDK并不包括JMS的支持,更不要說支持WebLogic的J2EE了。
2.2 MQSeries支持更多的
通信協(xié)議
MQSeries支持很多通信協(xié)議,但目前在實踐中常用的是TCP/IP協(xié)議和SNA協(xié)議。
WebLogic JMS僅支持TCP/IP協(xié)議。
有些人對MQSeries的單向通道的概念提出了異議,認為增加了配置的復(fù)雜性,僅僅是SNA協(xié)議的需要,而不是TCP/IP協(xié)議的需要。我個人認為這點也不無一些道理。但是在有防火墻的TCP/IP網(wǎng)絡(luò)上,不同的方向還是有差異的。
3. 群集實現(xiàn)的差異
MQSeries與WebLogic JMS在支持群集時,差異比較大,應(yīng)該說各有各的特點。
- MQSeries的群集建立在配置庫和群集通道基礎(chǔ)之上,可以定義“共享隊列”;WebLogic JMS的群集建立在WebLogic群集基礎(chǔ)之上,可以定義“分布式隊列”。
- MQSeries在寫共享隊列時,如果發(fā)現(xiàn)本地有,就只寫本地的隊列(這稱作本地優(yōu)先);如果本地沒有,就會輪流寫到所有定義了此共享隊列的隊列管理器。MQSeries在讀共享隊列時,只能從本地取。WebLogic JMS在讀寫分布式隊列時,不受本地影響,總是進行輪流或權(quán)重選擇。聽起來似乎WebLogic JMS的群集更靈活,其實也不盡然。當取得了JMS的對象QueueSender或QueueReceiver后,WebLogic實際上已經(jīng)綁定了一個JMS服務(wù)器的實例。如果每次寫或讀一個消息,都重新生成QueueSender或QueueReceiver,雖然比較好地支持了負載均衡,但勢必造成很大的性能損失。而MQSeries在輪流寫共享隊列時,沒有這方面的問題。
- WebLogic JMS的分布式隊列有一個叫做Forward Delay的有意思的屬性,定義了一個時間的長度。系統(tǒng)一旦發(fā)現(xiàn)超過這個時間長度,還沒有人讀這個隊列,就把它的消息轉(zhuǎn)送給群集中有消費者的隊列。有了這個屬性,應(yīng)用程序就可以只從一個JMS服務(wù)器的實例讀消息了。
項目中需要使用IloSolver,但沒人懂,網(wǎng)上資料太少了,不知道誰有這方面的資料給發(fā)一份,謝謝了! rcashellster@gmail.com
有兩類線程:用戶線程和守護線程。用戶線程是那些完成有用工作的線程。 守護線程是那些僅提供輔助功能的線程。Thread 類提供了 setDaemon() 函數(shù)。Java 程序?qū)⑦\行到所有用戶線程終止,然后它將破壞所有的守護線程。在 Java 虛擬機 (JVM) 中,即使在 main 結(jié)束以后,如果另一個用戶線程仍在運行,則程序仍然可以繼續(xù)運行。
摘要: 做任何事情都要仔細,出現(xiàn)錯誤要從最基本的地方著手,不能完全相信主觀的判斷,實際結(jié)果才是最有說服力的。往往問題都是由于很小的原因引起,卻高估它,好點的只是耽誤點時間,壞的就可能產(chǎn)生預(yù)想不到的后果。。。 閱讀全文
摘要: 這里列出了大多數(shù)的船公司
ABC ABC貨柜航運公司 A.B.C CONTAINTER LINE
ACBL 美國商業(yè)駁船航運公司 American Commercial Barge Line company
ACGR 冠航集團 Ace Group
ACL 大西洋集裝箱航運公司 Atlantic Contaier Line
ACT 聯(lián)合集裝箱運輸公司(英) Associated Container Transportation
。。。。。。。 閱讀全文
摘要: 主要船公司名稱及網(wǎng)址
澳大利亞國家航運有限公司-ANL(澳大利亞)
ANL CONTAINER LINE PTY Ltd
http://www.anl.com.au/index.php3 閱讀全文
摘要: 備案,以便查看
隨著計算機網(wǎng)絡(luò)和分布式應(yīng)用的不斷發(fā)展,遠程消息傳遞越來越成為應(yīng)用系統(tǒng)中不可缺少的組成部分。商業(yè)消息中間件的出現(xiàn)保證了消息傳輸?shù)目煽啃裕咝屎桶踩裕瑫r也減少了系統(tǒng)的開發(fā)周期。目前應(yīng)用最多的消息中間件產(chǎn)品為IBM MQSeries。本文就針對MQ的基本操作與配置進行詳細的闡述,希望對讀者有所幫助。 閱讀全文
摘要: 備案,以便隨時查看
關(guān)系數(shù)據(jù)庫設(shè)計之時是要遵守一定的規(guī)則的。尤其是數(shù)據(jù)庫設(shè)計范式 現(xiàn)簡單介紹1NF(第一范式),2NF(第二范式),3NF(第三范式)和BCNF,另有第四范式和第五范式留到以后再介紹。 在你設(shè)計數(shù)據(jù)庫之時,若能符合這幾個范式,你就是數(shù)據(jù)庫設(shè)計的高手。 閱讀全文
對于大型的WEB APP多數(shù)需要在集群環(huán)境下運行,那么在開發(fā)WEB APP時就需要注意幾點,以便可以支持FAILOVER.
1. SESSION中的數(shù)據(jù)做了修改后一定要手動的SET到SESSION 中 ??? 如果當前的MANAGED SERVER DOWN掉,ADMIN SERVER會自動failover到其他的MANAGED SERVER,?并復(fù)制SESSION數(shù)據(jù).當你對SESSION中的數(shù)據(jù)做了修改后,必須SET回SESSION,否則修改后的數(shù)據(jù)不會被復(fù)制到另一個SERVER,數(shù)據(jù)丟失.
2. SESSION中的數(shù)據(jù)必須是可序列化的. ??? 很容易理解, 只有可以被序列化的數(shù)據(jù)才能被復(fù)制
3. 靜態(tài)數(shù)據(jù)必須是只讀的 ????同上, 當FAILOVER時,靜態(tài)數(shù)據(jù)是不會被復(fù)制的,如果靜態(tài)數(shù)據(jù)被修改了,白改! ????例如經(jīng)常會用靜態(tài)屬性去做記數(shù)器,這樣就需要考慮用其他方法了
其實就算WEB APP目前沒有準備使用集群,也應(yīng)該注意這幾點,以便以后可以方便的移植到集群.
歡迎大家指正和補充!
多數(shù)項目是由用戶提出需求,我們的項目用戶要求我們來推薦需求,然后由他們來審核. 今天帶著1個多月整理的需求文檔跟用戶一起討論,說是討論,大部分是由我們講解給用戶聽,只要有拿不定主意的地方就是一句話"改成可配置". 可配置不但可以提高系統(tǒng)的靈活性,也可以解決一些摸棱兩可的需求.以后系統(tǒng)只要遇到系統(tǒng)可以配置的地方,不用考慮,作成可配置,一準沒錯!
一個項目中的URL中有HTML特殊符號,被SiteMinder阻止了,想了許多方法去改這個URL,沒成功. 后來才想到修改SiteMinder的配置,反正是內(nèi)部有限的幾個人使用,沒有必要留著跨站腳本的檢驗,于是問題得到解決.
下面是SiteMInder文檔中的一段:
Disabling Cross-Site Scrpting Checks
In most cases, the Web Agent should block against cross-site scripting, However, if you have URLs that include HTML characters or your site already has an application that checks for croos-site scripting, you may want to disable this feature.
To disable the cross-site cripting:
Add the following parameter to the WebAgent.conf file:
csschecking = "No"
The default is YES.
For detailed information about cross-site scripting, refer to the following site:
http://www.cert.org/ and read CERT advisory CA-2000-02.
摘要: 從網(wǎng)上搜的帖子,忘記是哪里的,保存在這里以便隨時查看.
在使用delete語句刪除數(shù)據(jù)時,數(shù)據(jù)庫是要做日志記錄的,以便將來可以恢復(fù)數(shù)據(jù),可是我在刪除上百萬條數(shù)據(jù)時,十分緩慢甚至死機,請問有沒有什么好方法?
閱讀全文
|