فئة Java.io.PipedInputStream في Java

أنابيب في IO، يوفر رابطًا بين خيطين يعملان في JVM في نفس الوقت. لذلك يتم استخدام الأنابيب كمصدر أو وجهة.  

• يتم أيضًا توصيل PipedInputStream باستخدام PipedOutputStream. لذلك يمكن كتابة البيانات باستخدام PipedOutputStream ويمكن كتابتها باستخدام PipedInputStream. ولكن استخدام كلا الخيطين في نفس الوقت سيؤدي إلى طريق مسدود لسلاسل الرسائل.
• يرسل PipedOutputStream نهاية الأنبوب. تتم كتابة البيانات إلى PipedOutputStream. يقال أن الأنبوب مكسور إذا لم يعد PipedInputStream الذي كان يقرأ البيانات موجودًا.

تصريح:   

public class PipedOutputStream  
 extends OutputStream  

منشئ:   

• بايبيدوتبوتستريم () : ينشئ PipedOutputStream أنه غير متصل.
• PipedOutputStream(PipedOutputStream inStream): يقوم بإنشاء PipedOutputStream 
  متصل بـ PipedInputStream - "inStream".

طُرق: 

الكتابة () : java.io.PipedOutputStream.write (بايت int) يكتب بايتًا محددًا إلى دفق الإخراج عبر الأنابيب. 

بناء الجملة : 

    public void write(int byte)     
  
    Parameters :      
byte : byte to be written  
  
    Return :    void  
    Exception :     
->     IOException :    if in case IO error occurs.

الكتابة (بايت [] المخزن المؤقت إزاحة int maxlen): java.io.PipedOutputStream.write (بايت [] المخزن المؤقت إزاحة int maxlen) يكتب الحد الأقصى من وحدات البايت من البيانات من المخزن المؤقت إلى دفق الإخراج عبر الأنابيب. يتم حظر الطريقة في حالة عدم كتابة أي بايت في الدفق. 

بناء الجملة : 

    public void write(byte[] buffer int offset int maxlen)     
  
    Parameters :      
buffer : data of the buffer  
offset : starting in the destination array - 'buffer'.  
maxlen : maximum length of array to be read  
  
    Return :    void  
    Exception :     
->     IOException :    if in case IO error occurs.

// Java program illustrating the working of PipedInputStream // write(byte[] buffer int offset int maxlen) import java.io.*; public class NewClass {  public static void main(String[] args) throws IOException  {  PipedInputStream geek_input = new PipedInputStream();  PipedOutputStream geek_output = new PipedOutputStream();  // Use of connect() : connecting geek_input with geek_output  geek_input.connect(geek_output);  byte[] buffer = {'J' 'A' 'V' 'A'};  // Use of write(byte[] buffer int offset int maxlen)  geek_output.write(buffer 0 4);  int a = 5;  System.out.print('Use of write(buffer offset maxlen) : ');  while(a>0)  {  System.out.print(' ' + (char) geek_input.read());  a--;  }  } } 

الإخراج: 

Use of write(buffer offset maxlen) : J A V A  

• إغلاق (): java.io.PipedOutputStream.إغلاق () يغلق دفق الإخراج عبر الأنابيب ويحرر الموارد المخصصة. 
  بناء الجملة : 

public void close()  
    Parameters :      
--------------  
    Return :       
void  
    Exception :     
->     IOException :    if in case IO error occurs.  

• الاتصال (وجهة PipedInputStream): java.io.PipedOutputStream.connect (وجهة PipedInputStream يربط دفق الإخراج عبر الأنابيب بتدفق الإدخال عبر الأنابيب "الوجهة" وفي حالة أن "الوجهة" عبارة عن أنابيب مع بعض استثناءات الإدخال والإخراج الأخرى للدفق 
  بناء الجملة : 

public void connect(PipedInputStream destination)  
    Parameters :      
destination : the Piped Input Stream to be connected to  
    Return :       
void  
    Exception :     
->     IOException :    if in case IO error occurs.  

• فلوش () : java.io.PipedOutputStream.flush () يمسح دفق الإخراج. 
  بناء الجملة : 

public void flush()  
    Parameters :      
------------  
    Return :       
void  
    Exception :     
->     IOException :    if in case IO error occurs.  

كود Java يوضح عمل أساليب فئة PipedOutputStream: 

// Java program illustrating the working of PipedInputStream // write() write(byte[] buffer int offset int maxlen) // close() flush() connect() import java.io.*; public class NewClass {  public static void main(String[] args) throws IOException  {  PipedInputStream geek_input = new PipedInputStream();  PipedOutputStream geek_output = new PipedOutputStream();  try  {  // Use of connect() : connecting geek_input with geek_output  geek_input.connect(geek_output);  // Use of write(int byte) :  geek_output.write(71);  geek_output.write(69);  geek_output.write(69);  geek_output.write(75);  geek_output.write(83);  // Use of flush() method :  geek_output.flush();  System.out.println('Use of flush() method : ');  int i = 5;  while(i > 0)  {  System.out.print(' ' + (char) geek_input.read());  i--;  }  // USe of close() method :  System.out.println('nClosing the Output stream');  geek_output.close();  }  catch (IOException except)  {  except.printStackTrace();  }  } } 

الإخراج: 

Use of flush() method :   
 G E E K S  
Closing the Output stream