?? sockconnectortest.java
字號:
// ============================================================================//// = PACKAGE// tests.SOCK_SAP// // = FILENAME// SOCKConnectorTest.java//// = AUTHOR// Prashant Jain// // ============================================================================package JACE.tests.SOCK_SAP;import java.io.*;import java.net.*;import JACE.OS.*;import JACE.SOCK_SAP.*;public class SOCKConnectorTest{ static void print_usage_and_die () { System.out.println ("Usage: SOCKConnectorTest <hostname> [<port>]"); System.exit (0); } void processRequests (SOCKStream stream) throws IOException { // 1.0 JDK DataInputStream in = new DataInputStream (System.in); BufferedReader in = new BufferedReader(new InputStreamReader(System.in)); String msg; int ack_len; while (true) { StringBuffer ack = new StringBuffer (); ACE.DEBUG ("Enter input: "); ACE.FLUSH (); msg = in.readLine (); if (msg == null) break; stream.send (msg); ACE.DEBUG ("Waiting for ack..."); ack_len = stream.recv (ack); if (ack_len == 0) break; else ACE.DEBUG (ack.toString ()); } } public void init (String host, int port) { SOCKStream stream = new SOCKStream (); SOCKConnector connector = new SOCKConnector (); try { connector.connect (stream, host, port); processRequests (stream); } catch (IOException e) { ACE.ERROR (e); } } public static void main (String [] args) { ACE.enableDebugging (); int port = ACE.DEFAULT_SERVER_PORT; SOCKConnectorTest client = new SOCKConnectorTest (); // check arg count if (args.length == 0 || args.length > 2) print_usage_and_die(); if (args.length == 2) { try { port = Integer.parseInt (args[1]); } catch (NumberFormatException e) { client.print_usage_and_die (); } } client.init (args[0], port); }}
?? 快捷鍵說明
復制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -