Unity C# Scoket Thread

关于 Scoket和Thread 也没什么要说的，网上有很多资料。但是需要注意的是 Scoket和Thread 都需要创建和杀死。不然一定会造成程序假死。好了上代码

服务器：

using System;
using System.Collections;
using System.Collections.Generic;
using System.IO;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;
using UnityEngine;

public class TCPTestServer : MonoBehaviour
{
    #region private members     
    /// <summary>     
    /// 服务器监听连接    
    /// </summary>     
    private TcpListener tcpListener;
    /// <summary> 
    /// 服务器监听线程
    /// </summary>     
    private Thread tcpListenerThread;
    /// <summary>     
    /// 创建连接上的客户端
    /// </summary>     
    private TcpClient connectedTcpClient;
    #endregion

    // Use this for initialization
    void Start()
    {
        // 启动服务器监听线程        
        tcpListenerThread = new Thread(new ThreadStart(ListenForIncommingRequests));
        tcpListenerThread.IsBackground = true;
        tcpListenerThread.Start();
    }

    // Update is called once per frame
    void Update()
    {
        // 服务器发送测试数据
        if (Input.GetKeyDown(KeyCode.R))
        {
            Debug.Log("R");
            SendMessage();
        }

        if (Input.GetKeyDown(KeyCode.Escape))
        {
            Debug.Log("Escape Server");
            Close();
            Application.Quit();
        }
    }

    /// <summary>     
    /// 服务器监听
    /// </summary>     
    private void ListenForIncommingRequests()
    {
        try
        {
            // 创建监听端口
            tcpListener = new TcpListener(IPAddress.Parse("127.0.0.1"), 8052);
            tcpListener.Start();
            Debug.Log("Server is listening");
            Byte[] bytes = new Byte[1024];
            while (true)
            {
                using (connectedTcpClient = tcpListener.AcceptTcpClient())
                {                
                    using (NetworkStream stream = connectedTcpClient.GetStream())
                    {
                        int length;                        
                        while ((length = stream.Read(bytes, 0, bytes.Length)) != 0)
                        {
                            var incommingData = new byte[length];
                            Array.Copy(bytes, 0, incommingData, 0, length);                            
                            string clientMessage = Encoding.Unicode.GetString(incommingData);
                            Debug.Log("客户端: " + clientMessage);
                        }
                    }
                }
            }
        }
        catch (SocketException socketException)
        {
            Debug.Log("SocketException " + socketException.ToString());
        }
    }
    /// <summary>     
    /// Send message to client using socket connection.     
    /// </summary>     
    private void SendMessage()
    {
        if (connectedTcpClient == null)
        {
            return;
        }

        try
        {
            // Get a stream object for writing.             
            NetworkStream stream = connectedTcpClient.GetStream();
            if (stream.CanWrite)
            {
                string serverMessage = "小畜生";
                byte[] serverMessageAsByteArray = Encoding.Unicode.GetBytes(serverMessage);
                stream.Write(serverMessageAsByteArray, 0, serverMessageAsByteArray.Length);
            }
        }
        catch (SocketException socketException)
        {
            Debug.Log("Socket exception: " + socketException);
        }
    }

    private void OnApplicationQuit()
    {
        Close();
    }

    private void OnDestroy()
    {
        Close();
    }

    // 关闭TCP连接和线程，防止程序假死
    void Close()
    {
        if (tcpListenerThread != null)
        {
            tcpListenerThread.Interrupt();
            tcpListenerThread.Abort();
        }

        if(null != tcpListener)
        {
            tcpListener.Stop();
        }

        if(null != connectedTcpClient)
        {
            connectedTcpClient.Close();
        }
    }
}

客户端：

using System;
using System.Collections;
using System.Collections.Generic;
using System.Net.Sockets;
using System.Text;
using System.Threading;
using UnityEngine;
using UnityEngine.UI;
using Newtonsoft.Json;
using System.IO;

public class TCPTestClient : MonoBehaviour
{
    #region private members     
    private TcpClient socketConnection;
    private Thread clientReceiveThread;
    #endregion
    // Use this for initialization     
    void Start()
    {
        
    }
    // Update is called once per frame
    void Update()
    {
        // 连接服务器
        if (Input.GetKeyDown(KeyCode.Q))
        {
            Debug.Log("Q");
            ConnectToTcpServer();
        }

        // 发送消息到服务器
        if (Input.GetKeyDown(KeyCode.Space))
        {
            Debug.Log("Space");
            SendMessage();
        }

        if (Input.GetKeyDown(KeyCode.Escape))
        {
            Debug.Log("Escape Client");
            Close();
            Application.Quit();
        }

    }
    /// <summary>     
    /// 连接服务器    
    /// </summary>     
    private void ConnectToTcpServer()
    {
        try
        {
            clientReceiveThread = new Thread(new ThreadStart(ListenForData));
            clientReceiveThread.IsBackground = true;
            clientReceiveThread.Start();
        }
        catch (Exception e)
        {
            Debug.Log("On client connect exception " + e);
        }
    }
    /// <summary>     
    /// 接受服务器消息
    /// </summary>     
    private void ListenForData()
    {
        try
        {
            socketConnection = new TcpClient("localhost", 8052);
            Byte[] bytes = new Byte[1024];
            while (true)
            {
                // Using 用完就会销毁            
                using (NetworkStream stream = socketConnection.GetStream())
                {
                    int length;
                    while ((length = stream.Read(bytes, 0, bytes.Length)) != 0)
                    {
                        var incommingData = new byte[length];
                        Array.Copy(bytes, 0, incommingData, 0, length);
                        string serverMessage = Encoding.Unicode.GetString(incommingData);
                        Debug.Log("服务器: " + serverMessage);                                  
                    }
                }
            }
        }
        catch (SocketException socketException)
        {
            Debug.Log("Socket exception: " + socketException);
        }
    }
    /// <summary>     
    /// 发送数据    
    /// </summary>     
    private void SendMessage()
    {
        if (socketConnection == null)
        {
            return;
        }
        try
        {        
            NetworkStream stream = socketConnection.GetStream();
            if (stream.CanWrite)
            {
                string clientMessage = "小妖精";
                byte[] clientMessageAsByteArray = Encoding.Unicode.GetBytes(clientMessage);
                stream.Write(clientMessageAsByteArray, 0, clientMessageAsByteArray.Length);
            }
        }
        catch (SocketException socketException)
        {
            Debug.Log("Socket exception: " + socketException);
        }
    }

    public void CreatePagoda(string str)
    {
        ModelCreate.modelDelegate(str);
    }

    private void OnApplicationQuit()
    {
        Close();
    }

    private void OnDestroy()
    {
        Close();
    }

    // 关闭TCP连接和线程，防止程序假死
    void Close()
    {
        if (null != clientReceiveThread)
        {
            clientReceiveThread.Interrupt();
            clientReceiveThread.Abort();            
        }
        if (null != socketConnection)
        {
            socketConnection.Close();
        }
    }
}