.net如何处理高并发socket,建立高性能健壮的socket服务

1.使用supersocket

  • 高性能的事件驱动通信;
  • 非常简单易用; 你只需要通过创建几个类就能获得一个健壮的 Socket 服务器;
  • 内置的命令行协议让你能够迅速创建一个网络命令行接口服务器;
  • 强大且高性能的协议解析实现工具帮你简化了网络数据的分析工作;
  • 灵活的配置功能和友好的配置 API;
  • 多监听器支持; 让你在一个服务器实例内监听多个端口;
  • 多服务器实例托管的支持让你从容面对复杂的部署需求;
  • 应用程序域和进程级别的隔离能够满足你大部分的宿主场景;
  • 内置的 SSL/TLS 加密支持;
  • 会话级别的发送队列能够让你通过会话并发的发送数据,并保持高性能和可控性;
  • SuperSocket 的命令处理模式让你的业务逻辑更清晰,更有条理;
  • 优良的可扩展 API 支持: Command Filter, Connection Filter, Command Loader;
  • 可替换的日志架构允许你使用你喜欢的日志组件;
  • 动态语言的支持; 允许你用 Python 之类的脚本语言来实现命令;
  • 与 Mono/Linux 保持二进制级别的兼容;
  • Windows Azure 的支持;
  • 内置你可以直接用于 Flash 或 Silverlight 客户端的 Socket 策略服务器;

官网地址:http://www.supersocket.net/

SuperSocket 层次示意图

SuperSocket 对象模型图示意图

SuperSocket 请求处理模型示意图

SuperSocket 隔离模型示意图

看到一个问题,说如何保持5000-10000+的健壮的socket服务。

初学者肯定是会把每个连接都开一个线程来监听。这很浪费资源

通常只会(动态地)占用几个线程就能保持3000个长连接会话了。
“为每个监听对象开一个新的线程”这是设计错误。你可以使用NetworkStream的异步Read,在没有消息的时候无需阻塞在什么线程里。

据不同的操作系统,多线程的约束条件也不同。当你发现工作线程超过1000个,或者IOCP(IO完成端口)线程超过800个,就应该赶紧断掉服务器进行维护了。
首先要有一个意识,使用几个、十几个线程就足以应付上千个普通业务连接了。
有人说“如果我要保持1000个客户端连接,就得开1001个线程来接收数据”,这纯粹是瞎扯。请一定要注意。

我说的“工作线程”是指你的进程中使用的工作线程总数,而不是只windows的。

在你的windows中,总线程数超过1500个是经常有的事情。你可以打开你的进程管理器看看cpu的指标,看看当前有多少线程在切换使用。很可能超过1500个。但是可以监视每一个单个的进程,看看它的线程数,通常只有10个左右(只有System线程数会有100多)。

而你的服务器进程,工作线程数不应该太高。平常只有十几个线程足以应对几千客户端了。

如果你用.net 开发,你可以使用  supersocket 这个是我目前开发比较全面的, 或者用一个较 fastsocket的,也不错(相关更轻一点).

时间: 2024-11-07 14:03:16

.net如何处理高并发socket,建立高性能健壮的socket服务的相关文章

Swoole如何处理高并发

有需要学习交流的友人请加入swoole交流群的咱们一起,有问题一起交流,一起进步!前提是你是学技术的.感谢阅读! 点此加入该群 swoole如何处理高并发 ①Reactor模型介绍 IO复用异步非阻塞程序使用经典的Reactor模型,Reactor顾名思义就是反应堆的意思,它本身不处理任何数据收发.只是可以监视一个socket(也可以是管道.eventfd.信号)句柄的事件变化. Reactor只是一个事件发生器,实际对socket句柄的操作,如connect/accept.send/recv.

大数据量、高并发数据库的高性能、高可用性解决方案

大数据量.高并发数据库的高性能.高可用性解决方案: 1.拆表:大表拆小表(垂直拆,水平拆:分表,分区partition,分片sharding),可以在应用层实现,也可以在数据库层面实现一部分:提高系统性能. 2.分库:把表放到不同的数据库,这也是分布式数据库的基础:提高系统性能. 3.分布式:不同的数据库放到不同的服务器:提高系统性能. 4.集群:使用数据库复制等技术组建集群,实现读写分离.备份等:提高系统性能.可用性. 5.缓存:对常用的数据进行缓存.提高系统性能. 6.备份:主从库,快照,热

