c#實現(xiàn)多線程局域網(wǎng)聊天系統(tǒng)
更新時間：2015年06月04日 16:16:37 投稿：hebedich
這篇文章主要介紹了c#實現(xiàn)多線程局域網(wǎng)聊天系統(tǒng)的相關代碼，有此方面需求的小伙伴可以參考下。
覺得好有點幫助就頂一下啦。
socke編程，支持多客戶端，多線程操作避免界面卡死。
開啟socket
private void button1_Click(object sender, EventArgs e)
{
try
{
int port = int.Parse(txt_port.Text);
string host = txt_ip.Text;
//創(chuàng)建終結(jié)點
IPAddress ip = IPAddress.Parse(host);
IPEndPoint ipe = new IPEndPoint(ip, port);
//創(chuàng)建Socket并開始監(jiān)聽
newsock = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); //創(chuàng)建一個Socket對象，如果用UDP協(xié)議，則要用SocketTyype.Dgram類型的套接字
newsock.Bind(ipe); //綁定EndPoint對象
newsock.Listen(0); //開始監(jiān)聽
//為新建立的連接創(chuàng)建新的Socket
acceptClientThread = new Thread(new ThreadStart(AcceptClient));
acceptClientThread.Start();
SetText("開始監(jiān)聽");
}
catch (Exception exp)
{
CommonFunction.WriteLog(exp, exp.Message);
}
}
監(jiān)控端口，接收客戶端
/// <summary>
/// 接受客戶端，可接受多個客戶端同時連入，并對連入的客戶端注冊到客戶端列表
/// </summary>
public void AcceptClient()
{
try
{
while (true)
{
Socket client = newsock.Accept();
ip = client.Handle;
RegeistUser(client.Handle, client);
Thread clientThread = new Thread(new ParameterizedThreadStart(ReceiveData));
object o = client;
clientThread.Start(o);
}
}
catch (Exception exp)
{
CommonFunction.WriteLog(exp, exp.Message);
}
}
接收客戶端數(shù)據(jù)并廣播數(shù)據(jù)
/// <summary>
/// 接收客戶端數(shù)據(jù)并，轉(zhuǎn)發(fā)到目標客戶端。
/// </summary>
public void ReceiveData(object o)
{
try
{
while (true)
{
Socket client = (Socket)o;
string recvStr = "";
byte[] recvBytes = new byte[1024];
int bytes;
bytes = client.Receive(recvBytes, recvBytes.Length, 0); //從客戶端接受消息
recvStr = Encoding.UTF8.GetString(recvBytes, 0, bytes);
SendMessage(client, recvStr);
SetText(recvStr);
CommonFunction.WriteErrorLog(recvStr);
}
}
catch (Exception exp)
{
CommonFunction.WriteLog(exp, exp.Message);
}
}
判斷是用戶注冊還是發(fā)送消息
/// <summary>
/// 判斷是用戶注冊還是發(fā)送消息
/// </summary>
/// <param name="p_strMessage"></param>
public void SendMessage(Socket client,string p_strMessage)
{
if (p_strMessage.StartsWith("@"))
{
RegeistUser(p_strMessage, client);
}
else if (p_strMessage.StartsWith(">"))
{
DeleteClident(p_strMessage);
}
else
{
//SendMessageToTarget(p_strMessage);
SendAllMessage(p_strMessage);
}
}
將socket注冊為指定用戶名
/// <summary>
/// 將socket注冊為指定用戶名
/// </summary>
/// <param name="user"></param>
/// <param name="ss"></param>
public void RegeistUser(string user, Socket ss)
{
user = user.Remove(0, 1);
userSocketDict.Add(user, ss);
SendOneMessage(ss, "歡迎" + user + "連入！");
RefreshClient();
}
從客戶端字典中移除客戶端
/// <summary>
/// 從客戶端字典中移除客戶端
/// </summary>
/// <param name="p_strMessage"></param>
public void DeleteClident(string p_strMessage)
{
p_strMessage = p_strMessage.Remove(0, 1);
userSocketDict.Remove(p_strMessage);
RefreshClient();
}
群發(fā)消息
/// <summary>
/// 群發(fā)消息
/// </summary>
/// <param name="p_strsend"></param>
public void SendAllMessage(string p_strsend)
{
//MessageBox.Show(p_strsend);
foreach (string item in userSocketDict.Keys)
{
byte[] bs = Encoding.UTF8.GetBytes(p_strsend);
userSocketDict[item].Send(bs, bs.Length, 0);
}
}
給文本框賦值
public delegate void SetTextHandler(string text);
/// <summary>
/// 給文本框賦值
/// </summary>
/// <param name="text"></param>
private void SetText(string text)
{
if (rich_back.InvokeRequired == true)
{
SetTextHandler set = new SetTextHandler(SetText);//委托的方法參數(shù)應和SetText一致
rich_back.Invoke(set, new object[] { text }); //此方法第二參數(shù)用于傳入方法,代替形參text
}
else
{
rich_back.Text += "\n" + text;
}
}
連入服務器
private void button1_Click(object sender, EventArgs e)
{
try
{
user = txt_name.Text;
int port = int.Parse(txt_port.Text);
string host = txt_ip.Text;
//創(chuàng)建終結(jié)點EndPoint
IPAddress ip = IPAddress.Parse(host);
IPEndPoint ipe = new IPEndPoint(ip, port); //把ip和端口轉(zhuǎn)化為IPEndPoint的實例
//創(chuàng)建Socket并連接到服務器
Socket c = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); // 創(chuàng)建Socket
cc = c;
c.Connect(ipe); //連接到服務器
clientThread = new Thread(new ThreadStart(ReceiveData));
clientThread.Start();
//向服務器發(fā)送本機用戶名，以便服務器注冊客戶端
SendMessage("@" + txt_name.Text);
}
catch (ArgumentException ex)
{
Console.WriteLine("argumentNullException:{0}", ex);
}
catch (SocketException exp)
{
Console.WriteLine("SocketException:{0}",exp);
}
}
向服務器發(fā)送消息
private void button3_Click(object sender, EventArgs e)
{
if (""==txt_target.Text)
{
MessageBox.Show("未選擇對話人物");
return;
}
//向服務器發(fā)送信息
string sendStr = txt_name.Text + "@" + target + ":" + txt_message.Text;
SendMessage(sendStr);
rch_back.Text += "\n" + sendStr;
txt_message.Text = "";
}
隱身
private void button2_Click(object sender, EventArgs e)
{
try
{
SendMessage(">" + txt_name.Text);
//cc.Disconnect(true);
//cc.Shutdown(SocketShutdown.Both);
//cc.Close();
}
catch (Exception exp)
{
CommonFunction.WriteLog(exp, exp.Message);
}
}
以上所述就是本文的全部內(nèi)容了，希望大家能夠喜歡。
相關文章
這篇文章主要介紹了C#利用棧實現(xiàn)加減乘除運算的實現(xiàn)方法,需要的朋友可以參考下2019-11-11
這篇文章主要介紹了C#泛型的類型參數(shù)約束的相關資料，文中講解非常細致，幫助大家更好的理解和學習c#，感興趣的朋友可以了解下2020-07-07
今天小編就為大家分享一篇關于C#將PPT文件轉(zhuǎn)換成PDF文件，小編覺得內(nèi)容挺不錯的，現(xiàn)在分享給大家，具有很好的參考價值，需要的朋友一起跟隨小編來看看吧2019-01-01
C# ODP.NET 調(diào)用Oracle函數(shù)返回值時報錯的一個解決方案
這篇文章主要介紹了C# ODP.NET 調(diào)用Oracle函數(shù)返回值時報錯的一個解決方案，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2019-12-12
這篇文章主要介紹了C#獲取每個年,月,周的起始日期和結(jié)束日期的方法,涉及C#時間與日期基本操作技巧,具有一定參考借鑒價值,需要的朋友可以參考下2017-02-02
下面小編就為大家?guī)硪黄馕鲥e誤富文本json字符串(帶雙引號)的快速解決方法。小編覺得挺不錯的，現(xiàn)在就分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2016-08-08
本文詳細講解了C#中深拷貝和淺拷貝的介紹與用法，文中通過示例代碼介紹的非常詳細。對大家的學習或工作具有一定的參考借鑒價值，需要的朋友可以參考下2022-03-03
這篇文章主要介紹了C#判斷本地文件是否處于打開狀態(tài)的方法,涉及C#操作文件的技巧,非常具有實用價值,需要的朋友可以參考下2015-05-05
C# 調(diào)用C++寫的dll的實現(xiàn)方法
C#調(diào)用C++的非托管類的dll其實很簡單基本就是固定的調(diào)用格式，有需要的朋友可以參考一下2013-10-10
這篇文章主要介紹了c# 閉包的相關知識以及需要注意的地方，文中講解非常細致，代碼幫助大家理解和學習，感興趣的朋友可以參考下2020-06-06