创建线程是比较经典的一种服务器开发模型,给每个客户端分配一个线程来提供服务
public void start() throws IOException {
System.out.println("启动服务器");
//创建线程池
ExecutorService service = Executors.newCachedThreadPool();
while(true) {
//建立连接
Socket clientSocket = serverSocket.accept();
//创建线程,每个线程去服务一个客户端
/*Thread t = new Thread(() -> {
try { processConnection(clientSocket); } catch (IOException e) { throw new RuntimeException(e); } }); t.start();*/
//使用线程池
service.submit(() -> {
try {
processConnection(clientSocket);
} catch (IOException e) {
throw new RuntimeException(e);
}
});
}
}
晚上 21:00开始比赛,可能就有几百万人涌入直播间
这瞬间几百万格客户端就连上服务器了
现代的服务器针对上述高并发场景,肯定是分布式(集群)方式来应对
- 一台服务器无论如何也是没法去应对几百万个客户端,所以就引入更多的服务器
newFixedThreadPool
是需要指定最大线程数的,但如果固定线程数,就意味着同时只能处理这么多个客户端 针对这个问题,还有一个方案能解决这个问题,虽然数目非常多,但仍然可以使用较少的线程,提供高效的服务——IO 多路复用
希望在进行网络服务器开发的时候,可以使用更少的线程,处理更多的客户端
IO 多路复用,也就是操作系统内核提供的功能(IO 多路复用具体的实现方案有很多种,最知名的就是 Linux
下的 epoll
)
Socket
(每个 Socket
对应一个客户端)放到这个数据结构里Socket
都是处于阻塞等待(没有数据需要处理),少数收到数据的 Socket
,epoll
就会通过回调函数的方式,通知应用程序,这里有数据了Socket
进行处理即可比如你今晚,你想吃烧烤,你妈想吃饺子,你爸想吃炒菜
你自己去买,先买烧烤,等;再买饺子,等;再买炒菜,等;完成。——>单线程,花的时间是最多的
你们三个一起去买,各买各的,分别等;完成——>多线程,花的时间机会缩短很多,等待的时间是三者最大值,系统开销也会更大
你自己去买,你先去买烧烤,给老板说“好了叫我”;再去买饺子,给老板说“好了叫我”;再去买炒菜,给老板说“好了叫我”,此时一个线程同时等待三份饭——>IO 多路复用的方案,此时等待的时间相比于多线程方案,相差不大,但是只需要一个线程就可以了
- 最关键的就是老爸能够喊我,哪个客户端来数据了,操作系统就能通知到应用程序
- 服务器开发中最主流的方案,尤其是 IO 多路复用中的 `epoll`
原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。
如有侵权,请联系 cloudcommunity@tencent.com 删除。
原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。
如有侵权,请联系 cloudcommunity@tencent.com 删除。