Kalter, симулятор

У кого нибудь есть реализация RLE-сжатия? И насчет этой статьи, я не понял, на выходе после расшифровки/шифровки получается измененный поток?

RblSb, Поищи в файлах темы, я там разные варианты делал

RblSb, да, на выходе изменённый.

aNNiMON, rle туда видимо не прилепить, придется грузить все в массив байт

RblSb, если я правильно понимаю о чем ты, то прикрутить очень просто. При записи записываешь байт, и запоминаешь его, если потом приходит такой же, то увеличиваешь счетчик, если другой, то пишешь счетчик и этот новый. В flush просто птшешь счетчик. При чтении по аналогии.

Насчет алгоритма понятно, но как прочитать байт в inputstream и чтобы там благодаря собственному потоку оказалось два байта - не понял. Примеры в статье только для шифрования туда-обратно и годятся. Зачем нужен flush()?

RblSb, посмотри библиотеку net.sf.zipme, там ZipInputStream, ZipOutputStream и для Gzip тоже. Так что можно и для сжатия делать.
В GzipInputStream есть только метод read(byte[] buf, int offset, int length), его за глаза хватит, readByte не нужен по сути.

flush() дописывает оставвшиеся байты из буфера в файл

Цитата RblSb:

---

Насчет алгоритма понятно, но как прочитать байт в inputstream и чтобы там благодаря собственному потоку оказалось два байта - не понял. Примеры в статье только для шифрования туда-обратно и годятся. ЗКак-то так (не проверял)

Открыть спойлер

Закрыть спойлер

[копировать] [скачать]

1. package ua.naiksoftware.io;
2.  
3. import java.io.DataOutputStream;
4. import java.io.IOException;
5. import java.io.OutputStream;
6.  
7. /**
8.  * http://uk.wikipedia.org/wiki/RLE
9.  * @author Naik
10.  */
11. public class RleOutputStream extends OutputStream {
12.  
13.     private long count;
14.     private int current;
15.     private final DataOutputStream out;
16.  
17.     public RleOutputStream(OutputStream out) {
18.         this.out = new DataOutputStream(out);
19.         count = 0;
20.     }
21.  
22.     @Override
23.     public void write(int b) throws IOException {
24.         if (b == current) {
25.             count++;
26.         } else {
27.             if (count != 0) {
28.                 out.write(current);
29.                 out.writeLong(count);
30.             }
31.             current = b;
32.             count = 1;
33.         }
34.     }
35.  
36.     @Override
37.     public void flush() throws IOException {
38.         if (count != 0) {
39.             out.write(current);
40.             out.writeLong(count);
41.         }
42.         out.flush();
43.         super.flush();// не знаю, нужен вызов метода суперкласса или нет..
44.     }
45.  
46. }

Открыть спойлер

Закрыть спойлер

[копировать] [скачать]

1. package ua.naiksoftware.io;
2.  
3. import java.io.DataInputStream;
4. import java.io.IOException;
5. import java.io.InputStream;
6.  
7. /**
8.  * http://uk.wikipedia.org/wiki/RLE
9.  * @author Naik
10.  */
11. public class RleInputStream extends InputStream {
12.  
13.     private long count;
14.     private int current;
15.     private final DataInputStream input;
16.  
17.     public RleInputStream(InputStream input) {
18.         this.input = new DataInputStream(input);
19.     }
20.  
21.     @Override
22.     public int read() throws IOException {
23.         if (count < 1) {
24.             current = input.read();
25.             count = input.readLong();
26.         }
27.         count--;
28.         return current;
29.     }
30.  
31. }