Классы Java для работы с потоками

       

Socket s; InputStream is; OutputStream



Листинг 4

. Файл SocketClient.java
import java.io.*; import java.net.*; import java.util.*;
public class SocketClient { public static void main(String args[]) { byte bKbdInput[] = new byte[256]; Socket s; InputStream is; OutputStream os;
try { System.out.println( "Socket Client Application" + "\nEnter any string or" + " 'quit' to exit...");
} catch(Exception ioe) { System.out.println(ioe.toString());
}
try { s = new Socket("localhost",9999);
is = s.getInputStream();
os = s.getOutputStream();
byte buf[] = new byte[512]; int length; String str;
while(true) { length = System.in.read(bKbdInput);
if(length != 1) { str = new String(bKbdInput, 0);

StringTokenizer st; st = new StringTokenizer( str, "\r\n");
str = new String( (String)st.nextElement());

System.out.println(">
" + str);

os.write(bKbdInput, 0, length);
os.flush();

length = is.read(buf);
if(length == -1) break;
str = new String(buf, 0);
st = new StringTokenizer( str, "\r\n");
str = new String( (String)st.nextElement());
System.out.println(">
>
" + str);

if(str.equals("quit")) break; } } is.close();
os.close();
s.close();
} catch(Exception ioe) { System.out.println(ioe.toString());
}
try { System.out.println( "Press <Enter>
to " + "terminate application...");
System.in.read(bKbdInput);
} catch(Exception ioe) { System.out.println(ioe.toString());
} } }

Содержание раздела