流关闭错误-Storm

Question

我正在尝试读取html" target="_blank">文件中的一行，在喷口中，然后将其发送到螺栓，但我一直收到流关闭错误。我关闭错误还是这里有什么问题？

public class InputSpout extends BaseRichSpout {
    private SpoutOutputCollector collector;
    public void
    declareOutputFields( OutputFieldsDeclarer declarer) {
        declarer.declare( new Fields("logfile"));
    }
    private FileReader fileReader;
    private boolean completed = false;
    private TopologyContext context;
    @Override
    public void open( Map config, TopologyContext context, SpoutOutputCollector collector) { 
        try {
            this.context = context;
            this.fileReader = new FileReader(("logfile.txt").toString());
        } catch (FileNotFoundException e) {
            throw new RuntimeException("Error reading file "
                    + ("logfile"));
        }
        this.collector = collector;
    }
    public void nextTuple() {


        if (completed) {
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {

            }
        }
        String str;
        BufferedReader reader = new BufferedReader(fileReader);
        str = null;
        try {
            str = reader.readLine();
        } catch (IOException e1) {
            e1.printStackTrace();
        }
        try {
            while (str != null) {
                this.collector.emit(new Values(str));
                str = reader.readLine();
            }

        } catch (Exception e) {
            throw new RuntimeException("Error reading typle", e);
        } finally {
            completed = true;
        }
        try {
            reader.close();
            fileReader.close();
        } catch (IOException e) {
            e.printStackTrace();
        }

这是我遇到的错误：

Java语言io。IOException：溪流在周日关闭。nio。反恐精英。StreamDecoder。ensureOpen（StreamDecoder.java:46）在sun上。nio。反恐精英。StreamDecoder。在java上读取（StreamDecoder.java:147）。io。InputStreamReader。在java上读取（InputStreamReader.java:184）。io。BufferedReader。在java中填充（BufferedReader.java:154）。io。BufferedReader。java上的readLine（BufferedReader.java:317）。io。BufferedReader。myStorm上的readLine（BufferedReader.java:382）。输入口。backtype处的nextTuple（InputSpout.java:52）。暴风雨守护进程。遗嘱执行人$fn\uu 4654$fn\uu 4669$fn\uu 4698。在backtype调用（executor.clj:565）。暴风雨util$async\u循环$fn\u 458。在clojure调用（util.clj:463）。郎.AFn。在java上运行（AFn.java:24）。lang.Thread。运行（Thread.java:745）

Answer 1

您正在关闭nextTuple中fileReader使用的InputStream，使其无法用于后续调用。无需关闭此Reader-只需在读取所有数据后关闭单个BufferedReader。