Dreamine.Communication.Sockets.Servers.TcpServerTransport에 대한 상속 다이어그램 :

[범례]

Dreamine.Communication.Sockets.Servers.TcpServerTransport에 대한 협력 다이어그램:

[범례]

클래스
class	TcpClientConnectionEntry

Public 멤버 함수
	TcpServerTransport (TcpServerTransportOptions options)
	TcpServerTransport (TcpServerTransportOptions options, IMessageProtocolAdapter protocolAdapter, IMessageFrameCodec frameCodec)
Task	ConnectAsync (CancellationToken cancellationToken=default)
async Task	DisconnectAsync (CancellationToken cancellationToken=default)
Task	SendAsync (MessageEnvelope message, CancellationToken cancellationToken=default)
async Task	SendAsync (TcpServerSendTargetMode targetMode, MessageEnvelope message, CancellationToken cancellationToken=default)
Task	BroadcastAsync (MessageEnvelope message, CancellationToken cancellationToken=default)
async ValueTask	DisposeAsync ()

속성
ConnectionState	State `[get]`
TransportKind	Kind `[get]`
int	ConnectedClientCount `[get]`
TcpServerSendTargetMode	SendTargetMode `[get, set]`

이벤트
EventHandler< MessageEnvelope >?	MessageReceived
EventHandler< int >?	ConnectedClientCountChanged

Private 멤버 함수
TcpClientConnectionEntry[]	GetTargetClients (TcpServerSendTargetMode targetMode)
async Task	SendToClientAsync (TcpClientConnectionEntry target, byte[] payload, CancellationToken cancellationToken)
async Task	AcceptLoopAsync (CancellationToken cancellationToken)
async Task	ReceiveLoopAsync (Guid clientId, TcpClient client, CancellationToken cancellationToken)
void	CleanupListener ()
void	CleanupClients ()
void	RemoveClient (Guid clientId, TcpClient client)
void	SetState (ConnectionState state)
void	NotifyConnectedClientCountChanged ()

정적 Private 멤버 함수
static IPAddress	ParseHost (string host)
static void	ValidateOptions (TcpServerTransportOptions options)

Private 속성
readonly TcpServerTransportOptions	_options
readonly IMessageProtocolAdapter	_protocolAdapter
readonly IMessageFrameCodec	_frameCodec
readonly ConcurrentDictionary< Guid, TcpClientConnectionEntry >	_clients = new()
TcpListener?	_listener
CancellationTokenSource?	_serverCts
Task?	_acceptLoopTask
int	_state = (int)ConnectionState.Disconnected

상세한 설명

여러 TCP 클라이언트의 연결, 수신 및 대상별 메시지 송신을 관리합니다.

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

생성자 & 소멸자 문서화

◆ TcpServerTransport() [1/2]

Dreamine.Communication.Sockets.Servers.TcpServerTransport.TcpServerTransport ( TcpServerTransportOptions options )

inline

기본 Dreamine JSON 프로토콜과 길이 접두사 프레임으로 TCP 서버를 초기화합니다.

매개변수

options 수신 주소, 대기열, 버퍼 및 송신 대상 설정입니다.

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

        : this(
            options,
            new DreamineEnvelopeProtocolAdapter(),
            new LengthPrefixedMessageFrameCodec())
    {
    }

◆ TcpServerTransport() [2/2]

Dreamine.Communication.Sockets.Servers.TcpServerTransport.TcpServerTransport	(	TcpServerTransportOptions	options,
		IMessageProtocolAdapter	protocolAdapter,
		IMessageFrameCodec	frameCodec )

inline

TCP 서버 설정과 사용자 지정 프로토콜 및 프레임 코덱으로 서버를 초기화합니다.

매개변수

options	수신 주소, 대기열, 버퍼 및 송신 대상 설정입니다.
protocolAdapter	메시지와 외부 페이로드를 변환할 어댑터입니다.
frameCodec	클라이언트 스트림의 메시지 경계를 처리할 코덱입니다.

예외

