阻塞通信
Java中经常会使用Scoket套接字来实现网通信,
举个栗子:
import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;public class testSocket {public static void main(String[] args) throws IOException {final int DEFAULT_PORT = 8080;ServerSocket serverSocket = null;serverSocket = new ServerSocket(DEFAULT_PORT);System.out.println("启动服务,监听端口:" + DEFAULT_PORT);while (true) {Socket socket = serverSocket.accept();System.out.println("客户端:" + socket.getPort() + "已连接");new Thread(new Runnable() {Socket socket;public Runnable setSocket(Socket s){this.socket=s;return this;}@Overridepublic void run() {try {BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(socket.getInputStream()));String clientStr = null; //读取一行信息clientStr = bufferedReader.readLine();System.out.println("客户端发了一段消息:" + clientStr);BufferedWriter bufferedWriter = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));bufferedWriter.write("我已经收到你的消息了");bufferedWriter.flush(); //清空缓冲区触发消息发送} catch (IOException e) {e.printStackTrace();}}}.setSocket(socket)).start();}}
}
上面这个实例就是BIO模型,也就是阻塞通信模型,它会等待客户端建立连接,并且等待客户端的数据传输
阻塞的本质
阻塞是指进程在等待某个事件发生之前的等待状态,它是属于操作系统层面的调度,我们通过下面操作来追踪Java程序中有多少程序,每一个线程对内核产生了哪些操作。
strace,Linux操作系统中的指令
-
把ServerSocketExample.java,去掉package导入头,拷贝到linux服务器的 /data/app目录下。
-
使用javac ServerSocketExample.java进行编译,得到.class文件
-
使用下面这个命令来追踪(打开一个新窗口)
按照strace官网的描述, strace是一个可用于诊断、调试和教学的Linux用户空间跟踪器。我们用它来监控用户空间进程和内核的交互,比如系统调用、信号传递、进程状态变更等。
strace -ff -o out java ServerSocketExample
-
-f 跟踪目标进程,以及目标进程创建的所有子进程
-
-o 把strace的输出单独写到指定的文件
-
-
上述指令执行完成后,会在/data/app目录下得到很多out.*的文件,每个文件代表一个线程。因为Java本身是多线程的。
[root@localhost app]# ll
total 748
-rw-r--r--. 1 root root 14808 Aug 23 12:51 out.33320 //最小的表示主线程
-rw-r--r--. 1 root root 186893 Aug 23 12:51 out.33321
-rw-r--r--. 1 root root 961 Aug 23 12:51 out.33322
-rw-r--r--. 1 root root 917 Aug 23 12:51 out.33323
-rw-r--r--. 1 root root 833 Aug 23 12:51 out.33324
-rw-r--r--. 1 root root 819 Aug 23 12:51 out.33325
-rw-r--r--. 1 root root 23627 Aug 23 12:53 out.33326
-rw-r--r--. 1 root root 1326 Aug 23 12:51 out.33327
-rw-r--r--. 1 root root 1144 Aug 23 12:51 out.33328
-rw-r--r--. 1 root root 1270 Aug 23 12:51 out.33329
-rw-r--r--. 1 root root 8136 Aug 23 12:53 out.33330
-rw-r--r--. 1 root root 8158 Aug 23 12:53 out.33331
-rw-r--r--. 1 root root 6966 Aug 23 12:53 out.33332
-rw-r--r--. 1 root root 1040 Aug 23 12:51 out.33333
5.打开out.33321这个文件(主线程后面的一个文件),shift+g到该文件的尾部,可以看到如下内容。
下面这些方法,都是属于系统调用,也就是调用操作系统提供的内核指令触发相关的操作。
# 创建socket fd
socket(AF_INET6, SOCK_STREAM, IPPROTO_IP) = 5
....
# 绑定8888端口
bind(5, {sa_family=AF_INET6, sin6_port=htons(8888), inet_pton(AF_INET6, "::", &sin6_addr), sin6_flowinfo=0, sin6_scope_id=0}, 28) = 0
# 创建一个socket并监听申请的连接, 5表示sockfd,50表示等待队列的最大长度
listen(5, 50) = 0
mprotect(0x7f21d00df000, 4096, PROT_READ|PROT_WRITE) = 0
write(1, "\345\220\257\345\212\250\346\234\215\345\212\241\357\274\214\347\233\221\345\220\254\347\253\257\345\217\243\357\274\23288"..., 34) = 34
write(1, "\n", 1) = 1
lseek(3, 58916778, SEEK_SET) = 58916778
read(3, "PK\3\4\n\0\0\10\0\0U\23\213O\336\274\205\24X8\0\0X8\0\0\25\0\0\0", 30) = 30
lseek(3, 58916829, SEEK_SET) = 58916829
read(3, "\312\376\272\276\0\0\0004\1\367\n\0\6\1\37\t\0\237\1 \t\0\237\1!\t\0\237\1\"\t\0"..., 14424) = 14424
# poll, 把当前的文件指针挂到等待队列,文件指针指的是fd=5,简单来说就是让当前进程阻塞,直到有事件触发唤醒
* events: 表示请求事件,POLLIN(普通或优先级带数据可读)、POLLERR,发生错误。
poll([{fd=5, events=POLLIN|POLLERR}], 1, -1
从这个代码中可以看到,Socket的accept方法最终是调用系统的poll函数来实现线程阻塞的。
通过在linux服务器输入 man 2 poll
man: 帮助手册
2:表示系统调用相关的函数
DESCRIPTIONpoll() performs a similar task to select(2): it waits for one of a set of filedescriptors to become ready to perform I/O.
poll类似于select函数,它可以等待一组文件描述符中的IO就绪事件
6.通过下面命令访问socket server。
telnet 192.168.221.128 8888
这个时候通过tail -f out.33321这个文件,发现被阻塞的poll()方法,被POLLIN事件唤醒了,表示监听到了一次连接。
poll([{fd=5, events=POLLIN|POLLERR}], 1, -1) = 1 ([{fd=5, revents=POLLIN}])
accept(5, {sa_family=AF_INET6, sin6_port=htons(53778), inet_pton(AF_INET6, "::ffff