AnonymousPipeServerStream Klasa

Definicja

Przestrzeń nazw:

System.IO.Pipes

Zestaw:

System.IO.Pipes.dll

Źródło:

AnonymousPipeServerStream.cs

Uwidacznia strumień wokół potoku anonimowego, który obsługuje zarówno operacje synchroniczne, jak i asynchroniczne odczytu i zapisu.

public ref class AnonymousPipeServerStream sealed : System::IO::Pipes::PipeStream

public sealed class AnonymousPipeServerStream : System.IO.Pipes.PipeStream

type AnonymousPipeServerStream = class
    inherit PipeStream

Public NotInheritable Class AnonymousPipeServerStream
Inherits PipeStream

Dziedziczenie

Object

MarshalByRefObject

Stream

PipeStream

AnonymousPipeServerStream

Przykłady

Poniższy przykład wysyła ciąg z procesu nadrzędnego do procesu podrzędnego przy użyciu potoków anonimowych. W tym przykładzie tworzony jest obiekt AnonymousPipeServerStream w procesie nadrzędnym z wartością PipeDirectionPipeDirection.Out. Tworzy również obiekt AnonymousPipeClientStream w procesie podrzędnym z wartością PipeDirectionPipeDirection.In. Proces nadrzędny wysyła następnie ciąg dostarczony przez użytkownika do procesu podrzędnego. Ciąg jest wyświetlany w konsoli programu .

Ten przykład dotyczy procesu serwera, który używa klasy AnonymousPipeServerStream. Dla całego przykładu kodu, w tym kodu dla klienta potoku i serwera, zobacz How to: Use Anonymous Pipe for Local Interprocess Communication.

//<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>

Uwagi

Potoki anonimowe pomagają zapewnić bezpieczną i bezpieczną komunikację między procesami podrzędnymi i nadrzędnymi. Klasa AnonymousPipeServerStream umożliwia procesowi nadrzędnego wysyłanie lub odbieranie informacji z procesu podrzędnego.

Potoki anonimowe to nienazwane potoki jednokierunkowe, które zwykle przesyłają dane między procesami nadrzędnymi i podrzędnymi. Potoki anonimowe są zawsze lokalne; nie można ich używać za pośrednictwem sieci. Wartość PipeDirectionInOut nie jest obsługiwana, ponieważ potoki anonimowe są definiowane jako jednokierunkowe.

Potoki anonimowe nie obsługują trybu odczytu PipeTransmissionMode.Message.

Po stronie klienta potoku anonimowego należy utworzyć z uchwytu potoku dostarczonego przez serwer po stronie serwera przez wywołanie metody GetClientHandleAsString. Ciąg jest następnie przekazywany jako parametr podczas tworzenia procesu klienta. Następnie proces klienta jest przekazywany do konstruktora AnonymousPipeClientStream jako parametru pipeHandleAsString.

Obiekt AnonymousPipeServerStream musi usunąć dojście klienta przy użyciu metody DisposeLocalCopyOfClientHandle, aby otrzymywać powiadomienia po zakończeniu pracy klienta.

Konstruktory

AnonymousPipeServerStream()	Inicjuje nowe wystąpienie klasy AnonymousPipeServerStream.
AnonymousPipeServerStream(PipeDirection)	Inicjuje nowe wystąpienie klasy AnonymousPipeServerStream z określonym kierunkiem potoku.
AnonymousPipeServerStream(PipeDirection, HandleInheritability)	Inicjuje nowe wystąpienie klasy AnonymousPipeServerStream z określonym kierunkiem potoku i trybem dziedziczenia.
AnonymousPipeServerStream(PipeDirection, HandleInheritability, Int32)	Inicjuje nowe wystąpienie klasy AnonymousPipeServerStream z określonym kierunkiem potoku, trybem dziedziczenia i rozmiarem buforu.
AnonymousPipeServerStream(PipeDirection, SafePipeHandle, SafePipeHandle)	Inicjuje nowe wystąpienie klasy AnonymousPipeServerStream z określonych uchwytów potoku.

