C#使用Socket实现本地多人聊天室
更新时间：2022年02月11日 08:23:38 作者：.roughbonbon
这篇文章主要为大家详细介绍了C#使用Socket实现本地多人聊天室，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
本文实例为大家分享了C#使用Socket实现本地多人聊天室的具体代码，供大家参考，具体内容如下
【脚本一：Server端】
使用本机地址：127.0.0.1
完整代码
using System;
using System.Collections.Generic;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;
namespace ConsoleApp1
{
public class Server
{
Socket mySocket = null;
Dictionary<IPAddress, Socket> cliDic = new Dictionary<IPAddress, Socket>();
public void Connect(int port)
{
string IP = "127.0.0.1";
//IPAddress IPAddress = IPAddress.Parse("127.0.0.1");
IPAddress address = IPAddress.Any;
//创建IP终结点，把IP地址与端口绑定到网络终结点上
IPEndPoint endPoint = new IPEndPoint(address, port);
//创建客户端套接字
mySocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
///监听套接字终结点
mySocket.Bind(endPoint);
//服务端可接收客户端连接数量为无限个
mySocket.Listen(0);
//开启线程监听客户端
Thread myThread = new Thread(Listen_Con);
myThread.Start();
Console.WriteLine("开始监听...");
}
/// <summary>
/// 接收连接的客户端并存储客户端的信息
/// </summary>
/// <param name="obj"></param>
public void Listen_Con(Object obj)
{
Socket cliSocket = null;
//持续监听客户端的请求
while (true)
{
try
{
cliSocket = mySocket.Accept();
}
catch (Exception e)
{
Console.WriteLine(e.Message);
}
string cliEndPoint = cliSocket.RemoteEndPoint.ToString();
IPAddress cliAddress = (cliSocket.RemoteEndPoint as IPEndPoint).Address;
int cliPort = (cliSocket.RemoteEndPoint as IPEndPoint).Port;
cliDic.Add(cliAddress, cliSocket);
string MsgStr = "[客户端结点:" + cliEndPoint + "\n+客户端IP：" + cliAddress.ToString() + "\n客户端端口:" +
cliPort.ToString() + "\n已连接]";
byte[] MsgBytes = Encoding.UTF8.GetBytes(MsgStr);
cliSocket.Send(MsgBytes);
Thread rec_Cli = new Thread(Receive_Con);
rec_Cli.Start(cliSocket);
Thread sed_Cli = new Thread(SendToCli);
sed_Cli.Start(cliSocket);
}
}
/// <summary>
/// 接收已连接的客户端发送的消息
/// </summary>
/// <param name="socket"></param>
public void Receive_Con(Object socket)
{
Socket client = socket as Socket;
while (true)
{
//创建大小为1024*1024的内存缓冲区（1M）
byte[] recBytes = new byte[1024 * 1024];
//尝试把接收的字节存储到缓冲区
try
{
int length = client.Receive(recBytes);
//把机器接收的字节数组转换为string
string recMsg = Encoding.UTF8.GetString(recBytes, 0, length);
//将服务器接收到的信息转发到所有已连接的客户端
if (cliDic.Count > 0)
{
foreach (var soc in cliDic)
{
soc.Value.Send(Encoding.UTF8.GetBytes("[" + soc.Value.RemoteEndPoint + "]:" + recMsg));
}
}
Console.WriteLine("[" + client.RemoteEndPoint + "]:" + recMsg);
}
catch (Exception)
{
cliDic.Remove((client.RemoteEndPoint as IPEndPoint).Address);
//客户端断开的异常
Console.WriteLine("[客户端" + (client.RemoteEndPoint as IPEndPoint).Address + "已断开]");
Console.WriteLine("[客户端终结点：" + client.RemoteEndPoint+"]");
//断开套接字
client.Close();
break;
}
}
}
public void SendToCli(object obj)
{
Socket curCliSoc = obj as Socket;
while (true)
{
byte[] ByteToAll = new byte[1024 * 1024];
try
{
string MsgToAll = Console.ReadLine();
ByteToAll = Encoding.UTF8.GetBytes("[服务端]:"+MsgToAll);
curCliSoc.Send(ByteToAll);
}
catch(Exception)
{
Console.WriteLine("ERROR:" + curCliSoc.RemoteEndPoint + "已与服务端断开！");
curCliSoc.Close();
if(cliDic.ContainsKey((curCliSoc.RemoteEndPoint as IPEndPoint).Address))
{
cliDic.Remove((curCliSoc.RemoteEndPoint as IPEndPoint).Address);
}
}
}
}
}
public class ServerMain
{
static void Main(string[] args)
{
Server s1 = new Server();
s1.Connect(8800);
}
}
}Server端运行结果：
【脚本二：Client端】
完整代码
using System;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;
namespace ConsoleApp1
{
public class Client
{
string SerIP = "127.0.0.1";
Socket myClient = null;
Thread ConnectThread = null;
IPAddress SerAdd;
IPEndPoint SerEP;
public void Connect_To_Ser(int port)
{
myClient = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
SerAdd = IPAddress.Parse(SerIP);
SerEP = new IPEndPoint(SerAdd, port);
while (true)
{
try
{
myClient.Connect(SerEP);
break;
}
catch
{
Console.WriteLine("无法连接到服务端，请重试...");
}
}
ConnectThread = new Thread(Receive_Ser);
ConnectThread.Start();
}
public void Receive_Ser()
{
while (true)
{
byte[] SerBytes = new byte[1024 * 1024];
try
{
int length = myClient.Receive(SerBytes);
string Msg = Encoding.UTF8.GetString(SerBytes, 0, length);
Console.WriteLine(Msg);
}
catch (Exception)
{
Console.WriteLine("已与服务端断开连接...");
break;
}
}
}
public void SendToSer()
{
while (true)
{
try
{
string SendMsg = Console.ReadLine();
myClient.Send(Encoding.UTF8.GetBytes(SendMsg));
}
catch (Exception)
{
Console.WriteLine("[SendToSer]已断开连接");
break;
}
}
}
}
public class ClienMain
{
static void Main(string[] Args)
{
Client c1 = new Client();
c1.Connect_To_Ser(8800);
c1.SendToSer();
}
}
}客户端运行效果：
①客户端先于服务端运行
②客户端迟于服务端运行
暂时总效果：
功能完善：
①客户端连上服务端后若服务端断开再打开，客户端无法重连
②心跳包重连
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持脚本之家。
相关文章
C#发送HttpPost请求来调用WebService的方法
在C#中发送HttpPost请求来调用WebService中的MyAction方法，代码如下：需要的朋友可以参考一下2013-03-03
这篇文章主要介绍了c#在WebAPI使用Session的方法,小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧2018-07-07
让窗体拖到屏幕边缘自动隐藏的原理，通过Form1_LocationChanged的方法，当窗体位置发生改变时，判断其是否在屏幕边缘，在则隐藏。再通过Timer控件经过指定时间判断出鼠标的位置，若鼠标在屏幕左边、上边或右边，这根据窗体的位置，调出窗体。2009-02-02
这篇文章介绍了C#获取文件夹所占空间大小的方法，文中通过示例代码介绍的非常详细。对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下2022-06-06
本文主要介绍了c# Bitmap转bitmapImage高效方法，文中通过示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2021-11-11
线性回归与多项式拟合是两种常用的回归分析方法,线性回归模型简单,易于计算,但只适用于线性关系的数据,多项式拟合能处理非线性数据,模型更复杂,拟合度更高,但容易产生过拟合问题,计算成本较高,适用场景不同,线性回归适合线性数据,多项式拟合适合非线性数据2024-10-10
这篇文章主要介绍了c#中的索引器的相关资料，帮助大家更好的理解和学习c#，感兴趣的朋友可以了解下2020-09-09
这篇文章主要介绍了c#字符串值类型与引用类型比较示例,需要的朋友可以参考下2014-03-03
这篇文章主要为大家详细介绍了如何基于WPF编写一个有趣的久坐提醒桌面小程序，文中的示例代码讲解详细，感兴趣的小伙伴可以动手尝试一下2023-08-08
本文通过两个示例讲解了一下Process类调用外部应用程序的基本用法，并简单讲解了StartInfo属性，有需要的朋友可以参考一下。2016-03-03
最新评论