Unity【Socket TCP】- 服务端与客户端通讯的简单示例

简介: Unity【Socket TCP】- 服务端与客户端通讯的简单示例

应粉丝需求做一个服务端与客户端通讯的示例,需求比较简单,我们使用Socket TCP协议去构建,直接使用固定长度信息法。

image.gif

一、服务端搭建:

打开Visual Studio,文件/新建/项目,创建一个控制台应用:

image.gif

image.gif

新建Server类与Client类:

image.gifimage.gif编辑代码如下:

using System.Net;
using System.Net.Sockets;
namespace CoderZ
{
    public class Server
    {
        //端口
        private const int port = 8008;
        //客户端列表
        private List<Client> clients = new List<Client>();
        private static void Main(string[] args)
        {
            Console.WriteLine("服务端启动...");
            Server server = new Server();
            server.Init();
        }
        //服务端初始化
        private void Init()
        {
            TcpListener listener = new TcpListener(IPAddress.Any, port);
            listener.Start();
            try
            {
                while (true)
                {
                    Console.WriteLine("等待客户端接入...");
                    TcpClient client = listener.AcceptTcpClient();
                    Client clientInstance = new Client(client, this);
                    clients.Add(clientInstance);
                    Console.WriteLine($"{client.Client.RemoteEndPoint}接入.");
                }
            }
            catch(Exception error)
            {
                throw new Exception(error.ToString());
            }
        }
        /// <summary>
        /// 广播:向所有客户端发送数据
        /// </summary>
        /// <param name="data"></param>
        public void Broadcast(string data)
        {
            for (int i = 0; i < clients.Count; i++)
            {
                clients[i].Send(data);
            }
        }
        /// <summary>
        /// 移除客户端
        /// </summary>
        /// <param name="client"></param>
        public void Remove(Client client)
        {
            if (clients.Contains(client)) 
            { 
                clients.Remove(client);
            }
        }
    }
}

image.gif

using System.Text;
using System.Net.Sockets;
namespace CoderZ
{
  public class Client
  {
    private Server server;
    private TcpClient tcpClient;
    private NetworkStream stream;
    /// <summary>
    /// 构造函数
    /// </summary>
    /// <param name="tcpClient"></param>
    /// <param name="server"></param>
    public Client(TcpClient tcpClient, Server server)
        {
      this.server = server;
      this.tcpClient = tcpClient;
      //启动线程 读取数据
      Thread thread = new Thread(TcpClientThread);
      thread.Start();
        }
    private void TcpClientThread()
        {
      stream = tcpClient.GetStream();
      //使用固定长度
      byte[] buffer = new byte[1024];
            try
            {
                while (true)
                {
          int length = stream.Read(buffer, 0, buffer.Length);
          if (length != 0)
                    {
            string data = Encoding.UTF8.GetString(buffer, 0, length);
            //解包
            Unpack(data);
                    }
                }
            }
      catch(Exception error)
            {
                Console.WriteLine(error.ToString());
            }
            finally
            {
        server.Remove(this);
            }
        }
    //拆包:解析数据
    private void Unpack(string data)
        {
        }
    /// <summary>
    /// 发送数据
    /// </summary>
    /// <param name="data"></param>
    public void Send(string data)
        {
      byte[] buffer = Encoding.UTF8.GetBytes(data);
      stream.Write(buffer, 0, buffer.Length);
        }
  }
}

image.gif

数据的解析我们这里使用LitJson.dll工具,没有该工具的可以联系我发一份,打开视图/解决方案资源管理器:

image.gif

右键解决方案/添加/项目引用:

image.gif

点击浏览,找到LitJson工具,点击确定进行引用:

image.gif

有了LitJson后我们便可以进行数据的解析,但是我们还没有定义任何数据结构,我们想要传输的数据包括图片和字符,因此这里定义如下数据结构:

