设为首页收藏本站
开启辅助访问

在路上

 找回密码
 立即注册
在路上 › 站点首页 ›学习 › 查看内容

MQ发送文件到队列的Java代码

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

摘要: MQ发送文件到队列 mqfilesend.java package com.mq.dpca.file;import java.io.File;import java.io.FileInputStream;import com.ibm.mq.MQEnvironment;import com.ibm.mq.MQException;imp ...
MQ发送文件到队列

mqfilesend.java
  1. package com.mq.dpca.file;
  3. import java.io.File;
  4. import java.io.FileInputStream;
  6. import com.ibm.mq.MQEnvironment;
  7. import com.ibm.mq.MQException;
  8. import com.ibm.mq.MQMessage;
  9. import com.ibm.mq.MQPutMessageOptions;
  10. import com.ibm.mq.MQQueue;
  11. import com.ibm.mq.MQQueueManager;
  12. import com.ibm.mq.constants.MQConstants;
  14. /**
  15. *
  16. * MQ发送文件功能
  17. *
  18. */
  19. public class mqfilesend {
  20. final int BUFFER_LEN = 1024 * 1024; // 定义发送文件的大小
  22. private MQQueueManager qmgr; // 连接到队列管理器
  24. private MQQueue outQueue; // 传输队列
  26. private String queueName = "aa"; // 队列名称
  28. private String host = "127.0.0.1"; // 队列名称
  30. private int port = 1414; // 侦听器的端口号
  32. private String channel = "SYSTEM.BKR.CONFIG"; // 通道名称
  34. private String qmgrName = "mm"; // 队列管理器
  36. private MQMessage outMsg; // 创建消息缓冲
  38. private MQPutMessageOptions pmo; // 设置获取消息选项
  40. private String fileName = "D:\log.txt"; // 要往队列上发的文件
  42. /**
  43. * 初始化服务器连接信息
  44. *
  45. * @throws Exception
  46. */
  47. private void init() throws Exception {
  48. /** 设置MQEnvironment 属性以便客户机连接 */
  49. MQEnvironment.hostname = host;
  50. MQEnvironment.channel = channel;
  51. MQEnvironment.port = port;
  52. // MQEnvironment.properties.put(MQC.TRANSPORT_PROPERTY,MQC.TRANSPORT_WEBSPHERE
  53. // MQ);
  55. /* 连接到队列管理器 */
  56. qmgr = new MQQueueManager(qmgrName);
  58. /* 设置队列打开选项以便输出 */
  59. int opnOptn = MQConstants.MQOO_OUTPUT
  60. | MQConstants.MQOO_FAIL_IF_QUIESCING;
  61. // int opnOptn = MQConstants.MQOO_OUTPUT ;
  63. outQueue = qmgr.accessQueue(queueName, opnOptn, null, null, null);
  64. }
  66. /**
  67. * 发送的主程序
  68. *
  69. * @throws Exception
  70. */
  71. public void sendMessages() throws Exception {
  72. /* 设置放置消息选项 */
  73. pmo = new MQPutMessageOptions();
  74. outMsg = new MQMessage();
  75. FileInputStream fis = new FileInputStream(new File(fileName));
  76. byte buffer[] = new byte[BUFFER_LEN];
  77. int count = 0;
  78. while (true) {
  79. count = fis.read(buffer, 0, BUFFER_LEN);
  80. if (count == -1) {
  81. break;
  82. }
  83. outMsg.write(buffer);
  85. if (count < BUFFER_LEN) {
  86. System.out.println("aaa");
  87. }
  88. outQueue.put(outMsg, pmo);
  89. outMsg.clearMessage();
  90. }
  91. fis.close();
  92. }
  94. public void runGoupSender() {
  95. try {
  96. init();
  97. sendMessages();
  98. qmgr.commit();
  99. System.out.println("n Messages successfully Send ");
  100. } catch (MQException mqe) {
  101. mqe.printStackTrace();
  102. try {
  103. System.out.println("n Backing out Transaction ");
  104. qmgr.backout();
  105. System.exit(2);
  106. } catch (Exception e) {
  107. e.printStackTrace();
  108. System.exit(2);
  109. }
  110. } catch (Exception e) {
  111. e.printStackTrace();
  112. System.exit(2);
  113. }
  114. }
  116. /**
  117. * 程序的入口
  118. *
  119. * @param args
  120. */
  121. public static void main(String args[]) {
  122. MQFileSender mfs = new MQFileSender();
  123. int i = 0;
  124. while (true) {
  125. i++;
  126. System.out.println("消息记录" + i);
  127. mfs.runGoupSender();
  128. if (i == 1) {
  129. break;
  130. }
  131. }
  132. }
  133. }
