C#中Socket与Unity相结合示例代码

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


namespace Server
{
 /// 

 /// 对象池
 /// 
 public class Conn
 {
  //常量，用于表示传输的字节最大数量，最大接收的字节数
  public const int buffer_Size = 1024;

  //Socket
  public Socket socket;

  //是否连接
  public bool isUse = false;

  //传输数组，用来存储接受到的数据
  public byte[] readBuff = new byte[buffer_Size];


  public int buffCount = 0;

  /// 

  /// 构造函数
  /// 
  public Conn()
  {
   readBuff = new byte[buffer_Size];
  }

  /// 

  /// 初始化
  /// 
  /// 
  public void Init(Socket socket)
  {
   this.socket = socket;
   isUse = true;
   buffCount = 0;
  }

  /// 

  /// 缓冲区剩下的字节数
  /// 
  /// 
  public int BuffRemain()
  {
   return buffer_Size - buffCount;
  }

  /// 

  /// 获得客户端地址
  /// 
  /// 
  public string GetAdress()
  {
   if (!isUse)
   {
    return "无法获得地址";
   }
   else
   {
    return socket.RemoteEndPoint.ToString();
   }

  }

  /// 

  /// 关闭连接
  /// 
  public void Close()
  {
   if (!isUse)
   {
    return;

   }
   else
   {
    Console.WriteLine("断开连接" + GetAdress());
    socket.Close();
    isUse = false;
   }
  }
 }
}

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

namespace Server
{
 class Serv
 {
  //监听套接字
  public Socket listenfd;

  //客户端链接
  public Conn[] conns;

  //最大的连接数量
  public int maxCOnn= 50;

  //获取链接池索引，返回负数表示获取失败
  public int NewIndex()
  {
   if(cOnns==null)
   {
    return -1;
   }
   for (int i = 0; i 

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

public class net : MonoBehaviour
{
 //ip和端口
 public InputField hostInput;
 public InputField portInput;

 //显示客户端接受的消息
 public Text recvText;
 public string recvStr;

 //显示客户端IP和端口
 public Text clientText;

 //聊天输入框
 public InputField TextInput;

 Socket socket;

 const int buffer_Size = 1024;
 public byte[] readBuff = new byte[buffer_Size];


 void FixedUpdate()
 {
  recvText.text = recvStr;
 }


 //连接服务器（需要一个Button触发）
 public void Connetion()
 {
  recvText.text = "";

  socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);

  string host = hostInput.text;
  int port = int.Parse(portInput.text);

  socket.Connect(host, port);
  clientText.text = "客户端地址："+socket.LocalEndPoint.ToString();
  socket.BeginReceive(readBuff, 0, buffer_Size, SocketFlags.None, ReceiveCb,socket);

 }

 /// 

 /// 接受数据
 /// 
 /// 
 public void ReceiveCb(IAsyncResult ar)
 {
  
  try
  {
   int count = socket.EndReceive(ar);

   string str = System.Text.Encoding.UTF8.GetString(readBuff, 0, count);

   if (recvStr.Length > 300) recvStr = "";

   recvStr += socket.LocalEndPoint.ToString()+str + "\n";
   Debug.Log("12346");
   socket.BeginReceive(readBuff, 0, buffer_Size, SocketFlags.None, ReceiveCb, socket);
  }catch(SocketException ex)
  {
   Debug.Log(ex);
  }
 }

 /// 

 /// 发送数据,（需要一个Button触发）
 /// 
 public void Send()
 {
  string str = TextInput.text;
  byte[] tex = System.Text.Encoding.UTF8.GetBytes(str);
  try
  {
   socket.Send(tex);
  
  }
  catch(SocketException ex)
  {
   Debug.Log(ex);
  }
 }
}