连接MQ

该例子主要针对给MQ发消息和接收消息数据

package my.test;

import com.ibm.mq.MQC;
import com.ibm.mq.MQEnvironment;
import com.ibm.mq.MQException;
import com.ibm.mq.MQMessage;
import com.ibm.mq.MQPutMessageOptions;
import com.ibm.mq.MQQueue;
import com.ibm.mq.MQQueueManager;

public class Test {
	private void setCosysMessage(String sendMessage) {
		try {
			
			// 建立MQ客户端调用上下文环境
			MQEnvironment.hostname = "10.12.18.146"; // 服务器ip地址
			MQEnvironment.port = 1414; // 服务器MQ服务端口
			MQEnvironment.CCSID = 1208; // 服务器MQ服务使用的编码
			MQEnvironment.channel ="SERVERCONN"; // 服务器连接通道名
			MQQueueManager queueManager = null;
			MQQueue queue = null;
			queueManager = new MQQueueManager("QM1"); // 队列管理器名称
			queue = queueManager.accessQueue("cosys_counter", MQC.MQOO_OUTPUT); // 队列名称
			MQPutMessageOptions pmo = new MQPutMessageOptions(); // 消息属性
			pmo.options = MQC.MQPMO_LOGICAL_ORDER;
			MQMessage message = new MQMessage();
			message.format = "MQSTR"; // 字符串
			message.writeString(sendMessage);
			System.out.println("message==" + message.encoding + "  " + message.characterSet);
			queue.put(message, pmo);
			// 关闭队列
			queue.close();
			// 关闭队列管理器
			queueManager.disconnect();
		} catch (MQException xp) {
			
		} catch (Exception e) {
			
		}
	}
	//发送消息
	public static void send() {
		try {

			//   建立MQ客户端调用上下文环境
			MQEnvironment.hostname = "10.12.18.146"; //   服务器ip地址   
			MQEnvironment.port = 1414; //   服务器MQ服务端口   
			MQEnvironment.CCSID = 1208; //   服务器MQ服务使用的编码   
			MQEnvironment.channel = "SERVERCONN"; //   服务器连接通道名      
			MQQueueManager queueManager = null;
			MQQueue queue = null;
			queueManager = new MQQueueManager("QM1"); //队列管理器名称
			queue = queueManager.accessQueue("cosys_counter", MQC.MQOO_OUTPUT); //队列名称
			MQPutMessageOptions pmo = new MQPutMessageOptions(); //消息属性
			pmo.options = MQC.MQPMO_LOGICAL_ORDER;
			MQMessage message = new MQMessage();
			//message.format = "MQSTR"; //字符串
			//message.writeUTF("");
			message.writeString("");
			//message.writeBytes("");
			System.out.println("message==" + message.encoding + "  "
					+ message.characterSet);
			queue.put(message, pmo);
			//   关闭队列   
			queue.close();
			//   关闭队列管理器   
			queueManager.disconnect();
		} catch (MQException e) {
			e.printStackTrace();
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
	
	public static void main(String arge[]) {
		Test aa = new Test();
		
		aa.send();
	}
}