70 lines
3.0 KiB
VB.net
70 lines
3.0 KiB
VB.net
Imports System.ServiceModel
|
|
Imports System.Xml
|
|
Imports DigitalData.Modules.Base
|
|
Imports DigitalData.Modules.Logging
|
|
|
|
Namespace WCF
|
|
Public Class Channel(Of TChannel As IClientChannel)
|
|
Inherits BaseClass
|
|
|
|
Private ReadOnly ChannelFactory As ChannelFactory(Of TChannel)
|
|
|
|
Public Event Reconnect As EventHandler
|
|
|
|
Public Sub New(pLogConfig As LogConfig, pServerAddress As ServerAddress)
|
|
MyBase.New(pLogConfig)
|
|
ChannelFactory = GetChannelFactory(pServerAddress)
|
|
End Sub
|
|
|
|
''' <summary>
|
|
''' Creates a channel and adds a Faulted-Handler
|
|
''' </summary>
|
|
''' <returns>A channel object</returns>
|
|
Public Function GetChannel() As TChannel
|
|
Try
|
|
Logger.Debug("Creating channel.")
|
|
Dim oChannel = ChannelFactory.CreateChannel()
|
|
|
|
AddHandler oChannel.Faulted, Sub() RaiseEvent Reconnect(Me, Nothing)
|
|
|
|
Return oChannel
|
|
Catch ex As Exception
|
|
Logger.Error(ex)
|
|
Throw ex
|
|
End Try
|
|
End Function
|
|
|
|
''' <summary>
|
|
''' Creates and returns a channel factory with the supplied name and address
|
|
''' </summary>
|
|
''' <param name="pName">The service name, will be: net.tcp://ip:port/DigitalData/Services/[name]</param>
|
|
''' <param name="pAddress">The service address, in the form of ip address and port</param>
|
|
''' <returns></returns>
|
|
Private Function GetChannelFactory(pAddress As ServerAddress, Optional pName As String = "Main") As ChannelFactory(Of TChannel)
|
|
Dim oBinding = GetBinding()
|
|
Dim oAddress = New EndpointAddress($"net.tcp://{pAddress.Host}:{pAddress.Port}/DigitalData/Services/{pName}")
|
|
Dim oFactory = New ChannelFactory(Of TChannel)(oBinding, oAddress)
|
|
Return oFactory
|
|
End Function
|
|
|
|
Public Shared Function GetBinding(Optional AuthenticationMode As TcpClientCredentialType = TcpClientCredentialType.Windows) As NetTcpBinding
|
|
Return New NetTcpBinding() With {
|
|
.MaxReceivedMessageSize = Constants.ChannelSettings.MAX_RECEIVED_MESSAGE_SIZE,
|
|
.MaxBufferSize = Constants.ChannelSettings.MAX_BUFFER_SIZE,
|
|
.MaxBufferPoolSize = Constants.ChannelSettings.MAX_BUFFER_POOL_SIZE,
|
|
.TransferMode = TransferMode.Streamed,
|
|
.Security = New NetTcpSecurity() With {
|
|
.Mode = SecurityMode.Transport,
|
|
.Transport = New TcpTransportSecurity() With {
|
|
.ClientCredentialType = AuthenticationMode
|
|
}
|
|
},
|
|
.ReaderQuotas = New XmlDictionaryReaderQuotas() With {
|
|
.MaxArrayLength = Constants.ChannelSettings.MAX_ARRAY_LENGTH,
|
|
.MaxStringContentLength = Constants.ChannelSettings.MAX_STRING_CONTENT_LENGTH
|
|
}
|
|
}
|
|
End Function
|
|
End Class
|
|
End Namespace
|