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
投稿
猜你喜欢
- 在很多语音视频软件系统中,经常有将实时的音频或视频录制为文件保存到磁盘的需求,比如,视频监控系统中录制监控到的视频、视频会议系统中录制整个会
- PipedOutputStream和PipedInputStream在java中,PipedOutputStream和PipedInputS
- 前言:C# 10 对于 Lambda 做了很多的优化,我们可以在 C# 中更加方便地使用委托和 Lambda 了,下面就来看一些示例1、Na
- 1.springboot启动过程中,首先会收集需要加载的bean的定义,作为BeanDefinition对象,添加到BeanFactory中
- 本文实例为大家分享了Unity快速生成常用文件夹的具体代码,供大家参考,具体内容如下前言每次打开新工程创建文件夹都很麻烦,写了一个小工具代码
- 现在的项目越来越多的都是打包成jar运行尤其是springboot项目,这时候配置文件如果一直放在项目中,每次进行简单的修改时总会有些不方便
- 问题描述我在接受 mq 消息的时候,需要做一个重试次数限制,如果超过 maxNum 就发邮件告警,不再重试。所以我需要对 consumer
- 首先看下我们要分析的代码段如下:输出结果如下:输出结果(a).PNG输出结果(b).PNG输出结果(c).PNG括号里是一个二元式:(单词类
- 什么是响应式简单来说当数据发生变化时,对数据有依赖的代码会重新执行。例如在Vue中,当我们的数据发生改变,界面上对该数据的引用组件会重新渲染
- 前言本文主要讲述如何在同一个窗体内,实现不同功能模块的页面切换。一、准备工作1.搭建一个简单的mvvm项目结构首先搭建一个简单的项目框架,然
- 本文实例讲述了Android编程实现ListView滚动提示等待框功能。分享给大家供大家参考,具体如下:其实原理很简单,只需要设置监听lis
- 该系统分为前台和后台,前台可以自主注册,后台管理员角色,除基础脚手架外,实现的功能有:后台管理员功能有:商品分类管理、商品管理、套餐管理、新
- 一、序言(一)背景内容软件应用技术架构中DAO层最常见的选型组件为MyBatis,熟悉MyBatis的朋友都清楚,曾几何时MyBatis是多
- 给TextureView添加边框(专业名词为描边),有三种解决方案:1.设置一个9 patch 的,右边框,中间是空的PNG。2.自定义一个
- 本文旨在通过重写Comparator接口的compare()方法实现对List的升序、降序、倒序排序。首先明确一点:compare(Inte
- 想要实现无限轮播,一直向左滑动,当到最后一个view时,会滑动到第一个,无限…可以自己写ViewPager然后加handler先实现自动滚动
- 一、背景在通过Runnable接口创建线程时,启动线程需要借助Thread类,这里就涉及到了静态代理模式。二、实例以歌手演出为例,在演出的这
- 最近项目用到了Spring Boot ,但是在控制器返回html视图并渲染参数的时候,存在了疑问。后面考虑用Thymeleaf ,感觉真的不
- 一、反射的基本概念1、反射的概念将类的各个组成部分封装成其他对象,这就是反射的机制.通过上图,我们可以通过反射获得Person类的Class
- 一、问题描述Android应用程序的四大组件中Activity、BroadcastReceiver、ContentProvider、Serv