Как написать данные сразу двум объектам java.io.OutputStream?

Ответ 1

Попробуйте Apache Commons TeeOutputStream.

Ответ 2

Просто сканируй свой. Нет никакой магии. Используя Apache TeeOutputStream, вы в основном используете код ниже. Конечно, используя библиотеку ввода-вывода Apache Commons, вы можете использовать другие классы, но иногда приятно писать что-то для себя.:)

public final class TeeOutputStream extends OutputStream {

  private final OutputStream out;
  private final OutputStream tee;

  public TeeOutputStream(OutputStream out, OutputStream tee) {
    if (out == null)
      throw new NullPointerException();
    else if (tee == null)
      throw new NullPointerException();

    this.out = out;
    this.tee = tee;
  }

  @Override
  public void write(int b) throws IOException {
    out.write(b);
    tee.write(b);
  }

  @Override
  public void write(byte[] b) throws IOException {
    out.write(b);
    tee.write(b);
  }

  @Override
  public void write(byte[] b, int off, int len) throws IOException {
    out.write(b, off, len);
    tee.write(b, off, len);
  }

  @Override
  public void flush() throws IOException {
    out.flush();
    tee.flush();
  }

  @Override
  public void close() throws IOException {
    out.close();
    tee.close();
  }
}

Тестирование с помощью вышеуказанного класса со следующим

public static void main(String[] args) throws IOException {
  TeeOutputStream out = new TeeOutputStream(System.out, System.out);
  out.write("Hello world!".getBytes());
  out.flush();
  out.close();
}

будет печатать Hello World!Hello World!.

(Примечание: переопределенная close() может использовать некоторую осторожность:

Ответ 3

Просто нашел эту тему, потому что мне пришлось столкнуться с той же проблемой. Если кто-то хочет увидеть мое решение (код java7):

package Core;
import java.io.IOException;
import java.io.OutputStream;
import java.util.Iterator;
import java.util.LinkedList;
import java.util.List;

public class MultiOutputStream extends OutputStream {

private List<OutputStream> out;

public MultiOutputStream(List<OutputStream> outStreams) {

    this.out = new LinkedList<OutputStream>();

    for (Iterator<OutputStream> i = outStreams.iterator(); i.hasNext();) {
        OutputStream outputStream = (OutputStream) i.next();

        if(outputStream == null){
            throw new NullPointerException();
        }
        this.out.add(outputStream);
    }
}

@Override
public void write(int arg0) throws IOException {

    for (Iterator<OutputStream> i = out.iterator(); i.hasNext();) {
        OutputStream var = (OutputStream) i.next();

        var.write(arg0);
    }
}

@Override
public void write(byte[] b) throws IOException{

    for (Iterator<OutputStream> i = out.iterator(); i.hasNext();) {
        OutputStream var = (OutputStream) i.next();

        var.write(b);
    }
}

@Override
public void write(byte[] b, int off, int len) throws IOException{

    for (Iterator<OutputStream> i = out.iterator(); i.hasNext();) {
        OutputStream var = (OutputStream) i.next();

        var.write(b, off, len);
    }
}

@Override
public void close() throws IOException{

    for (Iterator<OutputStream> i = out.iterator(); i.hasNext();) {
        OutputStream var = (OutputStream) i.next();

        var.close();
    }
}

@Override
public void flush() throws IOException{

    for (Iterator<OutputStream> i = out.iterator(); i.hasNext();) {
        OutputStream var = (OutputStream) i.next();

        var.flush();
    }
}

}

Хорошо работает до сих пор, просто протестировали некоторые основные операции, например. создавая MultiOutputStream из потока System.out и 2 PrintStreams, каждый из которых записывается в отдельный журнал. Я использовал

System.setOut(multiOutputStream);

чтобы записать на экран терминала и два журнала, которые работали без проблем.

Ответ 4

Сверните свое, это в основном тривиально. Используйте ArrayList<OutputStream> или любой другой популярный в настоящее время для хранения всех потоков, которые вы хотите, и напишите метод write, чтобы перебрать их все, записывая их каждому.

Ответ 5

final ByteArrayOutputStream byteStream = new ByteArrayOutputStream();
final FileOutputStream fileStream = new FileOutputStream(new File("/tmp/somefile"));
OutputStream outStream = new OutputStream() {

    public void write(int b) throws IOException {
        byteStream.write(b);
        fileStream.write(b);
    }
};
outStream.write("Hello world".getBytes());