1

我有一个包含 java objects 的文件，用以下代码编写：

     from(somewhere).process(new Processor() {

          @Override
          public void process(final Exchange exchange) {
              ...
              ByteArrayOutputStream bos = new ByteArrayOutputStream();
              ObjectOutput out = new ObjectOutputStream(bos);
              out.writeObject(myObject);
              exchange.getOut().setBody(bos.toByteArray());
          }
     }).to("file://pathFile");

现在，我想快速阅读它们。我不知道我该怎么做，就像我猜的下面的代码。

from("file://pathFile").convertBodyTo(String.class)

.split(body().tokenize("???")) // How can I tokenize my file ?

.streaming().threads(2)

.process(new Processor() {

      @Override
      public void process(final Exchange exchange) {
        String filePath = (String) exchange.getIn().getHeader(Exchange.FILE_PATH);
        File file = new File(filePath);
        MyObject myObject = null;
        try {
          FileInputStream fis = new FileInputStream(file);
          InputStream buffer = new BufferedInputStream(fis);
          ObjectInput input = new ObjectInputStream(buffer);

          Object obj = null;
          while ((obj = input.readObject()) != null) {
              // Do something
              myObject = obj;
          }

        } catch (Exception e) {
            ...
        } finally {
          ...
        }
        exchange.getIn().setBody(myObject);
      }
}).to(somewhere);

编辑：我编辑我阅读对象的方式。该代码仍然存在问题，我们无法附加到 ObjectOutputStream。这将破坏流。这个问题有一个解决方案[here]。我们只能写一次流头。

但如果我这样做，我将无法使用多个线程拆分和读取我的文件。那么我可以在 ObjectOutputStream 标头上拆分或访问我的文件吗？

4

1 回答 1

1

您只是使用 将其转换为 String convertBodyTo(String.class)，因此正文中有一个 String 而不是 InputStream ....

于 2012-10-18T18:15:09.157 回答