关于openmqjava的信息

本篇文章给大家谈谈openmqjava，以及对应的知识点，希望对各位有所帮助，不要忘了收藏本站喔。

本文目录一览：

• 1、mq java client 方式和mq java binding方式的区别
• 2、java 怎么样调用IBM MQ 或者通信问题
• 3、谁来讲一下OpenMQ啊，咋个弄这个东西啊，一点都搞不懂，回答得好有加分奖励哦。

mq java client 方式和mq java binding方式的区别

MQ Java Binding方式使用JNI(Java Native Interface)类似于MQ 服务器应用程序。

MQSeries Java客户机服务器连接最快的方式是MQ Java Binding方式，这种方式要求MQ Java应用和MQ Server在同一台机器上。使用MQ Java Binding方式避免了建立网络连接的开销，因此，当连接对性能影响很大时，应当选用MQ Java Binding方式。

MQ Java Client方式通过Server端定义的服务器连接通道连接，服务器方需要启动侦听程序。MQ Java Client方式用于Java客户程序和服务器不在同一台机器时进行连接。

客户端连接，建立MQEnvironment类

MQEnvironment.hostname

以下是，客户端连接例子

// ===========================================================================

//

// Licensed Materials - Property of IBM

//

// 5639-C34

//

// (c) Copyright IBM Corp. 1995,1999

//

// ===========================================================================

// WebSphere MQ M'z Java f sample applet

//

// This sample runs as an applet using the appletviewer and HTML file,

// using the command :-

// appletviewer MQSample.html

// Output is to the command line, NOT the applet viewer window.

//

// Note. If you receive WebSphere MQ error 2 reason 2059 and you are sure your

// WebSphere MQ and TCP/IP setup is correct,

// you should click on the "Applet" selection in the Applet viewer window

// select properties, and change "Network access" to unrestricted.

import com.ibm.mq.*; // Include the WebSphere MQ classes for Java package

public class MQSample extends java.applet.Applet

{

private String hostname = "your_hostname"; // define the name of your

// host to connect to

private String channel = "server_channel"; // define name of channel

// for client to use

// Note. assumes WebSphere MQ Server

// is listening on the default

// TCP/IP port of 1414

private String qManager = "your_Q_manager"; // define name of queue

// manager object to

// connect to.

private MQQueueManager qMgr; // define a queue manager object

// When the class is called, this initialization is done first.

public void init()

{

// Set up WebSphere MQ environment

MQEnvironment.hostname = hostname; // Could have put the

// hostname channel

MQEnvironment.channel = channel; // string directly here!

MQEnvironment.properties.put(MQC.TRANSPORT_PROPERTY,//Set TCP/IP or server

MQC.TRANSPORT_MQSERIES);//Connection

} // end of init

public void start()

{

try {

// Create a connection to the queue manager

qMgr = new MQQueueManager(qManager);

// Set up the options on the queue we wish to open...

// Note. All WebSphere MQ Options are prefixed with MQC in Java.

int openOptions = MQC.MQOO_INPUT_AS_Q_DEF |

MQC.MQOO_OUTPUT ;

// Now specify the queue that we wish to open, and the open options...

MQQueue system_default_local_queue =

qMgr.accessQueue("SYSTEM.DEFAULT.LOCAL.QUEUE",

openOptions);

// Define a simple WebSphere MQ message, and write some text in UTF format..

MQMessage hello_world = new MQMessage();

hello_world.writeUTF("Hello World!");

// specify the message options...

MQPutMessageOptions pmo = new MQPutMessageOptions(); // accept the defaults,

// same as

// MQPMO_DEFAULT

// constant

// put the message on the queue

system_default_local_queue.put(hello_world,pmo);

// get the message back again...

// First define WebSphere MQ message buffer to receive the message into..

MQMessage retrievedMessage = new MQMessage();

retrievedMessage.messageId = hello_world.messageId;

// Set the get message options..

MQGetMessageOptions gmo = new MQGetMessageOptions(); // accept the defaults

// same as

// MQGMO_DEFAULT

// get the message off the queue..

system_default_local_queue.get(retrievedMessage, gmo);

// And prove we have the message by displaying the UTF message text

String msgText = retrievedMessage.readUTF();

System.out.println("The message is: " + msgText);

// Close the queue

system_default_local_queue.close();

// Disconnect from the queue manager

qMgr.disconnect();

}

// If an error has occurred in the above, try to identify what went wrong.

// Was it WebSphere MQ error?

1. WebSphere MQ classes for Java } applet (2/3)

}zk

