GHZLangChao/Assets/LangChaoRTC/MediaSoup/Scripts/Tcp/TServerC.cs

using UnityEngine;
using System.Collections;
//引入库
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;
using LitJson;

public class TServerC 
{
    public TServer ts;
    public int id;
    public Socket _socket;
    Thread connectThread; //连接线程
    byte[] recvData;
    byte[] sendData;
    int recvLen;
    string recvStr;
    string sname;

    bool isSpeak = false;
    bool isMute = false;

    public JsonData getInfo()
    {
        JsonData data = new JsonData();
        data["nickname"] = sname;
        data["socketId"] = id;
        data["canSpeek"] = isMute;
        data["isSpeak"] = isSpeak;
        return data;
    }

    public void init()
    {
        //开启一个线程连接，必须的，否则主线程卡死
        connectThread = new Thread(new ThreadStart(SocketReceive));
        connectThread.Start();
    }
    public static int bytes2Int(byte[] b)
    {
        int i0 = b[0] & 0xFF; //将最后的8位转给了int类型的最后的8位
        int i1 = (b[1] & 0xFF) << 8; //我们之所以先与 0xFF 不能直接 或运算，因为在进行运算时，会转为int类型，32位。如果是负数，前面就会补位全为1.也就不能算出正确的值了。所以，我们先与 （前面会有24个0）11111111，让高位保持为0.以保证后面运算的正确性
        int i2 = (b[2] & 0xFF) << 16;
        int i3 = (b[3] & 0xFF) << 24;
        return i0 | i1 | i2 | i3;
    }
    //服务器接收
    void SocketReceive()
    {
        while (true)
        {
            byte[] recvBytes = new byte[4];
            int bodyLength = _socket.Receive(recvBytes, 0, recvBytes.Length, SocketFlags.None);
            int baotou = bytes2Int(recvBytes);

            Debug.Log("准备接收==>" + baotou);
            //对data清零
            recvData = new byte[baotou];
            //获取收到的数据的长度
            recvLen = 0;

            while (recvLen != recvData.Length)
            {
              //  Debug.Log("准备接收==>" + recvLen);
                recvLen += _socket.Receive(recvData, recvLen, recvData.Length - recvLen, SocketFlags.None);
              //  Debug.Log("server 接收到Client 长度==>" + recvLen);
            }
            //如果收到的数据长度为0，则重连并进入下一个循环
            if (recvLen == 0)
            {
                _socket.Close();
                ts.clientSockets.Remove(this);
                Debug.Log("Client==>" + id +"断开连接=====》");
                // SocketConnet();
                break ;
            }
            //输出接收到的数据
            recvStr = Encoding.ASCII.GetString(recvData, 0, recvLen);
            //将接收到的数据经过处理再发送出去
            // sendStr = "From Server: " + recvStr;
            //SocketSend(sendStr);
            Debug.Log("server 接收到Client==>" + id + "的信息=====》"+ recvStr);
            JsonData data = JsonMapper.ToObject(recvStr) ;
            messageData(data);
        }
    }


             
    public void messageData(JsonData data)
    {
        TServerC tsc;
        JsonData fdata;
        switch (data["action"].ToString())
        {
            case "LoginByToken":
                sname = data["data"]["token"].ToString();
                break;
            case "CreateRoom":
                ts.ownerName = id.ToString();
                fdata = new JsonData();
                fdata["type"] = "Room";
                fdata["data"] = new JsonData();
                fdata["data"]["method"] = "Create";
                fdata["data"]["roomId"] = "0001";
                fdata["data"]["ownerName"] = ts.ownerName;

                fdata["data"]["RoomUserList"] = ts.getRoomList(id);
                fdata["data"]["message"] = "创建房间成功";
                ts.SocketSend(fdata.ToJson(), -1);
                break;
            case "JoinRoom":
                fdata = new JsonData();
                fdata["type"] = "Room";
                fdata["data"] = new JsonData();
                fdata["data"]["method"] = "UserJoin";
                fdata["data"]["roomId"] = "0001";
                fdata["data"]["socketId"] = id;
                fdata["data"]["nickname"] = id;
                fdata["data"]["message"] = "用户进入房间";
                ts.SocketSend(fdata.ToJson(), id);

                fdata = new JsonData();
                fdata["type"] = "Room";
                fdata["data"] = new JsonData();
                fdata["data"]["method"] = "Join";
                fdata["data"]["roomId"] = "0001";
                fdata["data"]["roomName"] = "0001";
                fdata["data"]["ownerName"] = ts.ownerName;
                fdata["data"]["RoomUserList"] = ts.getRoomList(id);
                fdata["data"]["message"] = "进入房间";
                SocketSend(fdata.ToJson());

                break;
            case "LeaveRoom":
                fdata = new JsonData();
                fdata["type"] = "UserLogout";
                fdata["data"] = new JsonData();
                fdata["data"]["socketId"] = id;
                fdata["data"]["nickname"] = id;
                fdata["data"]["message"] = "用户登出";
                ts.SocketSend(fdata.ToJson(), -1);
                _socket.Close();
                ts.clientSockets.Remove(this);
                break;
            case "IceCandidate":
                tsc = ts.getRoomSocketById(int.Parse(data["data"]["socketId"].ToString()));
                fdata = new JsonData();
                fdata["type"] = "IceCandidate";
                fdata["data"] = new JsonData();
                fdata["data"]["method"] = "IceCandidate";
                fdata["data"]["label"] = data["data"]["label"].ToString();
                fdata["data"]["candidate"] = data["data"]["candidate"].ToString();
                fdata["data"]["id"] = data["data"]["id"].ToString();
                fdata["data"]["socketId"] = id;
                tsc.SocketSend(fdata.ToJson());
                break;
            case "Offer":
                tsc = ts.getRoomSocketById(int.Parse(data["data"]["socketId"].ToString()));
                fdata = new JsonData();
                fdata["type"] = "Offer";
                fdata["data"] = new JsonData();
                fdata["data"]["method"] = "Offer";
                fdata["data"]["sdp"] = data["data"]["sdp"];
                fdata["data"]["socketId"] = id;
                tsc.SocketSend(fdata.ToJson());
                break;
            case "Answer":
                tsc = ts.getRoomSocketById(int.Parse(data["data"]["socketId"].ToString()));
                fdata = new JsonData();
                fdata["type"] = "Answer";
                fdata["data"] = new JsonData();
                fdata["data"]["method"] = "Answer";
                fdata["data"]["sdp"] = data["data"]["sdp"];
                fdata["data"]["socketId"] = id;
                tsc.SocketSend(fdata.ToJson());
                break;
            case "sendInfo":
                fdata = new JsonData();
                fdata["type"] = "Room";
                fdata["data"] = new JsonData();
                fdata["data"]["method"] = "sendInfo";
                fdata["data"]["roomList"] = data["data"]["info"].ToString();
                fdata["data"]["message"] = "用户进入房间";
                ts.SocketSend(fdata.ToJson(), id);
                break;
            case "csj":
                fdata = new JsonData();
                fdata["type"] = "Room";
                fdata["data"] = new JsonData();
                fdata["data"]["method"] = "csj";
                fdata["data"]["roomList"] = data["data"]["info"].ToString();
                ts.SocketSend(fdata.ToJson(), id);
                break;
            case "firstView":
                fdata = new JsonData();
                fdata["type"] = "View";
                fdata["data"] = new JsonData();
                fdata["data"]["method"] = "firstView";
                fdata["data"]["pose"] = data["data"]["info"].ToString();
                ts.SocketSend(fdata.ToJson(), id);
                break;
            case "thirdView":
                fdata = new JsonData();
                fdata["type"] = "View";
                fdata["data"] = new JsonData();
                fdata["data"]["method"] = "thirdView";
                fdata["data"]["pose"] = data["data"]["info"].ToString();
                ts.SocketSend(fdata.ToJson(), id);
                break;

        }

    }

   public void SocketSend(string sendStr)
    {
        //清空发送缓存
        sendData = new byte[1024];
        //数据类型转换
        sendData = Encoding.ASCII.GetBytes(sendStr);
        byte[] bb = TClient.int2Bytes(sendData.Length);
        _socket.Send(bb, bb.Length, SocketFlags.None);
        Debug.Log("Client发送的信息给服务器=====》长度" + sendData.Length);
        //发送
        _socket.Send(sendData, sendData.Length, SocketFlags.None);
        Debug.Log("server 向Client==>" + id + "发送的信息=====》" + sendStr);
    }

}