UnityTCP通信聊天

【实例截图】

【核心代码】

/// </summary>
public void ConnectToTcpServer()
{
try
{
OnLog(string.Format("Connecting to {0}:{1}", IPAddress, Port));
clientReceiveThread = new Thread(new ThreadStart(ListenForData));
clientReceiveThread.IsBackground = true;
clientReceiveThread.Start();
}
catch (Exception e)
{
OnLog("On client connect exception " e);
}
}

/// <summary>
/// Runs in background clientReceiveThread; Listens for incoming data.
/// </summary>     
private void ListenForData()
{
try
{
socketConnection = new TcpClient(IPAddress, Port);
OnConnected(this);
OnLog("Connected");

Byte[] bytes = new Byte[1024];
running = true;
while (running)
{
// Get a stream object for reading
using (stream = socketConnection.GetStream())
{
int length;
// Read incoming stream into byte array.
while (running && stream.CanRead)
{
length = stream.Read(bytes, 0, bytes.Length);
if (length != 0)
{
var incomingData = new byte[length];
Array.Copy(bytes, 0, incomingData, 0, length);
// Convert byte array to string message.
string serverJson = Encoding.ASCII.GetString(incomingData);
TCPTestServer.ServerMessage serverMessage = JsonUtility.FromJson<TCPTestServer.ServerMessage>(serverJson);
MessageReceived(serverMessage);
}
}
}
}
socketConnection.Close();
OnLog("Disconnected from server");
OnDisconnected(this);
}
catch (SocketException socketException)
{
OnLog("Socket exception: " socketException);
}
}

public void CloseConnection()
{
SendMessage("!disconnect");
running = false;
}

public void MessageReceived(TCPTestServer.ServerMessage serverMessage)
{
OnMessageReceived(serverMessage);
}

/// <summary>
/// Send message to server using socket connection.
/// </summary>
public bool SendMessage(string clientMessage)
{
if (socketConnection != null && socketConnection.Connected)
{
try
{
// Get a stream object for writing.
NetworkStream stream = socketConnection.GetStream();
if (stream.CanWrite)
{
// Convert string message to byte array.                 
byte[] clientMessageAsByteArray = Encoding.ASCII.GetBytes(clientMessage);
// Write byte array to socketConnection stream.                 
stream.Write(clientMessageAsByteArray, 0, clientMessageAsByteArray.Length);
OnSentMessage(clientMessage);
return true;
}
}
catch (SocketException socketException)
{
OnLog("Socket exception: " socketException);
}
}

return false;
}

public virtual void OnSentMessage(string message)
{
}
}