更新:ここでプロトコルを調べてみると、Unsized Envelope Record に何が入っているのかわかりません。オンラインで例が見つかりません。
オリジナル：
次のWCFサービスがあります
static void Main(string[] args)
{
var inst = new PlusFiver();
using (ServiceHost host = new ServiceHost(inst,
new Uri[] { new Uri("net.pipe://localhost") }))
{
host.AddServiceEndpoint(typeof(IPlusFive), new NetNamedPipeBinding(NetNamedPipeSecurityMode.None), "PipePlusFive");
host.Open();
Console.WriteLine("Service is Available. Press enter to exit.");
Console.ReadLine();
host.Close();
}
}
[ServiceContract]
public interface IPlusFive
{
[OperationContract]
int PlusFive(int value);
}
[ServiceBehavior(InstanceContextMode = InstanceContextMode.Single)]
public class PlusFiver : IPlusFive
{
public int PlusFive(int value)
{
Console.WriteLine("Adding 5 to " + value);
return value + 5;
}
}
サーバーがリクエストを処理したかどうかがわかるように、追加の 5 行を出力します。
これをテストするために使用した.NETクライアントがあり、すべてが期待どおりに機能します。
ここで、このためにアンマネージ C++ クライアントを作成したいと考えています。
パイプの名前を取得して書き込む方法を見つけました。ここ
からプロトコルをダウンロードしました
パイプに書き込むことはできますが、読み取ることはできません。そこから読み取ろうとすると、ERROR_BROKEN_PIPE 109 (0x6D) The pipe has been ended.エラーが発生します。読み取りを書き込みに置き換えると、書き込みは成功するので、少なくとも読み取りを試みるまでは、パイプが閉じているとは思いません。
これが私がパイプに接続する方法です。
HANDLE OpenPipe(OLECHAR* bstrGuid)
{
wstring pipeName = L"\\\\.\\pipe\\";
wstring strGuid = bstrGuid;
pipeName.append(strGuid.substr(1,36));
wcout << "Pipe Name " << endl;
wcout << pipeName.c_str() << endl;
HANDLE hPipe = CreateFile(pipeName.c_str(), GENERIC_WRITE | GENERIC_READ, FILE_SHARE_WRITE | FILE_SHARE_READ, NULL, OPEN_EXISTING, NULL, NULL);
if(hPipe == INVALID_HANDLE_VALUE)
{
wcout << "failed to create pipe" << endl;
system("pause");
return NULL;
}
return hPipe;
}
これは、私が送信する最初のメッセージを作成する方法です
std::list<wchar_t> GetFirstMessage()
{
std::list<wchar_t> message;
message.push_back(0x00);// version record
message.push_back(0x01);// major version
message.push_back(0x00);// minor version
message.push_back(0x01);// mode record
message.push_back(0x01);// singleton-unsized mode
message.push_back(0x02);// via record
wstring url = L"net.pipe://localhost/PipePlusFive";
message.push_back(url.length());// via length
for(int x= 0;x<url.length();x++)
{
message.push_back(url[x]); // via
}
message.push_back(0x03);
message.push_back(0x08);
return message;
}
これは、ファイルに書き込む方法です。
int WriteMessage(HANDLE hPipe, LPVOID message, int size)
{
DWORD bytesWritten;
BOOL bWrite = WriteFile(hPipe, &message, size, &bytesWritten, NULL);
wcout << "Bytes Written: " << bytesWritten << endl;
if(bWrite == false)
{
wcout << "fail"<<endl;
CloseHandle(hPipe);
system("pause");
return 1;
}
return 0;
}
list<wchar_t> full_message = GetFirstMessage();
int result = WriteMessage(hPipe, &full_message, full_message.size());
if (result == 1)
{ return 1;}
これが私がエンドメッセージを書いている方法です
wchar_t message = 12;
result = WriteMessage(hPipe, &message, 1);
if (result == 1)
{ return 1;}
これが私が応答を読み取ろうとしている方法です
char buffer[10];
DWORD bytesRead;
BOOL bRead = ReadFile(hPipe, buffer, 1, &bytesRead, NULL);
if(bRead == false)
{
wcout << "fail read"<<endl;
wcout << "error: " << GetLastError() << endl;
CloseHandle(hPipe);
system("pause");
return 1;
}
私はC ++を初めて使用するので、プロトコルに正しく従っていないのか、これをやろうとしているときに愚かな間違いを犯しているのかわかりませんか?
更新: 問題は、リストの内容ではなく、名前付きパイプへのポインター アドレスを書き込んでいたことでした。私はそれを修正し、プリアンブル Ack レコードを読み取ることができるようになりました。ここで、プロトコルの次の部分で何を送信する必要があるかを把握する必要があります。