GHZMRSpace/Assets/GHZAlter/NetWorkLAN/client.cs

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

using System.Threading;
using UnityEngine;
using UnityEngine.UI;
using BeinLab.Util;
using UnityEngine.Networking;

public class client : MonoBehaviour
{
    private string staInfo = "NULL";             //状态信息
    private string inputIp = "192.168.50.140";   //输入ip地址
    private string inputPort = "18180";           //输入端口号
    public string Message = "NULL";             //发送的消息
    private int recTimes = 0;                    //接收到信息的次数
    private string recMes = "NULL";              //接收到的消息
    private Socket socketSend;                   //客户端套接字，用来链接远端服务器
    private bool clickSend = false;              //是否点击发送按钮

    private bool isConnect = true;
    private float times = 0;
    private string ipPath;
    public Queue<String> queueRecMsg;
    void Start()
    {
        ipPath = Application.persistentDataPath + "/Ipconfig/" + "ip.txt";
        Debug.Log(ipPath);
       StartCoroutine(  SettingIP());
        // ClickConnect();

        TimerMgr.Instance.CreateTimer(()=> { SendData(); }, 0.1f, -1);
        queueRecMsg = new Queue<string>();

    }

    void Update()
    {
        if(!isConnect)
        {
            times += Time.deltaTime;
            if(times>3f)
            {
                times = 0;
                ClickConnect();
            }
        }
    }

    IEnumerator  SettingIP()
    {
        yield return new WaitForSeconds(0.2f);
        if (File.Exists(ipPath))
        {
            //Debug.Log("ipPath "+ ipPath);
            //var webRequest = UnityWebRequest.Get(ipPath);
            //yield return webRequest.SendWebRequest();
            //if (webRequest.error != null)
            //{

            //    Debug.LogError(webRequest.error);
            //}
            //else
            //{
            //    while (!webRequest.isDone)
            //    {                 
            //        yield return 0;
            //    }
            //    if (webRequest.isDone)
            //    {

            //        byte[] bytes = webRequest.downloadHandler.data;
            //        Debug.Log("  DownLoad OK " + ipPath);

            //        Debug.Log(webRequest.downloadHandler.data.Length);
            //        // if (!File.Exists(Application.dataPath + "/Resources/YourVideoName.mp4"))
            //        inputIp = System.Text.Encoding.Default.GetString(webRequest.downloadHandler.data);
            //        Debug.Log(inputIp);
            //        ClickConnect();
            //    }
            //}
            FileStream fileStream = new FileStream(ipPath, FileMode.Open, FileAccess.Read);
            fileStream.Seek(0, SeekOrigin.Begin);
            //创建文件长度缓冲区
            byte[] bytes = new byte[fileStream.Length];
         
            //读取文件
            fileStream.Read(bytes, 0, (int)fileStream.Length);
            Debug.Log("  bytes   " + bytes.Length);
            //释放文件读取流
            fileStream.Close();
            fileStream.Dispose();
            fileStream = null;

            inputIp = System.Text.Encoding.Default.GetString(bytes);
            Debug.Log(inputIp);
            ClickConnect();

        }
        else
        {
            Directory.CreateDirectory(Application.persistentDataPath + "/Ipconfig");
            FileInfo fileInfo = new FileInfo(ipPath);
            //设置Log文件输出地址
            FileStream FileWriter = fileInfo.Open(FileMode.Create, FileAccess.ReadWrite, FileShare.Read);
            UTF8Encoding encoding = new UTF8Encoding();
            FileWriter.Write(encoding.GetBytes("192.168.50.17"), 0, encoding.GetByteCount("192.168.50.17"));
            FileWriter.Close();
            Application.Quit();
           
        }
    }

