在配置文件加上Networking。

使用socket加以上頭文件

并加上ISocketSubsystem的頭文件

?通過傳過來的IP與端口號進(jìn)行一個(gè)綁定，第一行就是將BindIP分割然后分別放進(jìn)ip的四個(gè)值內(nèi)（A,B,C,D），然后創(chuàng)建一個(gè)FInternetAddr類型的智能指針，將ip的值與外界傳來的端口號對FInternetAddr進(jìn)行一個(gè)初始化賦值，最后對讓socket對地址進(jìn)行一個(gè)綁定。

服務(wù)器進(jìn)行一個(gè)監(jiān)聽，看客戶端是否發(fā)出消息讓服務(wù)器進(jìn)行接收

?

?對消息進(jìn)行接收

客戶端發(fā)送消息，先將要發(fā)送的字符串進(jìn)行char的轉(zhuǎn)化。

然后對處理后的數(shù)據(jù)發(fā)送到指定地址

FSocket::HasPendingData將返回一個(gè)值，通知您是否
從套接字讀取是安全的。文章來源地址http://www.zghlxwxcb.cn/news/detail-618033.html

// Fill out your copyright notice in the Description page of Project Settings.

#pragma once

#include "CoreMinimal.h"
#include "GameFramework/Actor.h"
#include "Networking/Public/Interfaces/IPv4/IPv4Address.h"
#include "ServerSocket.generated.h"

UCLASS()
class MYCTEST_API AServerSocket : public AActor
{
	GENERATED_BODY()
	
public:	
	// Sets default values for this actor's properties
	AServerSocket();

	FSocket* ServerSocket;
	FSocket* ClientSocket;

	FTimerHandle SocketTimerHandle;

	FIPv4Address ip;

	FVector currentLoc;

	float SocketDelta;

protected:
	// Called when the game starts or when spawned
	virtual void BeginPlay() override;

public:	
	// Called every frame
	virtual void Tick(float DeltaTime) override;

	virtual void EndPlay(const EEndPlayReason::Type EEndPlayReason);

	bool CreateSocket();

	//Bind創(chuàng)建的Socket 需要ip和port
	bool BindSocket(const FString& BindIP, const int32 BindPort);

	//監(jiān)聽Socket
	bool ListenSocket(int32 MaxConnectionNum);

	//Accept Client
	bool AcceptSocket();

	//收發(fā)消息
	bool sendMsg(const FString& Msg);

	FString RecvMsg();

	//轉(zhuǎn)換函數(shù)
	FString StringFromBinaryArray(const TArray<uint8>& BinaryArray) {
		return FString(ANSI_TO_TCHAR(reinterpret_cast<const char*>(BinaryArray.GetData())));
	}

	UFUNCTION(BlueprintCallable)
	void Test(const FString &BindIP, const int32 Port, const int32 MaxListener);

	void HandleFunc();
};

// Fill out your copyright notice in the Description page of Project Settings.


#include "ServerSocket.h"
#include "SocketSubsystem.h"
#include "Sockets.h"
#include "Engine/World.h"
#include "TimerManager.h"
#include "Kismet/KismetStringLibrary.h"
#include "UObject/ConstructorHelpers.h"
#include "Components/StaticMeshComponent.h"
#include "Engine/StaticMesh.h"

// Sets default values
// Called when the game starts or when spawned

#define SPHERE_PATH TEXT("/Game/StarterContent/Shapes/Shape_Sphere")

AServerSocket::AServerSocket()
{
	// Set this actor to call Tick() every frame.  You can turn this off to improve performance if you don't need it.
	PrimaryActorTick.bCanEverTick = true;

	currentLoc = FVector(0.f, 0.f, 0.f);
	UStaticMeshComponent* staticMeshComponent = CreateDefaultSubobject<UStaticMeshComponent>(TEXT("Mesh"));
	struct FContructor {
		ConstructorHelpers::FObjectFinderOptional<UStaticMesh> Mesh;
		FContructor() : Mesh(SPHERE_PATH) {}
	};

	static FContructor ConstructorStatics;

	auto tempMesh = ConstructorStatics.Mesh;

	staticMeshComponent->SetupAttachment(RootComponent);

	if (tempMesh.Succeeded()) {
		staticMeshComponent->SetStaticMesh(tempMesh.Get());
	}

}

// Called when the game starts or when spawned
void AServerSocket::BeginPlay()
{
	Super::BeginPlay();

#if 0
	APlayerController* myPlayerController = UGameplayStatics::GetPlayerController(this, 0);

	if (myPlayerController) {
		this->EnableInput(myPlayerController);
	}
#endif

}

// Called every frame
void AServerSocket::Tick(float DeltaTime)
{
	Super::Tick(DeltaTime);

	SocketDelta = DeltaTime;
	AddActorWorldOffset(currentLoc);
	GEngine->AddOnScreenDebugMessage(-1, 5.f, FColor::Yellow, FString::Printf(TEXT("%d-%d-%d"), currentLoc.X, currentLoc.Y, currentLoc.Z));
}

