using System.Collections.Generic;
using System.Net;
using System.Net.Sockets;

namespace 聊天室_Socket_TCP_服務(wù)器端
{
? ? class Program
? ? {
? ? ? ? static List<Client> clients = new List<Client>();
? ? ? ? static List<Client> notClients = new List<Client>();

? ? ? ? /// <summary>
? ? ? ? /// 廣播消息
? ? ? ? /// </summary>
? ? ? ? /// <param name="message"></param>
? ? ? ? public static void CastMessageTOAllConnetedClients(string message)
? ? ? ? {
? ? ? ? ? ? foreach (var client in clients)
? ? ? ? ? ? {
? ? ? ? ? ? ? ? if (client.Conneted)
? ? ? ? ? ? ? ? {
? ? ? ? ? ? ? ? ? ? client.CastMessage(message);
? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? else
? ? ? ? ? ? ? ? {
? ? ? ? ? ? ? ? ? ? notClients.Add(client);
? ? ? ? ? ? ? ? }
? ? ? ? ? ? }
? ? ? ? ? ? foreach (var temp in notClients)
? ? ? ? ? ? {
? ? ? ? ? ? ? ? clients.Remove(temp);
? ? ? ? ? ? }
? ? ? ? }

? ? ? ? static void Main(string[] args)
? ? ? ? { ? ? ? ??
? ? ? ? ? ? Socket tcpSever = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
? ? ? ? ? ? tcpSever.Bind(new IPEndPoint(IPAddress.Parse("192.168.1.2"), 8899));
? ? ? ? ? ? tcpSever.Listen(100);//監(jiān)聽是否有客戶端發(fā)起連接
? ? ? ? ? ? Console.WriteLine("Begin to listen...");

? ? ? ? ? ? while (true)
? ? ? ? ? ? {
? ? ? ? ? ? ? ? Socket clientSocket = tcpSever.Accept();
? ? ? ? ? ? ? ? if (clientSocket!=null)
? ? ? ? ? ? ? ? {
? ? ? ? ? ? ? ? ? ? Console.WriteLine("A client has connneted...");
? ? ? ? ? ? ? ? ? ? Client client = new Client(clientSocket);//將每個(gè)新創(chuàng)建的連接通信放于client類做通信
? ? ? ? ? ? ? ? ? ? clients.Add(client);
? ? ? ? ? ? ? ? }
? ? ? ? ? ? }
? ? ? ? ? ? Console.ReadKey();
? ? ? ? }
? ? }
}

using System;
using System.Net.Sockets;
using System.Text;
using System.Threading;

namespace 聊天室_Socket_TCP_服務(wù)器端
{
? ? /// <summary>
? ? /// 利用該類和客戶端做通信
? ? /// </summary>
? ? class Client
? ? {
? ? ? ? public Socket clientSocket;
? ? ? ? private Thread mesManageTherad;?
? ? ? ? private byte[] bufffer=new byte[20];

? ? ? ? public Client(Socket soc)
? ? ? ? {
? ? ? ? ? ? clientSocket = soc;
? ? ? ? ? ? //由于消息是不斷發(fā)送的，需要多次進(jìn)行處理。這里開一個(gè)線程，專門用來(lái)處理消息。
? ? ? ? ? ? mesManageTherad = new Thread(MessageSendFromClient);
? ? ? ? ? ? mesManageTherad.Start();
? ? ? ? }

? ? ? ? private void MessageSendFromClient()
? ? ? ? {
? ? ? ? ? ? //開啟的線程一直檢測(cè)客戶端客戶端發(fā)過(guò)來(lái)的消息
? ? ? ? ? ? while (true)
? ? ? ? ? ? {
? ? ? ? ? ? ? ? //判斷連接是否斷開， ?SelectMode.SelectRead讀狀態(tài)模式。
? ? ? ? ? ? ? ? //poll已斷開返回true
? ? ? ? ? ? ? ? if (clientSocket.Poll(10,SelectMode.SelectRead)==true) ? ?
? ? ? ? ? ? ? ? {
? ? ? ? ? ? ? ? ? ? clientSocket.Close();
? ? ? ? ? ? ? ? ? ? break;//終止本線程
? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? ? ? int byteNum = clientSocket.Receive(bufffer);//從客戶端接受消息
? ? ? ? ? ? ? ? ? ? string mes = Encoding.UTF8.GetString(bufffer, 0 , byteNum);
? ? ? ? ? ? ? ? ? ? Console.WriteLine("客戶端發(fā)送過(guò)來(lái)的消息："+mes);
? ? ? ? ? ? ? ? ? ? //廣播消息出去給每個(gè)客戶端
? ? ? ? ? ? ? ? ? ? Program.CastMessageTOAllConnetedClients(mes);//對(duì)CastMessage的一層封裝
? ? ? ? ? ? }
? ? ? ? }

? ? ? ? /// <summary>
? ? ? ? /// Send messages to Clients
? ? ? ? /// </summary>
? ? ? ? public void CastMessage(string message)
? ? ? ? {
? ? ? ? ? ? byte[] data = Encoding.UTF8.GetBytes(message);
? ? ? ? ? ? clientSocket.Send(data);
? ? ? ? }

? ? ? ? /// <summary>
? ? ? ? /// 判斷是否斷開連接
? ? ? ? /// </summary>
? ? ? ? public bool Conneted
? ? ? ? {
? ? ? ? ? ? get
? ? ? ? ? ? {
? ? ? ? ? ? ? ? return clientSocket.Connected;
? ? ? ? ? ? }
? ? ? ? }

? ? }
}

using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;
using UnityEngine;

public class ChatManager : MonoBehaviour {

? ? private string _ipAdress = "192.168.1.2";
? ? private int _port=8899;
? ? EndPoint remotPoint;
? ? Socket clientSocket;
? ? public UIInput buttonInput;
? ? private bool isCanSend=false;
? ? private string buttonMessage=null;

? ? Thread receiveThread;
? ? byte[] bufferReceive = new byte[1024];
? ? public UILabel chatWindowLable;
? ? private string message = "";//默認(rèn)為空串


? ? // Use this for initialization
? ? void Start () {
? ? ? ? ConnetToSever(_ipAdress, _port);//與服務(wù)器建立連接
? ? }

? ? // Update is called once per frame
? ? void Update () {
? ? ? ? if (message!=null&&message!="")
? ? ? ? {
? ? ? ? ? ? chatWindowLable.text += "\n" + message;
? ? ? ? ? ? message = "";//清空消息
? ? ? ? }
? ? }

? ? void ConnetToSever(string ipadress,int port)
? ? {
? ? ? ? clientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
? ? ? ? remotPoint = new IPEndPoint(IPAddress.Parse(ipadress),port);
? ? ? ? //建立連接
? ? ? ? clientSocket.Connect(remotPoint);
? ? ? ? //因?yàn)槭且恢痹跍?zhǔn)備接受的狀態(tài)，所以開啟一個(gè)線程來(lái)負(fù)責(zé)處理接受消息
? ? ? ? receiveThread = new Thread(ReceiveMessageFormSever);
? ? ? ? receiveThread.Start();

? ? }

? ? private new void SendMessage(string message)
? ? {
? ? ? ? byte [] buffer= Encoding.UTF8.GetBytes(message);
? ? ? ? clientSocket.SendTo(buffer,remotPoint);
? ? }

? ? public void OnSendButtonClickS()
? ? {

? ? ? ? if (buttonInput.value!=null)
? ? ? ? {
? ? ? ? ? ? buttonMessage = buttonInput.value;
? ? ? ? }
? ? ? ? else
? ? ? ? {
? ? ? ? ? ? buttonMessage = "輸入框?yàn)榭眨?;
? ? ? ? }
? ? ? ? SendMessage(buttonMessage);
? ? ? ? buttonInput.value = "";
? ? }

? ? private void ReceiveMessageFormSever()
? ? {
? ? ? ? while (true)
? ? ? ? {
? ? ? ? ? ? if (clientSocket.Connected)
? ? ? ? ? ? {
? ? ? ? ? ? ? ? int length = clientSocket.Receive(bufferReceive);
? ? ? ? ? ? ? ? message = Encoding.UTF8.GetString(bufferReceive, 0, length);
? ? ? ? ? ? ? ? //ps:不要在單獨(dú)的線程里面操作unity組件
? ? ? ? ? ? }
? ? ? ? ? ? else
? ? ? ? ? ? {
? ? ? ? ? ? ? ? break;
? ? ? ? ? ? }
? ? ? ? }
? ? }
}