C#使用Socket实现局域网聊天

本文实例为大家分享了C#使用Socket实现局域网聊天的具体代码，供大家参考，具体内容如下

先运行一个java写的局域网聊天，效果图如下

后使用c#图形修改如下：

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>","rn")); 
          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(); 
    } 
  } 
} 

								 
 1/3    1 2 3 下一页 尾页