unreal engine c++ 创建tcp server， tcp client

TCP客户端

TcpConnect.h

// Fill out your copyright notice in the Description page of Project Settings.#pragma once#include "CoreMinimal.h"
#include "Common/UdpSocketReceiver.h"
#include "GameFramework/Actor.h"DECLARE_DELEGATE_TwoParams(FOnServerResponseReceived, const int32&, bool);class FTcpConnect : public FRunnable
{
public:// Sets default values for this actor's propertiesFTcpConnect();virtual ~FTcpConnect(){if (ReceiveThread != nullptr){ReceiveThread->Kill(true);delete ReceiveThread;}}// virtual FSingleThreadRunnable* GetSingleThreadInterface() override// {// 	return this;// }
public:// Called every framevoid ConnectToServer(FString ServerAddress, const int32 ServerPort);void SendMessage(const FString& Message);FOnServerResponseReceived& OnDataReceived(){return OnServerResponseReceived;}virtual bool Init() override;virtual void Stop() override;protected:virtual uint32 Run() override;virtual void Exit() override;private:FSocket* Socket;TSharedPtr<FInternetAddr> RemoteAddr;FIPv4Endpoint LocalEndpoint;TArray<uint8> ReceivedData;FUdpSocketReceiver* UDPReceiver;bool bIsReceiving;FRunnableThread* ReceiveThread;int64 StartMs;FOnServerResponseReceived OnServerResponseReceived;
};

TcpConnect.cpp

