package com.codingdict;

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

  public class MyServer {

      public static void main(String[] args) {

          try {

              // 初始化服务端socket连接，并监听8888端口的socket请求
              ServerSocket serverSocket = new ServerSocket(8888);

              System.out.println("****** I am Server, now begin to wait the client ******");

              int count = 0;

              // 处理socket请求
              Socket socket = null;
              while (true) {

                  socket = serverSocket.accept();
                  ServerThread serverThread = new ServerThread(socket);
                  System.out.println("client host address is: " + socket.getInetAddress().getHostAddress());
                  serverThread.start();
                  count++;
                  System.out.println("now client count is: " + count);

              }
          } catch (IOException e) {
              e.printStackTrace();
          }
      }
  }

package com.codingdict;

  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.Socket;

  public class ServerThread extends Thread {
      private Socket socket;
      public ServerThread(Socket socket) {
          this.socket = socket;
      }

      @Override
      public void run() {

          InputStream inputStream = null;
          InputStreamReader inputStreamReader = null;
          BufferedReader bufferedReader = null;
          OutputStream outputStream = null;
          PrintWriter printWriter = null;

          try {

              // server接收消息
              inputStream = socket.getInputStream();
              inputStreamReader = new InputStreamReader(inputStream);
              bufferedReader = new BufferedReader(inputStreamReader);

              String str;
              if ((str = bufferedReader.readLine()) != null) {
                  System.out.println("I am Server, now get message from Client: " + str);
              }
              socket.shutdownInput();

              // server发送消息
              outputStream = socket.getOutputStream();
              printWriter = new PrintWriter(outputStream);
              printWriter.write("[welcome to you!]");
              printWriter.flush();

          } catch (IOException e) {
              e.printStackTrace();
          } finally {
              // 关闭资源
              try {
                  if (printWriter != null) {
                      printWriter.close();
                  }
                  if (outputStream != null) {
                      outputStream.close();

                  }
                  if (bufferedReader != null) {
                      bufferedReader.close();
                  }
                  if (inputStreamReader != null) {
                      inputStreamReader.close();
                  }
                  if (inputStream != null) {
                      inputStream.close();
                  }
                  if (socket != null) {
                      socket.close();
                  }
              } catch (IOException e) {
                  e.printStackTrace();
              }
          }
      }
  }