Unity實現局域網聊天室功能

基於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;

}

總結:第一次寫學習博,還有很多地方要學習啊。

留待解決的問題:此聊天室隻能用於局域網以內,廣域網就無法實現通信瞭,還要看看怎麼實現遠程的一個通信,不然這個就沒有存在的意義瞭。

以上就是本文的全部內容,希望對大傢的學習有所幫助,也希望大傢多多支持WalkonNet。

推薦閱讀: