IO的read方法返回-1和阻塞的区别

之前一直在疑惑,什么叫阻塞,什么叫结束。潜意识以为这两个都是服务器读到最后 了
一定程度上来讲是的,都是当前内容读到了最后。但是返回-1是当前流到了最后,而阻塞是因为当前流读到了最后没内容了,但是客户端还没有关闭流。
当客户端关闭了输出流的时候,服务器会知道。返回-1。否则等待接下来的数据或者等待关闭.例子如下
服务端

package com.jiaxz.io.test;

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

public class Servers {

    public void test() throws IOException{
        ServerSocket ss = new ServerSocket(8888);
        InputStream is = null;
        try {
            is = ss.accept().getInputStream();
        } catch (IOException e) {
            e.printStackTrace();
        }
        
        byte[] data = new byte[8];
        int length;
        while((length = is.read(data)) != -1){
            String result = new String(data);
            System.out.println(result);
            System.out.println("length:" + length);
        }
        System.out.print("success");
    }
    
    public static void main(String[] args) {
        Servers server = new Servers();
        try {
            server.test();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

}

<br />

客户端

package com.jiaxz.io.test;

import java.io.BufferedOutputStream;
import java.io.IOException;
import java.io.OutputStream;
import java.net.Socket;
import java.net.UnknownHostException;

public class Client {

    public void test() throws UnknownHostException, IOException, InterruptedException{
        String msg = "11";
        byte[] byteMsg = msg.getBytes();

        Socket socket = new Socket("localhost", 8888);
        OutputStream out = socket.getOutputStream();
        BufferedOutputStream bw = new BufferedOutputStream(out);
        for (int i = 0;i<10;i++) {
            bw.write(byteMsg);
            Thread.sleep(2*(2^i));
            bw.flush();
        }
        bw.close();
        for (int i = 0;i<10;i++) {
            bw.write(byteMsg);
            Thread.sleep(2*(2^i));
            bw.flush();
        }
    }
    public static void main(String[] args) {
        Client client = new Client();
        try {
            client.test();
        } catch (UnknownHostException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

}

flush()是什么用的?交由下一章节

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
【社区内容提示】社区部分内容疑似由AI辅助生成,浏览时请结合常识与多方信息审慎甄别。
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

相关阅读更多精彩内容

  • Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具(例如配置管理,服务发现,断路器,智...
    卡卡罗2017阅读 136,483评论 19 139
  • Java Socket编程 对于Java Socket编程而言,有两个概念,一个是ServerSocket,一个是...
    天空下天的月亮阅读 2,123评论 10 41
  • 第一章 Nginx简介 Nginx是什么 没有听过Nginx?那么一定听过它的“同行”Apache吧!Ngi...
    JokerW阅读 32,996评论 24 1,002
  • 26.1 引言 远程登录(Remote Login)是Internet上最广泛的应用之一。我们可以先登录(即注册)...
    张芳涛阅读 4,257评论 0 6
  • 风华绝代,畅享心欢爱。 曼妙腰肢旋舞态,张嘴明皇忘菜。 引来安史挥旗,大唐南北东西。 被赐白稠自缢,香消魂散谁提。
    李缓之阅读 1,007评论 26 69

友情链接更多精彩内容