/**
 * Socket服务端
 * 功能说明：
 * 
 */
public class Server {
 /**
   * 入口
   * 
   * @param args
   * @throws IOException
   */
 public static void main(String[] args) throws IOException {
  // 为了简单起见，所有的异常信息都往外抛
  int port = 8899;
  // 定义一个ServiceSocket监听在端口8899上
  ServerSocket server = new ServerSocket(port);
  System.out.println("等待与客户端建立连接...");
  while (true) {
   // server尝试接收其他Socket的连接请求，server的accept方法是阻塞式的
   Socket socket = server.accept();
   /**
       * 我们的服务端处理客户端的连接请求是同步进行的， 每次接收到来自客户端的连接请求后，
       * 都要先跟当前的客户端通信完之后才能再处理下一个连接请求。 这在并发比较多的情况下会严重影响程序的性能，
       * 为此，我们可以把它改为如下这种异步处理与客户端通信的方式
       */
   // 每接收到一个Socket就建立一个新的线程来处理它
   new Thread(new Task(socket)).start();
  }
  // server.close();
 }
 /**
   * 处理Socket请求的线程类
   */
 static class Task implements Runnable {
  private Socket socket;
  /**
     * 构造函数
     */
  public Task(Socket socket) {
   this.socket = socket;
  }
  @Override
      public void run() {
   try {
    handlerSocket();
   }
   catch (Exception e) {
    e.printStackTrace();
   }
  }
  /**
     * 跟客户端Socket进行通信
     * 
     * @throws IOException
     */
  private void handlerSocket() throws Exception {
   // 跟客户端建立好连接之后，我们就可以获取socket的InputStream，并从中读取客户端发过来的信息了
   /**
       * 在从Socket的InputStream中接收数据时，像上面那样一点点的读就太复杂了，
       * 有时候我们就会换成使用BufferedReader来一次读一行
       * 
       * BufferedReader的readLine方法是一次读一行的，这个方法是阻塞的，直到它读到了一行数据为止程序才会继续往下执行，
       * 那么readLine什么时候才会读到一行呢？直到程序遇到了换行符或者是对应流的结束符readLine方法才会认为读到了一行，
       * 才会结束其阻塞，让程序继续往下执行。
       * 所以我们在使用BufferedReader的readLine读取数据的时候一定要记得在对应的输出流里面一定要写入换行符（
       * 流结束之后会自动标记为结束，readLine可以识别），写入换行符之后一定记得如果输出流不是马上关闭的情况下记得flush一下，
       * 这样数据才会真正的从缓冲区里面写入。
       */
   BufferedReader br = new BufferedReader(
             new InputStreamReader(socket.getInputStream(), "UTF-8"));
   StringBuilder sb = new StringBuilder();
   String temp;
   int index;
   while ((temp = br.readLine()) != null) {
    if ((index = temp.indexOf("eof")) != -1) {
     // 遇到eof时就结束接收
     sb.append(temp.substring(0, index));
     break;
    }
    sb.append(temp);
   }
   System.out.println("Form Cliect[port:" + socket.getPort()
             + "] 消息内容:" + sb.toString());
   // 回应一下客户端
   Writer writer = new OutputStreamWriter(socket.getOutputStream(),
             "UTF-8");
   writer.write(String.format("Hi,%d.天朗气清，惠风和畅！", socket.getPort()));
   writer.flush();
   writer.close();
   System.out.println(
             "To Cliect[port:" + socket.getPort() + "] 回复客户端的消息发送成功");
   br.close();
   socket.close();
  }
 }
}

import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.Reader;
import java.io.Writer;
import java.net.Socket;
/** * Socket客户端
* 功能说明： * * @author 大智若愚的小懂 * @Date 2016年8月30日 * @version 1.0 */
public class Client {
 /** * 入口 * @param args */
 public static void main(String[] args) {
  // 开启三个客户端，一个线程代表一个客户端 
  for (int i = 0; i < 3; i++) {
   new Thread(new Runnable() {
    @Override public void run() {
     try {
      TestClient client = TestClientFactory.createClient();
      client.send(String.format("Hello,Server!I'm %d.这周末天气如何。", client.client.getLocalPort()));
      client.receive();
     }
     catch (Exception e) {
      e.printStackTrace();
     }
    }
   }
   ).start();
  }
 }
 /** * 生产测试客户端的工厂 */
 static class TestClientFactory {
  public static TestClient createClient() throws Exception {
   return new TestClient("127.0.0.1", 8899);
  }
 }
 /** * 测试客户端 */
 static class TestClient {
  /** * 构造函数 * @param host 要连接的服务端IP地址 * @param port 要连接的服务端对应的监听端口 * @throws Exception */
  public TestClient(String host, int port) throws Exception {
   // 与服务端建立连接 
   this.client = new Socket(host, port);
   System.out.println("Cliect[port:" + client.getLocalPort() + "] 与服务端建立连接...");
  }
  private Socket client;
  private Writer writer;
  /** * 发送消息 * @param msg * @throws Exception */
  public void send(String msg) throws Exception {
   // 建立连接后就可以往服务端写数据了 
   if(writer == null) {
    writer = new OutputStreamWriter(client.getOutputStream(), "UTF-8");
   }
   writer.write(msg);
   writer.write("eof\n");
   writer.flush();
   // 写完后要记得flush 
   System.out.println("Cliect[port:" + client.getLocalPort() + "] 消息发送成功");
  }
  /** * 接收消息 * @throws Exception */
  public void receive() throws Exception {
   // 写完以后进行读操作 
   Reader reader = new InputStreamReader(client.getInputStream(), "UTF-8");
   // 设置接收数据超时间为10秒 
   client.setSoTimeout(10*1000);
   char[] chars = new char[64];
   int len;
   StringBuilder sb = new StringBuilder();
   while ((len = reader.read(chars)) != -1) {
    sb.append(new String(chars, 0, len));
   }
   System.out.println("Cliect[port:" + client.getLocalPort() + "] 消息收到了，内容:" + sb.toString());
   reader.close();
   // 关闭连接 
   writer.close();
   client.close();
  }
 }
}