Unity的Socket通讯，Unity作为服务端-Toy模板网

这篇具有很好参考价值的文章主要介绍了Unity的Socket通讯，Unity作为服务端。希望对大家有所帮助。如果存在错误或未考虑完全的地方，请大家不吝赐教，您也可以点击"举报违法"按钮提交疑问。

最近在研究Socket通讯，发现对Unity来说，作为客户端的情况比较多，于是突发奇想搞一个服务器端，废话不多说直接上代码

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

public class Test : MonoBehaviour
{
private static int myProt = 12345; //端口
static Socket serverSocket;
Thread myThread;
Dictionary<string, Thread> threadDic = new Dictionary<string, Thread>();//存储线程，程序结束后关闭线程
private void Start()
{
//服务器IP地址，127.0.0.1 为本机IP地址
IPAddress ip = IPAddress.Parse("127.0.0.1");
//IPAddress ip = IPAddress.Any; //本机地址
Debug.Log(ip.ToString());
serverSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);

IPEndPoint iPEndPoint = new IPEndPoint(ip, myProt);
//serverSocket.Bind(new IPEndPoint(ip, myProt)); //绑定IP地址：端口
serverSocket.Bind(iPEndPoint); //绑定IP地址：端口
serverSocket.Listen(10); //最多10个连接请求
//Console.WriteLine("creat service {0} success",
// serverSocket.LocalEndPoint.ToString());

myThread = new Thread(ListenClientConnect);
myThread.Start();
//Console.ReadLine();
Debug.Log("服务器启动...........");

}

// 监听客户端是否连接
private void ListenClientConnect()
{
while (true)
{
Socket clientSocket = serverSocket.Accept(); //1.创建一个Socket 接收客户端发来的请求信息没有消息时堵塞
clientSocket.Send(Encoding.ASCII.GetBytes("Server Say Hello")); //2.向客户端发送连接成功消息
Thread receiveThread = new Thread(ReceiveMessage); //3.为已经连接的客户端创建一个线程此线程用来处理客户端发送的消息
receiveThread.Start(clientSocket); //4.开启线程

//添加到字典中
string clientIp = ((IPEndPoint)clientSocket.RemoteEndPoint).Address.ToString();
//Debug.Log( clientSocket.LocalEndPoint.ToString()); //获取ip:端口号
if (!threadDic.ContainsKey(clientIp))
{
threadDic.Add(clientIp, receiveThread);
}
}
}

private byte[] result = new byte[1024]; //1.存入的byte值最大数量1024
//开启线程接收数据（将Socket作为值传入）
private void ReceiveMessage(object clientSocket)
{
Socket myClientSocket = (Socket)clientSocket; //2.转换传入的客户端Socket
while (true)
{
try
{
//接收数据
int receiveNumber = myClientSocket.Receive(result); //3.将客户端得到的byte值写入
//Debug.Log(receiveNumber);//子节数量
if (receiveNumber > 0)
{
Debug.Log("client say :" + Encoding.ASCII.GetString(result, 0, receiveNumber));
}
else
{
Debug.Log("client： " + ((IPEndPoint)myClientSocket.RemoteEndPoint).Address.ToString() + "断开连接");
threadDic[((IPEndPoint)myClientSocket.RemoteEndPoint).Address.ToString()].Abort(); //清除线程
}
}
catch (Exception ex)
{
//myClientSocket.Shutdown(SocketShutdown.Both); //出现错误关闭Socket
Debug.Log(" 错误信息" + ex); //打印错误信息
break;
}
}
}