Я делаю введенный .dll записанным в C++, и я хочу общаться с приложением C# с помощью именованных каналов.
Теперь, я использую созданный в Системе. IO.Pipe классы .NET в приложении C#, и я использую регулярные функции в C++.
У меня нет большого опыта в C++ (Read: Это - мой первый код C++..), tho я испытан в 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 #: "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 ++
#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();
}
}
}