Właściwości

CanRead	Pobiera wartość wskazującą, czy bieżący strumień obsługuje operacje odczytu. (Odziedziczone po PipeStream)
CanSeek	Pobiera wartość wskazującą, czy bieżący strumień obsługuje operacje wyszukiwania. (Odziedziczone po PipeStream)
CanTimeout	Pobiera wartość określającą, czy bieżący strumień może upłynął limit czasu. (Odziedziczone po Stream)
CanWrite	Pobiera wartość wskazującą, czy bieżący strumień obsługuje operacje zapisu. (Odziedziczone po PipeStream)
ClientSafePipeHandle	Pobiera bezpieczny uchwyt dla obiektu AnonymousPipeClientStream, który jest obecnie połączony z obiektem AnonymousPipeServerStream.
InBufferSize	Pobiera rozmiar w bajtach buforu przychodzącego dla potoku. (Odziedziczone po PipeStream)
IsAsync	Pobiera wartość wskazującą, czy obiekt PipeStream został otwarty asynchronicznie lub synchronicznie. (Odziedziczone po PipeStream)
IsConnected	Pobiera lub ustawia wartość wskazującą, czy obiekt PipeStream jest połączony. (Odziedziczone po PipeStream)
IsHandleExposed	Pobiera wartość wskazującą, czy dojście do obiektu PipeStream jest uwidocznione. (Odziedziczone po PipeStream)
IsMessageComplete	Pobiera wartość wskazującą, czy w komunikacie zwróconym z najnowszej operacji odczytu jest więcej danych. (Odziedziczone po PipeStream)
Length	Pobiera długość strumienia w bajtach. (Odziedziczone po PipeStream)
OutBufferSize	Pobiera rozmiar w bajtach buforu wychodzącego dla potoku. (Odziedziczone po PipeStream)
Position	Pobiera lub ustawia bieżącą pozycję bieżącego strumienia. (Odziedziczone po PipeStream)
ReadMode	Ustawia tryb odczytu dla obiektu AnonymousPipeServerStream. W przypadku potoków anonimowych tryb transmisji musi być Byte.
ReadTimeout	Pobiera lub ustawia wartość w milisekundach, która określa, jak długo strumień będzie próbował odczytać przed upływem limitu czasu. (Odziedziczone po Stream)
SafePipeHandle	Pobiera bezpieczny uchwyt dla lokalnego końca potoku, który jest hermetyzowany przez bieżący obiekt PipeStream. (Odziedziczone po PipeStream)
TransmissionMode	Pobiera tryb transmisji potoku obsługiwany przez bieżący potok.
WriteTimeout	Pobiera lub ustawia wartość w milisekundach, która określa, jak długo strumień będzie próbował zapisać przed upływem limitu czasu. (Odziedziczone po Stream)

Metody

