国产探花免费观看_亚洲丰满少妇自慰呻吟_97日韩有码在线_资源在线日韩欧美_一区二区精品毛片,辰东完美世界有声小说,欢乐颂第一季,yy玄幻小说排行榜完本

首頁 > 編程 > C# > 正文

C#使用Socket實現局域網聊天

2019-10-29 21:02:30
字體:
來源:轉載
供稿:網友

本文實例為大家分享了C#使用Socket實現局域網聊天的具體代碼,供大家參考,具體內容如下

先運行一個java寫的局域網聊天,效果圖如下

C#,Socket,聊天

后使用c#圖形修改如下:

C#,Socket,聊天

C#代碼:

servlet服務端

 

using System; using System.Collections.Generic; using System.Drawing; using System.Windows.Forms; using System.Net; using System.Net.Sockets; using System.Threading; using System.IO; using System.Text; using System.Text.RegularExpressions;  namespace Server {   public partial class MainForm : Form   {     private TcpListener listener;          private Dictionary<String,TcpClient> socketList;     private bool tag = true;     private StringBuilder charList;          public MainForm()     {       InitializeComponent();       Control.CheckForIllegalCrossThreadCalls = false;     }          void Bu_StartClick(object sender, EventArgs e)     {       cb_chatList.Items.Clear();       selectChat.Text="";       int port = 8888;       //創建服務端,并且啟動       try{         listener = new TcpListener(IPAddress.Parse(ipAddress()),port);         listener.Start();                    bu_Start.Enabled = false;         bu_stop.Enabled = true;       }catch(Exception ex)       {         MessageBox.Show("服務器啟動失敗, 原因:"+ex.Message);         bu_Start.Enabled = true;         bu_stop.Enabled = false;         return;       }       selectChat.Text = "服務器啟動成功,訪問IP:"+ipAddress()+" 端口號:"+port;              //記錄住連接的客戶端       socketList = new Dictionary<String,TcpClient>();       charList = new StringBuilder();              //使用多線程,用于多個客戶端接入       Thread th = new Thread(new ThreadStart(executeTask));       th.Start();     }     public void executeTask()     {       while(tag)       {         //等待用戶連接         TcpClient client = null;         try{           client = listener.AcceptTcpClient();         }catch(Exception)         {         }         Thread th = new Thread(executeRead);         th.Start((Object)client);       }     }     public void executeRead(Object pamars)     {       //永久監聽讀取客戶端       TcpClient client = pamars as TcpClient;       while(tag)       {         NetworkStream ns = client.GetStream();         StreamReader sr = new StreamReader(ns);         String msg = String.Empty;         String people = String.Empty;         try {           msg = sr.ReadLine();           if(msg.IndexOf("<clientName>")!=-1)           {             msg = Regex.Split(msg,"=")[1];             cb_chatList.Items.Add(msg);                    charList.Append(msg).Append("<@>");             socketList.Add(msg,client);             msg = "<br>歡迎【"+msg+"】光臨<br>";           }           selectChat.AppendText(msg.Replace("<br>","/r/n"));           sendMsg(String.Empty,msg);         } catch (Exception) {           //MessageBox.Show(ex.Message.ToString());           break;         }       }     }     public void sendMsg(String target,String msg)     {       if(String.Empty!=target)       {         TcpClient client = socketList[target];         StreamWriter sw = new StreamWriter(client.GetStream());         sw.WriteLine(msg);         sw.Flush();        }else{         Dictionary<String,TcpClient>.KeyCollection keyColl = socketList.Keys;         foreach (String name in keyColl)          {           StreamWriter sw = new StreamWriter(socketList[name].GetStream());           sw.WriteLine(msg+"<@=@>"+charList.ToString());           sw.Flush();                }       }     }     /*根據計算名獲取IP地址*/     public String ipAddress()     {       IPAddress[] address = Dns.GetHostAddresses(Dns.GetHostName());       return address[2].ToString();     }          void ServerFromFormClosing(object sender, FormClosingEventArgs e)     {       e.Cancel = false;       if(tag)         tag = false;       if(listener!=null)         listener.Stop();     }          void Bu_stopClick(object sender, EventArgs e)     {       bu_Start.Enabled = true;       bu_stop.Enabled = false;       if(tag)         tag = false;       if(listener!=null)         listener.Stop();     }   } } 

Client客戶端

using System; using System.Drawing; using System.Windows.Forms; using System.Threading; using System.Net; using System.Net.Sockets; using System.IO; using System.Text; using System.Text.RegularExpressions;  namespace Client {   public partial class MainForm : Form   {     private System.Windows.Forms.Timer closeWindowTimer;          private StreamReader sr;     private StreamWriter sw;     private TcpClient tc;     private ClientLong cl;     private bool tag = true;            public MainForm(TcpClient tcp,ClientLong clo)     {       cl = clo;       tc = tcp;       InitializeComponent();       Control.CheckForIllegalCrossThreadCalls = false;       bu_simple.Hide();     }     void ClientFromLoad(object sender, EventArgs e)     {       PiayCheckedChanged();     }          /*事件方法*/     public void PiayCheckedChanged()     {       closeWindowTimer = new System.Windows.Forms.Timer();       closeWindowTimer.Interval = 1000;       closeWindowTimer.Tick += new EventHandler(theout);       closeWindowTimer.Start();     }          /*執行的事件*/     public void theout(object source, EventArgs e)     {       //這里單獨開一個線程用來顯示信息       try{         Thread t1 = new Thread(new ThreadStart(readMsg));         t1.Start();       }catch(Exception)       {       }     }     void readMsg()     {       if(tag && tc!=null){         sr = new StreamReader(tc.GetStream());         String msg = sr.ReadLine();         String[] address = Regex.Split(msg,"<@=@>");         chatText.AppendText(address[0].Replace("<br>","/r/n"));         address = Regex.Split(address[1],"<@>");         cb_chatList.Items.Clear();         foreach (String s in address)         {           if(!String.IsNullOrEmpty(s) && s != cl.clientName)             cb_chatList.Items.Add(s);                 }       }     }     void Button1Click(object sender, EventArgs e)     {       if(String.IsNullOrEmpty(textBox2.Text)){         MessageBox.Show("請輸入消息");return;       }       sw = new StreamWriter(tc.GetStream());       sw.WriteLine("<br>"+cl.clientName+"  "+DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")+"<br> "+textBox2.Text);       textBox2.Text = "";       sw.Flush();     }     void Bu_exitClick(object sender, EventArgs e)     {       MainFormFormClosing(null,null);     }     void Button2Click(object sender, EventArgs e)     {       chatText.Text = "";      }     void MainFormFormClosing(object sender, FormClosingEventArgs e)     {       closeWindowTimer.Stop();       cl.Close();       tag = false;       if(sr!=null)         sr.Close();       if(sw!=null)         sw.Close();     }     void Bu_simpleClick(object sender, EventArgs e)     {       String selected = cb_chatList.Text;       if(selected==null)       {         MessageBox.Show("請選擇單聊對象");         return;       }     }   } } 

補充:

1.上傳下載文件、聊天表情、私聊、踢人.......都是可以擴展的功能。

只是目前還沒有可執行的思路,希望有相同愛好者多多提出寶貴意見,我會繼續關注。

以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支持VEVB武林網。


注:相關教程知識閱讀請移步到c#教程頻道。
發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表
主站蜘蛛池模板: 禹城市| 环江| 若尔盖县| 宾阳县| 金堂县| 鹤峰县| 桑日县| 广德县| 秦安县| 屏南县| 科技| 武强县| 孟州市| 肇源县| 大竹县| 东明县| 崇仁县| 天台县| 成安县| 遵义市| 东辽县| 杭锦后旗| 德令哈市| 百色市| 英吉沙县| 虞城县| 屏东市| 九龙县| 麻栗坡县| 沽源县| 朝阳县| 南平市| 博罗县| 大理市| 雷山县| 恩施市| 夏河县| 双峰县| 体育| 乌兰察布市| 阳山县|