Dreamine.Communication.Core.Resilience.ResilientMessageTransport 클래스 참조

더 자세히 ...

Dreamine.Communication.Core.Resilience.ResilientMessageTransport에 대한 상속 다이어그램 :

Dreamine.Communication.Core.Resilience.ResilientMessageTransport에 대한 협력 다이어그램:

Public 멤버 함수
	ResilientMessageTransport (IMessageTransport innerTransport, ReconnectPolicy? reconnectPolicy=null, OutboundQueueOptions? queueOptions=null, IOutboundMessageQueue? outboundQueue=null)
async Task	ConnectAsync (CancellationToken cancellationToken=default)
async Task	DisconnectAsync (CancellationToken cancellationToken=default)
async Task	SendAsync (MessageEnvelope message, CancellationToken cancellationToken=default)
async Task	FlushQueueAsync (CancellationToken cancellationToken=default)
async ValueTask	DisposeAsync ()

속성
TransportKind	Kind [get]
ConnectionState	State [get]
int	QueuedMessageCount [get]
bool	IsManualDisconnectRequested [get]
bool	IsResilienceLoopRequested [get]

이벤트
EventHandler< MessageEnvelope >?	MessageReceived
EventHandler< ConnectionState >?	StateChanged
EventHandler< int >?	QueueCountChanged

Private 멤버 함수
async Task	HandleDisconnectedSendAsync (MessageEnvelope message, CancellationToken cancellationToken)
async Task	WaitUntilConnectedAsync (CancellationToken cancellationToken)
void	EnsureResilienceLoopStarted ()
async Task	RunResilienceLoopAsync (CancellationToken cancellationToken)
void	SetManualDisconnectRequested (bool value)
void	SetResilienceLoopRequested (bool value)
void	OnInnerMessageReceived (object? sender, MessageEnvelope message)
void	NotifyStateChangedIfNeeded ()
void	NotifyQueueCountChanged ()
void	ThrowIfDisposed ()

정적 Private 멤버 함수
static bool	IsOperationalState (ConnectionState state)
static async Task	DelaySafelyAsync (TimeSpan delay, CancellationToken cancellationToken)

Private 속성
readonly IMessageTransport	_innerTransport
readonly ReconnectPolicy	_reconnectPolicy
readonly OutboundQueueOptions	_queueOptions
readonly IOutboundMessageQueue	_outboundQueue
readonly ReconnectDelayCalculator	_delayCalculator
readonly SemaphoreSlim	_flushLock = new(1, 1)
readonly object	_loopSync = new()
readonly object	_notifySync = new()
CancellationTokenSource	_lifetimeCts = new()
Task?	_resilienceLoopTask
int	_manualDisconnectRequested = 1
int	_resilienceLoopRequested
int	_disposeGuard
bool	_disposed
ConnectionState	_lastNotifiedState = ConnectionState.Disconnected

상세한 설명

내부 메시지 전송 계층에 자동 재연결, 지수 백오프 및 연결 끊김 송신 큐를 추가합니다.

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

생성자 & 소멸자 문서화

ResilientMessageTransport()

Dreamine.Communication.Core.Resilience.ResilientMessageTransport.ResilientMessageTransport ( IMessageTransport innerTransport, ReconnectPolicy? reconnectPolicy = null, OutboundQueueOptions? queueOptions = null, IOutboundMessageQueue? outboundQueue = null )

inline

내부 전송 계층과 선택적 복원·큐 설정으로 전송 계층을 초기화합니다.

매개변수

innerTransport	실제 연결과 송수신을 담당할 전송 계층입니다.
reconnectPolicy	재연결 간격과 횟수를 제어할 정책입니다.
queueOptions	연결 끊김 송신 처리와 큐 제한 설정입니다.
outboundQueue	사용자 지정 송신 큐이며, null이면 메모리 큐를 생성합니다.

예외

ArgumentNullException

