SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime 클래스 참조

더 자세히 ...

Public 멤버 함수
	CommunicationSampleRuntime (IMessageBus messageBus)
void	AddInMemoryChannel ()
async Task	ConnectInMemoryAsync ()
async Task	DisconnectInMemoryAsync ()
async Task	SendInMemoryAsync (string text)
void	ReceiveInMemory (string text)
async Task	StartTcpServerAsync (string protocol, string encodingName=PlainTextProtocolOptions.Utf8EncodingName, string sendTargetMode=nameof(TcpServerSendTargetMode.Broadcast), bool echoEnabled=false)
void	UpdateTcpServerOptions (string protocol, string encodingName=PlainTextProtocolOptions.Utf8EncodingName, string sendTargetMode=nameof(TcpServerSendTargetMode.Broadcast), bool echoEnabled=false)
async Task	StopTcpServerAsync ()
async Task	SendTcpServerAsync (string protocol, string text, string encodingName=PlainTextProtocolOptions.Utf8EncodingName, string sendTargetMode=nameof(TcpServerSendTargetMode.Broadcast))
async Task	ConnectTcpClientAsync (string protocol, string encodingName=PlainTextProtocolOptions.Utf8EncodingName)
async Task	DisconnectTcpClientAsync ()
async Task	SendTcpClientAsync (string protocol, string text, string encodingName=PlainTextProtocolOptions.Utf8EncodingName)
async Task	StopAllTcpAsync ()
async Task	StartUdpLoopbackAsync (string protocol, string encodingName=PlainTextProtocolOptions.Utf8EncodingName)
async Task	ConnectUdpPeerAAsync (string protocol, string encodingName=PlainTextProtocolOptions.Utf8EncodingName)
async Task	ConnectUdpPeerBAsync (string protocol, string encodingName=PlainTextProtocolOptions.Utf8EncodingName)
async Task	DisconnectUdpPeerAAsync ()
async Task	DisconnectUdpPeerBAsync ()
async Task	StopAllUdpAsync ()
async Task	SendUdpPeerAAsync (string protocol, string text, string encodingName=PlainTextProtocolOptions.Utf8EncodingName)
async Task	SendUdpPeerBAsync (string protocol, string text, string encodingName=PlainTextProtocolOptions.Utf8EncodingName)
async Task	ConnectSerialAsync (string portName, int baudRate, string protocol, string encodingName=PlainTextProtocolOptions.Utf8EncodingName)
async Task	DisconnectSerialAsync ()
async Task	SendSerialAsync (string protocol, string text, string encodingName=PlainTextProtocolOptions.Utf8EncodingName)
async Task	ConnectRabbitMqAsync (string host, int port, string virtualHost, string userName, string password, string exchangeName, string queueName, string routingKey)
async Task	SubscribeRabbitMqAsync (string exchangeName, string queueName, string routingKey)
async Task	PublishRabbitMqAsync (string exchangeName, string routingKey, string text)
async Task	DisconnectRabbitMqAsync ()
async Task	StopAllAsync ()

속성
CommunicationMonitorViewModel	Monitor [get]
IReadOnlyList< string >	TcpProtocols [get]
IReadOnlyList< string >	SerialProtocols [get]
IReadOnlyList< string >	UdpProtocols [get]
IReadOnlyList< string >	TextEncodings [get]
IReadOnlyList< string >	TcpServerSendTargetModes [get]
IReadOnlyList< string >	UdpTextEncodings [get]

Private 멤버 함수
async Task	PrepareTcpClientTransportAsync (string protocol, string encodingName)
async Task	SubscribeInMemoryAsync ()
async void	OnTcpServerMessageReceived (object? sender, MessageEnvelope message)
void	AttachTcpResilientStateMonitor (IMessageTransport transport, string channelName)
void	AttachTcpServerClientCountMonitor (TcpServerTransport tcpServerTransport, string protocol, string encodingName)
void	UpdateTcpServerDescription (string protocol, string encodingName, int clientCount, TcpServerSendTargetMode targetMode, bool echoEnabled)
void	AttachTcpClientQueueMonitor (IMessageTransport transport, string protocol, string encodingName, string channelName)
void	OnTcpClientMessageReceived (object? sender, MessageEnvelope message)
void	OnUdpPeerAMessageReceived (object? sender, MessageEnvelope message)
void	OnUdpPeerBMessageReceived (object? sender, MessageEnvelope message)
void	OnSerialMessageReceived (object? sender, MessageEnvelope message)
void	EnsureTcpServerChannel (string protocol, string encodingName=PlainTextProtocolOptions.Utf8EncodingName)
void	EnsureTcpClientChannel (string protocol, string encodingName=PlainTextProtocolOptions.Utf8EncodingName)
void	EnsureUdpPeerChannel (string peerName, string protocol, string encodingName)
void	EnsureSerialChannel ()
void	EnsureRabbitMqChannel ()
string	GetSerialChannelName ()
void	AddRabbitMqErrorLog (string name, string text)

정적 Private 멤버 함수
static ReconnectPolicy	CreateSampleReconnectPolicy ()
static OutboundQueueOptions	CreateSampleOutboundQueueOptions ()
static OutboundQueueOptions	CreateSampleServerOutboundQueueOptions ()
static string	CreateTcpServerDescription (string protocol, string encodingName, int port, int clientCount, TcpServerSendTargetMode targetMode, bool echoEnabled)
static IMessageProtocolAdapter	CreateProtocolAdapter (string protocol, string routePrefix="tcp", string namePrefix="Tcp", string encodingName=PlainTextProtocolOptions.Utf8EncodingName)
static IMessageFrameCodec	CreateFrameCodec (string protocol, string encodingName=PlainTextProtocolOptions.Utf8EncodingName)
static int	GetTcpPort (string protocol)
static string	GetTcpServerChannelName (string protocol, string encodingName=PlainTextProtocolOptions.Utf8EncodingName)
static string	GetTcpClientChannelName (string protocol, string encodingName=PlainTextProtocolOptions.Utf8EncodingName)
static string	GetUdpPeerChannelName (string peerName, string protocol, string encodingName=PlainTextProtocolOptions.Utf8EncodingName)
static string	NormalizeTextEncodingName (string encodingName)
static int	GetUdpLocalPort (string peerName)
static int	GetUdpRemotePort (string peerName)
static string	NormalizeUdpPeerName (string peerName)
static MessageEnvelope	CreateTcpMessageByProtocol (string protocol, string direction, string text, string encodingName=PlainTextProtocolOptions.Utf8EncodingName)
static MessageEnvelope	CreateUdpMessageByProtocol (string protocol, string direction, string text, string encodingName=PlainTextProtocolOptions.Utf8EncodingName)
static MessageEnvelope	CreateSerialMessageByProtocol (string protocol, string direction, string text, string encodingName=PlainTextProtocolOptions.Utf8EncodingName)
static MessageEnvelope	CreateRabbitMqMessage (string direction, string route, string text)
static MessageEnvelope	CreateTextMessage (string name, string route, string text, string protocol)
static byte[]	EnsureJsonPayload (string text)
static string	EscapeJsonString (string value)
static TcpServerSendTargetMode	NormalizeTcpServerSendTargetMode (string? sendTargetMode)
static string	NormalizeProtocol (string? protocol)
static string	NormalizeText (string? value, string defaultValue)
static void	RunOnUiThread (Action action)

Private 속성
readonly IMessageBus	_messageBus
bool	_isInMemorySubscribed
bool	_isRabbitMqSubscribed
IMessageTransport?	_tcpServer
TcpServerTransport?	_rawTcpServer
IMessageTransport?	_tcpClient
UdpTransport?	_udpPeerA
UdpTransport?	_udpPeerB
SerialPortTransport?	_serialTransport
RabbitMqMessageBus?	_rabbitMqBus
string	_currentServerProtocol = PlainTextProtocol
string	_currentClientProtocol = PlainTextProtocol
string	_currentServerEncoding = PlainTextProtocolOptions.Utf8EncodingName
string	_currentClientEncoding = PlainTextProtocolOptions.Utf8EncodingName
TcpServerSendTargetMode	_currentServerSendTargetMode = TcpServerSendTargetMode.Broadcast
bool	_currentServerEchoEnabled
string	_currentUdpPeerAProtocol = PlainTextProtocol
string	_currentUdpPeerBProtocol = PlainTextProtocol
string	_currentUdpPeerAEncoding = PlainTextProtocolOptions.Utf8EncodingName
string	_currentUdpPeerBEncoding = PlainTextProtocolOptions.Utf8EncodingName
string	_currentSerialProtocol = RawAvailableProtocol
string	_currentSerialEncoding = PlainTextProtocolOptions.Utf8EncodingName
string	_currentSerialPortName = string.Empty
int	_currentSerialBaudRate = 9600
string	_currentRabbitMqHost = "localhost"
int	_currentRabbitMqPort = 5672
string	_currentRabbitMqVirtualHost = "/"
string	_currentRabbitMqExchangeName = "dreamine.sample.exchange"
string	_currentRabbitMqQueueName = "dreamine.sample.queue"
string	_currentRabbitMqRoutingKey = "dreamine.sample.route"

정적 Private 속성
const string	InMemoryChannelName = "InMemory-Communication"
const string	InMemoryRouteName = "sample.communication.message"
const string	RabbitMqChannelName = "RabbitMQ-MessageBus"
const string	RabbitMqProtocol = "RabbitMQ"
const string	DreamineEnvelopeProtocol = "DreamineEnvelope"
const string	PlainTextProtocol = "PlainText"
const string	RawAvailableProtocol = "RawAvailable"
const string	RawJsonProtocol = "RawJson"
const int	DreamineProtocolPort = 15001
const int	PlainTextProtocolPort = 15002
const int	RawAvailableProtocolPort = 15002
const int	RawJsonProtocolPort = 15003
const int	UdpPeerALocalPort = 16001
const int	UdpPeerBLocalPort = 16002

상세한 설명

Communication 샘플 전체에서 공유되는 Runtime 컨텍스트입니다.

이 클래스는 Communication 샘플 탭들이 공유하는 Monitor, InMemory MessageBus, TCP Server, TCP Client, Serial Port, RabbitMQ MessageBus 인스턴스를 관리합니다.

CommunicationSampleRuntime.cs 파일의 39 번째 라인에서 정의되었습니다.

생성자 & 소멸자 문서화

CommunicationSampleRuntime()

SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.CommunicationSampleRuntime ( IMessageBus messageBus )

inline

CommunicationSampleRuntime 클래스의 새 인스턴스를 초기화합니다.

매개변수

messageBus

InMemory 샘플에 사용할 MessageBus입니다.

예외

ArgumentNullException

필수 입력 인자 중 하나가 null인 경우 발생합니다.

CommunicationSampleRuntime.cs 파일의 472 번째 라인에서 정의되었습니다.

    {
        _messageBus = messageBus ?? throw new ArgumentNullException(nameof(messageBus));
        Monitor = new CommunicationMonitorViewModel();
 
        _ = SubscribeInMemoryAsync();
    }

다음을 참조함 : _messageBus, Monitor, SubscribeInMemoryAsync().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

멤버 함수 문서화

AddInMemoryChannel()

void SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.AddInMemoryChannel ( )

inline

InMemory 채널을 추가합니다.

CommunicationSampleRuntime.cs 파일의 584 번째 라인에서 정의되었습니다.

    {
        if (Monitor.Channels.Any(x => x.Name == InMemoryChannelName))
        {
            return;
        }
 
        Monitor.AddChannel(
            InMemoryChannelName,
            TransportKind.InMemory,
            "SampleSmart in-memory communication channel.");
    }

다음을 참조함 : InMemoryChannelName, Monitor.

다음에 의해서 참조됨 : ConnectInMemoryAsync(), DisconnectInMemoryAsync(), ReceiveInMemory(), SendInMemoryAsync().

이 함수를 호출하는 함수들에 대한 그래프입니다.:

AddRabbitMqErrorLog()

void SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.AddRabbitMqErrorLog ( string name, string text )

inlineprivate

Rabbit Mq Error Log 항목을 추가합니다.

매개변수

name	name에 사용할 string 값입니다.
text	text에 사용할 string 값입니다.

CommunicationSampleRuntime.cs 파일의 4398 번째 라인에서 정의되었습니다.

    {
        var message = CreateTextMessage(
            name,
            _currentRabbitMqRoutingKey,
            text,
            RabbitMqProtocol);
 
        Monitor.AddReceiveLog(
            RabbitMqChannelName,
            TransportKind.RabbitMq,
            message);
    }

다음을 참조함 : _currentRabbitMqRoutingKey, CreateTextMessage(), Monitor, RabbitMqChannelName, RabbitMqProtocol.

다음에 의해서 참조됨 : ConnectRabbitMqAsync(), PublishRabbitMqAsync(), SubscribeRabbitMqAsync().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

이 함수를 호출하는 함수들에 대한 그래프입니다.:

AttachTcpClientQueueMonitor()

void SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.AttachTcpClientQueueMonitor ( IMessageTransport transport, string protocol, string encodingName, string channelName )

inlineprivate

대상 객체에 동작을 연결합니다.

매개변수

transport	transport에 사용할 IMessageTransport 값입니다.
protocol	protocol에 사용할 string 값입니다.
encodingName	encoding Name에 사용할 string 값입니다.
channelName	channel Name에 사용할 string 값입니다.

CommunicationSampleRuntime.cs 파일의 3014 번째 라인에서 정의되었습니다.

    {
        if (transport is not ResilientMessageTransport resilientTransport)
        {
            return;
        }
 
        resilientTransport.QueueCountChanged += (_, queueCount) =>
        {
            var queueStatusMessage = CreateTcpMessageByProtocol(
                protocol,
                "Client.QueueStatus",
                $"QueueCount={queueCount}, State={resilientTransport.State}",
                encodingName);
 
            RunOnUiThread(() =>
            {
                Monitor.AddReceiveLog(
                    channelName,
                    TransportKind.Tcp,
                    queueStatusMessage);
 
                Monitor.UpdateChannelState(
                    channelName,
                    resilientTransport.State);
            });
        };
    }

다음을 참조함 : CreateTcpMessageByProtocol(), Monitor, RunOnUiThread().

다음에 의해서 참조됨 : PrepareTcpClientTransportAsync().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

이 함수를 호출하는 함수들에 대한 그래프입니다.:

AttachTcpResilientStateMonitor()

void SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.AttachTcpResilientStateMonitor ( IMessageTransport transport, string channelName )

inlineprivate

대상 객체에 동작을 연결합니다.

매개변수

transport	transport에 사용할 IMessageTransport 값입니다.
channelName	channel Name에 사용할 string 값입니다.

CommunicationSampleRuntime.cs 파일의 2763 번째 라인에서 정의되었습니다.

    {
        if (transport is not ResilientMessageTransport resilientTransport)
        {
            return;
        }
 
        resilientTransport.StateChanged += (_, state) =>
        {
            RunOnUiThread(() =>
            {
                Monitor.UpdateChannelState(
                    channelName,
                    state);
            });
        };
    }

다음을 참조함 : Monitor, RunOnUiThread().

다음에 의해서 참조됨 : PrepareTcpClientTransportAsync(), StartTcpServerAsync().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

이 함수를 호출하는 함수들에 대한 그래프입니다.:

AttachTcpServerClientCountMonitor()

void SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.AttachTcpServerClientCountMonitor ( TcpServerTransport tcpServerTransport, string protocol, string encodingName )

inlineprivate

대상 객체에 동작을 연결합니다.

매개변수

tcpServerTransport	tcp Server Transport에 사용할 TcpServerTransport 값입니다.
protocol	protocol에 사용할 string 값입니다.
encodingName	encoding Name에 사용할 string 값입니다.

CommunicationSampleRuntime.cs 파일의 2815 번째 라인에서 정의되었습니다.

    {
        tcpServerTransport.ConnectedClientCountChanged += (_, clientCount) =>
        {
            RunOnUiThread(() =>
            {
                UpdateTcpServerDescription(
                    protocol,
                    encodingName,
                    clientCount,
                    _currentServerSendTargetMode,
                    _currentServerEchoEnabled);
            });
        };
    }

다음을 참조함 : _currentServerEchoEnabled, _currentServerSendTargetMode, RunOnUiThread(), UpdateTcpServerDescription().

다음에 의해서 참조됨 : StartTcpServerAsync().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

이 함수를 호출하는 함수들에 대한 그래프입니다.:

ConnectInMemoryAsync()

async Task SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.ConnectInMemoryAsync ( )

inline

InMemory MessageBus에 연결합니다.

반환값

Connect In Memory Async 작업에서 생성한 Task 결과입니다.

CommunicationSampleRuntime.cs 파일의 613 번째 라인에서 정의되었습니다.

    {
        AddInMemoryChannel();
 
        await _messageBus.ConnectAsync();
 
        Monitor.UpdateChannelState(
            InMemoryChannelName,
            ConnectionState.Connected);
    }

다음을 참조함 : _messageBus, AddInMemoryChannel(), InMemoryChannelName, Monitor.

다음에 의해서 참조됨 : SendInMemoryAsync().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

이 함수를 호출하는 함수들에 대한 그래프입니다.:

