Imports System.IO
Imports System.IO.Pipes
Imports System.Threading
 
Public Class TestPipe
 
    Public Sub ThreadStartServer()
        ' Create a name pipe
        Using pipeStream As New NamedPipeServerStream("mytestpipe")
            Console.WriteLine("[Server] Pipe created {0}", _
              pipeStream.GetHashCode())
 
            ' Wait for a connection
            pipeStream.WaitForConnection()
            Console.WriteLine("[Server] Pipe connection established")
 
            Using sr As New StreamReader(pipeStream),
                sw As New StreamWriter(pipeStream)
                sw.AutoFlush = True
                Dim temp As String = String.Empty
                ' We read a line from the pipe and print it together with the 
                ' current time
                While (assign(temp, sr.ReadLine())) IsNot Nothing
                    Dim dt As DateTime = DateTime.Now
                    Console.WriteLine("[Server] {0}: {1}", dt, temp)
                    If temp = "time" Then
                        sw.WriteLine(dt.ToString())
                    End If
                End While
            End Using
        End Using
 
        Console.WriteLine("[Server] Connection lost")
    End Sub
 
    Public Sub ThreadStartClient(obj As Object)
 
        Using pipeStream As New NamedPipeClientStream("mytestpipe")
            ' The connect function will indefinately wait for the pipe to 
            ' become available
            ' If that is not acceptable specify a maximum waiting time (in ms)
            pipeStream.Connect()
 
            Console.WriteLine("[Client] Pipe connection established")
            Using sw As New StreamWriter(pipeStream),
                sr As New StreamReader(pipeStream)
                sw.AutoFlush = True
                Dim temp As String = String.Empty
                Console.WriteLine("[Client] Please type a message and press" & _
                  "[Enter], or type 'quit' to exit the program")
                While (assign(temp, Console.ReadLine())) IsNot Nothing
                    If temp = "quit" Then
                        Exit While
                    End If
                    sw.WriteLine(temp)
                    If temp = "time" Then
                        Dim response As String = sr.ReadLine()
                        Console.WriteLine("[Response] time=" & response)
                    End If
                End While
            End Using
        End Using
    End Sub
 
    Private Sub TestPipe()
 
        Dim ServerThread As New Thread(AddressOf ThreadStartServer)
        Dim ClientThread As New Thread(AddressOf ThreadStartClient)
 
        ServerThread.Start()
        ClientThread.Start()
 
    End Sub
 
    Private Shared Function assign(Of T)(ByRef target As T, value As T) As T
        target = value
        Return value
    End Function
 
    Public Shared Sub Main()
        Dim tp As New TestPipe
        tp.TestPipe()
    End Sub
 
End Class

________
Alle Angaben ohne Gewähr. Keine Haftung für Vorschläge, Tipps oder sonstige Hilfe, falls es schiefgeht, nur Zeit verschwendet oder man sonst nicht zufrieden ist