UE4 TCP连接 客户端 服务器 C++项目实例

#include "TCPBase.h" void UTCPBase::SendMessage(const FString& Message) { if (Message.IsEmpty())return; for (auto& Socket : SocketArray) { FString Msg = Message; TCHAR* MessageChar = Msg.GetCharArray().GetData(); int32 size = FCString::Strlen(MessageChar) + 1; int32 sent = 0; if (Socket->Send((uint8*)TCHAR_TO_UTF8(MessageChar), size, sent)) { UE_LOG(LogTemp, Warning, TEXT("SendMessage Success!")); } else { UE_LOG(LogTemp, Error, TEXT("SendMessage Failed!")); } } } void UTCPBase::RecvMessage_Implementation(const FString& Message) { //Handle In Blueprint } void UTCPBase::BeginDestroy() { Super::BeginDestroy(); CloseOwnerSocket(); } void UTCPBase::StartSocket(FSocket* ConnectSocket) { auto object = new FAutoDeleteAsyncTask<AutoDeleteSimpleAsyncTask>(ConnectSocket, this); object->StartBackgroundTask(); SocketArray.Emplace(ConnectSocket); } void UTCPBase::CloseSocket(FSocket* ConnectSocket) { if (ConnectSocket) { SocketArray.Remove(ConnectSocket); ConnectSocket->Close(); ISocketSubsystem::Get(PLATFORM_SOCKETSUBSYSTEM)->DestroySocket(ConnectSocket); } } void UTCPBase::CloseAllSocket() { if (SocketArray.Num() > 0) { for (auto& it : SocketArray) { if (it) { it->Close(); ISocketSubsystem::Get(PLATFORM_SOCKETSUBSYSTEM)->DestroySocket(it); } } SocketArray.Empty(); } } void UTCPBase::CloseOwnerSocket() { CloseAllSocket(); } void UTCPBase::SendJson() { TSharedPtr<FJsonObject> JsonObject = MakeShareable(new FJsonObject); JsonObject->SetStringField("name", "jock"); JsonObject->SetNumberField("damage", 20); JsonObject->SetBoolField("isme", true); FString Message; TSharedRef<TJsonWriter<>> Writer = TJsonWriterFactory<>::Create(&Message); FJsonSerializer::Serialize(JsonObject.ToSharedRef(), Writer); SendMessage(Message); } void AutoDeleteSimpleAsyncTask::DoWork() { TArray<uint8> ReceiveData; uint32 Size = 0; while (ConnectSocket && ConnectSocket->GetConnectionState() == SCS_Connected) { if (ConnectSocket->HasPendingData(Size)) { Size = FMath::Min<int32>(Size + 1, DATASIZE); ReceiveData.Empty(); ReceiveData.Init(0, Size); int32 Readed; ConnectSocket->Recv(ReceiveData.GetData(), Size, Readed); Owner->RecvMessage(FString(UTF8_TO_TCHAR(reinterpret_cast<const char*>(ReceiveData.GetData())))); } } ConnectSocket = nullptr; Owner = nullptr; }