Hololens2初入——socket 异步通讯

介绍

Hololens2真机中运行的程序与在电脑端的程序要求有些不同。它不支持同步的socket，必须采用异步的形式才能跑的通。具体的原因和细节我也没去研究过，不过记得在官网上确实提到过这一点。

下面是一段示例代码，忘了是不是从其他地方直接拷贝过来还是自己有稍微修改过了，时间有点长，也忘了参考的出处了，如果有侵犯问题请私信我。

把下面的代码复制到C#的脚本中， 脚本名称修改为TcpClient.cs，然后把这个脚本随意挂在某个对象上就可以。 这边的代码是客户端的代码，服务端的暂时忘了放在哪里了，找到再补上。

调式的话建议用一个网络调试助手小软件来调式。 网络调试助手中开启 服务端就可以。

有其他问题直接在文章下面询问， 这样其他人才能看得到，尽量不要私信我。

代码

using System;using ;using .Sockets;using System.Text;using UnityEngine;using UnityEngine.Events;using UnityEngine.UI;namespace MyCode{public class TcpClient : MonoBehaviour{//连接到Tcp客户端并能够收发信息,断线重连,将客户端发送过来的信息显示在debugText中//手机开热点服务器ip 172.20.10.1 (不一定是这个,从网络设置中查看)public Text debugText;public GameObject cube;public Socket m_socket;IPEndPoint m_endPoint;private SocketAsyncEventArgs m_connectSAEA;private SocketAsyncEventArgs m_sendSAEA;public string ip = "192.168.137.1";//改成自己的ippublic int port = 56789;private string preMsg = " ";bool needReconnect = false;public UnityEvent tcp发送事件;public UnityEvent Tcp发送事件 => tcp发送事件;private void Start(){//Client();Invoke("Client", 1f);}private void Update(){// //接收信息的回调函数上无法处理与Unity直接相关部分,在这里进行修改// if (debugText && preMsg != " ") //接收消息// {////if (preMsg == "red")////{//// cube.GetComponent<Renderer>().material.color = Color.red;//// preMsg = "";////}////else if (preMsg == "green")////{//// cube.GetComponent<Renderer>().material.color = Color.green;//// preMsg = "";////}//debugText.text = preMsg; //显示在Debug的UI上//preMsg = " ";// }// //else// //{// // cube.GetComponent<Renderer>().material.color = Color.yellow;// //}if (needReconnect) //处理断线重连{Invoke("Client", 5f);needReconnect = false;}}public void Client(){m_socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);IPAddress iPAddress = IPAddress.Parse(ip);// IPAddress iPAddress = getIdAddress();print(iPAddress.ToString());m_endPoint = new IPEndPoint(iPAddress, port);m_connectSAEA = new SocketAsyncEventArgs {RemoteEndPoint = m_endPoint};pleted += new EventHandler<SocketAsyncEventArgs>(OnConnectedCompleted);m_socket.ConnectAsync(m_connectSAEA);}private void OnConnectedCompleted(object sender, SocketAsyncEventArgs e){if (e.SocketError != SocketError.Success){needReconnect = true;return;}Socket socket = sender as Socket;string iPRemote = socket.RemoteEndPoint.ToString();Debug.Log("Client : 连接服务器" + iPRemote + "成功");SocketAsyncEventArgs receiveSAEA = new SocketAsyncEventArgs();byte[] receiveBuffer = new byte[1024 * 1024 * 16];receiveSAEA.SetBuffer(receiveBuffer, 0, receiveBuffer.Length);pleted += OnReceiveCompleted;receiveSAEA.RemoteEndPoint = m_endPoint;socket.ReceiveAsync(receiveSAEA);}private void OnReceiveCompleted(object sender, SocketAsyncEventArgs e){if (e.SocketError == SocketError.OperationAborted) return;Socket socket = sender as Socket;if (e.SocketError == SocketError.Success && e.BytesTransferred > 0){string ipAdress = socket.RemoteEndPoint.ToString();int lengthBuffer = e.BytesTransferred;byte[] receiveBuffer = e.Buffer;//读取指定位数的信息byte[] data = new byte[lengthBuffer];Array.Copy(receiveBuffer, 0, data, 0, lengthBuffer);string str = System.Text.Encoding.Default.GetString(data);string newstr = str;Debug.Log(newstr);preMsg = newstr; //这里直接赋值给debugText.text无法更新,通过update中检测的方式更新信息//向服务器端发送消息Send("Receive Message");socket.ReceiveAsync(e);}else if (e.BytesTransferred == 0) //连接断开的处理{if (e.SocketError == SocketError.Success){Debug.Log("主动断开连接 ");//DisConnect();}else{Debug.Log("被动断开连接 ");}needReconnect = true; //通过update中检测的方式更新信息}else{return;}}#region 发送public void Send(string msg){byte[] sendBuffer = Encoding.Default.GetBytes(msg);if (m_sendSAEA == null){m_sendSAEA = new SocketAsyncEventArgs();pleted += OnSendCompleted;}m_sendSAEA.SetBuffer(sendBuffer, 0, sendBuffer.Length);if (m_socket != null){m_socket.SendAsync(m_sendSAEA);}}void OnSendCompleted(object sender1, SocketAsyncEventArgs e1){if (e1.SocketError != SocketError.Success) return;Socket socket1 = sender1 as Socket;byte[] sendBuffer = e1.Buffer;string sendMsg = Encoding.Default.GetString(sendBuffer);Debug.Log("Client : Send message" + sendMsg + "to Serer" + socket1.RemoteEndPoint.ToString());}#endregion#region 断开连接void DisConnect(){Debug.Log("断开连接");if (m_socket != null){try{m_socket.Shutdown(SocketShutdown.Both);}catch (SocketException excep){}finally{m_socket.Close();}}}#endregion//——————————-10-03———————#date#—————#time#—————————//private IPAddress getIdAddress(){//IPHostEntry ipEntity = Dns.GetHostEntry(Dns.GetHostName());IPAddress ipAddr = ipEntity.AddressList[0];//IPAddress ipAddr = Dns.GetHostAddresses(Dns.GetHostName())[0];//if (ipAddr.AddressFamily == .Sockets.AddressFamily.InterNetworkV6)//判断是否IP6协议//{// ipAddr = Dns.GetHostEntry(Dns.GetHostName()).AddressList[1];//}IPAddress ipAddr = null;IPAddress[] arrIP = Dns.GetHostAddresses(Dns.GetHostName());foreach (IPAddress ip in arrIP){if (.Sockets.AddressFamily.InterNetwork.Equals(ip.AddressFamily)){ipAddr = ip; // IPV4}// else if (.Sockets.AddressFamily.InterNetworkV6.Equals(ip.AddressFamily))// {//ipAddr = ip;// }}return ipAddr;}}}