innerTransport 가 null인 경우 발생합니다.

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

    {
        _innerTransport = innerTransport ?? throw new ArgumentNullException(nameof(innerTransport));
        _reconnectPolicy = reconnectPolicy ?? new ReconnectPolicy();
        _queueOptions = queueOptions ?? new OutboundQueueOptions();
        _outboundQueue = outboundQueue ?? new InMemoryOutboundMessageQueue(_queueOptions);
        _delayCalculator = new ReconnectDelayCalculator(_reconnectPolicy);
 
        _lastNotifiedState = State;
        _innerTransport.MessageReceived += OnInnerMessageReceived;
    }

다음을 참조함 : _delayCalculator, _innerTransport, _lastNotifiedState, _outboundQueue, _queueOptions, _reconnectPolicy, OnInnerMessageReceived(), State.

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

멤버 함수 문서화

ConnectAsync()

async Task Dreamine.Communication.Core.Resilience.ResilientMessageTransport.ConnectAsync ( CancellationToken cancellationToken = default )

inline

내부 연결과 필요 시 백그라운드 재연결 루프를 시작합니다.

매개변수

cancellationToken

최초 연결과 큐 전송 취소 요청을 감시하는 토큰입니다.

반환값

비동기 연결 및 초기 큐 처리 작업입니다.

예외

ObjectDisposedException	이미 해제된 경우 발생합니다.
OperationCanceledException	작업 취소가 요청된 경우 발생할 수 있습니다.

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

    {
        ThrowIfDisposed();
 
        SetManualDisconnectRequested(false);
        EnsureResilienceLoopStarted();
        NotifyStateChangedIfNeeded();
 
        try
        {
            await _innerTransport.ConnectAsync(cancellationToken).ConfigureAwait(false);
            NotifyStateChangedIfNeeded();
 
            if (_queueOptions.FlushOnReconnect)
            {
                await FlushQueueAsync(cancellationToken).ConfigureAwait(false);
            }
        }
        catch
        {
            NotifyStateChangedIfNeeded();
 
            if (!_reconnectPolicy.Enabled)
            {
                throw;
            }
 
            // 자동 재접속 모드에서는 최초 연결 실패를 치명 오류로 보지 않습니다.
            // 이후 백그라운드 재접속 루프가 계속 연결을 시도합니다.
        }
    }

다음을 참조함 : _innerTransport, _queueOptions, _reconnectPolicy, EnsureResilienceLoopStarted(), FlushQueueAsync(), NotifyStateChangedIfNeeded(), SetManualDisconnectRequested(), ThrowIfDisposed().

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

DelaySafelyAsync()

async Task Dreamine.Communication.Core.Resilience.ResilientMessageTransport.DelaySafelyAsync ( TimeSpan delay, CancellationToken cancellationToken )

inlinestaticprivate

최소 양수 시간 동안 대기하고 정상적인 취소 예외를 내부에서 처리합니다.

매개변수

delay	대기할 시간입니다.
cancellationToken	대기 취소 토큰입니다.

반환값

안전한 비동기 대기 작업입니다.

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

    {
        if (delay <= TimeSpan.Zero)
        {
            delay = TimeSpan.FromMilliseconds(1);
        }
 
        try
        {
            await Task.Delay(delay, cancellationToken).ConfigureAwait(false);
        }
        catch (OperationCanceledException)
        {
            // 정상적인 종료 경로입니다.
        }
    }

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

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

DisconnectAsync()

async Task Dreamine.Communication.Core.Resilience.ResilientMessageTransport.DisconnectAsync ( CancellationToken cancellationToken = default )

inline

자동 재연결을 중지하고 내부 연결을 종료합니다.

매개변수

cancellationToken

연결 해제 취소 요청을 감시하는 토큰입니다.

반환값

비동기 연결 해제 작업입니다.

예외

