package cn.edu.itec.mqclient;

?

import java.io.File;

?

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.MQQueueManager;

?

public class MQPut {

?????? private String HOST_URL = "192.168.1.116";

?

?????? private String MQ_CHANNEL = "EXAMPLE.CHANNEL";

?

?????? private String MQ_MANAGER = "QMGR";

?

?????? private String MQ_QUEUE = "EXAMPLE.QUEUE";

?

?????? private int MQ_PORT = 4001;

?

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

????????????? new MQPut().SendFile("f:/JMSExampleEJB.jar");

?????? }

?

?????? public void SendFile(String sFilePath) {

????????????? try {

?

???????????????????? /* 設(shè)置 MQEnvironment 屬性以便客戶機(jī)連接 */

???????????????????? MQEnvironment.hostname = HOST_URL;

???????????????????? MQEnvironment.channel = MQ_CHANNEL;

???????????????????? MQEnvironment.properties.put(MQC.TRANSPORT_PROPERTY,

?????????????????????????????????? MQC.TRANSPORT_MQSERIES);

???????????????????? MQEnvironment.CCSID = 1381;

???????????????????? MQEnvironment.port = MQ_PORT;

?

???????????????????? /* 連接到隊(duì)列管理器 */

???????????????????? MQQueueManager qMgr = new MQQueueManager(MQ_MANAGER);

???????????????????? System.out.println("queue manager is connected!");

?

???????????????????? /* 設(shè)置打開選項(xiàng)以便打開用于輸出的隊(duì)列，如果隊(duì)列管理器正在停止，我們也已設(shè)置了選項(xiàng)去應(yīng)對不成功情況。 */

???????????????????? int openOptions = MQC.MQOO_OUTPUT | MQC.MQOO_FAIL_IF_QUIESCING;

?

???????????????????? /* 打開隊(duì)列 */

???????????????????? com.ibm.mq.MQQueue queue = qMgr.accessQueue(MQ_QUEUE, openOptions);

?

???????????????????? /* 設(shè)置放置消息選項(xiàng)我們將使用默認(rèn)設(shè)置 */

???????????????????? MQPutMessageOptions pmo = new MQPutMessageOptions();

?

???????????????????? /* 創(chuàng)建消息， MQMessage 類包含實(shí)際消息數(shù)據(jù)的數(shù)據(jù)緩沖區(qū)，和描述消息的所有 MQMD 參數(shù) */

?

???????????????????? /* 創(chuàng)建消息緩沖區(qū) */

???????????????????? MQMessage outMsg = new MQMessage();

?

???????????????????? /* set the properties of the message fot the selector */

???????????????????? outMsg.correlationId = "clinet_B_receive".getBytes();

???????????????????? outMsg.messageId = "1Aa".getBytes();

????????????????????

???????????????????? /* write msg */

???????????????????? MsgWriter.readFile(outMsg, new File(sFilePath));

?

???????????????????? /* put message with default options */

???????????????????? queue.put(outMsg, new MQPutMessageOptions());

???????????????????? System.out.println("send file is success!");

???????????????????? /* release resource */

???????????????????? queue.close();

???????????????????? qMgr.disconnect();

?

????????????? } catch (MQException ex) {

???????????????????? //System.out.println("fft!");

???????????????????? System.out.println("An MQ Error Occurred: Completion Code is :\t"

?????????????????????????????????? + ex.completionCode + "\n\n The Reason Code is :\t"

?????????????????????????????????? + ex.reasonCode);

???????????????????? ex.printStackTrace();

????????????? } catch (Exception e) {

???????????????????? e.printStackTrace();

????????????? }

?????? }

?

?????? private void readFileToMessage(String FilePath) {

?

?????? }

}

?

package cn.edu.itec.mqclient;

?

import java.io.FileOutputStream;

import java.io.IOException;

import java.util.Hashtable;

?

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.MQQueueManager;

?

/**

?* @author Administrator

?*

?* TODO To change the template for this generated type comment go to Window -

?* Preferences - Java - Code Style - Code Templates

?*/

public class MQGet {

?????? private static String HOST_URL = "192.168.1.116";

?

?????? private static String MQ_CHANNEL = "EXAMPLE.CHANNEL";

?

?????? private static String MQ_MANAGER = "QMGR";

?

?????? private static String MQ_QUEUE = "EXAMPLE.SENDQUEUE";

?

?????? private static int MQ_PORT = 4001;

?

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

????????????? MQGet.getMessage();

?????? }

?

