using System;
using System.Collections.Generic;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;
namespace ChatRoomService
{
? ? class Service
? ? {
? ? ? ? Socket socketSevice ;
? ? ? ? List<Socket> userList;//用戶組
? ? ? ? public Service()
? ? ? ? {
? ? ? ? ? ?socketSevice = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
? ? ? ? ? ?userList = new List<Socket>();
? ? ? ? }

? ? ? ? public void ?Start()
? ? ? ? {
? ? ? ? ? ? socketSevice.Bind(new IPEndPoint(IPAddress.Any,5566));
? ? ? ? ? ? socketSevice.Listen(10);
? ? ? ? ? ? Console.WriteLine("服務(wù)器啟動成功");

? ? ? ? ? ? //開啟接受連接,用多線程
? ? ? ? ? ? Thread accThread = new Thread(Accept);
? ? ? ? ? ? accThread.IsBackground = true;
? ? ? ? ? ? accThread.Start();
? ? ? ? }

? ? ? ? private void Accept()
? ? ? ? {
? ? ? ? ? ? //接受連接
? ? ? ? ? ? Socket clientSocket = socketSevice.Accept();
? ? ? ? ? ? userList.Add(clientSocket);
? ? ? ? ? ? //打印已經(jīng)連接IP地址
? ? ? ? ? ? Console.WriteLine(IPToAddress(clientSocket)+"連接進(jìn)來了");

? ? ? ? ? ? //
? ? ? ? ? ? Thread RecvThread = new Thread(ReceMessage);
? ? ? ? ? ? RecvThread.IsBackground = true;
? ? ? ? ? ? RecvThread.Start(clientSocket);

? ? ? ? ? ? Accept();//遞歸
? ? ? ? }
? ? ? ? //接收客戶端信息
? ? ? ? private void ReceMessage(Object obj)
? ? ? ? {
? ? ? ? ? ? Socket client = obj as Socket;
? ? ? ? ? ? byte[] strByte = new byte[1024 * 1024];//設(shè)定接受字符的長度
? ? ? ? ? ? string str = "";
? ? ? ? ? ? try
? ? ? ? ? ? {
? ? ? ? ? ? ? int len = client.Receive(strByte);//接受用戶發(fā)送的內(nèi)容
? ? ? ? ? ? ? str = Encoding.Default.GetString(strByte, 0, len);
? ? ? ? ? ? ? Broadcast(str,client);//廣播給用戶
? ? ? ? ? ? ? Console.WriteLine(str);
? ? ? ? ? ? ?}
? ? ? ? ? ? ?catch (Exception e)
? ? ? ? ? ? ?{
? ? ? ? ? ? ? ? Console.WriteLine(IPToAddress(client)+"退出");
? ? ? ? ? ? ? ? userList.Remove(client);
? ? ? ? ? ? ? ? Thread.CurrentThread.Abort();//退出時(shí)掐死線程，不然遞歸反彈
? ? ? ? ? ? }
? ? ? ? ? ?ReceMessage(client); //使用遞歸
? ? ? ? }

? ? ? ? /// <summary>
? ? ? ? /// 廣播信息
? ? ? ? /// </summary>
? ? ? ? /// <param name="useStr">傳入收到的傳輸?shù)膬?nèi)容</param>
? ? ? ? /// <param name="obj">傳送信息的客戶</param>
? ? ? ? private void Broadcast(string userStr,object obj)
? ? ? ? {
? ? ? ? ? ? Socket clientSend = obj as Socket; //當(dāng)前發(fā)送信息的客戶
? ? ? ? ? ? foreach (Socket client in userList)
? ? ? ? ? ? {
? ? ? ? ? ? ? ? if (client != clientSend)//將信息廣播給其他用戶
? ? ? ? ? ? ? ? {
? ? ? ? ? ? ? ? ? ? client.Send(Encoding.Default.GetBytes(IPToAddress(clientSend)+":"+userStr));
? ? ? ? ? ? ? ? }
? ? ? ? ? ? }
? ? ? ? }? ? ? ? //轉(zhuǎn)換出連來客戶的IP地址
? ? ? ? private string IPToAddress(Socket soket)
? ? ? ? {
? ? ? ? ? ? return (soket.RemoteEndPoint as IPEndPoint).Address.ToString();
? ? ? ? }
? ? }
}

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace ChatRoomService
{
? ? class Program
? ? {
? ? ? ? static void Main(string[] args)
? ? ? ? {
? ? ? ? ? ? Service ss = new Service();
? ? ? ? ? ? ss.Start();
? ? ? ? ? ? Console.ReadLine();
? ? ? ? }
? ? }
}

using System;
using System.Collections.Generic;
using System.Linq;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;
using System.Threading.Tasks;

namespace ChatRoom
{
? ? class ClientRoom
? ? {
? ? ? ? Socket clientSocket;

? ? ? ? public ClientRoom()
? ? ? ? {
? ? ? ? ? ? clientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);//初始化服務(wù)器
? ? ? ? }
? ? ? ? /// <summary>
? ? ? ? /// 連接服務(wù)器
? ? ? ? /// </summary>
? ? ? ? /// <param name="Ip"></param>
? ? ? ? /// <param name="port"></param>
? ? ? ? public void Connected(string Ip,int port)
? ? ? ? {
? ? ? ? ? ? clientSocket.Connect(Ip,port);
? ? ? ? ? ? Console.WriteLine("連接成功");
? ? ? ? ? ? // ClientSocket.Bind(new IPEndPoint());

? ? ? ? ? ? Thread RecvThread = new Thread(RecvMessage);
? ? ? ? ? ? RecvThread.IsBackground = true;
? ? ? ? ? ? RecvThread.Start();
? ? ? ? }

? ? ? ?public void Send(String str)
? ? ? ? {
? ? ? ? ? ? clientSocket.Send(Encoding.Default.GetBytes(str));
? ? ? ? }

? ? ? ? /// <summary>
? ? ? ? /// 接受信息
? ? ? ? /// </summary>
? ? ? ? private void RecvMessage()
? ? ? ? {
? ? ? ? ? ? try
? ? ? ? ? ? {
? ? ? ? ? ? ? ? byte[] strByte = new byte[500 * 1024];
? ? ? ? ? ? ? ? int len = clientSocket.Receive(strByte);
? ? ? ? ? ? ? ? Console.WriteLine(Encoding.Default.GetString(strByte, 0, len));
? ? ? ? ? ? }
? ? ? ? ? ? catch (Exception e) //服務(wù)器關(guān)閉
? ? ? ? ? ? {
? ? ? ? ? ? ? ? Console.WriteLine("服務(wù)器關(guān)閉");
? ? ? ? ? ? ? ? Thread.CurrentThread.Abort();//關(guān)閉時(shí)切斷進(jìn)程
? ? ? ? ? ? }
? ? ? ? ? ? RecvMessage();
? ? ? ? } ? ? ? ?
? ? }
}

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace ChatRoom
{
? ? class Program
? ? {
? ? ? ? static void Main(string[] args)
? ? ? ? {
? ? ? ? ? ? ClientRoom client = new ClientRoom();
? ? ? ? ? ? client.Connected("127.0.0.1", 5566);
? ? ? ? ? ? string str = Console.ReadLine();
? ? ? ? ? ? while (!str.Equals("q"))
? ? ? ? ? ? {
? ? ? ? ? ? ? ? client.Send(str);
? ? ? ? ? ? ? ? str = Console.ReadLine();
? ? ? ? ? ? }
? ? ? ? ? ? Console.ReadLine();
? ? ? ? }
? ? }
}