NamedPipeClientStream Sınıf

  • Başvuru

Tanım

Ad Alanı:
System.IO.Pipes
Bütünleştirilmiş Kod:
System.IO.Pipes.dll
Bütünleştirilmiş Kod:
System.Core.dll
Bütünleştirilmiş Kod:
netstandard.dll
Kaynak:
NamedPipeClientStream.cs
Kaynak:
NamedPipeClientStream.cs
Kaynak:
NamedPipeClientStream.cs

Adlandırılmış bir kanalın çevresinde hem zaman uyumlu hem de zaman uyumsuz okuma ve yazma işlemlerini destekleyen bir Stream kullanıma sunar.

public ref class NamedPipeClientStream sealed : System::IO::Pipes::PipeStream
public sealed class NamedPipeClientStream : System.IO.Pipes.PipeStream
type NamedPipeClientStream = class
    inherit PipeStream
Public NotInheritable Class NamedPipeClientStream
Inherits PipeStream
Devralma
Object
Stream
PipeStream
NamedPipeClientStream
Devralma
Object
MarshalByRefObject
Stream
PipeStream
NamedPipeClientStream

Örnekler

Aşağıdaki örnek, adlandırılmış kanallar kullanarak bir üst işlemden aynı bilgisayardaki alt işleme bir dize göndermenin bir yolunu gösterir. Bu örnek, üst işlemde bir NamedPipeServerStream nesnesi oluşturur. NamedPipeServerStream nesnesinin OutPipeDirection değeri vardır. Sunucu daha sonra alt işlemdeki bir NamedPipeClientStream nesnesinin ona bağlanmasını bekler. Bu örnekte, her iki işlem de aynı bilgisayardadır ve NamedPipeClientStream nesnesi InPipeDirection değerine sahiptir. Üst işlem daha sonra alt işleme kullanıcı tarafından sağlanan bir dize gönderir. Dize konsolda görüntülenir.

Bu örnek, sunucu işlemine bağlanan istemci işlemine yöneliktir. Hem kanal istemcisinin hem de sunucunun kodu dahil olmak üzere kod örneğinin tamamı için bkz. Nasıl yapılır: Ağ İşlemler Arası İletişimiçin Adlandırılmış Kanallar Kullanma .

using System;
using System.IO;
using System.IO.Pipes;

class PipeClient
{
    static void Main(string[] args)
    {
        using (NamedPipeClientStream pipeClient =
            new NamedPipeClientStream(".", "testpipe", PipeDirection.In))
        {

            // Connect to the pipe or wait until the pipe is available.
            Console.Write("Attempting to connect to pipe...");
            pipeClient.Connect();

            Console.WriteLine("Connected to pipe.");
            Console.WriteLine("There are currently {0} pipe server instances open.",
               pipeClient.NumberOfServerInstances);
            using (StreamReader sr = new StreamReader(pipeClient))
            {
                // Display the read text to the console
                string temp;
                while ((temp = sr.ReadLine()) != null)
                {
                    Console.WriteLine("Received from server: {0}", temp);
                }
            }
        }
        Console.Write("Press Enter to continue...");
        Console.ReadLine();
    }
}

Imports System.IO
Imports System.IO.Pipes
Imports System.Security.Principal

Class PipeClient

    Shared Sub Main(ByVal args As String())

        Dim pipeClient As New NamedPipeClientStream("localhost", _
                    "testpipe", PipeDirection.In, PipeOptions.None)

        ' Connect to the pipe or wait until the pipe is available.
        Console.WriteLine("Attempting to connect to the pipe...")
        pipeClient.Connect()

        Console.WriteLine("Connect to the pipe.")
        Console.WriteLine("There are currently {0} pipe server instances open.", _
                          pipeClient.NumberOfServerInstances)

        Dim sr As New StreamReader(pipeClient)
        Dim temp As String

        temp = sr.ReadLine()
        While Not temp Is Nothing
            Console.WriteLine("Received from server: {0}", temp)
            temp = sr.ReadLine()
        End While
        Console.Write("Press Enter to continue...")
        Console.ReadLine()
    End Sub
