使用 Groovy(Grails) 写入文件对于某些行（断行）失败

Question

我正在使用 Groovy 在 .csv 文件中执行一些大规模写入。更具体地说，我有一个 Quartz 作业正在运行，并创建了一些发送到 RabbitMQ 队列的 Map 消息。该队列被 10 个消费者使用，并导致生成一些字符串列表。对于列表中的每个元素，我只需将其写入管道分隔的 .csv 文件中。具有写入 .csv 文件的方法的实际服务是标准（单例）事务性 grails 服务。当我记录要写入的行时，一切都很好，但是在文件中，有些行被“破坏”了。我的写作方式是：

def writeRowsToFile(List<String> rows, File file) {
  rows.each {row->
    file.append("${row}\n")
  }
}

最初我使用的是：

file.withWriterAppend {out->
  out.write(row.toString())
  out.newLine()
}

也得到了同样的东西......

如果出现问题，所有行都会失败。可能是某种竞争条件、并发性还是我不知道还有什么问题？

任何帮助将不胜感激。

谢谢

Answer 1

你应该用第二种方式，即：

def writeRowsToFile(List<String> rows, File file) {
  file.withWriterAppend {out->
    rows.eachWithIndex { row, idx ->

      // It's probably \n chars in your strings
      if( row ==~ /.*[\n\r]+.*/ ) {
        println "Detected a CRLF char in rows[$idx]"
      }

      out.writeLine row
    }
  }
}

但是，您说这可能是“某种竞争条件”

是否有多个线程写入同一个文件？

如果不是，您的row 数据中更有可能包含\n 字符