纳金网

标题: C# 客户端服务器Socket [打印本页]
作者: 刀锋狼    时间: 2015-7-31 00:49
标题: 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;

  8. public class ServerSocket {

  10. public string ipStr;
  11. public int port;
  12. public int maxConnections;
  13. public bool IsRun {
  14. get {
  15. return isRun;
  16. }
  17. }

  19. private Socket serverSocket;
  20. private Thread serverThread;
  21. private bool isRun;
  22. private Socket temp;

  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. }

  35. public void StartServer () {
  36. isRun = true;
  37. serverThread.Start ();
  38. }

  40. public void StopServer () {
  41. isRun = false;
  42. serverSocket.Close ();
  43. if (serverThread.IsAlive) {
  44. serverThread.Abort ();
  45. }
  46. }

  48. private ServerSocket () {

  50. }

  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. }

  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;

  9. public class Client : MonoBehaviour {

  11. public string ipStr;
  12. public int port;
  13. public InputField t;
  14. public Text text;

  16. private string str = "";

  18. Socket s;

  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. }

  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. }

  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    时间: 2017-5-5 13:57
水平一般般



欢迎光临 纳金网 (http://rs.narkii.com/club/) Powered by Discuz! X2.5