Unity实现局域网聊天室功能

来源：jb51　　时间：2021/10/11 9:22:35　　对本文有异议

基于Unity实现一个简单的局域网聊天室，供大家参考，具体内容如下

学习Unity有一点时间了，之前学的都是做客户端的一些内容，现在开始学习联网。我的这个是在观看了 Siki 的教学内容来做的，也有自己的一点点小小的改动在里面。纯粹用于练手了。

因为本人也是小白一枚，所以，有错误的地方或者更好的实现方法，也希望有大神能帮忙指正，多谢!

整体过程分为两部分：构建服务端、构建客户端。

服务端：

大概思路：

1. 声明Socket连接以及绑定IP和端口，这里面使用

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Net.Sockets;
using System.Net;
 
 
namespace ServerApplication
{
    class Program
    {
        public static string IP;
        public static int Port;
        static List<Client> clientList = new List<Client>();
 
        static Socket serverSocket;
 
 
        static void Main(string[] args)
        {
 
            //绑定IP和端口
            BindIPAndPort();
            //
            while (true)
            {
                Socket clientSocket = serverSocket.Accept();
                Client client = new Client(clientSocket);
                clientList.Add(client);
                Console.WriteLine("一台主机进入连接");
            }
        }
 
 
 
        /// <summary>
        /// 广播数据
        /// </summary>
        public static void BroadcostMSG(string s)
        {
            List<Client> NotConnectedList = new List<Client>();
            foreach (var item in clientList)
            {
                if(item.IsConnected)
                {
                    item.SendMSG(s);
                }
                else
                {
                    NotConnectedList.Add(item);
                }
 
            }
 
            foreach (var item in NotConnectedList)
            {
                clientList.Remove(item);
            }
 
 
        }
 
 
 
        /// <summary>
        /// 绑定IP和端口
        /// </summary>
       public static void BindIPAndPort()
        {
 
            //创建一个serverSocket
            serverSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
 
            //声明IP和端口
            Console.WriteLine("输入IP地址：");
            IP = Console.ReadLine();
            string ipStr = IP;
 
 
            Console.WriteLine("请输入端口：");
            Port = int.Parse(Console.ReadLine());
            int port = Port;
 
            IPAddress serverIp = IPAddress.Parse(ipStr);
            EndPoint serverPoint = new IPEndPoint(serverIp, port);
 
            //socket和ip进行绑定
            serverSocket.Bind(serverPoint);
 
            //监听最大数为100
            serverSocket.Listen(100);
        }
    }
}

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Net.Sockets;
using System.Threading;
 
namespace ServerApplication
{
    class Client
    {
        public Socket clientSocket;
        //声明一个线程用于接收信息
        Thread t;
        //接收信息所用容器
        byte[] data = new byte[1024];
 
       //构造函数
        public Client(Socket s)
        {
            clientSocket = s;
            t = new Thread(ReceiveMSG);
            t.Start();
        }
 
        /// <summary>
        /// 接收数据
        /// </summary>
        void ReceiveMSG()
        {
            while(true)
            {
                if (clientSocket.Poll(10,SelectMode.SelectRead))
                {
                    break;
                }
 
                data = new byte[1024];
                int length = clientSocket.Receive(data);
                string message = Encoding.UTF8.GetString(data, 0, length);
 
                Program.BroadcostMSG(message);
                Console.WriteLine("收到消息：" + message);
            }
 
        }
 
        /// <summary>
        /// 发送数据
        /// </summary>
        /// <param name="s"></param>
       public void SendMSG(string message)
        {
            byte[] data = Encoding.UTF8.GetBytes(message);
            clientSocket.Send(data);
        }
 
 
 
        //判断此Client对象是否在连接状态
        public bool IsConnected
        {
            get { return clientSocket.Connected; }
        }
 
    }
}

客户端：

a.UI界面

UI界面是使用UGUI实现的
登录用户可以自己取名进行登录（发言时用于显示），使用时需要输入服务端的IP地址和端口号

下面是聊天室的页面，在输入框内输入要发送的消息，点击Send，将信息发送出去

这是服务端的信息

b.关于客户端的脚本

（1）这是ClientManager，负责与服务端进行连接，通信

using System.Collections;
using System.Collections.Generic;
using UnityEngine;
using System.Net.Sockets;
using System.Net;
using System.Text;
using UnityEngine.UI;
using System.Threading;
public class ClientManager : MonoBehaviour
{
    //ip:192.168.1.7
    public string ipAddressstr;
    public int port;
    public Text ipTextToShow;
    //Socket
    private Socket ClientServer;
 
    //文本输入框
    public InputField inputTxt;
    public string inputMSGStr;
 
    //接收
    Thread t;
    public Text receiveTextCom;
    public string message;
 
