MQ发送文件到队列的Java代码详解编程语言

MQEnvironment.port = port; // MQEnvironment.properties.put(MQC.TRANSPORT_PROPERTY,MQC.TRANSPORT_WEBSPHERE // MQ); /* 连接到队列管理器 */ qmgr = new MQQueueManager(qmgrName); /* 设置队列打开选项以便输出 */ int opnOptn = MQConstants.MQOO_OUTPUT | MQConstants.MQOO_FAIL_IF_QUIESCING; // int opnOptn = MQConstants.MQOO_OUTPUT ; outQueue = qmgr.accessQueue(queueName, opnOptn, null, null, null); /** * 发送的主程序 * @throws Exception public void sendMessages() throws Exception { /* 设置放置消息选项 */ pmo = new MQPutMessageOptions(); outMsg = new MQMessage(); FileInputStream fis = new FileInputStream(new File(fileName)); byte buffer[] = new byte[BUFFER_LEN]; int count = 0; while (true) { count = fis.read(buffer, 0, BUFFER_LEN); if (count == -1) { break; outMsg.write(buffer); if (count BUFFER_LEN) { System.out.println("aaa"); outQueue.put(outMsg, pmo); outMsg.clearMessage(); fis.close(); public void runGoupSender() { try { init(); sendMessages(); qmgr.commit(); System.out.println("/n Messages successfully Send "); } catch (MQException mqe) { mqe.printStackTrace(); try { System.out.println("/n Backing out Transaction "); qmgr.backout(); System.exit(2); } catch (Exception e) { e.printStackTrace(); System.exit(2); } catch (Exception e) { e.printStackTrace(); System.exit(2); /** * 程序的入口 * @param args public static void main(String args[]) { MQFileSender mfs = new MQFileSender(); int i = 0; while (true) { i++; System.out.println("消息记录" + i); mfs.runGoupSender(); if (i == 1) { break; MQConfig.java ~ 6KB  (6) 

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; 

原创文章，作者：ItWorker，如若转载，请注明出处：https://blog.ytso.com/10150.html

cgojava