java socket通信实现

package henu.sgl.tcptalk; import java.io.BufferedReader; import java.io.BufferedWriter; import java.io.IOException; import java.io.InputStreamReader; import java.io.OutputStreamWriter; import java.net.Socket; import java.net.UnknownHostException; import java.util.Scanner; public class Client { public static void main(String[] args) { try { @SuppressWarnings("resource") Socket s = new Socket("127.0.0.1",8888); System.out.println("客户端IP:"+s.getLocalAddress()+"端口"+s.getPort()); //构建IO流 BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(s.getOutputStream())); @SuppressWarnings("resource") Scanner scanner = new Scanner(System.in); while(true){ System.out.println("客户端（手动输入）："); bw.write(scanner.nextLine()+"\n"); bw.newLine(); bw.flush(); BufferedReader br = new BufferedReader(new InputStreamReader(s.getInputStream())); //读取服务器返回的消息数据 System.out.println(br.readLine()); } } catch (UnknownHostException e) { System.err.println("服务停止"); } catch (IOException e) { e.printStackTrace(); } } }