ConnectRabbitMqAsync()

async Task SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.ConnectRabbitMqAsync ( string host, int port, string virtualHost, string userName, string password, string exchangeName, string queueName, string routingKey )

inline

RabbitMQ에 연결합니다.

매개변수

host	RabbitMQ Host입니다.
port	RabbitMQ Port입니다.
virtualHost	RabbitMQ VirtualHost입니다.
userName	RabbitMQ 사용자 이름입니다.
password	RabbitMQ 비밀번호입니다.
exchangeName	Exchange 이름입니다.
queueName	Queue 이름입니다.
routingKey	RoutingKey입니다.

반환값

Connect Rabbit Mq Async 작업에서 생성한 Task 결과입니다.

CommunicationSampleRuntime.cs 파일의 2209 번째 라인에서 정의되었습니다.

    {
        host = NormalizeText(host, "localhost");
        virtualHost = NormalizeText(virtualHost, "/");
        userName = NormalizeText(userName, "guest");
        password = NormalizeText(password, "guest");
        exchangeName = NormalizeText(exchangeName, "dreamine.sample.exchange");
        queueName = NormalizeText(queueName, "dreamine.sample.queue");
        routingKey = NormalizeText(routingKey, "dreamine.sample.route");
 
        if (port <= 0 || port > 65535)
        {
            port = 5672;
        }
 
        if (_rabbitMqBus is not null &&
            _rabbitMqBus.State == ConnectionState.Connected &&
            _currentRabbitMqHost == host &&
            _currentRabbitMqPort == port &&
            _currentRabbitMqVirtualHost == virtualHost &&
            _currentRabbitMqExchangeName == exchangeName &&
            _currentRabbitMqQueueName == queueName &&
            _currentRabbitMqRoutingKey == routingKey)
        {
            return;
        }
 
        if (_rabbitMqBus is not null)
        {
            await DisconnectRabbitMqAsync();
        }
 
        _currentRabbitMqHost = host;
        _currentRabbitMqPort = port;
        _currentRabbitMqVirtualHost = virtualHost;
        _currentRabbitMqExchangeName = exchangeName;
        _currentRabbitMqQueueName = queueName;
        _currentRabbitMqRoutingKey = routingKey;
        _isRabbitMqSubscribed = false;
 
        EnsureRabbitMqChannel();
 
        _rabbitMqBus = new RabbitMqMessageBus(
            new RabbitMqMessageBusOptions
            {
                HostName = host,
                Port = port,
                VirtualHost = virtualHost,
                UserName = userName,
                Password = password,
                ExchangeName = exchangeName,
                QueueName = queueName,
                RoutingKey = routingKey
            });
 
        try
        {
            await _rabbitMqBus.ConnectAsync();
 
            Monitor.UpdateChannelState(
                RabbitMqChannelName,
                ConnectionState.Connected);
        }
        catch (Exception ex)
        {
            Monitor.UpdateChannelState(
                RabbitMqChannelName,
                ConnectionState.Faulted);
 
            AddRabbitMqErrorLog("RabbitMQ.Connect.Failed", ex.Message);
        }
    }

다음을 참조함 : _currentRabbitMqExchangeName, _currentRabbitMqHost, _currentRabbitMqPort, _currentRabbitMqQueueName, _currentRabbitMqRoutingKey, _currentRabbitMqVirtualHost, _isRabbitMqSubscribed, _rabbitMqBus, AddRabbitMqErrorLog(), DisconnectRabbitMqAsync(), EnsureRabbitMqChannel(), Monitor, NormalizeText(), RabbitMqChannelName.

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

ConnectSerialAsync()

async Task SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.ConnectSerialAsync ( string portName, int baudRate, string protocol, string encodingName = PlainTextProtocolOptions::Utf8EncodingName )

inline

선택된 설정으로 Serial Port를 연결합니다.

매개변수

portName	Serial Port 이름입니다.
baudRate	BaudRate입니다.
protocol	프로토콜 이름입니다.
encodingName	PlainText 외부 송수신 인코딩 이름입니다.

반환값

Connect Serial Async 작업에서 생성한 Task 결과입니다.

CommunicationSampleRuntime.cs 파일의 1954 번째 라인에서 정의되었습니다.

    {
        if (string.IsNullOrWhiteSpace(portName))
        {
            return;
        }
 
        protocol = NormalizeProtocol(protocol);
        encodingName = NormalizeTextEncodingName(encodingName);
 
        if (_serialTransport is not null &&
            _serialTransport.State == ConnectionState.Connected &&
            _currentSerialPortName == portName &&
            _currentSerialBaudRate == baudRate &&
            _currentSerialProtocol == protocol &&
            _currentSerialEncoding == encodingName)
        {
            return;
        }
 
        if (_serialTransport is not null)
        {
            await DisconnectSerialAsync();
        }
 
        _currentSerialPortName = portName;
        _currentSerialBaudRate = baudRate;
        _currentSerialProtocol = protocol;
        _currentSerialEncoding = encodingName;
 
        EnsureSerialChannel();
 
        _serialTransport = new SerialPortTransport(
            new SerialPortTransportOptions
            {
                PortName = portName,
                BaudRate = baudRate
            },
            CreateProtocolAdapter(
                protocol,
                "serial",
                "Serial",
                encodingName),
            CreateFrameCodec(protocol, encodingName));
 
        _serialTransport.MessageReceived += OnSerialMessageReceived;
 
        await _serialTransport.ConnectAsync();
 
        Monitor.UpdateChannelState(
            GetSerialChannelName(),
            ConnectionState.Connected);
    }

다음을 참조함 : _currentSerialBaudRate, _currentSerialEncoding, _currentSerialPortName, _currentSerialProtocol, _serialTransport, CreateFrameCodec(), CreateProtocolAdapter(), DisconnectSerialAsync(), EnsureSerialChannel(), GetSerialChannelName(), Monitor, NormalizeProtocol(), NormalizeTextEncodingName(), OnSerialMessageReceived().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

ConnectTcpClientAsync()

async Task SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.ConnectTcpClientAsync ( string protocol, string encodingName = PlainTextProtocolOptions::Utf8EncodingName )

inline

선택된 프로토콜로 TCP Client를 연결합니다.

매개변수

protocol	프로토콜 이름입니다.
encodingName	PlainText 외부 송수신 인코딩 이름입니다.

반환값

Connect Tcp Client Async 작업에서 생성한 Task 결과입니다.

CommunicationSampleRuntime.cs 파일의 1133 번째 라인에서 정의되었습니다.

    {
        protocol = NormalizeProtocol(protocol);
        encodingName = NormalizeTextEncodingName(encodingName);
 
        if (_tcpClient is not null &&
            _tcpClient.State == ConnectionState.Connected &&
            _currentClientProtocol == protocol &&
            _currentClientEncoding == encodingName)
        {
            return;
        }
 
        await PrepareTcpClientTransportAsync(protocol, encodingName);
 
        if (_tcpClient is null)
        {
            return;
        }
 
        var channelName = GetTcpClientChannelName(protocol, encodingName);
 
        Monitor.UpdateChannelState(channelName, ConnectionState.Connecting);
 
        try
        {
            await _tcpClient.ConnectAsync();
 
            Monitor.UpdateChannelState(
                channelName,
                _tcpClient.State);
        }
        catch
        {
            // ResilientMessageTransport의 내부 WatchLoop가 계속 재연결을 시도합니다.
            // 수동 Connect 실패는 UI 상태만 Connecting으로 유지하고 예외를 샘플 밖으로 전파하지 않습니다.
            Monitor.UpdateChannelState(channelName, ConnectionState.Connecting);
        }
    }

다음을 참조함 : _currentClientEncoding, _currentClientProtocol, _tcpClient, GetTcpClientChannelName(), Monitor, NormalizeProtocol(), NormalizeTextEncodingName(), PrepareTcpClientTransportAsync().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

ConnectUdpPeerAAsync()

async Task SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.ConnectUdpPeerAAsync ( string protocol, string encodingName = PlainTextProtocolOptions::Utf8EncodingName )

inline

선택된 프로토콜로 UDP Peer A를 시작합니다.

매개변수

protocol	프로토콜 이름입니다.
encodingName	PlainText 외부 송수신 인코딩 이름입니다.

반환값

Connect Udp Peer A Async 작업에서 생성한 Task 결과입니다.

CommunicationSampleRuntime.cs 파일의 1502 번째 라인에서 정의되었습니다.

    {
        protocol = NormalizeProtocol(protocol);
        encodingName = NormalizeTextEncodingName(encodingName);
 
        if (_udpPeerA is not null &&
            _udpPeerA.State == ConnectionState.Connected &&
            _currentUdpPeerAProtocol == protocol &&
            _currentUdpPeerAEncoding == encodingName)
        {
            return;
        }
 
        if (_udpPeerA is not null)
        {
            await DisconnectUdpPeerAAsync();
        }
 
        _currentUdpPeerAProtocol = protocol;
        _currentUdpPeerAEncoding = encodingName;
 
        EnsureUdpPeerChannel("A", protocol, encodingName);
 
        _udpPeerA = new UdpTransport(
            new UdpTransportOptions
            {
                LocalHost = "127.0.0.1",
                LocalPort = UdpPeerALocalPort,
                RemoteHost = "127.0.0.1",
                RemotePort = UdpPeerBLocalPort,
                ReuseAddress = true
            },
            CreateProtocolAdapter(
                protocol,
                "udp",
                "Udp",
                encodingName));
 
        _udpPeerA.MessageReceived += OnUdpPeerAMessageReceived;
 
        await _udpPeerA.ConnectAsync();
 
        Monitor.UpdateChannelState(
            GetUdpPeerChannelName("A", protocol, encodingName),
            ConnectionState.Connected);
    }

다음을 참조함 : _currentUdpPeerAEncoding, _currentUdpPeerAProtocol, _udpPeerA, CreateProtocolAdapter(), DisconnectUdpPeerAAsync(), EnsureUdpPeerChannel(), GetUdpPeerChannelName(), Monitor, NormalizeProtocol(), NormalizeTextEncodingName(), OnUdpPeerAMessageReceived(), UdpPeerALocalPort, UdpPeerBLocalPort.

다음에 의해서 참조됨 : SendUdpPeerAAsync(), StartUdpLoopbackAsync().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

이 함수를 호출하는 함수들에 대한 그래프입니다.:

ConnectUdpPeerBAsync()

async Task SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.ConnectUdpPeerBAsync ( string protocol, string encodingName = PlainTextProtocolOptions::Utf8EncodingName )

inline

선택된 프로토콜로 UDP Peer B를 시작합니다.

매개변수

protocol	프로토콜 이름입니다.
encodingName	PlainText 외부 송수신 인코딩 이름입니다.

반환값

Connect Udp Peer B Async 작업에서 생성한 Task 결과입니다.

CommunicationSampleRuntime.cs 파일의 1583 번째 라인에서 정의되었습니다.

    {
        protocol = NormalizeProtocol(protocol);
        encodingName = NormalizeTextEncodingName(encodingName);
 
        if (_udpPeerB is not null &&
            _udpPeerB.State == ConnectionState.Connected &&
            _currentUdpPeerBProtocol == protocol &&
            _currentUdpPeerBEncoding == encodingName)
        {
            return;
        }
 
        if (_udpPeerB is not null)
        {
            await DisconnectUdpPeerBAsync();
        }
 
        _currentUdpPeerBProtocol = protocol;
        _currentUdpPeerBEncoding = encodingName;
 
        EnsureUdpPeerChannel("B", protocol, encodingName);
 
        _udpPeerB = new UdpTransport(
            new UdpTransportOptions
            {
                LocalHost = "127.0.0.1",
                LocalPort = UdpPeerBLocalPort,
                RemoteHost = "127.0.0.1",
                RemotePort = UdpPeerALocalPort,
                ReuseAddress = true
            },
            CreateProtocolAdapter(
                protocol,
                "udp",
                "Udp",
                encodingName));
 
        _udpPeerB.MessageReceived += OnUdpPeerBMessageReceived;
 
        await _udpPeerB.ConnectAsync();
 
        Monitor.UpdateChannelState(
            GetUdpPeerChannelName("B", protocol, encodingName),
            ConnectionState.Connected);
    }

다음을 참조함 : _currentUdpPeerBEncoding, _currentUdpPeerBProtocol, _udpPeerB, CreateProtocolAdapter(), DisconnectUdpPeerBAsync(), EnsureUdpPeerChannel(), GetUdpPeerChannelName(), Monitor, NormalizeProtocol(), NormalizeTextEncodingName(), OnUdpPeerBMessageReceived(), UdpPeerALocalPort, UdpPeerBLocalPort.

다음에 의해서 참조됨 : SendUdpPeerBAsync(), StartUdpLoopbackAsync().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

이 함수를 호출하는 함수들에 대한 그래프입니다.:

CreateFrameCodec()

IMessageFrameCodec SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.CreateFrameCodec ( string protocol, string encodingName = PlainTextProtocolOptions::Utf8EncodingName )

inlinestaticprivate

Frame Codec 값을 생성합니다.

매개변수

protocol	protocol에 사용할 string 값입니다.
encodingName	encoding Name에 사용할 string 값입니다.

반환값

Create Frame Codec 작업에서 생성한 IMessageFrameCodec 결과입니다.

CommunicationSampleRuntime.cs 파일의 3530 번째 라인에서 정의되었습니다.

    {
        var delimiterEncoding = PlainTextProtocolOptions.CreateEncoding(encodingName);
 
        return NormalizeProtocol(protocol) switch
        {
            DreamineEnvelopeProtocol => new LengthPrefixedMessageFrameCodec(),
 
            PlainTextProtocol => new DelimiterMessageFrameCodec(
                "\r\n",
                delimiterEncoding,
                1024 * 1024),
 
            RawAvailableProtocol => new RawAvailableMessageFrameCodec(),
 
            RawJsonProtocol => new DelimiterMessageFrameCodec(
                "\r\n",
                Encoding.UTF8,
                1024 * 1024),
 
            _ => new DelimiterMessageFrameCodec(
                "\r\n",
                delimiterEncoding,
                1024 * 1024)
        };
    }

다음을 참조함 : DreamineEnvelopeProtocol, NormalizeProtocol(), PlainTextProtocol, RawAvailableProtocol, RawJsonProtocol.

다음에 의해서 참조됨 : ConnectSerialAsync(), PrepareTcpClientTransportAsync(), StartTcpServerAsync().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

이 함수를 호출하는 함수들에 대한 그래프입니다.:

CreateProtocolAdapter()

IMessageProtocolAdapter SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.CreateProtocolAdapter ( string protocol, string routePrefix = "tcp", string namePrefix = "Tcp", string encodingName = PlainTextProtocolOptions::Utf8EncodingName )

inlinestaticprivate

Protocol Adapter 값을 생성합니다.

매개변수

protocol	protocol에 사용할 string 값입니다.
routePrefix	route Prefix에 사용할 string 값입니다.
namePrefix	name Prefix에 사용할 string 값입니다.
encodingName	encoding Name에 사용할 string 값입니다.

반환값

Create Protocol Adapter 작업에서 생성한 IMessageProtocolAdapter 결과입니다.

CommunicationSampleRuntime.cs 파일의 3463 번째 라인에서 정의되었습니다.

    {
        var normalizedProtocol = NormalizeProtocol(protocol);
        var textEncoding = PlainTextProtocolOptions.CreateEncoding(encodingName);
 
        return normalizedProtocol switch
        {
            DreamineEnvelopeProtocol => new DreamineEnvelopeProtocolAdapter(),
 
            PlainTextProtocol => new PlainTextProtocolAdapter(
                textEncoding,
                $"{routePrefix}.plaintext",
                $"{namePrefix}.PlainText"),
 
            RawAvailableProtocol => new PlainTextProtocolAdapter(
                textEncoding,
                $"{routePrefix}.raw.available",
                $"{namePrefix}.RawAvailable"),
 
            RawJsonProtocol => new RawJsonProtocolAdapter(
                textEncoding,
                $"{routePrefix}.rawjson",
                $"{namePrefix}.RawJson"),
 
            _ => new PlainTextProtocolAdapter(
                textEncoding,
                $"{routePrefix}.plaintext",
                $"{namePrefix}.PlainText")
        };
    }

다음을 참조함 : DreamineEnvelopeProtocol, NormalizeProtocol(), PlainTextProtocol, RawAvailableProtocol, RawJsonProtocol.

다음에 의해서 참조됨 : ConnectSerialAsync(), ConnectUdpPeerAAsync(), ConnectUdpPeerBAsync(), PrepareTcpClientTransportAsync(), StartTcpServerAsync().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

이 함수를 호출하는 함수들에 대한 그래프입니다.:

CreateRabbitMqMessage()

MessageEnvelope SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.CreateRabbitMqMessage ( string direction, string route, string text )

inlinestaticprivate

Rabbit Mq Message 값을 생성합니다.

매개변수

direction	direction에 사용할 string 값입니다.
route	route에 사용할 string 값입니다.
text	text에 사용할 string 값입니다.

반환값

Create Rabbit Mq Message 작업에서 생성한 MessageEnvelope 결과입니다.

