C#使用Socket实现本地多人聊天室
短信预约 -IT技能 免费直播动态提醒
本文实例为大家分享了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();
}
}
}客户端运行效果：
①客户端先于服务端运行
②客户端迟于服务端运行
暂时总效果：
功能完善：
①客户端连上服务端后若服务端断开再打开，客户端无法重连
②心跳包重连
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持编程网。
免责声明：
① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的，并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据，供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。
② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341
