import java.io.BufferedReader; import java.io.BufferedWriter; import java.io.InputStreamReader; import java.io.OutputStreamWriter; import java.net.Socket; public class Client extends Thread { public void Write() throws Exception { Socket s=new Socket("127.0.0.1",12345); BufferedWriter bw=new BufferedWriter(new OutputStreamWriter(s.getOutputStream())); BufferedReader br=new BufferedReader(new InputStreamReader(System.in)); String message="客户端说:"; while(!(message.equals(""))) { message=br.readLine(); System.out.println("客户端说:"+message); bw.write(message+"\n"); bw.flush(); } bw.close(); s.close(); } public void run() { Socket m=null; BufferedReader dr=null; try { m=new Socket("127.0.0.1",12345); dr=new BufferedReader(new InputStreamReader(m.getInputStream())); String msg="服务器说:"; while(!(msg.equals(""))) { msg=dr.readLine(); System.out.println("服务器说:"+msg); } } catch(Exception e){e.printStackTrace();} finally { try { dr.close(); m.close(); } catch(Exception e){e.printStackTrace();} } } public static void main(String args[])throws Exception { Client c=new Client(); c.start(); c.Write(); } } |