今天跟大家繼續學習下socket，由於最近有個招標引數需要給之前的一款產品做教師端以及後臺資料庫部分，忙了將近兩個禮拜，今天剛釋出了，就繼續我們的socket通訊部分。

         之前服務端一直在VS中去做，考慮到後面客戶端與伺服器一體化，就把服務端也在unity中實現了，需要注意的一點是，由於服務端中包含阻塞方法，而unity所有指令碼都只在僅存的一個主執行緒中執行，所以如果直接在start中呼叫啟動伺服器的方法，unity會直接卡死的，所以我們就自己起一個執行緒去搞服務端部分，unity中起執行緒後要清楚兩點：

1、monoBehavior類中的方法儘量別用了，會出現不可預知的

2、自己起的執行緒，系統不會摻和，自己找個合適的地方再把他kill掉。

         下面的程式碼是在程式結束時殺掉執行緒，想起以前老謝給我講的，起執行緒就像拉屎，完事一定要記得自己擦，系統不會給你擦，經測試不擦第二次啟動unity會無響應。

這一次程式碼裡簡單實現了從客戶端傳送一個字串的包到服務端，服務端接收後並打印出來，程式碼全部貼出來：

1、服務端部分：

using UnityEngine;
using System.Collections;

using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;
using System;
/// <summary>
/// scoket伺服器監聽埠指令碼
/// </summary>
public class SocketServer : MonoBehaviour
{

    private Thread thStartServer;//定義啟動socket的執行緒
    void Start()
    {
        thStartServer = new Thread(StartServer);
        thStartServer.Start();//啟動該執行緒
    }

    void Update()
    {
    }

    private void StartServer()
    {
        const int bufferSize = 8792;//快取大小,8192位元組
        IPAddress ip = IPAddress.Parse("192.168.0.13");

        TcpListener tlistener = new TcpListener(ip, 10001);
        tlistener.Start();
        Debug.Log("Socket伺服器監聽啟動......");

        TcpClient remoteClient = tlistener.AcceptTcpClient();//接收已連線的客戶端,阻塞方法
        Debug.Log("客戶端已連線！local:" + remoteClient.Client.LocalEndPoint + "<---Client:" + remoteClient.Client.RemoteEndPoint);
        NetworkStream streamToClient = remoteClient.GetStream();//獲得來自客戶端的流
        do
        {
            try  //直接關掉客戶端，伺服器端會丟擲異常
            {
                //接收客戶端傳送的資料部分
                byte[] buffer = new byte[bufferSize];//定義一個快取buffer陣列
                int byteRead = streamToClient.Read(buffer, 0, bufferSize);//將資料搞入快取中（有朋友說read()是阻塞方法，測試中未發現程式阻塞）
                if (byteRead == 0)//連線斷開，或者在TCPClient上呼叫了Close()方法，或者在流上呼叫了Dispose()方法。
                {
                    Debug.Log("客戶端連線斷開......");
                    break;
                }

                string msg = Encoding.Unicode.GetString(buffer, 0, byteRead);//從二進位制轉換為字串對應的客戶端會有從字串轉換為二進位制的方法
                Debug.Log("接收資料：" + msg + ".資料長度:[" + byteRead + "byte]");
            }
            catch(Exception ex)
            {
                Debug.Log("客戶端異常："+ex.Message);
                break;
            }
        }
        while (true);
    }

    void OnApplicationQuit()
    {
        thStartServer.Abort();//在程式結束時殺掉執行緒，想起以前老謝給我講的，起執行緒就像拉屎，完事一定要記得自己擦，系統不會給你擦，經測試不擦第二次啟動unity會無響應
    }


}
 

2、客戶端部分：

using UnityEngine;
using System.Collections;

using System.Net;
using System.Net.Sockets;
using System;
using System.Text;

public class SocketClient : MonoBehaviour
{

    void Start()
    {

    }

    void Update()
    {
        if (Input.GetKeyDown(KeyCode.Alpha1))
        {
            Client();
        }
        if (Input.GetKeyDown(KeyCode.Alpha2))
        {
            SimulateMultiUserClient();
        }
    }
    TcpClient client;
    private void Client()
    {
        client = new TcpClient();
        try
        {
            client.Connect(IPAddress.Parse("192.168.0.13"), 10001);//同步方法，連線成功、丟擲異常、伺服器不存在等之前程式會被阻塞
        }
        catch (Exception ex)
        {
            Debug.Log("客戶端連線異常：" + ex.Message);
        }
        Debug.Log("LocalEndPoint = " + client.Client.LocalEndPoint + ". RemoteEndPoint = " + client.Client.RemoteEndPoint);

        //客戶端傳送資料部分
        for (int i = 0; i < 2; i++)
        {
            try
            {
                string msg = "hello server i am No " + i;
                NetworkStream streamToServer = client.GetStream();//獲得客戶端的流
                byte[] buffer = Encoding.Unicode.GetBytes(msg);//將字串轉化為二進位制
                streamToServer.Write(buffer, 0, buffer.Length);//將轉換好的二進位制資料寫入流中併發送
                Debug.Log("發出訊息：" + msg);
            }
            catch(Exception ex)
            {
                Debug.Log("服務端產生異常："+ex.Message);
            }
        }
    }

    private void SimulateMultiUserClient()
    {
        for (int i = 0; i < 2; i++)
        {
            client = new TcpClient();
            try
            {
                client.Connect(IPAddress.Parse("192.168.0.13"), 10001);//連線到伺服器端
            }
            catch (Exception ex)//丟擲連線錯誤的異常
            {
                Debug.Log("客戶端連線異常：" + ex.Message);
            }
            Debug.Log("LocalEndPoint = " + client.Client.LocalEndPoint + ". RemoteEndPoint = " + client.Client.RemoteEndPoint);
            //客戶端傳送資料部分
            string msg = "hello server i am No " + i;
            NetworkStream streamToServer = client.GetStream();//獲得客戶端的流
            byte[] buffer = Encoding.Unicode.GetBytes(msg);//將字串轉化為二進位制
            streamToServer.Write(buffer, 0, buffer.Length);//將轉換好的二進位制資料寫入流中併發送
            Debug.Log("發出訊息：" + msg);
        }
    }

    private void SendMsgToServer(string content)
    {

    }
}