/*

  * write by:wjf

  * date:2015-05-20

  * dec:MQ操作客户端

  *

  */

 using System;

 using System.Diagnostics;

 using System.IO;

 using IBM.WMQ;

 namespace RsaTest

 {

     public class IbmMQClient : IDisposable

     {

         // 定义MQ 服务器的IP 地址；

         private string hostname = "182.180.80.241";

         //private const string hostname = "182.180.80.243";

         //MQ侦听端口号

         //private const int port = 54221;

         private readonly int port;

         // 设置队列打开选项为可存放；

         private const int openOptions = MQC.MQOO_OUTPUT; // MQC.MQOO_INPUT_AS_Q_DEF | MQC.MQOO_OUTPUT;

         // 队列管理器；

         private readonly MQQueueManager qManager;

         //队列名称

         private readonly string qName;

         // 定义MQ 服务器连接通道的名称；

         private readonly string channel;

         // 定义队列管理器的名称；

         //private string qManagerName;

         public IbmMQClient(string qManagerName, string channel, string qName, string sPort, string hostname)

         {

             //this.qManagerName = qManagerName;

             this.channel = channel;

             this.qName = qName;

             this.port = Convert.ToInt32(sPort);

             this.hostname = hostname;

             InitQueueEnv();

             qManager = new MQQueueManager(qManagerName);

         }

         /// <summary>

         /// 初始化队列环境

         /// </summary>

         private void InitQueueEnv()

         {

             // 初始化MQ 环境变量，以指定MQ 服务器的连接参数；

             // 指定MQ 服务器的主机名称；

             MQEnvironment.Hostname = hostname;

             // 指定MQ 服务器的服务器连接通道的名称；

             MQEnvironment.Channel = channel;

             // 指定MQ 服务器的侦听器的侦听端口号；

             MQEnvironment.Port = port;

             //MQEnvironment.UserId = "mqm";

         }

         public void SendMessage(string message)

         {

             if (qManager == null)

             {

                 throw new Exception("队列管理器未初始化。");

             }

             // 获得队列的访问句柄；

             MQQueue lq = qManager.AccessQueue(qName, openOptions);

             try

             {

                 // 构造新的消息对象，为发送消息做准备；

                 MQMessage mo = new MQMessage();

                 //指定编码（有点小重要哦）

                 mo.CharacterSet = ;

                 // 填入消息内容；

                 //mo.WriteUTF(message);

                 mo.WriteString(message);

                 //指定消息的格式

                 mo.Format = MQC.MQFMT_STRING;

                 // 构造放入消息选项对象；

                 MQPutMessageOptions pmo = new MQPutMessageOptions();

                 // 向已打开队列放入已构造的测试消息；

                 lq.Put(mo, pmo);

             }

             finally

             {

                 try

                 {

                     // 关闭本地队列；

                     lq.Close();

                 }

                 catch (Exception e)

                 {

                     Debug.WriteLine(e);

                 }

             }

         }

         public void SendFile(string filePath)

         {

             if (qManager == null)

             {

                 throw new Exception("队列管理器未初始化。");

             }

             // 获得队列的访问句柄；

             MQQueue lq = qManager.AccessQueue(qName, openOptions);

             try

             {

                 // 构造新的消息对象，为发送消息做准备；

                 MQMessage mo = new MQMessage();

                 //构建文件信息对象

                 FileInfo fi = new FileInfo(filePath);

                 //写入文件大小

                 mo.WriteInt8(fi.Length);

                 //写入文件名

                 mo.WriteUTF(fi.Name);

                 //写入文件内容

                 mo.Write(File.ReadAllBytes(filePath));

                 // 构造放入消息选项对象；

                 MQPutMessageOptions pmo = new MQPutMessageOptions();

                 // 向已打开队列放入已构造的测试消息；

                 lq.Put(mo, pmo);

             }

             finally

             {

                 try

                 {

                     // 关闭本地队列；

                     lq.Close();

                 }

                 catch (Exception e)

                 {

                     Debug.WriteLine(e);

                 }

             }

         }

         ~IbmMQClient()

         {

             Close();

         }

         /// <summary>

         /// Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources.

         /// </summary>

         /// <filterpriority></filterpriority>

         public void Dispose()

         {

             Close();

         }

         public void Close()

         {

             if (qManager != null)

             {

                 try

                 {

                     // 释放与队列管理器的连接；

                     qManager.Disconnect();

                 }

                 catch (Exception e)

                 {

                     Debug.WriteLine(e);

                 }

             }

         }

     }

 }