ObjectDisposedException	이미 해제된 경우 발생합니다.
OperationCanceledException	작업 취소가 요청된 경우 발생할 수 있습니다.

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

    {
        ThrowIfDisposed();
 
        SetManualDisconnectRequested(true);
        SetResilienceLoopRequested(false);
        NotifyStateChangedIfNeeded();
 
        await _innerTransport.DisconnectAsync(cancellationToken).ConfigureAwait(false);
        NotifyStateChangedIfNeeded();
    }

다음을 참조함 : _innerTransport, NotifyStateChangedIfNeeded(), SetManualDisconnectRequested(), SetResilienceLoopRequested(), ThrowIfDisposed().

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

DisposeAsync()

async ValueTask Dreamine.Communication.Core.Resilience.ResilientMessageTransport.DisposeAsync ( )

inline

재연결 루프를 중지하고 내부 전송 계층과 동기화 리소스를 비동기 해제합니다.

반환값

비동기 리소스 해제 작업입니다.

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

    {
        // Interlocked guard prevents concurrent double-dispose.
        if (Interlocked.CompareExchange(ref _disposeGuard, 1, 0) != 0)
        {
            return;
        }
 
        _disposed = true;
        SetManualDisconnectRequested(true);
        SetResilienceLoopRequested(false);
 
        _innerTransport.MessageReceived -= OnInnerMessageReceived;
 
        try
        {
            await _lifetimeCts.CancelAsync().ConfigureAwait(false);
        }
        catch
        {
            // Dispose 경로에서는 취소 실패를 무시합니다.
        }
 
        if (_resilienceLoopTask is not null)
        {
            try
            {
                await _resilienceLoopTask.ConfigureAwait(false);
            }
            catch
            {
                // Dispose 경로에서는 백그라운드 루프 예외를 무시합니다.
            }
        }
 
        _lifetimeCts.Dispose();
        _flushLock.Dispose();
 
        await _innerTransport.DisposeAsync().ConfigureAwait(false);
    }

다음을 참조함 : _disposed, _disposeGuard, _flushLock, _innerTransport, _lifetimeCts, _resilienceLoopTask, OnInnerMessageReceived(), SetManualDisconnectRequested(), SetResilienceLoopRequested().

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

EnsureResilienceLoopStarted()

void Dreamine.Communication.Core.Resilience.ResilientMessageTransport.EnsureResilienceLoopStarted ( )

inlineprivate

자동 재연결이 활성화된 경우 복원 루프가 하나만 실행되도록 보장합니다.

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

    {
        if (!_reconnectPolicy.Enabled)
        {
            return;
        }
 
        lock (_loopSync)
        {
            if (_disposed)
            {
                return;
            }
 
            SetResilienceLoopRequested(true);
 
            if (_resilienceLoopTask is { IsCompleted: false })
            {
                return;
            }
 
            if (_lifetimeCts.IsCancellationRequested)
            {
                _lifetimeCts.Dispose();
                _lifetimeCts = new CancellationTokenSource();
            }
 
            _resilienceLoopTask = Task.Run(
                () => RunResilienceLoopAsync(_lifetimeCts.Token),
                CancellationToken.None);
        }
    }

다음을 참조함 : _disposed, _lifetimeCts, _loopSync, _reconnectPolicy, _resilienceLoopTask, RunResilienceLoopAsync(), SetResilienceLoopRequested().

다음에 의해서 참조됨 : ConnectAsync(), FlushQueueAsync(), SendAsync(), WaitUntilConnectedAsync().

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

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

FlushQueueAsync()

async Task Dreamine.Communication.Core.Resilience.ResilientMessageTransport.FlushQueueAsync ( CancellationToken cancellationToken = default )

inline

연결된 동안 만료되지 않은 송신 대기 메시지를 순서대로 전송합니다.

매개변수

cancellationToken

큐 전송 취소 요청을 감시하는 토큰입니다.

반환값

비동기 큐 전송 작업입니다.

예외