    //建立链接
    private void ClickConnect()
    {
        Debug.Log("ClickConnect");
      
        isConnect = true;
        try
        {
            int _port = Convert.ToInt32(inputPort);             //获取端口号
            string _ip = inputIp;                               //获取ip地址
            Debug.Log("ClickConnect1 "+ _ip+ _port);
            if (inputIp == null)
                return;
            //创建客户端Socket，获得远程ip和端口号
            socketSend = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            IPAddress ip = IPAddress.Parse(_ip);
            IPEndPoint point = new IPEndPoint(ip, _port);
            Debug.Log("ClickConnect2");
            socketSend.Connect(point);
            Debug.Log("连接成功 , " + " ip = " + ip + " port = " + _port);
            staInfo = ip + ":" + _port + "  连接成功";

            Thread r_thread = new Thread(Received);             //开启新的线程，不停的接收服务器发来的消息
            r_thread.IsBackground = true;
            r_thread.Start();

            Thread s_thread = new Thread(SendMessage);          //开启新的线程，不停的给服务器发送消息
            s_thread.IsBackground = true;
            s_thread.Start();
        }
        catch (Exception e)
        {
            Debug.LogError(e.ToString());
            Debug.Log("IP或者端口号错误......");
            staInfo = "IP或者端口号错误......";
            isConnect = false;
        }
    }

    /// <summary>
    /// 接收服务端返回的消息
    /// </summary>
    void Received()
    {
        while (true)
        {
            try
            {
                byte[] buffer = new byte[1024 * 6];
                //实际接收到的有效字节数
                int len = socketSend.Receive(buffer);
                if (len == 0)
                {
                   // isConnect = false;
                    break;
                }

                recMes = Encoding.UTF8.GetString(buffer, 0, len);

                Debug.Log("客户端接收到的数据 ： " + recMes);

                recTimes++;
                staInfo = "接收到一次数据，接收次数为 ：" + recTimes;
               // Debug.Log("接收次数为：" + recTimes);
                queueRecMsg.Enqueue(recMes);
               
            }
            catch { }
        }
    }

    public void SendData()
    {
        Debug.Log("sendData");
        if (socketSend!=null&&SocketExtensions.IsConnected(socketSend))
        {
            if(NetWorkLANManager.Instance.createDesMsg.Count>0)
            {
                Message = NetWorkLANManager.Instance.createDesMsg.Dequeue();
                clickSend = true;
                return;
            }
            if(NetWorkLANManager.Instance.queueMsg.Count>0)
            {
                Message = NetWorkLANManager.Instance.queueMsg.Dequeue();
                clickSend = true;
            }
        }
    }

    /// <summary>
    /// 向服务器发送消息
    /// </summary>
    /// <param name="sender"></param>
    /// <param name="e"></param>
    void SendMessage()
    {
        try
        {
            while (true)
            {
                if (clickSend)                              //如果点击了发送按钮
                {
                    clickSend = false;
                    if (socketSend.Connected)
                    {
                        byte[] buffer = new byte[1024 * 6];
                        buffer = Encoding.UTF8.GetBytes(Message);
                        socketSend.Send(buffer);
                       // Debug.Log("发送的数据为：" + Message);
                    }
                    else
                    {
                        isConnect = false;
                    }
                   
                }
            }
        }
        catch { }
    }


    private void OnDisable()
    {
        Debug.Log("begin OnDisable()");

        if (socketSend.Connected)
        {
            try
            {
                socketSend.Shutdown(SocketShutdown.Both);    //禁用Socket的发送和接收功能
                socketSend.Close();                          //关闭Socket连接并释放所有相关资源
            }
            catch (Exception e)
            {
                print(e.Message);
            }
        }

        Debug.Log("end OnDisable()");
    }

    //用户界面
    //void OnGUI()
    //{
    //    //GUI.color = Color.black;

    //    //GUI.Label(new Rect(65, 10, 60, 20), "状态信息");

    //    //GUI.Label(new Rect(135, 10, 80, 60), staInfo);

    //    //GUI.Label(new Rect(65, 70, 50, 20), "服务器ip地址");

    //    //inputIp = GUI.TextField(new Rect(125, 70, 100, 20), inputIp, 20);

    //    //GUI.Label(new Rect(65, 110, 50, 20), "服务器端口");

    //    //inputPort = GUI.TextField(new Rect(125, 110, 100, 20), inputPort, 20);

    //    //GUI.Label(new Rect(65, 150, 80, 20), "接收到消息：");

    //    //GUI.Label(new Rect(155, 150, 80, 20), recMes);

    //    //GUI.Label(new Rect(65, 190, 80, 20), "发送的消息：");

    //    //Message = GUI.TextField(new Rect(155, 190, 100, 20), Message, 20);

    //    //if (GUI.Button(new Rect(65, 270, 300, 100), "发送信息"))
    //    //{
    //    //    clickSend = true;
    //    //}
    //}
}