Java TCP 通信：实现简单的 Echo 服务器与客户端

news/2025/3/6 17:18:38/

TCP（Transmission Control Protocol）是一种面向连接的、可靠的传输层协议。与 UDP 不同，TCP 保证了数据的顺序、可靠性和完整性，适用于需要可靠传输的应用场景，如文件传输、网页浏览等。本文将基于 Java 实现一个简单的 TCP Echo 服务器和客户端，并通过代码总结相关的知识点。

1. TCP Echo 服务器

1.1 服务器代码结构

java">import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;public class TcpEchoServer {private ServerSocket serverSocket = null;public TcpEchoServer(int port) throws IOException {serverSocket = new ServerSocket(port);}public void start() throws IOException {System.out.println("服务器启动！");ExecutorService executorService = Executors.newCachedThreadPool();while (true) {// 通过 accept 方法，把内核中已经建立好的连接拿到应用程序中Socket clientSocket = serverSocket.accept();// 使用线程池处理客户端连接executorService.submit(() -> {try {processConnection(clientSocket);} catch (IOException e) {e.printStackTrace();}});}}// 通过这个方法，来处理连接public void processConnection(Socket clientSocket) throws IOException {// 打印客户端上线日志System.out.printf("[%s:%d] 客户端上线！\n", clientSocket.getInetAddress(), clientSocket.getPort());try (InputStream inputStream = clientSocket.getInputStream();OutputStream outputStream = clientSocket.getOutputStream()) {// 使用 Scanner 读取客户端请求Scanner scanner = new Scanner(inputStream);while (true) {if (!scanner.hasNext()) {// 连接断开System.out.printf("[%s:%d] 客户端下线！\n", clientSocket.getInetAddress(), clientSocket.getPort());break;}// 1. 读取请求并解析String request = scanner.next();// 2. 根据请求计算响应String response = process(request);// 3. 把响应写回到客户端PrintWriter printWriter = new PrintWriter(outputStream);printWriter.println(response);printWriter.flush();// 4. 打印请求交互的内容System.out.printf("[%s:%d] req=%s, resp=%s\n", clientSocket.getInetAddress(), clientSocket.getPort(),request, response);}} catch (IOException e) {e.printStackTrace();} finally {clientSocket.close();}}public String process(String request) {return request;}public static void main(String[] args) throws IOException {TcpEchoServer server = new TcpEchoServer(9090);server.start();}
}
1.2 服务器代码解析
ServerSocket：ServerSocket 是 Java 中用于监听客户端连接的类。服务器通过 ServerSocket 绑定到指定端口，等待客户端连接。Socket：Socket 是 Java 中用于表示客户端连接的类。服务器通过 serverSocket.accept() 方法获取客户端的连接，并返回一个 Socket 对象。线程池：为了支持多客户端并发连接，服务器使用 ExecutorService 线程池来处理每个客户端的请求。Executors.newCachedThreadPool() 创建了一个可缓存的线程池，根据需要创建新线程。processConnection()：该方法用于处理客户端连接。它通过 InputStream 和 OutputStream 与客户端进行数据交互。Scanner：Scanner 用于从 InputStream 中读取客户端发送的请求数据。PrintWriter：PrintWriter 用于将响应数据写入 OutputStream，并发送给客户端。日志打印：服务器在处理每个请求后，会打印客户端的地址、端口、请求内容和响应内容，方便调试和监控。2. TCP Echo 客户端
2.1 客户端代码结构
java复制import java.io.*;
import java.net.Socket;
import java.util.Scanner;public class TcpEchoClient {private Socket socket = null;public TcpEchoClient(String serverIP, int serverPort) throws IOException {socket = new Socket(serverIP, serverPort);}public void start() {Scanner scanner = new Scanner(System.in);try (InputStream inputStream = socket.getInputStream();OutputStream outputStream = socket.getOutputStream()) {PrintWriter writer = new PrintWriter(outputStream);Scanner scannerNetwork = new Scanner(inputStream);while (true) {// 从控制台读取用户输入System.out.print("-> ");String request = scanner.next();// 发送请求到服务器writer.println(request);writer.flush();// 读取服务器响应String response = scannerNetwork.next();System.out.println(response);}} catch (IOException e) {e.printStackTrace();}}public static void main(String[] args) throws IOException {TcpEchoClient client = new TcpEchoClient("127.0.0.1", 9090);client.start();}
}

2. TCP Echo 客户端

2.1 客户端代码结构

java">import java.io.*;
import java.net.Socket;
import java.util.Scanner;public class TcpEchoClient {private Socket socket = null;public TcpEchoClient(String serverIP, int serverPort) throws IOException {socket = new Socket(serverIP, serverPort);}public void start() {Scanner scanner = new Scanner(System.in);try (InputStream inputStream = socket.getInputStream();OutputStream outputStream = socket.getOutputStream()) {PrintWriter writer = new PrintWriter(outputStream);Scanner scannerNetwork = new Scanner(inputStream);while (true) {// 从控制台读取用户输入System.out.print("-> ");String request = scanner.next();// 发送请求到服务器writer.println(request);writer.flush();// 读取服务器响应String response = scannerNetwork.next();System.out.println(response);}} catch (IOException e) {e.printStackTrace();}}public static void main(String[] args) throws IOException {TcpEchoClient client = new TcpEchoClient("127.0.0.1", 9090);client.start();}
}

2.2 客户端代码解析

  1. Socket：客户端通过 Socket 连接到服务器。Socket 的构造函数需要指定服务器的 IP 地址和端口号。

  2. InputStream 和 OutputStream：客户端通过 InputStream 读取服务器返回的响应数据，通过 OutputStream 发送请求数据。

  3. PrintWriter：PrintWriter 用于将请求数据写入 OutputStream，并发送给服务器。

  4. Scanner：Scanner 用于从控制台读取用户输入，并从 InputStream 中读取服务器返回的响应数据。

  5. 循环交互：客户端通过一个无限循环，不断从控制台读取用户输入，发送请求并接收响应。

3. 总结

通过实现这个简单的 TCP Echo 服务器和客户端，我们可以总结出以下知识点：

  1. TCP 协议的特点：TCP 是一种面向连接的协议，保证了数据的顺序、可靠性和完整性，适用于需要可靠传输的应用场景。

  2. ServerSocket 和 Socket：这两个类是 Java 中实现 TCP 通信的核心类。ServerSocket 用于监听客户端连接，Socket 用于表示客户端连接。

  3. 多线程处理：为了支持多客户端并发连接，服务器使用线程池来处理每个客户端的请求。

  4. 流操作：InputStream 和 OutputStream 是 Java 中用于读写数据的核心类。通过 Scanner 和 PrintWriter，可以方便地进行文本数据的读写。

  5. 日志与调试：在实际开发中，打印日志是非常重要的，它可以帮助我们监控程序的运行状态，排查问题。

  6. Echo 服务器的应用：Echo 服务器是一种简单的网络服务，它将客户端发送的数据原样返回。虽然简单，但它可以帮助我们理解网络通信的基本原理。


http://www.ppmy.cn/news/1577121.html

相关文章

【GB28181】 SIP信令服务器

【GB28181】 SIP信令服务器

概述 本文仅总结关于GB28181下的注册、心跳维持等与推流拉流相配合的SIP信令，主要基于eXosip库实现；其中搭建信令服务器参考了开源代码以及B站up北小菜，文章结尾有链接 主要逻辑梳理 配置自身SIP服务器，同时配置自己想要访问的SI…
阅读更多...
6.从零开始学会Vue--{{路由}}

6.从零开始学会Vue--{{路由}}

1.路由简介 Vue 作为一个渐进式框架，在使用 vue-router 之后可以是程序变为一个 SPA 的单页面应用, 它的本质是使用了 js 的 History API： Vue Router 利用浏览器的 History API（如 pushState 和 replaceState），实现…
阅读更多...
自学微信小程序的第八天

自学微信小程序的第八天

DAY8 1、使用动画API即可完成动画效果的制作，先通过wx.createAnimation()方法获取Animation实例，然后调用Animation实例的方法实现动画效果。 表40：wx.createAnimation()方法的常用选项 选项 类型 说明 duration number 动画持续时间，单位为毫秒，默认值为400毫秒 timing…
阅读更多...
【计算机视觉】手势识别

【计算机视觉】手势识别

手势识别是计算机视觉领域中的重要方向，通过对摄像机采集的手部相关的图像序列进行分析处理，进而识别其中的手势，手势被识别后用户就可以通过手势来控制设备或者与设备交互。完整的手势识别一般有手的检测和姿态估计、手部跟踪和手势识别等。…
阅读更多...
HTTP四次挥手是什么？

HTTP四次挥手是什么？

四次挥手，这是TCP协议用来关闭连接的过程。四次挥手是确保两个主机之间能够安全、可靠地关闭连接的重要机制。我会用简单易懂的方式来讲解，帮助你理解它的原理和过程。 1. 什么是四次挥手？ 定义 四次挥手是TCP协议用来关闭连接的过程。它通…
阅读更多...
泵吸式激光可燃气体监测仪：快速精准守护燃气管网安全

泵吸式激光可燃气体监测仪：快速精准守护燃气管网安全

在城市化进程加速的今天，燃气泄漏、地下管网老化等问题时刻威胁着城市安全。如何实现精准、高效的可燃气体监测，守护“城市生命线”，成为新型基础设施建设的核心课题。泵吸式激光可燃气体监测仪，以创新科技赋能安全监测&#xff0…
阅读更多...
C# Unity 面向对象补全计划 之 索引器与迭代器

C# Unity 面向对象补全计划 之 索引器与迭代器

本文仅作学习笔记与交流，不作任何商业用途，作者能力有限，如有不足还请斧正 本篇有部分内容出自唐老狮,唐老师网站指路:全部 - 游习堂 - 唐老狮创立的游戏开发在线学习平台 - Powered By EduSoho 目录 1.索引器 2.迭代器 1.索引器 我的理解 索…
阅读更多...
ElasticSearch 在半导体工厂中的智能应用与 AI 联动

ElasticSearch 在半导体工厂中的智能应用与 AI 联动

您是否曾想过如何将 ElasticSearch 这一强大的搜索和分析引擎应用于半导体工厂的智能生产中？本文将为您揭示 ElasticSearch 在半导体行业的应用场景、与 AI 和向量数据库的结合方式，以及与开源 AI（如 DeepSeek）的联动方法&#xf…
阅读更多...
最新文章

Copyright @ 2022~2023