import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.io.BufferedWriter;
import java.io.OutputStreamWriter;
public class ShakingServer{
 public static void main(String[] args) throws IOException {

 //创建服务器套接字实例，设置监听端口为2000
 ServerSocket server=new ServerSocket(2000);
 //开始监听客户端的请求，并阻塞
 Socket socket=server.accept();
 //请求收到后，自动建立连接。通过IO流进行数据传输
 System.out.println("连接建立成功");

 OutputStream os=socket.getOutputStream();
 PrintWriter pw=new PrintWriter(new BufferedWriter(new OutputStreamWriter(os)),true);
 pw.write("欢迎访问摇头耶稣的世界！");
 pw.flush();
  //因为我关闭了输出流，所以另一端的readLine方法才正常结束了
 socket.shutdownOutput();

 InputStream is=socket.getInputStream();
 InputStreamReader isr=new InputStreamReader(is);
 BufferedReader br=new BufferedReader(isr);
 while(true) {
  String str=br.readLine();
  if(str.equals("quit")) {
  break;
  }
  System.out.println("Client said: "+str);
 }
 socket.shutdownInput();
 //socket.shutdownOutput();
 socket.close();
 server.close();
 }
}

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.Socket;

public class ShakingClient{
 public static void main(String[] args) throws IOException{

 //创建客户端的套接字，设置连接的服务器的IP地址和端口号
 Socket socket=new Socket("169.254.132.203",2000);
 //输入流读取服务器发送的信息
 BufferedReader br=new BufferedReader(new InputStreamReader(socket.getInputStream()));
  //开启自动刷新缓冲区
 PrintWriter pw=new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())),true);  
  //从键盘读取数据
 BufferedReader ii=new BufferedReader(new InputStreamReader(System.in));
 System.out.println(br.readLine());
  //因为开启了自动刷新，且调用的是println方法，所以可以不调用flush方法
 pw.println("请求进入摇头耶稣的世界");
 //pw.flush();
 while(true) {
  String str=ii.readLine();
  //使用了回车符来保证另一端的readLine方法正常结束
  pw.write(str+"\r");
  pw.flush();
  //如果输入quit则退出聊天室
  if(str.equals("quit")) {
  break;
  }
 }
 socket.shutdownInput();
 socket.shutdownOutput();
 socket.close();
 }
}