ArgumentNullException options , protocolAdapter 또는 frameCodec 이 null인 경우 발생합니다.

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

    {
        _options = options ?? throw new ArgumentNullException(nameof(options));
        _protocolAdapter = protocolAdapter ?? throw new ArgumentNullException(nameof(protocolAdapter));
        _frameCodec = frameCodec ?? throw new ArgumentNullException(nameof(frameCodec));
 
        ValidateOptions(_options);
    }

다음을 참조함 : _frameCodec, _options, _protocolAdapter, ValidateOptions().

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

멤버 함수 문서화

◆ AcceptLoopAsync()

async Task Dreamine.Communication.Sockets.Servers.TcpServerTransport.AcceptLoopAsync ( CancellationToken cancellationToken )

inlineprivate

TCP 클라이언트를 계속 수락하고 각 연결의 수신 루프를 시작합니다.

매개변수

cancellationToken 수락 루프 종료 토큰입니다.

반환값: 백그라운드 수락 루프 작업입니다.

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

    {
        if (_listener is null)
        {
            return;
        }
 
        try
        {
            while (!cancellationToken.IsCancellationRequested &&
                   State == ConnectionState.Listening)
            {
                var client = await _listener.AcceptTcpClientAsync(cancellationToken)
                    .ConfigureAwait(false);
 
                client.ReceiveBufferSize = _options.ReceiveBufferSize;
                client.SendBufferSize = _options.SendBufferSize;
 
                var clientId = Guid.NewGuid();
                var entry = new TcpClientConnectionEntry(
                    clientId,
                    client,
                    DateTimeOffset.UtcNow);
 
                _clients[clientId] = entry;
                NotifyConnectedClientCountChanged();
 
                _ = Task.Run(
                    () => ReceiveLoopAsync(clientId, client, cancellationToken),
                    cancellationToken);
            }
        }
        catch (OperationCanceledException)
        {
        }
        catch (ObjectDisposedException)
        {
        }
        catch (SocketException)
        {
            if (!cancellationToken.IsCancellationRequested)
            {
                SetState(ConnectionState.Faulted);
                CleanupListener();
                CleanupClients();
            }
        }
        catch (IOException)
        {
            if (!cancellationToken.IsCancellationRequested)
            {
                SetState(ConnectionState.Faulted);
                CleanupListener();
                CleanupClients();
            }
        }
        catch
        {
            if (!cancellationToken.IsCancellationRequested)
            {
                SetState(ConnectionState.Faulted);
                CleanupListener();
                CleanupClients();
            }
        }
    }

다음을 참조함 : _clients, _listener, _options, CleanupClients(), CleanupListener(), NotifyConnectedClientCountChanged(), ReceiveLoopAsync(), SetState(), State.

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

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

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

◆ BroadcastAsync()

Task Dreamine.Communication.Sockets.Servers.TcpServerTransport.BroadcastAsync	(	MessageEnvelope	message,
		CancellationToken	cancellationToken = default )

inline

연결된 모든 TCP 클라이언트에게 메시지를 병렬 전송합니다.

매개변수

message	브로드캐스트할 메시지입니다.
cancellationToken	브로드캐스트 취소 토큰입니다.

반환값: 비동기 브로드캐스트 작업입니다.

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

    {
        return SendAsync(TcpServerSendTargetMode.Broadcast, message, cancellationToken);
    }

다음을 참조함 : SendAsync().

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

◆ CleanupClients()

void Dreamine.Communication.Sockets.Servers.TcpServerTransport.CleanupClients ( )

inlineprivate

현재 연결된 모든 클라이언트를 제거하고 해제합니다.

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

    {
        foreach (var pair in _clients.ToArray())
        {
            RemoveClient(pair.Key, pair.Value.Client);
        }
    }

다음을 참조함 : _clients, RemoveClient().

다음에 의해서 참조됨 : AcceptLoopAsync(), ConnectAsync(), DisconnectAsync().

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

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

◆ CleanupListener()

void Dreamine.Communication.Sockets.Servers.TcpServerTransport.CleanupListener ( )

inlineprivate

