MQ发送消息到队列的Java代码

2016-12-20 13:16| 发布者: zhangjf| 查看: 710| 评论: 0

摘要: MQ发送消息到队列 MsgSend.java package com.mq.dpca.msg;import javax.jms.JMSException;import javax.jms.Queue;import javax.jms.QueueConnection;import javax.jms.QueueSender;import ...

MQ发送消息到队列

MsgSend.java

package com.mq.dpca.msg;
import javax.jms.JMSException;
import javax.jms.Queue;
import javax.jms.QueueConnection;
import javax.jms.QueueSender;
import javax.jms.QueueSession;
import javax.jms.Session;
import javax.jms.TextMessage;
import com.ibm.mq.jms.MQQueueConnectionFactory;
import com.ibm.msg.client.wmq.WMQConstants;
/**
* MQ字符串发送功能
*
*/
public class MsgSend {
MQQueueConnectionFactory mcf;
QueueConnection qconn;
MQConfig mc = null;
/**
* 初始化连接
*
* @throws JMSException
*/
public void openConnection() throws JMSException {
mc = MQConfig.getInstance();
mcf = new MQQueueConnectionFactory();
mcf.setConnectionNameList(mc.getMQ_HOST_NAME());
// mcf.setHostName(mc.getMQ_HOST_NAME());
mcf.setChannel(mc.getMQ_CHANNEL());
mcf.setTransportType(WMQConstants.WMQ_CM_CLIENT);
mcf.setClientReconnectOptions(WMQConstants.WMQ_CLIENT_RECONNECT);
// mcf.setPort(Integer.parseInt(mc.getMQ_PROT()));
mcf.setCCSID(Integer.parseInt(mc.getMQ_CCSID()));
mcf.setQueueManager(mc.getMQ_MANAGER());
qconn = mcf.createQueueConnection();
}
/**
* 发送消息
*
* @param key
* @param msgInfo
* @throws JMSException
* @throws InterruptedException
*/
public void send(String key, String msgInfo) {
QueueSession session = null;
QueueSender sender = null;
try {
openConnection();
session = qconn.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
Queue queue = session.createQueue(mc.getMQ_QUEUE_NAME());
sender = session.createSender(queue);
TextMessage msg = session.createTextMessage();
msg.setText(msgInfo);
// msg.setStringProperty("Key", key);
sender.send(msg);
} catch (JMSException e) {
e.printStackTrace();
} finally {
try {
sender.close();
session.close();
qconn.close();
} catch (JMSException e) {
e.printStackTrace();
}
}
}
/**
* 程序的入口
* @param args
* @throws JMSException
* @throws InterruptedException
*/
public static void main(String[] args) throws JMSException,
InterruptedException {
MsgSend ms = new MsgSend();
String str = "<root><esbHeader><requestId>d5d001f47d46e1471ae42ebf1dded7a2</requestId><serviceName>syncCustmoerInfo</serviceName>"
+ "<key>3DOxe6EfkvcAAAFH95SjNwAAAAAAAAAD</key></esbHeader><serviceNameReq><security><key>f7b17a6ffcd5561748c5bb98075aa432</key><date>2013-04-10 15:25:00</date></security>"
+ "<customer><khmc>测试客户ES2B</khmc><fzxsid>120483321</fzxsid><khczqh>010</khczqh><khczfj>1234</khczfj><khcz>567892012</khcz>"
+ "</customer>"
+ "<customer><khmc>测试客户ES2B</khmc><fzxsid>120483321</fzxsid><khczqh>010</khczqh><khczfj>1234</khczfj><khcz>567892012</khcz>"
+ "</customer>"
+ "<customer><khmc>测试客户ES2B</khmc><fzxsid>120483321</fzxsid><khczqh>010</khczqh><khczfj>1234</khczfj><khcz>567892012</khcz>"
+ "</customer>" + "</serviceNameReq>" + "</root>";
ms.send("", str);
// Thread.sleep(10000);
System.out.print("消息发送完毕！");
}
}

复制代码

MQConfig.java ~ 6KB

