【Unity3D】同步Socket通讯

这篇具有很好参考价值的文章主要介绍了【Unity3D】同步Socket通讯。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

1 前言

         在多人对战网络游戏中,玩家之间一般不是直接通讯,而是与服务器通讯,服务器再把消息转发给其他玩家。网络通讯一般基于 Socket 实现,也有一些开源网络游戏框架,如:光子引擎 Photon,其底层仍然使用 Socket 实现网络通讯。

        同步 Socket 是指 Socket 的部分方法会阻塞当前线程(如:Accept、Receive 方法),直到方法返回,当前线程才会继续执行。

        当有客户连接上服务器后,服务器会生成一个 Socket(通过 Accept 方法返回 Socket,可以理解为客服),与客户对接,进行信息交流。

2 案例

        1)Socket 基本操作接口

        BaseSocket.cs

public interface BaseSocket {
	void Listening(); // 监听连接, 监听消息
	void Receive(); // 接收到消息
	void Send(string msg); // 发送消息
}

        2)服务端

         SyncSocketServer.cs

using System;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;

public class SyncSocketServer : BaseSocket{
	private Socket serverSocket; // 服务端通讯主机socket, 监听打进来的电话,并转接给客服
	private Socket kefuScoket; // 客服socket, 负责与客户一对一通讯
	private Action<string> msgCallback; // 消息回调
	private byte[] readBuff; // 收到消息的缓存

	public SyncSocketServer(Action<string> callback) {
		msgCallback = callback;
		serverSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
		IPEndPoint endPoint = new IPEndPoint(IPAddress.Any, 12345);
		serverSocket.Bind(endPoint); // 绑定ip和端口
		new Thread(() => {
			Listening();
		}).Start();
	}

	public void Listening() {
		serverSocket.Listen(1); // 监听电话连接, 设置最大客服人数, 如果是0就是无限个客服
		kefuScoket = serverSocket.Accept(); // 接电话, 分配客服和客户进行一对一通信, 没有电话打进来就会一直阻塞
		msgCallback("客服的本地端口是: " + kefuScoket.LocalEndPoint.ToString());
		msgCallback("客户的远程端口是: " + kefuScoket.RemoteEndPoint.ToString());
		readBuff = new byte[1024];
		while(true) {
			Receive();
		}
	}

	public void Receive() {
		Array.Clear(readBuff, 0, readBuff.Length); // 清空缓存
		int count = kefuScoket.Receive(readBuff); // 收到消息, 并存放在缓冲区, 没有消息就会一直阻塞
		string msg = Encoding.UTF8.GetString(readBuff, 0, count);
		msgCallback("客户端发来消息: " + msg);
	}

	public void Send(string msg) {
		byte[] buffer = Encoding.UTF8.GetBytes(msg);
		kefuScoket.Send(buffer);
	}

	~SyncSocketServer() {
		kefuScoket.Close();
		serverSocket.Close();
	}
}

        3)客户端

        SyncSocketClient.cs

using System;
using System.Net.Sockets;
using System.Text;
using System.Threading;

public class SyncSocketClient : BaseSocket {
    private Socket clientSocket; // 客户端socket
    private Action<string> msgCallback; // 消息回调
	private byte[] readBuff; // 收到消息的缓存

    public SyncSocketClient(Action<string> callback) {
        msgCallback = callback;
        clientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
        new Thread(() => {
            clientSocket.Connect("127.0.0.1", 12345); //连接服务器, 未连接上就会一直阻塞
			Listening();
		}).Start();
    }

    public void Listening() {
        readBuff = new byte[1024];
        while(true) {
            Receive();
        }
    }

    public void Receive() {
        Array.Clear(readBuff, 0, readBuff.Length); // 清空缓存
        int count = clientSocket.Receive(readBuff); // 收到消息, 并存放在缓冲区, 没有消息就会一直阻塞
        string msg = Encoding.UTF8.GetString(readBuff, 0, count);
        msgCallback("客服发来消息: " + msg);
    }

	public void Send(string msg) {
        byte[] buffer = Encoding.UTF8.GetBytes(msg);
		clientSocket.Send(buffer);
	}

	~SyncSocketClient() {
		clientSocket.Close();
	}
}

        4)测试类

        SyncSocketTest.cs

using UnityEngine;

public class SyncSocketTest : MonoBehaviour {
	private BaseSocket socket; // 客户端/服务端socket
	private string sendText; // 发送的消息
	private string receiveText; // 接收的消息
	private bool isSideInited = false; // 是否已初始化端测
	private string sideTag = null; // 端测标记, 服务端/客户端

	private void Awake() {
		Application.runInBackground = true; // 支持后台运行
	}

	private void OnGUI() {
		InitSide();
		initSideView();
	}

	private void InitSide() { // 初始化端测
		if (!isSideInited) {
			CreateServer();
			CreateClient();
		}
	}

	private void CreateServer() { // 创建服务器
		if (GUILayout.Button("创建服务器")) {
			socket = new SyncSocketServer((msg) => {
				receiveText += msg + "\n";
			});
			sideTag = "服务端";
			isSideInited = true;
		}
	}

	private void CreateClient() { // 创建客户端
		if (GUILayout.Button("创建客户端")) {
			socket = new SyncSocketClient((msg) => {
				receiveText += msg + "\n";
			});
			sideTag = "客户端";
			isSideInited = true;
		}
	}

	private void initSideView() { // 初始化端测界面
		if (isSideInited) {
			GUILayout.Label(sideTag);
			sendText = GUILayout.TextField(sendText);
			if (GUILayout.Button("发送")) {
				socket.Send(sendText);
			}
			GUILayout.Label("接收到的消息: ");
			GUILayout.Label(receiveText);
		}
	}
}

        5)运行效果

