我对 IBM MQSeries 不是很熟悉,但我正在编写 c# 脚本,用于从我的队列服务器写入和读取文件。问题是我的阅读作品,但我的写作没有。请注意,我使用的是同一个队列,所以不要费心去那个方向。
我的代码首先使用以下代码访问 MQserver:
MQQueueManager qManager;
MQQueue queue;
MQMessage queueMessage;
MQGetMessageOptions queueGetMessageOptions;
MQPutMessageOptions queuePutMessageOptions;
string QueueName;
public MQAccess(string queueName, string queueManager, string connection, string channel)
{
QueueName = queueName;
qManager = new MQQueueManager(queueManager, channel, connection);
queue = qManager.AccessQueue(QueueName, MQC.MQOO_INPUT_AS_Q_DEF + MQC.MQOO_FAIL_IF_QUIESCING);
}
我可以使用以下代码从队列中读取文件:
public bool NextMessage(ref string message, ref DateTime putDateTime)
{
queueMessage = new MQMessage();
queueMessage.Format = MQC.MQFMT_STRING;
queueGetMessageOptions = new MQGetMessageOptions();
queueGetMessageOptions.Options = MQC.MQOO_INPUT_AS_Q_DEF + MQC.MQOO_FAIL_IF_QUIESCING;
try
{
queue.Get(queueMessage, queueGetMessageOptions);
}
catch (MQException mqex)
{
if (mqex.ReasonCode == MQC.MQRC_NO_MSG_AVAILABLE)
{
message = "";
return false;
}
else
throw mqex;
}
message = queueMessage.ReadString(queueMessage.MessageLength);
putDateTime = queueMessage.PutDateTime;
if (message.StartsWith("´╗┐"))
{
message = message.Substring(3, message.Length - 3);
}
return true;
}
但是,如果我尝试使用以下代码编写它会给我错误:
public void WriteMessage(string message)
{
queueMessage = new MQMessage();
queueMessage.WriteString(message);
queueMessage.Format = MQC.MQFMT_STRING;
queuePutMessageOptions = new MQPutMessageOptions();
queue.Put(queueMessage, queuePutMessageOptions);
}
我的错误捕获给了我错误:
应用程序中的错误
当然,这并没有显示太多。所以我检查了服务器上的事件日志,这向我显示了错误:
通过 TCP/IP 从 stx041774 (192.168.225.51) 接收数据时出错。这可能是由于通信故障。
TCP/IP (recv) 调用的返回码是 10054 (X'2746')。记录这些值并告诉系统管理员。
我查了 10054 并表示:
现有连接被远程主机强行关闭。
有谁知道我能做些什么来完成这项工作?我是否必须设置一个 MQC 选项才能写入?因为我不知道如何处理这些选项,所以我什至不确定这是否是问题所在。
请记住,我每次都会关闭我的连接:
public void Close()
{
queueMessage = null;
queue.Close();
qManager.Close();
}
~MQAccess()
{
queueMessage = null;
queue.Close();
qManager.Close();
}