复制代码
MQConfig.java ~ 6KB (6)
  1. package com.mq.dpca.msg;
  3. import java.io.BufferedInputStream;
  4. import java.io.FileInputStream;
  5. import java.io.FileNotFoundException;
  6. import java.io.IOException;
  7. import java.io.InputStream;
  8. import java.util.Properties;
  9. import java.util.PropertyResourceBundle;
  10. import java.util.ResourceBundle;
  12. import com.mq.dpca.util.RenameUtil;
  14. /**
  15. * MQ访问配置文件各参数的获取
  16. *
  17. */
  18. public class MQConfig {
  19. // MQ配置及server配置文件路径
  20. private static final String ACTIONPATH = "config.properties";
  21. private static MQConfig instance = null;
  23. private String MQ_MANAGER = null;
  24. private String MQ_HOST_NAME = null;
  25. private String MQ_CHANNEL = null;
  26. private String MQ_QUEUE_NAME = null;
  27. private String MQ_PROT = null;
  28. private String MQ_CCSID = null;
  29. private String MQ_QUEUE_SUB = null;
  30. private String FILE_DIR = null;
  32. public String getFILE_DIR() {
  33. return FILE_DIR;
  34. }
  36. public void setFILE_DIR(String fILE_DIR) {
  37. FILE_DIR = fILE_DIR;
  38. }
  40. public String getMQ_MANAGER() {
  41. return MQ_MANAGER;
  42. }
  44. public void setMQ_MANAGER(String mq_manager) {
  45. MQ_MANAGER = mq_manager;
  46. }
  48. public String getMQ_HOST_NAME() {
  49. return MQ_HOST_NAME;
  50. }
  52. public void setMQ_HOST_NAME(String mq_host_name) {
  53. MQ_HOST_NAME = mq_host_name;
  54. }
  56. public String getMQ_CHANNEL() {
  57. return MQ_CHANNEL;
  58. }
  60. public void setMQ_CHANNEL(String mq_channel) {
  61. MQ_CHANNEL = mq_channel;
  62. }
  64. public String getMQ_QUEUE_NAME() {
  65. return MQ_QUEUE_NAME;
  66. }
  68. public void setMQ_QUEUE_NAME(String mq_queue_name) {
  69. MQ_QUEUE_NAME = mq_queue_name;
  70. }
  72. public String getMQ_PROT() {
  73. return MQ_PROT;
  74. }
  76. public void setMQ_PROT(String mq_prot) {
  77. MQ_PROT = mq_prot;
  78. }
  80. public String getMQ_CCSID() {
  81. return MQ_CCSID;
  82. }
  84. public void setMQ_CCSID(String mq_ccsid) {
  85. MQ_CCSID = mq_ccsid;
  86. }
  88. public static MQConfig getInstance() {
  89. if (instance == null) {
  90. instance = new MQConfig().getNewDbConfig();
  91. }
  92. return instance;
  93. }
  95. public static ResourceBundle getCFG(){
  96. String cfgPath = "";
  97. InputStream in = null;
  98. ResourceBundle pathCfg = null;
  99. ResourceBundle mqCfg = null;
  100. pathCfg = PropertyResourceBundle.getBundle("config");
  101. cfgPath = RenameUtil.getParameter(pathCfg, "mqcfgPath");
  102. try {
  103. in = new BufferedInputStream(new FileInputStream(cfgPath));
  104. mqCfg = new PropertyResourceBundle(in);
  105. return mqCfg;
  106. } catch (FileNotFoundException e) {
  107. e.printStackTrace();
  108. }catch (IOException e) {
  109. e.printStackTrace();
  110. }
  111. return mqCfg;
  112. }
  114. public static MQConfig getNewDbConfig() {
  116. MQConfig dc = new MQConfig();
  117. Properties prop = new Properties();
  118. String path = null;
  119. InputStream fis = null;
  121. try {
  122. fis = MQConfig.class.getClassLoader().getResourceAsStream(
  123. "config.properties");
  124. // fis = new FileInputStream(new File(path + ACTIONPATH));
  125. prop.load(fis);
  126. dc.MQ_CCSID = prop.getProperty("MQ_CCSID");
  127. dc.MQ_CHANNEL = prop.getProperty("MQ_CHANNEL");
  128. dc.MQ_HOST_NAME = prop.getProperty("MQ_HOST_NAME");
  129. dc.MQ_MANAGER = prop.getProperty("MQ_MANAGER");
  130. dc.MQ_PROT = prop.getProperty("MQ_PROT");
  131. dc.MQ_QUEUE_NAME = prop.getProperty("MQ_QUEUE_NAME");
  132. dc.MQ_QUEUE_SUB = prop.getProperty("MQ_QUEUE_SUB");
  133. dc.FILE_DIR = prop.getProperty("FILE_DIR");
  134. } catch (FileNotFoundException e) {
  135. e.printStackTrace();
  136. } catch (IOException e) {
  137. e.printStackTrace();
  138. }
  140. return dc;
  141. }
  143. public static MQConfig MqConfig() {
  145. MQConfig dc = new MQConfig();
  146. ResourceBundle rb = getCFG();
  147. try {
  148. // fis = new FileInputStream(new File(path + ACTIONPATH));
  149. dc.MQ_CCSID = RenameUtil.getParameter(rb,"MQ_CCSID");
  150. dc.MQ_CHANNEL = RenameUtil.getParameter(rb,"MQ_CHANNEL");
  151. dc.MQ_HOST_NAME = RenameUtil.getParameter(rb,"MQ_HOST_NAME");
  152. dc.MQ_MANAGER = RenameUtil.getParameter(rb,"MQ_MANAGER");
  153. dc.MQ_PROT = RenameUtil.getParameter(rb,"MQ_PROT");
  154. dc.MQ_QUEUE_NAME = RenameUtil.getParameter(rb,"MQ_QUEUE_NAME");
  155. dc.MQ_QUEUE_SUB = RenameUtil.getParameter(rb,"MQ_QUEUE_SUB");
  156. dc.FILE_DIR = RenameUtil.getParameter(rb,"FILE_DIR");
  157. } catch (Exception e) {
  158. e.printStackTrace();
  159. }
  160. return dc;
  161. }
  163. public static MQConfig getNewDbConfigFromKey(String key) {
  164. MQConfig dc = null;
  165. Properties prop = new Properties();
  166. String path = null;
  167. InputStream fis = null;
  168. try {
  169. fis = MQConfig.class.getClassLoader().getResourceAsStream(
  170. "config.properties");
  171. // fis = new FileInputStream(new File(path + ACTIONPATH));
  172. prop.load(fis);
  173. dc = new MQConfig();
  174. dc.MQ_MANAGER = prop.getProperty(key + "_MQ_MANAGER");
  175. dc.MQ_CCSID = prop.getProperty(key + "_MQ_CCSID");
  176. dc.MQ_CHANNEL = prop.getProperty(key + "_MQ_CHANNEL");
  177. dc.MQ_HOST_NAME = prop.getProperty(key + "_MQ_HOST_NAME");
  178. dc.MQ_PROT = prop.getProperty(key + "_MQ_PROT");
  179. dc.MQ_QUEUE_NAME = prop.getProperty(key + "_MQ_QUEUE_NAME");
  180. dc.MQ_QUEUE_SUB = prop.getProperty(key + "_MQ_QUEUE_SUB");
  181. dc.FILE_DIR = prop.getProperty(key + "_FILE_DIR");
  182. } catch (FileNotFoundException e) {
  183. dc = null;
  184. } catch (IOException e) {
  185. dc = null;
  186. }
  188. return dc;
  189. }
  191. public static void main(String args[]) throws Exception {
  192. MQConfig mc = MQConfig.getNewDbConfigFromKey("002");
  193. System.out.println(mc);
  194. }
  196. public void setMQ_QUEUE_SUB(String mQ_QUEUE_SUB) {
  197. MQ_QUEUE_SUB = mQ_QUEUE_SUB;
  198. }
  200. public String getMQ_QUEUE_SUB() {
  201. return MQ_QUEUE_SUB;
  202. }
  204. public static String getValueByKey(String key) {
  205. InputStream fis = null;
  206. String value = null;
  207. Properties prop = new Properties();
  208. try {
  209. fis = MQConfig.class.getClassLoader().getResourceAsStream(
  210. "config.properties");
  211. prop.load(fis);
  212. value = prop.getProperty(key);
  213. } catch (FileNotFoundException e) {
  214. e.printStackTrace();
  215. } catch (IOException e) {
  216. e.printStackTrace();
  217. }
  218. return value;
  219. }
  220. }
复制代码
收藏 邀请
上一篇：Java实现对cookie的操作(增删改查)下一篇：Java文件读写操作具体代码实现

最新评论

相关分类

小黑屋|在路上 ( 蜀ICP备15035742号-1 )  

;

GMT+8, 2025-8-23 04:36

Copyright 2015-2025 djqfx

返回顶部