AnonymousPipeServerStream 类
定义
重要
一些信息与预发行产品相关，相应产品在发行之前可能会进行重大修改。 对于此处提供的信息，Microsoft 不作任何明示或暗示的担保。
公开匿名管道周围的流，该管道既支持同步读写操作，也支持异步读写操作。
public ref class AnonymousPipeServerStream sealed : System::IO::Pipes::PipeStreampublic sealed class AnonymousPipeServerStream : System.IO.Pipes.PipeStreamtype AnonymousPipeServerStream = class
inherit PipeStreamPublic NotInheritable Class AnonymousPipeServerStream
Inherits PipeStream- 继承
- 继承
示例
以下示例使用匿名管道将字符串从父进程发送到子进程。 此示例在父进程中PipeDirection创建AnonymousPipeServerStream值为 的对象PipeDirection.Out。它还会在AnonymousPipeClientStream子进程中PipeDirection创建值为 的对象PipeDirection.In。 接下来，父进程将用户提供的字符串发送给子进程。 字符串显示在控制台中。
此示例适用于使用 AnonymousPipeServerStream 类的服务器进程。 有关整个代码示例（包括管道客户端和服务器的代码），请参阅 如何：使用匿名管道进行本地进程间通信。
//<snippet01>
#using <System.dll>
#using <System.Core.dll>
using namespace System;
using namespace System::IO;
using namespace System::IO::Pipes;
using namespace System::Diagnostics;
ref class PipeServer
{
public:
static void Main()
{
Process^ pipeClient = gcnew Process();
pipeClient->StartInfo->FileName = "pipeClient.exe";
AnonymousPipeServerStream^ pipeServer =
gcnew AnonymousPipeServerStream(PipeDirection::Out,
HandleInheritability::Inheritable);
Console::WriteLine("[SERVER] Current TransmissionMode: {0}.",
pipeServer->TransmissionMode);
// Pass the client process a handle to the server.
pipeClient->StartInfo->Arguments =
pipeServer->GetClientHandleAsString();
pipeClient->StartInfo->UseShellExecute = false;
pipeClient->Start();
pipeServer->DisposeLocalCopyOfClientHandle();
try
{
// Read user input and send that to the client process.
StreamWriter^ sw = gcnew StreamWriter(pipeServer);
sw->AutoFlush = true;
// Send a 'sync message' and wait for client to receive it.
sw->WriteLine("SYNC");
pipeServer->WaitForPipeDrain();
// Send the console input to the client process.
Console::Write("[SERVER] Enter text: ");
sw->WriteLine(Console::ReadLine());
sw->Close();
}
// Catch the IOException that is raised if the pipe is broken
// or disconnected.
catch (IOException^ e)
{
Console::WriteLine("[SERVER] Error: {0}", e->Message);
}
pipeServer->Close();
pipeClient->WaitForExit();
pipeClient->Close();
Console::WriteLine("[SERVER] Client quit. Server terminating.");
}
};
int main()
{
PipeServer::Main();
}
//</snippet01>
//<snippet01>
using System;
using System.IO;
using System.IO.Pipes;
using System.Diagnostics;
class PipeServer
{
static void Main()
{
Process pipeClient = new Process();
pipeClient.StartInfo.FileName = "pipeClient.exe";
using (AnonymousPipeServerStream pipeServer =
new AnonymousPipeServerStream(PipeDirection.Out,
HandleInheritability.Inheritable))
{
Console.WriteLine("[SERVER] Current TransmissionMode: {0}.",
pipeServer.TransmissionMode);
// Pass the client process a handle to the server.
pipeClient.StartInfo.Arguments =
pipeServer.GetClientHandleAsString();
pipeClient.StartInfo.UseShellExecute = false;
pipeClient.Start();
pipeServer.DisposeLocalCopyOfClientHandle();
try
{
// Read user input and send that to the client process.
using (StreamWriter sw = new StreamWriter(pipeServer))
{
sw.AutoFlush = true;
// Send a 'sync message' and wait for client to receive it.
sw.WriteLine("SYNC");
pipeServer.WaitForPipeDrain();
// Send the console input to the client process.
Console.Write("[SERVER] Enter text: ");
sw.WriteLine(Console.ReadLine());
}
}
// Catch the IOException that is raised if the pipe is broken
// or disconnected.
catch (IOException e)
{
Console.WriteLine("[SERVER] Error: {0}", e.Message);
}
}
pipeClient.WaitForExit();
pipeClient.Close();
Console.WriteLine("[SERVER] Client quit. Server terminating.");
}
}
//</snippet01>
'<snippet01>
Imports System.IO
Imports System.IO.Pipes
Imports System.Diagnostics
Class PipeServer
Shared Sub Main()
Dim pipeClient As New Process()
pipeClient.StartInfo.FileName = "pipeClient.exe"
Using pipeServer As New AnonymousPipeServerStream(PipeDirection.Out, _
HandleInheritability.Inheritable)
Console.WriteLine("[SERVER] Current TransmissionMode: {0}.",
pipeServer.TransmissionMode)
' Pass the client process a handle to the server.
pipeClient.StartInfo.Arguments = pipeServer.GetClientHandleAsString()
pipeClient.StartInfo.UseShellExecute = false
pipeClient.Start()
pipeServer.DisposeLocalCopyOfClientHandle()
Try
' Read user input and send that to the client process.
Using sw As New StreamWriter(pipeServer)
sw.AutoFlush = true
' Send a 'sync message' and wait for client to receive it.
sw.WriteLine("SYNC")
pipeServer.WaitForPipeDrain()
' Send the console input to the client process.
Console.Write("[SERVER] Enter text: ")
sw.WriteLine(Console.ReadLine())
End Using
Catch e As IOException
' Catch the IOException that is raised if the pipe is broken
' or disconnected.
Console.WriteLine("[SERVER] Error: {0}", e.Message)
End Try
End Using
pipeClient.WaitForExit()
pipeClient.Close()
Console.WriteLine("[SERVER] Client quit. Server terminating.")
End Sub
End Class
'</snippet01>
注解
匿名管道有助于在子进程和父进程之间提供安全可靠的进程间通信。 类 AnonymousPipeServerStream 使父进程能够从子进程发送或接收信息。
匿名管道是未命名的单向管道，通常在父进程和子进程之间传输数据。 匿名管道始终是本地管道;它们不能通过网络使用。 PipeDirection不支持 值InOut，因为匿名管道定义为单向管道。
匿名管道不支持 PipeTransmissionMode.Message 读取模式。
匿名管道的客户端必须通过调用 GetClientHandleAsString 方法从服务器端提供的管道句柄创建。 然后，在创建客户端进程时，字符串将作为参数传递。 然后，在客户端进程中，它将作为 pipeHandleAsString 参数传递给AnonymousPipeClientStream构造函数。
对象 AnonymousPipeServerStream 必须使用 方法释放客户端句柄 DisposeLocalCopyOfClientHandle ，以便在客户端退出时收到通知。
构造函数
| AnonymousPipeServerStream() |
初始化 AnonymousPipeServerStream 类的新实例。 |
| AnonymousPipeServerStream(PipeDirection) |
使用指定的管道方向初始化 AnonymousPipeServerStream 类的新实例。 |
| AnonymousPipeServerStream(PipeDirection, HandleInheritability) |
使用指定的管道方向和继承模式初始化 AnonymousPipeServerStream 类的新实例。 |
| AnonymousPipeServerStream(PipeDirection, HandleInheritability, Int32) |
使用指定的管道方向、继承模式和缓冲区大小初始化 AnonymousPipeServerStream 类的新实例。 |
| AnonymousPipeServerStream(PipeDirection, HandleInheritability, Int32, PipeSecurity) |
使用指定的管道方向、继承模式、缓冲区大小和管道安全性初始化 AnonymousPipeServerStream 类的新实例。 |
| AnonymousPipeServerStream(PipeDirection, SafePipeHandle, SafePipeHandle) |
从指定的管道句柄初始化 AnonymousPipeServerStream 类的新实例。 |
属性
| CanRead |
获取一个值，该值指示当前流是否支持读操作。 (继承自 PipeStream) |
| CanSeek |
获取一个值，该值指示当前流是否支持查找操作。 (继承自 PipeStream) |
| CanTimeout |
获取一个值，该值确定当前流是否可以超时。 (继承自 Stream) |
| CanWrite |
获取一个值，该值指示当前流是否支持写操作。 (继承自 PipeStream) |
| ClientSafePipeHandle |
获取 AnonymousPipeClientStream 对象的安全句柄，当前该对象连接到 AnonymousPipeServerStream 对象。 |
| InBufferSize |
获取管道的入站缓冲区的大小（以字节为单位）。 (继承自 PipeStream) |
| IsAsync |
获取一个值，该值指示 PipeStream 对象是异步打开还是同步打开。 (继承自 PipeStream) |
| IsConnected |
获取或设置一个值，该值指示是否已连接 PipeStream 对象。 (继承自 PipeStream) |
| IsHandleExposed |
获取一个值，该值指示是否公开了 PipeStream 对象的句柄。 (继承自 PipeStream) |
| IsMessageComplete |
获取一个值，该值指示最近的读操作返回的消息中是否有更多数据。 (继承自 PipeStream) |
| Length |
获取流长度（以字节为单位）。 (继承自 PipeStream) |
| OutBufferSize |
获取管道的出站缓冲区的大小（以字节为单位）。 (继承自 PipeStream) |
| Position |
获取或设置当前流的当前位置。 (继承自 PipeStream) |
| ReadMode |
设置 AnonymousPipeServerStream 对象的读取模式。 对于匿名管道，传输模式必须为 Byte。 |
| ReadTimeout |
获取或设置一个值（以毫秒为单位），该值确定流在超时前将尝试读取的时间。 (继承自 Stream) |
| SafePipeHandle |
获取当前 PipeStream 对象所封装的本地管道末端的安全句柄。 (继承自 PipeStream) |
| TransmissionMode |
获取当前管道支持的管道传输模式。 |
| WriteTimeout |
获取或设置一个值（以毫秒为单位），该值确定流在超时前将尝试写入多长时间。 (继承自 Stream) |
方法
扩展方法
| GetAccessControl(PipeStream) |
返回管道流的安全信息。 |
| SetAccessControl(PipeStream, PipeSecurity) |
更改现有管道流的安全属性。 |
| ConfigureAwait(IAsyncDisposable, Boolean) |
配置如何执行从异步可处置项返回的任务的等待。 |
适用于
反馈
即将发布：在整个 2024 年，我们将逐步淘汰作为内容反馈机制的“GitHub 问题”，并将其取代为新的反馈系统。 有关详细信息，请参阅：https://aka.ms/ContentUserFeedback。
提交和查看相关反馈