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

Question

我正在制作一个用 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# 应用程序之间使用命名管道

Answer 1

一些事情。

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

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

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

a - 在单独的线程上使用阻塞管道或 b - 使用 Overlapped IO 使用非阻塞管道 c - 使用 IOCompletion 端口使用非阻塞管道

第一个选项将是最简单的，并且听起来像您正在做的事情，它可以很好地扩展。这是一个指向 (a) 的简单示例的链接 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());
}

更新：由于我没有在 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();
    }
  }
}