?????? public static void getMessage() {

????????????? try {

???????????????????? /* 設(shè)置 MQEnvironment 屬性以便客戶機(jī)連接 */

???????????????????? MQEnvironment.hostname = HOST_URL;

???????????????????? MQEnvironment.channel = MQ_CHANNEL;

???????????????????? MQEnvironment.properties.put(MQC.TRANSPORT_PROPERTY,

?????????????????????????????????? MQC.TRANSPORT_MQSERIES);

???????????????????? MQEnvironment.CCSID = 1381;

???????????????????? MQEnvironment.port = MQ_PORT;

?

???????????????????? /* 連接到隊(duì)列管理器 */

???????????????????? MQQueueManager qMgr = new MQQueueManager(MQ_MANAGER);

???????????????????? System.out.println("queue manager is connected!");

?

???????????????????? /*

???????????????????? ?* 設(shè)置打開選項(xiàng)以便打開用于輸出的隊(duì)列，如果隊(duì)列管理器停止，我們也 已設(shè)置了選項(xiàng)去應(yīng)對不成功情況

???????????????????? ?*/

???????????????????? int openOptions = MQC.MQOO_INPUT_SHARED

?????????????????????????????????? | MQC.MQOO_FAIL_IF_QUIESCING;

?

???????????????????? /* 打開隊(duì)列 */

???????????????????? com.ibm.mq.MQQueue queue = qMgr.accessQueue(MQ_QUEUE, openOptions);

???????????????????? System.out.println(" 隊(duì)列連接成功 ");

???????????????????? /* 設(shè)置放置消息選項(xiàng) */

???????????????????? MQGetMessageOptions gmo = new MQGetMessageOptions();

?

???????????????????? /* 在同步點(diǎn)控制下獲取消息 */

???????????????????? gmo.options = gmo.options + MQC.MQGMO_SYNCPOINT;

?

???????????????????? /* 如果在隊(duì)列上沒有消息則等待 */

???????????????????? gmo.options = gmo.options + MQC.MQGMO_WAIT;

?

???????????????????? /* 如果隊(duì)列管理器停頓則失敗 */

???????????????????? gmo.options = gmo.options + MQC.MQGMO_FAIL_IF_QUIESCING;

?

???????????????????? /* 設(shè)置等待的時間限制 */

???????????????????? gmo.waitInterval = MQC.MQWI_UNLIMITED;

???????????????????? /* create the message buffer store */

???????????????????? MQMessage inMessage = new MQMessage();

???????????????????? /* set the selector */

???????????????????? inMessage.correlationId = "clinet_B_receive".getBytes();

???????????????????? /* get the message */

???????????????????? queue.get(inMessage, gmo);

???????????????????? System.out.println("get message success");

????????????????????

???????????????????? /* 讀出消息對象 */

???????????????????? Hashtable messageObject = (Hashtable) inMessage.readObject();

???????????????????? System.out.println(messageObject);

???????????????????? /* 讀出消息內(nèi)容 */

???????????????????? byte[] content = (byte[]) messageObject.get("content");

???????????????????? /* save file */

???????????????????? FileOutputStream output = new FileOutputStream(

?????????????????????????????????? "f:/exampleReceive.jar");

???????????????????? output.write(content);

???????????????????? output.close();

?

???????????????????? System.out.println(messageObject.get("FileName"));

???????????????????? /* 提交事務(wù) , 相當(dāng)于確認(rèn)消息已經(jīng)接收，服務(wù)器會刪除該消息 */

???????????????????? qMgr.commit();

?

????????????? } catch (MQException e) {

???????????????????? e.printStackTrace();

????????????? } catch (IOException e) {

???????????????????? // TODO Auto-generated catch block

???????????????????? e.printStackTrace();

????????????? } catch (ClassNotFoundException e) {

???????????????????? // TODO Auto-generated catch block

???????????????????? e.printStackTrace();

????????????? }

?????? }

}

package ejbs;

?

import javax.jms.ObjectMessage;

import javax.jms.BytesMessage;

import javax.jms.StreamMessage;

import javax.jms.TextMessage;

import javax.jms.JMSException;

import ehub.ihub.exchangeManager.*;

import java.util.Hashtable;

import java.io.ByteArrayInputStream;

import java.io.FileOutputStream;

import java.io.File;

import java.io.ObjectInputStream;

?

/**

?* Bean implementation class for Enterprise Bean: MQMDBBean

?*/

public class MQMDBBeanBean implements javax.ejb.MessageDrivenBean,

