当前位置:   article > 正文

unity使用Socket进行文件上传_byte[]连接 unity

byte[]连接 unity

一、制作思路

1.首先大家要先了解一下、socket一些接口的使用

https://blog.csdn.net/qq_42345116/article/details/122185529

2.思路

2.1首先 我们知道Socket之间传输的数据是Byte数组,所以我们客户端要上传的文件必须是byte数组文件

使用这个方法将文件转换为byte[]数组

  1. #region 将文件转换成byte[] 数组
  2. /// <summary>
  3. /// 将文件转换成byte[] 数组
  4. /// </summary>
  5. /// <param name="fileUrl">文件路径文件名称</param>
  6. /// <returns>byte[]</returns>
  7. protected byte[] GetFileData(string fileUrl)
  8. {
  9. FileStream fs = new FileStream(fileUrl, FileMode.Open, FileAccess.Read);
  10. lock (fs)
  11. {
  12. try
  13. {
  14. byte[] buffur = new byte[fs.Length];
  15. fs.Read(buffur, 0, (int)fs.Length);
  16. return buffur;
  17. }
  18. catch (Exception ex)
  19. {
  20. return null;
  21. }
  22. finally
  23. {
  24. if (fs != null)
  25. {
  26. //关闭资源
  27. fs.Close();
  28. }
  29. }
  30. }
  31. }
  32. #endregion

2.2相应的服务器接收到客户端的byte数组文件后要将其反转成文件进行保存

  1. #region 将byte数组转换为文件并保存到指定地址
  2. /// <summary>
  3. /// 将byte数组转换为文件并保存到指定地址
  4. /// </summary>
  5. /// <param name="buff">byte数组</param>
  6. /// <param name="savepath">保存地址</param>
  7. public static void Bytes2File(byte[] buff, string savepath)
  8. {
  9. if (File.Exists(savepath))
  10. {
  11. File.Delete(savepath);
  12. }
  13. FileStream fs = new FileStream(savepath, FileMode.CreateNew);
  14. BinaryWriter bw = new BinaryWriter(fs);
  15. bw.Write(buff, 0, buff.Length);
  16. bw.Close();
  17. fs.Close();
  18. }
  19. #endregion

2.3但是保存文件需要地址(F:/)+文件名称(XXX文件名)+文件类型 (.png)而我们客户端传过来的byte数组没有这些信息,所以这里我用了Json数据进行组合传输

  1. //1.Json数据类
  2. [Serializable]
  3. public class JsonData
  4. {
  5. public string flieName; //文件名称(文件名称)
  6. public byte[] fileData; //文件byte[]数据
  7. }
  8. //2.获取文件名称 类型
  9. string[] splitData=path.Slip('/'); //将文件路径拆分 为了获取文件名和文件类型
  10. jsonData = new JsonData()
  11. {
  12. flieName = splitData[splitData.Length - 1], //拆分的最后一个一定是文件名.文件类型
  13. fileData = GetFileData(filePath) //将文件转换为byte[]
  14. };
  15. string data=JsonMapper.ToJson(jsonData);//转换成json
  16. byte[] sendData = Encoding.UTF8.GetBytes(data)//string转换成byte数组

这样我们就获取到一个json的byte数组数据。

2.4这还没完,要知道在网络中数据是用包来传输的,每个包能存放的byte数量只有那么多,超出了就要分包发送,文件总是很大的,肯定要分包发送,但是我们服务器没有办法判断是否已经接收完客户端的所有文件数据,所以我们客户端需要在服务器接收数据前先发送一个byte数组(这个数组信息代表了文件的总大小),服务器知道了文件大小以后就开始整合数据,直到接收数据大小等于发送的数据大小后,开始转换byte数据

  1. //1.接上文sendData就是我们要发送的json byte数组,我们获取他的长度通过Send发送给服务器
  2. clientSocket.Send(Encoding.UTF8.GetBytes(sendData.Length.ToString()));

