多语言展示
当前在线:120今日阅读:165今日分享:48

Java 网络编程之OIO

java的iO主要包含三种。OIO(同步阻塞)、NIO(同步非阻塞)、AIO(异步非阻塞)。OIO与NIO之间的最大的区别是,OIO是面向流的,而NIO是面向缓冲区的。OIO面向流意味着每次从流中读一个或多个字节,直至读取所有字节,它们没有被缓存在任何地方。此外,它不能前后移动流中的数据。如果需要前后移动从流中读取的数据,需要先将它缓存到一个缓冲区。 Java NIO的缓冲导向方法略有不同。数据读取到一个它稍后处理的缓冲区,需要时可在缓冲区中前后移动。这就增加了处理过程中的灵活性。但是,还需要检查是否该缓冲区中包含所有您需要处理的数据。而且,需确保当更多的数据读入缓冲区时,不要覆盖缓冲区里尚未处理的数据。
工具/原料
1

window 10

2

telnet

3

JDK 1.6+

方法/步骤
1

用OIO实现一个简单客户端。具体代码如下:package com.zhshl.nio; import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import java.io.PrintWriter; import java.net.ServerSocket; import java.net.Socket; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; /**  * zhshl  2018/10/5  */ public class OIOServer {     public static void main(String[] args) throws IOException {         ServerSocket serverSocket = new ServerSocket(10010);         ExecutorService executorService = Executors.newCachedThreadPool();         System.out.println('服务器启动成功');         while(true){             //获取一个套字节(阻塞)             final Socket socket = serverSocket.accept();             System.out.println('来了一个新的客户端');             executorService.execute(new Runnable() {                 public void run() {                     handler(socket);                 }             });         }     }     /**      * 读取数据      * @param socket      */     public static void handler(Socket socket) {         try {             byte[] bytes = new byte[1024];             InputStream inputStream = socket.getInputStream();             OutputStream outputStream = socket.getOutputStream();             PrintWriter printWriter = new PrintWriter(outputStream);             while(true){                 //读取数据(阻塞)                 int read = inputStream.read(bytes);                 if(read != -1){                     System.out.println(new String(bytes, 0, read,'GBK'));                     printWriter.print('你好:'+socket.getInetAddress()+',' +                             '你刚刚发送的消息我已经接收到了。发送的内容为:' + new String(bytes, 0, read,'GBK'));                     printWriter.flush();                 }else{                     break;                 }             }         } catch (Exception e) {             e.printStackTrace();         }finally{             try {                 System.out.println('socket关闭');                 socket.close();             } catch (IOException e) {                 e.printStackTrace();             }         }     } }

2

一、测试,此处采用telnet 来进行测试1、 window + R键,调出如下图的对话框

3

2、 输入cmd打开,点击确定。在CMD中输入telnet 127.0.0.1 10010 后按下回车键。然后按ctrl + ] 键,出现如下界面

4

未能成功连接,请检测telnet 是否已经开启开启方法:确保下图所示的Telnet 客户端已经开启

5

发送消息在telnet输入 send  hello

6

在服务端的控制台看到有hello 打印出来。

注意事项

测试前记得先启动服务端 OIO的阻塞点有: 1、 serverSocket.accept(); 2、 inputStream.read(bytes);

推荐信息