MQ消息有时没有下载，建议使用任何远程MQ监控工具

Question

我编写了连接远程 MQ 并下载消息的代码，但有时缺少一些消息。我正在发布我的代码。谁能告诉我这段代码有什么错误

using IBM.WMQ;

internal class MQReader
{
    private static MQQueueManager queueManager;
    private static MQMessage queueMessage;
    private static MQGetMessageOptions queueGetMessageOptions;
    private static MQQueue queue;
    static string strReturn = "";
    static string message = "";
    static string mqexception = "";
    static string connerror = "";
    static string QueueName;
    static string QueueManagerName;
    static string ChannelInfo;
    static string channelName;
    static string PortNumber;
    static string transportType;
    static string connectionName;
    static bool running;
    static bool conresult;
    static string checkconnexp;
    static bool connerrorflag;
    static bool checkconnresult;

    public static bool connectMQ()
    {
        bool flag;
        QueueManagerName = ConfigurationManager.AppSettings["QueueManager"];
        QueueName = ConfigurationManager.AppSettings["Queuename"];
        ChannelInfo = ConfigurationManager.AppSettings["ChannelInformation"];
        PortNumber = ConfigurationManager.AppSettings["Port"];
        char[] separator = { '/' };
        string[] ChannelParams;
        ChannelParams = ChannelInfo.Split(separator);
        channelName = ConfigurationManager.AppSettings["Channel"];
        transportType = ConfigurationManager.AppSettings["TransportType"];
        connectionName = ConfigurationManager.AppSettings["ConnectionName"];

        try
        {
            queueManager = new MQQueueManager(QueueManagerName,
                channelName, connectionName);
            queue = queueManager.AccessQueue(QueueName,
                MQC.MQOO_INPUT_AS_Q_DEF + MQC.MQOO_FAIL_IF_QUIESCING);
            connerror = "Connected Successfully";
            flag = true;
        }
        catch (MQException connectionexp)
        {
            connerror = "Exception: " + connectionexp.Message;
            logFile(connerror);
            flag = false;
        }

        return flag;
    }

    private static void logFile(string errormsg)
    {
        string path = ConfigurationManager.AppSettings["logFilePath"];
        string fileName = path + "MQLog" + DateTime.Now.Date.ToString("yyyyMMdd") + ".txt";
        System.IO.File.AppendAllText(fileName, errormsg + Environment.NewLine);
    }

    public static void getMessage()
    {
        conresult = connectMQ();
        running = true;

        while (running)
        {
            if (conresult == true)
            {
                try
                {
                    queueMessage = new MQMessage();
                    queueMessage.Format = MQC.MQFMT_STRING;
                    queueGetMessageOptions = new MQGetMessageOptions();
                    queueGetMessageOptions.Options |= MQC.MQGMO_WAIT | MQC.MQGMO_FAIL_IF_QUIESCING;
                    queueGetMessageOptions.WaitInterval = 60000;
                    queue.Get(queueMessage, queueGetMessageOptions);
                    message = queueMessage.ReadString(queueMessage.MessageLength);
                }
                catch (MQException exp)
                {
                    mqexception = exp.Message;
                    message = "Exception: " + mqexception;
                }

                if (message != "Exception: " + mqexception)
                {
                    string path = ConfigurationManager.AppSettings["xmlFilePath"];
                    string fileName = path + "MQMessage" + DateTime.Now.ToString("yyyyMMddHHmmssfff") + ".xml";
                    System.IO.File.WriteAllText(fileName, message);         
                }
                else   
                {
                    logFile(message);
                    queueManager.Close();
                    queueManager.Disconnect();
                    conresult = false;
                }
            }

            if (conresult == false)
            {                   
                conresult = connectMQ();
            }
        }
    }

    public void InitializeConnections()
    {
        getMessage();
    }       

    public void StopIt()
    {
        queueManager.Disconnect();
        running = false;
    }
}

有时消息未下载或丢失到本地目录。所有连接代码都是来自 web.config 的凭据。

编辑 请建议任何远程 mq 监控工具，它会在消息发送到 mq 和下载消息时进行记录。任何 power shell 脚本或任何工具都可以。

Answer 1

我会很有礼貌，只对那个代码说“Yuk”。

首先，C# 是一门面向对象的语言，因此您应该学习如何使用 try、catch 和 finally。

if (message != "Exception: " + mqexception)

那是什么？这不是您进行字符串比较的方式，为什么 try{} 部分中没有该代码？

string fileName = path + "MQMessage" + DateTime.Now.ToString("yyyyMMddHHmmssfff") + ".xml";

嗯。你没有丢失你的信息，你把它们扔掉了。如果您在同一毫秒内收到 2 条或更多消息会发生什么？

来自 Write​All​Text 的文档：

创建一个新文件，将内容写入文件，然后关闭 文件。如果目标文件已经存在，则覆盖。

因此，这意味着当您在同一毫秒内收到 2 条或更多消息时，下一条消息会覆盖前一条消息。