[Serializable]
public class SimpleData
{
  /// <summary>
  /// 图片数据
  /// </summary>
  public string pic;
  /// <summary>
  /// 字符内容
  /// </summary>
  public string content;
}

image.gif

引入LitJson命名空间后,解析数据:

//拆包:解析数据
private void Unpack(string data)
{
  SimpleData simpleData = JsonMapper.ToObject<SimpleData>(data);
  Console.WriteLine(simpleData.pic);
  Console.WriteLine(simpleData.content);
}

image.gif

此时运行我们的服务端:

image.gif

image.gif

二、Unity客户端搭建:

创建Client类,继承自MonoBehaviour,同时定义与服务端一致的数据结构:

using System;
using System.Text;
using UnityEngine;
using System.Threading;
using System.Net.Sockets;
using System.Collections.Generic;
public class Client : MonoBehaviour
{
    private string ipAddress;
    private int port;
    private bool isConnected;
    private Thread connectThread;
    private Thread readDataThread;
    private TcpClient tcpClient;
    private NetworkStream stream;
    //将数据存于队列 依次取出
    private Queue<string> queue = new Queue<string>();
    private void Start()
    {
        connectThread = new Thread(ConnectThead);
        connectThread.Start();
    }
    //连接线程
    private void ConnectThead()
    {
        tcpClient = new TcpClient();
        tcpClient.BeginConnect(ipAddress, port, ConnectThreadCallBack, tcpClient);
        float waitTime = 0f;
        while (!isConnected)
        {
            Thread.Sleep(500);
            waitTime += Time.deltaTime;
            if (waitTime > 3f)
            {
                waitTime = 0f;
                throw new Exception("连接超时");
            }
        }
    }
    private void ConnectThreadCallBack(IAsyncResult result)
    {
        tcpClient = result.AsyncState as TcpClient;
        if (tcpClient.Connected)
        {
            isConnected = true;
            tcpClient.EndConnect(result);
            stream = tcpClient.GetStream();
            readDataThread = new Thread(ReadDataThread);
            readDataThread.Start();
        }
    }
    //读取数据线程
    private void ReadDataThread()
    {
        try
        {
            while (isConnected)
            {
                byte[] buffer = new byte[1024];
                int length = stream.Read(buffer, 0, buffer.Length);
                string data = Encoding.UTF8.GetString(buffer, 0, length);
                queue.Enqueue(data);
            }
        }
        catch(Exception error)
        {
            throw new Exception(error.ToString());
        }
    }
    //程序退出时关闭线程
    private void OnApplicationQuit()
    {
        stream?.Close();
        connectThread?.Abort();
        readDataThread?.Abort();
    }
    /// <summary>
    /// 发送数据
    /// </summary>
    /// <param name="content"></param>
    public void SendData(string content)
    {
        byte[] buffer = Encoding.UTF8.GetBytes(content);
        stream.Write(buffer, 0, buffer.Length);
    }
}
[Serializable]
public class SimpleData
{
    /// <summary>
    /// 图片数据
    /// </summary>
    public string pic;
    /// <summary>
    /// 字符内容
    /// </summary>
    public string content;
}

image.gif

创建一个空物体为其挂载Client脚本:

image.gif

运行Unity程序,回到服务端控制台窗口,可以看到我们已经成功与服务端连接:

image.gif

我们找一张图片,将图片和字符数据发送给服务端测试,将它放到Assets目录中,我们通过代码读取这张图片的数据:

image.gif

示例代码,将其与Client脚本挂在同一物体上:

using System;
using System.IO;
using UnityEngine;
using LitJson;
public class Foo : MonoBehaviour
{
    private void OnGUI()
    {
        if (GUILayout.Button("发送数据", GUILayout.Width(200f), GUILayout.Height(50f)))
        {
            var bytes = File.ReadAllBytes(Application.dataPath + "/pic.jpg");
            SimpleData simpleData = new SimpleData()
            {
                pic = Convert.ToString(bytes),
                content = "这是一张汽车图片"
            };
            //使用LitJson序列化
            string data = JsonMapper.ToJson(simpleData);
            GetComponent<Client>().SendData(data);
        }
    }
}