CommunicationSampleRuntime.cs 파일의 4289 번째 라인에서 정의되었습니다.

    {
        return new MessageEnvelope
        {
            Name = $"RabbitMQ.{direction}",
            Route = route,
            Payload = Encoding.UTF8.GetBytes(text),
            Headers = new Dictionary<string, string>
            {
                ["ContentType"] = "text/plain",
                ["Protocol"] = RabbitMqProtocol
            }
        };
    }

다음을 참조함 : RabbitMqProtocol.

다음에 의해서 참조됨 : PublishRabbitMqAsync().

이 함수를 호출하는 함수들에 대한 그래프입니다.:

CreateSampleOutboundQueueOptions()

OutboundQueueOptions SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.CreateSampleOutboundQueueOptions ( )

inlinestaticprivate

SampleSmart TCP Client 예제에서 사용할 송신 큐 정책을 생성합니다.

반환값

송신 큐 정책입니다.

CommunicationSampleRuntime.cs 파일의 2699 번째 라인에서 정의되었습니다.

    {
        return new OutboundQueueOptions
        {
            DisconnectedSendPolicy = DisconnectedSendPolicy.Queue,
            MaxQueueSize = 10_000,
            DropOldestWhenFull = true,
            MaxMessageAge = null,
            FlushOnReconnect = true
        };
    }

다음에 의해서 참조됨 : PrepareTcpClientTransportAsync().

이 함수를 호출하는 함수들에 대한 그래프입니다.:

CreateSampleReconnectPolicy()

ReconnectPolicy SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.CreateSampleReconnectPolicy ( )

inlinestaticprivate

SampleSmart TCP Client 예제에서 사용할 재연결 정책을 생성합니다.

반환값

재연결 정책입니다.

CommunicationSampleRuntime.cs 파일의 2670 번째 라인에서 정의되었습니다.

    {
        return new ReconnectPolicy
        {
            Enabled = true,
            InitialDelay = TimeSpan.FromSeconds(1),
            MaxDelay = TimeSpan.FromSeconds(5),
            BackoffFactor = 1.5,
            MaxRetryCount = null,
            WatchInterval = TimeSpan.FromMilliseconds(500)
        };
    }

다음에 의해서 참조됨 : PrepareTcpClientTransportAsync(), StartTcpServerAsync().

이 함수를 호출하는 함수들에 대한 그래프입니다.:

CreateSampleServerOutboundQueueOptions()

OutboundQueueOptions SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.CreateSampleServerOutboundQueueOptions ( )

inlinestaticprivate

TCP Server 예제에서 사용할 송신 큐 정책을 생성합니다.

반환값

송신 큐 정책입니다.

CommunicationSampleRuntime.cs 파일의 2727 번째 라인에서 정의되었습니다.

    {
        return new OutboundQueueOptions
        {
            DisconnectedSendPolicy = DisconnectedSendPolicy.Fail,
            MaxQueueSize = 1_000,
            DropOldestWhenFull = true,
            MaxMessageAge = null,
            FlushOnReconnect = false
        };
    }

다음에 의해서 참조됨 : StartTcpServerAsync().

이 함수를 호출하는 함수들에 대한 그래프입니다.:

CreateSerialMessageByProtocol()

MessageEnvelope SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.CreateSerialMessageByProtocol ( string protocol, string direction, string text, string encodingName = PlainTextProtocolOptions::Utf8EncodingName )

inlinestaticprivate

Serial Message By Protocol 값을 생성합니다.

매개변수

protocol	protocol에 사용할 string 값입니다.
direction	direction에 사용할 string 값입니다.
text	text에 사용할 string 값입니다.
encodingName	encoding Name에 사용할 string 값입니다.

반환값

Create Serial Message By Protocol 작업에서 생성한 MessageEnvelope 결과입니다.

CommunicationSampleRuntime.cs 파일의 4173 번째 라인에서 정의되었습니다.

    {
        var normalizedProtocol = NormalizeProtocol(protocol);
        var normalizedEncodingName = NormalizeTextEncodingName(encodingName);
        var payload = Encoding.UTF8.GetBytes(text);
 
        return normalizedProtocol switch
        {
            DreamineEnvelopeProtocol => new MessageEnvelope
            {
                Name = $"Serial.{direction}.DreamineEnvelope",
                Route = "sample.communication.serial",
                Payload = payload,
                Headers = new Dictionary<string, string>
                {
                    ["Protocol"] = DreamineEnvelopeProtocol
                }
            },
 
            PlainTextProtocol => new MessageEnvelope
            {
                Name = $"Serial.{direction}.PlainText",
                Route = "serial.plaintext",
                Payload = payload,
                Headers = new Dictionary<string, string>
                {
                    ["ContentType"] = "text/plain",
                    ["Protocol"] = PlainTextProtocol,
                    ["ExternalEncoding"] = normalizedEncodingName
                }
            },
 
            RawAvailableProtocol => new MessageEnvelope
            {
                Name = $"Serial.{direction}.RawAvailable",
                Route = "serial.raw.available",
                Payload = payload,
                Headers = new Dictionary<string, string>
                {
                    ["ContentType"] = "text/plain",
                    ["Protocol"] = RawAvailableProtocol,
                    ["ExternalEncoding"] = normalizedEncodingName
                }
            },
 
            RawJsonProtocol => new MessageEnvelope
            {
                Name = $"Serial.{direction}.RawJson",
                Route = "serial.rawjson",
                Payload = EnsureJsonPayload(text),
                Headers = new Dictionary<string, string>
                {
                    ["ContentType"] = "application/json",
                    ["Protocol"] = RawJsonProtocol
                }
            },
 
            _ => new MessageEnvelope
            {
                Name = $"Serial.{direction}.PlainText",
                Route = "serial.plaintext",
                Payload = payload,
                Headers = new Dictionary<string, string>
                {
                    ["ContentType"] = "text/plain",
                    ["Protocol"] = PlainTextProtocol,
                    ["ExternalEncoding"] = normalizedEncodingName
                }
            }
        };
    }

다음을 참조함 : DreamineEnvelopeProtocol, EnsureJsonPayload(), NormalizeProtocol(), NormalizeTextEncodingName(), PlainTextProtocol, RawAvailableProtocol, RawJsonProtocol.

다음에 의해서 참조됨 : SendSerialAsync().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

이 함수를 호출하는 함수들에 대한 그래프입니다.:

CreateTcpMessageByProtocol()

MessageEnvelope SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.CreateTcpMessageByProtocol ( string protocol, string direction, string text, string encodingName = PlainTextProtocolOptions::Utf8EncodingName )

inlinestaticprivate

Tcp Message By Protocol 값을 생성합니다.

매개변수

protocol	protocol에 사용할 string 값입니다.
direction	direction에 사용할 string 값입니다.
text	text에 사용할 string 값입니다.
encodingName	encoding Name에 사용할 string 값입니다.

반환값

Create Tcp Message By Protocol 작업에서 생성한 MessageEnvelope 결과입니다.

CommunicationSampleRuntime.cs 파일의 3925 번째 라인에서 정의되었습니다.

    {
        var normalizedProtocol = NormalizeProtocol(protocol);
        var normalizedEncodingName = NormalizeTextEncodingName(encodingName);
        var payload = Encoding.UTF8.GetBytes(text);
 
        return normalizedProtocol switch
        {
            DreamineEnvelopeProtocol => new MessageEnvelope
            {
                Name = $"Tcp.{direction}.DreamineEnvelope",
                Route = "sample.communication.tcp",
                Payload = payload,
                Headers = new Dictionary<string, string>
                {
                    ["Protocol"] = DreamineEnvelopeProtocol
                }
            },
 
            PlainTextProtocol => new MessageEnvelope
            {
                Name = $"Tcp.{direction}.PlainText",
                Route = "tcp.plaintext",
                Payload = payload,
                Headers = new Dictionary<string, string>
                {
                    ["ContentType"] = "text/plain",
                    ["Protocol"] = PlainTextProtocol,
                    ["ExternalEncoding"] = normalizedEncodingName
                }
            },
 
            RawAvailableProtocol => new MessageEnvelope
            {
                Name = $"Tcp.{direction}.RawAvailable",
                Route = "tcp.raw.available",
                Payload = payload,
                Headers = new Dictionary<string, string>
                {
                    ["ContentType"] = "text/plain",
                    ["Protocol"] = RawAvailableProtocol,
                    ["ExternalEncoding"] = normalizedEncodingName
                }
            },
 
            RawJsonProtocol => new MessageEnvelope
            {
                Name = $"Tcp.{direction}.RawJson",
                Route = "tcp.rawjson",
                Payload = EnsureJsonPayload(text),
                Headers = new Dictionary<string, string>
                {
                    ["ContentType"] = "application/json",
                    ["Protocol"] = RawJsonProtocol
                }
            },
 
            _ => new MessageEnvelope
            {
                Name = $"Tcp.{direction}.PlainText",
                Route = "tcp.plaintext",
                Payload = payload,
                Headers = new Dictionary<string, string>
                {
                    ["ContentType"] = "text/plain",
                    ["Protocol"] = PlainTextProtocol,
                    ["ExternalEncoding"] = normalizedEncodingName
                }
            }
        };
    }

다음을 참조함 : DreamineEnvelopeProtocol, EnsureJsonPayload(), NormalizeProtocol(), NormalizeTextEncodingName(), PlainTextProtocol, RawAvailableProtocol, RawJsonProtocol.

다음에 의해서 참조됨 : AttachTcpClientQueueMonitor(), OnTcpServerMessageReceived(), SendTcpClientAsync(), SendTcpServerAsync().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

이 함수를 호출하는 함수들에 대한 그래프입니다.:

CreateTcpServerDescription()

string SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.CreateTcpServerDescription ( string protocol, string encodingName, int port, int clientCount, TcpServerSendTargetMode targetMode, bool echoEnabled )

inlinestaticprivate

Tcp Server Description 값을 생성합니다.

매개변수

protocol	protocol에 사용할 string 값입니다.
encodingName	encoding Name에 사용할 string 값입니다.
port	port에 사용할 int 값입니다.
clientCount	client Count에 사용할 int 값입니다.
targetMode	target Mode에 사용할 TcpServerSendTargetMode 값입니다.
echoEnabled	echo Enabled에 사용할 bool 값입니다.

반환값

Create Tcp Server Description 작업에서 생성한 string 결과입니다.

CommunicationSampleRuntime.cs 파일의 2961 번째 라인에서 정의되었습니다.

    {
        var echoText = echoEnabled ? "On" : "Off";
 
        return $"TCP server [{protocol}/{NormalizeTextEncodingName(encodingName)}] on 127.0.0.1:{port}. Clients={clientCount}. Target={targetMode}. Echo={echoText}.";
    }

다음에 의해서 참조됨 : EnsureTcpServerChannel(), UpdateTcpServerDescription().

이 함수를 호출하는 함수들에 대한 그래프입니다.:

CreateTextMessage()

MessageEnvelope SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.CreateTextMessage ( string name, string route, string text, string protocol )

inlinestaticprivate

Text Message 값을 생성합니다.

매개변수

name	name에 사용할 string 값입니다.
route	route에 사용할 string 값입니다.
text	text에 사용할 string 값입니다.
protocol	protocol에 사용할 string 값입니다.

반환값

Create Text Message 작업에서 생성한 MessageEnvelope 결과입니다.

CommunicationSampleRuntime.cs 파일의 4355 번째 라인에서 정의되었습니다.

    {
        return new MessageEnvelope
        {
            Name = name,
            Route = route,
            Payload = Encoding.UTF8.GetBytes(text),
            Headers = new Dictionary<string, string>
            {
                ["ContentType"] = "text/plain",
                ["Protocol"] = protocol
            }
        };
    }

다음에 의해서 참조됨 : AddRabbitMqErrorLog(), ReceiveInMemory(), SendInMemoryAsync().

이 함수를 호출하는 함수들에 대한 그래프입니다.:

CreateUdpMessageByProtocol()

MessageEnvelope SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.CreateUdpMessageByProtocol ( string protocol, string direction, string text, string encodingName = PlainTextProtocolOptions::Utf8EncodingName )

inlinestaticprivate

Udp Message By Protocol 값을 생성합니다.

매개변수

protocol	protocol에 사용할 string 값입니다.
direction	direction에 사용할 string 값입니다.
text	text에 사용할 string 값입니다.
encodingName	encoding Name에 사용할 string 값입니다.

반환값

Create Udp Message By Protocol 작업에서 생성한 MessageEnvelope 결과입니다.

CommunicationSampleRuntime.cs 파일의 4049 번째 라인에서 정의되었습니다.

    {
        var normalizedProtocol = NormalizeProtocol(protocol);
        var normalizedEncodingName = NormalizeTextEncodingName(encodingName);
        var payload = Encoding.UTF8.GetBytes(text);
 
        return normalizedProtocol switch
        {
            DreamineEnvelopeProtocol => new MessageEnvelope
            {
                Name = $"Udp.{direction}.DreamineEnvelope",
                Route = "sample.communication.udp",
                Payload = payload,
                Headers = new Dictionary<string, string>
                {
                    ["Protocol"] = DreamineEnvelopeProtocol
                }
            },
 
            PlainTextProtocol => new MessageEnvelope
            {
                Name = $"Udp.{direction}.PlainText",
                Route = "udp.plaintext",
                Payload = payload,
                Headers = new Dictionary<string, string>
                {
                    ["ContentType"] = "text/plain",
                    ["Protocol"] = PlainTextProtocol,
                    ["ExternalEncoding"] = normalizedEncodingName
                }
            },
 
            RawAvailableProtocol => new MessageEnvelope
            {
                Name = $"Udp.{direction}.RawAvailable",
                Route = "udp.raw.available",
                Payload = payload,
                Headers = new Dictionary<string, string>
                {
                    ["ContentType"] = "text/plain",
                    ["Protocol"] = RawAvailableProtocol,
                    ["ExternalEncoding"] = normalizedEncodingName
                }
            },
 
            RawJsonProtocol => new MessageEnvelope
            {
                Name = $"Udp.{direction}.RawJson",
                Route = "udp.rawjson",
                Payload = EnsureJsonPayload(text),
                Headers = new Dictionary<string, string>
                {
                    ["ContentType"] = "application/json",
                    ["Protocol"] = RawJsonProtocol
                }
            },
 
            _ => new MessageEnvelope
            {
                Name = $"Udp.{direction}.PlainText",
                Route = "udp.plaintext",
                Payload = payload,
                Headers = new Dictionary<string, string>
                {
                    ["ContentType"] = "text/plain",
                    ["Protocol"] = PlainTextProtocol,
                    ["ExternalEncoding"] = normalizedEncodingName
                }
            }
        };
    }

다음을 참조함 : DreamineEnvelopeProtocol, EnsureJsonPayload(), NormalizeProtocol(), NormalizeTextEncodingName(), PlainTextProtocol, RawAvailableProtocol, RawJsonProtocol.

다음에 의해서 참조됨 : SendUdpPeerAAsync(), SendUdpPeerBAsync().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

이 함수를 호출하는 함수들에 대한 그래프입니다.:

DisconnectInMemoryAsync()

async Task SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.DisconnectInMemoryAsync ( )

inline

InMemory MessageBus 연결을 해제합니다.

반환값

Disconnect In Memory Async 작업에서 생성한 Task 결과입니다.

CommunicationSampleRuntime.cs 파일의 640 번째 라인에서 정의되었습니다.

    {
        AddInMemoryChannel();
 
        await _messageBus.DisconnectAsync();
 
        Monitor.UpdateChannelState(
            InMemoryChannelName,
            ConnectionState.Disconnected);
    }

다음을 참조함 : _messageBus, AddInMemoryChannel(), InMemoryChannelName, Monitor.

다음에 의해서 참조됨 : StopAllAsync().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

이 함수를 호출하는 함수들에 대한 그래프입니다.:

DisconnectRabbitMqAsync()

async Task SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.DisconnectRabbitMqAsync ( )

inline

RabbitMQ 연결을 해제합니다.

반환값

Disconnect Rabbit Mq Async 작업에서 생성한 Task 결과입니다.

CommunicationSampleRuntime.cs 파일의 2497 번째 라인에서 정의되었습니다.

    {
        if (_rabbitMqBus is null)
        {
            if (Monitor.Channels.Any(x => x.Name == RabbitMqChannelName))
            {
                Monitor.UpdateChannelState(
                    RabbitMqChannelName,
                    ConnectionState.Disconnected);
            }
 
            return;
        }
 
        await _rabbitMqBus.DisposeAsync();
 
        _rabbitMqBus = null;
        _isRabbitMqSubscribed = false;
 
        if (Monitor.Channels.Any(x => x.Name == RabbitMqChannelName))
        {
            Monitor.UpdateChannelState(
                RabbitMqChannelName,
                ConnectionState.Disconnected);
        }
    }

다음을 참조함 : _isRabbitMqSubscribed, _rabbitMqBus, Monitor, RabbitMqChannelName.

다음에 의해서 참조됨 : ConnectRabbitMqAsync(), StopAllAsync().

이 함수를 호출하는 함수들에 대한 그래프입니다.:

