BIO初探究

本文主要是介绍BIO初探究，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

文章目录

前言
一、阻塞式 IO 到底阻塞在哪？
二、多个客户端连接
- 多个客户端，我们服务端代码应该怎么样修改呢？
总结

前言

提示：这里可以添加本文要记录的大概内容：

做了一年多物联网，数采这块也接触了不少，但在网络IO 方面使用一直都是网上找找代码，每次自己实现简单 BIO 服务或client 都存在这样那样的问题，做此篇记录一下；

提示：以下是本篇文章正文内容，下面案例可供参考

一、阻塞式 IO 到底阻塞在哪？

一提到 BIO ，第一反应是阻塞式 IO, 性能不好，各种低效率，但是在 tomcat 7 之前的不都是阻塞式IO 吗？那么多应用不也跑的好好的；话不多说，看下面示例；

现在需要开发一个 BIO 服务器，用来和多个客户端收发消息；代码如下


import java.io.IOException;
import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Date;public class TestServer {public static void main(String[] args) throws IOException {ServerSocket server = new ServerSocket(9090);System.out.println("开启server等待连接");while (true) {// todo 查看是否阻塞Socket accept = server.accept();// todo 查看流是否阻塞InputStream inputStream = accept.getInputStream();byte[] content = new byte[26];int len = 0;/*int len = inputStream.read(content);System.out.println("len: " + len + " rev: " + new String(content));*/while ((len = inputStream.read(content)) != -1) {System.out.println("result:" + len);Date date = new Date();System.out.println(date.toLocaleString() + " rev:" + new String(content));content = new byte[26];}}}
}

客户端

private static void connectServer(String message) {Socket socket;try {//socket = new Socket("127.0.0.1", 4545);socket = new Socket("127.0.0.1", 9090);System.out.println("connect server success");PrintWriter pw = new PrintWriter(socket.getOutputStream());for (int i = 0; i < 2; i++) {pw.write(message);//pw.write("\n");pw.flush();System.out.println("发送" + message + "成功");Thread.currentThread().sleep(1000);}//pw.close();} catch (IOException e) {throw new RuntimeException(e);} catch (InterruptedException e) {throw new RuntimeException(e);}}

执行输出发送的message 信息；

二、多个客户端连接

多个客户端，我们服务端代码应该怎么样修改呢？

网上的代码，一搜多个客户端连接是不是立马就想着把上图服务端的代码写到一个thread 里边去？

服务端代码

// 修改前
InputStream inputStream = accept.getInputStream();
byte[] content = new byte[26];
int len = 0;while ((len = inputStream.read(content)) != -1) {System.out.println("result:" + len);Date date = new Date();System.out.println(date.toLocaleString() + " rev:" + new String(content));content = new byte[26];
}// 修改后
new thread(() -> {InputStream inputStream = accept.getInputStream();byte[] content = new byte[26];int len = 0;while ((len = inputStream.read(content)) != -1) {System.out.println("result:" + len);Date date = new Date();System.out.println(date.toLocaleString() + " rev:" + new String(content));content = new byte[26];}
}).start();

客户端端代码

import java.io.IOException;
import java.io.PrintWriter;
import java.net.Socket;
import java.util.ArrayList;
import java.util.List;public class TestClient {public static void main(String[] args) throws IOException {List<Thread> list = new ArrayList();for (int i = 0; i < 10; i++) {int finalI = i;Thread thread = new Thread(() ->connectServer("hello server,I M client " + finalI));list.add(thread);}for (Thread thread : list) {thread.start();}System.in.read();}private static void connectServer(String message) {Socket socket;try {socket = new Socket("127.0.0.1", 9090);System.out.println("connect server success");PrintWriter pw = new PrintWriter(socket.getOutputStream());for (int i = 0; i < 2; i++) {pw.write(message);//pw.write("\n");pw.flush();System.out.println("发送" + message + "成功");Thread.currentThread().sleep(1000);}pw.close();} catch (IOException e) {throw new RuntimeException(e);} catch (InterruptedException e) {throw new RuntimeException(e);}}
}