在同一台计算机上的 .net 应用程序之间传输大数据

Question

我有两个在同一台机器上运行的 .net 应用程序。 第一个应用程序是“引擎”。它构建图像 - 图像的大小约为 4M。 第二个应用程序是“查看器”。它显示了“引擎”发送的图像。 引擎每 10-15 秒发送一次图像。

我的问题是将图像从引擎传递给查看器的最糟糕的方法是什么。 目前，我正在为此使用 FileSystem。引擎将图像写入文件系统文件夹，查看器使用 FileSystemWatcher 获取此文件。

这种方法可以吗？这靠谱吗？

Answer 1

由于 .NET Framework 4.0 您可以为此使用内存映射文件，我相信它会比基于文件系统的方法更快，因为您不需要昂贵的文件系统 IO 操作。

内存映射文件包含虚拟文件的内容 记忆。文件和内存空间之间的这种映射使 应用程序，包括多个进程，通过以下方式修改文件 直接读取和写入内存。 内存映射文件可以在多个进程之间共享。进程可以使用创建文件的进程分配的通用名称映射到 > 相同的内存映射文件

所以要跨多个进程共享 MMF，您只需要共享一个 MMF 名称，因此您可以考虑以下方法：

• 引擎创建 MMF 文件并与查看器共享一个名称（字符串）
• 使用MemoryMappedFile.OpenExisting(sharedName)方法查看访问MMF（参见MSDN从不同进程访问相同MMF的示例）

有用的链接：

• Memory-Mapped Files
• Working with memory mapped files in .NET 4 - 强烈推荐阅读这篇文章，它描述了为什么 MMF 真的是 "is the most efficient way for multiple processes on a single machine to communicate with each other"。基本上它表明所有其他 IPC 选项都是基于 MMF 的。

（来自上述文章）如果我们检查其他 IPC 方法，我们可以看到以下架构：

Answer 2

有很多不错的选择：

• 消息队列
• 命名管道（直接）
• 内存映射文件
• 命名管道或 MSMQ 上的 WCF

其中任何一个都足够快，所以我建议最容易实现。

在我看来，消息队列 (MSMQ) 使用起来最简单，为您提供对象传输（与流相反）并为您提供可选的传输持久性（在发送方或接收方未运行的情况下很有用）。所有这些对于 WCF over MSMQ 来说都是正确的，但 WCF 意味着更多的开销、复杂性和涉及的配置，并且没有额外的（在这种情况下）价值。

这样发送：

MessageQueue queue = new MessageQueue(".\\private$\\ImagesQueue");
Message msg = new Message
{
    Formatter = new BinaryMessageFormatter(),
    Body = myImage,
    Label = "Image"
};
queue.Send(msg);

接收：

MessageQueue queue = new MessageQueue(".\\private$\\ImagesQueue");
msg = queue.Receive(TimeSpan.FromMilliseconds(100));
if (msg != null)
{
    msg.Formatter = new BinaryMessageFormatter();
    myImage = (MyImage)msg.Body;
}

使用前需要创建队列。您可以在应用程序启动时执行此操作

在你的课堂上有这个：

private const string queueName = ".\\private$\\ImagesQueue";

并且在应用程序初始化/启动中确保你有你的队列：

if (!MessageQueue.Exists(queueName)
{
    MessageQueue myQueue = MessageQueue.Create(queueName);
}

使用这种队列机制，引擎不必等待查看器完成。这将大大提高感知性能，因为您可以在仍查看前一张图像的同时生成下一张图像（实际上是其中的数量）。使用内存映射文件实现起来并不容易。

MSMQ 是标准的 Windows 组件，但需要在 Windows 功能中启用。

Answer 3

是的，这是一种有效的方法。并且假设您的代码不包含错误，是的，它是可靠的。

但它很慢。如果吞吐量是一个问题，您可能需要使用套接字（如果您想将引擎和查看器拆分到不同的机器）或命名管道（用于同一台机器上的进程间通信）。

Answer 4

使用ZeroMQ。它非常易于使用（如果您只发送一种消息，则比 WCF 更容易），没有太多开销，并且通常可以很好地解决许多进程间通信问题。