DisconnectSerialAsync()

async Task SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.DisconnectSerialAsync ( )

inline

현재 Serial Port 연결을 해제합니다.

반환값

Disconnect Serial Async 작업에서 생성한 Task 결과입니다.

CommunicationSampleRuntime.cs 파일의 2028 번째 라인에서 정의되었습니다.

    {
        var channelName = GetSerialChannelName();
 
        if (_serialTransport is null)
        {
            if (Monitor.Channels.Any(x => x.Name == channelName))
            {
                Monitor.UpdateChannelState(channelName, ConnectionState.Disconnected);
            }
 
            return;
        }
 
        _serialTransport.MessageReceived -= OnSerialMessageReceived;
 
        await _serialTransport.DisposeAsync();
 
        _serialTransport = null;
 
        if (Monitor.Channels.Any(x => x.Name == channelName))
        {
            Monitor.UpdateChannelState(channelName, ConnectionState.Disconnected);
        }
    }

다음을 참조함 : _serialTransport, GetSerialChannelName(), Monitor, OnSerialMessageReceived().

다음에 의해서 참조됨 : ConnectSerialAsync(), StopAllAsync().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

이 함수를 호출하는 함수들에 대한 그래프입니다.:

DisconnectTcpClientAsync()

async Task SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.DisconnectTcpClientAsync ( )

inline

현재 TCP Client 연결을 해제합니다.

반환값

Disconnect Tcp Client Async 작업에서 생성한 Task 결과입니다.

CommunicationSampleRuntime.cs 파일의 1286 번째 라인에서 정의되었습니다.

    {
        var protocol = _currentClientProtocol;
        var encodingName = _currentClientEncoding;
        var channelName = GetTcpClientChannelName(protocol, encodingName);
 
        if (_tcpClient is null)
        {
            if (Monitor.Channels.Any(x => x.Name == channelName))
            {
                Monitor.UpdateChannelState(channelName, ConnectionState.Disconnected);
            }
 
            return;
        }
 
        _tcpClient.MessageReceived -= OnTcpClientMessageReceived;
 
        await _tcpClient.DisposeAsync();
 
        _tcpClient = null;
 
        if (Monitor.Channels.Any(x => x.Name == channelName))
        {
            Monitor.UpdateChannelState(channelName, ConnectionState.Disconnected);
        }
    }

다음을 참조함 : _currentClientEncoding, _currentClientProtocol, _tcpClient, GetTcpClientChannelName(), Monitor, OnTcpClientMessageReceived().

다음에 의해서 참조됨 : PrepareTcpClientTransportAsync(), StopAllTcpAsync().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

이 함수를 호출하는 함수들에 대한 그래프입니다.:

DisconnectUdpPeerAAsync()

async Task SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.DisconnectUdpPeerAAsync ( )

inline

UDP Peer A 연결을 해제합니다.

반환값

Disconnect Udp Peer A Async 작업에서 생성한 Task 결과입니다.

CommunicationSampleRuntime.cs 파일의 1648 번째 라인에서 정의되었습니다.

    {
        var protocol = _currentUdpPeerAProtocol;
        var encodingName = _currentUdpPeerAEncoding;
        var channelName = GetUdpPeerChannelName("A", protocol, encodingName);
 
        if (_udpPeerA is null)
        {
            if (Monitor.Channels.Any(x => x.Name == channelName))
            {
                Monitor.UpdateChannelState(channelName, ConnectionState.Disconnected);
            }
 
            return;
        }
 
        _udpPeerA.MessageReceived -= OnUdpPeerAMessageReceived;
 
        await _udpPeerA.DisposeAsync();
 
        _udpPeerA = null;
 
        if (Monitor.Channels.Any(x => x.Name == channelName))
        {
            Monitor.UpdateChannelState(channelName, ConnectionState.Disconnected);
        }
    }

다음을 참조함 : _currentUdpPeerAEncoding, _currentUdpPeerAProtocol, _udpPeerA, GetUdpPeerChannelName(), Monitor, OnUdpPeerAMessageReceived().

다음에 의해서 참조됨 : ConnectUdpPeerAAsync(), StopAllUdpAsync().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

이 함수를 호출하는 함수들에 대한 그래프입니다.:

DisconnectUdpPeerBAsync()

async Task SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.DisconnectUdpPeerBAsync ( )

inline

UDP Peer B 연결을 해제합니다.

반환값

Disconnect Udp Peer B Async 작업에서 생성한 Task 결과입니다.

CommunicationSampleRuntime.cs 파일의 1692 번째 라인에서 정의되었습니다.

    {
        var protocol = _currentUdpPeerBProtocol;
        var encodingName = _currentUdpPeerBEncoding;
        var channelName = GetUdpPeerChannelName("B", protocol, encodingName);
 
        if (_udpPeerB is null)
        {
            if (Monitor.Channels.Any(x => x.Name == channelName))
            {
                Monitor.UpdateChannelState(channelName, ConnectionState.Disconnected);
            }
 
            return;
        }
 
        _udpPeerB.MessageReceived -= OnUdpPeerBMessageReceived;
 
        await _udpPeerB.DisposeAsync();
 
        _udpPeerB = null;
 
        if (Monitor.Channels.Any(x => x.Name == channelName))
        {
            Monitor.UpdateChannelState(channelName, ConnectionState.Disconnected);
        }
    }

다음을 참조함 : _currentUdpPeerBEncoding, _currentUdpPeerBProtocol, _udpPeerB, GetUdpPeerChannelName(), Monitor, OnUdpPeerBMessageReceived().

다음에 의해서 참조됨 : ConnectUdpPeerBAsync(), StopAllUdpAsync().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

이 함수를 호출하는 함수들에 대한 그래프입니다.:

EnsureJsonPayload()

byte[] SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.EnsureJsonPayload ( string text )

inlinestaticprivate

Ensure Json Payload 작업을 수행합니다.

매개변수

text	text에 사용할 string 값입니다.

반환값

Ensure Json Payload 작업에서 생성한 byte[] 결과입니다.

CommunicationSampleRuntime.cs 파일의 4438 번째 라인에서 정의되었습니다.

    {
        if (string.IsNullOrWhiteSpace(text))
        {
            text = "{\"cmd\":\"PING\"}";
        }
 
        var trimmed = text.Trim();
 
        if (trimmed.StartsWith("{", StringComparison.Ordinal) ||
            trimmed.StartsWith("[", StringComparison.Ordinal))
        {
            return Encoding.UTF8.GetBytes(trimmed);
        }
 
        var json = $$"""
        {"message":"{{EscapeJsonString(text)}}"}
        """;
 
        return Encoding.UTF8.GetBytes(json);
    }

다음을 참조함 : EscapeJsonString().

다음에 의해서 참조됨 : CreateSerialMessageByProtocol(), CreateTcpMessageByProtocol(), CreateUdpMessageByProtocol().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

이 함수를 호출하는 함수들에 대한 그래프입니다.:

EnsureRabbitMqChannel()

void SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.EnsureRabbitMqChannel ( )

inlineprivate

Ensure Rabbit Mq Channel 작업을 수행합니다.

CommunicationSampleRuntime.cs 파일의 3376 번째 라인에서 정의되었습니다.

    {
        if (Monitor.Channels.Any(x => x.Name == RabbitMqChannelName))
        {
            return;
        }
 
        Monitor.AddChannel(
            RabbitMqChannelName,
            TransportKind.RabbitMq,
            $"RabbitMQ on {_currentRabbitMqHost}:{_currentRabbitMqPort}, vhost={_currentRabbitMqVirtualHost}, exchange={_currentRabbitMqExchangeName}, queue={_currentRabbitMqQueueName}, route={_currentRabbitMqRoutingKey}.");
    }

다음을 참조함 : Monitor, RabbitMqChannelName.

다음에 의해서 참조됨 : ConnectRabbitMqAsync().

이 함수를 호출하는 함수들에 대한 그래프입니다.:

EnsureSerialChannel()

void SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.EnsureSerialChannel ( )

inlineprivate

Ensure Serial Channel 작업을 수행합니다.

CommunicationSampleRuntime.cs 파일의 3353 번째 라인에서 정의되었습니다.

    {
        var channelName = GetSerialChannelName();
 
        if (Monitor.Channels.Any(x => x.Name == channelName))
        {
            return;
        }
 
        Monitor.AddChannel(
            channelName,
            TransportKind.Serial,
            $"Serial [{_currentSerialProtocol}/{_currentSerialEncoding}] on {_currentSerialPortName}:{_currentSerialBaudRate}.");
    }

다음을 참조함 : GetSerialChannelName(), Monitor.

다음에 의해서 참조됨 : ConnectSerialAsync().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

이 함수를 호출하는 함수들에 대한 그래프입니다.:

EnsureTcpClientChannel()

void SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.EnsureTcpClientChannel ( string protocol, string encodingName = PlainTextProtocolOptions::Utf8EncodingName )

inlineprivate

Ensure Tcp Client Channel 작업을 수행합니다.

매개변수

protocol	protocol에 사용할 string 값입니다.
encodingName	encoding Name에 사용할 string 값입니다.

CommunicationSampleRuntime.cs 파일의 3273 번째 라인에서 정의되었습니다.

    {
        var channelName = GetTcpClientChannelName(protocol, encodingName);
        var port = GetTcpPort(protocol);
 
        if (Monitor.Channels.Any(x => x.Name == channelName))
        {
            return;
        }
 
        Monitor.AddChannel(
            channelName,
            TransportKind.Tcp,
            $"TCP client [{protocol}/{NormalizeTextEncodingName(encodingName)}] to 127.0.0.1:{port}.");
    }

다음을 참조함 : GetTcpClientChannelName(), GetTcpPort(), Monitor.

다음에 의해서 참조됨 : PrepareTcpClientTransportAsync().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

이 함수를 호출하는 함수들에 대한 그래프입니다.:

EnsureTcpServerChannel()

void SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.EnsureTcpServerChannel ( string protocol, string encodingName = PlainTextProtocolOptions::Utf8EncodingName )

inlineprivate

Ensure Tcp Server Channel 작업을 수행합니다.

매개변수

protocol	protocol에 사용할 string 값입니다.
encodingName	encoding Name에 사용할 string 값입니다.

CommunicationSampleRuntime.cs 파일의 3225 번째 라인에서 정의되었습니다.

    {
        var channelName = GetTcpServerChannelName(protocol, encodingName);
        var port = GetTcpPort(protocol);
 
        if (Monitor.Channels.Any(x => x.Name == channelName))
        {
            return;
        }
 
        Monitor.AddChannel(
            channelName,
            TransportKind.Tcp,
            CreateTcpServerDescription(
                protocol,
                encodingName,
                port,
                0,
                _currentServerSendTargetMode,
                _currentServerEchoEnabled));
    }

다음을 참조함 : _currentServerEchoEnabled, _currentServerSendTargetMode, CreateTcpServerDescription(), GetTcpPort(), GetTcpServerChannelName(), Monitor.

다음에 의해서 참조됨 : StartTcpServerAsync().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

이 함수를 호출하는 함수들에 대한 그래프입니다.:

EnsureUdpPeerChannel()

void SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.EnsureUdpPeerChannel ( string peerName, string protocol, string encodingName )

inlineprivate

Ensure Udp Peer Channel 작업을 수행합니다.

매개변수

peerName	peer Name에 사용할 string 값입니다.
protocol	protocol에 사용할 string 값입니다.
encodingName	encoding Name에 사용할 string 값입니다.

CommunicationSampleRuntime.cs 파일의 3323 번째 라인에서 정의되었습니다.

    {
        encodingName = NormalizeTextEncodingName(encodingName);
 
        var channelName = GetUdpPeerChannelName(peerName, protocol, encodingName);
        var localPort = GetUdpLocalPort(peerName);
        var remotePort = GetUdpRemotePort(peerName);
 
        if (Monitor.Channels.Any(x => x.Name == channelName))
        {
            return;
        }
 
        Monitor.AddChannel(
            channelName,
            TransportKind.Udp,
            $"UDP peer {peerName} [{protocol}/{encodingName}] 127.0.0.1:{localPort} -> 127.0.0.1:{remotePort}.");
    }

다음을 참조함 : GetUdpLocalPort(), GetUdpPeerChannelName(), GetUdpRemotePort(), Monitor, NormalizeTextEncodingName().

다음에 의해서 참조됨 : ConnectUdpPeerAAsync(), ConnectUdpPeerBAsync().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

이 함수를 호출하는 함수들에 대한 그래프입니다.:

EscapeJsonString()

string SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.EscapeJsonString ( string value )

inlinestaticprivate

Escape Json String 작업을 수행합니다.

매개변수

value

적용할 값입니다.

반환값

Escape Json String 작업에서 생성한 string 결과입니다.

CommunicationSampleRuntime.cs 파일의 4484 번째 라인에서 정의되었습니다.

    {
        return value
            .Replace("\\", "\\\\", StringComparison.Ordinal)
            .Replace("\"", "\\\"", StringComparison.Ordinal)
            .Replace("\r", "\\r", StringComparison.Ordinal)
            .Replace("\n", "\\n", StringComparison.Ordinal);
    }

다음에 의해서 참조됨 : EnsureJsonPayload().

이 함수를 호출하는 함수들에 대한 그래프입니다.:

GetSerialChannelName()

string SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.GetSerialChannelName ( )

inlineprivate

Serial Channel Name 값을 가져옵니다.

반환값

Get Serial Channel Name 작업에서 생성한 string 결과입니다.

CommunicationSampleRuntime.cs 파일의 3405 번째 라인에서 정의되었습니다.

    {
        if (string.IsNullOrWhiteSpace(_currentSerialPortName))
        {
            return "Serial-Port";
        }
 
        return $"Serial-{_currentSerialPortName}";
    }

다음을 참조함 : _currentSerialPortName.

다음에 의해서 참조됨 : ConnectSerialAsync(), DisconnectSerialAsync(), EnsureSerialChannel(), OnSerialMessageReceived(), SendSerialAsync().

이 함수를 호출하는 함수들에 대한 그래프입니다.:

GetTcpClientChannelName()

string SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.GetTcpClientChannelName ( string protocol, string encodingName = PlainTextProtocolOptions::Utf8EncodingName )

inlinestaticprivate

Tcp Client Channel Name 값을 가져옵니다.

매개변수

protocol	protocol에 사용할 string 값입니다.
encodingName	encoding Name에 사용할 string 값입니다.

반환값

Get Tcp Client Channel Name 작업에서 생성한 string 결과입니다.

CommunicationSampleRuntime.cs 파일의 3675 번째 라인에서 정의되었습니다.

    {
        var normalizedEncodingName = NormalizeTextEncodingName(encodingName);
 
        return NormalizeProtocol(protocol) switch
        {
            DreamineEnvelopeProtocol => "TCP-Client-Dreamine",
            PlainTextProtocol => $"TCP-Client-PlainText-{normalizedEncodingName}",
            RawAvailableProtocol => $"TCP-Client-RawAvailable-{normalizedEncodingName}",
            RawJsonProtocol => "TCP-Client-RawJson",
            _ => $"TCP-Client-PlainText-{normalizedEncodingName}"
        };
    }

다음을 참조함 : DreamineEnvelopeProtocol, NormalizeProtocol(), NormalizeTextEncodingName(), PlainTextProtocol, RawAvailableProtocol, RawJsonProtocol.

다음에 의해서 참조됨 : ConnectTcpClientAsync(), DisconnectTcpClientAsync(), EnsureTcpClientChannel(), OnTcpClientMessageReceived(), PrepareTcpClientTransportAsync(), SendTcpClientAsync().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

이 함수를 호출하는 함수들에 대한 그래프입니다.:

GetTcpPort()

int SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.GetTcpPort ( string protocol )

inlinestaticprivate

Tcp Port 값을 가져옵니다.

매개변수

protocol

protocol에 사용할 string 값입니다.

반환값

Get Tcp Port 작업에서 생성한 int 결과입니다.

CommunicationSampleRuntime.cs 파일의 3583 번째 라인에서 정의되었습니다.

    {
        return NormalizeProtocol(protocol) switch
        {
            DreamineEnvelopeProtocol => DreamineProtocolPort,
            PlainTextProtocol => PlainTextProtocolPort,
            RawAvailableProtocol => RawAvailableProtocolPort,
            RawJsonProtocol => RawJsonProtocolPort,
            _ => PlainTextProtocolPort
        };
    }

다음을 참조함 : DreamineEnvelopeProtocol, DreamineProtocolPort, NormalizeProtocol(), PlainTextProtocol, PlainTextProtocolPort, RawAvailableProtocol, RawAvailableProtocolPort, RawJsonProtocol, RawJsonProtocolPort.

다음에 의해서 참조됨 : EnsureTcpClientChannel(), EnsureTcpServerChannel(), PrepareTcpClientTransportAsync(), StartTcpServerAsync(), UpdateTcpServerDescription().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

이 함수를 호출하는 함수들에 대한 그래프입니다.:

GetTcpServerChannelName()

string SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.GetTcpServerChannelName ( string protocol, string encodingName = PlainTextProtocolOptions::Utf8EncodingName )

inlinestaticprivate

