Java Socket构建阻塞的TCP通信

1.服务器端

1.创建ServerSocket对象，可在构造子中指定监听的端口；

private int port = 8000;
private ServerSocket serverSocket;
……
serverSocket = new ServerSocket(port);

2.服务器端调用ServerSocket对象的accept()方法，该方法一直监听端口，等待客户的连接请求，如 果接收到一个连接请求，accept()方法就会返回一个Socket对象，这个Socket对象与客户端的Socket对象 将形成一条通信线路；

Socket socket = null;
socket = serverSocket.accept(); // 等待客户连接

3.Socket类提供了getInputStream()方法和getOutputStream()方法。

InputStream socketIn = socket.getInputStream();

OutputStream socketOut = socket.getOutputStream();

源代码EchoServer.java

public class EchoServer {
　　 private int port = 8000;
　　 private ServerSocket serverSocket;
　　 public EchoServer() throws IOException {
　　　 serverSocket = new ServerSocket(port);
　　　 System.out.println("Server Start");
　　 }
　　 public String echo(String msg) {
　　　 return "echo:" + msg;
　　 }
　　 private PrintWriter getWriter(Socket socket) throws IOException {
　　　 OutputStream socketOut = socket.getOutputStream();
　　　 return new PrintWriter(socketOut, true);
　　 }
　　 private BufferedReader getReader(Socket socket) throws IOException {
　　　 InputStream socketIn = socket.getInputStream();
　　　 return new BufferedReader(new InputStreamReader(socketIn));
　　 }
　　 public void service() {
　　　 while (true) {
　　　　　 Socket socket = null;
　　　　　 try {
　　　　　　　 socket = serverSocket.accept(); // 等待客户连接
　　　　　　　 System.out.println("New connection accepted "
　　　　　　　　　　 + socket.getInetAddress() + ":" + socket.getPort());
　　　　　　　 BufferedReader br = getReader(socket);
　　　　　　　 PrintWriter pw = getWriter(socket);
　　　　　　　 String msg = null;
　　　　　　　 while ((msg = br.readLine()) != null) {
　　　　　　　　　 System.out.println(msg);
　　　　　　　　　 pw.println(echo(msg));
　　　　　　　　　 if (msg.equals("bye")) // 如果客户发送的消息为“bye”，就结束通信
　　　　　　　　　　 break;
　　　　　　　 }
　　　　　 } catch (IOException e) {
　　　　　　　 e.printStackTrace();
　　　　　 } finally {
　　　　　　　 try {
　　　　　　　　　 if (socket != null)
　　　　　　　　　　 socket.close(); // 断开连接
　　　　　　　 } catch (IOException e) {
　　　　　　　　　 e.printStackTrace();
　　　　　　　 }
　　　　　 }
　　　 }
　　 }
　　 public static void main(String args[]) throws IOException {
　　　 new EchoServer().service();
　　 }
}