基于java BIO实现一个时间查询的demo-摩杜云开发者社区

server = new ServerSocket(port);
System.out.println("The time server is start in port:"+port);
Socket socket = null;
while (true){
    socket = server.accept();
    new Thread(new TimeServerHandler(socket)).start();

}

用ServerSocket类来监听port端口打开服务，然后接收到请求之后，就创建新的线程来处理请求，处理类的核心代码如下

in = new BufferedReader(new InputStreamReader(
         this.socket.getInputStream()));
out = new PrintWriter(this.socket.getOutputStream(),true);
String currentTime = null;
String body = null;
while (true){
    body = in.readLine();
    if (body==null){
        break;
    }
    System.out.println("The time server receive order: " + body);
    currentTime = "QUERY TIME ORDER".equalsIgnoreCase(body)? new java.util.Date(
            System.currentTimeMillis()).toString():"BAO ORDER";
    out.println(currentTime);
}

客户端核心代码

socket = new Socket("127.0.0.1",port);
in = new BufferedReader(new InputStreamReader(
        socket.getInputStream()));
out = new PrintWriter(socket.getOutputStream(),true);
out.println("QUERY TIME ORDER");
System.out.println("Send order 2 server succeed.");
String resp = in.readLine();
System.out.println("Now is : " + resp);

客户端使用socker来创建一个socket连接，绑定端口号和ip地址。
完整代码请看

//
import com.sun.security.ntlm.Server;

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

public class TimeServer {
    public static void main(String[] args) throws IOException{
        /**
         * @Author: chaojilaji
         * @Description:
         * @Date: 16:21 2018/7/21  * @param args laodiao
         */
        int port = 8080;
        if (args !=null && args.length>0){
            try {
                port = Integer.valueOf(args[0]);
            }catch (NumberFormatException e){
//                e.printStackTrace();

            }
        }
        ServerSocket server = null;
        try {
            server = new ServerSocket(port);
            System.out.println("The time server is start in port:"+port);
            Socket socket = null;
            while (true){
                socket = server.accept();
                new Thread(new TimeServerHandler(socket)).start();

            }
        }finally {
            if (server != null){
                System.out.println("The time server close");
                server.close();
                server = null;
            }
        }
    }
}
//
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;

public class TimeServerHandler implements Runnable{
    private Socket socket;
    public TimeServerHandler(Socket socket){
        this.socket = socket;
    }
    @Override
    public void run() {
        BufferedReader in = null;
        PrintWriter out = null;
        try {
            in = new BufferedReader(new InputStreamReader(
               this.socket.getInputStream()));
            out = new PrintWriter(this.socket.getOutputStream(),true);
            String currentTime = null;
            String body = null;
            while (true){
                body = in.readLine();
                if (body==null){
                    break;
                }
                System.out.println("The time server receive order: " + body);
                currentTime = "QUERY TIME ORDER".equalsIgnoreCase(body)? new java.util.Date(
                        System.currentTimeMillis()).toString():"BAO ORDER";
                out.println(currentTime);
            }
        }catch (Exception e){
            if (in!=null){
                try {
                    in.close();
                }catch (IOException el){
                    el.printStackTrace();
                }
            }
            if (out!=null){
                out.close();
                out = null;
            }
            if(this.socket!=null){
                try {
                    this.socket.close();
                }catch (IOException el){
                    el.printStackTrace();
                }
                this.socket = null;
            }
        }
    }
}
//
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;

public class TimeClient {
    public static void main(String[] args){
        int port = 8080;
        if (args!=null && args.length>0){
            try{
                port = Integer.valueOf(args[0]);
            }catch (NumberFormatException el) {
                //
            }
        }
        Socket socket = null;
        BufferedReader in = null;
        PrintWriter out = null;
        try {
            socket = new Socket("127.0.0.1",port);
            in = new BufferedReader(new InputStreamReader(
                    socket.getInputStream()));
            out = new PrintWriter(socket.getOutputStream(),true);
            out.println("QUERY TIME ORDER");
            System.out.println("Send order 2 server succeed.");
            String resp = in.readLine();
            System.out.println("Now is : " + resp);
        }catch (Exception e){

        }finally {
            if (out!=null){
                out.close();
                out = null;
            }
            if (in!=null){
                try {
                    in.close();
                }catch (IOException e){
                    e.printStackTrace();
                }
            }
            if (socket!=null){
                try {
                    socket.close();
                }catch (IOException e){
                    e.printStackTrace();
                }
                socket = null;
            }
        }
    }
}

先运行服务端程序，在执行客户端请求即可看到效果。