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

Question

我正在制作一个用 C++ 编写的注入(inject) .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 被注入(inject)并连接到 C# 服务器，但当它收到一条消息时，它只是使注入(inject)它的应用程序崩溃。

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

Answer 1

一些事情。

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

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

The first option would be the easiest and for what it sounds like you are doing, it will scale fine. Here is a link to a simple sample to (a)http://msdn.microsoft.com/en-us/library/aa365588(VS.85).aspx

4- Make sure that your encodings match on both sides. For example, if your C++ code is compiled for Unicode, you must read the Pipe stream on the C# side using Unicode encoding. Some thing like the following.

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();
    }
  }
}