passer d'un OutputStream à un InputStream...

passer d'un OutputStream à un InputStream... - Java - Programmation

Marsh Posté le 21-03-2003 à 00:26:16    

'lut,
 
dans une classe j'écris des brols dans un OutputStream que je voudrais donner à une autre classe qui doit le lire dans un InputStream...
 
je me suis battu un peu car j'ai toujours un peu de mal avec les Stream...
 
pourriez-vous me dire si vous avez une version plus simple de ce code:
 

Code :
  1. import java.io.BufferedReader;
  2. import java.io.ByteArrayInputStream;
  3. import java.io.ByteArrayOutputStream;
  4. import java.io.DataInputStream;
  5. import java.io.DataOutputStream;
  6. import java.io.IOException;
  7. import java.io.InputStreamReader;
  9. /**
  10. * User: cd
  11. * Date: Mar 20, 2003
  12. */
  13. public class StreamTest{
  14. public static void main(String[] args){
  15.  ByteArrayOutputStream stream = new ByteArrayOutputStream();
  17.  DataOutputStream dos = new DataOutputStream(stream);
  19.  try{
  20.   dos.writeBytes("Hello!" );
  21.  }
  22.  catch(IOException e){
  23.   System.out.println("Bardaf! [out]" );
  24.  }
  26.  DataInputStream dis = new DataInputStream(new ByteArrayInputStream(stream.toByteArray()));
  27.  BufferedReader buff = new BufferedReader(new InputStreamReader(dis));
  29.  try{
  30.   System.out.println(buff.readLine());
  31.  }
  32.  catch(IOException e){
  33.   System.out.println("Bardaf! [in]" );
  34.  }
  35. }
  36. }


 
paske je trouve ça lourd en objets en cascade...


Message édité par TBone le 21-03-2003 à 00:26:50

---------------
As the plane took off, the pilot turned to the co-pilot and said, “Have you ever flown solo?” Co-pilot: No. Typically I fly much higher than this.
Reply

Marsh Posté le 21-03-2003 à 00:26:16   

Reply

Marsh Posté le 21-03-2003 à 00:27:19    

sans passer par un fichier...


---------------
As the plane took off, the pilot turned to the co-pilot and said, “Have you ever flown solo?” Co-pilot: No. Typically I fly much higher than this.
Reply

Marsh Posté le 21-03-2003 à 00:38:20    

PipedInputStream d'un cote et PipedOutputStream de l'autre, ensuite tu connectes les deux pour avoir un pipe.
 
Bye

Reply

Marsh Posté le 21-03-2003 à 00:39:29    

Ce sont 2 classes de java.io, disponibles depuis la jdk 1.0 et donc oui c'est plus simple a utiliser que ton code.

Reply

Marsh Posté le 21-03-2003 à 00:51:43    

j'vais aller voir ça.
 
merci :hello:


---------------
As the plane took off, the pilot turned to the co-pilot and said, “Have you ever flown solo?” Co-pilot: No. Typically I fly much higher than this.
Reply

Marsh Posté le 21-03-2003 à 08:51:12    

TBone a écrit :

j'vais aller voir ça.
 
merci :hello:


 
you're welcome ;)

Reply

Marsh Posté le 09-06-2004 à 15:39:23    

Attention, ces 2 classes sont conçues pour être utilisées par 2 threads différents


---------------
http://runnerstats.net
Reply

Marsh Posté le 09-06-2004 à 17:11:45    

phenixl a écrit :

PipedInputStream d'un cote et PipedOutputStream de l'autre, ensuite tu connectes les deux pour avoir un pipe.
 
Bye


merde, j'avais recodé ca moi même  :cry:  
 

noldor a écrit :

Attention, ces 2 classes sont conçues pour être utilisées par 2 threads différents


ha ben du coup j'ai pas fait ca pour rien [:meganne]
 