End Class

Açıklamalar

Adlandırılmış kanallar, bir kanal sunucusu ile bir veya daha fazla kanal istemcisi arasındaki iletişim için tek yönlü veya çift yönlü kanallar sağlar. Adlandırılmış kanallar, yerel olarak veya ağ üzerinden işlemler arası iletişim için kullanılabilir. Tek bir kanal adı birden çok NamedPipeClientStream nesnesi tarafından paylaşılabilir.

Herhangi bir işlem adlandırılmış kanal sunucusu veya istemci ya da her ikisi gibi davranabilir.

Oluşturucular

NamedPipeClientStream(PipeDirection, Boolean, Boolean, SafePipeHandle)

Belirtilen kanal yönüne sahip belirtilen kanal tutamacı için NamedPipeClientStream sınıfının yeni bir örneğini başlatır.
NamedPipeClientStream(String)

Belirtilen kanal adıyla NamedPipeClientStream sınıfının yeni bir örneğini başlatır.
NamedPipeClientStream(String, String)

Belirtilen kanal ve sunucu adlarıyla NamedPipeClientStream sınıfının yeni bir örneğini başlatır.
NamedPipeClientStream(String, String, PipeAccessRights, PipeOptions, TokenImpersonationLevel, HandleInheritability)

Belirtilen kanal ve sunucu adları ve belirtilen kanal seçenekleri, güvenlik kimliğe bürünme düzeyi ve devralınabilirlik modu ile NamedPipeClientStream sınıfının yeni bir örneğini başlatır.
NamedPipeClientStream(String, String, PipeDirection)

Belirtilen kanal ve sunucu adları ve belirtilen kanal yönüyle NamedPipeClientStream sınıfının yeni bir örneğini başlatır.
NamedPipeClientStream(String, String, PipeDirection, PipeOptions)

Belirtilen kanal ve sunucu adları ve belirtilen kanal yönü ve kanal seçenekleriyle NamedPipeClientStream sınıfının yeni bir örneğini başlatır.
NamedPipeClientStream(String, String, PipeDirection, PipeOptions, TokenImpersonationLevel)

Belirtilen kanal ve sunucu adları ve belirtilen kanal yönü, kanal seçenekleri ve güvenlik kimliğe bürünme düzeyi ile NamedPipeClientStream sınıfının yeni bir örneğini başlatır.
NamedPipeClientStream(String, String, PipeDirection, PipeOptions, TokenImpersonationLevel, HandleInheritability)

belirtilen kanal ve sunucu adları ve belirtilen kanal yönü, kanal seçenekleri, güvenlik kimliğe bürünme düzeyi ve devralınabilirlik modu ile NamedPipeClientStream sınıfının yeni bir örneğini başlatır.

Özellikler

CanRead

Geçerli akışın okuma işlemlerini destekleyip desteklemediğini belirten bir değer alır.

(Devralındığı yer: PipeStream)
CanSeek

Geçerli akışın arama işlemlerini destekleyip desteklemediğini belirten bir değer alır.

(Devralındığı yer: PipeStream)
CanTimeout

Geçerli akışın zaman aşımına neden olup olmadığını belirleyen bir değer alır.

(Devralındığı yer: Stream)
CanWrite

Geçerli akışın yazma işlemlerini destekleyip desteklemediğini belirten bir değer alır.

(Devralındığı yer: PipeStream)
InBufferSize

Bir kanal için gelen arabelleğin bayt cinsinden boyutunu alır.

(Devralındığı yer: PipeStream)
IsAsync

bir PipeStream nesnesinin zaman uyumsuz olarak mı yoksa zaman uyumlu olarak mı açıldığını gösteren bir değer alır.

(Devralındığı yer: PipeStream)
IsConnected

bir PipeStream nesnesinin bağlı olup olmadığını belirten bir değer alır veya ayarlar.

