java实现的一对一聊天系统

import java.net.*; import java.io.*; import java.text.SimpleDateFormat; import java.util.*; class GetInforClient implements Runnable { Socket socket; public static boolean ing=true; SimpleDateFormat format=new SimpleDateFormat("[yyyy-MM-dd]HH:mm:ss "); GetInforClient(Socket s)throws IOException { socket=s; } public void run() { try { BufferedReader is=new BufferedReader(new InputStreamReader(socket.getInputStream())); while(ing==true)System.out.println(format.format(new Date())+"Server:"+is.readLine()); is.close(); }catch(IOException e){System.out.println("run error getinfor");} } } class SendInforClient implements Runnable { Socket socket; SimpleDateFormat format=new SimpleDateFormat("[yyyy-MM-dd]HH:mm:ss "); SendInforClient(Socket s)throws IOException { socket=s; } public void run() { try { BufferedReader sin=new BufferedReader(new InputStreamReader(System.in)); PrintWriter os=new PrintWriter(socket.getOutputStream()); String line; line=sin.readLine(); while(!line.equals("bye")) { os.println(line); os.flush(); System.out.println(format.format(new Date())+"Client:"+line); line=sin.readLine(); } GetInforClient.ing=false; os.close(); }catch(IOException e){System.out.println("run error sendinfor");} } } public class ChatClient { public static void main(String[] args) { try { String host="127.0.0.1"; Scanner input=new Scanner(System.in); System.out.println("choose other host? y/n"); char ch=input.next().charAt(0); while(!(ch=='y'||ch=='n')) { ch=input.next().charAt(0); } if(ch=='y') { System.out.println("use ip:"); host=input.next(); } Socket socket=new Socket(host,4700); System.out.println("The server has been successfully connected to start the conversation!"); Runnable getinfor=new GetInforClient(socket); Runnable sendinfor=new SendInforClient(socket); Thread t1=new Thread(getinfor); Thread t2=new Thread(sendinfor); t1.start(); t2.start(); //socket.close(); }catch(IOException e){System.out.println("error");} } }