Java实现高效PDF文件传输技巧

import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;

public class PDFTransferExample {
    public static void main(String[] args) {
        // 读取PDF文件
        try (FileInputStream fis = new FileInputStream("source.pdf")) {
            // 写入PDF文件
            try (FileOutputStream fos = new FileOutputStream("destination.pdf")) {
                byte[] buffer = new byte[1024];
                int bytesRead;
                while ((bytesRead = fis.read(buffer)) != -1) {
                    fos.write(buffer, 0, bytesRead);
                }
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

import org.apache.commons.io.FileUtils;

import java.io.File;
import java.io.IOException;

public class PDFTransferApacheCommonsIO {
    public static void main(String[] args) {
        File sourceFile = new File("source.pdf");
        File destinationFile = new File("destination.pdf");

        try {
            FileUtils.copyFile(sourceFile, destinationFile);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.ChannelOption;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.SocketChannel;
import io.netty.channel.socket.nio.NioServerSocketChannel;
import io.netty.handler.codec.http.HttpObjectAggregator;
import io.netty.handler.codec.http.HttpRequestDecoder;
import io.netty.handler.codec.http.HttpResponseEncoder;
import io.netty.handler.codec.http.LastHttpContent;
import io.netty.handler.stream.ChunkedStream;

import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.net.InetSocketAddress;

public class NettyPDFServer {
    public static void main(String[] args) {
        EventLoopGroup bossGroup = new NioEventLoopGroup();
        EventLoopGroup workerGroup = new NioEventLoopGroup();
        try {
            ServerBootstrap b = new ServerBootstrap();
            b.group(bossGroup, workerGroup)
             .channel(NioServerSocketChannel.class)
             .childHandler(new ChannelInitializer<SocketChannel>() {
                 @Override
                 public void initChannel(SocketChannel ch) throws Exception {
                     ch.pipeline().addLast(new HttpRequestDecoder(), new HttpResponseEncoder(),
                         new HttpObjectAggregator(1024 * 1024 * 10), new NettyPDFServerHandler());
                 }
             })
             .option(ChannelOption.SO_BACKLOG, 128)
             .childOption(ChannelOption.SO_KEEPALIVE, true);

            b.bind(8080).sync().channel().closeFuture().sync();
        } catch (InterruptedException e) {
            e.printStackTrace();
        } finally {
            workerGroup.shutdownGracefully();
            bossGroup.shutdownGracefully();
        }
    }
}

class NettyPDFServerHandler extends SimpleChannelInboundHandler<HttpRequest> {
    @Override
    protected void channelRead0(ChannelHandlerContext ctx, HttpRequest req) throws Exception {
        if (req.getMethod().equals(HttpMethod.GET)) {
            File file = new File("source.pdf");
            FileInputStream fis = new FileInputStream(file);
            ctx.write(new LastHttpContent(
                ctx.newChunkedFile(FileUtils.readFileToByteArray(file)),
                HttpResponseStatus.OK,
                req.headers(),
                "application/pdf"
            ));
        }
    }
}

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

public class PDFSocketServer {
    public static void main(String[] args) {
        int port = 8080;
        try (ServerSocket serverSocket = new ServerSocket(port)) {
            System.out.println("Server is listening on port " + port);
            Socket clientSocket = serverSocket.accept();
            System.out.println("Client connected: " + clientSocket.getInetAddress());

            try (BufferedInputStream in = new BufferedInputStream(
                     new FileInputStream("source.pdf"));
                 BufferedOutputStream out = new BufferedOutputStream(
                     clientSocket.getOutputStream())) {
                byte[] buffer = new byte[1024];
                int bytesRead;
                while ((bytesRead = in.read(buffer)) != -1) {
                    out.write(buffer, 0, bytesRead);
                }
                out.flush();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

import com.itextpdf.text.Document;
import com.itextpdf.text.Paragraph;
import com.itextpdf.text.pdf.PdfWriter;
import com.itextpdf.text.pdf.PdfReader;
import com.itextpdf.text.pdf.PdfCopy;
import com.itextpdf.text.pdf.PdfContentByte;

import java.io.FileOutputStream;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;

public class PDFiTextExample {
    public static void main(String[] args) {
        Document document = new Document();
        try (PdfWriter.getInstance(document, new FileOutputStream("example.pdf"))) {
            document.open();
            document.add(new Paragraph("Hello, iText!"));
            document.close();
        } catch (Exception e) {
            e.printStackTrace();
        }

        Socket socket = new Socket("localhost", 8080);
        try (InputStream in = new FileInputStream("example.pdf");
             OutputStream out = socket.getOutputStream()) {
            byte[] buffer = new byte[1024];
            int bytesRead;
            while ((bytesRead = in.read(buffer)) != -1) {
                out.write(buffer, 0, bytesRead);
            }
            out.flush();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}