基于C#的IBM消息队列操作客户端

fateame

　　背景：
　　做XX项目需要把交易的消息推送给YY系统，技术选型MQ
　　另：选用MQ原因是为了防止YY系统宕机，无法接受收消息
　　实现
　　1、安装IBM WebSphere MQ客户端
　　2、引用amqmdnet.dll（在客户端的安装目录下可以找到）
　　3、C#代码如下



  1 /*
  2  * write by:wjf
  3  * date:2015-05-20
  4  * dec:MQ操作客户端
  5  *
  6  */
  7 using System;
  8 using System.Diagnostics;
  9 using System.IO;
10 using IBM.WMQ;
11
12 namespace RsaTest
13 {
14     public class IbmMQClient : IDisposable
15     {
16         // 定义MQ 服务器的IP 地址；
17         private string hostname = "182.180.80.241";
18         //private const string hostname = "182.180.80.243";
19         //MQ侦听端口号
20         //private const int port = 54221;
21         private readonly int port;
22         // 设置队列打开选项为可存放；
23         private const int openOptions = MQC.MQOO_OUTPUT; // MQC.MQOO_INPUT_AS_Q_DEF | MQC.MQOO_OUTPUT;
24
25         // 队列管理器；
26         private readonly MQQueueManager qManager;
27         //队列名称
28         private readonly string qName;
29         // 定义MQ 服务器连接通道的名称；
30         private readonly string channel;
31         // 定义队列管理器的名称；
32         //private string qManagerName;
33
34         public IbmMQClient(string qManagerName, string channel, string qName, string sPort, string hostname)
35         {
36             //this.qManagerName = qManagerName;
37             this.channel = channel;
38             this.qName = qName;
39             this.port = Convert.ToInt32(sPort);
40             this.hostname = hostname;
41             InitQueueEnv();
42             qManager = new MQQueueManager(qManagerName);
43         }
44
45         /// <summary>
46         /// 初始化队列环境
47         /// </summary>
48         private void InitQueueEnv()
49         {
50             // 初始化MQ 环境变量，以指定MQ 服务器的连接参数；
51             // 指定MQ 服务器的主机名称；
52             MQEnvironment.Hostname = hostname;
53             // 指定MQ 服务器的服务器连接通道的名称；
54             MQEnvironment.Channel = channel;
55             // 指定MQ 服务器的侦听器的侦听端口号；
56             MQEnvironment.Port = port;            
57             //MQEnvironment.UserId = "mqm";            
58         }
59
60         public void SendMessage(string message)
61         {
62             if (qManager == null)
63             {
64                 throw new Exception("队列管理器未初始化。");
65             }
66             // 获得队列的访问句柄；
67             MQQueue lq = qManager.AccessQueue(qName, openOptions);
68
69             try
70             {
71                 // 构造新的消息对象，为发送消息做准备；
72                 MQMessage mo = new MQMessage();
73                 //指定编码（有点小重要哦）
74                 mo.CharacterSet = 1208;
75                 // 填入消息内容；
76                 //mo.WriteUTF(message);
77                 mo.WriteString(message);
78                 //指定消息的格式
79                 mo.Format = MQC.MQFMT_STRING;
80                 // 构造放入消息选项对象；
81                 MQPutMessageOptions pmo = new MQPutMessageOptions();
82                 // 向已打开队列放入已构造的测试消息；
83                 lq.Put(mo, pmo);
84             }
85             finally
86             {
87                 try
88                 {
89                     // 关闭本地队列；
90                     lq.Close();
91                 }
92                 catch (Exception e)
93                 {
94                     Debug.WriteLine(e);
95                 }
96             }
97         }
98
99         public void SendFile(string filePath)
100         {
101             if (qManager == null)
102             {
103                 throw new Exception("队列管理器未初始化。");
104             }
105             // 获得队列的访问句柄；
106             MQQueue lq = qManager.AccessQueue(qName, openOptions);
107
108             try
109             {
110                 // 构造新的消息对象，为发送消息做准备；
111                 MQMessage mo = new MQMessage();
112                 //构建文件信息对象
113                 FileInfo fi = new FileInfo(filePath);
114                 //写入文件大小
115                 mo.WriteInt8(fi.Length);
116                 //写入文件名
117                 mo.WriteUTF(fi.Name);
118                 //写入文件内容
119                 mo.Write(File.ReadAllBytes(filePath));
120                 // 构造放入消息选项对象；
121                 MQPutMessageOptions pmo = new MQPutMessageOptions();
122                 // 向已打开队列放入已构造的测试消息；
123                 lq.Put(mo, pmo);
124             }
125             finally
126             {
127                 try
128                 {
129                     // 关闭本地队列；
130                     lq.Close();
131                 }
132                 catch (Exception e)
133                 {
134                     Debug.WriteLine(e);
135                 }
136             }
137         }
138
139         ~IbmMQClient()
140         {
141             Close();
142         }
143
144         /// <summary>
145         /// Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources.
146         /// </summary>
147         /// <filterpriority>2</filterpriority>
148         public void Dispose()
149         {
150             Close();
151         }
152
153         public void Close()
154         {
155             if (qManager != null)
156             {
157                 try
158                 {
159                     // 释放与队列管理器的连接；
160                     qManager.Disconnect();
161                 }
162                 catch (Exception e)
163                 {
164                     Debug.WriteLine(e);
165                 }
166             }
167         }
168     }
169 }