Как отправлять сообщения между c ++ .dll и C # приложением, используя именованный канал? - PullRequest
Новая
       4

Как отправлять сообщения между c ++ .dll и C # приложением, используя именованный канал?

5 голосов
/ 23 апреля 2010

Я делаю закачанный .dll, написанный на C ++, и хочу общаться с приложением C #, используя именованные каналы.

Теперь я использую встроенные классы System.IO.Pipe .net в приложении C # и использую обычные функции в 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 Ответ

16 голосов
/ 24 апреля 2010

Несколько вещей.

1- Используете ли вы то же имя трубы
C ++: "\\. \ Pipe \ HyperPipe"
C #: "HyperPipe"

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

Первый вариант будет самым простым, и, как бы вы ни говорили, он будет хорошо масштабироваться. Вот ссылка на простой пример (а) http://msdn.microsoft.com/en-us/library/aa365588(VS.85).aspx

4- Убедитесь, что ваши кодировки совпадают с обеих сторон. Например, если ваш код C ++ скомпилирован для Unicode, вы должны прочитать поток Pipe на стороне C #, используя кодировку Unicode. Что-то вроде следующего. 

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

Обновление : поскольку я не работал с этим в C #, я подумал, что напишу небольшой тест. Просто используя блокировку труб без потоков или чего-то еще, просто чтобы подтвердить работу основы, вот очень грубый тестовый код.

C ++ Server 

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