java socket通信

package com.java4all.controller;

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

/**
 * Author: yunqing
 * Date: 2018/9/14
 * Description:
 */
public class BeatServer {

    /**server port*/
    public static Integer PORT = 8113;

    public static void main(String[] args){

        //try with resources to close resources
        try(    //服务端
                ServerSocket serverSocket = new ServerSocket(PORT);
                //侦听到此套接字的连接并接受,此方法将一直阻塞，直到建立连接为止。
                Socket socket = serverSocket.accept();
                //接受客户端发送的信息
                BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
                //向客户端发送返回信息
                PrintWriter writer = new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())),true)
        ){
            System.out.println("服务端在等待......");
            int i = 0;
            while (true){
                //读取客户端数据
                String str = reader.readLine();
                if(str.equals("END")){
                    break;
                }
                System.out.println("客户端第"+(++i)+"次发来信息为："+str);

                //向客户端发送数据
                writer.println("服务器接收到了客户端的消息【"+str+"】"+System.currentTimeMillis());
                writer.flush();
            }
        }catch (Exception ex){
            ex.printStackTrace();
        }
    }
}

package com.java4all.controller;

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

/**
 * Author: yunqing
 * Date: 2018/9/14
 * Description:
 */
public class BeatClient {

    /**server host*/
    private static String LOCALHOST = "127.0.0.1";
    /**server port*/
    private static Integer SERVERPORT = 8113;

    public static void main(String[] args){
        //try with resources to close resources
        try(    //指定服务器地址和端口
                Socket socket = new Socket(LOCALHOST, SERVERPORT);
                //接受服务器发送的返回消息
                BufferedReader reader =
                        new BufferedReader(new InputStreamReader(socket.getInputStream()));
                //向服务器发送消息
                PrintWriter writer =
                        new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())));
            ){
            for (int i = 1; i <= 10; i ++){
                Thread.sleep(3000);
                //像服务器发送请求
                writer.println("这是我请求服务器的第："+i+"次,"+System.currentTimeMillis());
                writer.flush();

                //获取服务器的响应信息
                String str = reader.readLine();
                System.out.println(str);
            }
            writer.println("END");
            writer.flush();
        }catch (Exception ex){
            ex.printStackTrace();
        }
    }
}

服务端在等待......
客户端第1次发来信息为：这是我请求服务器的第：1次,1536911457490
客户端第2次发来信息为：这是我请求服务器的第：2次,1536911460492
客户端第3次发来信息为：这是我请求服务器的第：3次,1536911463494
客户端第4次发来信息为：这是我请求服务器的第：4次,1536911466494
客户端第5次发来信息为：这是我请求服务器的第：5次,1536911469495
客户端第6次发来信息为：这是我请求服务器的第：6次,1536911472497
客户端第7次发来信息为：这是我请求服务器的第：7次,1536911475499
客户端第8次发来信息为：这是我请求服务器的第：8次,1536911478501
客户端第9次发来信息为：这是我请求服务器的第：9次,1536911481501
客户端第10次发来信息为：这是我请求服务器的第：10次,1536911484501

服务器接收到了客户端的消息【这是我请求服务器的第：1次,1536911457490】1536911457490
服务器接收到了客户端的消息【这是我请求服务器的第：2次,1536911460492】1536911460493
服务器接收到了客户端的消息【这是我请求服务器的第：3次,1536911463494】1536911463494
服务器接收到了客户端的消息【这是我请求服务器的第：4次,1536911466494】1536911466494
服务器接收到了客户端的消息【这是我请求服务器的第：5次,1536911469495】1536911469495
服务器接收到了客户端的消息【这是我请求服务器的第：6次,1536911472497】1536911472497
服务器接收到了客户端的消息【这是我请求服务器的第：7次,1536911475499】1536911475499
服务器接收到了客户端的消息【这是我请求服务器的第：8次,1536911478501】1536911478501
服务器接收到了客户端的消息【这是我请求服务器的第：9次,1536911481501】1536911481501
服务器接收到了客户端的消息【这是我请求服务器的第：10次,1536911484501】1536911484501