????????????? javax.jms.MessageListener {

?????? private javax.ejb.MessageDrivenContext fMessageDrivenCtx;

?

?????? /**

?????? ?* getMessageDrivenContext

?????? ?*/

?????? public javax.ejb.MessageDrivenContext getMessageDrivenContext() {

????????????? return fMessageDrivenCtx;

?????? }

?

?????? /**

?????? ?* setMessageDrivenContext

?????? ?*/

?????? public void setMessageDrivenContext(javax.ejb.MessageDrivenContext ctx) {

????????????? fMessageDrivenCtx = ctx;

?????? }

?

?????? /**

?????? ?* ejbCreate

?????? ?*/

?????? public void ejbCreate() {

?????? }

?

?????? /**

?????? ?* onMessage

?????? ?*/

?????? public void onMessage(javax.jms.Message msg) {

????????????? try {

???????????????????? System.out.println(msg.toString());

???????????????????? if (msg instanceof TextMessage) {

??????????????????????????? System.out.println("TextMessage");

???????????????????? } else if (msg instanceof ObjectMessage) {

??????????????????????????? System.out.println("ObjectMessage");

???????????????????? } else if (msg instanceof StreamMessage) {

??????????????????????????? System.out.println("StreamMessage");

???????????????????? } else if (msg instanceof BytesMessage) {

??????????????????????????? System.out.println("BytesMessage");

??????????????????????????? BytesMessage bytesMessage = (BytesMessage) msg;

??????????????????????????? String sCorrelationID = new String(bytesMessage

????????????????????????????????????????? .getJMSCorrelationIDAsBytes());

??????????????????????????? String sMessageID = bytesMessage.getJMSMessageID();

??????????????????????????? long size = bytesMessage.getBodyLength();

??????????????????????????? System.out.println("size=" + size + "/n CorrelationID="

????????????????????????????????????????? + sCorrelationID + "/n MessageID=" + sMessageID);

??????????????????????????? /*read the message and save the file*/

??????????????????????????? ReadMessage.readMessage(bytesMessage);

??????????????????????????? System.out.println("read message success");

??????????????????????????? /*send the message to the client */

??????????????????????????? SendMessage.sendFileToReceiveQueue(new File("c:/receivedExample.jar"));

??????????????????????????? System.out.println("send file success");

???????????????????????????

???????????????????? } else {

?

??????????????????????????? System.out.println("no message");

???????????????????? }

?

????????????? } catch (Exception e) {

???????????????????? System.out.println("onmessage 執(zhí)行錯誤，回滾！ ");

???????????????????? e.printStackTrace(System.err);

???????????????????? fMessageDrivenCtx.setRollbackOnly();

????????????? }

?????? }

?

?????? private void getProperties(byte[] p) {

?

?????? }

?

?????? /**

?????? ?* ejbRemove

?????? ?*/

?????? public void ejbRemove() {

?????? }

}

/*

?* Created on 2006-2-15

?*

?* TODO To change the template for this generated file go to

?* Window - Preferences - Java - Code Style - Code Templates

?*/

package ehub.ihub.exchangeManager;

?

import java.io.ByteArrayInputStream;

import java.io.FileOutputStream;

import java.io.IOException;

import java.io.ObjectInputStream;

import java.util.Hashtable;

?

import javax.jms.BytesMessage;

import javax.jms.JMSException;

?

/**

?* @author Administrator

?*

?*?

?*/

public class ReadMessage {

?????? /**

?????? ?* read message including property and body

?????? ?*

?????? ?* @param Message

?????? ?* @throws JMSException

?????? ?* @throws IOException

?????? ?* @throws ClassNotFoundException

?????? ?*/

?????? public static void readMessage(BytesMessage Message) {

????????????? try {

???????????????????? long bodySize = Message.getBodyLength();

?

???????????????????? byte[] buf = new byte[Integer.parseInt(String.valueOf(bodySize))];

???????????????????? /* 消息內(nèi)容讀到字節(jié)數(shù)組中 */

???????????????????? Message.readBytes(buf);

???????????????????? ByteArrayInputStream byteArrayInputStream = new ByteArrayInputStream(

?????????????????????????????????? buf);

???????????????????? /* 從字節(jié)流讀出消息對象 */

???????????????????? ObjectInputStream objectInputStream = new ObjectInputStream(

?????????????????????????????????? byteArrayInputStream);

???????????????????? Hashtable messageObject = (Hashtable) objectInputStream

?????????????????????????????????? .readObject();

???????????????????? /* 解析消息 */

???????????????????? byte[] contentBuf = (byte[]) messageObject.get("content");

???????????????????? /* 把文件保存 */

???????????????????? FileOutputStream fileWriter = new FileOutputStream(

?????????????????????????????????? "c:/receivedExample.jar");

???????????????????? fileWriter.write(contentBuf);

???????????????????? fileWriter.close();

????????????? } catch (JMSException e) {

???????????????????? e.printStackTrace();

????????????? } catch (IOException e) {

???????????????????? // TODO Auto-generated catch block

???????????????????? e.printStackTrace();

????????????? } catch (ClassNotFoundException e) {

???????????????????? // TODO Auto-generated catch block

???????????????????? e.printStackTrace();

????????????? }

?????? }

}