(Devralındığı yer: PipeStream)
IsHandleExposed

bir PipeStream nesnesi tanıtıcının kullanıma sunulduğunu belirten bir değer alır.

(Devralındığı yer: PipeStream)
IsMessageComplete

İletide en son okuma işleminden döndürülen daha fazla veri olup olmadığını belirten bir değer alır.

(Devralındığı yer: PipeStream)
Length

Bayt cinsinden bir akışın uzunluğunu alır.

(Devralındığı yer: PipeStream)
NumberOfServerInstances

Aynı kanal adını paylaşan sunucu örneklerinin sayısını alır.
OutBufferSize

Bir kanal için giden arabelleğin bayt cinsinden boyutunu alır.

(Devralındığı yer: PipeStream)
Position

Geçerli akışın geçerli konumunu alır veya ayarlar.

(Devralındığı yer: PipeStream)
ReadMode

PipeStream nesnesinin okuma modunu alır veya ayarlar.

(Devralındığı yer: PipeStream)
ReadTimeout

Akışın zaman aşımına uğramadan önce ne kadar süreyle okumayı deneyeceğini belirleyen bir değeri milisaniye cinsinden alır veya ayarlar.

(Devralındığı yer: Stream)
SafePipeHandle

Geçerli PipeStream nesnesinin kapsüllediğini borunun yerel ucu için güvenli tutamacı alır.

(Devralındığı yer: PipeStream)
TransmissionMode

Geçerli boru tarafından desteklenen boru iletim modunu alır.

(Devralındığı yer: PipeStream)
WriteTimeout

Akışın zaman aşımına uğramadan önce ne kadar süreyle yazmaya çalışacağını belirleyen bir değeri milisaniye cinsinden alır veya ayarlar.

(Devralındığı yer: Stream)

Yöntemler

BeginRead(Byte[], Int32, Int32, AsyncCallback, Object)

Zaman uyumsuz bir okuma işlemi başlatır.

(Devralındığı yer: PipeStream)
BeginWrite(Byte[], Int32, Int32, AsyncCallback, Object)

Zaman uyumsuz bir yazma işlemi başlatır.

(Devralındığı yer: PipeStream)
CheckPipePropertyOperations()

Borunun özellikleri almak veya ayarlamak için uygun durumda olduğunu doğrular.

(Devralındığı yer: PipeStream)
CheckReadOperations()

Borunun okuma işlemleri için bağlı durumda olduğunu doğrular.

(Devralındığı yer: PipeStream)
CheckWriteOperations()

Kanal yazma işlemleri için bağlı durumda olduğunu doğrular.

(Devralındığı yer: PipeStream)
Close()

Geçerli akışı kapatır ve geçerli akışla ilişkili tüm kaynakları (yuvalar ve dosya tanıtıcıları gibi) serbest bırakır. Bu yöntemi çağırmak yerine akışın düzgün şekilde atıldığından emin olun.

(Devralındığı yer: Stream)
Connect()

Sonsuz zaman aşımı değeriyle bekleyen bir sunucuya bağlanır.
Connect(Int32)

Belirtilen zaman aşımı süresi içinde bekleyen bir sunucuya bağlanır.
Connect(TimeSpan)

Belirtilen zaman aşımı süresi içinde bekleyen bir sunucuya bağlanır.
ConnectAsync()

Zaman uyumsuz olarak sonsuz zaman aşımı süresiyle bekleyen bir sunucuya bağlanır.
ConnectAsync(CancellationToken)

Zaman uyumsuz olarak bekleyen bir sunucuya bağlanır ve iptal isteklerini izler.
ConnectAsync(Int32)

Belirtilen zaman aşımı süresi içinde bekleyen bir sunucuya zaman uyumsuz olarak bağlanır.
ConnectAsync(Int32, CancellationToken)

Belirtilen zaman aşımı süresi içinde zaman uyumsuz olarak bekleyen bir sunucuya bağlanır ve iptal isteklerini izler.
ConnectAsync(TimeSpan, CancellationToken)

