unity使用socket通訊

認識socket

在計算機通信領域，socket 被翻譯為“套接字”，它是計算機之間進行通信的一種約定或一種方式。通過 socket 這種約定，一台計算機可以接收其他計算機的數據，也可以向其他計算機發送數據socket起源於Unix，而Unix/Linux基本哲學之一就是“一切皆文件”，都可以用“打開open –> 讀寫write/read –> 關閉close”模式來操作。我的理解就是Socket就是該模式的一個實現：即socket是一種特殊的文件，一些socket函數就是對其進行的操作（讀/寫IO、打開、關閉）。Socket()函數返回一個整型的Socket描述符，隨后的連接建立、數據傳輸等操作都是通過該Socket實現的。

實現socket通訊，需要兩個部分才能進行數據通訊。

1，客戶端請求連接

2，服務器響應

 

服務端

using System.Collections;
using System.Collections.Generic;
using UnityEngine;
using System.Net.Sockets;//需要引用socket命名空間
using System.Net;
using System.Linq;
using System.Text;
using System.Threading;

public class net : MonoBehaviour
{
    // Start is called before the first frame update
    void Start()
    {
        openServer();
    }

    // Update is called once per frame
    void Update()
    {

    }

    /// <summary>
    /// 打開鏈接
    /// </summary>
    void openServer()
    {
        try
        {
            IPAddress pAddress = IPAddress.Parse("127.0.0.1");
            IPEndPoint pEndPoint = new IPEndPoint(pAddress, 52315);
            Socket socket_server = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            socket_server.Bind(pEndPoint);
            socket_server.Listen(5);//設置最大連接數
            Debug.Log("監聽成功");
 37　　　　　　　　//創建新線程執行監聽，否則會阻塞UI，導致unity無響應
            Thread thread = new Thread(listen);
            thread.IsBackground = true;
            thread.Start(socket_server);
        }
        catch (System.Exception)
        {

            throw;
        }
    }
　　 /// <summary>
    /// 監聽
    /// </summary>
    Socket socketSend;
    void listen(object o)
    {
        try
        {
            Socket socketWatch = o as Socket;
            while (true)
            {
                socketSend = socketWatch.Accept();
                Debug.Log(socketSend.RemoteEndPoint.ToString() + ":" + "連接成功");

                Thread r_thread = new Thread(Received);
                r_thread.IsBackground = true;
                r_thread.Start(socketSend);
            }
        }
        catch (System.Exception)
        {

            throw;
        }
    }
 73　　  /// <summary>
    /// 獲取消息
    /// </summary>
    /// <param name="o"></param>
    void Received(object o)
    {
        try
        {
            Socket socketSend = o as Socket;
            while (true)
            {
                byte[] buffer = new byte[1024];
                int len = socketSend.Receive(buffer);
                if (len == 0) break;
                string str = Encoding.UTF8.GetString(buffer, 0, len);
                Debug.Log("服務器打印客戶端返回消息：" + socketSend.RemoteEndPoint + ":" + str);
                Send("我收到了");
            }
        }
        catch (System.Exception)
        {

            throw;
        }
    }
　　 /// <summary>
    /// 發送消息
    /// </summary>
    /// <param name="msg"></param>
    void Send(string msg)
    {
        byte[] buffer = Encoding.UTF8.GetBytes(msg);
        socketSend.Send(buffer);
    }
}

 

客戶端

using UnityEngine;
using UnityEngine.UI;
using System.Net;
using System.Net.Sockets;//引入socket命名空間
using System.Threading;
using System.Text;
using UnityEngine.SceneManagement;

public class net : MonoBehaviour
{
    //添加兩個按鈕用於發送數據和關閉連接
    public Button sen;
    public Button col;
    //輸入文本
    public InputField inputText;
    // Start is called before the first frame update
    void Start()
    {
        sen.onClick.AddListener(send_smg);//發送
        col.onClick.AddListener(close_btnClick);//關閉
    }

    // Update is called once per frame
    void Update()
    {

    }

    public void send_smg()
    {
        Send(inputText.text);
    }
    public void close_btnClick()
    {
        close();
    }

 　　/// <summary>
    /// 連接服務器
    /// </summary>
    static Socket socket_client;
    public static void ConnectServer()
    {
        try
        {
            IPAddress pAddress = IPAddress.Parse("127.0.0.1");
            IPEndPoint pEndPoint = new IPEndPoint(pAddress, 52315);
            socket_client = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            socket_client.Connect(pEndPoint);
            Debug.Log("連接成功");
            //創建線程，執行讀取服務器消息
            Thread c_thread = new Thread(Received);
            c_thread.IsBackground = true;
            c_thread.Start();
        }
        catch (System.Exception)
        {

            Debug.Log("IP端口號錯誤或者服務器未開啟");
        }
    }

　　 /// <summary>
    /// 讀取服務器消息
    /// </summary>
    public static void Received()
    {
        while (true)
        {
            try
            {
                byte[] buffer = new byte[1024];
                int len = socket_client.Receive(buffer);
                if (len == 0) break;
                string str = Encoding.UTF8.GetString(buffer, 0, len);
                Debug.Log("客戶端打印服務器返回消息：" + socket_client.RemoteEndPoint + ":" + str);
            }
            catch (System.Exception)
            {

                throw;
            }

        }
    }
 　　/// <summary>
    /// 發送消息
    /// </summary>
    /// <param name="msg"></param>
    public static void Send(string msg)
    {
        try
        {
            byte[] buffer = new byte[1024];
            buffer = Encoding.UTF8.GetBytes(msg);
            socket_client.Send(buffer);
        }
        catch (System.Exception)
        {

            Debug.Log("未連接");
        }
    }
　　 /// <summary>
    /// 關閉連接
    /// </summary>
    public static void close()
    {
        try
        {
            socket_client.Close();
            Debug.Log("關閉客戶端連接");
            SceneManager.LoadScene("control");
        }
        catch (System.Exception)
        {
            Debug.Log("未連接");
        }
    }
}

 

將服務器腳本和客戶端腳本分別掛載在各自對應unity對象上即可實現socket tcp連接通訊。