Netty学习1-BIO的阻塞分析

发表于   |   分类于   |     |   阅读次数

一、简介

最早学Java的时候，肯定学过ServerSocket、Socket这些类，然后完成所谓客户端与服务端的建立连接，客户端发送消息、服务端接受消息并返回给客户端消息，客户端接受来自服务端的消息。有点绕嘴，因为很多时候在开发中对于Socket使用不太多，对于这些的了解也仅限于此了。

二. 无线程池实现

1.代码

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
package com.sohu.tv.tradition.bio;
import java.io.IOException;
import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;
/**
 * bio服务器测试一：无线程池
 * 
 * @author leifu
 * @Date 2016-5-30
 * @Time 下午9:46:27
 */
public class BioTest {
    private final static int PORT = 10010;
    @SuppressWarnings("resource")
    public static void main(String[] args) throws Exception {
        ServerSocket serverSocket = new ServerSocket(PORT);
        System.out.println("server start");
        while (true) {
            // 获取一个套接字(阻塞)
            Socket socket = serverSocket.accept();
            System.out.println("新来了一个客户端: " + socket.getInetAddress().getHostName());
            // 业务处理
            handler(socket);
        }
    }
    /**
     * 读取数据
     * 
     * @param socket
     */
    private static void handler(Socket socket) {
        try {
            byte[] bytes = new byte[1024];
            InputStream inputStream = socket.getInputStream();
            while (true) {
                // 读取数据(阻塞)
                int read = inputStream.read(bytes);
                if (read != -1) {
                    System.out.println(new String(bytes, 0, read));
                } else {
                    break;
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            try {
                System.out.println("socket关闭");
                socket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}

2. 测试

3. 阻塞点分析

三. 含线程池实现

1.代码

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
@SuppressWarnings("resource")
   public static void main(String[] args) throws Exception {
       ExecutorService executorService = Executors.newFixedThreadPool(100);
       
       ServerSocket serverSocket = new ServerSocket(PORT);
       System.out.println("server start");
       while (true) {
           // 获取一个套接字(阻塞)
           final Socket socket = serverSocket.accept();
           System.out.println("新来了一个客户端: " + socket.getInetAddress().getHostName());
           // 业务处理
           executorService.execute(new Runnable() {
               public void run() {
                   handler(socket);
               }
           });
       }
   }

2.测试

3.阻塞点分析

四、BIO模型分析

1.visual show：

BIO模型

NIO模型

2.直白的语言分析和理解：