Belirtilen zaman aşımı süresi içinde zaman uyumsuz olarak bekleyen bir sunucuya bağlanır ve iptal isteklerini izler.
CopyTo(Stream)

Geçerli akıştan baytları okur ve başka bir akışa yazar. Her iki akış konumu da kopyalanan bayt sayısına göre gelişmiştir.

(Devralındığı yer: Stream)
CopyTo(Stream, Int32)

Geçerli akıştan baytları okur ve belirtilen arabellek boyutunu kullanarak başka bir akışa yazar. Her iki akış konumu da kopyalanan bayt sayısına göre gelişmiştir.

(Devralındığı yer: Stream)
CopyToAsync(Stream)

Geçerli akıştan gelen baytları zaman uyumsuz olarak okur ve başka bir akışa yazar. Her iki akış konumu da kopyalanan bayt sayısına göre gelişmiştir.

(Devralındığı yer: Stream)
CopyToAsync(Stream, CancellationToken)

Geçerli akıştan gelen baytları zaman uyumsuz olarak okur ve belirtilen iptal belirtecini kullanarak başka bir akışa yazar. Her iki akış konumu da kopyalanan bayt sayısına göre gelişmiştir.

(Devralındığı yer: Stream)
CopyToAsync(Stream, Int32)

Geçerli akıştan gelen baytları zaman uyumsuz olarak okur ve belirtilen arabellek boyutunu kullanarak başka bir akışa yazar. Her iki akış konumu da kopyalanan bayt sayısına göre gelişmiştir.

(Devralındığı yer: Stream)
CopyToAsync(Stream, Int32, CancellationToken)

Belirtilen arabellek boyutu ve iptal belirtecini kullanarak geçerli akıştan baytları zaman uyumsuz olarak okur ve başka bir akışa yazar. Her iki akış konumu da kopyalanan bayt sayısına göre gelişmiştir.

(Devralındığı yer: Stream)
CreateObjRef(Type)

Uzak bir nesneyle iletişim kurmak için kullanılan bir ara sunucu oluşturmak için gereken tüm ilgili bilgileri içeren bir nesne oluşturur.

(Devralındığı yer: MarshalByRefObject)
CreateWaitHandle()
Geçersiz.
Geçersiz.
Geçersiz.

bir WaitHandle nesnesi ayırır.

(Devralındığı yer: Stream)
Dispose()

Streamtarafından kullanılan tüm kaynakları serbest bırakır.

(Devralındığı yer: Stream)
Dispose(Boolean)

PipeStream sınıfı tarafından kullanılan yönetilmeyen kaynakları serbest bırakır ve isteğe bağlı olarak yönetilen kaynakları serbest bırakır.

(Devralındığı yer: PipeStream)
DisposeAsync()

Streamtarafından kullanılan yönetilmeyen kaynakları zaman uyumsuz olarak serbest bırakır.

(Devralındığı yer: Stream)
EndRead(IAsyncResult)

Bekleyen zaman uyumsuz okuma isteğini sonlandırır.

(Devralındığı yer: PipeStream)
EndWrite(IAsyncResult)

Bekleyen zaman uyumsuz yazma isteğini sonlandırır.

(Devralındığı yer: PipeStream)
Equals(Object)

Belirtilen nesnenin geçerli nesneye eşit olup olmadığını belirler.

(Devralındığı yer: Object)
Finalize()

Yönetilmeyen kaynakları serbest bırakır ve NamedPipeClientStream örneği çöp toplama tarafından geri kazanılmadan önce diğer temizleme işlemlerini gerçekleştirir.
Flush()

Geçerli akış için arabelleği temizler ve arabelleğe alınan verilerin temel alınan cihaza yazılmasına neden olur.

(Devralındığı yer: PipeStream)
FlushAsync()