/*

?* Created on 2006-2-16

?*

?* TODO To change the template for this generated file go to

?* Window - Preferences - Java - Code Style - Code Templates

?*/

package ehub.ihub.exchangeManager;

?

import java.io.File;

import java.io.FileInputStream;

import java.io.IOException;

import java.util.Hashtable;

?

import javax.jms.BytesMessage;

import javax.jms.Connection;

import javax.jms.ConnectionFactory;

import javax.jms.JMSException;

import javax.jms.MessageProducer;

import javax.jms.ObjectMessage;

import javax.jms.Queue;

import javax.jms.Session;

import javax.naming.Context;

import javax.naming.InitialContext;

import javax.naming.NamingException;

?

/**

?* @author Administrator

?*

?* TODO To change the template for this generated type comment go to Window -

?* Preferences - Java - Code Style - Code Templates

?*/

public class SendMessage {

?????? private static String MQ_CHANNEL = "EXAMPLE.CHANNEL";

?

?????? private static String MQ_MANAGER = "QMGR";

?

?????? private static String MQ_QUEUE = "EXAMPLE.SENDQUEUE";

?

?????? private static int MQ_PORT = 4001;

?

?????? private static String JMS_CONNECTIONFACTORY = "jms/JMSExampleConnectionFactory";

??????

?????? private static String QUEUE_NAME="jms/JMSExampleSendQueue";

?

?????? public static void sendFileToReceiveQueue(File file) {

?????????????

????????????? try {

???????????????????? Context initContext = new InitialContext();

???????????????????? ConnectionFactory qconFactory = (ConnectionFactory) initContext

?????????????????????????????????? .lookup(JMS_CONNECTIONFACTORY);

???????????????????? Connection qcon = qconFactory.createConnection();

???????????????????? Session session = qcon.createSession(false,

?????????????????????????????????? Session.AUTO_ACKNOWLEDGE);

???????????????????? Queue queue = (Queue) initContext.lookup(QUEUE_NAME);

????????????????????

???????????????????? MessageProducer producer = session.createProducer(queue);

????????????? ?????? ObjectMessage outMessage=session.createObjectMessage();

?????????????

???????????????????? /* write the file information into the message */

???????????????????? Hashtable fileInfo = new Hashtable();

???????????????????? fileInfo.put("FileName", file.getName());

???????????????????? fileInfo.put("FileSize", Long.toString(file.length()));

?

???????????????????? /* write the file content into the message */

???????????????????? FileInputStream fos = new FileInputStream(file);

???????????????????? byte[] buf;

???????????????????? int size = (int) file.length();

???????????????????? buf = new byte[size];

???????????????????? int num = fos.read(buf);

???????????????????? fos.close();

????????????????????

???????????????????? /*add the file byte stream to the object*/

???????????????????? fileInfo.put("content", buf);

????????????????????

???????????????????? outMessage.setObject(fileInfo);

???????????????????? outMessage.getObject();

???????????????????? outMessage.setJMSCorrelationIDAsBytes((new String("clinet_B_receive")).getBytes());

//?????????????????? qcon.start();

????????????????????

?

???????????????????? producer.send(outMessage);

???????????????????? producer.close();

???????????????????? session.close();

???????????????????? qcon.close();

????????????? } catch (NamingException e) {

???????????????????? System.out.println(" 獲得連接失敗 ,jndi 查找失敗 ");

???????????????????? e.printStackTrace();

????????????? } catch (JMSException e) {

???????????????????? System.out.println(" 發(fā)送文件異常 ");

???????????????????? // TODO Auto-generated catch block

???????????????????? e.printStackTrace();

????????????? } catch (IOException e) {

???????????????????? // TODO Auto-generated catch block

???????????????????? System.out.println(" 發(fā)送文件過程中 io 操作失敗 ");

???????????????????? e.printStackTrace();

????????????? }

?????? }

}