import java.net.*; import java.io.*; /* Protocol : Client ----------- Server * * <--------- <path> (single line) * (single line) <cmd> ----------> * <--------- <output> (several lines) * <--------- ==end== (single line) * * another session started again * * <--------- <path> (single line) * ..... */ public class Telnet { static int port = 23; static final String endMsg = "==end=="; public static void main(String[] args) throws Exception { if (args[0].equals("server")) runServer(); else if (args[0].equals("client")) runClient(args[1], port); else System.out.println("Client : java Telnet client ip\r\n"+ "Server : java Telnet server"); } public static void runClient(String host, int port) throws Exception { System.out.println("Host " + host + "; port " + port); Socket socket = new Socket(host, port); new CommandClient(socket).start(); System.out.println("Connected OK"); } public static void runServer() throws Exception { ServerSocket server = new ServerSocket(port); // 建立ServerSocket物件 while (true) { // 建立客戶端Socket物件 Socket socket = server.accept(); System.out.println("Accept Connection From : " + socket.getInetAddress()); new CommandServer(socket).start(); } } } class Command { ProcessBuilder pb; Command() { pb = new ProcessBuilder(); pb.directory(new File(".")); } public String exec(String command) throws Exception { String outMsg = "", errMsg = ""; if (command.startsWith("cd ")) { String path = command.substring(3); if (path.equals("\\")) { String tPath = getPath(); String rootPath = tPath.substring(0,3); File root = new File(rootPath); pb.directory(root); } else { try { File dir = new File(pb.directory(), path); pb.directory(dir); } catch (Exception e) { errMsg = "Error: "+e.toString(); } } } else { String[] cmd = { "cmd.exe", "/C", command }; pb.command(cmd); Process process = pb.start(); // 取得命令執行的結果串流結果傳回給 Client. // 請注意 process.getInputStream() 取得的是 command 的輸出串流， // 被重導到輸入串流以利讀取的結果 (這在概念上很怪，但確實如此) outMsg = readAll(process.getInputStream()); // 取得命令執行的錯誤串流結果傳回給 Client. errMsg = readAll(process.getErrorStream()); process.waitFor(); // 等待命令執行完畢 } return outMsg+errMsg; } public String getPath() throws Exception { return pb.directory().getCanonicalPath(); } public String readAll(InputStream is) throws Exception { StringBuffer rzText = new StringBuffer(); BufferedReader in = new BufferedReader(new InputStreamReader(is)); String line; while ((line = in.readLine()) != null) { rzText.append(line+"\r\n"); } return rzText.toString(); } } class CommandServer extends Thread { Socket socket; BufferedReader in; PrintStream out; Command command; public CommandServer(Socket s) throws Exception { socket = s; in = new BufferedReader(new InputStreamReader(socket.getInputStream())); out = new PrintStream(socket.getOutputStream()); command = new Command(); } public void run() { try { while (true) { out.println(command.getPath()); // set path to client out.flush(); String cmd = in.readLine(); // read command from client System.out.println(socket.getInetAddress()+" $ "+cmd); String rzMsg = command.exec(cmd); // execute command out.print(rzMsg); out.println(Telnet.endMsg); // 輸出結束訊息 out.flush(); } } catch (Exception e) { e.printStackTrace(); } } } class CommandClient extends Thread { Socket socket; BufferedReader in, stdin; PrintStream out; public CommandClient(Socket s) throws Exception { socket = s; in = new BufferedReader(new InputStreamReader(socket.getInputStream())); out = new PrintStream(socket.getOutputStream()); stdin = new BufferedReader(new InputStreamReader(System.in)); } public void run() { try { System.out.println("Accept from : " + socket.getInetAddress()); while (true) { String path = in.readLine(); // read path from server System.out.print(socket.getInetAddress()+" $ "+path+">"); String cmd = stdin.readLine(); // read command from console out.println(cmd); // send command to server while (true) { // read output of command from server String line = in.readLine(); if (line.equals(Telnet.endMsg)) break; System.out.println(line); } } } catch (Exception e) { e.printStackTrace(); } } }

import java.io.*; import java.net.*; import java.util.*; public class UrlDownload { // 主程式: 用法 java <url> <file> <proxy?> <port?>, 範例： java http://tw.yahoo.com/ yahoo.htm public static void main(String[] args) throws Exception { URL url = new URL(args[0]); // 建立URL物件 if (args.length == 4) setProxy(args[2], args[3]); // 開啟串流 DataInputStream in = new DataInputStream(url.openStream()); RandomAccessFile out = new RandomAccessFile(args[1], "rw"); try { System.out.println("開始下載檔案: " + args[1]); byte data; // 複製檔案 while(true) { data = (byte)in.readByte(); out.writeByte(data); } } catch(EOFException e) { } System.out.println("檔案下載成功......"); in.close(); // 關閉串流 out.close(); } public static void setProxy(String pProxy, String pPort) { Properties systemSettings = System.getProperties(); systemSettings.put("proxySet", "true"); systemSettings.put("proxyHost", pProxy); systemSettings.put("proxyPort", pPort); System.setProperties(systemSettings); } }

import java.net.*; import java.io.*; // 1. 本程式必須與 TcpClient.java 程式搭配執行，先執行本程式再執行 UdpClient。 // 2. 執行方法 : java TcpServer public class TcpServer { public static int port = 20; // 連接埠 public static void main(String args[]) throws Exception { ServerSocket ss = new ServerSocket(port); // 建立 TCP 伺服器。 while (true) { // 不斷的接收處理輸入訊息。 Socket sc = ss.accept(); // 接收輸入訊息。 OutputStream os = sc.getOutputStream(); // 取得輸出串流。 os.write("From Server : Hi !".getBytes("UTF-8"));// 送訊息到 Client 端。 os.close(); // 關閉輸出串流。 sc.close(); // 關閉 TCP 伺服器。 } } }

import java.net.*; import java.io.*; // 1. 本程式必須與 TcpServer.java 程式搭配執行，先執行 TcpServer 再執行本程式。 // 2. 本程式必須有一個參數，指定伺服器的 IP。 // 用法範例： java TcpClient 127.0.0.1 public class TcpClient { public static int port = 20; // 設定傳送埠為 20。 public static void main(String args[]) throws Exception { Socket client = new Socket(args[0], port); // 根據 args[0] 的 TCP Socket. InputStream in = client.getInputStream(); // 取得輸入訊息的串流 StringBuffer buf = new StringBuffer(); // 建立讀取字串。 try { while (true) { // 不斷讀取。 int x = in.read(); // 讀取一個 byte。(read 傳回 -1 代表串流結束) if (x==-1) break; // x = -1 代表串流結束，讀取完畢，用 break 跳開。 byte b = (byte) x; // 將 x 轉為 byte，放入變數 b. buf.append((char) b);// 假設傳送ASCII字元都是 ASCII。 } } catch (Exception e) { in.close(); // 關閉輸入串流。 } System.out.println(buf); // 印出接收到的訊息。 client.close(); // 關閉 TcpSocket. } }

import java.io.*; import java.net.*; // 1. 本程式必須與 UdpClient.java 程式搭配執行，先執行本程式再執行 UdpClient。 // 2. 執行方法 : java UdpServer public class UdpServer { int port; // 連接埠 public static void main(String args[]) throws Exception { UdpServer server = new UdpServer(5555); // 建立 UdpServer 伺服器物件。 server.run(); // 執行該伺服器。 } public UdpServer(int pPort) { port = pPort; // 設定連接埠。 } public void run() throws Exception { final int SIZE = 8192; // 設定最大的訊息大小為 8192. byte buffer[] = new byte[SIZE]; // 設定訊息暫存區 for (int count = 0; ; count++) { DatagramPacket packet = new DatagramPacket(buffer, buffer.length); DatagramSocket socket = new DatagramSocket(port); // 設定接收的 UDP Socket. socket.receive(packet); // 接收封包。 String msg = new String(buffer, 0, packet.getLength()); // 將接收訊息轉換為字串。 System.out.println(count+" : receive = "+msg); // 印出接收到的訊息。 socket.close(); // 關閉 UDP Socket. } } }

import java.io.*; import java.net.*; // 1. 本程式必須與 UdpServer.java 程式搭配執行，先執行 UdpServer 再執行本程式。 // 2. 本程式必須有一個參數，指定伺服器的 IP。 // 用法範例： java UdpClient 127.0.0.1 public class UdpClient extends Thread { int port; // port : 連接埠 InetAddress server; // InetAddress 是 IP, 此處的 server 指的是伺服器 IP String msg; // 欲傳送的訊息，每個 UdpClient 只能傳送一個訊息。 public static void main(String args[]) throws Exception { for (int i=0; i<100; i++) { // 建立 UdpClient，設定傳送對象與傳送訊息。 UdpClient client = new UdpClient(args[0], 5555, "UdpClient : "+i+"th message"); client.run(); // 啟動 UdpClient 開始傳送。 } } public UdpClient(String pServer, int pPort, String pMsg) throws Exception { port = pPort; // 設定連接埠 server = InetAddress.getByName(pServer); // 將伺服器網址轉換為 IP。 msg = pMsg; // 設定傳送訊息。 } public void run() { try { byte buffer[] = msg.getBytes(); // 將訊息字串 msg 轉換為位元串。 // 封裝該位元串成為封包 DatagramPacket，同時指定傳送對象。 DatagramPacket packet = new DatagramPacket(buffer, buffer.length, server, port); DatagramSocket socket = new DatagramSocket(); // 建立傳送的 UDP Socket。 socket.send(packet); // 傳送 socket.close(); // 關閉 UDP socket. } catch (Exception e) { e.printStackTrace(); } // 若有錯誤產生，列印函數呼叫堆疊。 } }

import java.io.*; import java.net.*; public class UrlParse { public static void main(String[] args) { try { URL url = new URL(args[0]); System.out.println("主機: " + url.getHost()); System.out.println("埠號: " + url.getPort()); System.out.println("協定: " + url.getProtocol()); System.out.println("檔案: " + url.getFile()); System.out.println("參數: " + url.getQuery()); System.out.println("引用: " + url.getRef()); } catch (Exception e) { e.printStackTrace(); } } }

import java.io.*; import java.net.*; public class IP { public static void main(String[] args) { String site = args[0]; try { InetAddress host = InetAddress.getByName(site); System.out.println("網域名稱: " + host.getHostName()); System.out.println("IP位址: " + host.getHostAddress()); System.out.println("本機名稱: " + InetAddress.getLocalHost()); } catch(Exception e) { System.out.println("IP 查詢錯誤!") ; } } }