目录
&＃x1f7e5; 认识Socket
&＃x1f7e7; 创建一个Socket服务器
1️⃣ 服务器端
2️⃣ Unity端&＃xff08;客户端&＃xff09;
&＃x1f7e8; 创建异步Socket Conn类
&＃x1f7e9; 创建异步Socket Sever类
1️⃣ 第一步&＃xff1a;添加Server类
2️⃣ 第二步&＃xff1a;改Main方法
3️⃣ 第三步&＃xff1a;调试
&＃x1f7e6; 实战&＃xff1a;开发一款多人聊天室
&＃x1f7e5; 认识Socket
Skcket&＃xff1a;套接字
Socket怎样传输数据&＃xff1f;
客户端&＃xff1a;
1、链接&＃xff1a;connect&＃xff0c;连接到服务器Accept
2、写入&＃xff1a;write——服务器read 往服务器发送请求/向服务器写入账号密码等
3、读取&＃xff1a;read——服务器write 客户端读取服务器发来的请求&＃xff0c;根据发来的信息进行下一步操作
4、关闭&＃xff1a;close——服务器close 如果一直连接socket&＃xff0c;会占用资源
服务端&＃xff1a;
1、绑定&＃xff1a;Bind
2、监听&＃xff1a;Listen
ps&＃xff1a;1,2步是先把服务器开启起来进行监听&＃xff0c;这样客户端才能访问进来
3、创建一个新的链接&＃xff1a;Accept。因为服务器不可能只和一个客户端连接&＃xff0c;所以和当前客户端建立一个新的连接&＃xff0c;当再来别的客户端连接时&＃xff0c;再创建新的链接
4、读取&＃xff1a;Read 当收到客户端write请求时&＃xff0c;读取数据库是否有该账号密码等&＃xff0c;进行数据的验证
5、写入&＃xff1a;write 当服务器在数据库读取到数据时&＃xff0c;服务器返回/发送请求&＃xff08;查询到信息&＃xff09;给客户端
6、关闭&＃xff1a;close
&＃x1f7e7; 创建一个Socket服务器
注&＃xff1a;本段是同步
同步和异步的区别&＃xff1a;
同步&＃xff1a;只能监听一个
异步&＃xff1a;可监听多个&＃xff08;真正根据listdfd.Listen(0); //监听的个数 0代表不限制&＃xff0c;同步模式即使这样写也只监听一个&＃xff09;
1️⃣ 服务器端
vs安装&＃xff1a;.NET桌面开发
VS新建&＃xff1a;控制台应用&＃xff08;.NET Framework&＃xff09; 文件名&＃xff1a;mysocket
代码如下&＃xff1a;
using System;
using System.Text;
using System.Net;
using System.Net.Sockets;namespace mysocket
{class Program{static void Main(string[] args){Socket listdfd &＃61; new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);IPAddress ipAdr &＃61; IPAddress.Parse("127.0.0.1"); //服务器地址IPEndPoint ipEp &＃61; new IPEndPoint(ipAdr, 1234); //服务器地址&＃43;端口号&＃xff08;端口号可随意&＃xff09;listdfd.Bind(ipEp);listdfd.Listen(0); //监听的个数 0代表不限制Console.WriteLine("服务器启动成功");while (true){Socket connfd &＃61; listdfd.Accept(); //创建一个新的链接Console.WriteLine("服务器Accept成功");byte[] readbuff &＃61; new byte[1024];int count &＃61; connfd.Receive(readbuff); //接受客户端信息&＃xff1a;有数据发送过来就会接收string str &＃61; Encoding.Default.GetString(readbuff, 0, count);Byte[] bytes &＃61; Encoding.Default.GetBytes("服务器输出" &＃43; str);connfd.Send(bytes);}}}
}
2️⃣ Unity端&＃xff08;客户端&＃xff09;
build Settings——Resolution and Presentation——Run in background&＃xff08;勾选&＃xff09;&＃xff0c;允许你的游戏在后台运行。若取消勾选&＃xff0c;则切换到后台时&＃xff0c;你的游戏将失去响应
创建connect脚本挂载到Camera&＃xff0c;代码如下
using UnityEngine;
using System.Net.Sockets;public class connect : MonoBehaviour {Socket socket;const int buff_size &＃61; 1024;byte[] readbuff &＃61; new byte[buff_size];private void Start(){connection();}public void connection(){socket &＃61; new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);string host &＃61; "127.0.0.1";int port &＃61; 1234;socket.Connect(host, port);print("客户端地址" &＃43; socket.LocalEndPoint); //显示客户端连接信息string str &＃61; "nihao";byte[] bytes &＃61; System.Text.Encoding.Default.GetBytes(str);socket.Send(bytes);int count &＃61; socket.Receive(readbuff);str &＃61; System.Text.Encoding.Default.GetString(readbuff, 0, count);print(str);socket.Close();}
}
此时&＃xff0c;调试VS&＃xff0c;启动Unity&＃xff0c;观察到以下结果
&＃x1f7e8; 创建异步Socket Conn类
在二基础上&＃xff0c;打开服务端&＃xff0c;添加Conn类&＃xff0c;代码如下
using System;
using System.Net.Sockets;namespace mysocket
{/// /// 处理客户端链接的类/// class Conn{//定义缓冲区public const int buff_size &＃61; 1024;//定义服务器public Socket socket;//是否使用public bool isUse &＃61; false;public byte[] readBuff &＃61; new byte[buff_size];public int buffCount &＃61; 0;public Conn(){readBuff &＃61; new byte[buff_size];}//初始化public void Init(Socket socket){this.socket &＃61; socket;isUse &＃61; true;buffCount &＃61; 0;}//缓冲所剩余的字节数public int BuffRemain(){return buff_size - buffCount;}//获取客户端地址public string GetAdress(){if (!isUse)return "无法获取地址";return socket.RemoteEndPoint.ToString();}//关闭连接public void Close(){if (!isUse)return;Console.WriteLine(GetAdress() &＃43; "与服务器断开连接");socket.Close();isUse &＃61; false;}}
}
&＃x1f7e9; 创建异步Socket Sever类
1️⃣ 第一步&＃xff1a;添加Server类
在第三基础上&＃xff0c;同样在服务器端添加Server类&＃xff0c;代码如下
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Net;
using System.Net.Sockets;namespace mysocket
{class Server{//监听嵌套字public Socket listedfd;//客户端连接public Conn[] conns;//最大连接数public int maxConn &＃61; 50;//获取连接池&＃xff0c;返回负数表示连接失败public int NewIndex(){if (conns &＃61;&＃61; null)return -1; //代表没有连接成功for(int i &＃61; 0; i }
2️⃣ 第二步&＃xff1a;改Main方法
将Program的Main&＃xff08;&＃xff09;内方法删掉&＃xff0c;改为如下异步方法&＃xff08;原内容为同步&＃xff09;
using System;namespace mysocket
{class Program{static void Main(string[] args){Server server &＃61; new Server();server.Start("127.0.0.1", 1234);while (true){string str &＃61; Console.ReadLine();switch (str){case "quit": //关闭socketreturn;}}}}
}
3️⃣ 第三步&＃xff1a;调试
在Main界面调试&＃xff0c;若出现“服务器启动成功”&＃xff0c;则代表成功
&＃x1f7e6; 实战&＃xff1a;开发一款多人聊天室
基于以上内容&＃xff0c;打开Unity的客户端&＃xff0c;将connect脚本内容改为如下所示&＃xff1a;
using UnityEngine;
using System.Net.Sockets;
using UnityEngine.UI;
using System;public class connect : MonoBehaviour {//服务器地址、服务器端口、聊天输入框public InputField hostInput, portInput,TextInput;//客户端收到的信息public Text connecttext;public Text txtstr; //用于UI显示服务器发送过来的数据public string serverstr; //注&＃xff1a;必须为public&＃xff01;服务器发送回来的数据//SocketSocket socket;const int buff_size &＃61; 1024;public byte[] readbuff &＃61; new byte[buff_size];private void Update(){txtstr.text &＃61; serverstr;}//连接服务器&＃xff0c;绑定“连接”按钮public void Connection(){txtstr.text &＃61; "";socket &＃61; new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);//开始连接服务器string host &＃61; hostInput.text;int port &＃61; int.Parse(portInput.text); //转化为intsocket.Connect(host, port);print("客户端地址" &＃43; socket.LocalEndPoint); //输出&＃xff1a;客户端地址127.0.0.1:54000connecttext.text &＃61; socket.LocalEndPoint.ToString();//开始接收数据//public IAsyncResult BeginReceive(byte[] buffer, int offset, int size, SocketFlags socket_flags, AsyncCallback callback, object state);socket.BeginReceive(readbuff, 0, buff_size, SocketFlags.None, ReceiveCb, null);}//回调方法void ReceiveCb(IAsyncResult ar){try{//接收数据的大小int count &＃61; socket.EndReceive(ar);string str &＃61; System.Text.Encoding.Default.GetString(readbuff, 0, count);if (serverstr.Length > 300) serverstr &＃61; "";serverstr &＃43;&＃61; str &＃43; "\n"; //服务器发送回来的数据(经过加换行处理&＃xff0c;且公用放在外面)&＃43;&＃61;接收数据&＃43; "\n"//继续接收数据socket.BeginReceive(readbuff, 0, buff_size, SocketFlags.None, ReceiveCb, null);}catch(Exception ex){txtstr.text &＃61; "连接已经断开" &＃43; ex.Message;socket.Close();}}public void Send(){string str &＃61; TextInput.text;byte[] bytes &＃61; System.Text.Encoding.Default.GetBytes(str);try{socket.Send(bytes);}catch{}}
}
Unity界面如下
现在运行Unity&＃xff0c;输入127.0.0.1&＃xff0c;端口1234&＃xff0c;即可开始通讯
unity发布exe&＃xff0c;运行多个exe&＃xff0c;可在多个客户端之间进行实时通讯
大家还有什么问题&＃xff0c;欢迎在下方留言&＃xff01;
如果你有 技术的问题 或 项目开发
都可以加下方联系方式
和我聊一聊你的故事&＃x1f9e1;
京公网安备 11010802041100号