Socket编程入门：一对一交互

package com.tang.nio.server;

import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;

/**
* 服务器端
* @author tang
* @date 2016-03-30
*/
public class SocketServer {

public static void main(String[] args) throws IOException{
// 创建服务器套接字，监听9999端口
ServerSocket serverSocket = new ServerSocket(9999);
// 接收客户端连接请求，在没有客户端访问之前，一直处于阻塞状态
Socket socket = serverSocket.accept();

System.out.println("接收到客户端连接请求");

// 构造Reader及Writer，分别用于读取客户端消息、向客户端发送消息
BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
PrintWriter printWriter = new PrintWriter(new OutputStreamWriter(socket.getOutputStream()));

while (true) {
// 循环处理消息，接收客户端消息
// 使用readLine需注意，消息应以'\n'结尾，否则网络连接会一直处于阻塞状态
String message = bufferedReader.readLine();
System.out.println("接收到客户端消息：" + message);

if("exit".equals(message)){
// 客户端发出exit消息，表示意图结束连接，此时跳出循环，结束连接
printWriter.write("已断开与服务器端连接\n");
printWriter.flush();
break;
} else {
// 响应客户端消息，以'\n'结尾，方便客户端readLine接收
printWriter.write(message + "\n");
printWriter.flush();
}
}

// 关闭套接字
socket.close();
}

}

package com.tang.nio.client;

import java.io.*;
import java.net.Socket;

/**
* 客户端
* @author tang
* @date 2016-03-30
*/
public class SocketClient {
public static void main(String[] args) throws IOException{
// 创建指向localhost主机9999端口的套接字
Socket socket = new Socket("localhost", 9999);

// 构造Reader及Writer，分别用于读取服务器端消息、向服务器端发送消息
BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
PrintWriter printWriter = new PrintWriter(new OutputStreamWriter(socket.getOutputStream()));

// 构造控制台Reader，获取用户输入的消息
BufferedReader consoleReader = new BufferedReader(new InputStreamReader(System.in));

while (true) {
// 接收用户控制台输入的消息
System.out.print("请输入发送到服务器的消息：");
String line = consoleReader.readLine();

// 将用户输入的消息发送到服务器端，以'\n'结尾
printWriter.write(line + "\n");
printWriter.flush();

// 获取服务器端响应的消息
String message = bufferedReader.readLine();
System.out.println("From Server：" + message);

// 如果发送到服务器端的消息为exit，跳出循环，结束连接
if("exit".equals(line)){
break;
}
}

// 关闭套接字
socket.close();
}
}

上面的代码实现了服务器端和客户端的消息传递及响应。首先启动服务器端，再启动客户端。客户端会提示输入要发送到服务器端的消息，在控制台输入文本后回车，服务器端就会接收到用户在控制台输入的消息，并处理后返回给客户端查看，这样一次客户端/服务器端的通信就完成了。如果客户端输入的消息为exit，那么客户端和服务器端就会断开套接字连接，终止通信。执行结果：





实现这个Demo有一个较为麻烦的问题，就是当Reader调用readLine方法接收读取数据时，因为是网络套接字通信，找不到输入终止符，这个方法总是会处于阻塞状态。解决办法就是在输入的消息后面加上字符'\n'，它就像我们在控制台输入文本后回车一个道理，表示消息到此结束，可以处理了。