ObjectDisposedException	이미 해제된 경우 발생합니다.
OperationCanceledException	작업 취소가 요청된 경우 발생할 수 있습니다.

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

    {
        ThrowIfDisposed();
 
        if (!_queueOptions.FlushOnReconnect)
        {
            return;
        }
 
        await _flushLock.WaitAsync(cancellationToken).ConfigureAwait(false);
 
        try
        {
            while (IsOperationalState(_innerTransport.State))
            {
                cancellationToken.ThrowIfCancellationRequested();
 
                var queuedMessage = await _outboundQueue
                    .TryDequeueAsync(cancellationToken)
                    .ConfigureAwait(false);
 
                if (queuedMessage is null)
                {
                    NotifyQueueCountChanged();
                    NotifyStateChangedIfNeeded();
                    return;
                }
 
                NotifyQueueCountChanged();
 
                if (queuedMessage.IsExpired(
                        _queueOptions.MaxMessageAge,
                        DateTimeOffset.UtcNow))
                {
                    continue;
                }
 
                try
                {
                    await _innerTransport
                        .SendAsync(queuedMessage.Message, cancellationToken)
                        .ConfigureAwait(false);
 
                    NotifyQueueCountChanged();
                    NotifyStateChangedIfNeeded();
                }
                catch (Exception ex)
                {
                    await _outboundQueue
                        .EnqueueFrontAsync(queuedMessage.WithFailure(ex), cancellationToken)
                        .ConfigureAwait(false);
 
                    NotifyQueueCountChanged();
                    EnsureResilienceLoopStarted();
                    NotifyStateChangedIfNeeded();
                    return;
                }
            }
        }
        finally
        {
            _flushLock.Release();
        }
    }

다음을 참조함 : _flushLock, _innerTransport, _outboundQueue, _queueOptions, EnsureResilienceLoopStarted(), IsOperationalState(), NotifyQueueCountChanged(), NotifyStateChangedIfNeeded(), ThrowIfDisposed().

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

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

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

HandleDisconnectedSendAsync()

async Task Dreamine.Communication.Core.Resilience.ResilientMessageTransport.HandleDisconnectedSendAsync ( MessageEnvelope message, CancellationToken cancellationToken )

inlineprivate

연결 끊김 송신 정책에 따라 실패, 큐 저장 또는 연결 대기 후 송신을 수행합니다.

매개변수

message	처리할 송신 메시지입니다.
cancellationToken	비동기 처리 취소 토큰입니다.

반환값

정책 처리 작업입니다.

예외

InvalidOperationException

정책이 즉시 실패이거나 알 수 없는 값인 경우 발생합니다.

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

    {
        switch (_queueOptions.DisconnectedSendPolicy)
        {
            case DisconnectedSendPolicy.Fail:
                throw new InvalidOperationException("Transport is not connected.");
 
            case DisconnectedSendPolicy.Queue:
                await _outboundQueue
                    .EnqueueAsync(new QueuedOutboundMessage(message), cancellationToken)
                    .ConfigureAwait(false);
 
                NotifyQueueCountChanged();
                return;
 
            case DisconnectedSendPolicy.WaitUntilConnected:
                await WaitUntilConnectedAsync(cancellationToken).ConfigureAwait(false);
                await _innerTransport.SendAsync(message, cancellationToken).ConfigureAwait(false);
                NotifyStateChangedIfNeeded();
                return;
 
            default:
                throw new InvalidOperationException(
                    $"Unsupported disconnected send policy: {_queueOptions.DisconnectedSendPolicy}");
        }
    }

다음을 참조함 : _innerTransport, _outboundQueue, _queueOptions, NotifyQueueCountChanged(), NotifyStateChangedIfNeeded(), WaitUntilConnectedAsync().

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

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

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

IsOperationalState()

bool Dreamine.Communication.Core.Resilience.ResilientMessageTransport.IsOperationalState ( ConnectionState state )

inlinestaticprivate

지정한 상태가 메시지 송신 가능한 연결 또는 수신 대기 상태인지 확인합니다.

매개변수

state

검사할 연결 상태입니다.

반환값

동작 가능한 상태이면 true입니다.

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

    {
        return state is ConnectionState.Connected or ConnectionState.Listening;
    }

