java怎样利用Socket实现网络通信功能 javaSocket网络通信的实用操作技巧​

ServerSocket

Socket

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

public class Server {
    public static void main(String[] args) throws IOException {
        ServerSocket serverSocket = new ServerSocket(12345); // 监听12345端口
        System.out.println("服务器启动，等待客户端连接...");

        while (true) {
            Socket clientSocket = serverSocket.accept(); // 阻塞，直到有客户端连接
            System.out.println("客户端连接成功！");

            // 创建输入输出流
            PrintWriter out = new PrintWriter(clientSocket.getOutputStream(), true);
            BufferedReader in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));

            String inputLine;
            while ((inputLine = in.readLine()) != null) {
                System.out.println("客户端发来消息: " + inputLine);
                out.println("服务器已收到: " + inputLine); // 回复客户端
            }

            // 关闭连接
            clientSocket.close();
            System.out.println("客户端断开连接。");
        }
        //serverSocket.close(); // 通常不需要在这里关闭，除非你想停止服务器
    }
}

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

public class Client {
    public static void main(String[] args) throws IOException {
        String serverAddress = "127.0.0.1"; // 服务器IP地址
        int serverPort = 12345; // 服务器端口

        Socket socket = new Socket(serverAddress, serverPort);
        System.out.println("成功连接到服务器！");

        // 创建输入输出流
        PrintWriter out = new PrintWriter(socket.getOutputStream(), true);
        BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
        BufferedReader stdIn = new BufferedReader(new InputStreamReader(System.in));

        String userInput;
        System.out.println("请输入要发送的消息 (输入 'exit' 退出):");
        while ((userInput = stdIn.readLine()) != null) {
            out.println(userInput); // 发送消息到服务器
            System.out.println("服务器回复: " + in.readLine());

            if (userInput.equals("exit")) {
                break;
            }
        }

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

IOException

IOException

IOException

try-catch

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

public class FileClient {
    public static void main(String[] args) throws IOException {
        String serverAddress = "127.0.0.1";
        int serverPort = 12345;
        String filePath = "example.txt"; // 要发送的文件

        Socket socket = new Socket(serverAddress, serverPort);
        System.out.println("连接到服务器...");

        File file = new File(filePath);
        FileInputStream fis = new FileInputStream(file);
        BufferedInputStream bis = new BufferedInputStream(fis);

        OutputStream os = socket.getOutputStream();

        byte[] buffer = new byte[8192]; // 8KB buffer
        int count;
        while ((count = bis.read(buffer)) > 0) {
            os.write(buffer, 0, count);
            os.flush(); // 确保数据立即发送
        }

        os.close();
        bis.close();
        socket.close();
        System.out.println("文件发送完毕！");
    }
}

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

public class FileServer {
    public static void main(String[] args) throws IOException {
        ServerSocket serverSocket = new ServerSocket(12345);
        System.out.println("服务器启动，等待客户端连接...");

        Socket clientSocket = serverSocket.accept();
        System.out.println("客户端连接成功！");

        InputStream is = clientSocket.getInputStream();
        FileOutputStream fos = new FileOutputStream("received.txt"); // 保存为received.txt
        BufferedOutputStream bos = new BufferedOutputStream(fos);

        byte[] buffer = new byte[8192];
        int count;
        while ((count = is.read(buffer)) > 0) {
            bos.write(buffer, 0, count);
            bos.flush();
        }

        bos.close();
        is.close();
        clientSocket.close();
        serverSocket.close();
        System.out.println("文件接收完毕！");
    }
}