BeginRead(Byte[], Int32, Int32, AsyncCallback, Object)	Rozpoczyna operację odczytu asynchronicznego. (Odziedziczone po PipeStream)
BeginWrite(Byte[], Int32, Int32, AsyncCallback, Object)	Rozpoczyna asynchroniczną operację zapisu. (Odziedziczone po PipeStream)
CheckPipePropertyOperations()	Sprawdza, czy potok jest w odpowiednim stanie do pobierania lub ustawiania właściwości. (Odziedziczone po PipeStream)
CheckReadOperations()	Sprawdza, czy potok jest w stanie połączonym dla operacji odczytu. (Odziedziczone po PipeStream)
CheckWriteOperations()	Sprawdza, czy potok jest w stanie połączonym dla operacji zapisu. (Odziedziczone po PipeStream)
Close()	Zamyka bieżący strumień i zwalnia wszystkie zasoby (takie jak gniazda i dojścia plików) skojarzone z bieżącym strumieniem. Zamiast wywoływać tę metodę, upewnij się, że strumień jest prawidłowo usuwany. (Odziedziczone po Stream)
CopyTo(Stream)	Odczytuje bajty z bieżącego strumienia i zapisuje je w innym strumieniu. Obie pozycje strumieni są zaawansowane przez liczbę skopiowanych bajtów. (Odziedziczone po Stream)
CopyTo(Stream, Int32)	Odczytuje bajty z bieżącego strumienia i zapisuje je w innym strumieniu przy użyciu określonego rozmiaru buforu. Obie pozycje strumieni są zaawansowane przez liczbę skopiowanych bajtów. (Odziedziczone po Stream)
CopyToAsync(Stream)	Asynchronicznie odczytuje bajty z bieżącego strumienia i zapisuje je w innym strumieniu. Obie pozycje strumieni są zaawansowane przez liczbę skopiowanych bajtów. (Odziedziczone po Stream)
CopyToAsync(Stream, CancellationToken)	Asynchronicznie odczytuje bajty z bieżącego strumienia i zapisuje je w innym strumieniu przy użyciu określonego tokenu anulowania. Obie pozycje strumieni są zaawansowane przez liczbę skopiowanych bajtów. (Odziedziczone po Stream)
CopyToAsync(Stream, Int32)	Asynchronicznie odczytuje bajty z bieżącego strumienia i zapisuje je w innym strumieniu przy użyciu określonego rozmiaru buforu. Obie pozycje strumieni są zaawansowane przez liczbę skopiowanych bajtów. (Odziedziczone po Stream)
CopyToAsync(Stream, Int32, CancellationToken)	Asynchronicznie odczytuje bajty z bieżącego strumienia i zapisuje je w innym strumieniu przy użyciu określonego rozmiaru buforu i tokenu anulowania. Obie pozycje strumieni są zaawansowane przez liczbę skopiowanych bajtów. (Odziedziczone po Stream)
CreateObjRef(Type)	Tworzy obiekt zawierający wszystkie istotne informacje wymagane do wygenerowania serwera proxy używanego do komunikowania się z obiektem zdalnym. (Odziedziczone po MarshalByRefObject)
CreateWaitHandle()	Przestarzałe. Przydziela obiekt WaitHandle. (Odziedziczone po Stream)
Dispose()	Zwalnia wszystkie zasoby używane przez Stream. (Odziedziczone po Stream)
Dispose(Boolean)	Zwalnia niezarządzane zasoby używane przez klasę PipeStream i opcjonalnie zwalnia zarządzane zasoby. (Odziedziczone po PipeStream)
DisposeAsync()	Asynchronicznie zwalnia niezarządzane zasoby używane przez Stream. (Odziedziczone po Stream)
DisposeLocalCopyOfClientHandle()	Zamyka lokalną kopię uchwytu obiektu AnonymousPipeClientStream.
EndRead(IAsyncResult)	Kończy oczekujące żądanie odczytu asynchronicznego. (Odziedziczone po PipeStream)
EndWrite(IAsyncResult)	Kończy oczekujące żądanie asynchronicznego zapisu. (Odziedziczone po PipeStream)
Equals(Object)	Określa, czy określony obiekt jest równy bieżącemu obiektowi. (Odziedziczone po Object)
Finalize()	Zwalnia niezarządzane zasoby i wykonuje inne operacje oczyszczania przed odzyskaniem wystąpienia AnonymousPipeServerStream przez odzyskiwanie pamięci.
Flush()	Czyści bufor dla bieżącego strumienia i powoduje zapisanie wszystkich buforowanych danych na urządzeniu źródłowym. (Odziedziczone po PipeStream)
FlushAsync()	Asynchronicznie czyści wszystkie dla tego strumienia i powoduje zapisanie wszystkich buforowanych danych na urządzeniu bazowym. (Odziedziczone po Stream)
FlushAsync(CancellationToken)	Asynchronicznie czyści bufor dla bieżącego strumienia i powoduje zapisanie wszystkich buforowanych danych na urządzeniu bazowym. (Odziedziczone po PipeStream)
GetAccessControl()	Pobiera obiekt PipeSecurity, który hermetyzuje wpisy listy kontroli dostępu (ACL) dla potoku opisanego przez bieżący obiekt PipeStream. (Odziedziczone po PipeStream)
GetClientHandleAsString()	Pobiera połączony uchwyt obiektu AnonymousPipeClientStream jako ciąg.
GetHashCode()	Służy jako domyślna funkcja skrótu. (Odziedziczone po Object)
GetLifetimeService()	Przestarzałe. Pobiera bieżący obiekt usługi okresu istnienia, który kontroluje zasady okresu istnienia dla tego wystąpienia. (Odziedziczone po MarshalByRefObject)
GetType()	Pobiera Type bieżącego wystąpienia. (Odziedziczone po Object)
InitializeHandle(SafePipeHandle, Boolean, Boolean)	Inicjuje obiekt PipeStream z określonego obiektu SafePipeHandle. (Odziedziczone po PipeStream)
InitializeLifetimeService()	Przestarzałe. Uzyskuje obiekt usługi okresu istnienia w celu kontrolowania zasad okresu istnienia dla tego wystąpienia. (Odziedziczone po MarshalByRefObject)
MemberwiseClone()	Tworzy płytkią kopię bieżącego Object. (Odziedziczone po Object)
MemberwiseClone(Boolean)	Tworzy płytkią kopię bieżącego obiektu MarshalByRefObject. (Odziedziczone po MarshalByRefObject)
ObjectInvariant()	Przestarzałe. Zapewnia obsługę Contract. (Odziedziczone po Stream)
Read(Byte[], Int32, Int32)	Odczytuje blok bajtów ze strumienia i zapisuje dane w określonym buforze rozpoczynającym się od określonej pozycji dla określonej długości. (Odziedziczone po PipeStream)
Read(Span<Byte>)	Odczytuje sekwencję bajtów z bieżącego strumienia, zapisuje je w tablicy bajtów i rozwija pozycję w strumieniu według liczby odczytanych bajtów. (Odziedziczone po PipeStream)
ReadAsync(Byte[], Int32, Int32)	Asynchronicznie odczytuje sekwencję bajtów z bieżącego strumienia i rozwija pozycję w strumieniu według liczby odczytanych bajtów. (Odziedziczone po Stream)
ReadAsync(Byte[], Int32, Int32, CancellationToken)	Asynchronicznie odczytuje sekwencję bajtów z bieżącego strumienia do tablicy bajtów rozpoczynającej się od określonej liczby bajtów, przechodzi pozycję w strumieniu według liczby odczytanych bajtów i monitoruje żądania anulowania. (Odziedziczone po PipeStream)
ReadAsync(Memory<Byte>, CancellationToken)	Asynchronicznie odczytuje sekwencję bajtów z bieżącego strumienia, zapisuje je w zakresie pamięci bajtów, rozwija pozycję w strumieniu według liczby odczytanych bajtów i monitoruje żądania anulowania. (Odziedziczone po PipeStream)
ReadAtLeast(Span<Byte>, Int32, Boolean)	Odczytuje co najmniej minimalną liczbę bajtów z bieżącego strumienia i rozwija pozycję w strumieniu według liczby odczytanych bajtów. (Odziedziczone po Stream)
ReadAtLeastAsync(Memory<Byte>, Int32, Boolean, CancellationToken)	Asynchronicznie odczytuje co najmniej minimalną liczbę bajtów z bieżącego strumienia, zwiększa pozycję w strumieniu przez liczbę odczytanych bajtów i monitoruje żądania anulowania. (Odziedziczone po Stream)
ReadByte()	Odczytuje bajt z potoku. (Odziedziczone po PipeStream)
ReadExactly(Byte[], Int32, Int32)	Odczytuje count liczbę bajtów z bieżącego strumienia i rozwija pozycję w strumieniu. (Odziedziczone po Stream)
ReadExactly(Span<Byte>)	Odczytuje bajty z bieżącego strumienia i przesuwa pozycję w strumieniu do momentu wypełnienia buffer. (Odziedziczone po Stream)
ReadExactlyAsync(Byte[], Int32, Int32, CancellationToken)	Asynchronicznie odczytuje count liczbę bajtów z bieżącego strumienia, zwiększa pozycję w strumieniu i monitoruje żądania anulowania. (Odziedziczone po Stream)
ReadExactlyAsync(Memory<Byte>, CancellationToken)	Asynchronicznie odczytuje bajty z bieżącego strumienia, przechodzi pozycję w strumieniu do momentu wypełnienia buffer i monitoruje żądania anulowania. (Odziedziczone po Stream)
Seek(Int64, SeekOrigin)	Ustawia bieżące położenie bieżącego strumienia na określoną wartość. (Odziedziczone po PipeStream)
SetAccessControl(PipeSecurity)	Stosuje wpisy listy kontroli dostępu (ACL) określone przez obiekt PipeSecurity do potoku określonego przez bieżący obiekt PipeStream. (Odziedziczone po PipeStream)
SetLength(Int64)	Ustawia długość bieżącego strumienia na określoną wartość. (Odziedziczone po PipeStream)
ToString()	Zwraca ciąg reprezentujący bieżący obiekt. (Odziedziczone po Object)
WaitForPipeDrain()	Czeka na drugi koniec potoku, aby odczytać wszystkie wysłane bajty. (Odziedziczone po PipeStream)
Write(Byte[], Int32, Int32)	Zapisuje blok bajtów w bieżącym strumieniu przy użyciu danych z buforu. (Odziedziczone po PipeStream)
Write(ReadOnlySpan<Byte>)	Zapisuje sekwencję bajtów w bieżącym strumieniu i przechodzi bieżącą pozycję w tym strumieniu przez liczbę zapisanych bajtów. (Odziedziczone po PipeStream)
WriteAsync(Byte[], Int32, Int32)	Asynchronicznie zapisuje sekwencję bajtów do bieżącego strumienia i przechodzi bieżącą pozycję w tym strumieniu przez liczbę zapisanych bajtów. (Odziedziczone po Stream)
WriteAsync(Byte[], Int32, Int32, CancellationToken)	Asynchronicznie zapisuje określoną liczbę bajtów z tablicy bajtów rozpoczynającej się od określonej pozycji, przechodzi bieżącą pozycję w tym strumieniu przez liczbę zapisanych bajtów i monitoruje żądania anulowania. (Odziedziczone po PipeStream)
WriteAsync(ReadOnlyMemory<Byte>, CancellationToken)	Asynchronicznie zapisuje sekwencję bajtów w bieżącym strumieniu, przechodzi bieżącą pozycję w tym strumieniu przez liczbę zapisanych bajtów i monitoruje żądania anulowania. (Odziedziczone po PipeStream)
WriteByte(Byte)	Zapisuje bajt do bieżącego strumienia. (Odziedziczone po PipeStream)

Metody rozszerzania

CopyToAsync(Stream, PipeWriter, CancellationToken)	Asynchronicznie odczytuje bajty z Stream i zapisuje je w określonym PipeWriterprzy użyciu tokenu anulowania.
GetAccessControl(PipeStream)	Zwraca informacje o zabezpieczeniach strumienia potoku.
SetAccessControl(PipeStream, PipeSecurity)	Zmienia atrybuty zabezpieczeń istniejącego strumienia potoku.
ConfigureAwait(IAsyncDisposable, Boolean)	Konfiguruje, w jaki sposób będą wykonywane oczekiwania na zadania zwrócone z asynchronicznego jednorazowego użytku.