unity3d游戏开发之实现基于Socket通讯的公共聊天室

socket编程聊天室基本流程一、引言Socket编程是一种用于网络通信的编程技术。

它允许程序员创建客户端和服务器应用程序，这些应用程序可以在不同的计算机上运行并通过Internet或局域网相互通信。

在本文中，我们将介绍Socket编程聊天室的基本流程。

二、Socket编程概述Socket编程是一种基于TCP/IP协议的网络编程技术。

它使用套接字（socket）来实现网络通信。

套接字是一种抽象概念，它表示一个网络连接点，可以用来发送和接收数据。

在Socket编程中，客户端和服务器之间建立一个连接，然后通过这个连接进行数据传输。

客户端向服务器发送请求，并等待服务器响应。

服务器接收请求并处理它，并将响应发送回客户端。

三、Socket编程聊天室基本流程1. 创建服务器程序首先，我们需要创建一个服务器程序来监听客户端连接请求。

在Python中，可以使用socket模块来创建套接字对象，并使用bind()方法将其绑定到指定的IP地址和端口号上。

2. 创建客户端程序然后，我们需要创建一个客户端程序来连接到服务器。

同样地，在Python中可以使用socket模块来创建套接字对象，并使用connect()方法连接到指定的IP地址和端口号上。

3. 实现消息传输一旦客户端和服务器之间建立了连接，它们就可以开始进行消息传输。

在Socket编程中，可以使用send()方法将数据发送到对方，使用recv()方法从对方接收数据。

4. 实现聊天室功能为了实现聊天室功能，我们需要让多个客户端能够同时连接到服务器，并且能够相互通信。

为此，我们可以使用多线程或异步编程技术来实现。

在多线程模式下，每个客户端连接都会被分配一个独立的线程来处理。

这个线程负责接收客户端发送的消息，并将其转发给其他客户端。

在异步编程模式下，我们可以使用协程或回调函数来处理消息传输。

当有新的消息到达时，就会触发相应的回调函数进行处理。

5. 实现用户管理为了实现用户管理功能，我们需要让每个客户端都能够注册一个唯一的用户名，并且能够查看当前在线的用户列表。

在Unity中如何实现异步Socket通信技术关于在Unity中如何实现异步Socket通信技术问题，蓝鸥Unity高级讲师分享以下内容，希望对喜欢Unity游戏开发的朋友或者正在学习Unity3d培训的同学有帮助。

在刚刚开发Unity项目的过程中，需要用到即时通信功能来完成服务器与客户端自定义的数据结构封装。

现在将部分主要功能的实现代码抽取出来实现了可以异步Socket请求的技术Demo。

