网络

TCP:与打电话类似,通知服务到位

UDP:与发短信类似,消息发出即可

IP和端口号是网络两大重要成员

端口号(Port)分为知名端口号[0-1024,不开放)和动态端口号[1024,10000多,开放可用)

三次握手,四次挥手:

unity网端简单案例:

分为:综合管理部分、客户端和服务器

需要Socket作为媒介来进行交互

见代码:

一、综合管理部分:

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

//综合管理部分
// 可以供客户端和服务器一块使用
public class TcpSocket
{
   private Socket socket;//当前实例化的套接字
   private byte[] data;//socket上的数据  
   private bool isServer; //用来区分服务器  还是客户端

//构造TcpSocket
   public TcpSocket(Socket socket,int dataLength, bool isServer)
   {
       this.socket = socket;
       data = new byte[dataLength];
       this.isServer = isServer;
   }  
// 接受----->客户端
   public void ClientReceive()
   {
       //data:数据缓存   0:接受位的偏移量  length
       socket.BeginReceive(data,0,data.Length,SocketFlags.None,new AsyncCallback(ClientEndReceive),null);
   }
   public void ClientEndReceive(IAsyncResult ar)
   {
       int receiveLength = socket.EndReceive(ar); //数据的处理      
       string dataStr = System.Text.Encoding.UTF8.GetString(data,0, receiveLength); //把接受完毕的字节数组转化为 string类型
       if (isServer)
       {  Debug.Log("服务器接受到了:" + dataStr);           
           for (int i = 0; i < Server.Instance.clients.Count; i++) //服务器要回什么
           {
               if (Server.Instance.clients[i].ClientConnect())
               {
                   Server.Instance.clients[i].ClientSeed(System.Text.Encoding.UTF8.GetBytes("服务器回复:"+ dataStr));
               }
           }
       }else {
           DataManager.Instance.Msg = dataStr;            
           Debug.Log("客户端接受到了:" + dataStr);
       }
   }


// 发送---->客户端发送给服务器
   public void  ClientSeed(byte[] data)
   {
       socket.BeginSend(data,0, data.Length, SocketFlags.None,new AsyncCallback(ClientSeedEnd),null );
   }

   private void ClientSeedEnd(IAsyncResult ar)
   {
       socket.EndSend(ar);
   }


//连接----客户端与服务器连接
   public void ClientConnect(string ip,int port)
   {
       socket.BeginConnect(new IPEndPoint(IPAddress.Parse(ip), port),new AsyncCallback(ClientEndConnect),null);
   }
   public void ClientEndConnect(IAsyncResult ar)
   {
       if (ar.IsCompleted) {
           Debug.Log("连接成功");
       }
       socket.EndConnect(ar);
   }

// 客户端与服务器是否连接

   public bool IsClientConnect()
   {
       return socket.Connected;
   }
//断开连接
   public void ClientClose()
   {
       if (socket!=null&& ISClientConnect())
       {
           socket.Close();
       }
   }

}
			

二、服务器部分:

注意:回调函数AcceptClient只有当服务器接受连接(连接成功了)才会被调用.

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

// 服务器

public class Server : MonoBehaviour {

   //单例服务器,继承Mono的
   private static Server instance;
   public static Server Instance
   {
       get {  return instance;  }
   }
   private void Awake()
   {
       instance = this;
   }
//------------------------------------------------------------------------
   private Socket server;//定义一个服务器
   public List<TcpSocket> clients;//所有连接的客户端
   private bool isLoopAccept = true;//是否循环接受客户端的请求
   
   void Start ()
   {
       //初始化服务器socket        协议族   
       server = new Socket(AddressFamily.InterNetwork,SocketType.Stream,ProtocolType.Tcp);       
       server.Bind(new IPEndPoint(IPAddress.Any,10086));//绑定端口号       
       server.Listen(100); //可以监听的客户端数目
//------------------------------------------------------------------------    
       //开辟一个线程      处理客户端连接请求  线程要暂停需用listenThread.Abort();
       Thread listenThread = new Thread(ReceiveClient);
       listenThread.Start(); //开启线程
       listenThread.IsBackground = true; //后台运行
//------------------------------------------------------------------------
       //初始化连接的客户端
       clients = new List<TcpSocket>();

   }

// 持续处理 接受客户端连接的请求  
   private void ReceiveClient()
   {
       while (isLoopAccept)
       {          
           server.BeginAccept(AcceptClient,null); //开始接受客户端连接请求            
           Debug.Log("检测客户端连接中.....");
           Thread.Sleep(1000);//每隔1s检测 有没有连接我            
       }       
   }
// 客户端连接成功之后回调
   private void AcceptClient(IAsyncResult ar)
   {
       //连接成功后处理该客户
      Socket client = server.EndAccept(ar);
      TcpSocket clientSocket = new TcpSocket(client,1024,true);
      clients.Add(clientSocket); 
      Debug.Log("连接成功");
   }
//关闭项目终止线程,停止服务器.
   private void OnApplicationQuit()
   {
       listenThread.Abort();
       listenThread.IsBackground = true;//关闭线程
   }
}
			

三、客户端部分:

			
using System.Collections;
using System.Collections.Generic;
using System.Net;
using System.Net.Sockets;
using System.Threading;
using System;
using UnityEngine;
using UnityEngine.UI;

//客户端
public class Client : MonoBehaviour {
    public InputField  input;
    public Text receiveText;

    TcpSocket tcpClient;
    Socket client;

    void Start () {
        //注册监听事件
        receiveText = GameObject.Find("ReceiveText").GetComponent<Text>();      
        
        tcpClient = new TcpSocket(client,1024,false);//初始化综合处理器
        client = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);//初始化客户端
    }              
    void Update () {
        if (tcpClient != null && tcpClient.IsClientConnect())//如果客户端不为空且客户端已连接
        {
            tcpClient.ClientReceive();//执行综合管理器中的ClientReceive()
        }
        receiveText.text = DataManager.Instance.Msg;
    }
    public void OnClickConnectBtn()//客户端向服务器开始连接输入(IP和端口号)按钮事件
    {
        if (!tcpClient.IsClientConnect())
        {
            tcpClient.ClientConnect("10.50.6.129",10086);
        }
    }
    public void OnClickToSendServer()//客户端向服务器发送文本消息按钮事件
    {
        if (tcpClient != null && tcpClient.IsClientConnect() && !String.IsNullOrEmpty(input.text))
        {
            tcpClient.ClientSeed(System.Text.Encoding.UTF8.GetBytes(input.text));
            input.text = "";
        }
    }
    private void OnApplicationQuit()//关闭项目,退出服务器连接
    {
        if (tcpClient != null && tcpClient.ClientConnect())
        {
            tcpClient.ClientClose();
        }
    }
    
}
			

栏目列表

首页 > Python基础教程 >

C#教程之unity网络----简单基础

网络