C#基于Socket的TCP通信實現(xiàn)聊天室案例

第C#基于Socket的TCP通信實現(xiàn)聊天室案例本文實例為大家分享了C#基于Socket的TCP通信實現(xiàn)聊天室的具體代碼，供大家參考，具體內(nèi)容如下

一、Socket(套接字)通信概念

套接字（socket）是通信的基石，用于描述IP地址和端口，是一個通信鏈的句柄，可以用來實現(xiàn)不同虛擬機或不同計算機之間的通信,是支持TCP/IP協(xié)議的網(wǎng)絡(luò)通信的基本操作單元。它是網(wǎng)絡(luò)通信過程中端點的抽象表示，包含進行網(wǎng)絡(luò)通信必須的五種信息：連接使用的協(xié)議，本地主機的IP地址，本地進程的協(xié)議端口，遠地主機的IP地址，遠地進程的協(xié)議端口。

應(yīng)用層通過傳輸層進行數(shù)據(jù)通信時，TCP會遇到同時為多個應(yīng)用程序進程提供并發(fā)服務(wù)的問題。多個TCP連接或多個應(yīng)用程序進程可能需要通過同一個TCP協(xié)議端口傳輸數(shù)據(jù)。為了區(qū)別不同的應(yīng)用程序進程和連接，許多計算機操作系統(tǒng)為應(yīng)用程序與TCP／IP協(xié)議交互提供了套接字(Socket)接口。應(yīng)用層可以和傳輸層通過Socket接口，區(qū)分來自不同應(yīng)用程序進程或網(wǎng)絡(luò)連接的通信，實現(xiàn)數(shù)據(jù)傳輸?shù)牟l(fā)服務(wù)。

二、建立socket連接

建立Socket連接至少需要一對套接字，其中一個運行于客戶端，稱為ClientSocket，另一個運行于服務(wù)器端，稱為ServerSocket。

套接字之間的連接過程分為三個步驟：服務(wù)器監(jiān)聽，客戶端請求，連接確認。

1、服務(wù)器監(jiān)聽：服務(wù)器端套接字并不定位具體的客戶端套接字，而是處于等待連接的狀態(tài)，實時監(jiān)控網(wǎng)絡(luò)狀態(tài)，等待客戶端的連接請求

2、客戶端請求：指客戶端的套接字提出連接請求，要連接的目標是服務(wù)器端的套接字。為此，客戶端的套接字必須首先描述它要連接的服務(wù)器的套接字，指出服務(wù)器端套接字的地址和端口號，然后就向服務(wù)器端套接字提出連接請求。

3、連接確認：當服務(wù)器端套接字監(jiān)聽到或者說接收到客戶端套接字的連接請求時，就響應(yīng)客戶端套接字的請求，建立一個新的線程，把服務(wù)器端套接字的描述發(fā)給客戶端，一旦客戶端確認了此描述，雙方就正式建立連接。而服務(wù)器端套接字繼續(xù)處于監(jiān)聽狀態(tài)，繼續(xù)接收其他客戶端套接字的連接請求。

三、SOCKET連接與TCP連接

創(chuàng)建Socket連接時，可以指定使用的傳輸層協(xié)議，Socket可以支持不同的傳輸層協(xié)議（TCP或UDP），當使用TCP協(xié)議進行連接時，該Socket連接就是一個TCP連接。

socket通信:分為同步和異步通信,通信兩端分別為客戶端（Client）和服務(wù)器(Server),，本文簡單介紹一下同步通信及案例

聊天室案例服務(wù)端

usingSystem;

usingSystem.Collections.Generic;

usingSystem.ComponentModel;

usingSystem.Data;

usingSystem.Drawing;

usingSystem.Linq;

usingSystem.Text;

usingSystem.Threading.Tasks;

usingSystem.Windows.Forms;

usingSystem.Net;

usingSystem.Net.Sockets;

usingSystem.Threading;

namespace服務(wù)器

publicpartialclassForm1:Form

