public class PipedInputStream extends InputStream
PipedInputStreamใชใใธใงใฏใใใ่ชญใฟ่พผใพใใๅฏพๅฟใใPipedOutputStreamใซๅฅใฎในใฌใใใซใใฃใฆๆธใ่พผใพใใพใใ ๅไธใฎในใฌใใใใไธกๆนใฎใชใใธใงใฏใใไฝฟ็จใใใใจใฏใในใฌใใใใใใใญใใฏใใๅฏ่ฝๆงใใใใใๆจๅฅจใใใฆใใพใใใ ใใคใใง้ฃ็ตใใใๅ
ฅๅในใใชใผใ ใซใฏไธๅฎ็ฏๅฒใฎใใใใกใๅซใพใใใใใ่ชญ่พผใฟๆไฝใจๆธ่พผใฟๆไฝใฏๅ้ขใใใพใใ ๆฅ็ถๆธใฎใใคใใง้ฃ็ตใใใๅบๅในใใชใผใ ใซใใผใฟใปใใคใใๆไพใใฆใใในใฌใใใ็ๅญใใชใใชใฃใๅ ดๅใฏใใใคใใๅฃใใฆใใใจๅผใฐใใพใใ PipedOutputStream| ไฟฎ้ฃพๅญใจๅ | ใใฃใผใซใ | ่ชฌๆ |
|---|---|---|
protected byte[] |
buffer |
ๅ
ฅใฃใฆใใใใผใฟใ็ฝฎใๅพช็ฐใใใใกใงใใ
|
protected int |
in |
ใใผใฟใฎๆฌกใฎใใคใใใใคใใง้ฃ็ตใใใๆฅ็ถๆธใฟใฎๅบๅในใใชใผใ ใใๅใๅใฃใใจใใซใใใฎๆฌกใฎใใคใใๆ ผ็ดใใๅพช็ฐใใใใกใฎใคใณใใใฏในไฝ็ฝฎใงใใ
|
protected int |
out |
ใใคใใง้ฃ็ตใใใใใฎๅ
ฅๅในใใชใผใ ใใใผใฟใฎๆฌกใฎใใคใใ่ชญใฟ่พผใใๅพช็ฐใใใใกใฎใคใณใใใฏในไฝ็ฝฎใงใใ
|
protected static int |
PIPE_SIZE |
ใใคใใฎๅพช็ฐๅ
ฅๅใใใใกใฎใใใฉใซใใปใตใคใบใงใใ
|
| ใณใณในใใฉใฏใฟ | ่ชฌๆ |
|---|---|
PipedInputStream() |
PipedInputStreamใใใพใ ๆฅ็ถใใใชใใใใซไฝๆใใพใใ |
PipedInputStream(int pipeSize) |
PipedInputStreamใใใพใ ๆฅ็ถใใใชใใใใซไฝๆใใพใใใใฎ้ใๆๅฎใใใใใคใใปใตใคใบใใใคใใฎใใใใกใซไฝฟ็จใใพใใ |
PipedInputStream(PipedOutputStream src) |
PipedInputStreamใใใใคใใง้ฃ็ตใใใๅบๅในใใชใผใ srcใซๆฅ็ถใใใใใใซไฝๆใใพใใ |
PipedInputStream(PipedOutputStream src, int pipeSize) |
PipedInputStreamใใใใคใใง้ฃ็ตใใใๅบๅในใใชใผใ srcใซๆฅ็ถใใใใใใซไฝๆใใพใใใใฎ้ใๆๅฎใใใใใคใใปใตใคใบใใใคใใฎใใใใกใซไฝฟ็จใใพใใ |
| ไฟฎ้ฃพๅญใจๅ | ใกใฝใใ | ่ชฌๆ |
|---|---|---|
int |
available() |
ใใญใใฏใใใซๅ
ฅๅในใใชใผใ ใใ่ชญใฟ่พผใใใจใใงใใใใคใๆฐใ่ฟใใพใใ
|
void |
close() |
ใใคใใซใใๅ
ฅๅในใใชใผใ ใ้ใใใใฎในใใชใผใ ใซ้ข้ฃใใใในใฆใฎใทในใใ ใปใชใฝใผในใ่งฃๆพใใพใใ
|
void |
connect(PipedOutputStream src) |
ใใคใใง้ฃ็ตใใใๅ
ฅๅในใใชใผใ ใใใคใใง้ฃ็ตใใใๅบๅในใใชใผใ
srcใซๆฅ็ถใใพใใ |
int |
read() |
ใใคใใง้ฃ็ตใใใๅ
ฅๅในใใชใผใ ใใใใผใฟใฎๆฌกใฎใใคใใ่ชญใฟ่พผใฟใพใใ
|
int |
read(byte[] b, int off, int len) |
ๆๅคง
lenใใคใใฎใใผใฟใใใใฎใใคใใง้ฃ็ตใใใๅ
ฅๅในใใชใผใ ใใใใคใ้
ๅใซ่ชญใฟ่พผใฟใพใใ |
protected void |
receive(int b) |
ใใผใฟใฎใใคใใๅใๅใใพใใ
|
mark, markSupported, read, reset, skipprotected static final int PIPE_SIZE
protected byte[] buffer
protected int in
in<0ใฏใใใใกใ็ฉบใงใใใใจใ็คบใใin==outใฏใใใใกใใใฃใฑใใงใใใใจใ็คบใใพใใprotected int out
public PipedInputStream(PipedOutputStream src) throws IOException
PipedInputStreamใใใใคใใง้ฃ็ตใใใๅบๅในใใชใผใ srcใซๆฅ็ถใใใใใใซไฝๆใใพใใ srcใซๆธใ่พผใพใใใใผใฟใปใใคใใฏใใใฎในใใชใผใ ใใใฎๅ
ฅๅใจใใฆไฝฟใใใใใซใชใใพใใ src - ๆฅ็ถๅ
ใฎในใใชใผใ ใIOException - ๅ
ฅๅบๅใจใฉใผใ็บ็ใใๅ ดๅใpublic PipedInputStream(PipedOutputStream src, int pipeSize) throws IOException
PipedInputStreamใใใใคใใง้ฃ็ตใใใๅบๅในใใชใผใ srcใซๆฅ็ถใใใใใใซไฝๆใใพใใใใฎ้ใๆๅฎใใใใใคใใปใตใคใบใใใคใใฎใใใใกใซไฝฟ็จใใพใใ srcใซๆธใ่พผใพใใใใผใฟใปใใคใใฏใใใฎในใใชใผใ ใใใฎๅ
ฅๅใจใใฆไฝฟใใใใใซใชใใพใใ src - ๆฅ็ถๅ
ใฎในใใชใผใ ใpipeSize - ใใคใใฎใใใใกใฎใตใคใบใIOException - ๅ
ฅๅบๅใจใฉใผใ็บ็ใใๅ ดๅใIllegalArgumentException - pipeSize <= 0ใฎๅ ดๅใpublic PipedInputStream()
public PipedInputStream(int pipeSize)
PipedInputStreamใใใพใ ๆฅ็ถใใใชใใใใซไฝๆใใพใใใใฎ้ใๆๅฎใใใใใคใใปใตใคใบใใใคใใฎใใใใกใซไฝฟ็จใใพใใ ไฝฟ็จๅใซใใใใPipedOutputStreamใซๆฅ็ถใใๅฟ
่ฆใใใใพใใ pipeSize - ใใคใใฎใใใใกใฎใตใคใบใIllegalArgumentException - pipeSize <= 0ใฎๅ ดๅใpublic void connect(PipedOutputStream src) throws IOException
srcใซๆฅ็ถใใพใใ ใใฎใชใใธใงใฏใใๅฅใฎใใคใใง้ฃ็ตใใใๅบๅในใใชใผใ ใซใใงใซๆฅ็ถใใใฆใใๅ ดๅใฏใIOExceptionใในใญใผใใใพใใ
srcใใใคใใซใใๆชๆฅ็ถใฎๅบๅในใใชใผใ ใงใsnkใใใคใใซใใๆชๆฅ็ถใฎๅ
ฅๅในใใชใผใ ใงใใๅ ดๅใ2ใคใฎในใใชใผใ ใฏไปฅไธใฎๅผๅบใใฎใฉใกใใใซใใฃใฆๆฅ็ถใใใพใใ
snk.connect(src)
ใพใใฏ
src.connect(snk)
2ใคใฎๅผๅบใใฏๅใๅนๆใๆใกใพใใ
src - ใใคใใซใใๆฅ็ถๅ
ใฎๅบๅในใใชใผใ ใIOException - ๅ
ฅๅบๅใจใฉใผใ็บ็ใใๅ ดๅใprotected void receive(int b)
throws IOException
b - ๅใๅใใใคใIOException - ใใคใใ brokenใฎ็ถๆ
ใงใใๅ ดๅใunconnectedใฎ็ถๆ
ใงใใๅ ดๅใ้ใใใใฆใใๅ ดๅใใพใใฏๅ
ฅๅบๅใจใฉใผใ็บ็ใใๅ ดๅใpublic int read()
throws IOException
0 - 255ใฎ็ฏๅฒใฎintใจใใฆ่ฟใใใพใใ ๅ
ฅๅใใผใฟใ่ชญใฟ่พผใใใใใซใชใใใในใใชใผใ ใฎ็ตใใใๆคๅบใใใใใใพใใฏไพๅคใ็บ็ใใใพใงใใใฎใกใฝใใใฏใใญใใฏใใใพใใ readใใฏใฉในInputStream-1ใIOException - ใใคใใunconnectedใฎ็ถๆ
ใงใใๅ ดๅใ brokenใฎ็ถๆ
ใงใใๅ ดๅใ้ใใใใฆใใๅ ดๅใใพใใฏๅ
ฅๅบๅใจใฉใผใ็บ็ใใๅ ดๅใpublic int read(byte[] b,
int off,
int len)
throws IOException
lenใใคใใฎใใผใฟใใใใฎใใคใใง้ฃ็ตใใใๅ
ฅๅในใใชใผใ ใใใใคใ้
ๅใซ่ชญใฟ่พผใฟใพใใ ใใผใฟใปในใใชใผใ ใฎ็ตใใใซ้ใใๅ ดๅใใพใใฏlenใใคใใใใคใใฎใใใใกใปใตใคใบใ่ถ
ใใฆใใๅ ดๅใlenใใคใใใๅฐใชใใใผใฟใ่ชญใฟ่พผใพใใพใใ len ใ0ใฎๅ ดๅใ่ชญใฟ่พผใพใใใใคใใฏใชใใ0ใ่ฟใใใพใใใใใงใชใๅ ดๅใๅฐใชใใจใ1ใใคใใฎๅ
ฅๅใๅฉ็จใงใใใใใซใชใใใในใใชใผใ ใฎ็ตใใใซ้ใใใใไพๅคใในใญใผใใใใพใงใกใฝใใใฏใใญใใฏใใพใใ readใใฏใฉในInputStreamb - ใใผใฟใฎ่ชญ่พผใฟๅ
ใฎใใใใกใoff - ่ปข้ๅ
้
ๅbใฎ้ๅงใชใใปใใlen - ่ชญใฟ่พผใพใใๆๅคงใใคใๆฐใ-1ใNullPointerException - bใnullใงใใๅ ดๅใIndexOutOfBoundsException - offใ่ฒ ใฎๅคใฎๅ ดๅใlenใ่ฒ ใฎๅคใฎๅ ดๅใใใใใฏlenใb.length - offใใๅคงใใๅ ดๅIOException - ใใคใใ brokenใฎ็ถๆ
ใงใใๅ ดๅใunconnectedใฎ็ถๆ
ใงใใๅ ดๅใ้ใใใใฆใใๅ ดๅใใพใใฏๅ
ฅๅบๅใจใฉใผใ็บ็ใใๅ ดๅใInputStream.read()public int available()
throws IOException
availableใใฏใฉในInputStreamclose()ใกใฝใใใๅผใณๅบใใใจใซใใ้ใใใใๅ ดๅใใพใใฏใใคใใunconnectedใ brokenใฎ็ถๆ
ใงใใๅ ดๅใฏ0ใIOException - ๅ
ฅๅบๅใจใฉใผใ็บ็ใใๅ ดๅใpublic void close()
throws IOException
closeใใคใณใฟใใงใผในCloseablecloseใใคใณใฟใใงใผในAutoCloseablecloseใใฏใฉในInputStreamIOException - ๅ
ฅๅบๅใจใฉใผใ็บ็ใใๅ ดๅใ ใใฐใพใใฏๆฉ่ฝใ้ไฟก
่ฉณ็ดฐใชAPIใชใใกใฌใณในใใใณ้็บ่
ใใญใฅใกใณใใซใคใใฆใฏใJava SEใฎใใญใฅใกใณใใๅ็
งใใฆใใ ใใใ ใใฎใใญใฅใกใณใใซใฏใๆฆๅฟต็ใชๆฆ่ฆใ็จ่ชใฎๅฎ็พฉใๅ้ฟๆนๆณใๆๅนใชใณใผใไพใชใฉใฎใ้็บ่
ใๅฏพ่ฑกใซใใใใ่ฉณ็ดฐใช่ชฌๆใๅซใพใใฆใใพใใ
Copyright ยฉ 1993, 2025, Oracle and/or its affiliates. All rights reserved. Use is subject to license terms. Documentation Redistribution Policyใๅ็
งใใฆใใ ใใใ