H5W3
当前位置:H5W3 > 其他技术问题 > 正文

java 中使用websphere MQ

    java 中使用websphere    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);                }    }}

本文地址:H5W3 » java 中使用websphere MQ

评论 0

  • 昵称 (必填)
  • 邮箱 (必填)
  • 网址