浅谈java中如何处理高并发的问题

1.从最基础的地方做起,优化我们写的代码,减少必要的资源浪费     a.避免频繁的使用new对象,对于整个应用只需要存在一个实例的类,我们可以使用单例模式.对于String连接操作,使用StringBuffer或StringBuilder,对于工具类可以通过静态方法来访问.     b.避免使用错误的方式,尽量不用instanceof做条件判断.使用java中效率高的类,比如ArrayList比Vector性能好. 2.html静态化     我们通过一个链接地址访问,通过这个链接地址,服务器

谈论java中如何处理高并发的问题

1 从最基础的地方做起,优化我们写的代码,减少必要的资源浪费.         a.避免频繁的使用new对象,对于整个应用只需要存在一个实例的类,我们可以使用单例模式.对于String连接操作,使用      StringBuffer或StringBuilder,对于工具类可以通过静态方法来访问.         b.避免使用错误的方式,尽量不用instanceof做条件判断.使用java中效率高的类,比如ArrayList比Vector性能好. 2 html静态化         我们通过一个

用一个示例讲解我是如何处理高并发的

去年做了一个远程升级的服务.客户端连接此服务可以下载更新程序.简单点说就是个TCP sever.基于C++. 运行环境是centOS 6.5. 刚开始客户端数量少而且访问不频繁,所以没太关注并发的问题.当时用工具测试大概只能支持的40次/秒的并发访问,而且已经有数据串包的情况出现了.最近有空做了不少的优化并记录了笔记备忘. 下面给出的代码都不是完整的项目源码,我只是截取了关键部分用于说明主题 我选择的测试工具是一个小的tcp客户端工具,可以比价快捷的进行多客户端连接的测试. 线程安全的单例模式

如何处理高并发情况下的DB插入

插入数据库,在大家开发过程中是很经常的事情,假设我们有这么一个需求: 1.  我们需要接收一个外部的订单,而这个订单号是不允许重复的 2.  数据库对外部订单号没有做唯一性约束 3.  外部经常插入相同的订单,对于已经存在的订单则拒绝处理 对于这个需求,很简单我们会用下面的代码进行处理(思路:先查找数据库,如果数据库存在则直接退出,否则插入) package com.yhj.test; import com.yhj.dao.OrderDao; import com.yhj.pojo.Order;

数据量、高并发数据库的高性能、高可用性解决方案

1.拆表:大表拆小表(垂直拆,水平拆:分表,分区partition,分片sharding),可以在应用层实现,也可以在数据库层面实现一部分:提高系统性能. 2.分库:把表放到不同的数据库,这也是分布式数据库的基础:提高系统性能. 3.分布式:不同的数据库放到不同的服务器:提高系统性能. 4.集群:使用数据库复制等技术组建集群,实现读写分离.备份等:提高系统性能.可用性. 5.缓存:对常用的数据进行缓存.提高系统性能. 6.备份:主从库,快照,热备,异地备份等:提高系统可用性.

项目中使用缓存的目的?(高并发和高性能)

用缓存,主要有两个用途,一个是高性能,一个是高并发. 1)高性能 假设这么个场景,你有个操作,一个请求过来,吭哧吭哧你各种乱七八糟操作mysql,半天查出来一个结果,耗时600ms.但是这个结果可能接下来几个小时都不会变了,或者变了也可以不用立即反馈给用户.那么此时咋办? 缓存啊,折腾600ms查出来的结果,扔缓存里,一个key对应一个value,下次再有人查,别走mysql折腾600ms了.直接从缓存里,通过一个key查出来一个value,2ms搞定.性能提升300倍. 这就是所谓的高性能.

nginx、swoole高并发原理初探

原文:https://segmentfault.com/a/1190000007614502 一.阅前热身 为了更加形象的说明同步异步.阻塞非阻塞,我们以小明去买奶茶为例. 1.同步与异步 ①同步与异步的理解 同步与异步的重点在消息通知的方式上,也就是调用结果通知的方式. 同步当一个同步调用发出去后,调用者要一直等待调用结果的通知后,才能进行后续的执行 异步:当一个异步调用发出去后,调用者不能立即得到调用结果的返回. 异步调用,要想获得结果,一般有两种方式:1.主动轮询异步调用的结果;2.被调用