{

publicForm1()

{

InitializeComponent();

//在多線程編程中,如果需要使用大到主線程需要進行檢查取消

CheckForIllegalCrossThreadCalls=false;

}

IDictionarystring,SocketclientList=newDictionarystring,Socket

privatevoidbutton1_Click(objectsender,EventArgse)

{

Threadth=newThread(StartSever);

th.IsBackground=true;

th.Start();

}

voidStartSever()

{

//1.創(chuàng)建服務(wù)器端電話

Socketserver=newSocket(AddressFamily.InterNetwork,SocketType.Stream,ProtocolType.IP);

//2.創(chuàng)建手機卡

IPAddressip=IPAddress.Parse(txtIP.Text);

//把ip和端口轉(zhuǎn)化為IPEndPoint實例

IPEndPointendpoint=newIPEndPoint(ip,int.Parse(txtPort.Text));

//3.將電話卡插入到電話中,綁定端口

server.Bind(endpoint);

//4.開始監(jiān)聽電話

server.Listen(20);

listMsg.Items.Add("服務(wù)器已成功開啟");

//5.等待接電話

while(true)

{

//接收接入的一個客戶端

SocketconnectClient=server.Accept();

if(connectClient!=null)

{

stringinfor=connectClient.RemoteEndPoint.ToString();

clientList.Add(infor,connectClient);

listMsg.Items.Add(infor+"加入服務(wù)器");

stringmsg=infor+"已成功進入聊天室";

SendMsg(msg);

Threadthread=newThread(ReciveMsg);

thread.IsBackground=true;

thread.Start(connectClient);

}

}

}

voidReciveMsg(objecto)

{

Socketclient=oasSocket;

while(true)

{

try

{

byte[]arrMsg=newbyte[1024*1024];

intlength=client.Receive(arrMsg);

if(length0)

{

stringrecMsg=Encoding.UTF8.GetString(arrMsg,0,length);

IPEndPointendpoint=client.RemoteEndPointasIPEndPoint;

listMsg.Items.Add(DateTime.Now+"["+endpoint.Port.ToString()+"]"+recMsg);

SendMsg("["+endpoint.Port.ToString()+"]"+recMsg);

}

}

catch(Exception)

{

client.Close();

clientList.Remove(client.RemoteEndPoint.ToString());

}

}

}

privatevoidlabel1_Click(objectsender,EventArgse)

{

stringip=IPAddress.Any.ToString();

txtIP.Text=ip;

}

voidSendMsg(stringstr)

{

foreach(variteminclientList)

{

byte[]arrMsg=Encoding.UTF8.GetBytes(str);

item.Value.Send(arrMsg);

}

}

privatevoidbutton2_Click(objectsender,EventArgse)

{

if(txtMsg.Text!="")

{

SendMsg(txtMsg.Text);

}

}

}

}

客戶端

usingSystem;

usingSystem.Collections.Generic;

usingSystem.ComponentModel;

usingSystem.Data;

usingSystem.Drawing;

usingSystem.Linq;

usingSystem.Text;

usingSystem.Threading.Tasks;

usingSystem.Windows.Forms;

usingSystem.Net;

usingSystem.Net.Sockets;

usingSystem.Threading;

namespace服務(wù)器2._12

publicpartialclassForm1:Form

{

publicForm1()

{

InitializeComponent();

CheckForIllegalCrossThreadCalls=false;

}

SocketClient;

privatevoidbutton1_Click(objectsender,EventArgse)

{

//創(chuàng)建服務(wù)器端電話

Client=newSocket(AddressFamily.InterNetwork,SocketType.Stream,ProtocolType.IP);

//創(chuàng)建手機卡

IPAddressip=IPAddress.Parse(txtIP.Text);

IPEndPointendinput=newIPEndPoint(ip,int.Parse(txtport.Text));

Client.Connect(endinput);

Threadth=newThread(ReciveMsg);

th.IsBackground=true;

th.Start(Client);

}

voidReciveMsg(objecto)

{

Socketclient=oasSocket;

//5.等待接電話

while(true)