image.gif

运行程序点击发送数据按钮,回到服务端控制台查看可以看见我们已经接收到数据:

image.gif

上面是客户端发送数据到服务端的示例,下面我们尝试从服务端发送数据到客户端:

服务端将图片放于解决方案中如图所示位置,我们通过代码读取图片数据:

image.gif

我们在客户端接入的时候将数据发送给客户端,因此就暂且将其写在Client构造函数里:

/// <summary>
/// 构造函数
/// </summary>
/// <param name="tcpClient"></param>
/// <param name="server"></param>
public Client(TcpClient tcpClient, Server server)
{
  this.server = server;
  this.tcpClient = tcpClient;
  //启动线程 读取数据
  Thread thread = new Thread(TcpClientThread);
  thread.Start();
  byte[] bytes = File.ReadAllBytes("pic.jpg");
  SimpleData simpleData = new SimpleData()
  {
    pic = Convert.ToBase64String(bytes),
    content = "这是一张图片"
  };
  string data = JsonMapper.ToJson(simpleData);
  Send(data);
}

image.gif

客户端中我们已经将服务端发送的数据存于队列中,因此从队列中将数据依次取出:

private void Update()
{
    if (queue.Count > 0)
    {
        string data = queue.Dequeue();
        //使用LitJson反序列化
        SimpleData simpleData = JsonMapper.ToObject<SimpleData>(data);
        byte[] bytes = Convert.FromBase64String(simpleData.pic);
        //将图片存到Assets目录
        File.WriteAllBytes(Application.dataPath + "/test.jpg", bytes);
        //打印字符内容
        Debug.Log(simpleData.content);
    }
}

image.gif

image.gif

目录
相关文章
|
3天前
|
监控 Unix Linux
采用异步socket实现客户端和服务端的通信
采用异步socket实现客户端和服务端的通信
8 0
|
9天前
|
XML JSON 网络协议
Socket实现模拟TCP通信粘包问题
Socket实现模拟TCP通信粘包问题
|
9天前
|
网络协议
Socket实现服务器和客户端(手把手教会)
Socket实现服务器和客户端(手把手教会)
|
9天前
|
网络协议 网络安全 程序员
socket,tcp,http三者之间的原理和区别
socket,tcp,http三者之间的原理和区别
socket,tcp,http三者之间的原理和区别
|
9天前
|
网络协议 Linux Go
Go语言TCP Socket编程(下)
Go语言TCP Socket编程
|
9天前
|
网络协议 Ubuntu Unix
Go语言TCP Socket编程(上)
Go语言TCP Socket编程
|
9天前
|
存储 网络协议 关系型数据库
Python从入门到精通:2.3.2数据库操作与网络编程——学习socket编程,实现简单的TCP/UDP通信
Python从入门到精通:2.3.2数据库操作与网络编程——学习socket编程,实现简单的TCP/UDP通信
|
9天前
|
网络协议 Linux Windows
TCP/IP、Http、Socket之间的区别
TCP/IP、Http、Socket之间的区别
|
9天前
|
网络协议 Ubuntu Unix
Linux 下使用 socket 实现 TCP 客户端
Linux 下使用 socket 实现 TCP 客户端
|
9天前
|
安全 Java 数据处理
Python网络编程基础(Socket编程)多线程/多进程服务器编程
【4月更文挑战第11天】在网络编程中,随着客户端数量的增加,服务器的处理能力成为了一个重要的考量因素。为了处理多个客户端的并发请求,我们通常需要采用多线程或多进程的方式。在本章中,我们将探讨多线程/多进程服务器编程的概念,并通过一个多线程服务器的示例来演示其实现。