C#基于Socket实现多人聊天功能
作者:以前是少年 发布时间:2021-12-06 12:00:47
标签: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 ;
List<Socket> userList;//用户组
public Service()
{
socketSevice = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
userList = new List<Socket>();
}
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); //使用递归
}
/// <summary>
/// 广播信息
/// </summary>
/// <param name="useStr">传入收到的传输的内容</param>
/// <param name="obj">传送信息的客户</param>
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);//初始化服务器
}
/// <summary>
/// 连接服务器
/// </summary>
/// <param name="Ip"></param>
/// <param name="port"></param>
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));
}
/// <summary>
/// 接受信息
/// </summary>
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();
}
}
}
可以正常对话,测试一下。假装和自己对话
目前还没有解决沾包问题
来源:https://blog.csdn.net/qq_38061677/article/details/81226818
0
投稿
猜你喜欢
- 在项目中有事需要对值为NULL的对象中Field不做序列化输入配置方式如下:[配置类型]:源码包中的枚举类:public static en
- 一、实验目的1. 掌握输入输出流的总体结构;2. 掌握流的概念;3. 掌握FileInputStream类、FileOutputStream
- 1.Action中的validate()方法Struts2提供了一个Validateable接口,这个接口中只存在validat
- 本文介绍spring中自定义缓存resolver,通过自定义resolver,可以在spring的cache注解中增加附加处理。一、概述ca
- pageHelper分页失效及配置问题我在使用pageHelper的系统中加入mybatis-plus, 结果所有分页都失效了原因我这边的失
- 参考dubbo和shenyu网关实现自定义的SPISPI标注注解标注提供SPI能力接口的注解@Documented@Retention(Re
- 前言『 * 』其实源于设计模式中的代理模式,而代理模式就是使用代理对象完成用户请求,屏蔽用户对真实对象的访问。举个最简单的例子,比如我们想
- 本文实例讲述了java数据结构与算法之冒泡排序。分享给大家供大家参考,具体如下:前面文章讲述的排序算法都是基于插入类的排序,这篇文章开始介绍
- MyBatis的前身叫iBatis,本是apache的一个开源项目, 2010年这个项目由apache software foundatio
- 因为某些需求,要在特定的时间执行一些任务,比如定时删除服务器存储的数据缓存,定时获取数据以及定时发送推送等等,这时就需要用到定时任务了。定时
- 1.Overview经常研究.NET源码库的小伙伴会经常看到一个关键字volatile,那它在开发当中的作用是什么呢?我们一起来看看官方文档
- java 事务详解一、什么是事务事务是访问数据库的一个操作序列,数据库应用系统通过事务集来完成对数据库的存取。事务的正确执行使得数据库从一种
- 建造者模式(Builder):将一个复杂对象的构建与它的表示分离,使得同样的构建过程可以创建不同的表示。使用场景:当创建复杂对象的算法应该独
- 如下所示:from jpype import *jvmPath = getDefaultJVMPath()jars = ["./F
- 本文实例讲述了Java实现克隆的三种方式。分享给大家供大家参考,具体如下:1、浅复制(浅克隆)这种浅复制,其实也就是把被复制的这个对象的一些
- 提出问题我做的是一个通讯录,用到了选项菜单,每一个菜单项左边我都添加了一个小图标,运行后发现没有显示出来。解决方案利用反射机制,根据对象来寻
- 本文实例讲述了java获取中文拼音首字母工具类定义与用法。分享给大家供大家参考,具体如下:package com.sw.documentar
- 首先我们常用的注解包括@Entity、@Table、@Id、@IdClass、@GeneratedValue、@Basic、@Transie
- 目录匿名方法的代价C#9 中使用静态匿名方法匿名函数 在 C# 中已经出现很多年了,虽然匿名函数用起来很爽,但代价是不小的,为了避免不必要那
- 网络应用分为客户端和服务端两部分,而Socket类是负责处理客户端通信的Java类。通过这个类可以连接到指定IP或域名的服务器上,并且可以和