tcp局域网简单通讯

using UnityEngine;
using System;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;
///using PimDeWitte.UnityMainThreadDispatcher;
using UnityEngine.UI;
using UnityEngine.Video;
using System.IO;
using System.Collections;
using UnityEngine.Networking;
using System.Collections.Generic;
using System.Linq;
public class TCPServer : MonoBehaviour
{
// Port to listen for incoming connections
public int serverPort = 8888;

1. // TCP listener
2. TcpListener listener;
4. //public Test Test;
6. // Start is called before the first frame update
7. void Start()
8. {

复制代码

// Test = GetComponent();
StartServer();
// PlayVideo(“初始场景”);
}

1. // Method to start the TCP server
2. void StartServer()
3. {
4.     try
5.     {
6.         listener = new TcpListener(IPAddress.Any, serverPort);
7.         listener.Start();
8.         Debug.Log("Server started, listening on port " + serverPort);
9.         isCliect = true;
11.         // Start accepting incoming connections in a separate thread
12.         Thread acceptThread = new Thread(new ThreadStart(AcceptConnections));
13.         acceptThread.Start();
14.     }
16.     catch (Exception e)
17.     {
18.       //  Debug.LogError("Failed to start server: " + e.Message);
19.     }
21. }
24. // Method to accept incoming connections
25. void AcceptConnections()
26. {
27.     while (true)
28.     {
29.         try
30.         {
31.             TcpClient client = listener.AcceptTcpClient();
32.             Debug.Log("Client connected: " + ((IPEndPoint)client.Client.RemoteEndPoint).Address.ToString());
34.             // Handle client communication in a separate thread
35.             Thread clientThread = new Thread(new ParameterizedThreadStart(HandleClient));
36.             clientThread.Start(client);
37.         }
39.         catch (Exception e)
40.         {
41.             //Debug.LogError("Error accepting client connection: " + e.Message);
42.         }
44.     }
46. }
49. // Method to handle client communication
50. List<byte> buffer = new List<byte>();
51. void HandleClient(object clientObj)
52. {
54.     TcpClient client = (TcpClient)clientObj;
55.     NetworkStream stream = client.GetStream();
57.     byte[] tempBuffer = new byte[1024];
58.   //  int bytesRead;
59.    
60.     while (isCliect)
61.     {
62.         try
63.         {
64.             int bytesRead = stream.Read(tempBuffer, 0, tempBuffer.Length);
65.             buffer.AddRange(tempBuffer.Take(bytesRead));
66.             if (buffer.Contains((byte)'\n'))
67.             {
68.                 byte[] completeData = buffer.ToArray();
69.                 string message = Encoding.UTF8.GetString(completeData, 0, completeData.Length - 1); // 移除分隔符
70.                 buffer.Clear(); // 清空缓冲区
71.                 if (string.IsNullOrEmpty(message)) AcceptConnections();
72.                 else
73.                 {
74.                     Debug.LogError(message);
75.                     StreamingAssetsEnumerator.instances.play(message);
76.                 }
78.                 Debug.Log(message);       // 处理数据...
79.             }
81.             // Read data from the client
82.            
83.                
85.             // 在这里处理接收到的消息并发送响应消息给客户端
86.             // Perform action based on received data
89.          
91.             
92.         }
94.         catch (Exception e)
95.         {
96.             Debug.LogError("Error receiving data from client: " + e.Message);
97.         }
99.     }
102.     client.Close();
103. }
106. public bool isCliect = false;
107. // Method to stop the server
108. void OnApplicationQuit()
109. {
110.     if (listener != null)
111.     {
112.         listener.Stop();
113.         isCliect = false;
114.     }
116. }

复制代码

}

服务器端从streamingassets下读取图片或者视频需要插入插件UnityMainThreadDispatcher-master插件
using UnityEngine;
using System;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;
using UnityEngine.UI;
public class TCPClient : MonoBehaviour
{
// IP address and port of the server
public string serverIP; // Replace with the IP address of your computer
public int serverPort;

1. // TCP client
2. TcpClient client;
3. NetworkStream stream;
5. public Image signal;
9. public Button Quit;
10. // Start is called before the first frame update
11. void Start()
12. {
13.     Quit.onClick.AddListener(() => QuitApp());
15.     serverIP = IPReader.ipAddress;
16.     serverPort = IPReader.port;
17.     ConnectToServer();
18.     //ContentServer();
19.     // InvokeRepeating("Reconnect", 1f, 1f);
20. }
23. // Method to connect to the server
27. void ContentServer()
28. {
29.     try
30.     {
31.         client = new TcpClient(serverIP, serverPort);
32.         Debug.Log("连接成功！");
33.         stream = client.GetStream();
34.         signal.color = Color.green;
35.         // 这里可以添加已连接的处理逻辑
36.     }
38.     catch (SocketException)
39.     {
40.         Debug.Log("连接失败！");
41.         signal.color = Color.red;
42.         // 处理连接失败的情况
43.     }
46. }
53. void ConnectToServer()
54. {
56.     while (true)
57.     {
58.         try
59.         {
60.             client = new TcpClient();
61.             client.Connect(serverIP, serverPort);
62.             stream = client.GetStream();
63.             Debug.Log("Connected to server.");
65.             signal.color = Color.green;
66.             // Start listening for incoming messages in a separate thread
67.             Thread receiveThread = new Thread(new ThreadStart(ReceiveData));
68.             receiveThread.Start();
69.             break; // Exit the loop once connected
70.         }
72.         catch (Exception e)
73.         {
74.             break;
75.             Debug.LogError("Failed to connect to server: " + e.Message);
76.             signal.color = Color.red;
78.             Thread.Sleep(3000); // Wait for 3 seconds before attempting to reconnect
79.         }
81.     }
83. }
86. // Method to receive data from the server
87. void ReceiveData()
88. {
89.     byte[] buffer = new byte[1024];
90.     int bytesRead;
92.     while (true)
93.     {
94.         try
95.         {
96.             // Read data from the server
97.             bytesRead = stream.Read(buffer, 0, buffer.Length);
98.             string receivedData = Encoding.UTF8.GetString(buffer, 0, bytesRead);
99.             Debug.LogError("Received data from server: " + receivedData);
100.         }
102.         catch (Exception e)
103.         {
104.             Debug.LogError("Error receiving data from server: " + e.Message);
105.             break;
106.         }
108.     }
110. }
114. // Method to send data to the server
115. public void SendData(byte[] data)
116. {
118.     if (stream == null || !client.Connected) ConnectToServer();
119.     if (stream != null && client.Connected)
120.     {
121.         byte[] sendData = data;
122.         stream.Write(sendData, 0, sendData.Length);
123.         Debug.Log("Sent data to server: " + data);
124.     }
126. }
129. // Clean up resources when the application quits
130. void OnApplicationQuit()
131. {
132.     if (client != null && client.Connected)
133.     {
134.         client.Close();
135.     }
137. }
141. public void QuitApp()
142. {

复制代码

#if UNITY_EDITOR
UnityEditor.EditorApplication.isPlaying = false;
#else
Application.Quit();
#endif

1. }

复制代码

}

`

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。