정리 예외를 전파하지 않고 TCP Listener를 중지합니다.

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

    {
        try
        {
            _listener?.Stop();
        }
        catch
        {
            // Ignore cleanup exceptions.
        }
 
        _listener = null;
    }

다음을 참조함 : _listener.

다음에 의해서 참조됨 : AcceptLoopAsync(), ConnectAsync(), DisconnectAsync().

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

◆ ConnectAsync()

Task Dreamine.Communication.Sockets.Servers.TcpServerTransport.ConnectAsync ( CancellationToken cancellationToken = default )

inline

TCP Listener를 시작하고 백그라운드 클라이언트 수락 루프를 실행합니다.

매개변수

cancellationToken 서버 및 수락 루프 수명과 연결할 취소 토큰입니다.

반환값: TCP 서버 시작 작업입니다.

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

    {
        if (State is ConnectionState.Listening or ConnectionState.Connecting)
        {
            return Task.CompletedTask;
        }
 
        cancellationToken.ThrowIfCancellationRequested();
 
        SetState(ConnectionState.Connecting);
 
        try
        {
            CleanupListener();
            CleanupClients();
 
            var ipAddress = ParseHost(_options.Host);
            _listener = new TcpListener(ipAddress, _options.Port);
            _listener.Start(_options.Backlog);
 
            _serverCts = CancellationTokenSource.CreateLinkedTokenSource(cancellationToken);
 
            SetState(ConnectionState.Listening);
 
            _acceptLoopTask = Task.Run(
                () => AcceptLoopAsync(_serverCts.Token),
                _serverCts.Token);
 
            return Task.CompletedTask;
        }
        catch
        {
            SetState(ConnectionState.Faulted);
            CleanupListener();
            CleanupClients();
 
            _serverCts?.Dispose();
            _serverCts = null;
 
            throw;
        }
    }

다음을 참조함 : _acceptLoopTask, _listener, _options, _serverCts, AcceptLoopAsync(), CleanupClients(), CleanupListener(), ParseHost(), SetState(), State.

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

◆ DisconnectAsync()

async Task Dreamine.Communication.Sockets.Servers.TcpServerTransport.DisconnectAsync ( CancellationToken cancellationToken = default )

inline

수락 루프와 Listener를 중지하고 연결된 모든 클라이언트를 해제합니다.

매개변수

cancellationToken 정리 후 연결 해제 취소 여부를 확인하는 토큰입니다.

반환값: 비동기 서버 종료 작업입니다.

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

    {
        if (State == ConnectionState.Disconnected)
        {
            return;
        }
 
        SetState(ConnectionState.Disconnecting);
 
        _serverCts?.Cancel();
 
        CleanupClients();
        CleanupListener();
 
        if (_acceptLoopTask is not null)
        {
            try
            {
                await _acceptLoopTask.ConfigureAwait(false);
            }
            catch (OperationCanceledException)
            {
            }
            catch (ObjectDisposedException)
            {
            }
            catch (SocketException)
            {
            }
        }
 
        _serverCts?.Dispose();
        _serverCts = null;
        _acceptLoopTask = null;
 
        cancellationToken.ThrowIfCancellationRequested();
 
        SetState(ConnectionState.Disconnected);
    }

다음을 참조함 : _acceptLoopTask, _serverCts, CleanupClients(), CleanupListener(), SetState(), State.

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

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

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

◆ DisposeAsync()

async ValueTask Dreamine.Communication.Sockets.Servers.TcpServerTransport.DisposeAsync ( )

inline

Listener, 수락 루프 및 클라이언트 연결을 비동기적으로 해제합니다.

반환값: 비동기 리소스 해제 작업입니다.

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

    {
        await DisconnectAsync().ConfigureAwait(false);
    }

다음을 참조함 : DisconnectAsync().

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

◆ GetTargetClients()

TcpClientConnectionEntry[] Dreamine.Communication.Sockets.Servers.TcpServerTransport.GetTargetClients ( TcpServerSendTargetMode targetMode )

inlineprivate

연결 시각과 대상 정책에 따라 송신 대상 클라이언트 스냅샷을 생성합니다.

매개변수

