WebSocket 기반 실시간 상호작용을 관리하는 게임 인스턴스 서브시스템입니다. 더 자세히 ...

#include <UWebSocketSystem.h>

UWebSocketSystem에 대한 상속 다이어그램 :

UWebSocketSystem에 대한 협력 다이어그램:

Public 멤버 함수
void	Connect ()
	WebSocket 서버와 연결을 수립합니다.

	DEFINE_SUBSYSTEM_GETTER_INLINE (UWebSocketSystem)

void	Disconnect ()
	활성화된 WebSocket 연결을 종료합니다.

bool	IsConnected () const
	현재 WebSocket 연결 상태를 조회합니다.

void	SendPing ()
	연결 상태 유지를 위해 Ping 메시지를 전송합니다.

Private 멤버 함수
virtual void	Deinitialize () override

virtual void	Initialize (FSubsystemCollectionBase &Collection) override

void	OnBinaryMessage_Native (const void *Data, SIZE_T Size, bool bIsLastFragment)
	바이너리 메시지를 수신했을 때 호출됩니다.

void	OnClosed_Native (int32 StatusCode, const FString &Reason, bool bWasClean)
	연결 종료 이벤트를 처리합니다.

void	OnConnected_Native ()
	WebSocket 연결 완료 콜백입니다.

void	OnConnectionError_Native (const FString &InErrorMessage)
	연결 오류 발생 시 호출되는 콜백입니다.

void	OnMessage_Native (const FString &InMessage)
	텍스트 메시지를 수신했을 때 호출됩니다.

정적 Private 멤버 함수
static void	LogNetwork (const FString &Message)
	WebSocket 관련 공통 로그 메시지를 출력합니다.

Private 속성
bool	bIsExpectingAudio = false
	서버에서 오디오 스트림 시작을 예상하는지 여부입니다.

TSharedPtr< IWebSocket >	WebSocket
	활성 WebSocket 인스턴스입니다.

상세한 설명

WebSocket 기반 실시간 상호작용을 관리하는 게임 인스턴스 서브시스템입니다.

텍스트 및 오디오 스트림을 위한 지속 연결을 유지하며 연결 상태를 게임 전역에서 공유합니다. 연결 수명은 GameInstance와 동일하며, 네트워크 교체나 종료 시 명시적으로 정리합니다. 사용 위치: 음성 대화/실시간 피드백 시스템에서 공통 연결 관리.

UWebSocketSystem.h 파일의 23 번째 라인에서 정의되었습니다.

멤버 함수 문서화

◆ Connect()

void UWebSocketSystem::Connect ( )

WebSocket 서버와 연결을 수립합니다.

기존 연결이 없을 때만 새 연결을 시도하며 비동기 연결 이벤트를 발생시킵니다. 사이드이펙트: 내부 WebSocket 인스턴스를 생성하고 연결 상태를 변경합니다.

UWebSocketSystem.cpp 파일의 43 번째 라인에서 정의되었습니다.

{
    if (IsConnected())
    {
        LogNetwork(TEXT("Already connected."));
        return;
    }
 
    const FString Url = NetworkConfig::GetSocketURL();
    if (Url.IsEmpty())
    {
        LogNetwork(TEXT("WebSocket URL is empty. Please check your configuration in DefaultMyNetwork.ini."));
        return;
    }
 
    LogNetwork(FString::Printf(TEXT("Connecting to %s"), *Url));
 
    FWebSocketsModule& WebSocketModule = FModuleManager::LoadModuleChecked<FWebSocketsModule>(TEXT("WebSockets"));
    WebSocket = WebSocketModule.CreateWebSocket(Url, TEXT("ws"));
 
    // Bind native delegates
    WebSocket->OnConnected().AddUObject(this, &UWebSocketSystem::OnConnected_Native);
    WebSocket->OnConnectionError().AddUObject(this, &UWebSocketSystem::OnConnectionError_Native);
    WebSocket->OnClosed().AddUObject(this, &UWebSocketSystem::OnClosed_Native);
    WebSocket->OnMessage().AddUObject(this, &UWebSocketSystem::OnMessage_Native);
    WebSocket->OnBinaryMessage().AddUObject(this, &UWebSocketSystem::OnBinaryMessage_Native);
 
    WebSocket->Connect();
}

다음을 참조함 : NetworkConfig::GetSocketURL(), IsConnected(), LogNetwork(), OnBinaryMessage_Native(), OnClosed_Native(), OnConnected_Native(), OnConnectionError_Native(), OnMessage_Native(), WebSocket.

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

◆ DEFINE_SUBSYSTEM_GETTER_INLINE()

UWebSocketSystem::DEFINE_SUBSYSTEM_GETTER_INLINE ( UWebSocketSystem )

◆ Deinitialize()

void UWebSocketSystem::Deinitialize ( )

overrideprivatevirtual

