欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

Bio、Nio、Aio的用法系列之BIO(一)

程序员文章站 2022-05-23 21:49:49
...

原文:http://101.201.71.142/wordpress/?p=187

BIO属于同步阻塞式IO

服务端

网络编程的基本模型是从Client/Server模型,就是让两个进城之间进行通信,其中服务端提供服务地址跟端口,客户端根据ip,port进行连接

首先我们先进行服务端代码的编写工作:

public class BioServerTest {
    public static void main(String [] args){
        try {
            ServerSocket serverSocket = new ServerSocket(8888);
            while (true){
                Socket socket = serverSocket.accept();
                System.out.println("接受到来自外星的信号>>>");
                new Thread(new BioServerHandle(socket)).start();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

上面我们开始监听8888端口,启动这个main后,肯定阻塞到accept,等待客户端发送过来消息

public class BioServerHandle implements Runnable{
    private Socket socket;

    public BioServerHandle(Socket socket){
        this.socket = socket;
    }

    @Override
    public void run() {
        BufferedReader br = null;
        PrintWriter pw = null;
        try {
            br = new BufferedReader(new InputStreamReader(this.socket.getInputStream()));
            pw = new PrintWriter(new OutputStreamWriter(this.socket.getOutputStream()),true);
            while (true){
                String body = br.readLine();
                if (body == null){
                    break;
                }
                System.out.print("the order is "+body);
                String currentTime = "queryTime".equals(body)? new java.util.Date(System.currentTimeMillis()).toString():"No Query";
                pw.println(currentTime);
            }
        } catch (IOException e) {
            try {
                br.close();
                pw.close();
                socket.close();
            }catch (Exception e1){

            }
        }
    }
}

客户端

我们有了服务端提供的ip跟端口,就可以进行通信了,下面直接贴代码

public class BioClient {
    public static void main(String [] args){
        BufferedReader br = null;
        PrintWriter pw = null;
        try {
            Socket socket = new Socket("127.0.0.1",8888);
            br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            pw = new PrintWriter(socket.getOutputStream(),true);
            pw.println("queryTime");
            System.out.println("发送了一个查询时间的命令过去");
            String result = br.readLine();
            System.out.print(result);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

先启动服务端,进行轮询,阻塞到accept,然后等待客户端的请求

实验结果

服务端结果:
接受到来自外星的信号>>>
the order is queryTime
客户端结果:
发送了一个查询时间的命令过去
Sat Apr 28 10:31:21 CST 2018
相关标签: java BIO IO