targetMode 적용할 대상 선택 정책입니다.

반환값: 선택된 클라이언트 연결 배열입니다.

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

    {
        var entries = _clients.Values
            .OrderBy(x => x.ConnectedAt)
            .ToArray();
 
        return targetMode switch
        {
            TcpServerSendTargetMode.Broadcast => entries,
            TcpServerSendTargetMode.FirstClient => entries.Take(1).ToArray(),
            TcpServerSendTargetMode.LastClient => entries.Reverse().Take(1).ToArray(),
            _ => entries
        };
    }

다음을 참조함 : Dreamine.Communication.Sockets.Enums.Broadcast, Dreamine.Communication.Sockets.Enums.FirstClient, Dreamine.Communication.Sockets.Enums.LastClient.

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

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

◆ NotifyConnectedClientCountChanged()

void Dreamine.Communication.Sockets.Servers.TcpServerTransport.NotifyConnectedClientCountChanged ( )

inlineprivate

현재 연결 클라이언트 수로 변경 이벤트를 발생시킵니다.

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

    {
        ConnectedClientCountChanged?.Invoke(this, ConnectedClientCount);
    }

다음을 참조함 : ConnectedClientCount, ConnectedClientCountChanged.

다음에 의해서 참조됨 : AcceptLoopAsync(), RemoveClient().

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

◆ ParseHost()

IPAddress Dreamine.Communication.Sockets.Servers.TcpServerTransport.ParseHost ( string host )

inlinestaticprivate

서버 바인딩 호스트 문자열을 IPv4 주소로 변환합니다.

매개변수

host	변환할 호스트 문자열입니다.

반환값: 바인딩에 사용할 IP 주소입니다.

예외

ArgumentException 올바른 IP 주소가 아닌 경우 발생합니다.

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

    {
        if (host == "0.0.0.0")
        {
            return IPAddress.Any;
        }
 
        if (host == "127.0.0.1" ||
            host.Equals("localhost", StringComparison.OrdinalIgnoreCase))
        {
            return IPAddress.Loopback;
        }
 
        if (IPAddress.TryParse(host, out var ipAddress))
        {
            return ipAddress;
        }
 
        throw new ArgumentException($"Invalid TCP server host: {host}", nameof(host));
    }

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

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

◆ ReceiveLoopAsync()

async Task Dreamine.Communication.Sockets.Servers.TcpServerTransport.ReceiveLoopAsync	(	Guid	clientId,
		TcpClient	client,
		CancellationToken	cancellationToken )

inlineprivate

특정 클라이언트의 프레임을 계속 읽어 메시지 수신 이벤트를 발생시킵니다.

매개변수

clientId	클라이언트 연결 식별자입니다.
client	데이터를 읽을 TCP 클라이언트입니다.
cancellationToken	수신 루프 종료 토큰입니다.

반환값: 클라이언트 수신 루프 작업입니다.

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

    {
        try
        {
            var stream = client.GetStream();
 
            while (!cancellationToken.IsCancellationRequested &&
                   State == ConnectionState.Listening &&
                   client.Connected)
            {
                var payload = await _frameCodec.ReadFrameAsync(stream, cancellationToken)
                    .ConfigureAwait(false);
 
                if (payload is null)
                {
                    break;
                }
 
                var message = _protocolAdapter.Decode(payload);
                MessageReceived?.Invoke(this, message);
            }
        }
        catch (OperationCanceledException)
        {
        }
        catch (ObjectDisposedException)
        {
        }
        catch (SocketException)
        {
        }
        catch
        {
            // 수신 루프 단위 예외는 해당 클라이언트 제거로 처리합니다.
        }
        finally
        {
            RemoveClient(clientId, client);
        }
    }

다음을 참조함 : _frameCodec, _protocolAdapter, MessageReceived, RemoveClient(), State.

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

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

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

◆ RemoveClient()

void Dreamine.Communication.Sockets.Servers.TcpServerTransport.RemoveClient	(	Guid	clientId,
		TcpClient	client )

inlineprivate