Tcp Server Channel Name 값을 가져옵니다.

매개변수

protocol	protocol에 사용할 string 값입니다.
encodingName	encoding Name에 사용할 string 값입니다.

반환값

Get Tcp Server Channel Name 작업에서 생성한 string 결과입니다.

CommunicationSampleRuntime.cs 파일의 3627 번째 라인에서 정의되었습니다.

    {
        var normalizedEncodingName = NormalizeTextEncodingName(encodingName);
 
        return NormalizeProtocol(protocol) switch
        {
            DreamineEnvelopeProtocol => "TCP-Server-Dreamine",
            PlainTextProtocol => $"TCP-Server-PlainText-{normalizedEncodingName}",
            RawAvailableProtocol => $"TCP-Server-RawAvailable-{normalizedEncodingName}",
            RawJsonProtocol => "TCP-Server-RawJson",
            _ => $"TCP-Server-PlainText-{normalizedEncodingName}"
        };
    }

다음을 참조함 : DreamineEnvelopeProtocol, NormalizeProtocol(), NormalizeTextEncodingName(), PlainTextProtocol, RawAvailableProtocol, RawJsonProtocol.

다음에 의해서 참조됨 : EnsureTcpServerChannel(), OnTcpServerMessageReceived(), SendTcpServerAsync(), StartTcpServerAsync(), StopTcpServerAsync(), UpdateTcpServerDescription().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

이 함수를 호출하는 함수들에 대한 그래프입니다.:

GetUdpLocalPort()

int SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.GetUdpLocalPort ( string peerName )

inlinestaticprivate

Udp Local Port 값을 가져옵니다.

매개변수

peerName

peer Name에 사용할 string 값입니다.

반환값

Get Udp Local Port 작업에서 생성한 int 결과입니다.

CommunicationSampleRuntime.cs 파일의 3808 번째 라인에서 정의되었습니다.

    {
        return NormalizeUdpPeerName(peerName) == "B"
            ? UdpPeerBLocalPort
            : UdpPeerALocalPort;
    }

다음을 참조함 : NormalizeUdpPeerName(), UdpPeerALocalPort, UdpPeerBLocalPort.

다음에 의해서 참조됨 : EnsureUdpPeerChannel().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

이 함수를 호출하는 함수들에 대한 그래프입니다.:

GetUdpPeerChannelName()

string SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.GetUdpPeerChannelName ( string peerName, string protocol, string encodingName = PlainTextProtocolOptions::Utf8EncodingName )

inlinestaticprivate

Udp Peer Channel Name 값을 가져옵니다.

매개변수

peerName	peer Name에 사용할 string 값입니다.
protocol	protocol에 사용할 string 값입니다.
encodingName	encoding Name에 사용할 string 값입니다.

반환값

Get Udp Peer Channel Name 작업에서 생성한 string 결과입니다.

CommunicationSampleRuntime.cs 파일의 3731 번째 라인에서 정의되었습니다.

    {
        var normalizedPeerName = NormalizeUdpPeerName(peerName);
        var normalizedEncodingName = NormalizeTextEncodingName(encodingName);
 
        return NormalizeProtocol(protocol) switch
        {
            DreamineEnvelopeProtocol => $"UDP-Peer{normalizedPeerName}-Dreamine",
            PlainTextProtocol => $"UDP-Peer{normalizedPeerName}-PlainText-{normalizedEncodingName}",
            RawAvailableProtocol => $"UDP-Peer{normalizedPeerName}-RawAvailable-{normalizedEncodingName}",
            RawJsonProtocol => $"UDP-Peer{normalizedPeerName}-RawJson",
            _ => $"UDP-Peer{normalizedPeerName}-PlainText-{normalizedEncodingName}"
        };
    }

다음을 참조함 : DreamineEnvelopeProtocol, NormalizeProtocol(), NormalizeTextEncodingName(), NormalizeUdpPeerName(), PlainTextProtocol, RawAvailableProtocol, RawJsonProtocol.

다음에 의해서 참조됨 : ConnectUdpPeerAAsync(), ConnectUdpPeerBAsync(), DisconnectUdpPeerAAsync(), DisconnectUdpPeerBAsync(), EnsureUdpPeerChannel(), OnUdpPeerAMessageReceived(), OnUdpPeerBMessageReceived(), SendUdpPeerAAsync(), SendUdpPeerBAsync().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

이 함수를 호출하는 함수들에 대한 그래프입니다.:

GetUdpRemotePort()

int SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.GetUdpRemotePort ( string peerName )

inlinestaticprivate

Udp Remote Port 값을 가져옵니다.

매개변수

peerName

peer Name에 사용할 string 값입니다.

반환값

Get Udp Remote Port 작업에서 생성한 int 결과입니다.

CommunicationSampleRuntime.cs 파일의 3839 번째 라인에서 정의되었습니다.

    {
        return NormalizeUdpPeerName(peerName) == "B"
            ? UdpPeerALocalPort
            : UdpPeerBLocalPort;
    }

다음을 참조함 : NormalizeUdpPeerName(), UdpPeerALocalPort, UdpPeerBLocalPort.

다음에 의해서 참조됨 : EnsureUdpPeerChannel().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

이 함수를 호출하는 함수들에 대한 그래프입니다.:

NormalizeProtocol()

string SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.NormalizeProtocol ( string? protocol )

inlinestaticprivate

Normalize Protocol 작업을 수행합니다.

매개변수

protocol

protocol에 사용할 string? 값입니다.

반환값

Normalize Protocol 작업에서 생성한 string 결과입니다.

CommunicationSampleRuntime.cs 파일의 4554 번째 라인에서 정의되었습니다.

    {
        if (string.IsNullOrWhiteSpace(protocol))
        {
            return PlainTextProtocol;
        }
 
        return protocol.Trim() switch
        {
            DreamineEnvelopeProtocol => DreamineEnvelopeProtocol,
            PlainTextProtocol => PlainTextProtocol,
            RawAvailableProtocol => RawAvailableProtocol,
            RawJsonProtocol => RawJsonProtocol,
            _ => PlainTextProtocol
        };
    }

다음을 참조함 : DreamineEnvelopeProtocol, PlainTextProtocol, RawAvailableProtocol, RawJsonProtocol.

다음에 의해서 참조됨 : ConnectSerialAsync(), ConnectTcpClientAsync(), ConnectUdpPeerAAsync(), ConnectUdpPeerBAsync(), CreateFrameCodec(), CreateProtocolAdapter(), CreateSerialMessageByProtocol(), CreateTcpMessageByProtocol(), CreateUdpMessageByProtocol(), GetTcpClientChannelName(), GetTcpPort(), GetTcpServerChannelName(), GetUdpPeerChannelName(), PrepareTcpClientTransportAsync(), SendSerialAsync(), SendTcpClientAsync(), SendTcpServerAsync(), SendUdpPeerAAsync(), SendUdpPeerBAsync(), StartTcpServerAsync(), UpdateTcpServerOptions().

이 함수를 호출하는 함수들에 대한 그래프입니다.:

NormalizeTcpServerSendTargetMode()

TcpServerSendTargetMode SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.NormalizeTcpServerSendTargetMode ( string? sendTargetMode )

inlinestaticprivate

Normalize Tcp Server Send Target Mode 작업을 수행합니다.

매개변수

sendTargetMode

send Target Mode에 사용할 string? 값입니다.

반환값

Normalize Tcp Server Send Target Mode 작업에서 생성한 TcpServerSendTargetMode 결과입니다.

CommunicationSampleRuntime.cs 파일의 4517 번째 라인에서 정의되었습니다.

    {
        if (Enum.TryParse<TcpServerSendTargetMode>(
                sendTargetMode,
                ignoreCase: true,
                out var parsed))
        {
            return parsed;
        }
 
        return TcpServerSendTargetMode.Broadcast;
    }

다음에 의해서 참조됨 : SendTcpServerAsync(), StartTcpServerAsync(), UpdateTcpServerOptions().

이 함수를 호출하는 함수들에 대한 그래프입니다.:

NormalizeText()

string SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.NormalizeText ( string? value, string defaultValue )

inlinestaticprivate

Normalize Text 작업을 수행합니다.

매개변수

value	적용할 값입니다.
defaultValue	default Value에 사용할 string 값입니다.

반환값

Normalize Text 작업에서 생성한 string 결과입니다.

CommunicationSampleRuntime.cs 파일의 4603 번째 라인에서 정의되었습니다.

    {
        return string.IsNullOrWhiteSpace(value)
            ? defaultValue
            : value.Trim();
    }

다음에 의해서 참조됨 : ConnectRabbitMqAsync(), PublishRabbitMqAsync(), SubscribeRabbitMqAsync().

이 함수를 호출하는 함수들에 대한 그래프입니다.:

NormalizeTextEncodingName()

string SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.NormalizeTextEncodingName ( string encodingName )

inlinestaticprivate

Normalize Text Encoding Name 작업을 수행합니다.

매개변수

encodingName

encoding Name에 사용할 string 값입니다.

반환값

Normalize Text Encoding Name 작업에서 생성한 string 결과입니다.

CommunicationSampleRuntime.cs 파일의 3772 번째 라인에서 정의되었습니다.

    {
        if (string.Equals(encodingName, PlainTextProtocolOptions.KoreanCodePage949EncodingName, StringComparison.OrdinalIgnoreCase) ||
            string.Equals(encodingName, "949", StringComparison.OrdinalIgnoreCase))
        {
            return PlainTextProtocolOptions.KoreanCodePage949EncodingName;
        }
 
        return PlainTextProtocolOptions.Utf8EncodingName;
    }

다음에 의해서 참조됨 : ConnectSerialAsync(), ConnectTcpClientAsync(), ConnectUdpPeerAAsync(), ConnectUdpPeerBAsync(), CreateSerialMessageByProtocol(), CreateTcpMessageByProtocol(), CreateUdpMessageByProtocol(), EnsureUdpPeerChannel(), GetTcpClientChannelName(), GetTcpServerChannelName(), GetUdpPeerChannelName(), PrepareTcpClientTransportAsync(), SendSerialAsync(), SendTcpClientAsync(), SendTcpServerAsync(), SendUdpPeerAAsync(), SendUdpPeerBAsync(), StartTcpServerAsync(), UpdateTcpServerOptions().

이 함수를 호출하는 함수들에 대한 그래프입니다.:

NormalizeUdpPeerName()

string SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.NormalizeUdpPeerName ( string peerName )

inlinestaticprivate

Normalize Udp Peer Name 작업을 수행합니다.

매개변수

peerName

peer Name에 사용할 string 값입니다.

반환값

Normalize Udp Peer Name 작업에서 생성한 string 결과입니다.

CommunicationSampleRuntime.cs 파일의 3870 번째 라인에서 정의되었습니다.

    {
        return string.Equals(peerName, "B", StringComparison.OrdinalIgnoreCase)
            ? "B"
            : "A";
    }

다음에 의해서 참조됨 : GetUdpLocalPort(), GetUdpPeerChannelName(), GetUdpRemotePort().

이 함수를 호출하는 함수들에 대한 그래프입니다.:

OnSerialMessageReceived()

void SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.OnSerialMessageReceived ( object? sender, MessageEnvelope message )

inlineprivate

Serial Message Received 이벤트 또는 상태 변경을 처리합니다.

매개변수

sender	이벤트를 발생시킨 객체입니다.
message	처리할 메시지입니다.

CommunicationSampleRuntime.cs 파일의 3188 번째 라인에서 정의되었습니다.

    {
        var channelName = GetSerialChannelName();
 
        RunOnUiThread(() =>
        {
            Monitor.AddReceiveLog(
                channelName,
                TransportKind.Serial,
                message);
        });
    }

다음을 참조함 : GetSerialChannelName(), Monitor, RunOnUiThread().

다음에 의해서 참조됨 : ConnectSerialAsync(), DisconnectSerialAsync().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

이 함수를 호출하는 함수들에 대한 그래프입니다.:

OnTcpClientMessageReceived()

void SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.OnTcpClientMessageReceived ( object? sender, MessageEnvelope message )

inlineprivate

Tcp Client Message Received 이벤트 또는 상태 변경을 처리합니다.

매개변수

sender	이벤트를 발생시킨 객체입니다.
message	처리할 메시지입니다.

CommunicationSampleRuntime.cs 파일의 3071 번째 라인에서 정의되었습니다.

    {
        var protocol = _currentClientProtocol;
        var encodingName = _currentClientEncoding;
        var channelName = GetTcpClientChannelName(protocol, encodingName);
 
        RunOnUiThread(() =>
        {
            Monitor.AddReceiveLog(
                channelName,
                TransportKind.Tcp,
                message);
        });
    }

다음을 참조함 : _currentClientEncoding, _currentClientProtocol, GetTcpClientChannelName(), Monitor, RunOnUiThread().

다음에 의해서 참조됨 : DisconnectTcpClientAsync(), PrepareTcpClientTransportAsync().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

이 함수를 호출하는 함수들에 대한 그래프입니다.:

OnTcpServerMessageReceived()

async void SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.OnTcpServerMessageReceived ( object? sender, MessageEnvelope message )

inlineprivate

Tcp Server Message Received 이벤트 또는 상태 변경을 처리합니다.

매개변수

sender	이벤트를 발생시킨 객체입니다.
message	처리할 메시지입니다.

CommunicationSampleRuntime.cs 파일의 2614 번째 라인에서 정의되었습니다.

    {
        var protocol = _currentServerProtocol;
        var encodingName = _currentServerEncoding;
        var channelName = GetTcpServerChannelName(protocol, encodingName);
 
        RunOnUiThread(() =>
        {
            Monitor.AddReceiveLog(
                channelName,
                TransportKind.Tcp,
                message);
        });
 
        if (_tcpServer is null ||
            _tcpServer.State != ConnectionState.Listening ||
            !_currentServerEchoEnabled)
        {
            return;
        }
 
        var receiveText = Encoding.UTF8.GetString(message.Payload);
 
        var echoMessage = CreateTcpMessageByProtocol(
            protocol,
            $"Server.Echo.{_currentServerSendTargetMode}",
            $"Echo from Dreamine TCP Server - {receiveText}",
            encodingName);
 
        RunOnUiThread(() =>
        {
            Monitor.AddSendLog(
                channelName,
                TransportKind.Tcp,
                echoMessage);
        });
 
        await _tcpServer.SendAsync(echoMessage);
    }

다음을 참조함 : _currentServerEchoEnabled, _currentServerEncoding, _currentServerProtocol, _tcpServer, CreateTcpMessageByProtocol(), GetTcpServerChannelName(), Monitor, RunOnUiThread().

다음에 의해서 참조됨 : StartTcpServerAsync(), StopTcpServerAsync().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

이 함수를 호출하는 함수들에 대한 그래프입니다.:

OnUdpPeerAMessageReceived()

void SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.OnUdpPeerAMessageReceived ( object? sender, MessageEnvelope message )

inlineprivate

Udp Peer A Message Received 이벤트 또는 상태 변경을 처리합니다.

매개변수

sender	이벤트를 발생시킨 객체입니다.
message	처리할 메시지입니다.

CommunicationSampleRuntime.cs 파일의 3110 번째 라인에서 정의되었습니다.

    {
        var protocol = _currentUdpPeerAProtocol;
        var encodingName = _currentUdpPeerAEncoding;
        var channelName = GetUdpPeerChannelName("A", protocol, encodingName);
 
        RunOnUiThread(() =>
        {
            Monitor.AddReceiveLog(
                channelName,
                TransportKind.Udp,
                message);
        });
    }

다음을 참조함 : _currentUdpPeerAEncoding, _currentUdpPeerAProtocol, GetUdpPeerChannelName(), Monitor, RunOnUiThread().

다음에 의해서 참조됨 : ConnectUdpPeerAAsync(), DisconnectUdpPeerAAsync().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

이 함수를 호출하는 함수들에 대한 그래프입니다.:

OnUdpPeerBMessageReceived()

void SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.OnUdpPeerBMessageReceived ( object? sender, MessageEnvelope message )

inlineprivate

Udp Peer B Message Received 이벤트 또는 상태 변경을 처리합니다.

매개변수

sender	이벤트를 발생시킨 객체입니다.
message	처리할 메시지입니다.

CommunicationSampleRuntime.cs 파일의 3149 번째 라인에서 정의되었습니다.

    {
        var protocol = _currentUdpPeerBProtocol;
        var encodingName = _currentUdpPeerBEncoding;
        var channelName = GetUdpPeerChannelName("B", protocol, encodingName);
 
        RunOnUiThread(() =>
        {
            Monitor.AddReceiveLog(
                channelName,
                TransportKind.Udp,
                message);
        });
    }

다음을 참조함 : _currentUdpPeerBEncoding, _currentUdpPeerBProtocol, GetUdpPeerChannelName(), Monitor, RunOnUiThread().

다음에 의해서 참조됨 : ConnectUdpPeerBAsync(), DisconnectUdpPeerBAsync().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

이 함수를 호출하는 함수들에 대한 그래프입니다.:

PrepareTcpClientTransportAsync()

async Task SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.PrepareTcpClientTransportAsync ( string protocol, string encodingName )

inlineprivate

