从入门到精通:实战案例教你轻松掌握Java网络编程

2026-11-09 0 阅读

Java网络编程是Java语言中一个非常重要的领域,它允许开发者创建网络应用程序,如Web服务器、客户端程序、分布式系统等。本文将带你从入门到精通,通过一系列实战案例,让你轻松掌握Java网络编程。

一、Java网络编程基础

1.1 网络编程概述

网络编程是指使用编程语言实现网络通信的过程。Java提供了丰富的API来支持网络编程,如java.net包。

1.2 Java网络编程模型

Java网络编程主要基于两种模型:阻塞IO和非阻塞IO。

  • 阻塞IO:在数据传输过程中,线程会一直等待,直到数据传输完成。
  • 非阻塞IO:线程在数据传输过程中不会等待,而是继续执行其他任务。

二、Java网络编程实战案例

2.1 创建简单的TCP服务器

以下是一个简单的TCP服务器示例:

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

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

        while (true) {
            Socket clientSocket = serverSocket.accept();
            System.out.println("New client connected");

            new Thread(new ClientHandler(clientSocket)).start();
        }
    }
}

class ClientHandler implements Runnable {
    private Socket clientSocket;

    public ClientHandler(Socket socket) {
        this.clientSocket = socket;
    }

    @Override
    public void run() {
        try {
            BufferedReader in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
            PrintWriter out = new PrintWriter(clientSocket.getOutputStream(), true);

            String inputLine;
            while ((inputLine = in.readLine()) != null) {
                System.out.println("Received: " + inputLine);
                out.println("Echo: " + inputLine);
            }
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            try {
                clientSocket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}

2.2 创建简单的HTTP服务器

以下是一个简单的HTTP服务器示例:

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

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

        while (true) {
            Socket clientSocket = serverSocket.accept();
            new Thread(new ClientHandler(clientSocket)).start();
        }
    }
}

class ClientHandler implements Runnable {
    private Socket clientSocket;

    public ClientHandler(Socket socket) {
        this.clientSocket = socket;
    }

    @Override
    public void run() {
        try {
            BufferedReader in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
            PrintWriter out = new PrintWriter(clientSocket.getOutputStream(), true);

            String requestLine = in.readLine();
            if (requestLine != null) {
                System.out.println("Request: " + requestLine);

                String response = "HTTP/1.1 200 OK\r\nContent-Type: text/html\r\n\r\nHello, World!";
                out.println(response);
            }
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            try {
                clientSocket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}

2.3 使用Java NIO进行网络编程

Java NIO(非阻塞IO)提供了更高效的网络编程方式。以下是一个使用Java NIO的简单TCP服务器示例:

import java.net.*;
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 SimpleNIOserver {
    public static void main(String[] args) throws IOException {
        Selector selector = Selector.open();
        ServerSocketChannel serverSocketChannel = ServerSocketChannel.open();
        serverSocketChannel.bind(new InetSocketAddress(1234));
        serverSocketChannel.configureBlocking(false);
        serverSocketChannel.register(selector, SelectionKey.OP_ACCEPT);

        while (true) {
            selector.select();
            Set<SelectionKey> keys = selector.selectedKeys();
            Iterator<SelectionKey> keyIterator = keys.iterator();

            while (keyIterator.hasNext()) {
                SelectionKey key = keyIterator.next();
                keyIterator.remove();

                if (key.isAcceptable()) {
                    registerClient(selector, serverSocketChannel);
                } else if (key.isReadable()) {
                    readClient(key);
                }
            }
        }
    }

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

    private static void readClient(SelectionKey key) throws IOException {
        SocketChannel clientChannel = (SocketChannel) key.channel();
        ByteBuffer buffer = ByteBuffer.allocate(1024);
        int bytesRead = clientChannel.read(buffer);
        if (bytesRead > 0) {
            buffer.flip();
            String message = new String(buffer.array(), 0, bytesRead);
            System.out.println("Received: " + message);
            buffer.clear();
        }
    }
}

三、总结

通过以上实战案例,相信你已经对Java网络编程有了更深入的了解。Java网络编程是一个广泛且深入的领域,需要不断学习和实践。希望本文能帮助你轻松掌握Java网络编程。

分享到: