unreal UDP模块

// Fill out your copyright notice in the Description page of Project Settings. #include "UDPHandle.h" #include "UDPCommunication.h" #include "Common/UdpSocketBuilder.h" #include "Common/UdpSocketReceiver.h" #include "Common/UdpSocketSender.h" UUDPHandle::UUDPHandle() { } void UUDPHandle::CreateSocket(FUDPSocketSettings const& Settings, bool DeleteBefore) { if(DeleteBefore) { CloseSocket(); } FIPv4Address IPv4Address; if(FIPv4Address::Parse(Settings.BindIP, IPv4Address) == false) { UE_LOG(LogUDPCommunication, Error, TEXT("InitSocket IPv4 Parse Error! ")); return; } Socket = FUdpSocketBuilder(Settings.UDPName) .AsReusable() .AsNonBlocking() .BoundToEndpoint(FIPv4Endpoint(IPv4Address, Settings.BindPort)) .WithSendBufferSize(Settings.BufferSize) .WithReceiveBufferSize(Settings.BufferSize); SocketSender = new FUdpSocketSender(Socket, *(Settings.UDPName + "_Sender")); SocketReceiver = new FUdpSocketReceiver(Socket, FTimespan::FromMilliseconds(100), *(Settings.UDPName + "_Receiver")); if(SocketReceiver) { SocketReceiver->OnDataReceived().BindLambda([this](const FArrayReaderPtr& DataPtr, const FIPv4Endpoint& Endpoint) { TArray<uint8> Data; Data.AddUninitialized(DataPtr->TotalSize()); DataPtr->Serialize(Data.GetData(), DataPtr->TotalSize()); FString IP = Endpoint.Address.ToString(); int32 Port = Endpoint.Port; AsyncTask(ENamedThreads::GameThread, [this, Data, IP, Port]() { UDPRecv.Broadcast(Data, IP, Port); }); }); SocketReceiver->Start(); } } void UUDPHandle::CloseSocket() { if(SocketSender) { delete SocketSender; SocketSender = nullptr; } if(SocketReceiver) { delete SocketReceiver; SocketReceiver = nullptr; } if(Socket) { ISocketSubsystem::Get(PLATFORM_SOCKETSUBSYSTEM)->DestroySocket(Socket); Socket = nullptr; } } void UUDPHandle::SendData(const TArray<uint8>& Data, FString const& IP, int32 const& Port) const { if(SocketSender) { const TSharedRef<TArray<uint8>, ESPMode::ThreadSafe> Sender = MakeShared<TArray<uint8>, ESPMode::ThreadSafe>(Data); FIPv4Endpoint Endpoint; FIPv4Endpoint::Parse(IP + ":" + FString::FromInt(Port), Endpoint); SocketSender->Send(Sender, Endpoint); } }