Danke für die Hilfe

Gruß Christian

Imports System.Runtime.Serialization.Formatters.Binary
Imports System.IO.Pipes
Imports System.Threading
Imports System.ComponentModel
 
 
Public Class frmPipe
 
    Dim dgv As New DataGridView With {.Parent = Me}
    Delegate Sub Tabledelegate(ByVal dt As DataTable)
 
 
    Private Sub frmPipe_Load(sender As System.Object, _
                e As System.EventArgs) Handles MyBase.Load
 
        'NamedPipe-Threads starten
 
        Dim st As New Thread(AddressOf serverthread)
        st.Start()
 
        Dim ct As New Thread(AddressOf clientthread)
        ct.Start()
 
    End Sub
 
 
 
    Private Sub serverthread()
 
        'Testdaten erstellen 
        Dim dt As New DataTable
        With dt
            .Columns.Add("SP1")
            .Columns.Add("SP2")
            .Columns.Add("SP3")
            .Rows.Add("11", "12", "13")
            .Rows.Add("21", "22", "23")
            .Rows.Add("31", "32", "33")
        End With
 
        'Übertragung der Datatable
 
        'Serialisierung der Datatable in einen Memorystream
        Dim bf As New BinaryFormatter
        Dim ms As New IO.MemoryStream
        bf.Serialize(ms, dt)
        Dim bl As Integer = ms.ToArray.Length 'Byte-Länge notieren
 
        'zu sendende Bytelänge in Bytearray wandeln
        Dim blb As Byte() = BitConverter.GetBytes(bl)
 
        'NamedPipe für das Senden der Tabelle erstellen
        Dim server As New NamedPipeServerStream("PipeTable")
        server.WaitForConnection()
 
        'Byte-Arrays übertragen (senden)
        server.Write(blb, 0, blb.Length) 'Länge 
        server.Write(ms.ToArray, 0, bl)  'Datatable-Serialisierung
 
    End Sub
 
 
    Private Sub clientthread()
 
        'NamedPipe für den Datenempfang
        Dim client As New NamedPipeClientStream("PipeTable")
        client.Connect()
 
        'Byte-Länge lesen 
        Dim blb(4) As Byte
        client.Read(blb, 0, 4)
        Dim bl As Integer = BitConverter.ToInt32(blb, 0)
 
        'Array für die empfangenen Daten 
        Dim buffer(bl) As Byte
 
        client.Read(buffer, 0, bl) 'Datatable-Serialisierung lesen
 
        'Deserialisieren des Byte-Array
        Dim msc As New IO.MemoryStream(buffer)
        Dim bfc As New BinaryFormatter
        Dim dtc As DataTable = _
           CType(bfc.Deserialize(msc, Nothing), DataTable)
 
        'Anzeige der erhaltenen Datatable-Daten im Grid 
        Me.Invoke(New Tabledelegate(AddressOf showtable), dtc)
    End Sub
 
 
 
    Private Sub showtable(ByVal dt As DataTable)
        dgv.DataSource = Nothing
        dgv.DataSource = dt
    End Sub
 
End Class

Danke für die Hilfe

