百度360必应搜狗淘宝本站头条
当前位置:网站首页 > 技术教程 > 正文

Java 网络编程(Socket/HTTP基础)详解

csdh11 2025-05-16 12:37 3 浏览

一、网络编程基础概念

1. TCP vs UDP

  • TCP:面向连接、可靠传输(三次握手保证连接),适合文件传输、HTTP请求。
  • UDP:无连接、不可靠但速度快,适合实时音视频、广播场景。

2. Socket 编程核心类

  • ServerSocket:TCP 服务端监听端口。
  • Socket:TCP 客户端与服务端通信的端点。
  • DatagramSocket:UDP 通信端点。
  • DatagramPacket:UDP 数据包容器。

二、TCP Socket 编程

1. 服务端实现步骤

// 1. 创建ServerSocket监听端口
try (ServerSocket serverSocket = new ServerSocket(8080)) {
    System.out.println("服务端启动,等待客户端连接...");
    
    // 2. 接受客户端连接(阻塞直到有连接)
    Socket clientSocket = serverSocket.accept();
    System.out.println("客户端已连接: " + clientSocket.getInetAddress());
    
    // 3. 获取输入输出流
    try (BufferedReader in = new BufferedReader(
            new InputStreamReader(clientSocket.getInputStream()));
         PrintWriter out = new PrintWriter(
                 clientSocket.getOutputStream(), true)) {
        
        // 4. 读取客户端数据
        String request = in.readLine();
        System.out.println("收到客户端消息: " + request);
        
        // 5. 返回响应
        out.println("你好客户端,已收到你的消息: " + request);
    }
} catch (IOException e) {
    e.printStackTrace();
}

2. 客户端实现步骤

try (Socket socket = new Socket("localhost", 8080)) {
    System.out.println("已连接到服务端");
    
    // 获取输入输出流
    try (BufferedReader in = new BufferedReader(
            new InputStreamReader(socket.getInputStream()));
         PrintWriter out = new PrintWriter(
                 socket.getOutputStream(), true)) {
        
        // 发送请求
        out.println("Hello Server!");
        
        // 接收响应
        String response = in.readLine();
        System.out.println("服务端响应: " + response);
    }
} catch (IOException e) {
    e.printStackTrace();
}

三、UDP Socket 编程

1. 服务端接收数据

try (DatagramSocket socket = new DatagramSocket(9090)) {
    byte[] buffer = new byte[1024];
    DatagramPacket packet = new DatagramPacket(buffer, buffer.length);
    
    System.out.println("UDP服务端启动...");
    socket.receive(packet); // 阻塞等待数据
    
    String received = new String(packet.getData(), 0, packet.getLength());
    System.out.println("收到来自 " + packet.getAddress() + " 的消息: " + received);
} catch (IOException e) {
    e.printStackTrace();
}

2. 客户端发送数据

try (DatagramSocket socket = new DatagramSocket()) {
    String message = "Hello UDP Server";
    byte[] data = message.getBytes();
    
    InetAddress address = InetAddress.getByName("localhost");
    DatagramPacket packet = new DatagramPacket(
        data, data.length, address, 9090
    );
    
    socket.send(packet);
    System.out.println("消息已发送");
} catch (IOException e) {
    e.printStackTrace();
}

四、HTTP 客户端编程

1. 使用 HttpURLConnection(Java 原生)

// GET请求示例
URL url = new URL("http://example.com/api/data");
HttpURLConnection conn = (HttpURLConnection) url.openConnection();
conn.setRequestMethod("GET");

try (BufferedReader in = new BufferedReader(
        new InputStreamReader(conn.getInputStream()))) {
    String line;
    StringBuilder response = new StringBuilder();
    while ((line = in.readLine()) != null) {
        response.append(line);
    }
    System.out.println("响应内容: " + response);
} finally {
    conn.disconnect();
}

// POST请求示例(JSON数据)
conn.setRequestMethod("POST");
conn.setRequestProperty("Content-Type", "application/json");
conn.setDoOutput(true);

String jsonBody = "{\"name\":\"John\", \"age\":30}";
try (OutputStream os = conn.getOutputStream()) {
    byte[] input = jsonBody.getBytes(StandardCharsets.UTF_8);
    os.write(input, 0, input.length);
}
// 读取响应同上...

2. 使用 HttpClient(Java 11+ 推荐)

HttpClient client = HttpClient.newHttpClient();

// GET请求
HttpRequest request = HttpRequest.newBuilder()
        .uri(URI.create("http://example.com/api/data"))
        .build();

HttpResponse<String> response = client.send(
        request, HttpResponse.BodyHandlers.ofString());
System.out.println("状态码: " + response.statusCode());
System.out.println("响应体: " + response.body());

// POST请求(JSON数据)
String jsonBody = "{\"name\":\"John\", \"age\":30}";
HttpRequest postRequest = HttpRequest.newBuilder()
        .uri(URI.create("http://example.com/api/user"))
        .header("Content-Type", "application/json")
        .POST(HttpRequest.BodyPublishers.ofString(jsonBody))
        .build();
HttpResponse<String> postResponse = client.send(
        postRequest, HttpResponse.BodyHandlers.ofString());

五、多线程服务器优化

1. 为每个客户端连接创建线程

try (ServerSocket serverSocket = new ServerSocket(8080)) {
    while (true) {
        Socket clientSocket = serverSocket.accept();
        new Thread(() -> {
            try (BufferedReader in = new BufferedReader(
                    new InputStreamReader(clientSocket.getInputStream()));
                 PrintWriter out = new PrintWriter(
                         clientSocket.getOutputStream(), true)) {
                
                String request = in.readLine();
                out.println("处理结果: " + request.toUpperCase());
            } catch (IOException e) {
                e.printStackTrace();
            }
        }).start();
    }
}

