public class TCPEchoServer {
    private static final int BUFSIZE = 32;

    /**
         * @param args
    　  */
        public static void main(String[] args) throws IOException {
            // TODO Auto-generated method stub
            // 从控制台获取需要监听的端口号
            if (args.length != 1)
                throw new IllegalArgumentException("Parameter(s):<Port>");
            // 获取端口号
            int servPort = Integer.parseInt(args[0]);
            // 实例化一个ServerSocket对象实例
            ServerSocket servSocket = new ServerSocket(servPort);
            System.out.println(MessageFormat.format("开始启动监听，端口号:{0}", args[0]));

            // 初始接收数据的总字节数
            int recvMsgSize;
            // 接收数据的缓冲区
            byte[] receiveBuf = new byte[BUFSIZE];

            // 循环迭代，监听端口号,处理新的连接请求
            while (true) {
                // 阻塞等待，每接收到一个请求就创建一个新的连接实例
                Socket clntSocket = servSocket.accept();
                // 获取连接的客户端的 SocketAddress
                SocketAddress clientAddress = clntSocket.getRemoteSocketAddress();
                // 打印输出连接客户端地址信息
                System.out.println("Handling client at" + clientAddress);
                // 从客户端接收数据的对象
                InputStream in = clntSocket.getInputStream();
                // 向客户端发送数据的对象
                OutputStream out = clntSocket.getOutputStream();
                // 读取客户端发送的数据后，再发送到客户端
                while ((recvMsgSize = in.read(receiveBuf)) != -1) {
                    out.write(receiveBuf, 0, recvMsgSize);
                }
                // 客户端关闭连接时，关闭连接
                System.out.println(" 客户端关闭连接");
                clntSocket.close();
            }

        }

}

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;
import java.net.SocketException;

public class TCPEchoClient {
    /**
     * @param args
     * @throws IOException
     */
    public static void main(String[] args) throws IOException {
        // TODO Auto-generated method stub
        // 判断从控制台接受的参数是否正确
        if ((args.length < 2) || (args.length > 3))
            throw new IllegalArgumentException("Parameter(s):<Server><Word>[<Port>]]");
        // 获取服务器地址
        String server = args[0];
        // 获取需要发送的信息
        byte[] data = args[1].getBytes();
        // 如果有三个从参数那么就获取发送信息的端口号，默认端口号为8099
        int servPort = (args.length == 3) ? Integer.parseInt(args[2]) : 8099;
        // 根据服务器地址和端口号实例化一个Socket实例
        Socket socket = new Socket(server, servPort);
        System.out.println("Connected to server...sending echo string");
        // 返回此套接字的输入流，即从服务器接受的数据对象
        InputStream in = socket.getInputStream();
        // 返回此套接字的输出流，即向服务器发送的数据对象
        OutputStream out = socket.getOutputStream();
        // 向服务器发送从控制台接收的数据
        out.write(data);
        // 接收数据的计数器，将写入数据的初始偏移量
        int totalBytesRcvd = 0;
        // 初始化接收数据的总字节数
        int bytesRcvd;
        while (totalBytesRcvd < data.length) {
            // 服务器关闭连接，则返回 -1,read方法返回接收数据的总字节数
            if ((bytesRcvd = in.read(data, totalBytesRcvd, data.length - totalBytesRcvd)) == -1)
                throw new SocketException("与服务器的连接已关闭");
            totalBytesRcvd += bytesRcvd;
        }
        // 打印服务器发送来的数据
        System.out.println("Received:" + new String(data));
        // 关闭连接
        socket.close();

    }

}

服务端程序，建立ServerSocket监听客户端Socket的连接请求，并使用Socket获取输入输出流。

public class Server{
      public static void main(String[] args){
              ServerSocket ss = new ServerSocket(3000);
               while(true){
                      Socket s= ss.accept();
                      PrintStream ps= new PrintStream (s.getOutputStream());
                      ps.println("您接收到服务器的消息");
                      ps.close();
                      s.close();
                       }
              }
}

客户端使用socket建立与IP地址、指定端口的连接，并使用Socket获取输入流获取数据。

public static void main(String[] args) throws IOException{
        Socket socket=new Soket("127.0.0.1",30000);
        BufferedRead br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
        String line=br.readLine();
        System.out.println("来自服务器的数据： "+line);
        br.close();
        socket.close();
}