java怎么将mq接收的文件消息提取出来

WebSphere MQ 接收发送

添加mq jar

类介绍：

SendMSG：消息发送类。

Main（）：主方法。

SendMSG（）：消息发送方法。

方法描述：

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

package test;

public class SendMSG{

MQEnvironmenthostname = "19216810201";

//通道类型为服务器连接通道

MQEnvironmentchannel = "tongdao";

MQEnvironmentCCSID = 1381;

//消息队列端口号

MQEnvironmentport = 10618;

try{

//建立队列管理器QM_SERVER为队列管理器名称

MQQueueManager qMgr = new MQQueueManager("test");

int openOptions = MQCMQOO_INPUT_AS_Q_DEF|MQCMQOO_OUTPUTMQCMQOO_INQUIRE;//建立队列INITQ队列名称INITQ为本地队列

MQQueue queue = qMgraccessQueue("wanghui",openOptions,null,null,null);

Systemoutprintln("成功建立通道");

MQMessage message = new MQMessage();

messageformat = MQCMQFMT_STRING;

messagecharacterSet = 1381;

messagewriteString("王辉");

messageexpiry = -1;//设置消息用不过期

queueput(message);//将消息放入队列

queueclose();//关闭队列

qMgrdisconnect();//断开连接

}catch(EOFExceptione){

eprintStackTrace();

}catch(MQExceptione){

eprintStackTrace();

}catch(Exceptione){

eprintStackTrace();

}

}

ReceiveMSG:消息接收类。

Main（）：主方法。

ReceiveMSG():消息接收方法。

public class ReceiveMSG {

MQEnvironmenthostname="19216810201";//通道类型为服务器连接通道

MQEnvironmentchannel="tongdao";

MQEnvironmentCCSID=1381;

MQEnvironmentport=10618;

try{

//建立队列管理器QM_SERVER为队列管理器名称

MQQueueManager qMgr = new MQQueueManager("test");

int openOptions=MQCMQOO_INPUT_AS_Q_DEF|MQCMQOO_OUTPUT|MQCMQOO_INQUIRE;//建立队列INITQ队列名称INITQ为本地队列

MQQueue queue=qMgraccessQueue("wanghui",openOptions,null,null,null);

Systemoutprintln("成功建立通道");

MQMessage message= new MQMessage();

messageformat=MQCMQFMT_STRING;

messagecharacterSet=1381;

//从队列中获取消息

MQGetMessage Optionspmo=new MQGetMessageOptions();

queueget(message,pmo);

Stringchars=messagereadLine();

Systemoutprintln(chars);

queueclose();//关闭队列

qMgrdisconnect();//断开连接

}catch(EOFExceptione){

eprintStackTrace();

}catch(MQExceptione){

eprintStackTrace();

}catch(Exceptione){

eprintStackTrace();

}

}

1）短连接：从连接建立到关闭持续的时间比较短。

过程大致是这样的 建立连接-->交换数据-->关闭连接 2）长连接：从连接建立到关闭持续的时间比较长。过程大致是这样的 建立连接-->交换数据-->交换数据---> ……-->交换数据 -->关闭连接 3）连接持续。

MQ 是应用层协议，TCP是网络层协议。他们不在一个层次。 MQ可以用TCP实现，也可以用UDP实现。 MQ的原理是基于消息的通信方式，Message Queue消息队列。 而消息队列一般都有API可以直接用，不用自己重新实现。