Linux系统Java如何进行网络编程

在Linux系统上进行Java网络编程，主要涉及到使用Java提供的网络API，如java.net包中的类和接口。以下是一些基本步骤和示例代码，帮助你开始Java网络编程：

1. 创建Socket连接

客户端

客户端通过Socket类连接到服务器。

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

public class Client {
    public static void main(String[] args) {
        try (Socket socket = new Socket("localhost", 8080);
             PrintWriter out = new PrintWriter(socket.getOutputStream(), true);
             BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()))) {

            // 发送数据到服务器
            out.println("Hello, Server!");

            // 接收服务器响应
            String response = in.readLine();
            System.out.println("Server response: " + response);

        } catch (UnknownHostException e) {
            System.err.println("Don't know about host: localhost.");
            e.printStackTrace();
        } catch (IOException e) {
            System.err.println("Couldn't get I/O for the connection to: localhost.");
            e.printStackTrace();
        }
    }
}

服务器

服务器通过ServerSocket类监听客户端连接。

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

public class Server {
    public static void main(String[] args) {
        try (ServerSocket serverSocket = new ServerSocket(8080)) {
            System.out.println("Server is listening on port 8080");

            while (true) {
                try (Socket clientSocket = serverSocket.accept();
                     PrintWriter out = new PrintWriter(clientSocket.getOutputStream(), true);
                     BufferedReader in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()))) {

                    // 接收客户端数据
                    String inputLine = in.readLine();
                    System.out.println("Client says: " + inputLine);

                    // 发送响应给客户端
                    out.println("Hello, Client!");

                } catch (IOException e) {
                    System.err.println("Exception caught when trying to listen on port 8080 or listening for a connection");
                    e.printStackTrace();
                }
            }
        } catch (IOException e) {
            System.err.println("Could not listen on port 8080");
            e.printStackTrace();
        }
    }
}

2. 使用URL和URLConnection

你也可以使用java.net.URL和java.net.URLConnection类来进行网络编程。

客户端

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

public class URLClient {
    public static void main(String[] args) {
        try {
            URL url = new URL("http://example.com");
            URLConnection connection = url.openConnection();
            BufferedReader in = new BufferedReader(new InputStreamReader(connection.getInputStream()));

            String inputLine;
            while ((inputLine = in.readLine()) != null) {
                System.out.println(inputLine);
            }
            in.close();
        } catch (MalformedURLException e) {
            System.err.println("Invalid URL: http://example.com");
            e.printStackTrace();
        } catch (IOException e) {
            System.err.println("I/O error occurred while trying to read from the URL.");
            e.printStackTrace();
        }
    }
}

3. 使用NIO（非阻塞I/O）

Java NIO提供了更高效的网络编程方式，适用于高并发场景。

服务器

import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.SelectionKey;
import java.nio.channels.Selector;
import java.nio.channels.ServerSocketChannel;
import java.nio.channels.SocketChannel;
import java.util.Iterator;
import java.util.Set;

public class NIOServer {
    public static void main(String[] args) throws IOException {
        Selector selector = Selector.open();
        ServerSocketChannel serverSocketChannel = ServerSocketChannel.open();
        serverSocketChannel.bind(new InetSocketAddress(8080));
        serverSocketChannel.configureBlocking(false);
        serverSocketChannel.register(selector, SelectionKey.OP_ACCEPT);

        while (true) {
            selector.select();
            Set<SelectionKey> selectedKeys = selector.selectedKeys();
            Iterator<SelectionKey> iter = selectedKeys.iterator();
            while (iter.hasNext()) {
                SelectionKey key = iter.next();

                if (key.isAcceptable()) {
                    register(selector, serverSocketChannel);
                }

                if (key.isReadable()) {
                    readDataFromSocket(key);
                }
                iter.remove();
            }
        }
    }

    private static void register(Selector selector, ServerSocketChannel serverSocketChannel) throws IOException {
        SocketChannel client = serverSocketChannel.accept();
        client.configureBlocking(false);
        client.register(selector, SelectionKey.OP_READ);
    }

    private static void readDataFromSocket(SelectionKey key) throws IOException {
        SocketChannel client = (SocketChannel) key.channel();
        ByteBuffer buffer = ByteBuffer.allocate(1024);
        int bytesRead = client.read(buffer);
        if (bytesRead == -1) {
            client.close();
        } else if (bytesRead > 0) {
            buffer.flip();
            byte[] data = new byte[buffer.remaining()];
            buffer.get(data);
            String message = new String(data).trim();
            System.out.println("Message received: " + message);
        }
    }
}

总结

以上是Java在Linux系统上进行网络编程的基本示例。你可以根据具体需求选择合适的网络API和方法。对于高并发场景，推荐使用NIO来提高性能。