void AServerSocket::EndPlay(const EEndPlayReason::Type EndPlayReason)
{
	Super::EndPlay(EndPlayReason);
	if (ServerSocket) {
		ServerSocket->Close();
		ISocketSubsystem::Get(PLATFORM_SOCKETSUBSYSTEM)->DestroySocket(ServerSocket);
	}
	if (ClientSocket) {
		ClientSocket->Close();
		ISocketSubsystem::Get(PLATFORM_SOCKETSUBSYSTEM)->DestroySocket(ClientSocket);
	}

}

bool AServerSocket::CreateSocket()
{
	ServerSocket = ISocketSubsystem::Get(PLATFORM_SOCKETSUBSYSTEM)->CreateSocket(NAME_Stream, "Send Information", false);
	if (!ServerSocket) {
		return false;
	}

	return true;
}

bool AServerSocket::BindSocket(const FString& BindIP, const int32 BindPort)
{
	FIPv4Address::Parse(BindIP, ip);
	TSharedPtr<FInternetAddr> addr = ISocketSubsystem::Get(PLATFORM_SOCKETSUBSYSTEM)->CreateInternetAddr();
	addr->SetIp(ip.Value);
	addr->SetPort(BindPort);
	bool bBind = ServerSocket->Bind(*addr);

	return bBind;
}

bool AServerSocket::ListenSocket(int32 MaxConnectionNum)
{
	ServerSocket->Listen(MaxConnectionNum);

	return false;
}

bool AServerSocket::AcceptSocket()
{
	ClientSocket = ServerSocket->Accept("Send Information");

	if (!ClientSocket)	return false;

	return true;
}

bool AServerSocket::sendMsg(const FString& Msg)
{
	TSharedPtr<FInternetAddr> addr = ISocketSubsystem::Get(PLATFORM_SOCKETSUBSYSTEM)->CreateInternetAddr();
	FText outputSample = FText::FromString(addr->ToString(false));
	GEngine->AddOnScreenDebugMessage(-1, 100.f, FColor::Yellow, addr->ToString(true));
	FString tempMsg = Msg;
	TCHAR* MsgChar = tempMsg.GetCharArray().GetData();
	int32 size = FCString::Strlen(MsgChar) + 1;
	int sent = 0;
	bool bSend;
	if (ClientSocket) {
		bSend = ClientSocket->SendTo((uint8*)TCHAR_TO_UTF8(MsgChar), size, sent, *addr);
	}
	bSend ? GEngine->AddOnScreenDebugMessage(-1, 5.f, FColor::Green, TEXT("Socket Sent Success")) : GEngine->AddOnScreenDebugMessage(-1, 5.f, FColor::Red, TEXT("Socket Failed"));

	return bSend;
}

FString AServerSocket::RecvMsg()
{
	TSharedPtr<FInternetAddr> addr = ISocketSubsystem::Get(PLATFORM_SOCKETSUBSYSTEM)->CreateInternetAddr();
	TArray<uint8> ReceiveData;
	FString ReceivedUE4String = "";
	uint32 Size;

	if (ClientSocket->HasPendingData(Size)) {
		uint8* Recv = new uint8[Size];
		ReceiveData.SetNumUninitialized(FMath::Min(Size, 65507u));
		int32 ByteRead = 0;
		ClientSocket->RecvFrom(ReceiveData.GetData(), ReceiveData.Num(), ByteRead, *addr);
		if (ReceiveData.Num() > 0) {
			GEngine->AddOnScreenDebugMessage(-1, 5.f, FColor::Green, FString::Printf(TEXT("Data Bytes Read-> %d"), ReceiveData.Num()));
			ReceivedUE4String = StringFromBinaryArray(ReceiveData);
			GEngine->AddOnScreenDebugMessage(-1, 5.f, FColor::Green, FString::Printf(TEXT("Data String Read-> %d"), ReceiveData.Num()));
		}
		else {
			GEngine->AddOnScreenDebugMessage(-1, 5.f, FColor::Green, FString::Printf(TEXT("Data Byte Read Failed"), ReceiveData.Num()));
		}
		return ReceivedUE4String;
	}

	return ReceivedUE4String;
}

void AServerSocket::Test(const FString& BindIP, const int32 Port, const int32 MaxListener) {
	if (CreateSocket()) {
		if (BindSocket(BindIP, Port)) {
			if (ListenSocket(MaxListener)) {
				if (AcceptSocket()) {
					UWorld* world = GetWorld();
					world->GetTimerManager().SetTimer(SocketTimerHandle, this, &AServerSocket::HandleFunc, SocketDelta, true);
				}
			}
		}
	}
}

void AServerSocket::HandleFunc()
{
	bool outIsValid = false;
	UKismetStringLibrary::Conv_StringToVector(RecvMsg(), currentLoc, outIsValid);
}

到了這里，關(guān)于UE4 使用Socket的文章就介紹完了。如果您還想了解更多內(nèi)容，請?jiān)谟疑辖撬阉鱐OY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章，希望大家以后多多支持TOY模板網(wǎng)！