2. 使用线程池管理连接

ExecutorService pool = Executors.newFixedThreadPool(10);
try (ServerSocket serverSocket = new ServerSocket(8080)) {
    while (true) {
        Socket clientSocket = serverSocket.accept();
        pool.submit(() -> {
            // 处理客户端连接(同上)
        });
    }
} finally {
    pool.shutdown();
}

六、常见问题与最佳实践

1.端口占用与释放

  • 确保关闭 Socket 和 ServerSocket(使用 try-with-resources)。
  • 避免 Address already in use 错误。

2.超时设置

socket.setSoTimeout(5000); // 设置读写超时(毫秒)

3.字符编码处理

  • 明确指定编码(如 StandardCharsets.UTF_8)。
  • 避免乱码问题。

4.HTTP 请求头设置

  • 如 User-Agent、Content-Type 需按需配置。

总结

Java 网络编程的核心是通过 Socket 实现客户端与服务端的通信:

  1. TCP Socket 提供可靠的双向字节流通信。
  2. UDP Socket 适合低延迟、允许丢包的场景。
  3. HTTP 客户端 可使用原生 HttpURLConnection 或更现代的 HttpClient。
  4. 多线程优化 提升服务器并发处理能力。

扩展方向:

  • Netty 框架(高性能网络应用开发)
  • WebSocket(实现双向实时通信)
  • NIO(非阻塞IO)(Selector 和 Channel 高效处理连接)

相关推荐

完美解决华硕主板机箱前置面板连接音箱无声音问题

#精品长文创作季#最近新组装了一台电脑主机,听歌时发现,音箱音频输入线插入主板自带的音频输出端口LINEOUT声音正常。但当将音箱音频输入线插入机箱自带的音频输出端口却没有声音。...

Java 监控直播流rtsp协议转rtmp、hls、httpflv协议返回浏览器

Java监控直播流rtsp协议转rtmp、hls、httpflv协议返回浏览器...

编译安装OpenCV全攻略,附本地源码包

本文以Ubuntu(适用于18,20,22版本,其他的未进行测试)为例,介绍了编译安装OpenCV的最佳实践。其他平台比如windows,只需要参考本文的思路做稍微调整即可。一、为什么需要编译安装Op...

音视频录制+RTMP直播推拉流

音视频录制:1,录音通过条件编译识别pc或者mac://条件编译技术识别pc或者mac#ifdefQ_OS_WIN#defineFMT_NAME"dshow"...

Python Socket.IO 简介

Socket.IO是一种传输协议,支持客户端与服务器之间基于事件的实时双向通信。客户端通常但不总是web浏览器,一般情况下,客户端是采用js编写的,当然,也可以用python、Java等。...

MyCat系列二--配置文件之server.xml

MyCat系列二--配置文件之server.xml从【安装与基本使用】一文中,可以看到MyCat运行,需要进行一些配置文件的相关配置,本文将重点介绍配置文件server.xml的基本元素信息,尽量了解...

3分钟搞懂Socket.IO:接口调试技巧

在数字化协作需求井喷的今天,即时通讯、协同文档、MMO游戏等场景对实时交互提出了严苛要求。传统HTTP协议"请求-响应"的离散式通信机制已难以满足需求,这正是Socket.IO这类实时...

「云原生」Containerd ctr,crictl 和 nerdctl 命令介绍与实战操作

一、概述作为接替Docker运行时的Containerd在早在Kubernetes1.7时就能直接与Kubelet集成使用,只是大部分时候我们因熟悉Docker,在部署集群时采用了默认的dockers...

搜狗开源srpc:自研高性能通用RPC框架

今年7月底,搜狗公司开源了内部的工业级C++服务器引擎Workflow,一路收获业内许多认可和关注。9月15日,作为Workflow最重要的生态项目——srpc,一个基于其打造的轻量级RPC框架,也在...

socket.io 权限认证

socket.io是一款流行的WebSocket库,提供了实时双向通信的能力。它支持多种身份验证方式,可用于保护某些敏感信息。接下来,我们将介绍如何使用socket.io权限认证1.安装依...

Linux高性能服务器设计

C10K和C10M计算机领域的很多技术都是需求推动的,上世纪90年代,由于互联网的飞速发展,网络服务器无法支撑快速增长的用户规模。1999年,DanKegel提出了著名的C10问题:一台服务器上同时...

19K 标星!开源局域网文件传输神器,AirDrop 跨平台替代品!

传统文件传输方式(如USB、蓝牙、邮件)要么速度慢,要么操作繁琐,而AirDrop仅限苹果生态。如果你还在为手机和电脑之间传文件来回折腾?还在装各种臃肿的客户端、扫码连Wi-Fi、用数据线拖来...

WebRTC 入门教程:搭建WebRTC信令服务器

前言我们在学习WebRTC时,首先要把实验环境搭建好,这样我们就可以在上面做各种实验了。对于WebRTC来说,它有一整套规范,如怎样使用它的接口、使用SDP进行媒体协商、通过ICE收集地址并进...

在 Go 中使用 Websockets 和 Socket.IO - 教程

注意-本教程是使用Go1.9版和googollee/go-socket.io编写的Websockets是我觉得有趣的东西,因为它们为我们提供了应用程序之间通信的替代选项,而不是标准的R...

2021 年 Node.js 开发人员学习路线图

Node.js自发布以来,已成为业界重要破局者之一。Uber、Medium、PayPal和沃尔玛等大型企业,纷纷将技术栈转向Node.js。Node.js支持开发功能强大的应用,例如实时追踪...