为什么MQC里面上传不了13M的安装包

以上参数中MQC.MQOO_INQUIRE和读取队列的裤御深度有关系...12-13 2904 对于MQ传输文件,我采逗纯闭取的思路...Struts 2是通过Commons FileUpload文山裂件上传。Commo...

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=0j<5j++){

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)

}

}

}

---