연결 사전에서 클라이언트를 제거하고 소켓을 닫은 뒤 개수 변경을 알립니다.

매개변수

clientId	제거할 연결 식별자입니다.
client	닫고 해제할 TCP 클라이언트입니다.

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

    {
        var removed = _clients.TryRemove(clientId, out _);
 
        try
        {
            client.Close();
            client.Dispose();
        }
        catch
        {
            // Ignore cleanup exceptions.
        }
 
        if (removed)
        {
            NotifyConnectedClientCountChanged();
        }
    }

다음을 참조함 : _clients, NotifyConnectedClientCountChanged().

다음에 의해서 참조됨 : CleanupClients(), ReceiveLoopAsync(), SendToClientAsync().

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

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

◆ SendAsync() [1/2]

Task Dreamine.Communication.Sockets.Servers.TcpServerTransport.SendAsync	(	MessageEnvelope	message,
		CancellationToken	cancellationToken = default )

inline

구성된 기본 대상 정책에 따라 연결된 클라이언트에게 메시지를 전송합니다.

매개변수

message	전송할 메시지입니다.
cancellationToken	송신 취소 요청을 감시하는 토큰입니다.

반환값: 비동기 대상별 송신 작업입니다.

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

    {
        return SendAsync(SendTargetMode, message, cancellationToken);
    }

다음을 참조함 : SendAsync(), SendTargetMode.

다음에 의해서 참조됨 : BroadcastAsync(), SendAsync().

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

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

◆ SendAsync() [2/2]

async Task Dreamine.Communication.Sockets.Servers.TcpServerTransport.SendAsync	(	TcpServerSendTargetMode	targetMode,
		MessageEnvelope	message,
		CancellationToken	cancellationToken = default )

inline

지정한 대상 정책으로 선택한 클라이언트들에게 메시지를 병렬 전송합니다.

매개변수

targetMode	클라이언트 선택 정책입니다.
message	전송할 메시지입니다.
cancellationToken	모든 클라이언트 송신 취소 토큰입니다.

반환값: 선택된 모든 클라이언트의 병렬 송신 작업입니다.

예외

ArgumentNullException	메시지가 `null`인 경우 발생합니다.
InvalidOperationException	서버가 수신 대기 중이 아니거나 대상 클라이언트가 없는 경우 발생합니다.

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

    {
        ArgumentNullException.ThrowIfNull(message);
 
        if (State != ConnectionState.Listening)
        {
            throw new InvalidOperationException("TCP server is not listening.");
        }
 
        var payload = _protocolAdapter.Encode(message);
        var targets = GetTargetClients(targetMode);
 
        if (targets.Length == 0)
        {
            throw new InvalidOperationException("No TCP client is connected to the server.");
        }
 
        var sendTasks = targets
            .Select(target => SendToClientAsync(target, payload, cancellationToken))
            .ToArray();
 
        await Task.WhenAll(sendTasks).ConfigureAwait(false);
    }

다음을 참조함 : _protocolAdapter, GetTargetClients(), SendToClientAsync(), State.

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

◆ SendToClientAsync()

async Task Dreamine.Communication.Sockets.Servers.TcpServerTransport.SendToClientAsync	(	TcpClientConnectionEntry	target,
		byte[]	payload,
		CancellationToken	cancellationToken )

inlineprivate

클라이언트별 잠금을 사용해 한 클라이언트에 프레임을 순차적으로 전송합니다.

매개변수

target	대상 클라이언트 연결 정보입니다.
payload	프레임으로 전송할 프로토콜 페이로드입니다.
cancellationToken	잠금 대기와 송신 취소 토큰입니다.

반환값: 단일 클라이언트 송신 작업입니다.

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

    {
        cancellationToken.ThrowIfCancellationRequested();
 
        if (!target.Client.Connected)
        {
            RemoveClient(target.ClientId, target.Client);
            return;
        }
 
        await target.SendLock.WaitAsync(cancellationToken).ConfigureAwait(false);
 
        try
        {
            if (!target.Client.Connected)
            {
                RemoveClient(target.ClientId, target.Client);
                return;
            }
 
            var stream = target.Client.GetStream();
 
            await _frameCodec.WriteFrameAsync(stream, payload, cancellationToken)
                .ConfigureAwait(false);
        }
        catch
        {
            RemoveClient(target.ClientId, target.Client);
        }
        finally
        {
            target.SendLock.Release();
        }
    }