服务器接收处理

  1. //2.这里是服务器要处理
  2. private byte[] result = new byte[1024]; //1.存入的byte值 最大数量1024
  3. private byte[] subpackageData; //1.分包数据存入信息
  4. int dataLength; //要接收信息总的长度
  5. bool isEndData = false; //是否接收到信息总长度
  6. //开启线程接收数据 (将Socket作为值传入)
  7. private void ReceiveMessage(object clientSocket)
  8. {
  9. Socket myClientSocket = (Socket)clientSocket; //2.转换传入的客户端Socket
  10. while (true)
  11. {
  12. try
  13. {
  14. //接收数据
  15. int receiveNumber = myClientSocket.Receive(result); //3.将客户端得到的byte值写入
  16. //没有接收信息总长度
  17. if (!isEndData)
  18. {
  19. //接收
  20. dataLength = int.Parse(Encoding.UTF8.GetString(result));
  21. subpackageData = new byte[0]; //初始化缓冲区
  22. Debug.Log("1.接收到信息的总长度: " + dataLength);
  23. isEndData = true;
  24. }
  25. else
  26. {
  27. //有数据 并且 接收到信息长度后执行
  28. if (receiveNumber > 0 && isEndData)
  29. {
  30. //1.整合数据
  31. byte[] newResult = new byte[(subpackageData.Length + receiveNumber)];
  32. Array.Copy(subpackageData, 0, newResult, 0, subpackageData.Length); //将上一次分包数据赋值给容器
  33. Array.Copy(result, 0, newResult, subpackageData.Length, receiveNumber); //将当前收到的数据赋值给容器
  34. subpackageData = newResult;
  35. Debug.Log("整合后数据长度: " + subpackageData.Length);
  36. //整合的数据超出 或等于数据
  37. if (subpackageData.Length >= dataLength)
  38. {
  39. isEndData = false; //设置没有接收到信息总长度
  40. //数据解析
  41. string data = Encoding.UTF8.GetString(subpackageData);
  42. Debug.Log(data);
  43. DisposeData(data);
  44. myClientSocket.Send(Encoding.UTF8.GetBytes("文件转换成功" + DateTime.Now));
  45. }
  46. }
  47. else
  48. {
  49. Debug.Log("client: " + ((IPEndPoint)myClientSocket.RemoteEndPoint).Address.ToString() + "断开连接");
  50. threadDic[((IPEndPoint)myClientSocket.RemoteEndPoint).Address.ToString()].Abort(); //清除线程
  51. }
  52. }
  53. }
  54. catch (Exception ex)
  55. {
  56. //myClientSocket.Shutdown(SocketShutdown.Both); //出现错误 关闭Socket
  57. Debug.Log(" 错误信息" + ex); //打印错误信息
  58. break;
  59. }
  60. }
  61. }