다음에 의해서 참조됨 : FlushQueueAsync(), RunResilienceLoopAsync(), SendAsync(), WaitUntilConnectedAsync().

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

NotifyQueueCountChanged()

void Dreamine.Communication.Core.Resilience.ResilientMessageTransport.NotifyQueueCountChanged ( )

inlineprivate

현재 송신 큐 개수로 큐 변경 이벤트를 발생시킵니다.

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

    {
        QueueCountChanged?.Invoke(this, _outboundQueue.Count);
    }

다음을 참조함 : _outboundQueue, QueueCountChanged.

다음에 의해서 참조됨 : FlushQueueAsync(), HandleDisconnectedSendAsync().

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

NotifyStateChangedIfNeeded()

void Dreamine.Communication.Core.Resilience.ResilientMessageTransport.NotifyStateChangedIfNeeded ( )

inlineprivate

마지막 알림 이후 유효 연결 상태가 바뀐 경우에만 상태 변경 이벤트를 발생시킵니다.

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

    {
        var currentState = State;
        EventHandler<ConnectionState>? handler;
 
        lock (_notifySync)
        {
            if (_lastNotifiedState == currentState)
            {
                return;
            }
 
            _lastNotifiedState = currentState;
            handler = StateChanged;
        }
 
        handler?.Invoke(this, currentState);
    }

다음을 참조함 : _lastNotifiedState, _notifySync, State, StateChanged.

다음에 의해서 참조됨 : ConnectAsync(), DisconnectAsync(), FlushQueueAsync(), HandleDisconnectedSendAsync(), RunResilienceLoopAsync(), SendAsync(), WaitUntilConnectedAsync().

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

OnInnerMessageReceived()

void Dreamine.Communication.Core.Resilience.ResilientMessageTransport.OnInnerMessageReceived ( object? sender, MessageEnvelope message )

inlineprivate

내부 수신 이벤트를 현재 전송 계층의 수신 이벤트로 다시 발생시킵니다.

매개변수

sender	내부 이벤트 발생 객체이며 사용하지 않습니다.
message	수신한 메시지입니다.

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

    {
        MessageReceived?.Invoke(this, message);
    }

다음을 참조함 : MessageReceived.

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

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

RunResilienceLoopAsync()

async Task Dreamine.Communication.Core.Resilience.ResilientMessageTransport.RunResilienceLoopAsync ( CancellationToken cancellationToken )

inlineprivate

연결 감시, 재연결 백오프 및 큐 전송을 수행하는 백그라운드 루프를 실행합니다.

매개변수

cancellationToken

루프 종료를 요청하는 토큰입니다.

반환값

복원 루프 작업입니다.

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

    {
        var reconnectAttempt = 0;
 
        while (!cancellationToken.IsCancellationRequested)
        {
            NotifyStateChangedIfNeeded();
 
            if (IsManualDisconnectRequested)
            {
                await DelaySafelyAsync(
                    _reconnectPolicy.WatchInterval,
                    cancellationToken)
                    .ConfigureAwait(false);
 
                continue;
            }
 
            if (IsOperationalState(_innerTransport.State))
            {
                reconnectAttempt = 0;
                NotifyStateChangedIfNeeded();
 
                if (_queueOptions.FlushOnReconnect && _outboundQueue.Count > 0)
                {
                    await FlushQueueAsync(cancellationToken).ConfigureAwait(false);
                }
 
                await DelaySafelyAsync(
                    _reconnectPolicy.WatchInterval,
                    cancellationToken)
                    .ConfigureAwait(false);
 
                continue;
            }
 
            if (_innerTransport.State == ConnectionState.Disconnecting)
            {
                await DelaySafelyAsync(
                    _reconnectPolicy.WatchInterval,
                    cancellationToken)
                    .ConfigureAwait(false);
 
                continue;
            }
 
            if (_reconnectPolicy.MaxRetryCount is not null &&
                reconnectAttempt >= _reconnectPolicy.MaxRetryCount.Value)
            {
                await DelaySafelyAsync(
                    _reconnectPolicy.MaxDelay,
                    cancellationToken)
                    .ConfigureAwait(false);
 
                continue;
            }
 
            reconnectAttempt++;
            NotifyStateChangedIfNeeded();
 
            try
            {
                await _innerTransport.ConnectAsync(cancellationToken).ConfigureAwait(false);
                reconnectAttempt = 0;
                NotifyStateChangedIfNeeded();
 
                if (_queueOptions.FlushOnReconnect)
                {
                    await FlushQueueAsync(cancellationToken).ConfigureAwait(false);
                }
            }
            catch
            {
                NotifyStateChangedIfNeeded();
 
                var delay = _delayCalculator.Calculate(reconnectAttempt);
 
                await DelaySafelyAsync(delay, cancellationToken)
                    .ConfigureAwait(false);
            }
        }
    }