Bu akış için tüm arabellekleri zaman uyumsuz olarak temizler ve arabelleğe alınan verilerin temel alınan cihaza yazılmasına neden olur.

(Devralındığı yer: Stream)
FlushAsync(CancellationToken)

Geçerli akış için arabelleği zaman uyumsuz olarak temizler ve arabelleğe alınan verilerin temel alınan cihaza yazılmasına neden olur.

(Devralındığı yer: PipeStream)
GetAccessControl()

Geçerli PipeStream nesnesi tarafından açıklanan kanal için erişim denetimi listesi (ACL) girdilerini kapsülleyen bir PipeSecurity nesnesi alır.

(Devralındığı yer: PipeStream)
GetHashCode()

Varsayılan karma işlevi işlevi görür.

(Devralındığı yer: Object)
GetLifetimeService()
Geçersiz.

Bu örnek için yaşam süresi ilkesini denetleen geçerli yaşam süresi hizmet nesnesini alır.

(Devralındığı yer: MarshalByRefObject)
GetType()

Geçerli örneğin Type alır.

(Devralındığı yer: Object)
InitializeHandle(SafePipeHandle, Boolean, Boolean)

Belirtilen SafePipeHandle nesnesinden bir PipeStream nesnesi başlatır.

(Devralındığı yer: PipeStream)
InitializeLifetimeService()
Geçersiz.

Bu örneğin yaşam süresi ilkesini denetlemek için bir yaşam süresi hizmet nesnesi alır.

(Devralındığı yer: MarshalByRefObject)
MemberwiseClone()

Geçerli Objectbasit bir kopyasını oluşturur.

(Devralındığı yer: Object)
MemberwiseClone(Boolean)

Geçerli MarshalByRefObject nesnesinin sığ bir kopyasını oluşturur.

(Devralındığı yer: MarshalByRefObject)
ObjectInvariant()
Geçersiz.

Contractiçin destek sağlar.

(Devralındığı yer: Stream)
Read(Byte[], Int32, Int32)

Bir akıştan bayt bloğunu okur ve verileri belirtilen bir uzunlukta belirtilen konumdan başlayarak belirtilen arabelleğe yazar.

(Devralındığı yer: PipeStream)
Read(Span<Byte>)

Geçerli akıştan bir bayt dizisi okur, bunları bir bayt dizisine yazar ve okunan bayt sayısına göre akış içindeki konumu ilerletir.

(Devralındığı yer: PipeStream)
ReadAsync(Byte[], Int32, Int32)

Geçerli akıştan zaman uyumsuz olarak bir bayt dizisi okur ve okunan bayt sayısına göre akış içindeki konumu ilerletir.

(Devralındığı yer: Stream)
ReadAsync(Byte[], Int32, Int32, CancellationToken)

Belirtilen sayıda bayt için belirtilen konumdan başlayarak geçerli akıştan bayt dizisine zaman uyumsuz olarak bir bayt dizisi okur, okunan bayt sayısına göre akıştaki konumu ilerletir ve iptal isteklerini izler.

(Devralındığı yer: PipeStream)
ReadAsync(Memory<Byte>, CancellationToken)

Geçerli akıştan zaman uyumsuz olarak bir bayt dizisi okur, bunları bir bayt bellek aralığına yazar, okunan bayt sayısına göre akıştaki konumu ilerletir ve iptal isteklerini izler.

(Devralındığı yer: PipeStream)
ReadAtLeast(Span<Byte>, Int32, Boolean)

Geçerli akıştan en az bayt sayısını okur ve okunan bayt sayısına göre akış içindeki konumu ilerletir.

(Devralındığı yer: Stream)
ReadAtLeastAsync(Memory<Byte>, Int32, Boolean, CancellationToken)

Geçerli akıştan en az en az sayıda bayt zaman uyumsuz olarak okur, okunan bayt sayısına göre akıştaki konumu ilerletir ve iptal isteklerini izler.

(Devralındığı yer: Stream)
ReadByte()

Borudan bayt okur.