62 WebSphere MQ 9C Java

}CLrzk

TBzkN];vr%DCLr,|9Cs(==:

1. ,S=SP\mw

2. +{"Ek SYSTEM.DEFAULT.LOCAL.QUEUE

3. YN!5XD{"

catch (MQException ex)

{

System.out.println("WebSphere MQ error occurred : Completion code " +

ex.completionCode +

" Reason code " + ex.reasonCode);

}

// Was it a Java buffer space error?

catch (java.io.IOException ex)

{

System.out.println("An error occurred whilst writing to the

message buffer: " + ex);

}

} // end of start

} // end of sample

java 怎么样调用IBM MQ 或者通信问题

websphere mq : 用于传输信息 具有跨平台的功能。

1 安装websphere mq 并启动

2 websphere mq 建立 queue Manager (如：MQSI_SAMPLE_QM)

3 建立queue 类型选择 Local类型 的 （如lq ）

3 建立channels 类型选择Server Connection （如BridgeChannel）

java 代码如下：

package test.mq;

import com.ibm.mq.*;

/*

* 成功的访问mq 的java 类

*/

public class FirstMqTest {

// public static void main(String[] args[]){

// FirstMqTest first = new FirstMqTest();

// first.test();

// }

public static void main(String args[]){

FirstMqTest first = new FirstMqTest();

first.test();

}

public void test(){

String qManager = "MQSI_SAMPLE_QM"; //QueueManager name

String qName = "lq";//Queue Name

try {

//configure connection parameters

MQEnvironment.hostname="172.16.17.123";//MQ Server name or IP

//MQEnvironment.port=1414;//listenr port

MQEnvironment.channel="BridgeChannel";//Server-Connection Channel

MQEnvironment.CCSID =1381;

// Create a connection to the QueueManager

System.out.println("Connecting to queue manager: "+qManager);

MQQueueManager qMgr = new MQQueueManager(qManager);

// Set up the options on the queue we wish to open

int openOptions = MQC.MQOO_INPUT_AS_Q_DEF | MQC.MQOO_OUTPUT;

// Now specify the queue that we wish to open and the open options

System.out.println("Accessing queue: "+qName);

MQQueue queue = qMgr.accessQueue(qName, openOptions);

// Define a simple WebSphere MQ Message ...

MQMessage msg = new MQMessage();

// ... and write some text in UTF8 format

msg.writeUTF("Hello, World!");

// Specify the default put message options

MQPutMessageOptions pmo = new MQPutMessageOptions();

// Put the message to the queue

System.out.println("Sending a message...");

/*

* 在此测试一下 mq 的传输次列

*

*/

for(int j=0;j 5;j++){

String str ="test11111111111";

str = str+j;

msg.writeUTF(str);

queue.put(msg, pmo);

}

queue.put(msg, pmo);

// Now get the message back again. First define a WebSphere MQ message

// to receive the data

MQMessage rcvMessage = new MQMessage();

// Specify default get message options

MQGetMessageOptions gmo = new MQGetMessageOptions();

// Get the message off the queue.

System.out.println("...and getting the message back again");

queue.get(rcvMessage, gmo);

// And display the message text...

String msgText = rcvMessage.readUTF();

System.out.println("The message is: " + msgText);

// Close the queue

System.out.println("Closing the queue");

queue.close();

// Disconnect from the QueueManager

System.out.println("Disconnecting from the Queue Manager");

qMgr.disconnect();

System.out.println("Done!");

}

catch (MQException ex) {

System.out.println("A WebSphere MQ Error occured : Completion Code "

+ ex.completionCode + " Reason Code " + ex.reasonCode);

}

catch (java.io.IOException ex) {

System.out.println("An IOException occured whilst writing to the message buffer: "

+ ex);

}

}

}

谁来讲一下OpenMQ啊，咋个弄这个东西啊，一点都搞不懂，回答得好有加分奖励哦。

这个东西啊，涉及到公司机密的内容我就不给你发了，不过给你看发几个例子，认真看一下会对你的学习很有帮助，我就是这么过来的~

关于openmqjava和的介绍到此就结束了，不知道你从中找到你需要的信息了吗 ？如果你还想了解更多这方面的信息，记得收藏关注本站。