Linux 上的 WebSphere MQ 开发快速入门

IBMJava2-SDK-1.4.2-0.0.i386.rpm
MQSeriesClient-6.0.0-0.i386.rpm
MQSeriesConfig-6.0.0-0.i386.rpm
MQSeriesFTA-6.0.0-0.i386.rpm
MQSeriesIES30-6.0.0-0.i386.rpm
MQSeriesJava-6.0.0-0.i386.rpm
MQSeriesKeyMan-6.0.0-0.i386.rpm
MQSeriesMan-6.0.0-0.i386.rpm
MQSeriesMsg_Zh_CN-6.0.0-0.i386.rpm
MQSeriesMsg_Zh_TW-6.0.0-0.i386.rpm
MQSeriesMsg_de-6.0.0-0.i386.rpm
MQSeriesMsg_es-6.0.0-0.i386.rpm
MQSeriesMsg_fr-6.0.0-0.i386.rpm
MQSeriesMsg_it-6.0.0-0.i386.rpm
MQSeriesMsg_ja-6.0.0-0.i386.rpm
MQSeriesMsg_ko-6.0.0-0.i386.rpm
MQSeriesMsg_pt-6.0.0-0.i386.rpm
MQSeriesRuntime-6.0.0-0.i386.rpm
MQSeriesSDK-6.0.0-0.i386.rpm
MQSeriesSamples-6.0.0-0.i386.rpm
MQSeriesServer-6.0.0-0.i386.rpm
MQSeriesTXClient-6.0.0-0.i386.rpm
PreReqs
READMEs
copyright
gsk7bas-7.0-3.15.i386.rpm
lap
licenses

mqm@wmq1:~/ # crtmqm WMQ1QM

mqm@wmq1:~/ # strmqm WMQ1QM

DEFINE QLOCAL ('WMQ1InputQ') +
		 REPLACE

DEFINE QLOCAL ('WMQ2QMXmitQ') +
		 DESCR('Transmission Queue to WMQ2QM') +
		 USAGE(XMITQ) +
		 TRIGGER +
		 TRIGTYPE(FIRST) +
		 TRIGDPTH(1) +
		 TRIGDATA('WMQ1QM.WMQ2QM') +
		 INITQ('SYSTEM.CHANNEL.INITQ') +
		 REPLACE

DEFINE QREMOTE ('WMQ1OutputQ') +
		 XMITQ('WMQ2QMXmitQ') +
		 RNAME('WMQ2InputQ') +
		 RQMNAME('WMQ2QM') +
		 REPLACE

DEFINE CHANNEL ('WMQ1QM.WMQ2QM') CHLTYPE(SDR) +
		 TRPTYPE(TCP) +
		 CONNAME('192.168.28.72(1414)') +
		 XMITQ('WMQ2QMXmitQ') +
		 REPLACE

DEFINE CHANNEL ('WMQ2QM.WMQ1QM') CHLTYPE(RCVR) +
		 TRPTYPE(TCP) +
		 REPLACE

DEFINE CHANNEL ('SYSTEM.ADMIN.SVRCONN') CHLTYPE(SVRCONN) +
		 TRPTYPE(TCP) +
		 DESCR(' ') +
		 HBINT(300) +
		 MAXMSGL(4194304) +
		 MCAUSER('MUSR_MQADMIN') +
		 RCVDATA(' ') +
		 RCVEXIT(' ') +
		 SCYDATA(' ') +
		 SCYEXIT(' ') +
		 SENDDATA(' ') +
		 SENDEXIT(' ') +
		 REPLACE

mqm@wmq1:~/ # runmqsc WMQ1QM < WMQ1QM.conf > qcreate.log

mqm@wmq1:~/ # strmqcsv WMQ1QM &
mqm@wmq1:~/ # runmqlsr -m WMQ1QM -t TCP &

mqm@wmq1:~/ # runmqchl -m WMQ1QM -c WMQ1QM.WMQ2QM &
mqm@wmq1:~/ # runmqchl -m WMQ1QM -c WMQ2QM.WMQ1QM &

queue.manager=WMQ1QM
queue.manager.host=192.168.28.71
queue.name=WMQ1OutputQ

package mqconn;