客户端脚本ClientScript///<summary>/// Client Script./// Created By 蓝鸥3G 2014.08.23///</summary>using UnityEngine;using System.Collections;public class ClientScript: MonoBehaviour {string msg = "";// Use this for initializationLOSocket client;void Start () {client = LOSocket.GetSocket(LOSocket.LOSocketType.CLIENT); client.InitClient ("127.0.0.1", 2222, ((string content) => { //收到服务器的回馈信息}));}void OnGUI() {msg = GUI.TextField(new Rect(0, 0, 500, 40), msg);if(GUI.Button(new Rect(0, 50, 100, 30), "Send")){client.SendMessage (msg);}}}服务器端脚本///<summary>/// Server Script./// Created By 蓝鸥3G 2014.08.23///</summary>//////using UnityEngine;using System.Collections;public class ServerScript : MonoBehaviour {private string receive_str;LOSocket server;// Use this for initializationvoid Start (){server = LOSocket.GetSocket(LOSocket.LOSocketType.SERVER);//初始化服务器server.InitServer((string content) => {receive_str = content;});}void OnGUI(){if (receive_str != null){bel (receive_str);}}}LOSocket框架///<summary>/// LOSocket./// Created By 蓝鸥3G 2014.08.23///</summary>//////using UnityEngine;using System.Collections;using ;using .Sockets;using System.Text;//收到消息后的委托回调public delegate void ReceiveCallBack(string content);public class LOSocket{//可以创建的Socket端口类型public enum LOSocketType{CLIENT = 0,SERVER = 1,}#region --------取消构造器private LOSocket(){}#endregion#region --------公共代码//通过静态方法获取不同的端口类型public static LOSocket GetSocket(LOSocket.LOSocketType type) {LOSocket socket = null;switch (type) {case LOSocketType.CLIENT:{//创建一个新的客户端socket = new LOSocket ();break;}case LOSocketType.SERVER:{//获取服务端socket = GetServer ();break;}}return socket;}#endregion#region --------客户端部分代码private Socket clientSocket;//声明客户端收到服务端返回消息后的回调委托函数private ReceiveCallBack clientReceiveCallBack;//用来存储服务端返回的消息数据byte[] Buffer = new byte[1024];//初始化客户端Socket信息public void InitClient(string ip,int port,ReceiveCallBack ccb) {this.clientReceiveCallBack = ccb;this.clientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);IPAddress address = IPAddress.Parse (ip);IPEndPoint ep = new IPEndPoint (address, port);this.clientSocket.Connect(ep);//开始异步等待接收服务端消息this.clientSocket.BeginReceive (Buffer, 0, Buffer.Length, SocketFlags.None, new System.AsyncCallback(ReceiveFromServer), this.clientSocket);}//收到服务端返回消息后的回调函数void ReceiveFromServer(System.IAsyncResult ar){//获取当前正在工作的Socket对象Socket worker = ar.AsyncState as Socket;int ByteRead=0;try{//接收完毕消息后的字节数ByteRead = worker.EndReceive(ar);}catch (System.Exception ex){this.clientReceiveCallBack (ex.ToString ());}if (ByteRead > 0){string Content = Encoding.Default.GetString (Buffer);//通过回调函数将消息返回给调用者this.clientReceiveCallBack (Content);}//继续异步等待接受服务器的返回消息worker.BeginReceive(Buffer, 0, Buffer.Length, SocketFlags.None, new System.AsyncCallback(ReceiveFromServer), worker);}//客户端主动发送消息public void SendMessage(string message){if (message == null)return;message += "\r\n";byte[] sendData = Encoding.UTF8.GetBytes (message);//异步发送消息请求clientSocket.BeginSend (sendData, 0, sendData.Length, SocketFlags.None, new System.AsyncCallback (SendToServer), clientSocket);}//发送消息结束的回调函数void SendToServer(System.IAsyncResult ar){Socket worker = ar.AsyncState as Socket;worker.EndSend (ar);}#endregion#region -------服务器部分代码//服务器端收到消息的存储空间byte[] ReceiveBuffer = new byte[1024];//服务器收到消息后的回调委托private ReceiveCallBack callback;//单例模式private static LOSocket serverSocket;private static LOSocket GetServer() {if (serverSocket == null) {serverSocket = new LOSocket();}return serverSocket;}//初始化服务器信息public void InitServer(ReceiveCallBack cb) {this.callback = cb;// 1.Socket server_socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);// 2.IPEndPoint endPoint = new IPEndPoint(IPAddress.Any, 2222);// 3.server_socket.Bind(endPoint);// 4.server_socket.Listen(10);// 5.开始异步等待客户端的请求链接server_socket.BeginAccept (new System.AsyncCallback (Accept), server_socket);this.callback ("开启服务器" + endPoint.ToString());}//接受到客户端的链接请求后的回调函数void Accept(System.IAsyncResult ar){//获取正在工作的Socket对象Socket socket = ar.AsyncState as Socket;//存储异步操作的信息，以及用户自定义的数据Socket worker = socket.EndAccept(ar);SocketError error;//开始异步接收客户端发送消息内容worker.BeginReceive (ReceiveBuffer, 0, ReceiveBuffer.Length, SocketFlags.None, new System.AsyncCallback (Receive), worker);//继续异步等待新的客户端链接请求socket.BeginAccept(new System.AsyncCallback(Accept), socket);}//服务端收到客户端的消息后的回调函数void Receive(System.IAsyncResult ar){//获取正在工作的Socket对象Socket worker = ar.AsyncState as Socket;int ByteRead=0;try{ByteRead = worker.EndReceive(ar);}catch (System.Exception ex){this.callback (ex.ToString ());}if (ByteRead > 0){string Content = Encoding.Default.GetString (ReceiveBuffer);this.callback (Content);}//继续异步等待客户端的发送消息请求worker.BeginReceive(ReceiveBuffer, 0, ReceiveBuffer.Length, SocketFlags.None, new System.AsyncCallback(Receive), worker);}#endregion}本资料出自蓝鸥Unity3D培训转载请注明。