二、服务器最终代码

  1. using LitJson;
  2. using System;
  3. using System.Collections;
  4. using System.Collections.Generic;
  5. using System.IO;
  6. using System.Net;
  7. using System.Net.Sockets;
  8. using System.Text;
  9. using System.Threading;
  10. using UnityEngine;
  11. //Json数据
  12. [Serializable]
  13. public class JsonData
  14. {
  15. public string operationType; //服务器事件类型(选择服务器要执行的方法)
  16. public string clientIP; //客户端本地ip
  17. public string flieName; //文件名称(文件名称)
  18. public byte[] fileData; //文件byte[]数据
  19. }
  20. public class SocketServer : MonoBehaviour
  21. {
  22. private string myip;
  23. private int myPort; //端口
  24. string saveFilePath; //保存地址
  25. JsonData jsonData;
  26. static Socket serverSocket;
  27. Thread myThread;
  28. Dictionary<string, Thread> threadDic = new Dictionary<string, Thread>();//存储线程,程序结束后关闭线程
  29. private void Start()
  30. {
  31. myip = ConfigFile.LoadString("Server");
  32. myPort = int.Parse(ConfigFile.LoadString("port"));
  33. saveFilePath = Application.streamingAssetsPath + "/"; //文件保存路径
  34. //服务器IP地址 ,127.0.0.1 为本机IP地址
  35. IPAddress ip = IPAddress.Parse(myip);
  36. //IPAddress ip = IPAddress.Any; //本机地址
  37. Debug.Log(ip.ToString());
  38. serverSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
  39. IPEndPoint iPEndPoint = new IPEndPoint(ip, myPort);
  40. serverSocket.Bind(iPEndPoint); //绑定IP地址:端口
  41. serverSocket.Listen(10); //最多10个连接请求
  42. //Console.WriteLine("creat service {0} success",
  43. // serverSocket.LocalEndPoint.ToString());
  44. myThread = new Thread(ListenClientConnect);
  45. myThread.Start();
  46. Debug.Log("服务器启动...........");
  47. }
  48. // 监听客户端是否连接
  49. private void ListenClientConnect()
  50. {
  51. while (true)
  52. {
  53. Socket clientSocket = serverSocket.Accept(); //1.创建一个Socket 接收客户端发来的连接请求 没有时堵塞
  54. string clientIp = ((IPEndPoint)clientSocket.RemoteEndPoint).Address.ToString();
  55. Debug.Log("客户端连接成功:" + clientIp);
  56. clientSocket.Send(Encoding.UTF8.GetBytes("连接成功")); //2.向客户端发送 连接成功 消息
  57. Thread receiveThread = new Thread(ReceiveMessage); //3.为已经连接的客户端创建一个线程 此线程用来处理客户端发送的消息
  58. receiveThread.Start(clientSocket); //4.开启线程
  59. //将已经连接的客户端添加到字典中
  60. if (!threadDic.ContainsKey(clientIp))
  61. {
  62. threadDic.Add(clientIp, receiveThread);
  63. }
  64. }
  65. }
  66. private byte[] result = new byte[1024]; //1.存入的byte值 最大数量1024
  67. private byte[] subpackageData; //1.分包数据存入信息
  68. int dataLength; //要接收信息总的长度
  69. bool isEndData = false; //是否接收到信息总长度
  70. //开启线程接收数据 (将Socket作为值传入)
  71. private void ReceiveMessage(object clientSocket)
  72. {
  73. Socket myClientSocket = (Socket)clientSocket; //2.转换传入的客户端Socket
  74. while (true)
  75. {
  76. try
  77. {
  78. result = new byte[1024]; //接收前要清空 否则写入时会保留后面的数值
  79. //接收数据
  80. int receiveNumber = myClientSocket.Receive(result); //3.将客户端得到的byte值写入
  81. //没有接收信息总长度
  82. if (!isEndData)
  83. {
  84. //接收
  85. dataLength = int.Parse(Encoding.UTF8.GetString(result));
  86. subpackageData = new byte[0]; //初始化缓冲区
  87. Debug.Log("1.接收到信息的总长度: " + dataLength);
  88. isEndData = true;
  89. }
  90. else
  91. {
  92. //有数据 并且 接收到信息长度后执行
  93. if (receiveNumber > 0 && isEndData)
  94. {
  95. //1.整合数据
  96. byte[] newResult = new byte[(subpackageData.Length + receiveNumber)];
  97. Array.Copy(subpackageData, 0, newResult, 0, subpackageData.Length); //将上一次分包数据赋值给容器
  98. Array.Copy(result, 0, newResult, subpackageData.Length, receiveNumber); //将当前收到的数据赋值给容器
  99. subpackageData = newResult;
  100. Debug.Log("整合后数据长度: " + subpackageData.Length);
  101. //整合的数据超出 或等于数据
  102. if (subpackageData.Length >= dataLength)
  103. {
  104. isEndData = false; //设置没有接收到信息总长度
  105. //数据解析
  106. string data = Encoding.UTF8.GetString(subpackageData);
  107. Debug.Log(data);
  108. DisposeData(data);
  109. myClientSocket.Send(Encoding.UTF8.GetBytes("文件转换成功" + DateTime.Now));
  110. }
  111. }
  112. else
  113. {
  114. Debug.Log("client: " + ((IPEndPoint)myClientSocket.RemoteEndPoint).Address.ToString() + "断开连接");
  115. threadDic[((IPEndPoint)myClientSocket.RemoteEndPoint).Address.ToString()].Abort(); //清除线程
  116. }
  117. }
  118. }
  119. catch (Exception ex)
  120. {
  121. //myClientSocket.Shutdown(SocketShutdown.Both); //出现错误 关闭Socket
  122. Debug.Log(" 错误信息" + ex); //打印错误信息
  123. break;
  124. }
  125. }
  126. }
  127. #region 数据处理
  128. private void DisposeData(string data)
  129. {
  130. //UTF8Encoding m_utf8 = new UTF8Encoding(false); //这是不带有BOM的UTF-8 使用带有BOM的UTF-8转换Json容易失败
  131. jsonData = JsonMapper.ToObject<JsonData>(data);
  132. string savePath = saveFilePath + jsonData.flieName;
  133. Debug.Log(savePath);
  134. //上传附件 判断是否存在
  135. if (File.Exists(savePath))
  136. {
  137. //文件存在 重命名新文件
  138. savePath = saveFilePath + "(Colon)"+jsonData.flieName;
  139. }
  140. Bytes2File(jsonData.fileData, savePath); //将byte数据转换为文件
  141. }
  142. #endregion
  143. #region 将byte数组转换为文件并保存到指定地址
  144. /// <summary>
  145. /// 将byte数组转换为文件并保存到指定地址
  146. /// </summary>
  147. /// <param name="buff">byte数组</param>
  148. /// <param name="savepath">保存地址</param>
  149. public static void Bytes2File(byte[] buff, string savepath)
  150. {
  151. if (File.Exists(savepath))
  152. {
  153. File.Delete(savepath);
  154. }
  155. FileStream fs = new FileStream(savepath, FileMode.CreateNew);
  156. BinaryWriter bw = new BinaryWriter(fs);
  157. bw.Write(buff, 0, buff.Length);
  158. bw.Close();
  159. fs.Close();
  160. }
  161. #endregion
  162. void OnApplicationQuit()
  163. {
  164. //结束线程必须关闭 否则下次开启会出现错误 (如果出现的话 只能重启unity了)
  165. myThread.Abort();
  166. //关闭开启的线程
  167. foreach (string item in threadDic.Keys)
  168. {
  169. Debug.Log(item);//de.Key对应于key/value键值对key
  170. //item.Value.GetType()
  171. threadDic[item].Abort();
  172. }
  173. }
  174. }