import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.util.Properties;

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 MQConnector
{
  protected String qManager = ""; // define name of queue manager

  protected String qManagerHost = "";

  protected String queuName = ""; // define name of queue

  protected MQQueue mqQueue;

  protected MQQueueManager qMgr;

  public static boolean DEBUG = true;

  public MQConnector()
  {

  }

  public void initMq()
  {
    try
    {
      FileInputStream fis = new FileInputStream(new File("mqconnect.properties"));
      Properties props = new Properties();
      props.load(fis);
      fis.close();
      qManager = props.getProperty("queue.manager");
      qManagerHost = props.getProperty("queue.manager.host");
      queuName = props.getProperty("queue.name");

	  // Create a connection to the queue manager
      MQEnvironment.channel = "SYSTEM.DEF.SVRCONN";
      MQEnvironment.hostname = qManagerHost;
      debug("Connecting to QueueManager " + qManager + " on " + qManagerHost);
      qMgr = new MQQueueManager(qManager);
    }
    catch (Exception e)
    {
      e.printStackTrace();
    }
  }

  public void openQueue() throws MQException
  {
    // 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...    
    debug("Opening queue: " + queuName);
    try
    {
      mqQueue = qMgr.accessQueue(queuName, openOptions);
    }
    catch(MQException mqe)
    {
      //check if MQ reason code 2045
      //means that opened queu is remote and it can not be opened as 
      //input queue
      //try to open as output only
      if(mqe.reasonCode==2045)
      {
        openOptions = MQC.MQOO_OUTPUT;
        mqQueue = qMgr.accessQueue(queuName, openOptions);
      }
    }
  }
    
  public void putMessageToQueue(String msg) throws MQException
  {
    try
    {
      debug("Sending message: " + msg);

      MQPutMessageOptions pmo = new MQPutMessageOptions(); 
      MQMessage mqMsg = new MQMessage();
      mqMsg.write(msg.getBytes());

      // put the message on the queue
      mqQueue.put(mqMsg, pmo);
    }
    catch (IOException e)
    {
      e.printStackTrace();
    }
  }

  public String getMessageFromQueue() throws MQException 
  {
    try
    {
      MQMessage mqMsg = new MQMessage();
      
      MQGetMessageOptions gmo = new MQGetMessageOptions();

      // Get a message from the queue
      mqQueue.get(mqMsg,gmo);  
       
      //Extract the message data
      int len=mqMsg.getDataLength();
      byte[] message = new byte[len];
      mqMsg.readFully(message,0,len);
      return new String(message);
    }
    catch(MQException mqe)
    {
      int reason=mqe.reasonCode;
      
      if(reason==2033)//no messages
      {
        return null;
      }
      else
      {
        throw mqe;
      }
    }    
    catch (IOException e)
    {
      e.printStackTrace();
      return null;
    }
  }
  
  
  public void closeQueue() throws MQException
  {
    debug("Closing queue and disconnecting QueueManager...");

    // Close the queue...
    mqQueue.close();
    // Disconnect from the queue manager
    qMgr.disconnect();

  }

  protected boolean hasArg(String arg, String[] args)
  {
    for(int i=0;i<args.length;i++)
    {
      if(args[i].equals(arg))
      {
        return true;
      }
    }
    return false;
  }
  
  public void debug(Object msg)
  {
    if (DEBUG)
    {
      System.out.println(msg);
    }
  }
    
}

package mqconn;

import java.io.BufferedReader;
import java.io.FileReader;

import com.ibm.mq.MQException;

public class MQSend extends MQConnector
{

  public MQSend()
  {

  }

  public void send(String[] args) throws MQException
  {
    boolean argsAreFiles = hasArg("-f", args);
    initMq();
    openQueue();
    for (int i = 0; i < args.length; i++)
    {
      if (args[i].equals("-f"))
        continue;

      if (!argsAreFiles)
      {
        putMessageToQueue(args[i]);
      }
      else
      {
        try
        {
          // send file contents as message
          BufferedReader br = new BufferedReader(new FileReader(args[i]));

          StringBuffer msg = new StringBuffer();
          for (String line = br.readLine(); line != null; line = br.readLine())
          {
            msg.append(line);
            msg.append('\n');
          }

          br.close();
          putMessageToQueue(msg.toString());
        }
        catch (Exception e)
        {
          System.out.println("Error while processing file " + args[i] + ": "
              + e.toString());
        }
      }
      System.out.println("Message sent.");
    }

    closeQueue();
    disconnectMq();
  }

  public static void main(String[] args)
  {
    MQSend mqsend = new MQSend();
    MQConnector.DEBUG = false;
    try
    {
      if (args == null || args.length == 0)
      {
        System.out.println("Usage: " + mqsend.getClass().getName()
            + " [-f] <file name | message> [<file name | message> ...]");
        System.exit(0);
      }
      mqsend.send(args);
    }
    catch (Exception e)
    {
      System.out.println(e.toString());
      System.out.println("Usage: " + mqsend.getClass().getName()
          + " [-f] <file name | message> [<file name | message> ...]");
    }

  }

}

package mqconn;

import com.ibm.mq.MQException;

public class MQGet extends MQConnector
{
  public MQGet()
  {
    
  }
  
  public String getMessages(String[] args) throws MQException
  {
   String message=getMessageFromQueue();
   return message;
    
  }
  
  public static void main(String[] args)
  {
    MQGet mqget = new MQGet();
    MQConnector.DEBUG=false;
    try
    {
      mqget.initMq();
      mqget.openQueue();

      String msg=mqget.getMessages(args);
      if(msg!=null)
      {
        System.out.println(msg);      
      }
      
      mqget.closeQueue();
      mqget.disconnectMq();      
    }
    catch (Exception e)
    {
      e.printStackTrace();
      System.out.println("Usage: "+mqget.getClass().getName()+" ");
    }
  }
}

queue.manager=WMQ1QM
queue.manager.host=127.0.0.1
queue.name=WMQ1OutputQ

queue.manager=WMQ2QM
queue.manager.host=127.0.0.1
queue.name=WMQ2InputQ

/opt/IBMJava2-142/bin/java -cp .:com.ibm.mq.jar mqconn.MQSend "$@"

/opt/IBMJava2-142/bin/java -cp .:com.ibm.mq.jar mqconn.MQGet "$@"

mqm@wmq1:~/bin> ./mqsend "This is test message"
MQJE001: Completion Code 2, Reason 2045
Message sent.

mqm@wmq2:~/bin> ./mqget
This is test message

mqm@wmq1:~/bin> ./mqsend "This is test message" This is another message
MQJE001: Completion Code 2, Reason 2045
Message sent.
Message sent.
Message sent.
Message sent.
Message sent.

mqm@wmq2:~/bin> ./mqget
This is test message
mqm@wmq2:~/bin> ./mqget
This
mqm@wmq2:~/bin> ./mqget
is
mqm@wmq2:~/bin> ./mqget
another
mqm@wmq2:~/bin> ./mqget
message
mqm@wmq2:~/bin> ./mqget
MQJE001: Completion Code 2, Reason 2033

mqm@wmq1:~/bin> ls -1 mqconn/*.java | awk '{print "mqsend -f "$1""}' | sh 2> /dev/null
Message sent.
Message sent.
Message sent.

mqm@wmq2:~/bin> ./mqget > msg1.txt