Gruß Christian

    Public Enum TransferTyp
        [String]
        Number
        Table
    End Enum
 
    <Serializable()> _
    Public Class TransferDaten
 
        Public Property Typ As TransferTyp 'Kennung
 
        Public Property AString As String  'Properties für diverse Übergaben
        Public Property BNumber As Decimal
        Public Property CTable As DataTable
 
    End Class

    Private Sub server_thread()
 
        'Testdaten erstellen 
 
        Dim dt As New DataTable
        With dt
            .Columns.Add("SP1")
            .Columns.Add("SP2")
            .Columns.Add("SP3")
            .Rows.Add("11", "12", "13")
            .Rows.Add("21", "22", "23")
            .Rows.Add("31", "32", "33")
        End With
 
        Dim tc As New TransferDaten
        'Transferklasse füllen
        tc.CTable = dt
        tc.Typ = TransferTyp.Table
 
        'Direkte Serialisierung der Datatable in der 
        'Transferklasse in die Pipe
        Dim bf As New BinaryFormatter
        Dim server As New NamedPipeServerStream("PipeTransfer")
        server.WaitForConnection()
        bf.Serialize(server, tc)
        server.Close()
 
    End Sub
 
 
 
    Private Sub Client_Thread()
 
        'NamedPipe für den Datenempfang
        Dim client As New NamedPipeClientStream("PipeTransfer")
        client.Connect()
 
        'Direkte Deserialisierung der empfangenen TC-Instanz
        Dim bfc As New BinaryFormatter
        Dim tc As TransferDaten = CType(bfc.Deserialize(client), TransferDaten)
        client.Close()
 
        'Hier Fallunterscheidung gemäß Übergabetyp vornehmen
        If tc.Typ = TransferTyp.Table Then
            'Anzeige der erhaltenen Datatable-Daten im Grid 
            Me.Invoke(New Tabledelegate(AddressOf showtable), tc.CTable)
        else
           '..... 
        End If
 
    End Sub

Danke für die Hilfe

Gruß Christian

Danke für die Hilfe

Gruß Christian

Danke für die Hilfe

Gruß Christian

  <System.Runtime.InteropServices.ComVisible(True)> _
 Public Sub Serverstart()
        Using PipeServer As New  _
          NamedPipeServerStream(PipeName, PipeDirection.InOut, _
          maxNumberOfServerinstances, PipeTransmissionMode.Message, _
          PipeOptions.Asynchronous)
 
            ZeileAnzeigen("Server: --> warte auf Client..." & " PipeName = " _
              & PipeName)
            PipeServer.WaitForConnection()
            ZeileAnzeigen("Server: --> verbunden")
            PipeOn = True
            While PipeOn
                Try
                    If Not PipeServer.IsConnected Then Serverstart()
                    Using sr As New StreamReader(PipeServer), sw As New _
                      StreamWriter(PipeServer)
                        sw.AutoFlush = True
                        Dim temp As String = String.Empty
                        tcOut = Nothing
                        While (assign(temp, sr.ReadLine())) IsNot Nothing
                            ServerInput = temp
                            If ServerInput.Length > 0 Then RaiseEvent _
                              PropertyChanged(Me, ServerRequest)
                            If Not tcOut Is Nothing Then
                                Dim bf As New BinaryFormatter
                                bf.Serialize(PipeServer, tcOut)
                            End If
                        End While
                        ZeileAnzeigen("Server: --> Daten")
                    End Using
                    'End If
                Catch ex As Exception
                    ' kam Fehler bei beenden Client vor Server --> 
                    ' unterbrochene Pipe
                    ZeileAnzeigen("Server Fehler: --> " & _
                      ex.InnerException.ToString)
                End Try
            End While
            ZeileAnzeigen("Server: --> beende")
        End Using
        PipeOn = False
    End Sub

  <System.Runtime.InteropServices.ComVisible(True)> _
 Public Sub ClientStart(ByVal AnfrageString As String)
        Using PipeClient As New NamedPipeClientStream(ServerName, PipeName, _
          PipeDirection.InOut, PipeOptions.None, _
          Security.Principal.TokenImpersonationLevel.Impersonation)
            ZeileAnzeigen("Client: --> warte auf Server..." & "PipeName = " _
            & String.Concat(ServerName, ",", PipeName))
            PipeClient.Connect()
            startTimer()
            PipeOn = True
            ZeileAnzeigen("Client: --> verbunden")
            sw = New StreamWriter(PipeClient)
            sw.AutoFlush = True
            sw.WriteLine(AnfrageString)
            ZeileAnzeigen("Client Anfrage: --> " & AnfrageString)
            If Not PipeOn Then PipeClient.Close()
            'Direkte Deserialisierung der empfangenen TC-Instanz
            Dim bfc As New BinaryFormatter
            Dim tc As TransferDaten = CType(bfc.Deserialize(PipeClient), _
              TransferDaten)
            If Not tc Is Nothing Then ClientInput = tc : RaiseEvent _
            PropertyChanged(Me, ClientRequest) : TimeOut.Dispose()
            PipeClient.Close()
            ZeileAnzeigen("Client: --> beendet")
        End Using
    End Sub

    Private tcOut As TransferDaten
    Public TransferTyp As TransferTyp
    Public TransferDataTable As DataTable
    Public TransferString As String
    Public TransferNumber As Decimal
    Public TransferCount As Integer
    Public Sub createTransferdata()
        Try
            tcOut = New TransferDaten
            With tcOut
                .Typ = TransferTyp
                If Not String.IsNullOrEmpty(TransferString) Then .TString = _
                  TransferString
                Select Case TransferTyp
                    Case NamedPipe.TransferTyp.Count
                        .TCount = TransferCount
                    Case NamedPipe.TransferTyp.Table
                        .CTable = TransferDataTable
                    Case NamedPipe.TransferTyp.Decimal
                        .TNumber = TransferNumber
                End Select
            End With
        Catch ex As Exception
            tcOut = Nothing
        End Try
    End Sub

