package com.socket; import java.io.BufferedReader; import java.io.InputStreamReader; import java.io.PrintWriter; import java.net.Socket; public class SocketClient { public static void main(String[] args) { try { // 1ãå建客æ·ç«¯Socketï¼æå®æå¡å¨å°ååç«¯å£ // Socket socket=new Socket("127.0.0.1",5200); Socket socket = new Socket("127.0.0.1", 8080); System.out.println("客æ·ç«¯å¯å¨æå"); // 2ãè·åè¾åºæµï¼åæå¡å¨ç«¯åéä¿¡æ¯ // 忬æºç52000端å£ååºå®¢æ·è¯·æ± BufferedReader br = new BufferedReader(new InputStreamReader(System.in)); // ç±ç³»ç»æ åè¾å ¥è®¾å¤æé BufferedReader对象 PrintWriter write = new PrintWriter(socket.getOutputStream()); // ç±Socket对象å¾å°è¾åºæµï¼å¹¶æé PrintWriter对象 //3ãè·åè¾å ¥æµï¼å¹¶è¯»åæå¡å¨ç«¯çååºä¿¡æ¯ BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream())); // ç±Socket对象å¾å°è¾å ¥æµï¼å¹¶æé ç¸åºçBufferedReader对象 String readline; readline = br.readLine(); // ä»ç³»ç»æ åè¾å ¥è¯»å ¥ä¸å符串 while (!readline.equals("end")) { // è¥ä»æ åè¾å ¥è¯»å ¥çå符串为 "end"ååæ¢å¾ªç¯ write.println(readline); // å°ä»ç³»ç»æ åè¾å ¥è¯»å ¥çå符串è¾åºå°Server write.flush(); // å·æ°è¾åºæµï¼ä½¿Server马䏿¶å°è¯¥å符串 System.out.println("Client:" + readline); // å¨ç³»ç»æ åè¾åºä¸æå°è¯»å ¥çå符串 System.out.println("Server:" + in.readLine()); // ä»Serverè¯»å ¥ä¸å符串ï¼å¹¶æå°å°æ åè¾åºä¸ readline = br.readLine(); // ä»ç³»ç»æ åè¾å ¥è¯»å ¥ä¸å符串 } // ç»§ç»å¾ªç¯ //4ãå ³éèµæº write.close(); // å ³éSocketè¾åºæµ in.close(); // å ³éSocketè¾å ¥æµ socket.close(); // å ³éSocket } catch (Exception e) { System.out.println("can not listen to:" + e);// åºéï¼æå°åºéä¿¡æ¯ } } }