借助Java Socket：实现高效数据交互的利器

闲谈

2024-01-08 19:38:23

Java Socket编程简介

Java Socket编程是一种基于TCP/IP协议实现服务器和客户端之间数据交互的技术。它允许程序在不同的计算机之间建立连接，并通过连接发送和接收数据。Java Socket编程主要涉及两个类：ServerSocket和Socket。

ServerSocket

ServerSocket用于创建一个服务器应用程序，它监听一个特定的端口，等待客户端连接。一旦客户端连接到服务器，ServerSocket就会创建一个Socket对象，用于与客户端进行通信。

Socket

Socket是一个用于表示连接的类。它可以被服务器端或客户端使用，用于发送和接收数据。

Java Socket编程示例

下面是一个简单的Java Socket编程示例，演示如何构建一个服务器-客户端应用程序：

// 服务器端代码

import java.io.*;
import java.net.*;

public class Server {
    public static void main(String[] args) throws IOException {
        // 创建ServerSocket，监听端口8080
        ServerSocket serverSocket = new ServerSocket(8080);

        // 等待客户端连接
        Socket socket = serverSocket.accept();

        // 从客户端读取数据
        InputStream inputStream = socket.getInputStream();
        BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(inputStream));
        String data = bufferedReader.readLine();

        // 打印客户端发送的数据
        System.out.println("Received data from client: " + data);

        // 向客户端发送数据
        OutputStream outputStream = socket.getOutputStream();
        PrintWriter printWriter = new PrintWriter(outputStream, true);
        printWriter.println("Hello, client!");

        // 关闭连接
        socket.close();
        serverSocket.close();
    }
}

// 客户端端代码

import java.io.*;
import java.net.*;

public class Client {
    public static void main(String[] args) throws IOException {
        // 创建Socket，连接到服务器端的8080端口
        Socket socket = new Socket("localhost", 8080);

        // 向服务器端发送数据
        OutputStream outputStream = socket.getOutputStream();
        PrintWriter printWriter = new PrintWriter(outputStream, true);
        printWriter.println("Hello, server!");

        // 从服务器端读取数据
        InputStream inputStream = socket.getInputStream();
        BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(inputStream));
        String data = bufferedReader.readLine();

        // 打印服务器端发送的数据
        System.out.println("Received data from server: " + data);

        // 关闭连接
        socket.close();
    }
}