UWebSocketSystem.cpp 파일의 22 번째 라인에서 정의되었습니다.

{
    if (WebSocket.IsValid())
    {
        // Unbind all delegates
        WebSocket->OnConnected().RemoveAll(this);
        WebSocket->OnConnectionError().RemoveAll(this);
        WebSocket->OnClosed().RemoveAll(this);
        WebSocket->OnMessage().RemoveAll(this);
        WebSocket->OnBinaryMessage().RemoveAll(this);
 
        if (WebSocket->IsConnected())
        {
            WebSocket->Close();
        }
    }
    Super::Deinitialize();
}

다음을 참조함 : WebSocket.

◆ Disconnect()

void UWebSocketSystem::Disconnect ( )

활성화된 WebSocket 연결을 종료합니다.

연결 종료 후 관련 콜백이 호출되며 내부 상태를 초기화합니다. 사이드이펙트: 네트워크 연결을 끊고 내부 연결 상태를 변경합니다.

UWebSocketSystem.cpp 파일의 73 번째 라인에서 정의되었습니다.

{
    if (WebSocket.IsValid() && WebSocket->IsConnected())
    {
        LogNetwork(TEXT("Disconnecting..."));
        WebSocket->Close();
    }
}

다음을 참조함 : LogNetwork(), WebSocket.

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

◆ Initialize()

void UWebSocketSystem::Initialize ( FSubsystemCollectionBase & Collection )

overrideprivatevirtual

UWebSocketSystem.cpp 파일의 16 번째 라인에서 정의되었습니다.

{
    Super::Initialize(Collection);
    bIsExpectingAudio = false;
}

다음을 참조함 : bIsExpectingAudio.

◆ IsConnected()

bool UWebSocketSystem::IsConnected ( ) const

현재 WebSocket 연결 상태를 조회합니다.

로컬 상태만 조회하며 네트워크 요청을 발생시키지 않습니다.

반환값: 연결되어 있으면 true입니다.

UWebSocketSystem.cpp 파일의 82 번째 라인에서 정의되었습니다.

{
    return WebSocket.IsValid() && WebSocket->IsConnected();
}

다음을 참조함 : WebSocket.

다음에 의해서 참조됨 : Connect(), SendPing().

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

◆ LogNetwork()

void UWebSocketSystem::LogNetwork ( const FString & Message )

staticprivate

WebSocket 관련 공통 로그 메시지를 출력합니다.

UWebSocketSystem.cpp 파일의 173 번째 라인에서 정의되었습니다.

{
    NETWORK_LOG(TEXT("[WS] %s"), *Message);
}

다음을 참조함 : NETWORK_LOG.

다음에 의해서 참조됨 : Connect(), Disconnect(), OnBinaryMessage_Native(), OnClosed_Native(), OnConnected_Native(), OnConnectionError_Native(), OnMessage_Native(), SendPing().

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

◆ OnBinaryMessage_Native()

void UWebSocketSystem::OnBinaryMessage_Native	(	const void *	Data,
		SIZE_T	Size,
		bool	bIsLastFragment
	)

private

바이너리 메시지를 수신했을 때 호출됩니다.

매개변수

Data	[in] 수신 버퍼 시작 주소입니다.
Size	[in] 버퍼 크기입니다.
bIsLastFragment	[in] 해당 프레임이 마지막 조각인지 여부입니다.

UWebSocketSystem.cpp 파일의 165 번째 라인에서 정의되었습니다.

{
    LogNetwork(FString::Printf(TEXT("Received binary message (%d bytes) - Currently not supported"), Size));
    // 바이너리 메시지는 현재 사용하지 않음 (모든 오디오는 JSON의 Base64로 전송됨)
}

다음을 참조함 : LogNetwork().

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

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

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

◆ OnClosed_Native()

void UWebSocketSystem::OnClosed_Native	(	int32	StatusCode,
		const FString &	Reason,
		bool	bWasClean
	)

private

연결 종료 이벤트를 처리합니다.

매개변수

StatusCode	[in] WebSocket 상태 코드입니다.
Reason	[in] 종료 사유입니다.
bWasClean	[in] 정상 종료 여부입니다.

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

{
    LogNetwork(FString::Printf(TEXT("Connection closed. Code: %d, Reason: %s, Clean: %s"), StatusCode, *Reason, bWasClean ? TEXT("true") : TEXT("false")));
    bIsExpectingAudio = false;
    // OnClosed.Broadcast(StatusCode, Reason, bWasClean);
}

다음을 참조함 : bIsExpectingAudio, LogNetwork().

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

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

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

◆ OnConnected_Native()

void UWebSocketSystem::OnConnected_Native ( )

private

WebSocket 연결 완료 콜백입니다.

UWebSocketSystem.cpp 파일의 101 번째 라인에서 정의되었습니다.

