NamedPipeServerStream Sınıf

Tanım

Ad Alanı:

System.IO.Pipes

Bütünleştirilmiş Kodlar:

netstandard.dll, System.IO.Pipes.dll

Kaynak:

NamedPipeServerStream.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 NamedPipeServerStream sealed : System::IO::Pipes::PipeStream

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

type NamedPipeServerStream = class
    inherit PipeStream

Public NotInheritable Class NamedPipeServerStream
Inherits PipeStream

Devralma

Object

MarshalByRefObject

Stream

PipeStream

NamedPipeServerStream

Ö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 değeri NamedPipeServerStreamolan bir PipeDirection nesne oluştururOut. Sunucu daha sonra alt işlemdeki bir NamedPipeClientStream nesnenin ona bağlanmasını bekler. Bu örnekte, her iki işlem de aynı bilgisayardadır ve NamedPipeClientStream nesnenin PipeDirection değeri vardır In. Ü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, sınıfını kullanan sunucu işlemine yöneliktir NamedPipeServerStream . Hem kanal istemcisinin hem de sunucunun kodu da dahil olmak üzere kod örneğinin tamamı için bkz . Nasıl yapılır: Ağ İşlemler Arası İletişim için Adlandırılmış Kanallar Kullanma.

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

class PipeServer
{
    static void Main()
    {
        using (NamedPipeServerStream pipeServer =
            new NamedPipeServerStream("testpipe", PipeDirection.Out))
        {
            Console.WriteLine("NamedPipeServerStream object created.");

            // Wait for a client to connect
            Console.Write("Waiting for client connection...");
            pipeServer.WaitForConnection();

            Console.WriteLine("Client connected.");
            try
            {
                // Read user input and send that to the client process.
                using (StreamWriter sw = new StreamWriter(pipeServer))
                {
                    sw.AutoFlush = true;
                    Console.Write("Enter text: ");
                    sw.WriteLine(Console.ReadLine());
                }
            }
            // Catch the IOException that is raised if the pipe is broken
            // or disconnected.
            catch (IOException e)
            {
                Console.WriteLine("ERROR: {0}", e.Message);
            }
        }
    }
}

Imports System.IO
Imports System.IO.Pipes

Class PipeServer

    Shared Sub Main()
        Dim pipeServer As New NamedPipeServerStream("testpipe", PipeDirection.Out)

        Console.WriteLine("NamedPipeServerStream object created.")

        ' Wait for a client to connect
        Console.Write("Waiting for a client connection...")
        pipeServer.WaitForConnection()

        Console.WriteLine("Client connected.")
        Try
            'Read user input and send that to the client process.
            Dim sw As New StreamWriter(pipeServer)
            sw.AutoFlush = True
            Console.Write("Enter Text: ")
            sw.WriteLine(Console.ReadLine())
        Catch ex As IOException
            ' Catch the IOException that is raised if the pipe is broken
            ' or disconnected
            Console.WriteLine("ERROR: {0}", ex.Message)
        End Try
    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 nesne tarafından paylaşılabilir.

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

Okuma ve yazma için iş parçacığı güvenliğiyle ilgili olarak, tek bir okuyucuya ve tek bir yazıcıya kadar bir örneği eşzamanlı olarak kullanabilir.

Oluşturucular

Name	Description
NamedPipeServerStream(PipeDirection, Boolean, Boolean, SafePipeHandle)	Belirtilen kanal tutamacından sınıfın NamedPipeServerStream yeni bir örneğini başlatır.
NamedPipeServerStream(String, PipeDirection, Int32, PipeTransmissionMode, PipeOptions, Int32, Int32)	Sınıfın NamedPipeServerStream yeni bir örneğini belirtilen kanal adı, kanal yönü, en fazla sunucu örneği sayısı, iletim modu, kanal seçenekleri ile başlatır ve arabellek boyutları içinde ve dışında önerilir.
NamedPipeServerStream(String, PipeDirection, Int32, PipeTransmissionMode, PipeOptions)	Sınıfın NamedPipeServerStream yeni bir örneğini belirtilen kanal adı, kanal yönü, en fazla sunucu örneği sayısı, iletim modu ve kanal seçenekleriyle başlatır.
NamedPipeServerStream(String, PipeDirection, Int32, PipeTransmissionMode)	Sınıfın NamedPipeServerStream yeni bir örneğini belirtilen kanal adı, kanal yönü, en fazla sunucu örneği sayısı ve iletim modu ile başlatır.
NamedPipeServerStream(String, PipeDirection, Int32)	Sınıfın NamedPipeServerStream yeni bir örneğini belirtilen kanal adı, kanal yönü ve en fazla sunucu örneği sayısıyla başlatır.
NamedPipeServerStream(String, PipeDirection)	Belirtilen kanal adı ve kanal yönüyle sınıfının yeni bir örneğini NamedPipeServerStream başlatır.
NamedPipeServerStream(String)	Belirtilen kanal adıyla sınıfının yeni bir örneğini NamedPipeServerStream başlatır.

