同时写入XML文件

Question

我正在不同的机器上运行多个进程，这些进程需要读/写到共享的XML文件，为此我正在使用DOM with Java和FileLocks（虽然我知道数据库将是一种更有效的方法，但由于项目限制，这种方法不可行） 。

要更改XML文件，相关过程首先创建一个专用锁定的通道，该通道用于读取文件，然后尝试在关闭通道之前重用相同的通道来写入新版本。这样锁就永远不会掉下来。但是，问题是java.nio.channels.ClosedChannelException，即使我从未明确关闭通道，尝试写入结果时也会得到提示。我怀疑那行代码：

doc = dBuilder.parse(Channels.newInputStream(channel));

关闭通道。如果是这样，我怎么能强迫通道保持打开状态？我的代码如下所示：

[更新后删除代码]

更新：System.out.println(channel.isOpen())在可疑代码行的前面和之后放置以确认这是关闭通道的位置。

更新： 问了一个单独的问题，下面的代码现在防止通道在解析操作期间关闭。现在的问题是，转换器没有替换原始的xml文件，而是将更改后的文档附加到原始文件中。在文档中，我找不到用于指定Transformer.transform（我已经搜索过Transformer/
Transformer factory/ StreamResult）输出的任何相关选项。我想念什么吗？编写之前是否需要以某种方式清除频道？谢谢。

更新： 最后通过将通道截断为0大小解决了附加问题。谢谢@JLRishe的建议。已发布工作代码作为答案。

Answer 1

这是最终生效的代码！有关不同部分的说明，请参阅问题更新。

import java.io.*;
import java.nio.channels.*;

import javax.xml.parsers.*;
import javax.xml.transform.*;
import javax.xml.transform.dom.DOMSource;
import javax.xml.transform.stream.StreamResult;
import javax.xml.xpath.*;

import org.w3c.dom.*;
import org.xml.sax.SAXException;

public class Test2{ 
    String path = "...Test 2.xml";

    public Test2(){
        Document doc = null;
        DocumentBuilderFactory dbFactory;
        DocumentBuilder dBuilder;
        NodeList itemList;
        Transformer transformer;
        FileChannel channel; 
        Element newElement;
        int prevNumber;
        TransformerFactory transformerFactory ;
        DOMSource source;
        StreamResult result;
        NonClosingInputStream ncis = null;
        try {
            channel = new RandomAccessFile(new File(path), "rw").getChannel();
            FileLock lock = channel.lock(0L, Long.MAX_VALUE, false);

            try {
                dbFactory = DocumentBuilderFactory.newInstance();
                dBuilder = dbFactory.newDocumentBuilder();
                ncis = new NonClosingInputStream(Channels.newInputStream(channel));
                doc = dBuilder.parse(ncis);
            } catch (SAXException | IOException | ParserConfigurationException e) {
                e.printStackTrace();
            }
            doc.getDocumentElement().normalize();
            itemList = doc.getElementsByTagName("Item");
            newElement = doc.createElement("Item");
            prevNumber = Integer.parseInt(((Element) itemList.item(itemList.getLength() - 1)).getAttribute("Number"));
            newElement.setAttribute("Number", (prevNumber + 1) + "");

            doc.getDocumentElement().appendChild(newElement);

            transformerFactory = TransformerFactory.newInstance();
            transformer = transformerFactory.newTransformer();
            source = new DOMSource(doc);
            channel.truncate(0);
            result = new StreamResult(Channels.newOutputStream(channel));

            transformer.setOutputProperty("{http://xml.apache.org/xslt}indent-amount", "4");
            transformer.setOutputProperty(OutputKeys.OMIT_XML_DECLARATION, "no");
            transformer.setOutputProperty(OutputKeys.METHOD, "xml");
            transformer.setOutputProperty(OutputKeys.INDENT, "yes");
            transformer.setOutputProperty(OutputKeys.ENCODING, "UTF-8");
            transformer.transform(source, result);
            channel.close();
        } catch (IOException | TransformerException e) {
            e.printStackTrace();
        } finally {
            try {
                ncis.reallyClose();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }

    class NonClosingInputStream extends FilterInputStream {

        public NonClosingInputStream(InputStream it) {
            super(it);
        }

        @Override
        public void close() throws IOException {
            // Do nothing.
        }

        public void reallyClose() throws IOException {
            // Actually close.
            in.close();
        }
    }

    public static void main(String[] args){
        new Test2();
    }
}