Danke für die Hilfe

Gruß Christian

<Serializable> _
Public Class tcOut As TransferDaten
    Public TransferTyp As TransferTyp
    Public TransferDataTable As DataTable
    Public TransferString As String
    Public TransferNumber As Decimal
    Public TransferCount As Integer
End Class

Public Enum TransferTyp
    [String]
    Count
    [Decimal]
    Table
End Enum
 
<Serializable()> _
Public Class TransferDaten
 
    Dim _Typ As TransferTyp
    Public Property Typ() As TransferTyp 'Kennung
        Get
            Return _Typ
        End Get
        Set(ByVal value As TransferTyp)
            _Typ = value
        End Set
    End Property
 
    Dim _String As String
    Public Property TString() As String  'Properties für diverse Übergaben
        Get
            Return _String
        End Get
        Set(ByVal value As String)
            _String = value
        End Set
    End Property
 
    Dim _Number As Decimal
    Public Property TNumber() As Decimal
        Get
            Return _Number
        End Get
        Set(ByVal value As Decimal)
            _Number = value
        End Set
    End Property
 
    Dim _Count As Integer
    Public Property TCount() As Integer
        Get
            Return _Count
        End Get
        Set(ByVal value As Integer)
            _Count = value
        End Set
    End Property
 
    Dim _DTable As DataTable
    Public Property CTable() As DataTable
        Get
            Return _DTable
        End Get
        Set(ByVal value As DataTable)
            _DTable = value
        End Set
    End Property
 
End Class

Danke für die Hilfe

Gruß Christian

Public Sub createTransferdata()
        'Try
        tcOut = New NamedPipe.TransferDaten
        With tcOut
            .Typ = NamedPipe.TransferTyp
            If Not String.IsNullOrEmpty(TransferString) Then .TString = _
              TransferString
            Select Case .Typ
                Case NamedPipe.TransferTyp.Count
                    .TCount = TransferCount
                Case NamedPipe.TransferTyp.Table
                    .CTable = Nothing
                    .CTable = New DataTable
                    .CTable = TransferDataTable.Copy
                Case NamedPipe.TransferTyp.Decimal
                    .TNumber = TransferNumber
            End Select
        End With
        'Catch ex As Exception
        'tcOut = Nothing
        'End Try
    End Sub

Danke für die Hilfe

Gruß Christian

