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

 更新时间:2017年10月11日 10:53:01   作者:青鱼谷雨  
这篇文章主要给大家介绍了关于C#中Socket与Unity相结合的相关资料,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考借鉴,下面随着小编来一起学习学习吧。

前言

初步接触了Socket,现使其与Unity相结合,做成一个简单的客户端之间可以互相发送消息的一个Test。下面话不多说了,来一起看看详细的介绍吧。

方法如下:

首先,是服务端的代码。

创建一个连接池,用于存储客户端的数量。

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


namespace Server
{
 /// <summary>
 /// 对象池
 /// </summary>
 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;

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

  /// <summary>
  /// 初始化
  /// </summary>
  /// <param name="socket"></param>
  public void Init(Socket socket)
  {
   this.socket = socket;
   isUse = true;
   buffCount = 0;
  }

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

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

  }

  /// <summary>
  /// 关闭连接
  /// </summary>
  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 < conns.Length;i++ )
   {
    if(conns[i]==null)
    {
     conns[i] = new Conn();
     return i;
    }else if(conns[i].isUse==false)
    {
     return i;
    }
   }
   return -1;
  }

  //开启一个服务器
  public void Start(string host,int port)
  {
   conns = new Conn[maxConn];


   for (int i = 0; i < maxConn;i++ )
   {
    conns[i] = new Conn();
   }


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

   IPAddress ipAdr = IPAddress.Parse(host);
   IPEndPoint ipEp = new IPEndPoint(ipAdr, port);

   //与一个本地终结点相关联
   listenfd.Bind(ipEp);

   //监听
   listenfd.Listen(maxConn);

   listenfd.BeginAccept(AcceptCb, listenfd);

  }

  //AcceptCb回调
  public void AcceptCb(IAsyncResult ar)
  {
   try
   {
    Socket sSocket = ar.AsyncState as Socket;
    Socket socket = sSocket.EndAccept(ar);

    int index = NewIndex();
    if(index<0)
    {
     socket.Close();
     Console.WriteLine("连接已满");
    }
    else
    {
     Conn conn = conns[index];
     conn.Init(socket);
     string adr = conn.GetAdress();
     Console.WriteLine("客户端连接[" + adr + "Conn池ID: " + index);

     conn.socket.BeginReceive(conn.readBuff, conn.buffCount, conn.BuffRemain(), SocketFlags.None, ReceiveCb, conn);

    }

    listenfd.BeginAccept(AcceptCb, listenfd);


   }catch(SocketException ex)
   {
    Console.WriteLine(ex);
   }

  }

  //ReceiveCb回调
  public void ReceiveCb(IAsyncResult ar)
  {
   Conn conn = (Conn)ar.AsyncState;
   try
   {
    int count = conn.socket.EndReceive(ar);
    if(count<=0)
    {
     Console.WriteLine("收到:" + conn.GetAdress() + "断开连接");
     conn.Close();
     return;
    }
    string str = Encoding.UTF8.GetString(conn.readBuff,0,count);
    Console.WriteLine("接收到[" + conn.GetAdress() + "]数据" + str);

    byte[] bytes = Encoding.UTF8.GetBytes(str);

    for (int i = 0; i < conns.Length;i++ )
    {
     if(conns[i]==null)
      continue;

     if (!conns[i].isUse)
      continue;
     Console.WriteLine("将消息传送给" + conns[i].GetAdress());
     conns[i].socket.Send(bytes);
    }
    conn.socket.BeginReceive(conn.readBuff, conn.buffCount, conn.BuffRemain(), SocketFlags.None,ReceiveCb, conn);

   }
   catch(SocketException ex)
   {
    Console.WriteLine(ex);
    Console.WriteLine("收到:" + conn.GetAdress() + "断开连接");
    conn.Close();
   }

  }
 }
}

最后是创建一个Unity的工程,搭建一个简单的页面,通过下面的代码你可以了解需要哪些组件

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);

 }

 /// <summary>
 /// 接受数据
 /// </summary>
 /// <param name="ar"></param>
 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);
  }
 }

 /// <summary>
 /// 发送数据,(需要一个Button触发)
 /// </summary>
 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);
  }
 }
}

以上内容出自罗培羽老师《unity3d网络游戏实战》一书。

总结

以上就是这篇文章的全部内容了,希望本文的内容对大家的学习或者工作具有一定的参考学习价值,如果有疑问大家可以留言交流,谢谢大家对脚本之家的支持。

相关文章

  • .NET实现父窗体关闭而不影响子窗体的方法

    .NET实现父窗体关闭而不影响子窗体的方法

    这篇文章主要介绍了.NET实现父窗体关闭而不影响子窗体的方法,很实用的功能,需要的朋友可以参考下
    2014-08-08
  • c#中返回文章发表的时间差的示例

    c#中返回文章发表的时间差的示例

    现在是2012-12-04 11:29:59,发表时间是:2012-12-02 21:29:59,传统的ts.Days因为值为1天14小时0分0秒,会返回“昨天”,而这个会返回“前天”
    2012-12-12
  • C#实现插入排序算法实例

    C#实现插入排序算法实例

    这篇文章主要介绍了C#实现插入排序算法,实例分析了插入排序算法的原理与实现技巧,需要的朋友可以参考下
    2015-05-05
  • Winform让DataGridView左侧显示图片

    Winform让DataGridView左侧显示图片

    本文主要介绍在如何让DataGridView左侧显示图片,这里主要讲解重写DataGridView的OnRowPostPaint方法,需要的朋友可以参考下。
    2016-05-05
  • c#解析jobject的数据结构

    c#解析jobject的数据结构

    这篇文章介绍了c#解析jobject数据结构的方法,文中通过示例代码介绍的非常详细。对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2022-07-07
  • 比较全的一个C#操作word文档示例

    比较全的一个C#操作word文档示例

    这篇文章主要介绍了比较全的一个C#操作word文档示例,本文来自己项目心得总结,本文还给出了一个示例,这个示例里面包括了一些常用的图、文、表、公式的编辑与排版以及页面设置、页眉、页码的操作,需要的朋友可以参考下
    2015-06-06
  • C#集合之自定义集合类

    C#集合之自定义集合类

    这篇文章介绍了C#集合之自定义集合类,文中通过示例代码介绍的非常详细。对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2022-05-05
  • C#简单发送email的方法

    C#简单发送email的方法

    这篇文章主要介绍了C#简单发送email的方法,涉及C#发送Email的相关技巧,非常具有实用价值,需要的朋友可以参考下
    2015-04-04
  • 详解C# Protobuf如何做到0分配内存的序列化

    详解C# Protobuf如何做到0分配内存的序列化

    这篇文章主要介绍了详解C# Protobuf如何做到0分配内存的序列化,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2020-04-04
  • 基于C#制作考试答题系统

    基于C#制作考试答题系统

    这篇文章主要为大家详细介绍了如何利用C#制作带窗体的考试答题系统,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2022-03-03

最新评论