名前付きパイプのプログラムを作成しています。
サーバー側(C++)のプログラムは以下の通りです。
#include <iostream>
#include <Windows.h>
DWORD createPipeThread( LPVOID lpParameter )
{
HANDLE pipe = ( (HANDLE*)lpParameter )[0];
HANDLE closeEvent = ( (HANDLE*)lpParameter )[1];
for( ;; ) {
OVERLAPPED overlapped;
size_t size = sizeof( OVERLAPPED );
std::memset( &overlapped, 0, size );
overlapped.hEvent = ::CreateEvent( nullptr, false, false, nullptr );
::ConnectNamedPipe( pipe, &overlapped );
HANDLE events[] = { overlapped.hEvent, closeEvent };
int eventIndex = ::WaitForMultipleObjects( 2, events, false, INFINITE ) - WAIT_OBJECT_0;
::CloseHandle( overlapped.hEvent );
if( eventIndex == 0 ){
std::wstring str = L"Hello, world";
DWORD result = 0;
::WriteFile( pipe, str.c_str(), ( str.length() + 1 ) * sizeof( wchar_t ), &result, nullptr );
::DisconnectNamedPipe( pipe );
} else {
break;
}
}
return 0;
}
int main()
{
HANDLE pipe = ::CreateNamedPipe( L"\\\\.\\pipe\\NamedPipeTest", PIPE_ACCESS_OUTBOUND | FILE_FLAG_OVERLAPPED, PIPE_WAIT | PIPE_READMODE_BYTE | PIPE_TYPE_BYTE, PIPE_UNLIMITED_INSTANCES, 1024, 1024, 1000, nullptr );
HANDLE closeEvent = ::CreateEvent( nullptr, false, false, nullptr );
HANDLE handles[] = { pipe, closeEvent };
HANDLE thread = ::CreateThread( nullptr, 0, (LPTHREAD_START_ROUTINE)createPipeThread, handles, 0, nullptr );
std::getchar();
::SetEvent( closeEvent );
::WaitForSingleObject( thread, 10000 );
::CloseHandle( closeEvent );
::CloseHandle( pipe );
}
クライアント側(C++)のコードは以下のとおりです。これは思ったとおり(Hello, Worldが出力される)に動きます。
#include <iostream>
#include <Windows.h>
int main()
{
HANDLE pipe = ::CreateFile( L"\\\\.\\pipe\\NamedPipeTest", GENERIC_READ, 0, nullptr, OPEN_EXISTING, 0, 0 );
if( pipe == INVALID_HANDLE_VALUE ) return 1;
const size_t bufSize = 1024;
wchar_t buf[bufSize];
std::memset( buf, 0, bufSize * sizeof( wchar_t ) );
DWORD result = 0;
::ReadFile( pipe, buf, bufSize * sizeof( wchar_t ), &result, nullptr );
std::wcout << buf << std::endl;
::CloseHandle( pipe );
return 0;
}
同様にクラアントをC#で書いたのですが、思ったとおりに動きません。何も出力されずに終わってしまいます。
namespace NamedPipeClientCSharp {
class Program {
static void Main( string[] args ) {
using( var pipe = new System.IO.Pipes.NamedPipeClientStream( ".", "NamedPipeTest", System.IO.Pipes.PipeDirection.In ) ) {
pipe.Connect();
/* NG 動作せず
byte[] buf = new byte[2048];
pipe.Read( buf, 0, 2048 );
System.Console.WriteLine( System.Text.Encoding.Unicode.GetString( buf ) );
*/
// NG 動作せず
using( var stream = new System.IO.StreamReader( pipe, System.Text.Encoding.Unicode ) )
System.Console.WriteLine( stream.ReadToEnd() );
}
}
}
}
stream.ReadToEnd()が空文字列を出力して終了してしまいます。
どのように修正すれば動くのかわかりましたら、教えていただけますでしょうか。
ReadToEnd()
ではなくC++と同様に1024文字読み取りをしてみてはどうでしょうか?