Java中利用Socket实现客户端聊天程序

public class Server {

public static void main（String[] args） {

try {

ServerSocket server = new ServerSocket（9999）；

Helper.println（"Server started, waiting for message."）；

Socket client = server.accept（）；

PrintWriter pw = null;

while （true） {

BufferedReader br = new BufferedReader（new InputStreamReader（

client.getInputStream（）））；

String content = br.readLine（）；

if （content.equals（"end"）） {

server.close（）；

br.close（）；

if （pw != null） {

pw.close（）；

}

break;

}

Helper.println（content）；

Helper.print（"Server:"）；

pw = new PrintWriter（client.getOutputStream（）， true）；

BufferedReader in = new BufferedReader（new InputStreamReader（System.in））；

String output = "Server : " + in.readLine（）；

pw.println（output）；

pw.flush（）；

}

Helper.println（"Client left! Server Closed."）；

} catch （IOException e） {

// TODO Auto-generated catch block

e.printStackTrace（）；

}

}

}
　

public class Client {

public static void main（String[] args） {

try {

Socket client = new Socket（"127.0.0.1", 9999）；

PrintWriter pw = null;

InputStreamReader isr = null;

Helper.println（"Client started, ready to write content."）；

String input = "";

while （true） {

Helper.print（"Client : "）；

InputStream is = System.in;

input = new BufferedReader（new InputStreamReader（is））

.readLine（）；

pw = new PrintWriter（client.getOutputStream（）， true）；

pw.println（"Client:" + input）；

if （input.equals（"end"）） {

client.close（）；

is.close（）；

pw.close（）；

if （isr != null） {

isr.close（）；

}

break;

}

isr = new InputStreamReader（client.getInputStream（））；

Helper.println（new BufferedReader（isr）。readLine（））；

}

Helper.println（"Client stopped!"）；

} catch （IOException e） {

// TODO Auto-generated catch block

e.printStackTrace（）；

}

}

}