package com.mq.dpca.msg;
import java.io.BufferedInputStream;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.io.InputStream;
import java.util.Properties;
import java.util.PropertyResourceBundle;
import java.util.ResourceBundle;
import com.mq.dpca.util.RenameUtil;
/**
* MQ访问配置文件各参数的获取
*
*/
public class MQConfig {
// MQ配置及server配置文件路径
private static final String ACTIONPATH = "config.properties";
private static MQConfig instance = null;
private String MQ_MANAGER = null;
private String MQ_HOST_NAME = null;
private String MQ_CHANNEL = null;
private String MQ_QUEUE_NAME = null;
private String MQ_PROT = null;
private String MQ_CCSID = null;
private String MQ_QUEUE_SUB = null;
private String FILE_DIR = null;
public String getFILE_DIR() {
return FILE_DIR;
}
public void setFILE_DIR(String fILE_DIR) {
FILE_DIR = fILE_DIR;
}
public String getMQ_MANAGER() {
return MQ_MANAGER;
}
public void setMQ_MANAGER(String mq_manager) {
MQ_MANAGER = mq_manager;
}
public String getMQ_HOST_NAME() {
return MQ_HOST_NAME;
}
public void setMQ_HOST_NAME(String mq_host_name) {
MQ_HOST_NAME = mq_host_name;
}
public String getMQ_CHANNEL() {
return MQ_CHANNEL;
}
public void setMQ_CHANNEL(String mq_channel) {
MQ_CHANNEL = mq_channel;
}
public String getMQ_QUEUE_NAME() {
return MQ_QUEUE_NAME;
}
public void setMQ_QUEUE_NAME(String mq_queue_name) {
MQ_QUEUE_NAME = mq_queue_name;
}
public String getMQ_PROT() {
return MQ_PROT;
}
public void setMQ_PROT(String mq_prot) {
MQ_PROT = mq_prot;
}
public String getMQ_CCSID() {
return MQ_CCSID;
}
public void setMQ_CCSID(String mq_ccsid) {
MQ_CCSID = mq_ccsid;
}
public static MQConfig getInstance() {
if (instance == null) {
instance = new MQConfig().getNewDbConfig();
}
return instance;
}
public static ResourceBundle getCFG(){
String cfgPath = "";
InputStream in = null;
ResourceBundle pathCfg = null;
ResourceBundle mqCfg = null;
pathCfg = PropertyResourceBundle.getBundle("config");
cfgPath = RenameUtil.getParameter(pathCfg, "mqcfgPath");
try {
in = new BufferedInputStream(new FileInputStream(cfgPath));
mqCfg = new PropertyResourceBundle(in);
return mqCfg;
} catch (FileNotFoundException e) {
e.printStackTrace();
}catch (IOException e) {
e.printStackTrace();
}
return mqCfg;
}
public static MQConfig getNewDbConfig() {
MQConfig dc = new MQConfig();
Properties prop = new Properties();
String path = null;
InputStream fis = null;
try {
fis = MQConfig.class.getClassLoader().getResourceAsStream(
"config.properties");
// fis = new FileInputStream(new File(path + ACTIONPATH));
prop.load(fis);
dc.MQ_CCSID = prop.getProperty("MQ_CCSID");
dc.MQ_CHANNEL = prop.getProperty("MQ_CHANNEL");
dc.MQ_HOST_NAME = prop.getProperty("MQ_HOST_NAME");
dc.MQ_MANAGER = prop.getProperty("MQ_MANAGER");
dc.MQ_PROT = prop.getProperty("MQ_PROT");
dc.MQ_QUEUE_NAME = prop.getProperty("MQ_QUEUE_NAME");
dc.MQ_QUEUE_SUB = prop.getProperty("MQ_QUEUE_SUB");
dc.FILE_DIR = prop.getProperty("FILE_DIR");
} catch (FileNotFoundException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
return dc;
}
public static MQConfig MqConfig() {
MQConfig dc = new MQConfig();
ResourceBundle rb = getCFG();
try {
// fis = new FileInputStream(new File(path + ACTIONPATH));
dc.MQ_CCSID = RenameUtil.getParameter(rb,"MQ_CCSID");
dc.MQ_CHANNEL = RenameUtil.getParameter(rb,"MQ_CHANNEL");
dc.MQ_HOST_NAME = RenameUtil.getParameter(rb,"MQ_HOST_NAME");
dc.MQ_MANAGER = RenameUtil.getParameter(rb,"MQ_MANAGER");
dc.MQ_PROT = RenameUtil.getParameter(rb,"MQ_PROT");
dc.MQ_QUEUE_NAME = RenameUtil.getParameter(rb,"MQ_QUEUE_NAME");
dc.MQ_QUEUE_SUB = RenameUtil.getParameter(rb,"MQ_QUEUE_SUB");
dc.FILE_DIR = RenameUtil.getParameter(rb,"FILE_DIR");
} catch (Exception e) {
e.printStackTrace();
}
return dc;
}
public static MQConfig getNewDbConfigFromKey(String key) {
MQConfig dc = null;
Properties prop = new Properties();
String path = null;
InputStream fis = null;
try {
fis = MQConfig.class.getClassLoader().getResourceAsStream(
"config.properties");
// fis = new FileInputStream(new File(path + ACTIONPATH));
prop.load(fis);
dc = new MQConfig();
dc.MQ_MANAGER = prop.getProperty(key + "_MQ_MANAGER");
dc.MQ_CCSID = prop.getProperty(key + "_MQ_CCSID");
dc.MQ_CHANNEL = prop.getProperty(key + "_MQ_CHANNEL");
dc.MQ_HOST_NAME = prop.getProperty(key + "_MQ_HOST_NAME");
dc.MQ_PROT = prop.getProperty(key + "_MQ_PROT");
dc.MQ_QUEUE_NAME = prop.getProperty(key + "_MQ_QUEUE_NAME");
dc.MQ_QUEUE_SUB = prop.getProperty(key + "_MQ_QUEUE_SUB");
dc.FILE_DIR = prop.getProperty(key + "_FILE_DIR");
} catch (FileNotFoundException e) {
dc = null;
} catch (IOException e) {
dc = null;
}
return dc;
}
public static void main(String args[]) throws Exception {
MQConfig mc = MQConfig.getNewDbConfigFromKey("002");
System.out.println(mc);
}
public void setMQ_QUEUE_SUB(String mQ_QUEUE_SUB) {
MQ_QUEUE_SUB = mQ_QUEUE_SUB;
}
public String getMQ_QUEUE_SUB() {
return MQ_QUEUE_SUB;
}
public static String getValueByKey(String key) {
InputStream fis = null;
String value = null;
Properties prop = new Properties();
try {
fis = MQConfig.class.getClassLoader().getResourceAsStream(
"config.properties");
prop.load(fis);
value = prop.getProperty(key);
} catch (FileNotFoundException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
return value;
}
}

复制代码

收藏邀请

上一篇：java实现发送邮件可多个附件内嵌图片下一篇：DateUtils日期操作Java类

		自动登录	找回密码
密码			立即注册

MQ发送消息到队列的Java代码

最新评论

相关分类