Java PrintStream在递归方法中写入文件异常的解决方案

public static LinkedQueue<Stock> getStockData(LinkedQueue<Stock> stockQueue, String startPath) throws Exception {
    File dir = new File(getValidDirectory(startPath));
    try (PrintStream recordErrors = new PrintStream(new File("EODdataERRORS.txt"))) { // PrintStream在此处实例化
        for (File name : dir.listFiles()) {
            if (name.isDirectory()) {
                getStockData(stockQueue, name.getPath()); // 递归调用
            } else if (name.canRead()) {
                // ... 文件读取和数据处理逻辑 ...
                try {
                    // ... 正常数据处理 ...
                } catch (Exception ex) {
                    recordErrors.println("ERROR: " + ex.getMessage()); // 在catch块中写入
                    System.err.println("ERROR: " + ex.getMessage()); // 同时输出到控制台
                }
            }
        }
    } catch (FileNotFoundException ex) {
        System.err.println("FileNotFoundException. Please ensure the directory is configured properly.");
    }
    return stockQueue;
}

import java.io.File;
import java.io.FileNotFoundException;
import java.util.Scanner;
// 假设 Stock 和 LinkedQueue 是已定义的类

public class StockProcessor {

    // 辅助方法，用于获取有效目录，此处省略具体实现
    private static String getValidDirectory(String path) {
        // 示例：简单返回路径，实际应包含路径验证逻辑
        return path;
    }

    public static void getStockData(LinkedQueue<Stock> stockQueue, LinkedQueue<String> errorQueue, String startPath) {
        File dir = new File(getValidDirectory(startPath));
        if (!dir.exists() || !dir.isDirectory()) {
            System.err.println("Directory not found or is not a directory: " + startPath);
            return;
        }

        try {
            File[] files = dir.listFiles();
            if (files == null) {
                System.err.println("No files or directories found in: " + startPath);
                return;
            }

            for (File name : files) {
                if (name.isDirectory()) {
                    // 递归调用，传递同一个 errorQueue 实例
                    getStockData(stockQueue, errorQueue, name.getPath());
                } else if (name.canRead()) {
                    try (Scanner readFile = new Scanner(name)) {
                        if (readFile.hasNextLine()) { // 跳过标题行
                            readFile.nextLine();
                        }
                        while (readFile.hasNext()) {
                            String line = readFile.nextLine();
                            String[] lineArray = line.split(",+");
                            if (lineArray.length == 8) {
                                try {
                                    // 假设 Stock 构造函数和 fromRecord 方法已定义
                                    Stock stock = new Stock(name.getName().replaceAll("_+(.*)", ""));
                                    stock.fromRecord(lineArray);
                                    stockQueue.enqueue(stock);
                                } catch (Exception ex) {
                                    String errorMessage = name.getName() + ": " + line + "; ERROR: " + ex.getMessage();
                                    errorQueue.enqueue(errorMessage); // 将错误添加到队列
                                    System.err.println(errorMessage);
                                }
                            } else {
                                String errorMessage = name.getName() + ": " + line + "; ERROR: Invalid record length.";
                                errorQueue.enqueue(errorMessage); // 将错误添加到队列
                                System.err.println(errorMessage);
                            }
                        }
                    } catch (FileNotFoundException e) {
                        String errorMessage = "FileNotFoundException for " + name.getPath() + ": " + e.getMessage();
                        errorQueue.enqueue(errorMessage);
                        System.err.println(errorMessage);
                    }
                }
            }
        } catch (Exception ex) { // 捕获其他可能的异常
            String errorMessage = "An unexpected error occurred in " + startPath + ": " + ex.getMessage();
            errorQueue.enqueue(errorMessage);
            System.err.println(errorMessage);
        }
    }

    // 假设的 Stock 类和 LinkedQueue 类
    static class Stock {
        String name;
        // ... other fields ...
        public Stock(String name) { this.name = name; }
        public void fromRecord(String[] data) { /* parse data */ }
    }

    static class LinkedQueue<E> {
        private static class Node<E> {
            E item;
            Node<E> next;
            Node(E element, Node<E> next) {
                this.item = element;
                this.next = next;
            }
        }
        private Node<E> head;
        private Node<E> tail;
        private int size = 0;

        public void enqueue(E item) {
            Node<E> oldTail = tail;
            tail = new Node<>(item, null);
            if (isEmpty()) {
                head = tail;
            } else {
                oldTail.next = tail;
            }
            size++;
        }

        public E dequeue() {
            if (isEmpty()) throw new java.util.NoSuchElementException();
            E item = head.item;
            head = head.next;
            if (isEmpty()) {
                tail = null;
            }
            size--;
            return item;
        }

        public boolean isEmpty() {
            return size == 0;
        }

        public int size() {
            return size;
        }
    }
}

import java.io.File;
import java.io.PrintStream;
import java.io.FileNotFoundException;

public class MainApp {
    public static void main(String[] args) {
        LinkedQueue<StockProcessor.Stock> stockQueue = new LinkedQueue<>();
        LinkedQueue<String> errorQueue = new LinkedQueue<>();
        String startDirectory = "/path/to/your/data"; // 替换为你的数据目录

        try {
            StockProcessor.getStockData(stockQueue, errorQueue, startDirectory);

            // 在所有文件处理完成后，统一将错误写入文件
            try (PrintStream recordErrors = new PrintStream(new File("EODdataERRORS.txt"))) {
                while (!errorQueue.isEmpty()) {
                    recordErrors.println(errorQueue.dequeue());
                }
                System.out.println("Error data successfully written to EODdataERRORS.txt");
            } catch (FileNotFoundException ex) {
                System.err.println("Could not create error file: " + ex.getMessage());
            }

            System.out.println("Total stocks processed: " + stockQueue.size());
            // ... 可以进一步处理 stockQueue 中的数据 ...

        } catch (Exception e) {
            System.err.println("An unhandled exception occurred during stock data processing: " + e.getMessage());
            e.printStackTrace();
        }
    }
}