C#如何基于Socket实现多人聊天功能
发表于:2024-09-23 作者:千家信息网编辑
千家信息网最后更新 2024年09月23日,这篇文章主要介绍C#如何基于Socket实现多人聊天功能,文中介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们一定要看完!具体内容如下服务器服务器负责接受所有客户端发来的消息,和将接受到的问题群发
千家信息网最后更新 2024年09月23日C#如何基于Socket实现多人聊天功能
这篇文章主要介绍C#如何基于Socket实现多人聊天功能,文中介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们一定要看完!
具体内容如下
服务器
服务器负责接受所有客户端发来的消息,和将接受到的问题群发到其他用户。
代码:
using System;using System.Collections.Generic;using System.Net;using System.Net.Sockets;using System.Text;using System.Threading;namespace ChatRoomService{ class Service { Socket socketSevice ; ListuserList;//用户组 public Service() { socketSevice = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); userList = new List (); } public void Start() { socketSevice.Bind(new IPEndPoint(IPAddress.Any,5566)); socketSevice.Listen(10); Console.WriteLine("服务器启动成功"); //开启接受连接,用多线程 Thread accThread = new Thread(Accept); accThread.IsBackground = true; accThread.Start(); } private void Accept() { //接受连接 Socket clientSocket = socketSevice.Accept(); userList.Add(clientSocket); //打印已经连接IP地址 Console.WriteLine(IPToAddress(clientSocket)+"连接进来了"); // Thread RecvThread = new Thread(ReceMessage); RecvThread.IsBackground = true; RecvThread.Start(clientSocket); Accept();//递归 } //接收客户端信息 private void ReceMessage(Object obj) { Socket client = obj as Socket; byte[] strByte = new byte[1024 * 1024];//设定接受字符的长度 string str = ""; try { int len = client.Receive(strByte);//接受用户发送的内容 str = Encoding.Default.GetString(strByte, 0, len); Broadcast(str,client);//广播给用户 Console.WriteLine(str); } catch (Exception e) { Console.WriteLine(IPToAddress(client)+"退出"); userList.Remove(client); Thread.CurrentThread.Abort();//退出时掐死线程,不然递归反弹 } ReceMessage(client); //使用递归 } /// /// 广播信息 /// /// 传入收到的传输的内容 /// 传送信息的客户 private void Broadcast(string userStr,object obj) { Socket clientSend = obj as Socket; //当前发送信息的客户 foreach (Socket client in userList) { if (client != clientSend)//将信息广播给其他用户 { client.Send(Encoding.Default.GetBytes(IPToAddress(clientSend)+":"+userStr)); } } } //转换出连来客户的IP地址 private string IPToAddress(Socket soket) { return (soket.RemoteEndPoint as IPEndPoint).Address.ToString(); } }}
using System;using System.Collections.Generic;using System.Linq;using System.Text;using System.Threading.Tasks;namespace ChatRoomService{ class Program { static void Main(string[] args) { Service ss = new Service(); ss.Start(); Console.ReadLine(); } }}
客户端
客户端的功能开始十分简单,可以发送信息给服务器。也可以接收服务器转发过来其他客户端的信息。
using System;using System.Collections.Generic;using System.Linq;using System.Net;using System.Net.Sockets;using System.Text;using System.Threading;using System.Threading.Tasks;namespace ChatRoom{ class ClientRoom { Socket clientSocket; public ClientRoom() { clientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);//初始化服务器 } ////// 连接服务器 /// /// /// public void Connected(string Ip,int port) { clientSocket.Connect(Ip,port); Console.WriteLine("连接成功"); // ClientSocket.Bind(new IPEndPoint()); Thread RecvThread = new Thread(RecvMessage); RecvThread.IsBackground = true; RecvThread.Start(); } public void Send(String str) { clientSocket.Send(Encoding.Default.GetBytes(str)); } ////// 接受信息 /// private void RecvMessage() { try { byte[] strByte = new byte[500 * 1024]; int len = clientSocket.Receive(strByte); Console.WriteLine(Encoding.Default.GetString(strByte, 0, len)); } catch (Exception e) //服务器关闭 { Console.WriteLine("服务器关闭"); Thread.CurrentThread.Abort();//关闭时切断进程 } RecvMessage(); } }}
using System;using System.Collections.Generic;using System.Linq;using System.Text;using System.Threading.Tasks;namespace ChatRoom{ class Program { static void Main(string[] args) { ClientRoom client = new ClientRoom(); client.Connected("127.0.0.1", 5566); string str = Console.ReadLine(); while (!str.Equals("q")) { client.Send(str); str = Console.ReadLine(); } Console.ReadLine(); } }}
可以正常对话,测试一下。假装和自己对话
目前还没有解决沾包问题
以上是"C#如何基于Socket实现多人聊天功能"这篇文章的所有内容,感谢各位的阅读!希望分享的内容对大家有帮助,更多相关知识,欢迎关注行业资讯频道!
服务器
服务
信息
客户
内容
用户
功能
客户端
递归
广播
多人
C#
成功
地址
端的
篇文章
线程
问题
对话
代码
数据库的安全要保护哪些东西
数据库安全各自的含义是什么
生产安全数据库录入
数据库的安全性及管理
数据库安全策略包含哪些
海淀数据库安全审计系统
建立农村房屋安全信息数据库
易用的数据库客户端支持安全管理
连接数据库失败ssl安全错误
数据库的锁怎样保障安全
如何开手机数据库
金融专业数据库有哪些
湛江发货软件开发
深圳网络安全宣传作品
如何攻击网站数据库
江苏专业服务器机柜
软件开发规程
福建收费软件开发
樱花服务器免费网站
数据库发展对于管理学的应用
安全证书未生效服务器
数据库同步中间件
浙江特色软件开发近期价格
提高网络安全的app
深圳市元视界网络技术有限公司
服务器病毒查杀
微信数据库无法恢复
串口线连接服务器
因特网服务器作用
dell服务器导轨
cosmic数据库使用教程
广州正规软件开发价位
vba读取服务器图片
美国服务器加cdn延迟多少
微商城数据库设计
海康存储服务器怎么调ip
磁力连接服务器 python
控制面板卸载数据库
网络技术b 范围
天脉网络技术