C#使⽤ProtocolBuffer（ProtoBuf）进⾏Unity中的Socket通信⾸先来说⼀下本⽂中例⼦所要实现的功能：基于ProtoBuf序列化对象使⽤Socket实现时时通信数据包的编码和解码下⾯来看具体的步骤：⼀、Unity中使⽤ProtoBuf导⼊DLL到Unity中，创建⽹络传输的模型类：using System;using ProtoBuf;//添加特性，表⽰可以被ProtoBuf⼯具序列化[ProtoContract]public class NetModel {//添加特性，表⽰该字段可以被序列化，1可以理解为下标[ProtoMember(1)]public int ID;[ProtoMember(2)]public string Commit;[ProtoMember(3)]public string Message;}using System;using ProtoBuf;//添加特性，表⽰可以被ProtoBuf⼯具序列化[ProtoContract]public class NetModel {//添加特性，表⽰该字段可以被序列化，1可以理解为下标[ProtoMember(1)]public int ID;[ProtoMember(2)]public string Commit;[ProtoMember(3)]public string Message;}在Unity中添加测试脚本，介绍ProtoBuf⼯具的使⽤。

using System;using System.IO;public class Test : MonoBehaviour {void Start () {//创建对象NetModel item = new NetModel(){ID = 1, Commit = "LanOu", Message = "Unity"};//序列化对象byte[] temp = Serialize(item);//ProtoBuf的优势⼀：⼩Debug.Log(temp.Length);//反序列化为对象NetModel result = DeSerialize(temp);Debug.Log(result.Message);}// 将消息序列化为⼆进制的⽅法// < param name="model">要序列化的对象< /param>private byte[] Serialize(NetModel model){try {//涉及格式转换，需要⽤到流，将⼆进制序列化到流中using (MemoryStream ms = new MemoryStream()) {//使⽤ProtoBuf⼯具的序列化⽅法ProtoBuf.Serializer.Serialize<NetModel> (ms, model);//定义⼆级制数组，保存序列化后的结果byte[] result = new byte[ms.Length];//将流的位置设为0，起始点ms.Position = 0;//将流中的内容读取到⼆进制数组中ms.Read (result, 0, result.Length);return result;}} catch (Exception ex) {Debug.Log ("序列化失败: " + ex.ToString());return null;}}// 将收到的消息反序列化成对象// < returns>The serialize.< /returns>// < param name="msg">收到的消息.</param>private NetModel DeSerialize(byte[] msg){try {using (MemoryStream ms = new MemoryStream()) {//将消息写⼊流中ms.Write (msg, 0, msg.Length);//将流的位置归0ms.Position = 0;//使⽤⼯具反序列化对象NetModel result = ProtoBuf.Serializer.Deserialize<NetModel> (ms);return result;}} catch (Exception ex) {Debug.Log("反序列化失败: " + ex.ToString());return null;}}}using System;using System.IO;public class Test : MonoBehaviour {void Start () {//创建对象NetModel item = new NetModel(){ID = 1, Commit = "LanOu", Message = "Unity"}; //序列化对象byte[] temp = Serialize(item);//ProtoBuf的优势⼀：⼩Debug.Log(temp.Length);//反序列化为对象NetModel result = DeSerialize(temp);Debug.Log(result.Message);}// 将消息序列化为⼆进制的⽅法// < param name="model">要序列化的对象< /param>private byte[] Serialize(NetModel model){try {//涉及格式转换，需要⽤到流，将⼆进制序列化到流中using (MemoryStream ms = new MemoryStream()) {//使⽤ProtoBuf⼯具的序列化⽅法ProtoBuf.Serializer.Serialize<NetModel> (ms, model);//定义⼆级制数组，保存序列化后的结果byte[] result = new byte[ms.Length];//将流的位置设为0，起始点ms.Position = 0;//将流中的内容读取到⼆进制数组中ms.Read (result, 0, result.Length);return result;}} catch (Exception ex) {Debug.Log ("序列化失败: " + ex.ToString());return null;}}// 将收到的消息反序列化成对象// < returns>The serialize.< /returns>// < param name="msg">收到的消息.</param>private NetModel DeSerialize(byte[] msg){try {using (MemoryStream ms = new MemoryStream()) {//将消息写⼊流中ms.Write (msg, 0, msg.Length);//将流的位置归0ms.Position = 0;//使⽤⼯具反序列化对象NetModel result = ProtoBuf.Serializer.Deserialize<NetModel> (ms); return result;}} catch (Exception ex) {Debug.Log("反序列化失败: " + ex.ToString());return null;}}}⼆、Unity中使⽤Socket实现时时通信通信应该实现的功能：服务器可以时时监听多个客户端服务器可以时时监听某⼀个客户端消息服务器可以时时给某⼀个客户端发消息⾸先我们需要定义⼀个客户端对象using System;using .Sockets;// 表⽰⼀个客户端public class NetUserToken {//连接客户端的Socketpublic Socket socket;//⽤于存放接收数据public byte[] buffer;public NetUserToken(){buffer = new byte[1024];}// 接受消息// < param name="data">Data.< /param>public void Receive(byte[] data){UnityEngine.Debug.Log("接收到消息！");}// 发送消息//< param name="data">Data.< /param>public void Send(byte[] data){}}using System;using .Sockets;// 表⽰⼀个客户端public class NetUserToken {//连接客户端的Socketpublic Socket socket;//⽤于存放接收数据public byte[] buffer;public NetUserToken(){buffer = new byte[1024];}// 接受消息// < param name="data">Data.< /param>public void Receive(byte[] data){UnityEngine.Debug.Log("接收到消息！");}// 发送消息//< param name="data">Data.< /param>public void Send(byte[] data){}}然后实现我们的服务器代码using System.Collections;using System.Collections.Generic;using ;using System;using .Sockets;public class NetServer{//单例脚本public static readonly NetServer Instance = new NetServer();//定义tcp服务器private Socket server;private int maxClient = 10;//定义端⼝private int port = 35353;//⽤户池private Stack<NetUserToken> pools;private NetServer(){//初始化socketserver = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);server.Bind(new IPEndPoint(IPAddress.Any, port));}//开启服务器public void Start(){server.Listen(maxClient);UnityEngine.Debug.Log("Server OK!");//实例化客户端的⽤户池pools = new Stack<NetUserToken>(maxClient);for(int i = 0; i < maxClient; i++){NetUserToken usertoken = new NetUserToken();pools.Push(usertoken);}//可以异步接受客户端, BeginAccept函数的第⼀个参数是回调函数，当有客户端连接的时候⾃动调⽤ server.BeginAccept (AsyncAccept, null);}//回调函数，有客户端连接的时候会⾃动调⽤此⽅法private void AsyncAccept(IAsyncResult result){try {//结束监听，同时获取到客户端Socket client = server.EndAccept(result);UnityEngine.Debug.Log("有客户端连接");//来了⼀个客户端NetUserToken userToken = pools.Pop();userToken.socket = client;//客户端连接之后，可以接受客户端消息BeginReceive(userToken);//尾递归，再次监听是否还有其他客户端连⼊server.BeginAccept(AsyncAccept, null);} catch (Exception ex) {UnityEngine.Debug.Log(ex.ToString());}}//异步监听消息private void BeginReceive(NetUserToken userToken){try {//异步⽅法userToken.socket.BeginReceive(userToken.buffer, 0, userToken.buffer.Length, SocketFlags.None, EndReceive, userToken);} catch (Exception ex) {UnityEngine.Debug.Log(ex.ToString());}}//监听到消息之后调⽤的函数private void EndReceive(IAsyncResult result){try {//取出客户端NetUserToken userToken = result.AsyncState as NetUserToken;//获取消息的长度int len = userToken.socket.EndReceive(result);if(len > 0){byte[] data = new byte[len];Buffer.BlockCopy(userToken.buffer, 0, data, 0, len);//⽤户接受消息userToken.Receive(data);//尾递归，再次监听客户端消息BeginReceive(userToken);}} catch (Exception ex) {UnityEngine.Debug.Log(ex.ToString());}}}using System.Collections;using System.Collections.Generic;using ;using System;using .Sockets;public class NetServer{//单例脚本public static readonly NetServer Instance = new NetServer();//定义tcp服务器private Socket server;private int maxClient = 10;//定义端⼝private int port = 35353;//⽤户池private Stack<NetUserToken> pools;private NetServer(){//初始化socketserver = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);server.Bind(new IPEndPoint(IPAddress.Any, port));}//开启服务器public void Start(){server.Listen(maxClient);UnityEngine.Debug.Log("Server OK!");//实例化客户端的⽤户池pools = new Stack<NetUserToken>(maxClient);for(int i = 0; i < maxClient; i++){NetUserToken usertoken = new NetUserToken();pools.Push(usertoken);}//可以异步接受客户端, BeginAccept函数的第⼀个参数是回调函数，当有客户端连接的时候⾃动调⽤server.BeginAccept (AsyncAccept, null);}//回调函数，有客户端连接的时候会⾃动调⽤此⽅法private void AsyncAccept(IAsyncResult result){try {//结束监听，同时获取到客户端Socket client = server.EndAccept(result);UnityEngine.Debug.Log("有客户端连接");//来了⼀个客户端NetUserToken userToken = pools.Pop();userToken.socket = client;//客户端连接之后，可以接受客户端消息BeginReceive(userToken);//尾递归，再次监听是否还有其他客户端连⼊server.BeginAccept(AsyncAccept, null);} catch (Exception ex) {UnityEngine.Debug.Log(ex.ToString());}}//异步监听消息private void BeginReceive(NetUserToken userToken){try {//异步⽅法userToken.socket.BeginReceive(userToken.buffer, 0, userToken.buffer.Length, SocketFlags.None,EndReceive, userToken);} catch (Exception ex) {UnityEngine.Debug.Log(ex.ToString());}}//监听到消息之后调⽤的函数private void EndReceive(IAsyncResult result){try {//取出客户端NetUserToken userToken = result.AsyncState as NetUserToken;//获取消息的长度int len = userToken.socket.EndReceive(result);if(len > 0){byte[] data = new byte[len];Buffer.BlockCopy(userToken.buffer, 0, data, 0, len);//⽤户接受消息userToken.Receive(data);//尾递归，再次监听客户端消息BeginReceive(userToken);}} catch (Exception ex) {UnityEngine.Debug.Log(ex.ToString());}}}在Unity中开启服务器，并使⽤C#控制台模拟客户端连接、发送消息操作。

unity 常用tcp通讯协议Unity作为一款流行的游戏开发引擎，常常需要在游戏中进行网络通信。

而TCP（传输控制协议）是一种常用的网络通信协议，可以确保数据的可靠传输。

本文将介绍Unity常用的TCP通信协议及其使用方法。

TCP通信协议是一种面向连接的协议，它通过建立可靠的连接来进行数据传输。

在Unity中，我们可以使用C#的Socket类来实现TCP 通信。

首先，我们需要创建一个Socket对象，并指定通信的IP地址和端口号。

然后，我们可以使用Socket的Connect方法来建立与服务器的连接。

建立连接后，我们可以使用Socket的Send和Receive方法来发送和接收数据。

发送数据时，我们可以将要发送的数据转换为字节数组，并使用Socket的Send方法发送。

接收数据时，我们可以使用Socket的Receive方法接收数据，并将接收到的字节数组转换为相应的数据类型。

在接收数据时，我们需要注意处理粘包和分包的问题，以确保数据的完整性和正确性。

在Unity中，我们通常会使用多线程来处理网络通信。

这是因为网络通信是一个耗时的操作，如果在主线程中进行，会导致游戏的卡顿。

因此，我们可以使用C#的Thread类来创建一个新的线程，并在该线程中进行网络通信。

在网络通信的过程中，我们可以使用C#的异步编程模型来提高通信效率。

通过使用异步方法和回调函数，我们可以在接收到数据时立即进行处理，而不需要等待数据的完全接收。

在使用TCP通信时，我们还需要考虑网络安全性的问题。

为了保护通信数据的机密性和完整性，我们可以使用加密算法和消息认证码来对数据进行加密和验证。

在Unity中，我们可以使用C#的加密库来实现数据的加密和解密。

同时，我们还可以使用数字证书来验证通信双方的身份，以防止中间人攻击。

除了TCP通信协议，Unity还支持其他常用的网络通信协议，如UDP （用户数据报协议）和WebSocket。

UDP协议是一种无连接的协议，它可以实现高速的数据传输，但无法确保数据的可靠性。