TCP Client Transport를 준비합니다. 연결은 수행하지 않고, 송신 큐와 재연결 Decorator를 구성합니다.

매개변수

protocol	프로토콜 이름입니다.
encodingName	PlainText 외부 송수신 인코딩 이름입니다.

반환값

Prepare Tcp Client Transport Async 작업에서 생성한 Task 결과입니다.

CommunicationSampleRuntime.cs 파일의 1207 번째 라인에서 정의되었습니다.

    {
        protocol = NormalizeProtocol(protocol);
        encodingName = NormalizeTextEncodingName(encodingName);
 
        if (_tcpClient is not null &&
            _currentClientProtocol == protocol &&
            _currentClientEncoding == encodingName)
        {
            return;
        }
 
        if (_tcpClient is not null)
        {
            await DisconnectTcpClientAsync();
        }
 
        _currentClientProtocol = protocol;
        _currentClientEncoding = encodingName;
 
        EnsureTcpClientChannel(protocol, encodingName);
 
        var port = GetTcpPort(protocol);
 
        var rawTcpClient = new TcpClientTransport(
            new TcpClientTransportOptions
            {
                Host = "127.0.0.1",
                Port = port
            },
            CreateProtocolAdapter(
                protocol,
                "tcp",
                "Tcp",
                encodingName),
            CreateFrameCodec(protocol, encodingName));
 
        _tcpClient = new ResilientMessageTransport(
            rawTcpClient,
            CreateSampleReconnectPolicy(),
            CreateSampleOutboundQueueOptions());
 
        var channelName = GetTcpClientChannelName(protocol, encodingName);
 
        AttachTcpResilientStateMonitor(
            _tcpClient,
            channelName);
 
        AttachTcpClientQueueMonitor(
            _tcpClient,
            protocol,
            encodingName,
            channelName);
 
        _tcpClient.MessageReceived += OnTcpClientMessageReceived;
 
        Monitor.UpdateChannelState(
            channelName,
            _tcpClient.State);
    }

다음을 참조함 : _currentClientEncoding, _currentClientProtocol, _tcpClient, AttachTcpClientQueueMonitor(), AttachTcpResilientStateMonitor(), CreateFrameCodec(), CreateProtocolAdapter(), CreateSampleOutboundQueueOptions(), CreateSampleReconnectPolicy(), DisconnectTcpClientAsync(), EnsureTcpClientChannel(), GetTcpClientChannelName(), GetTcpPort(), Monitor, NormalizeProtocol(), NormalizeTextEncodingName(), OnTcpClientMessageReceived().

다음에 의해서 참조됨 : ConnectTcpClientAsync(), SendTcpClientAsync().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

이 함수를 호출하는 함수들에 대한 그래프입니다.:

PublishRabbitMqAsync()

async Task SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.PublishRabbitMqAsync ( string exchangeName, string routingKey, string text )

inline

RabbitMQ 메시지를 발행합니다.

매개변수

exchangeName	Exchange 이름입니다.
routingKey	RoutingKey입니다.
text	송신 문자열입니다.

반환값

Publish Rabbit Mq Async 작업에서 생성한 Task 결과입니다.

CommunicationSampleRuntime.cs 파일의 2429 번째 라인에서 정의되었습니다.

    {
        exchangeName = NormalizeText(exchangeName, _currentRabbitMqExchangeName);
        routingKey = NormalizeText(routingKey, _currentRabbitMqRoutingKey);
 
        if (string.IsNullOrWhiteSpace(text))
        {
            text = "test";
        }
 
        if (_rabbitMqBus is null)
        {
            AddRabbitMqErrorLog(
                "RabbitMQ.Publish.Skipped",
                "RabbitMQ is not connected.");
            return;
        }
 
        if (_rabbitMqBus.State != ConnectionState.Connected)
        {
            AddRabbitMqErrorLog(
                "RabbitMQ.Publish.Skipped",
                $"RabbitMQ state is {_rabbitMqBus.State}.");
            return;
        }
 
        _currentRabbitMqExchangeName = exchangeName;
        _currentRabbitMqRoutingKey = routingKey;
 
        var message = CreateRabbitMqMessage(
            "Publish",
            routingKey,
            text);
 
        Monitor.AddSendLog(
            RabbitMqChannelName,
            TransportKind.RabbitMq,
            message);
 
        try
        {
            await _rabbitMqBus.PublishAsync(message);
        }
        catch (Exception ex)
        {
            AddRabbitMqErrorLog("RabbitMQ.Publish.Failed", ex.Message);
        }
    }

다음을 참조함 : _currentRabbitMqExchangeName, _currentRabbitMqRoutingKey, _rabbitMqBus, AddRabbitMqErrorLog(), CreateRabbitMqMessage(), Monitor, NormalizeText(), RabbitMqChannelName.

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

ReceiveInMemory()

void SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.ReceiveInMemory ( string text )

inline

InMemory 수동 수신 테스트 로그를 추가합니다.

매개변수

text	수신으로 표시할 문자열입니다.

CommunicationSampleRuntime.cs 파일의 719 번째 라인에서 정의되었습니다.

    {
        AddInMemoryChannel();
 
        if (string.IsNullOrWhiteSpace(text))
        {
            text = "Hello from SampleSmart manual receive";
        }
 
        var message = CreateTextMessage(
            "Sample.Receive",
            "sample.communication.manual-receive",
            text,
            "InMemory");
 
        Monitor.AddReceiveLog(
            InMemoryChannelName,
            TransportKind.InMemory,
            message);
    }

다음을 참조함 : AddInMemoryChannel(), CreateTextMessage(), InMemoryChannelName, Monitor.

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

RunOnUiThread()

void SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.RunOnUiThread ( Action action )

inlinestaticprivate

Run On Ui Thread 작업을 수행합니다.

매개변수

action

action에 사용할 Action 값입니다.

CommunicationSampleRuntime.cs 파일의 4628 번째 라인에서 정의되었습니다.

    {
        ArgumentNullException.ThrowIfNull(action);
 
        var dispatcher = Application.Current?.Dispatcher;
 
        if (dispatcher is null || dispatcher.CheckAccess())
        {
            action();
            return;
        }
 
        dispatcher.Invoke(action);
    }

다음에 의해서 참조됨 : AttachTcpClientQueueMonitor(), AttachTcpResilientStateMonitor(), AttachTcpServerClientCountMonitor(), OnSerialMessageReceived(), OnTcpClientMessageReceived(), OnTcpServerMessageReceived(), OnUdpPeerAMessageReceived(), OnUdpPeerBMessageReceived(), SubscribeInMemoryAsync(), SubscribeRabbitMqAsync().

이 함수를 호출하는 함수들에 대한 그래프입니다.:

SendInMemoryAsync()

async Task SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.SendInMemoryAsync ( string text )

inline

InMemory MessageBus로 테스트 메시지를 송신합니다.

매개변수

text	송신 문자열입니다.

반환값

Send In Memory Async 작업에서 생성한 Task 결과입니다.

CommunicationSampleRuntime.cs 파일의 675 번째 라인에서 정의되었습니다.

    {
        AddInMemoryChannel();
 
        if (_messageBus.State != ConnectionState.Connected)
        {
            await ConnectInMemoryAsync();
        }
 
        if (string.IsNullOrWhiteSpace(text))
        {
            text = "Hello from SampleSmart InMemory";
        }
 
        var message = CreateTextMessage(
            "Sample.Send",
            InMemoryRouteName,
            text,
            "InMemory");
 
        Monitor.AddSendLog(
            InMemoryChannelName,
            TransportKind.InMemory,
            message);
 
        await _messageBus.PublishAsync(message);
    }

다음을 참조함 : _messageBus, AddInMemoryChannel(), ConnectInMemoryAsync(), CreateTextMessage(), InMemoryChannelName, InMemoryRouteName, Monitor.

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

SendSerialAsync()

async Task SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.SendSerialAsync ( string protocol, string text, string encodingName = PlainTextProtocolOptions::Utf8EncodingName )

inline

현재 Serial Port로 메시지를 송신합니다.

매개변수

protocol	프로토콜 이름입니다.
text	송신 문자열입니다.
encodingName	PlainText 외부 송수신 인코딩 이름입니다.

반환값

Send Serial Async 작업에서 생성한 Task 결과입니다.

CommunicationSampleRuntime.cs 파일의 2094 번째 라인에서 정의되었습니다.

    {
        protocol = NormalizeProtocol(protocol);
        encodingName = NormalizeTextEncodingName(encodingName);
 
        if (string.IsNullOrWhiteSpace(text))
        {
            text = "test";
        }
 
        if (_serialTransport is null ||
            _serialTransport.State != ConnectionState.Connected)
        {
            return;
        }
 
        var message = CreateSerialMessageByProtocol(
            protocol,
            "Send",
            text,
            encodingName);
 
        var channelName = GetSerialChannelName();
 
        Monitor.AddSendLog(
            channelName,
            TransportKind.Serial,
            message);
 
        await _serialTransport.SendAsync(message);
    }

다음을 참조함 : _serialTransport, CreateSerialMessageByProtocol(), GetSerialChannelName(), Monitor, NormalizeProtocol(), NormalizeTextEncodingName().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

SendTcpClientAsync()

async Task SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.SendTcpClientAsync ( string protocol, string text, string encodingName = PlainTextProtocolOptions::Utf8EncodingName )

inline

선택된 프로토콜로 TCP Client에서 서버로 메시지를 송신합니다.

매개변수

protocol	프로토콜 이름입니다.
text	송신 문자열입니다.
encodingName	PlainText 외부 송수신 인코딩 이름입니다.

반환값

Send Tcp Client Async 작업에서 생성한 Task 결과입니다.

CommunicationSampleRuntime.cs 파일의 1354 번째 라인에서 정의되었습니다.

    {
        protocol = NormalizeProtocol(protocol);
        encodingName = NormalizeTextEncodingName(encodingName);
 
        if (string.IsNullOrWhiteSpace(text))
        {
            text = "Hello from Dreamine TCP Client";
        }
 
        await PrepareTcpClientTransportAsync(protocol, encodingName);
 
        if (_tcpClient is null)
        {
            return;
        }
 
        var message = CreateTcpMessageByProtocol(
            protocol,
            "Client.Send",
            text,
            encodingName);
 
        var channelName = GetTcpClientChannelName(protocol, encodingName);
 
        Monitor.AddSendLog(
            channelName,
            TransportKind.Tcp,
            message);
 
        await _tcpClient.SendAsync(message);
 
        if (_tcpClient is ResilientMessageTransport resilientTransport)
        {
            var queueStatusMessage = CreateTcpMessageByProtocol(
                protocol,
                "Client.QueueStatus",
                $"QueueCount={resilientTransport.QueuedMessageCount}, State={_tcpClient.State}",
                encodingName);
 
            Monitor.AddReceiveLog(
                channelName,
                TransportKind.Tcp,
                queueStatusMessage);
        }
 
        Monitor.UpdateChannelState(
            channelName,
            _tcpClient.State);
    }

다음을 참조함 : _tcpClient, CreateTcpMessageByProtocol(), GetTcpClientChannelName(), Monitor, NormalizeProtocol(), NormalizeTextEncodingName(), PrepareTcpClientTransportAsync().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

SendTcpServerAsync()

async Task SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.SendTcpServerAsync ( string protocol, string text, string encodingName = PlainTextProtocolOptions::Utf8EncodingName, string sendTargetMode = nameof(TcpServerSendTargetMode.Broadcast) )

inline

선택된 프로토콜로 TCP Server에서 연결된 클라이언트에게 메시지를 송신합니다.

매개변수

protocol	프로토콜 이름입니다.
text	송신 문자열입니다.
encodingName	PlainText 외부 송수신 인코딩 이름입니다.
sendTargetMode	send Target Mode에 사용할 string 값입니다.

반환값

Send Tcp Server Async 작업에서 생성한 Task 결과입니다.

CommunicationSampleRuntime.cs 파일의 1045 번째 라인에서 정의되었습니다.

    {
        protocol = NormalizeProtocol(protocol);
        encodingName = NormalizeTextEncodingName(encodingName);
        var targetMode = NormalizeTcpServerSendTargetMode(sendTargetMode);
        _currentServerSendTargetMode = targetMode;
 
        if (_rawTcpServer is not null)
        {
            _rawTcpServer.SendTargetMode = targetMode;
            UpdateTcpServerDescription(
                protocol,
                encodingName,
                _rawTcpServer.ConnectedClientCount,
                targetMode,
                _currentServerEchoEnabled);
        }
 
        if (string.IsNullOrWhiteSpace(text))
        {
            text = "Hello from Dreamine TCP Server";
        }
 
        if (_tcpServer is null ||
            _tcpServer.State != ConnectionState.Listening ||
            _currentServerProtocol != protocol ||
            _currentServerEncoding != encodingName)
        {
            await StartTcpServerAsync(protocol, encodingName, sendTargetMode, _currentServerEchoEnabled);
        }
 
        if (_tcpServer is null)
        {
            return;
        }
 
        var message = CreateTcpMessageByProtocol(
            protocol,
            $"Server.Send.{targetMode}",
            text,
            encodingName);
 
        var channelName = GetTcpServerChannelName(protocol, encodingName);
 
        Monitor.AddSendLog(
            channelName,
            TransportKind.Tcp,
            message);
 
        await _tcpServer.SendAsync(message);
    }

다음을 참조함 : _currentServerEchoEnabled, _currentServerEncoding, _currentServerProtocol, _currentServerSendTargetMode, _rawTcpServer, _tcpServer, CreateTcpMessageByProtocol(), GetTcpServerChannelName(), Monitor, NormalizeProtocol(), NormalizeTcpServerSendTargetMode(), NormalizeTextEncodingName(), StartTcpServerAsync(), UpdateTcpServerDescription().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

SendUdpPeerAAsync()

async Task SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.SendUdpPeerAAsync ( string protocol, string text, string encodingName = PlainTextProtocolOptions::Utf8EncodingName )

inline

UDP Peer A에서 Peer B로 메시지를 송신합니다.

매개변수

protocol	프로토콜 이름입니다.
text	송신 문자열입니다.
encodingName	PlainText 외부 송수신 인코딩 이름입니다.

반환값

Send Udp Peer A Async 작업에서 생성한 Task 결과입니다.

CommunicationSampleRuntime.cs 파일의 1782 번째 라인에서 정의되었습니다.

    {
        protocol = NormalizeProtocol(protocol);
        encodingName = NormalizeTextEncodingName(encodingName);
 
        if (string.IsNullOrWhiteSpace(text))
        {
            text = "Hello from Dreamine UDP Peer A";
        }
 
        if (_udpPeerA is null ||
            _udpPeerA.State != ConnectionState.Connected ||
            _currentUdpPeerAProtocol != protocol ||
            _currentUdpPeerAEncoding != encodingName)
        {
            await ConnectUdpPeerAAsync(protocol, encodingName);
        }
 
        if (_udpPeerA is null)
        {
            return;
        }
 
        var message = CreateUdpMessageByProtocol(
            protocol,
            "PeerA.Send",
            text,
            encodingName);
 
        var channelName = GetUdpPeerChannelName("A", protocol, encodingName);
 
        Monitor.AddSendLog(
            channelName,
            TransportKind.Udp,
            message);
 
        await _udpPeerA.SendAsync(message);
    }

다음을 참조함 : _currentUdpPeerAEncoding, _currentUdpPeerAProtocol, _udpPeerA, ConnectUdpPeerAAsync(), CreateUdpMessageByProtocol(), GetUdpPeerChannelName(), Monitor, NormalizeProtocol(), NormalizeTextEncodingName().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

SendUdpPeerBAsync()

async Task SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.SendUdpPeerBAsync ( string protocol, string text, string encodingName = PlainTextProtocolOptions::Utf8EncodingName )

inline

UDP Peer B에서 Peer A로 메시지를 송신합니다.

매개변수

protocol	프로토콜 이름입니다.
text	송신 문자열입니다.
encodingName	PlainText 외부 송수신 인코딩 이름입니다.

반환값

Send Udp Peer B Async 작업에서 생성한 Task 결과입니다.

CommunicationSampleRuntime.cs 파일의 1864 번째 라인에서 정의되었습니다.

    {
        protocol = NormalizeProtocol(protocol);
        encodingName = NormalizeTextEncodingName(encodingName);
 
        if (string.IsNullOrWhiteSpace(text))
        {
            text = "Hello from Dreamine UDP Peer B";
        }
 
        if (_udpPeerB is null ||
            _udpPeerB.State != ConnectionState.Connected ||
            _currentUdpPeerBProtocol != protocol ||
            _currentUdpPeerBEncoding != encodingName)
        {
            await ConnectUdpPeerBAsync(protocol, encodingName);
        }
 
        if (_udpPeerB is null)
        {
            return;
        }
 
        var message = CreateUdpMessageByProtocol(
            protocol,
            "PeerB.Send",
            text,
            encodingName);
 
        var channelName = GetUdpPeerChannelName("B", protocol, encodingName);
 
        Monitor.AddSendLog(
            channelName,
            TransportKind.Udp,
            message);
 
        await _udpPeerB.SendAsync(message);
    }