다음을 참조함 : _frameCodec, Dreamine.Communication.Sockets.Servers.TcpServerTransport.TcpClientConnectionEntry.Client, Dreamine.Communication.Sockets.Servers.TcpServerTransport.TcpClientConnectionEntry.ClientId, RemoveClient(), Dreamine.Communication.Sockets.Servers.TcpServerTransport.TcpClientConnectionEntry.SendLock.

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

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

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

◆ SetState()

void Dreamine.Communication.Sockets.Servers.TcpServerTransport.SetState ( ConnectionState state )

inlineprivate

원자적 연산으로 현재 서버 상태를 설정합니다.

매개변수

state 저장할 새 상태입니다.

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

    {
        Interlocked.Exchange(ref _state, (int)state);
    }

다음을 참조함 : _state.

다음에 의해서 참조됨 : AcceptLoopAsync(), ConnectAsync(), DisconnectAsync().

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

◆ ValidateOptions()

void Dreamine.Communication.Sockets.Servers.TcpServerTransport.ValidateOptions ( TcpServerTransportOptions options )

inlinestaticprivate

TCP 서버 호스트, 포트, 대기열 및 버퍼 설정을 검증합니다.

매개변수

options 검증할 TCP 서버 설정입니다.

예외

ArgumentException	호스트가 비어 있는 경우 발생합니다.
ArgumentOutOfRangeException	수치 설정이 허용 범위를 벗어난 경우 발생합니다.

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

    {
        ArgumentException.ThrowIfNullOrWhiteSpace(options.Host);
 
        if (options.Port <= 0 || options.Port > 65535)
        {
            throw new ArgumentOutOfRangeException(nameof(options.Port));
        }
 
        if (options.Backlog <= 0)
        {
            throw new ArgumentOutOfRangeException(nameof(options.Backlog));
        }
 
        if (options.ReceiveBufferSize <= 0)
        {
            throw new ArgumentOutOfRangeException(nameof(options.ReceiveBufferSize));
        }
 
        if (options.SendBufferSize <= 0)
        {
            throw new ArgumentOutOfRangeException(nameof(options.SendBufferSize));
        }
    }

다음을 참조함 : Dreamine.Communication.Sockets.Options.TcpServerTransportOptions.Backlog, Dreamine.Communication.Sockets.Options.TcpServerTransportOptions.Host, Dreamine.Communication.Sockets.Options.TcpServerTransportOptions.Port, Dreamine.Communication.Sockets.Options.TcpServerTransportOptions.ReceiveBufferSize, Dreamine.Communication.Sockets.Options.TcpServerTransportOptions.SendBufferSize.

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

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

멤버 데이터 문서화

◆ _acceptLoopTask

Task? Dreamine.Communication.Sockets.Servers.TcpServerTransport._acceptLoopTask

private

accept Loop Task 값을 보관합니다.

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

다음에 의해서 참조됨 : ConnectAsync(), DisconnectAsync().

◆ _clients

readonly ConcurrentDictionary<Guid, TcpClientConnectionEntry> Dreamine.Communication.Sockets.Servers.TcpServerTransport._clients = new()

private

clients 값을 보관합니다.

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

다음에 의해서 참조됨 : AcceptLoopAsync(), CleanupClients(), RemoveClient().

◆ _frameCodec

readonly IMessageFrameCodec Dreamine.Communication.Sockets.Servers.TcpServerTransport._frameCodec

private

frame Codec 값을 보관합니다.

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

다음에 의해서 참조됨 : ReceiveLoopAsync(), SendToClientAsync(), TcpServerTransport().

◆ _listener

TcpListener? Dreamine.Communication.Sockets.Servers.TcpServerTransport._listener

private

listener 값을 보관합니다.

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