Alanlar

Name	Description
MaxAllowedServerInstances	Sistem kaynaklarının izin verilen en fazla sunucu örneği sayısını temsil eder.

Özellikler

Name	Description
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 nesnenin zaman uyumsuz olarak mı yoksa zaman uyumlu olarak mı açıldığını gösteren bir PipeStream değer alır. (Devralındığı yer: PipeStream)
IsConnected	Bir nesnenin bağlı olup olmadığını belirten bir PipeStream değer alır veya ayarlar. (Devralındığı yer: PipeStream)
IsHandleExposed	Bir nesne tanıtıcının kullanıma sunulduğunu belirten bir PipeStream 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)
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	Nesne PipeStream için 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 nesnenin kapsüllediğini kanalın yerel ucu için güvenli tanıtıcıyı 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

Name	Description
BeginRead(Byte[], Int32, Int32, AsyncCallback, Object)	Zaman uyumsuz bir okuma işlemi başlatır. (Devralındığı yer: PipeStream)
BeginWaitForConnection(AsyncCallback, Object)	İstemcinin bağlanmasını beklemek için zaman uyumsuz bir işlem başlatır.
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)
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)
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)
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, 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)
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)	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)
CreateWaitHandle()	Geçersiz. Bir WaitHandle nesne ayırır. (Devralındığı yer: Stream)
Disconnect()	Geçerli bağlantının bağlantısını keser.
Dispose()	tarafından Streamkullanılan tüm kaynakları serbest bırakır. (Devralındığı yer: Stream)
Dispose(Boolean)	sınıfı tarafından PipeStream 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()	tarafından Streamkullanı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)
EndWaitForConnection(IAsyncResult)	İstemcinin bağlanmasını beklemek için zaman uyumsuz bir işlemi sonlandırır.
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 örnek çöp toplama tarafından geri kazanılmadan önce NamedPipeServerStream 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)
GetHashCode()	Varsayılan karma işlevi işlevi görür. (Devralındığı yer: Object)
GetImpersonationUserName()	Kanalın diğer ucundaki istemcinin kullanıcı adını alır.
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 PipeStream nesneden bir SafePipeHandle nesne 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 nesnenin sığ bir kopyasını oluşturur. (Devralındığı yer: MarshalByRefObject)
ObjectInvariant()	Geçersiz. için Contractdestek 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, 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(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(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)	count Geçerli akıştan 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 doldurulana kadar buffer akış içindeki konumu ilerler. (Devralındığı yer: Stream)
ReadExactlyAsync(Byte[], Int32, Int32, CancellationToken)	Geçerli akıştaki bayt sayısını zaman uyumsuz olarak okur count , 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, doldurulana kadar buffer akış içindeki konumu ilerletir ve iptal isteklerini izler. (Devralındığı yer: Stream)
RunAsClient(PipeStreamImpersonationWorker)	İstemcinin kimliğine bürünülirken temsilciyi çağırır.
Seek(Int64, SeekOrigin)	Geçerli akışın geçerli konumunu belirtilen değere ayarlar. (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)
WaitForConnection()	İstemcinin bu NamedPipeServerStream nesneye bağlanmasını bekler.
WaitForConnectionAsync()	Zaman uyumsuz olarak istemcinin bu NamedPipeServerStream nesneye bağlanmasını bekler.
WaitForConnectionAsync(CancellationToken)	Zaman uyumsuz olarak istemcinin bu NamedPipeServerStream nesneye bağlanmasını bekler ve iptal isteklerini izler.
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, 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(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(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ı

Name	Description
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.
CopyToAsync(Stream, PipeWriter, CancellationToken)	baytlarını Stream zaman uyumsuz olarak okur ve bir iptal belirteci kullanarak belirtilen PipeWriteröğesine yazar.
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.