1 import java.net.*; 2 import java.io.*; 3 import java.util.concurrent.ExecutionException; 4
5 public class TcpClient { 6 public static void main(String[] args) throws Exception{ 7 try{ 8 //建立套接字
9 Socket socket = null; 10 socket = new Socket(); 11 socket.connect(new InetSocketAddress("服务端ip",7327),8000); 12 //建立连接
13 InputStreamReader Sysin = new InputStreamReader(System.in); 14 BufferedReader SysBuf = new BufferedReader(Sysin); 15
16 InputStreamReader Socin = new InputStreamReader(socket.getInputStream()); 17 BufferedReader SocBuf = new BufferedReader(Socin); 18
19 PrintWriter Socout = new PrintWriter(socket.getOutputStream()); 20
21 //进行通信
22 String readline = SysBuf.readLine(); 23 while(!readline.equals("bye")){ 24 Socout.println(readline); 25 Socout.flush(); 26 //System.out.println("Client:"+readline);
27
28 System.out.println("Server:"+SocBuf.readLine()); 29 readline = SysBuf.readLine(); 30 } 31
32 //关闭IO和Socket
33 Socout.close(); 34 Socin.close(); 35 socket.close(); 36 } catch (Exception e){ 37 System.out.println("Error:"+e); 38 } 39 } 40 }