unity客户端接收服务端消息,Unity3D,# Unity基础,同步Socket,C#,Unity3D文章来源地址https://www.toymoban.com/news/detail-615745.html

到了这里,关于【Unity3D】同步Socket通讯的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • unity3D基础操作之01--unity3d窗口界面介绍

    提示:文章写完后,目录可以自动生成,如何生成可参考右边的帮助文档 1、Scene场景编辑窗口; 2、Game游戏运行窗口; 3、Hierarchy场景物体列表窗口; 4、Project项目资源列表窗口; 5、Inspector属性编辑列表窗口; 6、其他常调节窗口 在屏幕左上方为场景编辑窗口Scene,在场景编

    2024年02月06日
    浏览(76)
  • 【Unity3D】Unity3D 软件安装 ( 注册账号并下载 Unity Hub | 安装 Unity Hub | 获取个人版授权 | 中文环境设置 | 安装 Unity3D 编辑器 )

    Unity 官方网站 : 英文 : https://unity.com 中文 : https://unity.cn 进入 中文网站 https://unity.cn , 点击右上角的 \\\" 下载 Unity \\\" 按钮 ; 推荐下载 Unity3D 的长期支持版本 ; 点击界面中的 \\\" 下载 Unity Hub \\\" 选项 ; 根据你的系统 , 选择对应的 Unity Hub , 我在 Windows 上开发 , 因此选择 \\\" Windows 下载 \\\"

    2024年01月25日
    浏览(89)
  • 【Unity3D日常开发】Unity3D中实现单例模式详解

    推荐阅读 CSDN主页 GitHub开源地址 Unity3D插件分享 简书地址 我的个人博客 大家好,我是佛系工程师 ☆恬静的小魔龙☆ ,不定时更新Unity开发技巧,觉得有用记得一键三连哦。 首先,说一下,什么是 单例模式(Singleton) 。 单例模式是设计模式中常见的一种设计模式,目的是为了

    2024年02月02日
    浏览(61)
  • 【Unity3D-01】 记录Unity3D调用外接摄像头

    最近想在Unity3D上调用一个摄像头,通过查找资料发现仙魁XAN和八哥快走开的博客符合我的想法,实现起来也不难就尝试了一下 2.1 在这个工程里新建Canvas 如下图所示 然后下设RawImage为载体 2.2 在Assets里面新建一个脚本命名为PlaneManager.cs 代码内容如下(参考八哥快走开的博客)

    2024年02月04日
    浏览(50)
  • 【Unity3D小功能】Unity3D中实现Text显示版本功能

    推荐阅读 CSDN主页 GitHub开源地址 Unity3D插件分享 简书地址 我的个人博客 大家好,我是佛系工程师 ☆恬静的小魔龙☆ ,不定时更新Unity开发技巧,觉得有用记得一键三连哦。 在项目开发中,会遇到要控制版本的情况,比如说对比版本号,版本不对再更新版本的功能,这些就是

    2024年02月05日
    浏览(69)
  • 【Unity3D小功能】Unity3D中实现点击‘文字’出现‘UI面板’

    推荐阅读 CSDN主页 GitHub开源地址 Unity3D插件分享 简书地址 QQ群:398291828 大家好,我是佛系工程师 ☆恬静的小魔龙☆ ,不定时更新Unity开发技巧,觉得有用记得一键三连哦。 宠粉博主又来了,今天有粉丝问我如何实现点击一段文字然后出现的面板在那段文字附近显示: 深入了

    2024年04月13日
    浏览(77)
  • 【Unity3D日常开发】Unity3D中实现不同脚本之间的执行顺序控制

    推荐阅读 CSDN主页 GitHub开源地址 Unity3D插件分享 简书地址 我的个人博客 大家好,我是佛系工程师 ☆恬静的小魔龙☆ ,不定时更新Unity开发技巧,觉得有用记得一键三连哦。 首先,来了解一下事件函数的执行顺序,下图是官方给的脚本中事件函数的执行顺序: 众所周知,U

    2024年02月02日
    浏览(52)
  • 【Unity3D小功能】Unity3D中实现仿真时钟、表盘、仿原神时钟

    推荐阅读 CSDN主页 GitHub开源地址 Unity3D插件分享 简书地址 我的个人博客 大家好,我是佛系工程师 ☆恬静的小魔龙☆ ,不定时更新Unity开发技巧,觉得有用记得一键三连哦。 今天实现一个时钟工具,其实在之前已经完成了一个简单的时钟工具:【Unity3D应用案例系列】时钟、

    2024年02月05日
    浏览(72)
  • 【Unity3D编辑器开发】Unity3D中实现Transform快速复制粘贴【非常实用】

    推荐阅读 CSDN主页 GitHub开源地址 Unity3D插件分享 简书地址 我的个人博客 大家好,我是佛系工程师 ☆恬静的小魔龙☆ ,不定时更新Unity开发技巧,觉得有用记得一键三连哦。 在开发中,常常会遇到频繁复制粘贴物体的坐标、旋转、缩放的操作。 使用Unity自带的组件复制粘贴比

    2024年02月07日
    浏览(60)
  • 【Unity3D小功能】Unity3D中实现UI擦除效果、刮刮卡功能

    推荐阅读 CSDN主页 GitHub开源地址 Unity3D插件分享 简书地址 我的个人博客 大家好,我是佛系工程师 ☆恬静的小魔龙☆ ,不定时更新Unity开发技巧,觉得有用记得一键三连哦。 使用Unity3D实现UI的擦拭效果、刮刮卡功能的效果实现方式比较多,比如说用Shader、Texture渲染都是可以

    2024年02月04日
    浏览(224)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包