다음을 참조함 : _currentUdpPeerBEncoding, _currentUdpPeerBProtocol, _udpPeerB, ConnectUdpPeerBAsync(), CreateUdpMessageByProtocol(), GetUdpPeerChannelName(), Monitor, NormalizeProtocol(), NormalizeTextEncodingName().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

StartTcpServerAsync()

async Task SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.StartTcpServerAsync ( string protocol, string encodingName = PlainTextProtocolOptions::Utf8EncodingName, string sendTargetMode = nameof(TcpServerSendTargetMode.Broadcast), bool echoEnabled = false )

inline

선택된 프로토콜로 TCP Server를 시작합니다.

매개변수

protocol	프로토콜 이름입니다.
encodingName	PlainText 외부 송수신 인코딩 이름입니다.
sendTargetMode	send Target Mode에 사용할 string 값입니다.
echoEnabled	echo Enabled에 사용할 bool 값입니다.

반환값

Start Tcp Server Async 작업에서 생성한 Task 결과입니다.

CommunicationSampleRuntime.cs 파일의 788 번째 라인에서 정의되었습니다.

    {
        protocol = NormalizeProtocol(protocol);
        encodingName = NormalizeTextEncodingName(encodingName);
        var targetMode = NormalizeTcpServerSendTargetMode(sendTargetMode);
 
        if (_tcpServer is not null &&
            _tcpServer.State == ConnectionState.Listening &&
            _currentServerProtocol == protocol &&
            _currentServerEncoding == encodingName)
        {
            _currentServerSendTargetMode = targetMode;
            _currentServerEchoEnabled = echoEnabled;
 
            if (_rawTcpServer is not null)
            {
                _rawTcpServer.SendTargetMode = targetMode;
                UpdateTcpServerDescription(
                    protocol,
                    encodingName,
                    _rawTcpServer.ConnectedClientCount,
                    targetMode,
                    echoEnabled);
            }
 
            return;
        }
 
        if (_tcpServer is not null)
        {
            await StopTcpServerAsync();
        }
 
        _currentServerProtocol = protocol;
        _currentServerEncoding = encodingName;
        _currentServerSendTargetMode = targetMode;
        _currentServerEchoEnabled = echoEnabled;
 
        EnsureTcpServerChannel(protocol, encodingName);
 
        var port = GetTcpPort(protocol);
 
        _rawTcpServer = new TcpServerTransport(
            new TcpServerTransportOptions
            {
                Host = "127.0.0.1",
                Port = port,
                SendTargetMode = targetMode
            },
            CreateProtocolAdapter(
                protocol,
                "tcp",
                "Tcp",
                encodingName),
            CreateFrameCodec(protocol, encodingName));
 
        _tcpServer = new ResilientMessageTransport(
            _rawTcpServer,
            CreateSampleReconnectPolicy(),
            CreateSampleServerOutboundQueueOptions());
 
        var channelName = GetTcpServerChannelName(protocol, encodingName);
 
        AttachTcpResilientStateMonitor(
            _tcpServer,
            channelName);
 
        AttachTcpServerClientCountMonitor(
            _rawTcpServer,
            protocol,
            encodingName);
 
        UpdateTcpServerDescription(
            protocol,
            encodingName,
            _rawTcpServer.ConnectedClientCount,
            targetMode,
            echoEnabled);
 
        _tcpServer.MessageReceived += OnTcpServerMessageReceived;
 
        Monitor.UpdateChannelState(channelName, ConnectionState.Connecting);
 
        await _tcpServer.ConnectAsync();
 
        Monitor.UpdateChannelState(
            channelName,
            _tcpServer.State);
    }

다음을 참조함 : _currentServerEchoEnabled, _currentServerEncoding, _currentServerProtocol, _currentServerSendTargetMode, _rawTcpServer, _tcpServer, AttachTcpResilientStateMonitor(), AttachTcpServerClientCountMonitor(), CreateFrameCodec(), CreateProtocolAdapter(), CreateSampleReconnectPolicy(), CreateSampleServerOutboundQueueOptions(), EnsureTcpServerChannel(), GetTcpPort(), GetTcpServerChannelName(), Monitor, NormalizeProtocol(), NormalizeTcpServerSendTargetMode(), NormalizeTextEncodingName(), OnTcpServerMessageReceived(), StopTcpServerAsync(), UpdateTcpServerDescription().

다음에 의해서 참조됨 : SendTcpServerAsync().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

이 함수를 호출하는 함수들에 대한 그래프입니다.:

StartUdpLoopbackAsync()

async Task SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.StartUdpLoopbackAsync ( string protocol, string encodingName = PlainTextProtocolOptions::Utf8EncodingName )

inline

UDP Peer A와 Peer B를 모두 시작합니다.

매개변수

protocol	프로토콜 이름입니다.
encodingName	PlainText 외부 송수신 인코딩 이름입니다.

반환값

Start Udp Loopback Async 작업에서 생성한 Task 결과입니다.

CommunicationSampleRuntime.cs 파일의 1462 번째 라인에서 정의되었습니다.

    {
        await ConnectUdpPeerAAsync(protocol, encodingName);
        await ConnectUdpPeerBAsync(protocol, encodingName);
    }

다음을 참조함 : ConnectUdpPeerAAsync(), ConnectUdpPeerBAsync().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

StopAllAsync()

async Task SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.StopAllAsync ( )

inline

모든 통신 샘플 연결을 종료합니다.

반환값

Stop All Async 작업에서 생성한 Task 결과입니다.

CommunicationSampleRuntime.cs 파일의 2540 번째 라인에서 정의되었습니다.

    {
        await DisconnectRabbitMqAsync();
        await DisconnectSerialAsync();
        await StopAllUdpAsync();
        await StopAllTcpAsync();
        await DisconnectInMemoryAsync();
    }

다음을 참조함 : DisconnectInMemoryAsync(), DisconnectRabbitMqAsync(), DisconnectSerialAsync(), StopAllTcpAsync(), StopAllUdpAsync().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

StopAllTcpAsync()

async Task SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.StopAllTcpAsync ( )

inline

TCP Server와 TCP Client를 모두 종료합니다.

반환값

Stop All Tcp Async 작업에서 생성한 Task 결과입니다.

CommunicationSampleRuntime.cs 파일의 1424 번째 라인에서 정의되었습니다.

    {
        await DisconnectTcpClientAsync();
        await StopTcpServerAsync();
    }

다음을 참조함 : DisconnectTcpClientAsync(), StopTcpServerAsync().

다음에 의해서 참조됨 : StopAllAsync().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

이 함수를 호출하는 함수들에 대한 그래프입니다.:

StopAllUdpAsync()

async Task SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.StopAllUdpAsync ( )

inline

UDP Peer A와 Peer B를 모두 종료합니다.

반환값

Stop All Udp Async 작업에서 생성한 Task 결과입니다.

CommunicationSampleRuntime.cs 파일의 1736 번째 라인에서 정의되었습니다.

    {
        await DisconnectUdpPeerBAsync();
        await DisconnectUdpPeerAAsync();
    }

다음을 참조함 : DisconnectUdpPeerAAsync(), DisconnectUdpPeerBAsync().

다음에 의해서 참조됨 : StopAllAsync().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

이 함수를 호출하는 함수들에 대한 그래프입니다.:

StopTcpServerAsync()

async Task SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.StopTcpServerAsync ( )

inline

현재 TCP Server를 종료합니다.

반환값

Stop Tcp Server Async 작업에서 생성한 Task 결과입니다.

CommunicationSampleRuntime.cs 파일의 968 번째 라인에서 정의되었습니다.

    {
        var protocol = _currentServerProtocol;
        var encodingName = _currentServerEncoding;
        var channelName = GetTcpServerChannelName(protocol, encodingName);
 
        if (_tcpServer is null)
        {
            if (Monitor.Channels.Any(x => x.Name == channelName))
            {
                Monitor.UpdateChannelState(channelName, ConnectionState.Disconnected);
            }
 
            return;
        }
 
        _tcpServer.MessageReceived -= OnTcpServerMessageReceived;
 
        await _tcpServer.DisposeAsync();
 
        _tcpServer = null;
        _rawTcpServer = null;
 
        if (Monitor.Channels.Any(x => x.Name == channelName))
        {
            Monitor.UpdateChannelState(channelName, ConnectionState.Disconnected);
        }
    }

다음을 참조함 : _currentServerEncoding, _currentServerProtocol, _rawTcpServer, _tcpServer, GetTcpServerChannelName(), Monitor, OnTcpServerMessageReceived().

다음에 의해서 참조됨 : StartTcpServerAsync(), StopAllTcpAsync().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

이 함수를 호출하는 함수들에 대한 그래프입니다.:

SubscribeInMemoryAsync()

async Task SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.SubscribeInMemoryAsync ( )

inlineprivate

Subscribe In Memory Async 작업을 수행합니다.

반환값

Subscribe In Memory Async 작업에서 생성한 Task 결과입니다.

CommunicationSampleRuntime.cs 파일의 2565 번째 라인에서 정의되었습니다.

    {
        if (_isInMemorySubscribed)
        {
            return;
        }
 
        _isInMemorySubscribed = true;
 
        await _messageBus.SubscribeAsync(
            InMemoryRouteName,
            (message, _) =>
            {
                RunOnUiThread(() =>
                {
                    Monitor.AddReceiveLog(
                        InMemoryChannelName,
                        TransportKind.InMemory,
                        message);
                });
 
                return Task.CompletedTask;
            });
    }

다음을 참조함 : _isInMemorySubscribed, _messageBus, InMemoryChannelName, InMemoryRouteName, Monitor, RunOnUiThread().

다음에 의해서 참조됨 : CommunicationSampleRuntime().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

이 함수를 호출하는 함수들에 대한 그래프입니다.:

SubscribeRabbitMqAsync()

async Task SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.SubscribeRabbitMqAsync ( string exchangeName, string queueName, string routingKey )

inline

RabbitMQ 메시지 구독을 시작합니다.

매개변수

exchangeName	Exchange 이름입니다.
queueName	Queue 이름입니다.
routingKey	RoutingKey입니다.

반환값

Subscribe Rabbit Mq Async 작업에서 생성한 Task 결과입니다.

CommunicationSampleRuntime.cs 파일의 2330 번째 라인에서 정의되었습니다.

    {
        exchangeName = NormalizeText(exchangeName, _currentRabbitMqExchangeName);
        queueName = NormalizeText(queueName, _currentRabbitMqQueueName);
        routingKey = NormalizeText(routingKey, _currentRabbitMqRoutingKey);
 
        if (_rabbitMqBus is null)
        {
            AddRabbitMqErrorLog(
                "RabbitMQ.Subscribe.Skipped",
                "RabbitMQ is not connected.");
            return;
        }
 
        if (_rabbitMqBus.State != ConnectionState.Connected)
        {
            AddRabbitMqErrorLog(
                "RabbitMQ.Subscribe.Skipped",
                $"RabbitMQ state is {_rabbitMqBus.State}.");
            return;
        }
 
        if (_isRabbitMqSubscribed)
        {
            return;
        }
 
        _currentRabbitMqExchangeName = exchangeName;
        _currentRabbitMqQueueName = queueName;
        _currentRabbitMqRoutingKey = routingKey;
 
        try
        {
            await _rabbitMqBus.SubscribeAsync(
                routingKey,
                (message, _) =>
                {
                    RunOnUiThread(() =>
                    {
                        Monitor.AddReceiveLog(
                            RabbitMqChannelName,
                            TransportKind.RabbitMq,
                            message);
                    });
 
                    return Task.CompletedTask;
                });
 
            _isRabbitMqSubscribed = true;
        }
        catch (Exception ex)
        {
            AddRabbitMqErrorLog("RabbitMQ.Subscribe.Failed", ex.Message);
        }
    }

다음을 참조함 : _currentRabbitMqExchangeName, _currentRabbitMqQueueName, _currentRabbitMqRoutingKey, _isRabbitMqSubscribed, _rabbitMqBus, AddRabbitMqErrorLog(), Monitor, NormalizeText(), RabbitMqChannelName, RunOnUiThread().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

UpdateTcpServerDescription()

void SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.UpdateTcpServerDescription ( string protocol, string encodingName, int clientCount, TcpServerSendTargetMode targetMode, bool echoEnabled )

inlineprivate

Update Tcp Server Description 작업을 수행합니다.

매개변수

protocol	protocol에 사용할 string 값입니다.
encodingName	encoding Name에 사용할 string 값입니다.
clientCount	client Count에 사용할 int 값입니다.
targetMode	target Mode에 사용할 TcpServerSendTargetMode 값입니다.
echoEnabled	echo Enabled에 사용할 bool 값입니다.

CommunicationSampleRuntime.cs 파일의 2882 번째 라인에서 정의되었습니다.

    {
        var channelName = GetTcpServerChannelName(protocol, encodingName);
        var port = GetTcpPort(protocol);
 
        Monitor.UpdateChannelDescription(
            channelName,
            CreateTcpServerDescription(protocol, encodingName, port, clientCount, targetMode, echoEnabled));
    }

다음을 참조함 : CreateTcpServerDescription(), GetTcpPort(), GetTcpServerChannelName(), Monitor.

다음에 의해서 참조됨 : AttachTcpServerClientCountMonitor(), SendTcpServerAsync(), StartTcpServerAsync(), UpdateTcpServerOptions().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

이 함수를 호출하는 함수들에 대한 그래프입니다.:

UpdateTcpServerOptions()

void SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.UpdateTcpServerOptions ( string protocol, string encodingName = PlainTextProtocolOptions::Utf8EncodingName, string sendTargetMode = nameof(TcpServerSendTargetMode.Broadcast), bool echoEnabled = false )

inline

실행 중인 TCP Server의 송신 대상과 Echo 옵션을 갱신합니다.

매개변수

protocol	프로토콜 이름입니다.
encodingName	PlainText 외부 송수신 인코딩 이름입니다.
sendTargetMode	서버 송신 대상 정책입니다.
echoEnabled	Echo 응답 사용 여부입니다.

CommunicationSampleRuntime.cs 파일의 922 번째 라인에서 정의되었습니다.

    {
        protocol = NormalizeProtocol(protocol);
        encodingName = NormalizeTextEncodingName(encodingName);
        var targetMode = NormalizeTcpServerSendTargetMode(sendTargetMode);
 
        _currentServerSendTargetMode = targetMode;
        _currentServerEchoEnabled = echoEnabled;
 
        if (_rawTcpServer is null ||
            _currentServerProtocol != protocol ||
            _currentServerEncoding != encodingName)
        {
            return;
        }
 
        _rawTcpServer.SendTargetMode = targetMode;
 
        UpdateTcpServerDescription(
            protocol,
            encodingName,
            _rawTcpServer.ConnectedClientCount,
            targetMode,
            echoEnabled);
    }

다음을 참조함 : _currentServerEchoEnabled, _currentServerEncoding, _currentServerProtocol, _currentServerSendTargetMode, _rawTcpServer, NormalizeProtocol(), NormalizeTcpServerSendTargetMode(), NormalizeTextEncodingName(), UpdateTcpServerDescription().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

멤버 데이터 문서화

_currentClientEncoding

string SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime._currentClientEncoding = PlainTextProtocolOptions.Utf8EncodingName

private

current Client Encoding 값을 보관합니다.

CommunicationSampleRuntime.cs 파일의 300 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : ConnectTcpClientAsync(), DisconnectTcpClientAsync(), OnTcpClientMessageReceived(), PrepareTcpClientTransportAsync().

_currentClientProtocol

string SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime._currentClientProtocol = PlainTextProtocol

private

current Client Protocol 값을 보관합니다.

CommunicationSampleRuntime.cs 파일의 282 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : ConnectTcpClientAsync(), DisconnectTcpClientAsync(), OnTcpClientMessageReceived(), PrepareTcpClientTransportAsync().

_currentRabbitMqExchangeName

string SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime._currentRabbitMqExchangeName = "dreamine.sample.exchange"

private

current Rabbit Mq Exchange Name 값을 보관합니다.

CommunicationSampleRuntime.cs 파일의 428 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : ConnectRabbitMqAsync(), PublishRabbitMqAsync(), SubscribeRabbitMqAsync().

_currentRabbitMqHost

string SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime._currentRabbitMqHost = "localhost"

private

current Rabbit Mq Host 값을 보관합니다.

CommunicationSampleRuntime.cs 파일의 401 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : ConnectRabbitMqAsync().

_currentRabbitMqPort

int SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime._currentRabbitMqPort = 5672

private

current Rabbit Mq Port 값을 보관합니다.

CommunicationSampleRuntime.cs 파일의 410 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : ConnectRabbitMqAsync().

_currentRabbitMqQueueName

string SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime._currentRabbitMqQueueName = "dreamine.sample.queue"

private

current Rabbit Mq Queue Name 값을 보관합니다.

CommunicationSampleRuntime.cs 파일의 437 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : ConnectRabbitMqAsync(), SubscribeRabbitMqAsync().

_currentRabbitMqRoutingKey

string SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime._currentRabbitMqRoutingKey = "dreamine.sample.route"

private

current Rabbit Mq Routing Key 값을 보관합니다.

