C# 客户端服务器Socket

刀锋狼

1. using UnityEngine;
   
2. using System.Collections;
   
3. using System.Net.Sockets;
   
4. using System.Net;
   
5. using System.Threading;
   
6. using System.Text;
   
7. 
   
8. public class ServerSocket {
   
9. 
   
10. public string ipstr;
    
11. public int port;
    
12. public int maxConnections;
    
13. public bool IsRun {
    
14. get {
    
15. return isRun;
    
16. }
    
17. }
    
18. 
    
19. private Socket serverSocket;
    
20. private Thread serverThread;
    
21. private bool isRun;
    
22. private Socket temp;
    
23. 
    
24. public ServerSocket (string ipStr, int port = 2333, int maxConnections = 50) {
    
25. isRun = false;
    
26. this.ipStr = ipStr;
    
27. this.port = port;
    
28. this.maxConnections = maxConnections;
    
29. serverSocket = new Socket (AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
    
30. serverSocket.Bind (new IPEndPoint (IPAddress.Parse (ipStr), port));
    
31. serverSocket.Listen (maxConnections);
    
32. serverThread = new Thread (new ThreadStart (AsyncServer));
    
33. }
    
34. 
    
35. public void StartServer () {
    
36. isRun = true;
    
37. serverThread.Start ();
    
38. }
    
39. 
    
40. public void StopServer () {
    
41. isRun = false;
    
42. serverSocket.Close ();
    
43. if (serverThread.IsAlive) {
    
44. serverThread.Abort ();
    
45. }
    
46. }
    
47. 
    
48. private ServerSocket () {
    
49. 
    
50. }
    
51. 
    
52. private void AsyncServer () {
    
53. while (isRun) {
    
54. Socket userSocket = serverSocket.Accept ();
    
55. temp = userSocket;
    
56. Thread tt = new Thread (new ThreadStart (XXX));
    
57. tt.Start ();
    
58. }
    
59. }
    
60. 
    
61. private void XXX () {
    
62. Socket user = temp;
    
63. while (true) {
    
64. byte [] receivedData = new byte [1024];
    
65. user.Receive (receivedData);
    
66. string m = Encoding.UTF8.GetString (receivedData);
    
67. Debug.Log (m);
    
68. if (m != "") {
    
69. byte [] s = Encoding.UTF8.GetBytes (m);
    
70. user.Send (s);
    
71. }
    
72. }
    
73. }
    
74. }

复制代码

1. using UnityEngine;
   
2. using System.Collections;
   
3. using System.Net.Sockets;
   
4. using System.Net;
   
5. using System.Threading;
   
6. using System.Text;
   
7. using UnityEngine.UI;
   
8. 
   
9. public class Client : MonoBehaviour {
   
10. 
    
11. public string ipStr;
    
12. public int port;
    
13. public InputField t;
    
14. public Text text;
    
15. 
    
16. private string str = "";
    
17. 
    
18. Socket s;
    
19. 
    
20. void Start () {
    
21. s = new Socket (AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
    
22. s.Connect (new IPEndPoint (IPAddress.Parse (ipStr), port));
    
23. Thread tt = new Thread (new ThreadStart (DDD));
    
24. tt.Start ();
    
25. }
    
26. 
    
27. private void DDD () {
    
28. while (true) {
    
29. byte [] r = new byte [1024];
    
30. s.Receive (r);
    
31. str = Encoding.UTF8.GetString (r);
    
32. }
    
33. }
    
34. 
    
35. void Update () {
    
36. text.text = str;
    
37. if (Input.GetKeyDown (KeyCode.S)) {
    
38. byte [] sendbuf = Encoding.UTF8.GetBytes (t.text);
    
39. s.Send (sendbuf);
    
40. }
    
41. }
    
42. }

复制代码

GPSGIS3D

水平一般般