1. using System;
    2. using System.Collections;
    3. using System.Collections.Generic;
    4. using System.Net.Sockets;
    5. using UnityEngine;
    6. using UnityEngine.UI;
    8. public class Echo : MonoBehaviour
    9. {
    10.     //定义套接字
    11.     Socket socket;
    13.     //UGUI
    14.     public InputField inputField;
    15.     public Text text;
    17.     //接受缓冲区
    18.     byte[] readBuff = new byte[1024];
    19.     string recvStr = "";
    21.     /// <summary>
    22.     /// 点击连接按钮
    23.     /// </summary>
    24.     public void Connection()
    25.     {
    26.         //Socket
    27.         socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
    29.         //Connect
    30.         socket.BeginConnect("127.0.0.1", 8888, ConnectCallback, socket);
    31.     }
    33.     /// <summary>
    34.     /// Connect回调
    35.     /// </summary>
    36.     /// <param name="ar"></param>
    37.     public void ConnectCallback(IAsyncResult ar)
    38.     {
    39.         try
    40.         {
    41.             Socket socket = (Socket)ar.AsyncState;
    42.             socket.EndConnect(ar);
    43.             Debug.Log("Socket Connect Succ");
    44.             socket.BeginReceive(readBuff, 0, 1024, 0, ReceiveCallback, socket);
    45.         }
    46.         catch (SocketException ex)
    47.         {
    48.             Debug.Log("Socket Connect fail" + ex.ToString());
    49.         }
    50.     }
    52.     /// <summary>
    53.     /// Receive回调
    54.     /// </summary>
    55.     /// <param name="ar"></param>
    56.     public void ReceiveCallback(IAsyncResult ar)
    57.     {
    58.         try
    59.         {
    60.             Socket socket = (Socket)ar.AsyncState;
    61.             int count = socket.EndReceive(ar);
    62.             recvStr = System.Text.Encoding.Default.GetString(readBuff, 0, count);
    64.             socket.BeginReceive(readBuff, 0, 1024, 0, ReceiveCallback, socket);
    65.         }
    66.         catch (Exception ex)
    67.         {
    68.             Debug.Log("Socket Receive fail" + ex.ToString());
    69.         }
    70.     }
    72.     /// <summary>
    73.     /// 点击发送按钮
    74.     /// </summary>
    75.     public void Send()
    76.     {
    77.         //Send 
    78.         string sendStr = inputField.text;
    79.         byte[] sendBytes = System.Text.Encoding.Default.GetBytes(sendStr);
    81.         socket.BeginSend(sendBytes, 0, sendBytes.Length, 0, SendCallback, socket);
    83.         //后面就不需要Receive了
    84.     }
    86.     //Send回调
    87.     public void SendCallback(IAsyncResult ar)
    88.     {
    89.         try
    90.         {
    91.             Socket socket = (Socket)ar.AsyncState;
    92.             int count = socket.EndSend(ar);
    93.             Debug.Log("Socket Send succ" + count);
    94.         }
    95.         catch (SocketException ex)
    96.         {
    97.             Debug.Log("Socket Send fail" + ex.ToString());
    98.         }
    99.     }
    101.     public void Update()
    102.     {
    103.         text.text = recvStr;
    104.     }
    105. }