Public Function DataTableCopy(ByVal Dt As DataTable) As DataTable
        Dim DtN As New DataTable
        For Each C As DataColumn In Dt.Columns
            DtN.Columns.Add(C.ColumnName, C.DataType)
        Next
        For Each r As DataRow In Dt.Rows
            Dim nr As DataRow = DtN.NewRow
            For c As Integer = 0 To r.Table.Columns.Count - 1
                If Not r(c) Is DBNull.Value Then nr(c) = r(c)
            Next
            DtN.Rows.Add(nr)
        Next
        Return DtN
    End Function

.CTable = DataTableCopy(TransferDataTable)

Danke für die Hilfe

Gruß Christian

Danke für die Hilfe

Gruß Christian

Private Sub PipeClientStart(ByVal AnfrageString As String)
        If ps Is Nothing Then
            ps = New NamedPipe.Pipe
            RemoveHandler ps.PropertyChanged, AddressOf ServerAnswer
            AddHandler ps.PropertyChanged, AddressOf ServerAnswer
            RemoveHandler ps.PropertyChanged, AddressOf ClientTimeOut
            AddHandler ps.PropertyChanged, AddressOf ClientTimeOut
        End If
 
        With ps
            If String.IsNullOrEmpty(PipeServerName) Then PipeServerName = _
              .ServerName Else .ServerName = PipeServerName
            .PipeName = "MyPipeName"
            .ClientStart(AnfrageString)
        End With
    End Sub

 Private _PName As String = "Testpipe"
    Public Property PipeName() As String
        Get
            Return _PName
        End Get
        Set(ByVal value As String)
            _PName = value
        End Set
    End Property
 
    Private _ServerName As String = String.Empty
    Public Property ServerName() As String
        Get
            If _ServerName = String.Empty Then
                Using Pcs As New dlgServerName
                    Pcs.ShowDialog()
                    If Pcs.DialogResult = Windows.Forms.DialogResult.OK Then _
                      _ServerName = If(Pcs.PcName.Trim = String.Concat("\\", _
                      My.Computer.Name.Trim), ".", Pcs.PcName)
                End Using
            End If
            Return _ServerName
        End Get
        Set(ByVal value As String)
            If value = String.Concat("\\", My.Computer.Name.Trim) Then _
              _ServerName = "." Else _ServerName = value
        End Set
    End Property
 
 <System.Runtime.InteropServices.ComVisible(True)> _
 Public Sub ClientStart(ByVal AnfrageString As String)
        Using PipeClient As New NamedPipeClientStream(ServerName, PipeName, _
          PipeDirection.InOut, PipeOptions.None, _
          Security.Principal.TokenImpersonationLevel.Impersonation)
            ZeileAnzeigen("Client: --> warte auf Server..." & "PipeName = " _
            & String.Concat(ServerName, ",", PipeName))
            PipeClient.Connect()
            startTimer()
            PipeOn = True
            ZeileAnzeigen("Client: --> verbunden")
            sw = New StreamWriter(PipeClient)
            sw.AutoFlush = True
            sw.WriteLine(AnfrageString)
            ZeileAnzeigen("Client Anfrage: --> " & AnfrageString)
            If Not PipeOn Then PipeClient.Close()
            'Direkte Deserialisierung der empfangenen TC-Instanz
            ' Try
            Dim bfc As New BinaryFormatter
            Dim tc As TransferDaten = CType(bfc.Deserialize(PipeClient), _
              NamedPipe.TransferDaten)
            If Not tc Is Nothing Then ClientInput = tc : RaiseEvent _
            PropertyChanged(Me, ClientRequest) : TimeOut.Dispose()
            ' Catch ex As Exception
            'ZeileAnzeigen("Client Fehler: --> " & If(ex Is Nothing, "", 
            ' ex.InnerException.ToString))
            'TimeOut.Dispose()
            'End Try
            PipeClient.Close()
            ZeileAnzeigen("Client: --> beendet")
        End Using
    End Sub

Danke für die Hilfe

Gruß Christian

Danke für die Hilfe

Gruß Christian

Danke für die Hilfe

Gruß Christian

Danke für die Hilfe

Gruß Christian