C#实现简易多人聊天室
作者：docyard 发布时间：2023-02-06 06:09:47
标签：C#,聊天室
本文实例为大家分享了C#实现简易多人聊天室的具体代码，供大家参考，具体内容如下
只有一个群聊的功能
服务端
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using System.Windows.Forms;
namespace FinalChatRoomClient
{
public partial class Client : Form
{
//客户端负责接收服务端发来的数据消息的线程
Thread threadClient = null;
//创建客户端套接字，负责连接服务器
Socket socketClient = null;
public Client()
{
InitializeComponent();
//关闭对文本框跨线程操作的检查
TextBox.CheckForIllegalCrossThreadCalls = false;
}
private void start_Click(object sender, EventArgs e)
{
//获得文本框中的IP地址对象
IPAddress address = IPAddress.Parse(txtIp.Text.Trim());
//创建包含IP和端口的网络节点对象
IPEndPoint endPoint = new IPEndPoint(address, int.Parse(txtPort.Text.Trim()));
//创建客户端套接字，负责连接服务器
socketClient = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
try
{
//客户端连接到服务器
socketClient.Connect(endPoint);
ShowMsg("客户端连接服务器成功");
}
catch (SocketException ex)
{
ShowMsg("客户端连接服务器发生异常：" + ex.Message);
}
catch (Exception ex)
{
ShowMsg("客户端连接服务器发生异常：" + ex.Message);
}
threadClient = new Thread(ReceiveMsg);
threadClient.IsBackground = true;
threadClient.Start();
}
private void btnSend_Click(object sender, EventArgs e)
{
string strMsg = txtMsg.Text.Trim();
//将字符串转成方便网络传送的二进制数组
byte[] arrMsg = Encoding.UTF8.GetBytes(strMsg);
byte[] arrMsgSend = new byte[arrMsg.Length + 1];
arrMsgSend[0] = 0;//设置标识位，0代表发送的是文字
Buffer.BlockCopy(arrMsg, 0, arrMsgSend, 1, arrMsg.Length);
try
{
socketClient.Send(arrMsgSend);
//清空发送消息文本框中的消息
this.txtMsg.Text = "";
}
catch (SocketException ex)
{
ShowMsg("客户端发送消息时发生异常：" + ex.Message);
}
catch (Exception ex)
{
ShowMsg("客户端发送消息时发生异常：" + ex.Message);
}
}
private void ShowMsg(string msg)
{
txtRecord.AppendText(msg + "\r\n");
}
private void ReceiveMsg()
{
while (true)
{
//定义一个接收消息用的字节数组缓冲区（2M大小）
byte[] arrMsgRev = new byte[1024 * 1024 * 2];
//将接收到的数据存入arrMsgRev,并返回真正接收到数据的长度
int length = -1;
try
{
length = socketClient.Receive(arrMsgRev);
}
catch (SocketException ex)
{
ShowMsg("客户端接收消息时发生异常：" + ex.Message);
break;
}
catch (Exception ex)
{
MessageBox.Show("客户端接收消息时发生异常：" + ex.Message);
break;
}
//此时是将数组的所有元素（每个字节）都转成字符串，而真正接收到只有服务端发来的几个字符
string strMsgReceive = Encoding.UTF8.GetString(arrMsgRev, 0, length);
Console.WriteLine(strMsgReceive);
ShowMsg(strMsgReceive);
}
}
}
}
客户端
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using System.Windows.Forms;
namespace FinalChatRoomClient
{
public partial class Client : Form
{
//客户端负责接收服务端发来的数据消息的线程
Thread threadClient = null;
//创建客户端套接字，负责连接服务器
Socket socketClient = null;
public Client()
{
InitializeComponent();
//关闭对文本框跨线程操作的检查
TextBox.CheckForIllegalCrossThreadCalls = false;
}
private void start_Click(object sender, EventArgs e)
{
//获得文本框中的IP地址对象
IPAddress address = IPAddress.Parse(txtIp.Text.Trim());
//创建包含IP和端口的网络节点对象
IPEndPoint endPoint = new IPEndPoint(address, int.Parse(txtPort.Text.Trim()));
//创建客户端套接字，负责连接服务器
socketClient = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
try
{
//客户端连接到服务器
socketClient.Connect(endPoint);
ShowMsg("客户端连接服务器成功");
}
catch (SocketException ex)
{
ShowMsg("客户端连接服务器发生异常：" + ex.Message);
}
catch (Exception ex)
{
ShowMsg("客户端连接服务器发生异常：" + ex.Message);
}
threadClient = new Thread(ReceiveMsg);
threadClient.IsBackground = true;
threadClient.Start();
}
private void btnSend_Click(object sender, EventArgs e)
{
string strMsg = txtMsg.Text.Trim();
//将字符串转成方便网络传送的二进制数组
byte[] arrMsg = Encoding.UTF8.GetBytes(strMsg);
byte[] arrMsgSend = new byte[arrMsg.Length + 1];
arrMsgSend[0] = 0;//设置标识位，0代表发送的是文字
Buffer.BlockCopy(arrMsg, 0, arrMsgSend, 1, arrMsg.Length);
try
{
socketClient.Send(arrMsgSend);
//清空发送消息文本框中的消息
this.txtMsg.Text = "";
}
catch (SocketException ex)
{
ShowMsg("客户端发送消息时发生异常：" + ex.Message);
}
catch (Exception ex)
{
ShowMsg("客户端发送消息时发生异常：" + ex.Message);
}
}
private void ShowMsg(string msg)
{
txtRecord.AppendText(msg + "\r\n");
}
private void ReceiveMsg()
{
while (true)
{
//定义一个接收消息用的字节数组缓冲区（2M大小）
byte[] arrMsgRev = new byte[1024 * 1024 * 2];
//将接收到的数据存入arrMsgRev,并返回真正接收到数据的长度
int length = -1;
try
{
length = socketClient.Receive(arrMsgRev);
}
catch (SocketException ex)
{
ShowMsg("客户端接收消息时发生异常：" + ex.Message);
break;
}
catch (Exception ex)
{
MessageBox.Show("客户端接收消息时发生异常：" + ex.Message);
break;
}
//此时是将数组的所有元素（每个字节）都转成字符串，而真正接收到只有服务端发来的几个字符
string strMsgReceive = Encoding.UTF8.GetString(arrMsgRev, 0, length);
Console.WriteLine(strMsgReceive);
ShowMsg(strMsgReceive);
}
}
}
}
来源：https://www.cnblogs.com/wangkaipeng/p/7015930.html
0
投稿猜你喜欢
- maven的配置文件settings.xml存在于两个地方：1.安装的地方：${M2_HOME}/conf/settings.xml2.用户
- 项目配置依赖首先搭建一个标准的SpringBoot项目工程，相关版本以及依赖如下本项目借助SpringBoot 2.2.1.RELEASE
本文实例讲述了Android开发实现的计时器功能。分享给大家供大家参考，具体如下：效果图：布局：三个按钮 加上一个Chronometer&l- 场景yitter-idgenerator 是基于雪花算法进行改造的分布式ID自增算法，集成时需要为每个服务设置唯一的机器号，才能保证生成的I
- 本文实例讲述了Android编程获取通知栏高度的方法。分享给大家供大家参考，具体如下：这里通过反射机制获取通知栏高度通知栏高度写在dimen
- 账户类Account：Id：账户号码PassWord:账户密码Name:真实姓名PersonId:身份证号码Email:客户的电子邮箱Bal
- 在了解Lambda表达式之前我们先来区分一下面向对象的思想和函数式编程思想的区别面向对象的思想：做一件事情，找一个能解决这个事情的对象，调用
- 环境：主机:WIN10开发环境:Android Studio 2.2 Preview 3说明：两种方法实现底部弹出的对话框：DialogDi
- Settings -> Editor -> General -> Use soft wraps in editor&nbs
- 作为一位开发人员，都要有严格的代码规范。为此我总结了一些代码规范案例。目 录1. 前言2. 试用范围3. JAVA命名规范--3.1 公共约
- 1、存储在App内部最简单的一种。在尝试过程中发现，手机中很多文件夹都没有权限读写。我们可以将我们需要写的文件存放到App中的files文件
- using Microsoft.Win32 ; 1.读取指定名称的注册表的值 &nbs
- 本文实例为大家分享了java pdf加水印的具体代码，供大家参考，具体内容如下引入依赖<dependency> <grou
- 1. 参数中直接加入％％param.setUsername("％CD％"); param.set
- StringDictionary：默认key不区分大小写 NameValueCollection：默认key区分大小写 KeyedColle
- 最近在做数据挖掘的课程设计，需要将数据分析的结果很直观的展现给用户，这就要用到数据统计图，要实现这个功能就需要几个第三方包了：1.
- volatile这个关键字可能很多朋友都听说过，或许也都用过。在Java 5之前，它是一个备受争议的关键字，因为在程序中使用它往往会导致出人
- 目录关于日志级别为什么选用log4j2排除 spring-boot 自带的 logback 依赖添加 log4j2 依赖配置文件节点解析根节
- 今天在使用Nlog的时候，发现了一个之前没注意的问题。以前，我的app配置文件都是这么写的，当然配置比较多的时候会改用xml。 如
- BeanUtils.copyProperties无法封装使用BeanUtils.copyProperties(user, memeber);
