Java进阶学习:网络服务器编程
Java的Socket API提供了一个很方便的对象接口进行网络编程。本文用一个简单的TCP Echo Server做例子，演示了如何使用Java完成一个网络服务器。
用作例子的TCP Echo Server是按以下方式工作的：
当一个客户端通过TCP连接到服务器后，客户端可以通过这个连接发送数据到服务端，而服务端接收到数据后会把这些数据用同一个TCP连接发送回客户端。服务端会一直保持这个连接直到客户端关闭它为止。
因为服务器需要能同时处理多个客户端，我们先选用一个常见的多线程服务模型：
让一个Thread负责监听服务端口，当有新的连接建立的时候，这个监听的Thread会为这个连接创建一个新的Thread来处理它。这样，服务器可以接受多个连接，并让多个Thread来分别处理它们。
以下是相应的服务端程序：
public class EchoServer implements Runnable { public void run() { try { ServerSocket svr = new ServerSocket(7); while (true) { Socket sock = svr.accept(); new Thread(new EchoSession(sock)).start(); } } catch (IOException ex) { throw new ExceptionAdapter(ex); } } } |
这段代码先创建了一个ServerSocket的对象并让其监听在TCP端口7上，然后在一个循环中用accept()方法接收新的连接，并创建处理这一连接的Thread。实际处理每个客户端连接的逻辑包含在EchoSession这个类里面。
在以上代码中使用了ExceptionAdapter这个类，它的作用是把一个checked Exception包装成RuntimeException。详细的说明可以参考避免在Java中使用Checked Exception 一文。
以下是EchoSession的代码：
public class EchoSession implements Runnable { public EchoSession(Socket s) { _sock = s; } public void run() { |
try { try { InputStream input = _sock.getInputStream(); OutputStream output = _sock.getOutputStream(); byte [] buf = new byte [128]; while (true) { int count = input.read(buf); if (count == -1) break; output.write(buf, 0 , count); } } finally { _sock.close(); } } catch (IOException ex) { throw new ExceptionAdapter(ex); } } protected Socket _sock = null; } |
EchoSession接受一个Socket对象作为构造参数，在其run()方法中，它不停的从这个Socket对象的InputStream里面读数据并写回到该Socket的OutputStream中去，直到这个连接被客户端关闭为止（InputStream的read方法返回-1）。
EchoSession需要一个线程来执行，这容易让人联想到用Thread来作为EchoSession的父类。不过，这样做不够灵活，开销也比较大。而选择让EchoSession实现Runnable接口就灵活得多。在接下来的使用Thread Pool的Echo Server中可以看到这一点。
以上已经是一个完整的TCP Echo Server，不过随着客户不停的连接和断开，这个服务器会不停的产生和消除线程，而这两个都是比较‘昂贵'的操作。为了避免这种消耗，可以考虑采用Thread Pool的机制。
使用在一个简单的Thread缓冲池的实现一文中Thread Pool的实现，可以对EchoServer作如下修改（EchoSession无需做修改）：
public class EchoServer implements Runnable { public void run() { try { ServerSocket svr = new ServerSocket(7); |
// 初始化Thread Pool SyncQueue queue = new SyncQueue(10); for (int i = 0; i < 10; i ++) { new Thread(new Worker(queue)).start(); } while (true) { Socket sock = svr.accept(); // 把任务放入Thread Pool queue.put(new EchoSession(sock)); } } catch (IOException ex) { throw new ExceptionAdapter(ex); } } } |
这里可以看出让EchoSession实现Runnable接口的灵活性，无需修改它就可以在Thread Pool里使用。
在这个例子里使用的Thread Pool比较简单，没有动态调整Thread数量的功能，所以这个Echo Server最多只能同时服务10个客户端。然而通过重载SyncQueue，我们可以很方便地加入这个功能以突破这个限制。
在对网络服务器的性能以及并发度要求很高的时候，让每个客户端由一个专门的Thread来处理有可能不能满足我们的要求（想象一下同时有数千个客户端的情况）。这时可以考虑使用Java的NIO API来构建服务器架构，因为NIO中IO操作都是非阻塞的，我们只需要很少的Thread就可以充分地利用CPU来处理多个客户端的请求。关于NIO的话题，在这篇文章就不再赘述，希望以后能有机会讨论。 ：）
相关文章
这篇文章主要介绍了使用dom4j解析xml文件,并转出json格式问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教2023-09-09
这篇文章主要介绍了SpringBoot整合redis使用缓存注解详解,@Cacheable在方法执行前判断对应缓存是否存在,如果存在直接返回缓存结果,否者执行方法将结果缓存,适用于查询类,需要的朋友可以参考下2024-01-01
Java使用Thread和Runnable的线程实现方法比较
这篇文章主要介绍了Java使用Thread和Runnable的线程实现方法,结合实例形式对比分析了Java使用Thread和Runnable实现与使用线程的相关操作技巧,需要的朋友可以参考下2019-10-10
这篇文章主要介绍了Java数据类型之引用数据类型,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教2023-07-07
Spring gateway + Oauth2实现单点登录及详细配置
gateway是基于 WebFlux的响应式编程框架，所以在使用securityConfig时采用的注解是@EnableWebFluxSecurity，接下来通过本文给大家介绍Spring gateway + Oauth2实现单点登录及详细配置，感兴趣的朋友一起看看吧2021-09-09
SpringCloud 作为当下最为流行的微服务框架，也越来越多的人去学习和使用这个框架。下面，我将带大家简单地认识一下 SpringCloud 框架，以及如何来搭建一个 SpringCloud 项目环境的教程2022-05-05
缓存用于提升系统的性能,特别适用于一些对资源需求比较高的操作,下面这篇文章主要给大家介绍了关于Spring cache源码的相关资料,文中通过示例代码介绍的非常详细,需要的朋友可以参考下2022-03-03
这篇文章主要为大家介绍了Java8函数式接口Predicate用法示例详解，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪2023-07-07
这篇文章主要为大家详细介绍了JavaWeb导出Excel文件并弹出下载框的相关资料，感兴趣的小伙伴们可以参考一下2016-06-06
SpringData JPA快速上手之关联查询及JPQL语句书写详解
JPA都有SpringBoot的官方直接提供的starter,而Mybatis没有,直到SpringBoot 3才开始加入到官方模版中,这篇文章主要介绍了SpringData JPA快速上手,关联查询,JPQL语句书写的相关知识,感兴趣的朋友一起看看吧2023-09-09
最新评论