三、客户端最终代码

  1. using System.Collections;
  2. using System.Collections.Generic;
  3. using System.Net;
  4. using System.Net.Sockets;
  5. using System.Text;
  6. using UnityEngine.UI;
  7. using UnityEngine;
  8. using System;
  9. using System.IO;
  10. using LitJson;
  11. //Json数据
  12. [Serializable]
  13. public class JsonData
  14. {
  15. public string operationType = string.Empty; //服务器事件类型(选择服务器要执行的方法)
  16. public string clientIP = string.Empty; //客户端本地ip
  17. public string flieName = string.Empty; //文件名称(文件名称)
  18. public byte[] fileData = new byte[] { }; //文件byte[]数据
  19. }
  20. public class SocketClient : MonoBehaviour
  21. {
  22. private string myip;
  23. private int myPort; //端口
  24. JsonData jsonData; //整合的json数据
  25. public Button sendBtn;//发送
  26. public InputField path;//信息
  27. Socket clientSocket;
  28. byte[] sendData; //要发送的数据
  29. private static byte[] result = new byte[1024]; //接收服务器的数据
  30. string filePath;
  31. void Start()
  32. {
  33. myip = ConfigFile.LoadString("Server");
  34. myPort = int.Parse(ConfigFile.LoadString("port"));
  35. //按钮监听
  36. sendBtn.onClick.AddListener(delegate {
  37. //判断 路径不为空 并且 文件存在
  38. if (!path.text.Equals(string.Empty)&& File.Exists(path.text))
  39. {
  40. //判断 文件是否存在\反斜杠
  41. filePath = path.text.Contains("\\") ? path.text.Replace('\\', '/') : path.text;
  42. Debug.Log(filePath);
  43. try
  44. {
  45. //获取文件名称 类型
  46. FieldSplit(filePath, '/');
  47. jsonData = new JsonData()
  48. {
  49. operationType = "上传附件",
  50. clientIP = GetLocalIP.GetIP(GetLocalIP.ADDRESSFAM.IPv4),
  51. flieName = splitData[splitData.Length - 1],
  52. fileData = GetFileData(filePath) //将文件转换为byte[]
  53. };
  54. Debug.Log(jsonData.flieName);
  55. sendData = Encoding.UTF8.GetBytes(JsonMapper.ToJson(jsonData)); //将json数据转换为byte
  56. //1.先发送 数据长度
  57. clientSocket.Send(Encoding.UTF8.GetBytes(sendData.Length.ToString()));
  58. Debug.Log("byte数量:" + sendData.Length.ToString());
  59. //2.发送内容
  60. clientSocket.Send(sendData);//传送信息
  61. }
  62. catch (Exception ex)
  63. {
  64. Debug.Log("发送失败:" + ex);
  65. }
  66. }
  67. });
  68. //监听连接的客户端连接
  69. ListeningClient();
  70. }
  71. #region 获取文件名称 类型
  72. string[] splitData;
  73. private void FieldSplit(string field,char _value)
  74. {
  75. splitData = field.Split(_value);
  76. }
  77. #endregion
  78. void Update()
  79. {
  80. if (Input.GetKeyDown(KeyCode.Escape))
  81. {
  82. Application.Quit();
  83. }
  84. }
  85. #region 监听连接的客户端连接
  86. private void ListeningClient()
  87. {
  88. //要连接的服务器IP地址
  89. IPAddress ip = IPAddress.Parse(myip);//本地IP地址
  90. clientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
  91. try
  92. {
  93. clientSocket.Connect(new IPEndPoint(ip, myPort)); //配置服务器IP与端口 ,并且尝试连接
  94. }
  95. catch (Exception ex)
  96. {
  97. Debug.Log("Connect lose" + ex); //打印连接失败
  98. return;
  99. }
  100. int receiveLength = clientSocket.Receive(result);//接收服务器回复消息,成功则说明已经接通
  101. Debug.Log("服务器消息长度:" + receiveLength);
  102. if (receiveLength > 1)
  103. {
  104. Debug.Log("接收服务器消息:" + Encoding.UTF8.GetString(result));
  105. }
  106. }
  107. #endregion
  108. #region 将文件转换成byte[] 数组
  109. /// <summary>
  110. /// 将文件转换成byte[] 数组
  111. /// </summary>
  112. /// <param name="fileUrl">文件路径文件名称</param>
  113. /// <returns>byte[]</returns>
  114. protected byte[] GetFileData(string fileUrl)
  115. {
  116. FileStream fs = new FileStream(fileUrl, FileMode.Open, FileAccess.Read);
  117. lock (fs)
  118. {
  119. try
  120. {
  121. byte[] buffur = new byte[fs.Length];
  122. fs.Read(buffur, 0, (int)fs.Length);
  123. return buffur;
  124. }
  125. catch (Exception ex)
  126. {
  127. return null;
  128. }
  129. finally
  130. {
  131. if (fs != null)
  132. {
  133. //关闭资源
  134. fs.Close();
  135. }
  136. }
  137. }
  138. }
  139. #endregion
  140. }