다음에 의해서 참조됨 : AcceptLoopAsync(), CleanupListener(), ConnectAsync().

◆ _options

readonly TcpServerTransportOptions Dreamine.Communication.Sockets.Servers.TcpServerTransport._options

private

options 값을 보관합니다.

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

다음에 의해서 참조됨 : AcceptLoopAsync(), ConnectAsync(), TcpServerTransport().

◆ _protocolAdapter

readonly IMessageProtocolAdapter Dreamine.Communication.Sockets.Servers.TcpServerTransport._protocolAdapter

private

protocol Adapter 값을 보관합니다.

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

다음에 의해서 참조됨 : ReceiveLoopAsync(), SendAsync(), TcpServerTransport().

◆ _serverCts

CancellationTokenSource? Dreamine.Communication.Sockets.Servers.TcpServerTransport._serverCts

private

server Cts 값을 보관합니다.

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

다음에 의해서 참조됨 : ConnectAsync(), DisconnectAsync().

◆ _state

int Dreamine.Communication.Sockets.Servers.TcpServerTransport._state = (int)ConnectionState.Disconnected

private

state 값을 보관합니다.

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

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

속성 문서화

◆ ConnectedClientCount

int Dreamine.Communication.Sockets.Servers.TcpServerTransport.ConnectedClientCount

get

현재 서버에 연결된 TCP 클라이언트 수를 가져옵니다.

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

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

◆ Kind

TransportKind Dreamine.Communication.Sockets.Servers.TcpServerTransport.Kind

get

TCP 전송 방식을 가져옵니다.

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

◆ SendTargetMode

TcpServerSendTargetMode Dreamine.Communication.Sockets.Servers.TcpServerTransport.SendTargetMode

getset

기본 송신 작업에서 사용할 클라이언트 대상 정책을 가져오거나 설정합니다.

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

    {
        get => _options.SendTargetMode;
        set => _options.SendTargetMode = value;
    }

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

◆ State

ConnectionState Dreamine.Communication.Sockets.Servers.TcpServerTransport.State

get

스레드 안전하게 현재 서버 수신 대기 상태를 가져옵니다.

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

다음에 의해서 참조됨 : AcceptLoopAsync(), ConnectAsync(), DisconnectAsync(), ReceiveLoopAsync(), SendAsync().

이벤트 문서화

◆ ConnectedClientCountChanged

EventHandler<int>? Dreamine.Communication.Sockets.Servers.TcpServerTransport.ConnectedClientCountChanged

서버에 연결된 클라이언트 수가 변경될 때 발생합니다.

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

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

◆ MessageReceived

EventHandler<MessageEnvelope>? Dreamine.Communication.Sockets.Servers.TcpServerTransport.MessageReceived

클라이언트 프레임을 메시지로 디코딩했을 때 발생합니다.

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

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

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

TcpServerTransport.cs

클래스

Public 멤버 함수

속성

이벤트

Private 멤버 함수

정적 Private 멤버 함수

Private 속성

상세한 설명

생성자 & 소멸자 문서화

◆ TcpServerTransport() [1/2]

◆ TcpServerTransport() [2/2]

멤버 함수 문서화

◆ AcceptLoopAsync()

◆ BroadcastAsync()

◆ CleanupClients()

◆ CleanupListener()

◆ ConnectAsync()

◆ DisconnectAsync()

◆ DisposeAsync()

◆ GetTargetClients()

◆ NotifyConnectedClientCountChanged()

◆ ParseHost()

◆ ReceiveLoopAsync()

◆ RemoveClient()

◆ SendAsync() [1/2]

◆ SendAsync() [2/2]

◆ SendToClientAsync()

◆ SetState()

◆ ValidateOptions()

멤버 데이터 문서화

◆ _acceptLoopTask

◆ _clients

◆ _frameCodec

◆ _listener

◆ _options

◆ _protocolAdapter

◆ _serverCts

◆ _state

속성 문서화

◆ ConnectedClientCount

◆ Kind

◆ SendTargetMode

◆ State

이벤트 문서화

◆ ConnectedClientCountChanged

◆ MessageReceived