(Devralındığı yer: PipeStream)
ReadExactly(Byte[], Int32, Int32)

Geçerli akıştan count bayt sayısını okur ve akış içindeki konumu ilerletir.

(Devralındığı yer: Stream)
ReadExactly(Span<Byte>)

Geçerli akıştan baytları okur ve buffer doldurulana kadar akıştaki konumu ilerletir.

(Devralındığı yer: Stream)
ReadExactlyAsync(Byte[], Int32, Int32, CancellationToken)

Geçerli akıştan count bayt sayısını zaman uyumsuz olarak okur, akış içindeki konumu ilerletir ve iptal isteklerini izler.

(Devralındığı yer: Stream)
ReadExactlyAsync(Memory<Byte>, CancellationToken)

Geçerli akıştaki baytları zaman uyumsuz olarak okur, buffer doldurulana kadar akıştaki konumu ilerletir ve iptal isteklerini izler.

(Devralındığı yer: Stream)
Seek(Int64, SeekOrigin)

Geçerli akışın geçerli konumunu belirtilen değere ayarlar.

(Devralındığı yer: PipeStream)
SetAccessControl(PipeSecurity)

bir PipeSecurity nesnesi tarafından belirtilen erişim denetimi listesi (ACL) girdilerini geçerli PipeStream nesnesi tarafından belirtilen kanala uygular.

(Devralındığı yer: PipeStream)
SetLength(Int64)

Geçerli akışın uzunluğunu belirtilen değere ayarlar.

(Devralındığı yer: PipeStream)
ToString()

Geçerli nesneyi temsil eden bir dize döndürür.

(Devralındığı yer: Object)
WaitForPipeDrain()

Kanalın diğer ucunun gönderilen tüm baytları okumasını bekler.

(Devralındığı yer: PipeStream)
Write(Byte[], Int32, Int32)

Arabellekten alınan verileri kullanarak geçerli akışa bir bayt bloğu yazar.

(Devralındığı yer: PipeStream)
Write(ReadOnlySpan<Byte>)

Geçerli akışa bir bayt dizisi yazar ve bu akıştaki geçerli konumu yazılan bayt sayısına göre ilerletir.

(Devralındığı yer: PipeStream)
WriteAsync(Byte[], Int32, Int32)

Zaman uyumsuz olarak geçerli akışa bir bayt dizisi yazar ve bu akıştaki geçerli konumu yazılan bayt sayısına göre ilerletir.

(Devralındığı yer: Stream)
WriteAsync(Byte[], Int32, Int32, CancellationToken)

Belirli bir konumdan başlayan bayt dizisinden zaman uyumsuz olarak belirtilen sayıda bayt yazar, bu akıştaki geçerli konumu yazılan bayt sayısına göre ilerletir ve iptal isteklerini izler.

(Devralındığı yer: PipeStream)
WriteAsync(ReadOnlyMemory<Byte>, CancellationToken)

Zaman uyumsuz olarak geçerli akışa bir bayt dizisi yazar, bu akıştaki geçerli konumu yazılan bayt sayısına göre ilerletir ve iptal isteklerini izler.

(Devralındığı yer: PipeStream)
WriteByte(Byte)

Geçerli akışa bir bayt yazar.

(Devralındığı yer: PipeStream)

Uzantı Metotları

CopyToAsync(Stream, PipeWriter, CancellationToken)

Stream baytları zaman uyumsuz olarak okur ve bir iptal belirteci kullanarak belirtilen PipeWriteryazar.
GetAccessControl(PipeStream)

Kanal akışının güvenlik bilgilerini döndürür.
SetAccessControl(PipeStream, PipeSecurity)

Mevcut bir kanal akışının güvenlik özniteliklerini değiştirir.
ConfigureAwait(IAsyncDisposable, Boolean)

Zaman uyumsuz bir atılabilir öğeden döndürülen görevlerde awaits işleminin nasıl gerçekleştirileceğini yapılandırılır.

Şunlara uygulanır