Server

package com.huawei.socketstudy;

import java.net.ServerSocket;

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

public class Server
{
    static BufferedReader socketReader = null;
    static PrintWriter socketWriter = null;

    public static void main(String[] args) throws Exception
    {
        //创建服务器
        ServerSocket server = new ServerSocket(30000, 5);
        Socket socket = null;

        //接受客户端连接
        System.out.println("等待客户端连接...");
        socket = server.accept();
        System.out.println("来自: " + socket.getInetAddress().getHostAddress() +
                           "地址的客户端已经连接");

        //获取输入输出
        socketReader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
        socketWriter = new PrintWriter(socket.getOutputStream());

        //启动服务器线程，接收客户端发来的数据并原样返回
        ServerThread serverThread = new ServerThread();
        serverThread.start();

        server.close();
    }

    static class ServerThread extends Thread
    {
        public void run()
        {
            while (true)
            {
                try
                {
                    String words = socketReader.readLine();
                    System.out.println("有数据接收到：" + words);
                    socketWriter.write(words + "\r\n");
                    socketWriter.flush(); // send the data in buffer immediately
                }
                catch (Exception e)
                {
                    e.printStackTrace();
                    return;
                }
            }
        }
    }

}