{
    LogNetwork(TEXT("Connection successful."));
    bIsExpectingAudio = false;
    // OnConnected.Broadcast();
}

다음을 참조함 : bIsExpectingAudio, LogNetwork().

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

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

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

◆ OnConnectionError_Native()

void UWebSocketSystem::OnConnectionError_Native ( const FString & InErrorMessage )

private

연결 오류 발생 시 호출되는 콜백입니다.

매개변수

InErrorMessage [in] 서버에서 전달된 에러 메시지입니다.

UWebSocketSystem.cpp 파일의 108 번째 라인에서 정의되었습니다.

{
    LogNetwork(FString::Printf(TEXT("Connection failed: %s"), *InErrorMessage));
    // OnConnectionError.Broadcast(InErrorMessage);
}

다음을 참조함 : LogNetwork().

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

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

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

◆ OnMessage_Native()

void UWebSocketSystem::OnMessage_Native ( const FString & InMessage )

private

텍스트 메시지를 수신했을 때 호출됩니다.

매개변수

InMessage [in] 서버에서 전달한 JSON/문자열입니다.

UWebSocketSystem.cpp 파일의 121 번째 라인에서 정의되었습니다.

{
    TSharedPtr<FJsonObject> JsonObject;
    TSharedRef<TJsonReader<>> Reader = TJsonReaderFactory<>::Create(InMessage);
 
    if (!FJsonSerializer::Deserialize(Reader, JsonObject) || !JsonObject.IsValid())
    {
        LogNetwork(FString::Printf(TEXT("Failed to parse incoming JSON message: %s"), *InMessage));
        return;
    }
 
    FString MessageType;
    if (!JsonObject->TryGetStringField(TEXT("type"), MessageType))
    {
        LogNetwork(FString::Printf(TEXT("Incoming JSON has no 'type' field: %s"), *InMessage));
        return;
    }
 
    if (MessageType == TEXT("pong"))
    {
        LogNetwork(TEXT("Received Pong"));
    }
    else if (MessageType == TEXT("error"))
    {
        LogNetwork(FString::Printf(TEXT("Received message: %s"), *InMessage));
        
        FString ErrorMessage;
        if (JsonObject->TryGetStringField(TEXT("message"), ErrorMessage))
        {
            LogNetwork(FString::Printf(TEXT("Server Error: %s"), *ErrorMessage));
            // OnSocketError.Broadcast(ErrorMessage);
        }
        else
        {
            LogNetwork(TEXT("Server Error: (no message field)"));
            // OnSocketError.Broadcast(TEXT("Unknown server error"));
        }
    }
    else
    {
        LogNetwork(FString::Printf(TEXT("Unknown message type received: %s"), *MessageType));
    }
}

다음을 참조함 : LogNetwork().

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

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

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

◆ SendPing()

void UWebSocketSystem::SendPing ( )

연결 상태 유지를 위해 Ping 메시지를 전송합니다.

서버의 연결 유지 정책에 따라 주기적으로 호출될 수 있습니다. 사이드이펙트: 네트워크로 Ping 프레임을 송신합니다.

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

{
    if (!IsConnected())
    {
        LogNetwork(TEXT("Cannot send ping. Not connected."));
        return;
    }
    
    LogNetwork(TEXT("Sending Ping"));
    WebSocket->Send(TEXT("{\"type\":\"ping\"}"));
}

다음을 참조함 : IsConnected(), LogNetwork(), WebSocket.

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

멤버 데이터 문서화

◆ bIsExpectingAudio

bool UWebSocketSystem::bIsExpectingAudio = false

private

서버에서 오디오 스트림 시작을 예상하는지 여부입니다.

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

다음에 의해서 참조됨 : Initialize(), OnClosed_Native(), OnConnected_Native().

◆ WebSocket

TSharedPtr<IWebSocket> UWebSocketSystem::WebSocket

private

활성 WebSocket 인스턴스입니다.

UWebSocketSystem.h 파일의 93 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : Connect(), Deinitialize(), Disconnect(), IsConnected(), SendPing().

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

Source/Onepiece/Network/Public/UWebSocketSystem.h
Source/Onepiece/Network/Private/UWebSocketSystem.cpp

Public 멤버 함수

Private 멤버 함수

정적 Private 멤버 함수

Private 속성

상세한 설명

멤버 함수 문서화

◆ Connect()

◆ DEFINE_SUBSYSTEM_GETTER_INLINE()

◆ Deinitialize()

◆ Disconnect()

◆ Initialize()

◆ IsConnected()

◆ LogNetwork()

◆ OnBinaryMessage_Native()

◆ OnClosed_Native()

◆ OnConnected_Native()

◆ OnConnectionError_Native()

◆ OnMessage_Native()

◆ SendPing()

멤버 데이터 문서화

◆ bIsExpectingAudio

◆ WebSocket