四、其他脚本:

1.获取本地ip

  1. using System.Collections;
  2. using System.Collections.Generic;
  3. using System.Net.NetworkInformation;
  4. using System.Net.Sockets;
  5. using UnityEngine;
  6. public class GetLocalIP
  7. {
  8. #region 获取本地IP地址
  9. public enum ADDRESSFAM
  10. {
  11. IPv4, IPv6
  12. }
  13. /// <summary>
  14. /// 获取本机IP
  15. /// </summary>
  16. /// <param name="Addfam">要获取的IP类型</param>
  17. /// <returns></returns>
  18. public static string GetIP(ADDRESSFAM Addfam)
  19. {
  20. if (Addfam == ADDRESSFAM.IPv6 && !Socket.OSSupportsIPv6)
  21. {
  22. return null;
  23. }
  24. string output = "";
  25. foreach (NetworkInterface item in NetworkInterface.GetAllNetworkInterfaces())
  26. {
  27. #if UNITY_EDITOR_WIN || UNITY_STANDALONE_WIN
  28. NetworkInterfaceType _type1 = NetworkInterfaceType.Wireless80211;
  29. NetworkInterfaceType _type2 = NetworkInterfaceType.Ethernet;
  30. if ((item.NetworkInterfaceType == _type1 || item.NetworkInterfaceType == _type2) && item.OperationalStatus == OperationalStatus.Up)
  31. #endif
  32. {
  33. foreach (UnicastIPAddressInformation ip in item.GetIPProperties().UnicastAddresses)
  34. {
  35. //IPv4
  36. if (Addfam == ADDRESSFAM.IPv4)
  37. {
  38. if (ip.Address.AddressFamily == AddressFamily.InterNetwork)
  39. {
  40. output = ip.Address.ToString();
  41. }
  42. }
  43. //IPv6
  44. else if (Addfam == ADDRESSFAM.IPv6)
  45. {
  46. if (ip.Address.AddressFamily == AddressFamily.InterNetworkV6)
  47. {
  48. output = ip.Address.ToString();
  49. }
  50. }
  51. }
  52. }
  53. }
  54. return output;
  55. }
  56. #endregion
  57. }

2.获取xml

  1. using System.Xml.Linq;
  2. using System.Collections;
  3. using System.Collections.Generic;
  4. using UnityEngine;
  5. using System;
  6. public class ConfigFile
  7. {
  8. static string path = Application.dataPath + "/StreamingAssets/ConfigFile.xml";
  9. public static string LoadString(string str)
  10. {
  11. XDocument document = XDocument.Load(path);
  12. //获取到XML的根元素进行操作
  13. XElement root = document.Root;
  14. XElement ele = root.Element(str);
  15. return ele.Value;
  16. }
  17. }

3.ConfigFile.xml 配置文件 放到StreamingAssets文件夹下

  1. <?xml version="1.0" encoding="utf-8"?>
  2. <Info>
  3. <!--服务器ip配置-->
  4. <Server>127.0.0.1</Server>
  5. <port>9999</port>
  6. </Info>

4.json插件

链接:https://pan.baidu.com/s/14SgSgrK14zdGURfXVjeyjg 
提取码:syq1

最终效果:

客户端:

 服务器:

 上传成功  我们看一下内容是否有问题

客户端发送的文件:

 服务器接收的文件:

内容没问题 成功。。。 

声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/我家自动化/article/detail/108364
推荐阅读
相关标签
  

闽ICP备14008679号