c#实现多线程局域网聊天系统

 更新时间:2020年6月25日 11:29  点击:1326

觉得好有点帮助就顶一下啦。

socke编程,支持多客户端,多线程操作避免界面卡死。

开启socket

private void button1_Click(object sender, EventArgs e)
   {
     try
     {
       int port = int.Parse(txt_port.Text);
       string host = txt_ip.Text;
       //创建终结点
       IPAddress ip = IPAddress.Parse(host);
       IPEndPoint ipe = new IPEndPoint(ip, port);
       //创建Socket并开始监听
       newsock = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); //创建一个Socket对象,如果用UDP协议,则要用SocketTyype.Dgram类型的套接字
       newsock.Bind(ipe);  //绑定EndPoint对象
       newsock.Listen(0);  //开始监听
       //为新建立的连接创建新的Socket
       acceptClientThread = new Thread(new ThreadStart(AcceptClient));
       acceptClientThread.Start();
       SetText("开始监听");
     }
     catch (Exception exp)
     {
       CommonFunction.WriteLog(exp, exp.Message);
     }
   }

监控端口,接收客户端

/// <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);
      }
    }

接收客户端数据并广播数据

/// <summary>
    /// 接收客户端数据并,转发到目标客户端。
    /// </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);
      }
    }

判断是用户注册还是发送消息

/// <summary>
   /// 判断是用户注册还是发送消息
   /// </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();
    }

群发消息

/// <summary>
    /// 群发消息
    /// </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);//委托的方法参数应和SetText一致 
        rich_back.Invoke(set, new object[] { text }); //此方法第二参数用于传入方法,代替形参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;
        //创建终结点EndPoint
        IPAddress ip = IPAddress.Parse(host);
        IPEndPoint ipe = new IPEndPoint(ip, port);  //把ip和端口转化为IPEndPoint的实例
        //创建Socket并连接到服务器
        Socket c = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);  // 创建Socket
        cc = c;
        c.Connect(ipe); //连接到服务器
        clientThread = new Thread(new ThreadStart(ReceiveData));
        clientThread.Start();
        //向服务器发送本机用户名,以便服务器注册客户端
        SendMessage("@" + txt_name.Text);
      }
      catch (ArgumentException ex)
      {
        Console.WriteLine("argumentNullException:{0}", ex);
      }
      catch (SocketException exp)
      {
        Console.WriteLine("SocketException:{0}",exp);
      }
    }

向服务器发送消息

private void button3_Click(object sender, EventArgs e)
    {
      if (""==txt_target.Text)
      {
        MessageBox.Show("未选择对话人物");
        return;
      }
      //向服务器发送信息
      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);
      }
    }

以上所述就是本文的全部内容了,希望大家能够喜欢。

[!--infotagslink--]

相关文章

  • C# WinForm多线程解决界面卡死问题的完美解决方案,使用BeginInvoke

    问题描述:当我们的界面需要在程序运行中不断更新数据时,当一个textbox的数据需要变化时,为了让程序执行中不出现界面卡死的现像,最好的方法就是多线程来解决一个主线程来创建界...2020-06-24
  • 浅谈C# 字段和属性

    这篇文章主要介绍了C# 字段和属性的的相关资料,文中示例代码非常详细,供大家参考和学习,感兴趣的朋友可以了解下...2020-11-03
  • C#实现简单的登录界面

    我们在使用C#做项目的时候,基本上都需要制作登录界面,那么今天我们就来一步步看看,如果简单的实现登录界面呢,本文给出2个例子,由简入难,希望大家能够喜欢。...2020-06-25
  • C#中截取字符串的的基本方法详解

    这篇文章主要介绍了C#中截取字符串的的基本方法,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧...2020-11-03
  • C#实现简单的Http请求实例

    这篇文章主要介绍了C#实现简单的Http请求的方法,以实例形式较为详细的分析了C#实现Http请求的具体方法,需要的朋友可以参考下...2020-06-25
  • C#连接SQL数据库和查询数据功能的操作技巧

    本文给大家分享C#连接SQL数据库和查询数据功能的操作技巧,本文通过图文并茂的形式给大家介绍的非常详细,需要的朋友参考下吧...2021-05-17
  • C#中new的几种用法详解

    本文主要介绍了C#中new的几种用法,具有很好的参考价值,下面跟着小编一起来看下吧...2020-06-25
  • 使用Visual Studio2019创建C#项目(窗体应用程序、控制台应用程序、Web应用程序)

    这篇文章主要介绍了使用Visual Studio2019创建C#项目(窗体应用程序、控制台应用程序、Web应用程序),小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧...2020-06-25
  • C#开发Windows窗体应用程序的简单操作步骤

    这篇文章主要介绍了C#开发Windows窗体应用程序的简单操作步骤,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...2021-04-12
  • C#从数据库读取图片并保存的两种方法

    这篇文章主要介绍了C#从数据库读取图片并保存的方法,帮助大家更好的理解和使用c#,感兴趣的朋友可以了解下...2021-01-16
  • C#和JavaScript实现交互的方法

    最近做一个小项目不可避免的需要前端脚本与后台进行交互。由于是在asp.net中实现,故问题演化成asp.net中jiavascript与后台c#如何进行交互。...2020-06-25
  • C++调用C#的DLL程序实现方法

    本文通过例子,讲述了C++调用C#的DLL程序的方法,作出了以下总结,下面就让我们一起来学习吧。...2020-06-25
  • 轻松学习C#的基础入门

    轻松学习C#的基础入门,了解C#最基本的知识点,C#是一种简洁的,类型安全的一种完全面向对象的开发语言,是Microsoft专门基于.NET Framework平台开发的而量身定做的高级程序设计语言,需要的朋友可以参考下...2020-06-25
  • C#变量命名规则小结

    本文主要介绍了C#变量命名规则小结,文中介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下...2021-09-09
  • C# 中如何取绝对值函数

    本文主要介绍了C# 中取绝对值的函数。具有很好的参考价值。下面跟着小编一起来看下吧...2020-06-25
  • c#自带缓存使用方法 c#移除清理缓存

    这篇文章主要介绍了c#自带缓存使用方法,包括获取数据缓存、设置数据缓存、移除指定数据缓存等方法,需要的朋友可以参考下...2020-06-25
  • c#中(&&,||)与(&,|)的区别详解

    这篇文章主要介绍了c#中(&&,||)与(&,|)的区别详解,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧...2020-06-25
  • C#学习笔记- 随机函数Random()的用法详解

    下面小编就为大家带来一篇C#学习笔记- 随机函数Random()的用法详解。小编觉得挺不错的,现在就分享给大家,也给大家做个参考。一起跟随小编过来看看吧...2020-06-25
  • 经典实例讲解C#递归算法

    这篇文章主要用实例讲解C#递归算法的概念以及用法,文中代码非常详细,帮助大家更好的参考和学习,感兴趣的朋友可以了解下...2020-06-25
  • C#中list用法实例

    这篇文章主要介绍了C#中list用法,结合实例形式分析了C#中list排序、运算、转换等常见操作技巧,具有一定参考借鉴价值,需要的朋友可以参考下...2020-06-25