다음을 참조함 : _delayCalculator, _innerTransport, _outboundQueue, _queueOptions, _reconnectPolicy, DelaySafelyAsync(), FlushQueueAsync(), IsManualDisconnectRequested, IsOperationalState(), NotifyStateChangedIfNeeded().

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

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

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

SendAsync()

async Task Dreamine.Communication.Core.Resilience.ResilientMessageTransport.SendAsync ( MessageEnvelope message, CancellationToken cancellationToken = default )

inline

연결 상태와 끊김 송신 정책에 따라 즉시 전송하거나 큐에 저장합니다.

매개변수

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

반환값

비동기 송신 또는 큐 저장 작업입니다.

예외

ArgumentNullException	message 가 null인 경우 발생합니다.
InvalidOperationException	연결 끊김 정책이 즉시 실패이거나 지원하지 않는 경우 발생합니다.
ObjectDisposedException	이미 해제된 경우 발생합니다.
OperationCanceledException	작업 취소가 요청된 경우 발생할 수 있습니다.

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

    {
        ArgumentNullException.ThrowIfNull(message);
        ThrowIfDisposed();
 
        SetManualDisconnectRequested(false);
 
        if (IsOperationalState(_innerTransport.State))
        {
            try
            {
                await _innerTransport.SendAsync(message, cancellationToken).ConfigureAwait(false);
                NotifyStateChangedIfNeeded();
                return;
            }
            catch
            {
                await HandleDisconnectedSendAsync(message, cancellationToken).ConfigureAwait(false);
                EnsureResilienceLoopStarted();
                NotifyStateChangedIfNeeded();
                return;
            }
        }
 
        await HandleDisconnectedSendAsync(message, cancellationToken).ConfigureAwait(false);
        EnsureResilienceLoopStarted();
        NotifyStateChangedIfNeeded();
    }

다음을 참조함 : _innerTransport, EnsureResilienceLoopStarted(), HandleDisconnectedSendAsync(), IsOperationalState(), NotifyStateChangedIfNeeded(), SetManualDisconnectRequested(), ThrowIfDisposed().

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

SetManualDisconnectRequested()

void Dreamine.Communication.Core.Resilience.ResilientMessageTransport.SetManualDisconnectRequested ( bool value )

inlineprivate

수동 연결 해제 요청 플래그를 스레드 안전하게 설정합니다.

매개변수

value

설정할 플래그 값입니다.

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

    {
        Interlocked.Exchange(ref _manualDisconnectRequested, value ? 1 : 0);
    }

다음을 참조함 : _manualDisconnectRequested.

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

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

SetResilienceLoopRequested()

void Dreamine.Communication.Core.Resilience.ResilientMessageTransport.SetResilienceLoopRequested ( bool value )

inlineprivate

복원 루프 실행 요청 플래그를 스레드 안전하게 설정합니다.

매개변수

value

설정할 플래그 값입니다.

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

    {
        Interlocked.Exchange(ref _resilienceLoopRequested, value ? 1 : 0);
    }

