通过 MSMQ 到 WCF Web 服务的日志缓冲

Question

我手头上有一个有趣的情况。几年来，我们已经拥有一个 WCF 服务，该服务在我们网络上的 IIS 机器上运行，用于记录日志。应用程序使用 basicHttpBinding 发送日志消息并将其记录到数据库中。来自所有其他应用程序的大多数日志记录仅限于每个操作的几十个日志。最近，我们移植了另一个应用程序来使用此日志记录服务。该应用程序的日志记录比我们的日志记录服务的任何其他客户端都更加积极。它有一个操作，在其过程中可以记录超过 100,000 条消息（这是通过 CSV 文件导入 100,000 条记录）。

在试图找到一种方法来使其更有效地运行时，建议我尝试 MSMQ 将日志请求排队并将它们转发到服务，而不是让应用程序直接与日志记录服务通信（请求是< /em> 出于性能目的在单独的线程中发送）。这样，在写入日志时应用程序就不会被阻止。我已经在本地计算机上实现了这个 MSMQ 解决方案的概念验证，但由于我以前从未使用过 MSMQ，而且我现在才了解它在技术上的地位，所以我发现自己有很多问题和很少的答案。我希望有人可以向我指出一些有关 MSMQ 如何工作的简明信息，以便我可以更好地调试我编写的这个概念证明。

实施 MSMQ 后我看到的是：

• 我的应用程序将日志发送到 MSMQ 几乎立即返回 （而不是等待日志 致力于）这就是我想要的。
• 即使我发送了 1000 条日志到 MSMQ应用少于30个 秒，需要几分钟 所有 1000 个日志才能到达 数据库。看起来好像我的 队列有某种限制 启用它阻碍的地方 记录请求，但我不知道如何/在哪里检查。
• 如果我在从 MSMQ 服务接收日志的服务器上使用 net.tcp，我会收到大量服务超时错误，并且只有 90%（左右）的日志会发送到数据库，但如果我使用 basicHttpBinding，它会可靠地工作。

这是我的 MSMQ 服务中的代码：

public void QueueLog(Log log)
{
    try
    {
        ServiceClient writeLog = getLoggingService();

        string exceptionText = log.Exception == null ? string.Empty : log.Exception.ToString();
        writeLog.WriteCompatibleLog(log.LoggerName, (LoggingService.Logging.LogType)log.LogType, exceptionText, log.Message, log.ApplicationName, Utility.GetAssemblyVersion(Assembly.GetCallingAssembly()),
            Utility.GetFirstIPAddress(), Utility.GetHostName(), log.Category);
    }
    catch (Exception ex)
    {
        Debug.WriteLine("LoggingServiceWrapper.DotNet Error\n\n" + ex.GetBaseException().Message + "\n\n" + ex.GetBaseException().StackTrace);
    }
}

private ServiceClient getLoggingService()
{
    return new ServiceClient(new BasicHttpBinding(), new EndpointAddress("http://MyServer/Service.svc"));

}

这是我创建 MSMQ 服务的代码

if (!MessageQueue.Exists(Properties.Settings.Default.QueueName))
{
    MessageQueue.Create(Properties.Settings.Default.QueueName, true);
}

ServiceHost serviceHost = new ServiceHost(typeof(LoggingServiceQueue.LoggingServiceQueue), new Uri(Properties.Settings.Default.Address));
{
    serviceHost.Open();

    Console.ReadLine();

    serviceHost.Close();
}

这是我用来调用 MSMQ 服务的应用程序中的代码：

LoggingServiceQueueClient client = new LoggingServiceQueueClient(new NetMsmqBinding(NetMsmqSecurityMode.None), new EndpointAddress("net.msmq://localhost/private/Logging"));

client.QueueLog(new LoggingServiceQueue.Log
{
    LoggerName = loggerName,
    LogType = (LoggingServiceQueue.LogType)logType,
    ApplicationName = applicationName,
    Category = category,
    Exception = exception,
    Message = message,
    SourceHostName = Utility.GetHostName(),
    SourceIp = Utility.GetFirstIPAddress(),
    Version = Utility.GetAssemblyVersion(callingAssembly)
});

我感谢有人可以提供的任何帮助。我不太清楚使用 MSMQ 可以使用哪些功能。我通过谷歌做了大约 6 个小时的研究。我发现的大多数文档都很旧（2007 年）并且读起来很困难。也许他们希望我对这个主题有一些基础知识。

Answer 1

您所看到的（如果您在 WCF 上使用 net.msmq 绑定）就是设计的结果。

MSMQ 作为存储转发工具，会将消息存储在发送客户端和接收服务器的队列中，直到网络或处理带宽可用。这样做的作用是通过使进程异步来减轻客户端的负载（正如您所观察到的）。

您可以使用性能监视器查看队列的状态，出站队列（在客户端）和服务器队列中的消息数量会实时写入性能计数器，并且可以查看和/或记录。

如果性能不是最佳的，您可以更改 WCF 限制设置，以允许服务行为中有更多并发连接。

例如

<serviceThrottling
         maxConcurrentCalls="20"
         maxConcurrentSessions="20"
         maxConcurrentInstances="20"
       />