Code :
  1. import java.io.*;
  3. public class ByteArrayStream extends ByteArrayOutputStream {
  6. public ByteArrayStream() {
  7.  super();
  8. }
  10. public ByteArrayStream(int size) {
  11.  super(size);
  12. }
  14. /**
  15.  * the reset method is not supported.  
  16.  * @throws UnsupportedOperationException this exception is ALWAYS sent
  17.  */
  18. public synchronized void reset() {
  19.  throw new UnsupportedOperationException("The reset method is not supported" );
  20. }
  22. /**
  23.  * return a InputStream that read the actual content of the array. The end of the stream is  
  24.  * fixed to the actuel size of the array
  25.  */
  26. public synchronized InputStream getInputStream() {
  27.  return new ArrayInputStream();
  28. }
  31. //-----------------------------------------------------------------------------------
  32. // InputStream
  33. //-----------------------------------------------------------------------------------
  35. /**
  36.  * This class is a copy of the java.io.ByteArrayInputStream. only the synchronization has been change to  
  37.  * be synchronized on the outter object
  38.  */
  39. private class ArrayInputStream extends InputStream {
  41.  protected int pos;
  43.  protected int mark = 0;
  44.  protected int count;
  46.  public ArrayInputStream() {
  47.   synchronized (ByteArrayStream.this) {
  48.    this.pos = 0;
  49.    this.count = ByteArrayStream.this.count;
  50.   }
  51.  }
  53.  public int read() {
  54.   synchronized (ByteArrayStream.this) {
  55.    return (pos < count) ? (buf[pos++] & 0xff) : -1;
  56.   }
  57.  }
  59.  public int read(byte b[], int off, int len) {
  60.   synchronized (ByteArrayStream.this) {
  61.    if (b == null) {
  62.     throw new NullPointerException();
  63.    } else if ((off < 0) || (off > b.length) || (len < 0) || ((off + len) > b.length) || ((off + len) < 0)) {
  64.     throw new IndexOutOfBoundsException();
  65.    }
  66.    if (pos >= count) {
  67.     return -1;
  68.    }
  69.    if (pos + len > count) {
  70.     len = count - pos;
  71.    }
  72.    if (len <= 0) {
  73.     return 0;
  74.    }
  75.    System.arraycopy(buf, pos, b, off, len);
  76.    pos += len;
  77.    return len;
  78.   }
  79.  }
  81.  public long skip(long n) {
  82.   synchronized (ByteArrayStream.this) {
  83.    if (pos + n > count) {
  84.     n = count - pos;
  85.    }
  86.    if (n < 0) {
  87.     return 0;
  88.    }
  89.    pos += n;
  90.    return n;
  91.   }
  92.  }
  94.  public int available() {
  95.   synchronized (ByteArrayStream.this) {
  96.    return count - pos;
  97.   }
  98.  }
  100.  public boolean markSupported() {
  101.   return true;
  102.  }
  104.  public void mark(int readAheadLimit) {
  105.   synchronized (ByteArrayStream.this) {
  106.    mark = pos;
  107.   }
  108.  }
  110.  public void reset() {
  111.   synchronized (ByteArrayStream.this) {
  112.    pos = mark;
  113.   }
  114.  }
  116.  public void close() throws IOException {}
  117. }
  118. }


tu créés l'objet, tu écris dedans, et quand tu veux lire ce que tu as écrit, tu récupères un InputStream. Tu peux par la suite continuer à écrire dedans (le inputsream que tu as récupéré ne sera pas affecté) et tu peux re-récupérer un nouveau inputstream ..
 
Le code est fortement inspiré de ByteArrayInputStream et ByteArrayOutputStream du jdk. L'avantage c'est qu'ils se partagent le même tableau de byte => c'est économe au niveau mémoire :)


---------------
ma vie, mon oeuvre - HomePlayer
Reply

Sujets relatifs:

Leave a Replay

Make sure you enter the(*)required information where indicate.HTML code is not allowed