// Fill out your copyright notice in the Description page of Project Settings.#include "Subsystem/TcpConnect.h"// Sets default values
FTcpConnect::FTcpConnect()
{
}void FTcpConnect::ConnectToServer(FString ServerAddress, const int32 ServerPort)
{// Socket = ISocketSubsystem::Get(PLATFORM_SOCKETSUBSYSTEM)->CreateSocket(NAME_Stream, TEXT("default"), false);// RemoteAddr = ISocketSubsystem::Get(PLATFORM_SOCKETSUBSYSTEM)->CreateInternetAddr();bool bValid;RemoteAddr->SetIp(*ServerAddress, bValid);RemoteAddr->SetPort(ServerPort);if (Socket->Connect(*RemoteAddr)){UE_LOG(LogTemp, Display, TEXT("Connected to server"));// bIsReceiving = true;ReceiveThread = FRunnableThread::Create(this, TEXT("ReceiveThread"), 128 * 1024);}else{UE_LOG(LogTemp, Error, TEXT("Failed to connect to server"));}
}void FTcpConnect::SendMessage(const FString& Message)
{if (Socket){const TCHAR* MessageData = *Message;int32 BytesSent = 0;StartMs = FDateTime::Now().ToUnixTimestamp() * 1000.0 + FDateTime::Now().GetMillisecond();UE_LOG(LogTemp, Warning, TEXT(" start ms %d"), StartMs);Socket->Send((uint8*)TCHAR_TO_UTF8(MessageData), FCString::Strlen(MessageData), BytesSent);}
}// FOnServerResponseReceived& FTcpConnect::OnDataReceived()
//
// {
// 	// check(ReceiveThread == nullptr);
// 	return OnServerResponseReceived;
// }bool FTcpConnect::Init()
{if (ReceiveThread && Socket){return true;}return false;
}void FTcpConnect::Stop()
{bIsReceiving = false;if (ReceiveThread){ReceiveThread->WaitForCompletion();// ReceiveThread.re}if (Socket){Socket->Close();Socket = nullptr;// Socket.Reset();}
}uint32 FTcpConnect::Run()
{while (bIsReceiving){uint8 Data[1024];int32 BytesReceived = 0;if (Socket->Recv(Data, sizeof(Data), BytesReceived, ESocketReceiveFlags::None)){if (BytesReceived > 0){FString Message = FString(UTF8_TO_TCHAR((const char*)Data));UE_LOG(LogTemp, Warning, TEXT(" message %s"), *Message)int64 EndMs = FDateTime::Now().ToUnixTimestamp() * 1000.0 + FDateTime::Now().GetMillisecond();UE_LOG(LogTemp, Warning, TEXT(" start ms %d  %d"), EndMs, EndMs- StartMs);auto r = OnServerResponseReceived.ExecuteIfBound(EndMs - StartMs, true);bIsReceiving = false;}}FPlatformProcess::Sleep(0.05f);}return 0;
}void FTcpConnect::Exit()
{// FRunnable::Exit();
}

tcp server

// Fill out your copyright notice in the Description page of Project Settings.#pragma once#include "CoreMinimal.h"
#include "HAL/Runnable.h"class FSocket;
class FInternetAddr;/*** */
class MYPROJECT2_API FTcpServer : public FRunnable
{
public:FTcpServer();~FTcpServer();// 初始化服务器virtual bool Init() override;// 开始监听连接bool StartListening(FString IpAddress, int32 Port);// 停止监听连接void StopListening();// FRunnable 接口virtual uint32 Run() override;virtual void Stop() override;void HandleTextMessage(const FString& Message);private:// 处理客户端连接void HandleConnection(FSocket* NewClientSocket, const TSharedRef<FInternetAddr>& ClientAddress);FString StringFromBinaryArray(const TArray<uint8>& BinaryArray);class FSocket* serverSocket;FSocket* ListenSocket;FRunnableThread* ServerThread;FThreadSafeBool bIsStopping;TMap<FSocket*, FString> ClientDataMap; // 用于存储每个客户端的数据};

cpp

// Fill out your copyright notice in the Description page of Project Settings.#include "Net/TcpServer.h"#include "Common/TcpSocketBuilder.h"
#include "Interfaces/IPv4/IPv4Endpoint.h"FTcpServer::FTcpServer() : ListenSocket(nullptr), ServerThread(nullptr), bIsStopping(false)
{ServerThread = FRunnableThread::Create(this, TEXT("TcpServerThread"));
}FTcpServer::~FTcpServer()
{StopListening();
}bool FTcpServer::Init()
{// 初始化网络模块// if (!ISocketSubsystem::Init())// {// 	UE_LOG(LogTemp, Error, TEXT("Failed to initialize socket subsystem."));// 	return false;// }return true;
}bool FTcpServer::StartListening(FString IpAddress, int32 Port)
{FString ServerIP = IpAddress;FIPv4Address ServerAddr;if (!FIPv4Address::Parse(ServerIP, ServerAddr)){UE_LOG(LogTemp, Error, TEXT("Server Ip %s is illegal"), *ServerIP);}ListenSocket = FTcpSocketBuilder(TEXT("Socket Listener")).AsReusable().AsBlocking().BoundToAddress(ServerAddr).BoundToPort(Port).Listening(8).WithReceiveBufferSize(1024).WithSendBufferSize(1024);if (ListenSocket){UE_LOG(LogTemp, Warning, TEXT("Server Create Success!"), *ServerIP);// SocketCreateDelegate.Broadcast(true);// GetWorld()->GetTimerManager().SetTimer(ConnectCheckHandler, this, &ATCPServer::ConnectCheck, 1, true);return false;}else{UE_LOG(LogTemp, Error, TEXT("Server Create Failed!"));// SocketCreateDelegate.Broadcast(false);}return false;
}void FTcpServer::StopListening()
{if (ListenSocket){ListenSocket->Close();ISocketSubsystem::Get(PLATFORM_SOCKETSUBSYSTEM)->DestroySocket(ListenSocket);ListenSocket = nullptr;}if (ServerThread){ServerThread->WaitForCompletion();delete ServerThread;ServerThread = nullptr;}
}uint32 FTcpServer::Run()
{ISocketSubsystem* SocketSubsystem = ISocketSubsystem::Get(PLATFORM_SOCKETSUBSYSTEM);if (!SocketSubsystem){UE_LOG(LogTemp, Error, TEXT("Socket subsystem not available."));return 1;}while (!bIsStopping){if (!ListenSocket) continue;TSharedRef<FInternetAddr> ClientAddress = ISocketSubsystem::Get(PLATFORM_SOCKETSUBSYSTEM)->CreateInternetAddr();FSocket* NewClientSocket = ListenSocket->Accept(*ClientAddress, TEXT("MyTcpServer Connection"));UE_LOG(LogTemp, Log, TEXT("Run"));if (NewClientSocket){// 新客户端连接处理HandleConnection(NewClientSocket, ClientAddress);}FPlatformProcess::Sleep(0.01);}return 0;
}void FTcpServer::Stop()
{UE_LOG(LogTemp, Warning, TEXT("St opped"));bIsStopping = true;
}void FTcpServer::HandleTextMessage(const FString& Message)
{UE_LOG(LogTemp, Warning, TEXT("Received message: %s"), *Message);
}void FTcpServer::HandleConnection(FSocket* NewClientSocket, const TSharedRef<FInternetAddr>& ClientAddress)
{// 在这里处理新客户端连接的逻辑UE_LOG(LogTemp, Warning, TEXT("Client connected: %s"), *ClientAddress->ToString(true));// 接收和处理消息while (NewClientSocket && !bIsStopping){TArray<uint8> ReceivedData;uint32 Size;// 接收数据while (NewClientSocket->HasPendingData(Size)){ReceivedData.Init(0, FMath::Min(Size, 65507u));int32 Read = 0;NewClientSocket->Recv(ReceivedData.GetData(), ReceivedData.Num(), Read);// 处理接收到的数据（这里假设消息以'\n'分隔）FString ReceivedString = StringFromBinaryArray(ReceivedData);TArray<FString> Messages;ReceivedString.ParseIntoArray(Messages, TEXT("\n"), true);for (const FString& Message : Messages){// 处理文本消息HandleTextMessage(Message);}}// 睡眠一段时间，以避免空循环造成CPU过度使用FPlatformProcess::Sleep(0.01);}// 断开客户端连接// UE_LOG(LogTemp, Warning, TEXT("Client disconnected: %s"), *ClientAddress->ToString(true));// NewClientSocket->Close();// ISocketSubsystem::Get(PLATFORM_SOCKETSUBSYSTEM)->DestroySocket(NewClientSocket);}FString FTcpServer::StringFromBinaryArray(const TArray<uint8>& BinaryArray)
{return FString(ANSI_TO_TCHAR(reinterpret_cast<const char*>(BinaryArray.GetData())));
}

FTcpServerReceive

h

// Fill out your copyright notice in the Description page of Project Settings.#pragma once#include "CoreMinimal.h"
#include "HAL/Runnable.h"/*** */
class MYPROJECT2_API FTcpServerReceive: public FRunnable
{
public:FTcpServerReceive(FSocket* InSocket);~FTcpServerReceive();
protected:virtual bool Init() override;virtual void Stop() override;FString StringFromBinaryArray(TArray<uint8> Array);void HandleTextMessage(const FString& String);virtual uint32 Run() override;
private:FSocket* ClientSocket;FRunnableThread* ServerReceiveThread;bool bIsStopping;
};

cpp

// Fill out your copyright notice in the Description page of Project Settings.#include "Net/FTcpServerReceive.h"#include "Sockets.h"
#include "SocketSubsystem.h"FTcpServerReceive::FTcpServerReceive(FSocket* InSocket)
{ClientSocket = InSocket;ServerReceiveThread = FRunnableThread::Create(this, TEXT("ServerReceiveThread"));bIsStopping = false;
}FTcpServerReceive::~FTcpServerReceive()
{if (ClientSocket){ClientSocket->Close();ISocketSubsystem::Get(PLATFORM_SOCKETSUBSYSTEM)->DestroySocket(ClientSocket);ClientSocket = nullptr;}if (ServerReceiveThread){ServerReceiveThread->WaitForCompletion();delete ServerReceiveThread;ServerReceiveThread = nullptr;}
}bool FTcpServerReceive::Init()
{if (ServerReceiveThread && ClientSocket){UE_LOG(LogTemp, Warning, TEXT("  %s start"), *FString(__FUNCTION__));return true;}return false;
}void FTcpServerReceive::Stop()
{bIsStopping = true;
}FString FTcpServerReceive::StringFromBinaryArray(TArray<uint8> BinaryArray)
{return FString(ANSI_TO_TCHAR(reinterpret_cast<const char*>(BinaryArray.GetData())));
}void FTcpServerReceive::HandleTextMessage(const FString& Message)
{UE_LOG(LogTemp, Warning, TEXT("Received message: %s"), *Message);
}uint32 FTcpServerReceive::Run()
{while (ClientSocket){TArray<uint8> ReceivedData;uint32 Size;// 接收数据while (ClientSocket->HasPendingData(Size)){ReceivedData.Init(0, FMath::Min(Size, 65507u));int32 Read = 0;ClientSocket->Recv(ReceivedData.GetData(), ReceivedData.Num(), Read);// 处理接收到的数据（这里假设消息以'\n'分隔）FString ReceivedString = StringFromBinaryArray(ReceivedData);TArray<FString> Messages;ReceivedString.ParseIntoArray(Messages, TEXT("\n"), true);for (const FString& Message : Messages){// 处理文本消息HandleTextMessage(Message);}}// 睡眠一段时间，以避免空循环造成CPU过度使用FPlatformProcess::Sleep(0.05);}return 0;
}

使用

在GameInstance 使用


void UMyGameInstance::HandleTextMessage(const FString& Message)
{UE_LOG(LogTemp, Warning, TEXT("Received message: %s"), *Message);
}bool UMyGameInstance::Connected(FSocket* Socket, const FIPv4Endpoint& FiPv4Endpoint)
{UE_LOG(LogTemp, Warning, TEXT("Connected %s"), *FiPv4Endpoint.ToString());FTcpServerReceive* ServerReceive = new FTcpServerReceive(Socket);return true;
}void UMyGameInstance::Init()
{Super::Init();FIPv4Address ServerAddr;FIPv4Address::Parse("0.0.0.0", ServerAddr);FIPv4Endpoint IPv4;IPv4.Address = ServerAddr;IPv4.Port = 6666;#if UE_SERVER/FTcpListener* TcpServer = new FTcpListener(IPv4);TcpServer->OnConnectionAccepted().BindUObject(this, &UMyGameInstance::Connected);#elseFTcpClient* TcpClient = new FTcpClient();TcpClient->ConnectToServer("192.168.1.6", 6666);FTimerHandle h;FTimerDelegate d = FTimerDelegate::CreateLambda([=](){FString sent = "aaaaaa";TcpClient->SendMessage(sent);});// GetWorld()->GetTimerManager().SetTimer(h, d, 1.0f, true, 3.0f);#endif
}FString UMyGameInstance::StringFromBinaryArray(const TArray<uint8>& BinaryArray)
{return FString(ANSI_TO_TCHAR(reinterpret_cast<const char*>(BinaryArray.GetData())));
}TSharedPtr<TArray<uint8>, ESPMode::ThreadSafe> UMyGameInstance::StringToByteArray(FString DataString)
{TArray<uint8> DataArray;FTCHARToUTF8 Converter(*DataString);DataArray.Append(reinterpret_cast<const uint8*>(Converter.Get()), Converter.Length());return MakeShared<TArray<uint8>, ESPMode::ThreadSafe>(MoveTemp(DataArray));
}

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/30497.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

yumdownloader命令——yum下载rpm软件包到本地

yumdownloader命令——yum下载rpm软件包到本地

如果想通过 yum 下载服务的软件包&#xff0c;而不需要进行安装的话&#xff0c;可以使用 yumdownloader 命令&#xff0c;yumdownloader 命令可以下载软件包的RPM文件到本地。 yumdownloader 命令在软件包 yum-utils 里面&#xff0c;需要保证yum-utils已安装。 yum install…
阅读更多...
Stable Diffusion - 幻想 (Fantasy) 风格与糖果世界 (Candy Land) 的人物图像提示词配置

Stable Diffusion - 幻想 (Fantasy) 风格与糖果世界 (Candy Land) 的人物图像提示词配置

欢迎关注我的CSDN&#xff1a;https://spike.blog.csdn.net/ 本文地址&#xff1a;https://spike.blog.csdn.net/article/details/132212193 图像由 DreamShaper8 模型生成&#xff0c;融合糖果世界。 幻想 (Fantasy) 风格图像是一种以想象力为主导的艺术形式&#xff0c;创造了…
阅读更多...
Electron学习1 安装环境与第一个程序

Electron学习1 安装环境与第一个程序

Electron学习1 安装环境与第一个程序 一、 Electron 简介二、安装 nvm三、安装nodejs四、安装nrm五、安装electron1. npm 初始化2. 创建 package.json3. 安装electron4. 创建一个页面5. 创建文件main.js6. 创建预加载器文件 preload.js7. 启动程序 六、打包 一、 Electron 简介…
阅读更多...
Scala编程语言入门教程

Scala编程语言入门教程

Scala教程 方便个人学习和查阅 学习目标 Scala介绍 简介 Scala创始人Martin Odersky马丁奥德斯基 再回到我们的scala语言&#xff0c;在Scala官网https://www.scala-lang.org/介绍了其六大特征。 Java和scala可以混编 类型推测(自动推测类型) 并发和分布式&#xff08;Ac…
阅读更多...
Ubuntu 22.04 安装docker

Ubuntu 22.04 安装docker

参考&#xff1a; https://docs.docker.com/engine/install/ubuntu/ 支持的Ubuntu版本&#xff1a; Ubuntu Lunar 23.04Ubuntu Kinetic 22.10Ubuntu Jammy 22.04 (LTS)Ubuntu Focal 20.04 (LTS) 1 卸载旧版本 非官方的安装包&#xff0c;需要先卸载&#xff1a; docker.io…
阅读更多...
每日一学：什么是 Harbor ？

每日一学：什么是 Harbor ？

目录 什么是 Harbor &#xff1f; 一、Harbor 的优势 二、Harbor 架构构成 三、Core services 这是 Harbor 的核心功能 什么是 Harbor &#xff1f; Harbor 是 VMware 公司开源的企业级 Docker Registry 项目&#xff0c;其目标是帮助用户迅速搭建一个企业级的 Docker Reg…
阅读更多...
VUE之JWT前后端分离认证，学生管理系统

VUE之JWT前后端分离认证，学生管理系统

参考资料： SpringBoot搭建教程 SpringCloud搭建教程 JWT视频教程 JWT官网 Vue视频教程 JWT视频参考资料、VUE视频资料，及前后端demo 特别有参考价值的JWT博客1 特别有参考价值的JWT博客2 cookie、localstorage和sessionStorage的区别1 cookie、localstorage和sessi…
阅读更多...
Metamask登录方式集成

Metamask登录方式集成

Metamask登录 https://www.toptal.com/ethereum/one-click-login-flows-a-metamask-tutorial#how-the-login-flow-works 参考&#xff1a; https://zh.socialgekon.com/one-click-login-with-blockchain 后端需要在用户表中增加address和nonce字段。兼容其他登录方式&#xff0…
阅读更多...
【分布式技术专题】RocketMQ延迟消息实现原理和源码分析

【分布式技术专题】RocketMQ延迟消息实现原理和源码分析

痛点背景 业务场景 假设有这么一个需求&#xff0c;用户下单后如果30分钟未支付&#xff0c;则该订单需要被关闭。你会怎么做&#xff1f; 之前方案 最简单的做法&#xff0c;可以服务端启动个定时器&#xff0c;隔个几秒扫描数据库中待支付的订单&#xff0c;如果(当前时间-订…
阅读更多...
国产芯力特SIT1024QHG四通道本地互联网络（LIN）收发器，可替代TJA1024HG

国产芯力特SIT1024QHG四通道本地互联网络（LIN）收发器，可替代TJA1024HG

SIT1024Q 是一款四通道本地互联网络&#xff08;LIN&#xff09;物理层收发器&#xff0c;符合 LIN 2.0、LIN 2.1、LIN 2.2、 LIN 2.2A 、 ISO 17987-4:2016 (12V) 和 SAE J2602 标准。主要适用于使用 1kbps 至 20kbps 传输速 率的车载网络。 SIT1024Q 通过 TXDx 引…
阅读更多...
【0805作业】Linux中 AB终端通过两根有名管道进行通信聊天（半双工）（全双工）

【0805作业】Linux中 AB终端通过两根有名管道进行通信聊天（半双工）（全双工）

作业一&#xff1a;打开两个终端&#xff0c;要求实现AB进程对话【两根管道】 打开两个终端&#xff0c;要求实现AB进程对话 A进程先发送一句话给B进程&#xff0c;B进程接收后打印B进程再回复一句话给A进程&#xff0c;A进程接收后打印重复1.2步骤&#xff0c;当收到quit后&am…
阅读更多...
桥接模式-java实现

桥接模式-java实现

桥接模式 桥接模式的本质&#xff0c;是解决一个基类&#xff0c;存在多个扩展维度的的问题。 比如一个图形基类&#xff0c;从颜色方面扩展和从形状上扩展&#xff0c;我们都需要这两个维度进行扩展&#xff0c;这就意味着&#xff0c;我们需要创建一个图形子类的同时&#x…
阅读更多...
API接口 |产品经理一定要懂的技术知识

API接口 |产品经理一定要懂的技术知识

什么是接口❓ 要理解接口是什么&#xff0c;首先理解一下为什么要用接口&#xff1f; 两个独立的系统&#xff0c;它们的数据或程序是独立的&#xff0c;这就使得它们无法直接访问对方的数据库或程序&#xff08;两个独立的数据相当于两个独立的家庭&#xff0c;每个家庭肯定是…
阅读更多...
uniapp 运用Promise实现多图片上传

uniapp 运用Promise实现多图片上传

使用业务场景&#xff0c;循环多个图片上传控件&#xff0c;每一个上传到指定字段&#xff1b; dom结构如下&#xff1a; <u-form :model"userForm" :rules"rules" ref"uForm" labelWidth"160"> <u-form-item v-for"…
阅读更多...
【MMU】认识 MMU 及内存映射的流程

【MMU】认识 MMU 及内存映射的流程

MMU&#xff08;Memory Manager Unit&#xff09;&#xff0c;是内存管理单元&#xff0c;负责将虚拟地址转换成物理地址。除此之外&#xff0c;MMU 实现了内存保护&#xff0c;进程无法直接访问物理内存&#xff0c;防止内存数据被随意篡改。 目录 一、内存管理体系结构 1、…
阅读更多...
内网穿透：实现公网访问内网群晖NAS的方法

内网穿透：实现公网访问内网群晖NAS的方法

公网远程访问内网群晖NAS 7.X版 【内网穿透】 文章目录 公网远程访问内网群晖NAS 7.X版 【内网穿透】前言1. 在群晖控制面板找到“终端机和SNMP”2. 建立一条连接公网数据隧道3. 获取公网访问内网群晖NAS的数据隧道入口 前言 群晖NAS作为应用较为广泛的小型数据存储中心&#…
阅读更多...
SQL92 SQL99 语法 Oracle 、SQL Server 、MySQL 多表连接、Natural 、USING

SQL92 SQL99 语法 Oracle 、SQL Server 、MySQL 多表连接、Natural 、USING

SQL92 VS SQL 99 语法 92语法 内连接 from table1&#xff0c; table2 where table1.col table2.col 外连接 放在 从表 左连接&#xff1a; from table1&#xff0c; table2 where table1.col table2.col() 右连接&#xff1a; from table1&#xff0c; table2 where table…
阅读更多...
自定义注解（Annontation）

自定义注解（Annontation）

目录 1.注解定义 2.元注解定义 3. 自定义注解&#xff08;自定义的注解名称相同的会覆盖原注解&#xff09; 4.Annotation架构&#xff08;元注解参数介绍&#xff09; 1.注解定义 注解是用来将任何的信息或元数据&#xff08;metadata&#xff09;与程序元素&#xff08;类…
阅读更多...
苍穹外卖项目解读(四) 微信小程序支付、定时任务、WebSocket

苍穹外卖项目解读(四) 微信小程序支付、定时任务、WebSocket

前言 HM新出springboot入门项目《苍穹外卖》&#xff0c;笔者打算写一个系列学习笔记&#xff0c;“苍穹外卖项目解读”&#xff0c;内容主要从HM课程&#xff0c;自己实践&#xff0c;以及踩坑填坑出发&#xff0c;以技术&#xff0c;经验为主&#xff0c;记录学习&#xff0…
阅读更多...
深度学习基础知识扫盲

深度学习基础知识扫盲

深度学习 监督学习&#xff08;Supervised learning&#xff09;监督学习分类 无监督学习&#xff08;Non-supervised learning&#xff09;无监督学习的算法无监督学习使用场景 术语特征值特征向量特征工程&#xff08;Feature engineering&#xff09;特征缩放Sigmod functio…
阅读更多...
最新文章

Copyright @ 2022~2023