다음을 참조함 : _resilienceLoopRequested.

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

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

ThrowIfDisposed()

void Dreamine.Communication.Core.Resilience.ResilientMessageTransport.ThrowIfDisposed ( )

inlineprivate

전송 계층이 이미 해제되었으면 예외를 발생시킵니다.

예외

ObjectDisposedException

인스턴스가 해제된 경우 발생합니다.

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

    {
        ObjectDisposedException.ThrowIf(_disposed, this);
    }

다음을 참조함 : _disposed.

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

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

WaitUntilConnectedAsync()

async Task Dreamine.Communication.Core.Resilience.ResilientMessageTransport.WaitUntilConnectedAsync ( CancellationToken cancellationToken )

inlineprivate

복원 루프를 시작하고 내부 전송 계층이 연결될 때까지 비동기 대기합니다.

매개변수

cancellationToken

대기 취소 토큰입니다.

반환값

연결 대기 작업입니다.

예외

OperationCanceledException

취소가 요청된 경우 발생합니다.

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

    {
        EnsureResilienceLoopStarted();
        NotifyStateChangedIfNeeded();
 
        while (!IsOperationalState(_innerTransport.State))
        {
            cancellationToken.ThrowIfCancellationRequested();
            await Task.Delay(_reconnectPolicy.WatchInterval, cancellationToken)
                .ConfigureAwait(false);
        }
    }

다음을 참조함 : _innerTransport, _reconnectPolicy, EnsureResilienceLoopStarted(), IsOperationalState(), NotifyStateChangedIfNeeded().

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

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

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

멤버 데이터 문서화

_delayCalculator

readonly ReconnectDelayCalculator Dreamine.Communication.Core.Resilience.ResilientMessageTransport._delayCalculator

private

delay Calculator 값을 보관합니다.

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

다음에 의해서 참조됨 : ResilientMessageTransport(), RunResilienceLoopAsync().

_disposed

bool Dreamine.Communication.Core.Resilience.ResilientMessageTransport._disposed

private

disposed 값을 보관합니다.

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

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

_disposeGuard

int Dreamine.Communication.Core.Resilience.ResilientMessageTransport._disposeGuard

private

dispose Guard 값을 보관합니다.

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

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

_flushLock

readonly SemaphoreSlim Dreamine.Communication.Core.Resilience.ResilientMessageTransport._flushLock = new(1, 1)

private

flush Lock 값을 보관합니다.

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

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

_innerTransport

readonly IMessageTransport Dreamine.Communication.Core.Resilience.ResilientMessageTransport._innerTransport

private

inner Transport 값을 보관합니다.

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

다음에 의해서 참조됨 : ConnectAsync(), DisconnectAsync(), DisposeAsync(), FlushQueueAsync(), HandleDisconnectedSendAsync(), ResilientMessageTransport(), RunResilienceLoopAsync(), SendAsync(), WaitUntilConnectedAsync().

_lastNotifiedState

ConnectionState Dreamine.Communication.Core.Resilience.ResilientMessageTransport._lastNotifiedState = ConnectionState.Disconnected

private

last Notified State 값을 보관합니다.

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

다음에 의해서 참조됨 : NotifyStateChangedIfNeeded(), ResilientMessageTransport().

_lifetimeCts

CancellationTokenSource Dreamine.Communication.Core.Resilience.ResilientMessageTransport._lifetimeCts = new()

private

lifetime Cts 값을 보관합니다.

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

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

_loopSync

readonly object Dreamine.Communication.Core.Resilience.ResilientMessageTransport._loopSync = new()

private

loop Sync 값을 보관합니다.

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

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

_manualDisconnectRequested

int Dreamine.Communication.Core.Resilience.ResilientMessageTransport._manualDisconnectRequested = 1

private

manual Disconnect Requested 값을 보관합니다.

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

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

_notifySync

readonly object Dreamine.Communication.Core.Resilience.ResilientMessageTransport._notifySync = new()

private

notify Sync 값을 보관합니다.

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

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

