JAVA MQ API方式通訊採用Binding MQ Server方式
package
com.mqapi;
/**
* @modified by actorai E-mail:actorai@163.com
* @version 建立時間：2010-9-15
* 經過MQ API方式鏈接MQ;綁定服務器方式
* WebSphere MQ classes for Java的綁定模式與客戶鏈接模式存在下列區別：
* 1 忽略了MQEnvironmnet類所提供的大多數參數。
* 2 綁定模式支持MQBEGIN和快速綁定。
* 類說明
*/
import
java.io.IOException;
import
com.ibm.mq.MQC;
import
com.ibm.mq.MQEnvironment;
import
com.ibm.mq.MQException;
import
com.ibm.mq.MQGetMessageOptions;
import
com.ibm.mq.MQMessage;
import
com.ibm.mq.MQPutMessageOptions;
import
com.ibm.mq.MQQueue;
import
com.ibm.mq.MQQueueManager;
public
class
MessageByMQ_Bind{
//定義隊列管理器和隊列的名稱
private
static
String qmName;
private
static
String qName;
private
static
MQQueueManager qMgr;
static
{
//綁定模式只適用於那些運行在做爲隊列管理器主機的WebSphere MQ 服務器上的程序
//不須要設置一下環境變量
//設置環境:
//MQEnvironment中包含控制MQQueueManager對象中的環境的構成的靜態變量，MQEnvironment的值的設定會在MQQueueManager的構造函數加載的時候起做用，
//所以必須在創建MQQueueManager對象以前設定MQEnvironment中的值.
//MQEnvironment.hostname="10.0.4.213"; //MQ服務器的IP地址
//MQEnvironment.channel="CLIENT.QM_APPLE"; //服務器鏈接的通道
//MQEnvironment.CCSID=1381; //服務器MQ服務使用的編碼1381表明GBK、1208表明UTF(Coded Character Set Identifier:CCSID)
//MQEnvironment.port=1415; //MQ端口
qmName =
"QM_APPLE"
;
//MQ的隊列管理器名稱
qName =
"01"
;
//MQ遠程隊列的名稱
try
{
//定義並初始化隊列管理器對象並鏈接
//MQQueueManager能夠被多線程共享，可是從MQ獲取信息的時候是同步的，任什麼時候候只有一個線程能夠和MQ通訊。
qMgr =
new
MQQueueManager(qmName);
}
catch
(MQException e) {
// TODO Auto-generated catch block
System.out.println(
"初使化MQ出錯"
);
e.printStackTrace();
}
}
/**
* 往MQ發送消息
* @param message
* @return
*/
public
static
int
sendMessage(String message){
int
result=
0
;
try
{
//設置將要鏈接的隊列屬性
// Note. The MQC interface defines all the constants used by the WebSphere MQ Java programming interface
//(except for completion code constants and error code constants).
//MQOO_INPUT_AS_Q_DEF:Open the queue to get messages using the queue-defined default.
//MQOO_OUTPUT:Open the queue to put messages.
/*目標爲遠程隊列，全部這裏不能夠用MQOO_INPUT_AS_Q_DEF屬性*/
//int openOptions = MQC.MQOO_INPUT_AS_Q_DEF | MQC.MQOO_OUTPUT;
/*如下選項可適合遠程隊列與本地隊列*/
int
openOptions = MQC.MQOO_OUTPUT | MQC.MQOO_FAIL_IF_QUIESCING;
//鏈接隊列
//MQQueue provides inquire, set, put and get operations for WebSphere MQ queues.
//The inquire and set capabilities are inherited from MQManagedObject.
/*關閉了就從新打開*/
if
(qMgr==
null
|| !qMgr.isConnected()){
qMgr =
new
MQQueueManager(qmName);
}
MQQueue queue = qMgr.accessQueue(qName, openOptions);
//定義一個簡單的消息
MQMessage putMessage =
new
MQMessage();
//將數據放入消息緩衝區
putMessage.writeUTF(message);
//設置寫入消息的屬性（默認屬性）
MQPutMessageOptions pmo =
new
MQPutMessageOptions();
//將消息寫入隊列
queue.put(putMessage,pmo);
queue.close();
}
catch
(MQException ex) {
System.out.println(
"A WebSphere MQ error occurred : Completion code "
+ ex.completionCode +
" Reason code "
+ ex.reasonCode);
ex.printStackTrace();
}
catch
(IOException ex) {
System.out.println(
"An error occurred whilst writing to the message buffer: "
+ ex);
}
catch
(Exception ex){
ex.printStackTrace();
}
finally
{
try
{
qMgr.disconnect();
}
catch
(MQException e) {
e.printStackTrace();
}
}
return
result;
}
/**
* 從隊列中去獲取消息，若是隊列中沒有消息，就會發生異常，不過沒有關係，有TRY...CATCH，若是是第三方程序調用方法，若是無返回則說明無消息
* 第三方能夠將該方法放於一個無限循環的while(true){...}之中，不須要設置等待，由於在該方法內部在沒有消息的時候會自動等待。
* @return
*/
public
static
String getMessage(){
String message=
null
;
try
{
//設置將要鏈接的隊列屬性
// Note. The MQC interface defines all the constants used by the WebSphere MQ Java programming interface
//(except for completion code constants and error code constants).
//MQOO_INPUT_AS_Q_DEF:Open the queue to get messages using the queue-defined default.
//MQOO_OUTPUT:Open the queue to put messages.
int
openOptions = MQC.MQOO_INPUT_AS_Q_DEF | MQC.MQOO_OUTPUT;
MQMessage retrieve =
new
MQMessage();
//設置取出消息的屬性（默認屬性）
//Set the put message options.（設置放置消息選項）
MQGetMessageOptions gmo =
new
MQGetMessageOptions();
gmo.options = gmo.options + MQC.MQGMO_SYNCPOINT;
//Get messages under sync point control（在同步點控制下獲取消息）
gmo.options = gmo.options + MQC.MQGMO_WAIT;
// Wait if no messages on the Queue（若是在隊列上沒有消息則等待）
gmo.options = gmo.options + MQC.MQGMO_FAIL_IF_QUIESCING;
// Fail if Qeue Manager Quiescing（若是隊列管理器停頓則失敗）
gmo.waitInterval =
1000
;
// Sets the time limit for the wait.（設置等待的毫秒時間限制）
/*關閉了就從新打開*/
if
(qMgr==
null
|| !qMgr.isConnected()){
qMgr =
new
MQQueueManager(qmName);
}
MQQueue queue = qMgr.accessQueue(qName, openOptions);
// 從隊列中取出消息
queue.get(retrieve, gmo);
//message = retrieve.readUTF(); //此方法讀經過MQ資源管理器放入的消息會IO讀寫錯誤，經過MQ資源管理器放入的測試消息就不是UTF這樣的格式的，因此會報錯
message = retrieve.readLine();
//此方法讀xml格式，有網友提到可能會報錯
System.out.println(
"The message is: "
+ message);
queue.close();
}
catch
(MQException ex) {
System.out.println(
"A WebSphere MQ error occurred : Completion code "
+ ex.completionCode +
" Reason code "
+ ex.reasonCode);
}
catch
(IOException ex) {
//System.out.println("An error occurred whilst writing to the message buffer: " + ex);
ex.printStackTrace();
}
catch
(Exception ex){
ex.printStackTrace();
}
finally
{
try
{
qMgr.disconnect();
}
catch
(MQException e) {
e.printStackTrace();
}
}
return
message;
}
public
static
void
main(String args[]) {
/*下面兩個方法可同時使用，也能夠單獨使用*/
sendMessage(
"this is a test by MQ API Binding model"
);
//getMessage();
}
}
相關文章
- 1. 服務間通訊方式【MQ在分佈式系統中的使用場景】
- 2. python----MQ--實現通訊
- 3. MQ系列（0）——MQ簡介
- 4. 分佈式 - MQ
- 5. WebSphere MQ----通道
- 6. MQ學習——初識mq
- 7. Windows Phone 7 MVVM模式通訊方式之實現Binding Data
- 8. 通訊方式
- 9. rabbit-mq api
- 10. java mq 使用
- 更多相關文章...
- • Spring聲明式事務管理（基於XML方式實現） - Spring教程
- • Redis哨兵（Sentinel）模式的配置方法及其在Java中的用法 - Redis教程
- • 常用的分佈式事務解決方案
- • 委託模式
相關標籤/搜索
每日一句
-
每一个你不满意的现在，都有一个你没有努力的曾经。
歡迎關注本站公眾號,獲取更多信息
相關文章
- 1. 服務間通訊方式【MQ在分佈式系統中的使用場景】
- 2. python----MQ--實現通訊
- 3. MQ系列（0）——MQ簡介
- 4. 分佈式 - MQ
- 5. WebSphere MQ----通道
- 6. MQ學習——初識mq
- 7. Windows Phone 7 MVVM模式通訊方式之實現Binding Data
- 8. 通訊方式
- 9. rabbit-mq api
- 10. java mq 使用