面试题：Java网络编程中TCP与UDP混合应用架构设计

1. TCP 和 UDP 的选择

实时数据交互（聊天消息）：
- 选择 UDP：聊天消息对实时性要求较高，少量数据丢失对整体体验影响相对较小，UDP 无连接、开销小、传输速度快的特点能满足其需求。例如，用户在聊天时发出的文字消息，偶尔一两条消息丢失，用户重新发送即可，不会对聊天功能造成严重影响。
大量文件传输：
- 选择 TCP：文件传输要求数据的完整性和准确性，TCP 提供可靠的面向连接的传输服务，通过确认、重传等机制保证数据无差错、不丢失、不重复且按序到达。如传输一个重要的文档，任何数据的丢失或错误都可能导致文档无法正常打开或内容不完整，TCP 能确保文件准确无误地传输。

2. 实现两者之间的协同工作和数据交互

架构设计：
- 分层架构：采用分层架构设计，如分为应用层、传输层、网络层等。在应用层，分别实现基于 UDP 的聊天模块和基于 TCP 的文件传输模块。传输层根据业务需求选择相应的协议。
- 消息队列：引入消息队列（如 RabbitMQ、Kafka 等），用于在不同模块之间进行异步通信和解耦。例如，当有新的聊天消息到达时，将消息发送到消息队列，聊天模块从队列中读取消息进行处理；文件传输任务也可通过消息队列进行调度和管理。
具体实现：
- UDP 聊天模块：
  - Java 实现：使用 DatagramSocket 和 DatagramPacket 类。以下是一个简单示例：

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.SocketException;

public class UDPChatReceiver {
    public static void main(String[] args) {
        try (DatagramSocket socket = new DatagramSocket(9876)) {
            byte[] receiveBuffer = new byte[1024];
            DatagramPacket receivePacket = new DatagramPacket(receiveBuffer, receiveBuffer.length);
            socket.receive(receivePacket);
            String message = new String(receivePacket.getData(), 0, receivePacket.getLength());
            System.out.println("Received message: " + message);
        } catch (SocketException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.net.SocketException;
import java.net.SocketTimeoutException;

public class UDPChatSender {
    public static void main(String[] args) {
        String message = "Hello, UDP Chat!";
        try (DatagramSocket socket = new DatagramSocket()) {
            InetAddress address = InetAddress.getByName("localhost");
            DatagramPacket packet = new DatagramPacket(message.getBytes(), message.length(), address, 9876);
            socket.send(packet);
        } catch (SocketException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

- **TCP 文件传输模块**：
    - **Java 实现**：使用 `Socket` 和 `ServerSocket` 类。以下是一个简单的文件发送示例：

import java.io.BufferedInputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.OutputStream;
import java.net.Socket;

public class TCPFileSender {
    public static void main(String[] args) {
        String filePath = "example.txt";
        try (Socket socket = new Socket("localhost", 12345);
             OutputStream outputStream = socket.getOutputStream();
             BufferedInputStream bis = new BufferedInputStream(new FileInputStream(new File(filePath)))) {
            byte[] buffer = new byte[1024];
            int bytesRead;
            while ((bytesRead = bis.read(buffer)) != -1) {
                outputStream.write(buffer, 0, bytesRead);
            }
            outputStream.flush();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

    - **文件接收示例**：

import java.io.BufferedOutputStream;
import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;

public class TCPFileReceiver {
    public static void main(String[] args) {
        String savePath = "received_example.txt";
        try (ServerSocket serverSocket = new ServerSocket(12345);
             Socket socket = serverSocket.accept();
             InputStream inputStream = socket.getInputStream();
             BufferedOutputStream bos = new BufferedOutputStream(new FileOutputStream(new File(savePath)))) {
            byte[] buffer = new byte[1024];
            int bytesRead;
            while ((bytesRead = inputStream.read(buffer)) != -1) {
                bos.write(buffer, 0, bytesRead);
            }
            bos.flush();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

- **协同工作**：
    - **通过消息队列**：以聊天消息触发文件传输为例，当聊天模块接收到特定指令（如 “发送文件” 消息）时，将文件传输任务相关信息（如文件路径、接收方地址等）发送到消息队列。文件传输模块监听消息队列，获取任务信息后启动 TCP 文件传输流程。
    - **共享状态信息**：可以维护一个共享的状态信息表（如使用 Redis 等分布式缓存），记录聊天和文件传输的相关状态。例如，记录某个用户当前是否正在进行文件传输，以便聊天模块在用户传输文件时进行提示或暂停某些实时消息交互，避免资源冲突。

星途面试题库

面试题：Java网络编程中TCP与UDP混合应用架构设计

知识考点

面试题答案

1. TCP 和 UDP 的选择

2. 实现两者之间的协同工作和数据交互