CommunicationSampleRuntime.cs 파일의 446 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : AddRabbitMqErrorLog(), ConnectRabbitMqAsync(), PublishRabbitMqAsync(), SubscribeRabbitMqAsync().

_currentRabbitMqVirtualHost

string SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime._currentRabbitMqVirtualHost = "/"

private

current Rabbit Mq Virtual Host 값을 보관합니다.

CommunicationSampleRuntime.cs 파일의 419 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : ConnectRabbitMqAsync().

_currentSerialBaudRate

int SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime._currentSerialBaudRate = 9600

private

current Serial Baud Rate 값을 보관합니다.

CommunicationSampleRuntime.cs 파일의 391 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : ConnectSerialAsync().

_currentSerialEncoding

string SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime._currentSerialEncoding = PlainTextProtocolOptions.Utf8EncodingName

private

current Serial Encoding 값을 보관합니다.

CommunicationSampleRuntime.cs 파일의 373 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : ConnectSerialAsync().

_currentSerialPortName

string SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime._currentSerialPortName = string.Empty

private

current Serial Port Name 값을 보관합니다.

CommunicationSampleRuntime.cs 파일의 382 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : ConnectSerialAsync(), GetSerialChannelName().

_currentSerialProtocol

string SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime._currentSerialProtocol = RawAvailableProtocol

private

current Serial Protocol 값을 보관합니다.

CommunicationSampleRuntime.cs 파일의 364 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : ConnectSerialAsync().

_currentServerEchoEnabled

bool SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime._currentServerEchoEnabled

private

current Server Echo Enabled 값을 보관합니다.

CommunicationSampleRuntime.cs 파일의 318 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : AttachTcpServerClientCountMonitor(), EnsureTcpServerChannel(), OnTcpServerMessageReceived(), SendTcpServerAsync(), StartTcpServerAsync(), UpdateTcpServerOptions().

_currentServerEncoding

string SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime._currentServerEncoding = PlainTextProtocolOptions.Utf8EncodingName

private

current Server Encoding 값을 보관합니다.

CommunicationSampleRuntime.cs 파일의 291 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : OnTcpServerMessageReceived(), SendTcpServerAsync(), StartTcpServerAsync(), StopTcpServerAsync(), UpdateTcpServerOptions().

_currentServerProtocol

string SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime._currentServerProtocol = PlainTextProtocol

private

current Server Protocol 값을 보관합니다.

CommunicationSampleRuntime.cs 파일의 273 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : OnTcpServerMessageReceived(), SendTcpServerAsync(), StartTcpServerAsync(), StopTcpServerAsync(), UpdateTcpServerOptions().

_currentServerSendTargetMode

TcpServerSendTargetMode SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime._currentServerSendTargetMode = TcpServerSendTargetMode.Broadcast

private

current Server Send Target Mode 값을 보관합니다.

CommunicationSampleRuntime.cs 파일의 309 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : AttachTcpServerClientCountMonitor(), EnsureTcpServerChannel(), SendTcpServerAsync(), StartTcpServerAsync(), UpdateTcpServerOptions().

_currentUdpPeerAEncoding

string SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime._currentUdpPeerAEncoding = PlainTextProtocolOptions.Utf8EncodingName

private

current Udp Peer A Encoding 값을 보관합니다.

CommunicationSampleRuntime.cs 파일의 345 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : ConnectUdpPeerAAsync(), DisconnectUdpPeerAAsync(), OnUdpPeerAMessageReceived(), SendUdpPeerAAsync().

_currentUdpPeerAProtocol

string SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime._currentUdpPeerAProtocol = PlainTextProtocol

private

current Udp Peer A Protocol 값을 보관합니다.

CommunicationSampleRuntime.cs 파일의 327 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : ConnectUdpPeerAAsync(), DisconnectUdpPeerAAsync(), OnUdpPeerAMessageReceived(), SendUdpPeerAAsync().

_currentUdpPeerBEncoding

string SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime._currentUdpPeerBEncoding = PlainTextProtocolOptions.Utf8EncodingName

private

current Udp Peer B Encoding 값을 보관합니다.

CommunicationSampleRuntime.cs 파일의 354 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : ConnectUdpPeerBAsync(), DisconnectUdpPeerBAsync(), OnUdpPeerBMessageReceived(), SendUdpPeerBAsync().

_currentUdpPeerBProtocol

string SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime._currentUdpPeerBProtocol = PlainTextProtocol

private

current Udp Peer B Protocol 값을 보관합니다.

CommunicationSampleRuntime.cs 파일의 336 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : ConnectUdpPeerBAsync(), DisconnectUdpPeerBAsync(), OnUdpPeerBMessageReceived(), SendUdpPeerBAsync().

_isInMemorySubscribed

bool SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime._isInMemorySubscribed

private

is In Memory Subscribed 값을 보관합니다.

CommunicationSampleRuntime.cs 파일의 190 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : SubscribeInMemoryAsync().

_isRabbitMqSubscribed

bool SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime._isRabbitMqSubscribed

private

is Rabbit Mq Subscribed 값을 보관합니다.

CommunicationSampleRuntime.cs 파일의 199 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : ConnectRabbitMqAsync(), DisconnectRabbitMqAsync(), SubscribeRabbitMqAsync().

_messageBus

readonly IMessageBus SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime._messageBus

private

message Bus 값을 보관합니다.

CommunicationSampleRuntime.cs 파일의 180 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : CommunicationSampleRuntime(), ConnectInMemoryAsync(), DisconnectInMemoryAsync(), SendInMemoryAsync(), SubscribeInMemoryAsync().

_rabbitMqBus

RabbitMqMessageBus? SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime._rabbitMqBus

private

rabbit Mq Bus 값을 보관합니다.

CommunicationSampleRuntime.cs 파일의 263 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : ConnectRabbitMqAsync(), DisconnectRabbitMqAsync(), PublishRabbitMqAsync(), SubscribeRabbitMqAsync().

_rawTcpServer

TcpServerTransport? SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime._rawTcpServer

private

raw Tcp Server 값을 보관합니다.

CommunicationSampleRuntime.cs 파일의 218 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : SendTcpServerAsync(), StartTcpServerAsync(), StopTcpServerAsync(), UpdateTcpServerOptions().

_serialTransport

SerialPortTransport? SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime._serialTransport

private

serial Transport 값을 보관합니다.

CommunicationSampleRuntime.cs 파일의 254 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : ConnectSerialAsync(), DisconnectSerialAsync(), SendSerialAsync().

_tcpClient

IMessageTransport? SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime._tcpClient

private

tcp Client 값을 보관합니다.

CommunicationSampleRuntime.cs 파일의 227 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : ConnectTcpClientAsync(), DisconnectTcpClientAsync(), PrepareTcpClientTransportAsync(), SendTcpClientAsync().

_tcpServer

IMessageTransport? SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime._tcpServer

private

tcp Server 값을 보관합니다.

CommunicationSampleRuntime.cs 파일의 209 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : OnTcpServerMessageReceived(), SendTcpServerAsync(), StartTcpServerAsync(), StopTcpServerAsync().

_udpPeerA

UdpTransport? SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime._udpPeerA

private

udp Peer A 값을 보관합니다.

CommunicationSampleRuntime.cs 파일의 236 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : ConnectUdpPeerAAsync(), DisconnectUdpPeerAAsync(), SendUdpPeerAAsync().

_udpPeerB

UdpTransport? SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime._udpPeerB

private

udp Peer B 값을 보관합니다.

CommunicationSampleRuntime.cs 파일의 245 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : ConnectUdpPeerBAsync(), DisconnectUdpPeerBAsync(), SendUdpPeerBAsync().

DreamineEnvelopeProtocol

const string SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.DreamineEnvelopeProtocol = "DreamineEnvelope"

staticprivate

Dreamine Envelope Protocol 값을 보관합니다.

CommunicationSampleRuntime.cs 파일의 87 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : CreateFrameCodec(), CreateProtocolAdapter(), CreateSerialMessageByProtocol(), CreateTcpMessageByProtocol(), CreateUdpMessageByProtocol(), GetTcpClientChannelName(), GetTcpPort(), GetTcpServerChannelName(), GetUdpPeerChannelName(), NormalizeProtocol().

DreamineProtocolPort

const int SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.DreamineProtocolPort = 15001

staticprivate

Dreamine Protocol Port 값을 보관합니다.

CommunicationSampleRuntime.cs 파일의 124 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : GetTcpPort().

InMemoryChannelName

const string SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.InMemoryChannelName = "InMemory-Communication"

staticprivate

In Memory Channel Name 값을 보관합니다.

CommunicationSampleRuntime.cs 파일의 49 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : AddInMemoryChannel(), ConnectInMemoryAsync(), DisconnectInMemoryAsync(), ReceiveInMemory(), SendInMemoryAsync(), SubscribeInMemoryAsync().

InMemoryRouteName

const string SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.InMemoryRouteName = "sample.communication.message"

staticprivate

In Memory Route Name 값을 보관합니다.

CommunicationSampleRuntime.cs 파일의 58 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : SendInMemoryAsync(), SubscribeInMemoryAsync().

PlainTextProtocol

const string SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.PlainTextProtocol = "PlainText"

staticprivate

Plain Text Protocol 값을 보관합니다.

CommunicationSampleRuntime.cs 파일의 96 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : CreateFrameCodec(), CreateProtocolAdapter(), CreateSerialMessageByProtocol(), CreateTcpMessageByProtocol(), CreateUdpMessageByProtocol(), GetTcpClientChannelName(), GetTcpPort(), GetTcpServerChannelName(), GetUdpPeerChannelName(), NormalizeProtocol().

PlainTextProtocolPort

const int SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.PlainTextProtocolPort = 15002

staticprivate

Plain Text Protocol Port 값을 보관합니다.

CommunicationSampleRuntime.cs 파일의 133 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : GetTcpPort().

RabbitMqChannelName

const string SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.RabbitMqChannelName = "RabbitMQ-MessageBus"

staticprivate

Rabbit Mq Channel Name 값을 보관합니다.

CommunicationSampleRuntime.cs 파일의 68 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : AddRabbitMqErrorLog(), ConnectRabbitMqAsync(), DisconnectRabbitMqAsync(), EnsureRabbitMqChannel(), PublishRabbitMqAsync(), SubscribeRabbitMqAsync().

RabbitMqProtocol

const string SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.RabbitMqProtocol = "RabbitMQ"

staticprivate

Rabbit Mq Protocol 값을 보관합니다.

CommunicationSampleRuntime.cs 파일의 77 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : AddRabbitMqErrorLog(), CreateRabbitMqMessage().

RawAvailableProtocol

const string SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.RawAvailableProtocol = "RawAvailable"

staticprivate

Raw Available Protocol 값을 보관합니다.

CommunicationSampleRuntime.cs 파일의 105 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : CreateFrameCodec(), CreateProtocolAdapter(), CreateSerialMessageByProtocol(), CreateTcpMessageByProtocol(), CreateUdpMessageByProtocol(), GetTcpClientChannelName(), GetTcpPort(), GetTcpServerChannelName(), GetUdpPeerChannelName(), NormalizeProtocol().

RawAvailableProtocolPort

const int SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.RawAvailableProtocolPort = 15002

staticprivate

Raw Available Protocol Port 값을 보관합니다.

CommunicationSampleRuntime.cs 파일의 142 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : GetTcpPort().

RawJsonProtocol

const string SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.RawJsonProtocol = "RawJson"

staticprivate

Raw Json Protocol 값을 보관합니다.

CommunicationSampleRuntime.cs 파일의 114 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : CreateFrameCodec(), CreateProtocolAdapter(), CreateSerialMessageByProtocol(), CreateTcpMessageByProtocol(), CreateUdpMessageByProtocol(), GetTcpClientChannelName(), GetTcpPort(), GetTcpServerChannelName(), GetUdpPeerChannelName(), NormalizeProtocol().

RawJsonProtocolPort

const int SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.RawJsonProtocolPort = 15003

staticprivate

Raw Json Protocol Port 값을 보관합니다.

CommunicationSampleRuntime.cs 파일의 151 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : GetTcpPort().

UdpPeerALocalPort

const int SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.UdpPeerALocalPort = 16001

staticprivate

Udp Peer A Local Port 값을 보관합니다.

CommunicationSampleRuntime.cs 파일의 161 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : ConnectUdpPeerAAsync(), ConnectUdpPeerBAsync(), GetUdpLocalPort(), GetUdpRemotePort().

UdpPeerBLocalPort

const int SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.UdpPeerBLocalPort = 16002

staticprivate

Udp Peer B Local Port 값을 보관합니다.

CommunicationSampleRuntime.cs 파일의 170 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : ConnectUdpPeerAAsync(), ConnectUdpPeerBAsync(), GetUdpLocalPort(), GetUdpRemotePort().

속성 문서화

Monitor

CommunicationMonitorViewModel SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.Monitor

get

Communication Monitor ViewModel입니다.

CommunicationSampleRuntime.cs 파일의 488 번째 라인에서 정의되었습니다.

{ get; }

다음에 의해서 참조됨 : AddInMemoryChannel(), AddRabbitMqErrorLog(), AttachTcpClientQueueMonitor(), AttachTcpResilientStateMonitor(), CommunicationSampleRuntime(), ConnectInMemoryAsync(), ConnectRabbitMqAsync(), ConnectSerialAsync(), ConnectTcpClientAsync(), ConnectUdpPeerAAsync(), ConnectUdpPeerBAsync(), DisconnectInMemoryAsync(), DisconnectRabbitMqAsync(), DisconnectSerialAsync(), DisconnectTcpClientAsync(), DisconnectUdpPeerAAsync(), DisconnectUdpPeerBAsync(), EnsureRabbitMqChannel(), EnsureSerialChannel(), EnsureTcpClientChannel(), EnsureTcpServerChannel(), EnsureUdpPeerChannel(), OnSerialMessageReceived(), OnTcpClientMessageReceived(), OnTcpServerMessageReceived(), OnUdpPeerAMessageReceived(), OnUdpPeerBMessageReceived(), PrepareTcpClientTransportAsync(), PublishRabbitMqAsync(), ReceiveInMemory(), SendInMemoryAsync(), SendSerialAsync(), SendTcpClientAsync(), SendTcpServerAsync(), SendUdpPeerAAsync(), SendUdpPeerBAsync(), StartTcpServerAsync(), StopTcpServerAsync(), SubscribeInMemoryAsync(), SubscribeRabbitMqAsync(), UpdateTcpServerDescription().

SerialProtocols

IReadOnlyList<string> SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.SerialProtocols

get

초기값:

=
    [
        PlainTextProtocol,
        RawAvailableProtocol,
        RawJsonProtocol
    ]

선택 가능한 Serial 프로토콜 목록입니다.

CommunicationSampleRuntime.cs 파일의 514 번째 라인에서 정의되었습니다.

{ get; } =

TcpProtocols

IReadOnlyList<string> SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.TcpProtocols

get

초기값:

=
    [
        DreamineEnvelopeProtocol,
        PlainTextProtocol,
        RawAvailableProtocol,
        RawJsonProtocol
    ]

선택 가능한 TCP 프로토콜 목록입니다.

CommunicationSampleRuntime.cs 파일의 498 번째 라인에서 정의되었습니다.

{ get; } =

TcpServerSendTargetModes

IReadOnlyList<string> SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.TcpServerSendTargetModes

get

초기값:

=
    [
        nameof(TcpServerSendTargetMode.Broadcast),
        nameof(TcpServerSendTargetMode.FirstClient),
        nameof(TcpServerSendTargetMode.LastClient)
    ]

선택 가능한 TCP Server 송신 대상 정책 목록입니다.

CommunicationSampleRuntime.cs 파일의 559 번째 라인에서 정의되었습니다.

{ get; } =

TextEncodings

IReadOnlyList<string> SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.TextEncodings

get

초기값:

=
    [
        PlainTextProtocolOptions.Utf8EncodingName,
        PlainTextProtocolOptions.KoreanCodePage949EncodingName
    ]

선택 가능한 외부 PlainText 인코딩 목록입니다.

CommunicationSampleRuntime.cs 파일의 545 번째 라인에서 정의되었습니다.

{ get; } =

UdpProtocols

IReadOnlyList<string> SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.UdpProtocols

get

초기값:

=
    [
        DreamineEnvelopeProtocol,
        PlainTextProtocol,
        RawAvailableProtocol,
        RawJsonProtocol
    ]

선택 가능한 UDP 프로토콜 목록입니다.

CommunicationSampleRuntime.cs 파일의 529 번째 라인에서 정의되었습니다.

{ get; } =

UdpTextEncodings

IReadOnlyList<string> SampleSmart.Pages.PageSub.CommunicationTabs.CommunicationSampleRuntime.UdpTextEncodings

get

선택 가능한 UDP PlainText 인코딩 목록입니다.

CommunicationSampleRuntime.cs 파일의 574 번째 라인에서 정의되었습니다.

---

이 클래스에 대한 문서화 페이지는 다음의 파일로부터 생성되었습니다.:

• CommunicationSampleRuntime.cs