_outboundQueue

readonly IOutboundMessageQueue Dreamine.Communication.Core.Resilience.ResilientMessageTransport._outboundQueue

private

outbound Queue 값을 보관합니다.

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

다음에 의해서 참조됨 : FlushQueueAsync(), HandleDisconnectedSendAsync(), NotifyQueueCountChanged(), ResilientMessageTransport(), RunResilienceLoopAsync().

_queueOptions

readonly OutboundQueueOptions Dreamine.Communication.Core.Resilience.ResilientMessageTransport._queueOptions

private

queue Options 값을 보관합니다.

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

다음에 의해서 참조됨 : ConnectAsync(), FlushQueueAsync(), HandleDisconnectedSendAsync(), ResilientMessageTransport(), RunResilienceLoopAsync().

_reconnectPolicy

readonly ReconnectPolicy Dreamine.Communication.Core.Resilience.ResilientMessageTransport._reconnectPolicy

private

reconnect Policy 값을 보관합니다.

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

다음에 의해서 참조됨 : ConnectAsync(), EnsureResilienceLoopStarted(), ResilientMessageTransport(), RunResilienceLoopAsync(), WaitUntilConnectedAsync().

_resilienceLoopRequested

int Dreamine.Communication.Core.Resilience.ResilientMessageTransport._resilienceLoopRequested

private

resilience Loop Requested 값을 보관합니다.

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

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

_resilienceLoopTask

Task? Dreamine.Communication.Core.Resilience.ResilientMessageTransport._resilienceLoopTask

private

resilience Loop Task 값을 보관합니다.

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

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

속성 문서화

IsManualDisconnectRequested

bool Dreamine.Communication.Core.Resilience.ResilientMessageTransport.IsManualDisconnectRequested

getprivate

호출자가 수동 연결 해제를 요청했는지 스레드 안전하게 확인합니다.

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

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

IsResilienceLoopRequested

bool Dreamine.Communication.Core.Resilience.ResilientMessageTransport.IsResilienceLoopRequested

getprivate

연결 복원 루프 실행이 요청되었는지 스레드 안전하게 확인합니다.

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

Kind

TransportKind Dreamine.Communication.Core.Resilience.ResilientMessageTransport.Kind

get

내부 전송 계층의 전송 방식을 가져옵니다.

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

QueuedMessageCount

int Dreamine.Communication.Core.Resilience.ResilientMessageTransport.QueuedMessageCount

get

현재 송신 대기 큐에 저장된 메시지 수를 가져옵니다.

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

State

ConnectionState Dreamine.Communication.Core.Resilience.ResilientMessageTransport.State

get

내부 상태와 재연결 루프를 반영한 현재 유효 연결 상태를 가져옵니다.

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

    {
        get
        {
            if (IsOperationalState(_innerTransport.State))
            {
                return _innerTransport.State;
            }
 
            if (_reconnectPolicy.Enabled &&
                !IsManualDisconnectRequested &&
                IsResilienceLoopRequested)
            {
                return ConnectionState.Connecting;
            }
 
            return _innerTransport.State;
        }
    }

다음에 의해서 참조됨 : NotifyStateChangedIfNeeded(), ResilientMessageTransport().

이벤트 문서화

MessageReceived

EventHandler<MessageEnvelope>? Dreamine.Communication.Core.Resilience.ResilientMessageTransport.MessageReceived

내부 전송 계층이 메시지를 수신했을 때 발생합니다.

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

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

QueueCountChanged

EventHandler<int>? Dreamine.Communication.Core.Resilience.ResilientMessageTransport.QueueCountChanged

송신 대기 큐의 메시지 수가 변경될 때 발생합니다.

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

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

StateChanged

EventHandler<ConnectionState>? Dreamine.Communication.Core.Resilience.ResilientMessageTransport.StateChanged

복원 동작을 반영한 유효 연결 상태가 변경될 때 발생합니다.

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

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

---

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

• ResilientMessageTransport.cs