    // Use this for initialization
    void Start()
    {
        ipTextToShow.text = ipAddressstr;
       // ConnectedToServer();
 
    }
 
    // Update is called once per frame
    void Update()
    {
        if (message != null && message != "")
        {
            receiveTextCom.text = receiveTextCom.text + "\n" + message;
            message = "";
        }
    }
 
 
    /// <summary>
    /// 连接服务器
    /// </summary>
    public void ConnectedToServer()
    {
        ClientServer = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
 
        //声明IP地址和端口
        IPAddress ServerAddress = IPAddress.Parse(ipAddressstr);
        EndPoint ServerPoint = new IPEndPoint(ServerAddress, port);
 
        ipAddressstr = IpInfo.ipStr;
        port = IpInfo.portStr;
 
 
        //开始连接
        ClientServer.Connect(ServerPoint);
 
        t = new Thread(ReceiveMSG);
        t.Start();
 
    }
 
 
    /// <summary>
    /// 接收消息
    /// </summary>
    /// <returns>“string”</returns>
    void ReceiveMSG()
    {
        while (true)
        {
            if (ClientServer.Connected == false)
            {
                break;
            }
            byte[] data = new byte[1024];
            int length = ClientServer.Receive(data);
            message = Encoding.UTF8.GetString(data, 0, length);
            //Debug.Log("有消息进来");
 
        }
 
    }
 
 
    /// <summary>
    /// 发送string类型数据
    /// </summary>
    /// <param name="input"></param>
    public void SendMSG()
    {
 
        Debug.Log("button Clicked");
        //message = "我：" + inputTxt.text;
        inputMSGStr = inputTxt.text;
        byte[] data = Encoding.UTF8.GetBytes(IpInfo.name+":"+inputMSGStr);
        ClientServer.Send(data);
 
    }
 
    private void OnDestroy()
    {
        ClientServer.Shutdown(SocketShutdown.Both);
        ClientServer.Close();
    }
    private void OnApplicationQuit()
    {
        OnDestroy();
    }
}

（2）SceneManager，用于场景切换，这里只是利用GameObject进行SetActive（）来实现，并不是创建了单独的Scene进行管理。

using System.Collections;
using System.Collections.Generic;
using UnityEngine;
 
public class SceneManager : MonoBehaviour {
 
 
    public GameObject loginPanel;
    public GameObject communicatingPanel;
    // Use this for initialization
 
    public void OnSwitch()
    {
        loginPanel.SetActive(false);
        communicatingPanel.SetActive(true);
    }
}

（3）LogInPanel和IPInfo,一个挂载在登录界面上，一个是数据模型，用于存储数据。

using System.Collections;
using System.Collections.Generic;
using UnityEngine;
using UnityEngine.UI;
 
public class LogInPanel : MonoBehaviour {
 
 
    public Text nameInputTxt;
    public Text ipInputTxt;
    public Text portInputTxt;
 
 
    //private string name;
    //private string ipStr;
    //private string portStr;
 
 
    public void OnLogInClick()
    {
        IpInfo.name = nameInputTxt.text;
        IpInfo.ipStr = ipInputTxt.text;
        IpInfo.portStr = int.Parse(portInputTxt.text);
    }
 
 
 
}

public static class IpInfo {
 
    public static string name;
    public static string ipStr;
    public static int portStr;
 
}

总结：第一次写学习博，还有很多地方要学习啊。

留待解决的问题：此聊天室只能用于局域网以内，广域网就无法实现通信了，还要看看怎么实现远程的一个通信，不然这个就没有存在的意义了。

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持w3xue。

友情链接：直通硅谷　点职佳　北美留学生论坛

unity热门文章

Unity3D 计时器的实现代码(三种写法总结)

unity AudioSource播放完声音后要执行的函数或条件操作

Unity 实现给物体替换材质球

unity中camera摄像头控制详解

欧拉角的万向节死锁问题

原生实现C#与Lua相互调用方法(Unity3D可用)

unity推荐文章

[Unity] Dreamteck Splines实现沿路径移动功能

[Unity] 实现AssetBundle资源加载管理器

扩展实现Unity协程的完整栈跟踪

iOS使用Unity容器动态加载3D模型

【Unity3D】Unity与Android交互

Unity学习笔记--数据持久化之PlayerPrefs的使用

循序渐进介绍基于CommunityToolkit.Mvvm 和HandyControl的WPF应用端开发(12) -- 使用代码生成工具Database2Sharp生成WPF界面代码

循序渐进介绍基于CommunityToolkit.Mvvm 和HandyControl的WPF应用端开发(11) -- 下拉列表的数据绑定以及自定义系统字典列表控件

【Unity3D】UI Toolkit样式选择器

【Unity3D】UI Toolkit容器