【IT168 技术文章】
最近一个项目中要用到WebSphere MQ进行消息转发。整个项目由多个子系统组成，由于其他子系统是基于VS2005，为了统一，老大也希望这部分开发能在VS2005下进行。
在网上搜索了一下，COPY了一些代码在办公机器上做测试，总的来说还比较顺利。为了方便回家测试，就把代码COPY到了NB上。回家发现居然运行出错，错误代码2059。
网上搜了一下，发现有这个问题的人很多。IBM提供的文档也比较水：先检查网络是否连通，队列管理器是否启动等等。
看到也有很多人提出2059是CCSID的问题，看了一下觉得不太可能，因为应用场景不一样。网上一般都是MQ Client连MQ Server，这样才会出现两台机器的CCSID不一致。本项目中的场景是在MQ Server上跑一个程序，读本机的MQ消息。
试着用JAVA访问，居然收发正常。想想会不会是VS环境的问题呢？因为我NB上装的是VS2008。就把2008卸了，换成2005，还是错误代码2059。后来试着把办公机上的程序COPY到NB上，发现运行出错。而NB的VS2005开发的程序COPY到办公机上能正常运行。估计就是NB的软件环境问题了。
看了一下.NET Framework的版本，发现一个是2.0，一个是2.0SP1+3.5。估计就是.NET Framework的问题了。后面没有再仔细求证了。猜测是3.5的原因大一些，因为在鬼佬的网站上也有人提出VS2008访问MQ总是不通，返回2059。
程序代码：
文件名：IMQ.cs
using System;
using System.Collections.Generic;
using System.Text;
namespace CNMC.WYB.MQ
{
public delegate void MessageArrivaledHandler(string mqMessage);
interface IMQ
{
void Connect();
void Disconnect();
void Send(string msg);
string Receive();
void Listen();
event MessageArrivaledHandler MessageArrivalEvent;
}
}
文件名：WebSphereMQManagement .cs
using System;
using System.Collections.Generic;
using System.Text;
using IBM.WMQ;
using IBM.WMQ.PCF;
namespace CNMC.WYB.MQ
{
public enum ConnectionState { Open, Closed }
class WebSphereMQManagement : IMQ
{
private bool isListen = false;//用来标识是否持续监听消息队列
/// <summary>
/// 获取或设置是否持续监听消息队列标识
/// </summary>
public bool IsListen
{
get { return isListen; }
set { isListen = value; }
}
private ConnectionState state = ConnectionState.Closed;
/// <summary>
/// 获取连接状态
/// </summary>
public ConnectionState State
{
get { return state; }
}
private string queueManagerName;
private string queueName;
private MQQueueManager queueManager = null;
private MQQueue queue = null;
private WebSphereMQManagement(string qmName, string qName)
{
queueManagerName = qmName.Trim();
queueName = qName.Trim();
}
/// <summary>
/// 连接MQ
/// </summary>
public void Connect()
{
if (state == ConnectionState.Open)
return;
try
{
queueManager = new MQQueueManager(queueManagerName);
queue = queueManager.AccessQueue(queueName, MQC.MQOO_INPUT_AS_Q_DEF | MQC.MQOO_FAIL_IF_QUIESCING);
}
catch (MQException e)
{
throw new Exception("连接队列管理器或打开队列出错: 结束码：" + e.CompletionCode + ";错误原因代码：" + e.ReasonCode);
}
state = ConnectionState.Open;
}
