如何使用命名管道在 c++ .dll 和 C# 应用程序之间发送消息？

我正在制作一个用 C++ 编写的注入 .dll，并且我想使用命名管道与 C# 应用程序进行通信。

现在，我在 C# 应用程序中使用内置的 System.IO.Pipe .net 类，并在 C++ 中使用常规函数。

我在 C++ 方面没有太多经验（阅读：这是我的第一个 C++ 代码..），但我在 C# 方面经验丰富。

看来与服务器和客户端的连接正常，唯一的问题是消息没有发送。我尝试将 .dll 设置为服务器，将 C# 应用程序设置为服务器，将管道方向设置为 InOut（双工），但似乎都不起作用。

当我尝试将 .dll 设置为服务器（向 C# 应用程序发送消息）时，我使用的代码如下：

DWORD ServerCreate() // function to create the server and wait till it successfully creates it to return.
{
    hPipe = CreateNamedPipe(pipename,//The unique pipe name. This string must have the following form:  \\.\pipe\pipename
    PIPE_ACCESS_DUPLEX, 
    PIPE_TYPE_MESSAGE | PIPE_READMODE_MESSAGE | PIPE_NOWAIT, //write and read and return right away
    PIPE_UNLIMITED_INSTANCES,//The maximum number of instances that can be created for this pipe
    4096 , // output time-out 
    4096 , // input time-out 
    0,//client time-out 
    NULL);

   if(hPipe== INVALID_HANDLE_VALUE)
   {
    return 1;//failed
   }
   else
    return 0;//success
}

void SendMsg(string msg)
{
    DWORD cbWritten;
    WriteFile(hPipe,msg.c_str(), msg.length()+1, &cbWritten,NULL);
}

void ProccesingPipeInstance()
{
    while(ServerCreate() == 1)//if failed
{
    Sleep(1000);    
}

//if created success, wait to connect
ConnectNamedPipe(hPipe, NULL);
for(;;)
{
    SendMsg("HI!");
    if( ConnectNamedPipe(hPipe, NULL)==0)
        if(GetLastError()==ERROR_NO_DATA)
        {
            DebugPrintA("previous closed,ERROR_NO_DATA");
            DisconnectNamedPipe(hPipe);
            ConnectNamedPipe(hPipe, NULL);
        }
    Sleep(1000);

}

C# 客户端是这样的：

static void Main(string[] args)
    {
        Console.WriteLine("Hello!");

        using (var pipe = new NamedPipeClientStream(".", "HyprPipe", PipeDirection.In))
        {
            Console.WriteLine("Created Client!");

            Console.Write("Connecting to pipe server in the .dll ...");
            pipe.Connect();

            Console.WriteLine("DONE!");

            using (var pr = new StreamReader(pipe))
            {
                string t;
                while ((t = pr.ReadLine()) != null)
                {
                    Console.WriteLine("Message: {0}",t);
                }
            }
        }
    }

我看到 C# 客户端连接到 .dll，但它不会收到任何消息。 正如我之前所说，我尝试以相反的方式进行操作，并尝试让 C# 向 .dll 发送消息，这将在消息框中显示它们。 .dll 被注入并连接到 C# 服务器，但当它收到消息时，它只是使注入的应用程序崩溃。

请帮助我，或指导我如何在 C++ 和 C# 应用程序之间使用命名管道

一些东西。

1-您是否使用相同的管道名称
C++：“\\.\pipe\HyperPipe”
C#：“超级管道”

2-我认为在 C# 方面，使用 ReadToEnd() 可能更好，我只在 C++ 中使用过命名管道，但我认为 ReadToEnd() 会读取消息，因为您正在使用消息 为基础的管道。

3-在C++方面，您尝试使用非阻塞管道并轮询管道以获取连接和数据等。我建议三件事之一。

  a - Use a blocking pipe on a separate thread or
  b - Use non blocking pipes using Overlapped IO
  c - Use non blocking pipes using IOCompletion ports
  

第一个选项是最简单的，对于听起来你正在做的事情来说，它会很好地扩展。这是一个简单示例的链接 (a)http://msdn.microsoft.com/en-us/library/aa365588(VS.85).aspx http://msdn.microsoft.com/en-us/library/aa365588(VS.85).aspx

4- 确保双方的编码匹配。例如，如果您的 C++ 代码是针对 Unicode 编译的，则必须使用 Unicode 编码读取 C# 端的 Pipe 流。 像下面这样的一些事情。

using (StreamReader rdr = new StreamReader(pipe, System.Text.Encoding.Unicode))
{
  System.Console.WriteLine(rdr.ReadToEnd());
}

Update：由于我没有在 C# 中使用过这个，所以我想我应该编写一个小测试。只是使用阻塞管道，没有线程或任何东西，只是为了确认基础工作，这里是非常粗略的测试代码。

C++服务器

#include <tchar.h>
#include <windows.h>

int _tmain(int argc, _TCHAR* argv[])
{
  HANDLE hPipe = ::CreateNamedPipe(_T("\\\\.\\pipe\\HyperPipe"),
    PIPE_ACCESS_DUPLEX,
    PIPE_TYPE_MESSAGE | PIPE_READMODE_MESSAGE,
    PIPE_UNLIMITED_INSTANCES,
    4096,
    4096,
    0,
    NULL);


  ConnectNamedPipe(hPipe, NULL);

  LPTSTR data = _T("Hello");
  DWORD bytesWritten = 0;
  WriteFile(hPipe, data, _tcslen(data) * sizeof(TCHAR), &bytesWritten, NULL);
  CloseHandle(hPipe);
  return 0;
}

C# 客户端

using System;
using System.Text;
using System.IO;
using System.IO.Pipes;

namespace CSPipe
{
  class Program
  {
    static void Main(string[] args)
    {
      NamedPipeClientStream pipe = new NamedPipeClientStream(".", "HyperPipe", PipeDirection.InOut);
      pipe.Connect();
      using (StreamReader rdr = new StreamReader(pipe, Encoding.Unicode))
      {
        System.Console.WriteLine(rdr.ReadToEnd());
      }

      Console.ReadKey();
    }
  }
}