java的socket通信

import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.io.PrintWriter; import java.net.ServerSocket; import java.net.Socket; public class Server { // 搭建服务器端 public static void main(String[] args) throws IOException { Server server = new Server(); //创建一个服务器，即Server server.oneServer(); } public void oneServer() { try { ServerSocket server = null; server = new ServerSocket(5209); System.out.println("服务器启动成功"); System.out.println("等待客户端连接"); // 指定绑定的端口，并监听此端口。 Socket socket = server.accept(); System.out.println("监听到客户端的连接"); System.out.println("连接成功"); //调用accept()方法开始监听端口，等待客户端的连接 String line; //存储对方传过来的数据 BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream())); // 从socket对象中取出对方传过来的数据 PrintWriter writer=new PrintWriter(socket.getOutputStream()); // 向socket总写如要传给对方的数据 while ((line = in.readLine()) != null) { writer.println(line+" deal by servet"); // 向客户端输出该字符串 writer.flush(); // 刷新输出流，使Client马上收到该字符串 System.out.println("Client:" + line); // 从Client读入一字符串，并打印到标准输出上 } // 继续循环 // 关闭资源 writer.close(); //关闭Socket输出流 in.close(); // 关闭Socket输入流 socket.close(); // 关闭Socket server.close(); // 关闭server } catch (Exception e) {// 出错，打印出错信息 System.out.println("Error." + e); } } }