• 在下宝龙、
    2022-01-24
    老师我想问一下 按照老师你的图，select不是也阻塞了线程么，应用线程也不能做其他的事情，难道应用线程和select的线程不是同一个吗

    作者回复: io多路复用顾名思义，一个线程可以处理多个socket，只要有一个socket上可读或可写，线程就会忙碌起来。当然如果所有socket都不可读，也不可写，那么该线程的确是处理阻塞状态。但这和一个线程仅能处理一个socket，还阻塞在该socket的读/写上相比，是有质的飞跃的。

    
    5
  • bearlu
    2022-01-24
    老师，有没有netpoller的相关实现资料参考？

    作者回复: 我最初是看了这篇文章 https://morsmachine.dk/netpoller ，之后自己read source code的。只有自己读代码，结果才深刻。

    
    5
  • 撕影
    2022-11-30 来自辽宁
    由于go的GPM模型存在，实现多路复用简直就是降维打击。只挂起G而不挂起M，在G的视角里就是个阻塞模型而已，妙啊

    作者回复: 👍

    
    4
  • Aeins
    2022-06-06
    读完，好多细节还抓不住 1. go 中的 Socket 是操作系统 socket 的封装。go 通过 netpoller 模拟了阻塞式的I/O，运行时还是使用的I/O多路复用(不同操作系统提供了不同的系统调用，epoll等) 连接复用的情况 0. 读写都有锁保护 1. 多 goroutine 并发读，如何正确的指定度多少数据呢，给少了，会读不全，被其他 goroutine 读走，给多了，会读取不属于自己的数据吧。 2. 多 goroutine 并发写，如果一次写入一个完整的”业务包“，一般能保证单个业务包的完整 ，如果写超时，会有部分写入问题吗？ 一次写入一个业务包，TCP会从面向数据流，退化到面向业务包码？ 读的一端，为了区分不同goroutine(共用连接，数据不共享)的数据，要采取特殊的读取方式吗，需要以包为单位读取？

    作者回复: 这里仅是介绍了并发下网络I/O的可能存在的极端情况。实际设计中，尽量避免对一个socket的并发读和并发写。

    
    3
  • bearlu
    2022-01-24
    谢谢老师。我跟上了。还特意买了你新出的Go语言精进之路1，2，打算过年继续精进。

    作者回复: 👍。

    共 3 条评论
    3
  • Mew151
    2022-10-10 来自辽宁
    本节课的代码参见：https://github.com/dgqypl/tcpprogramming

    作者回复: 👍

    共 2 条评论
    2
  • 江楠大盗
    2022-07-06
    老师，有个地方想不清楚，请教一下。现在都是长连接复用一个tcp连接，这时服务端读取一个请求的部分数据后异常了，还有一部分数据未读取，这时下一个请求过来了，服务端应该怎么处理上一个请求遗留的那部分数据？因为tcp层面是没有业务语义的，怎么区分这部分数据要不要丢弃。

    作者回复: tcp仅是传输层协议。如何识别应用层协议包的是应用层协议来规定的。 像你提到的，如果某个应用层请求包存在数据异常，如果异常会导致后续所有请求均处理失败，那么意味着这个连接存在的意义不大了，断连是最好的选择。后续的请求由于没有得到服务端的应答，所以client端应该选择重发。 如果数据异常的请求对后续新请求没有太大影响，服务端可以选择将请求的剩余数据读取后，回复特定的失败应答。然后继续读取和处理后续的新请求。

    
    2
  • lesserror
    2022-02-17
    以前没接触过socket编程，只是经常看到这个知识点。感谢Tony Bai老师的细致讲解。有几点疑惑，烦请老师解答。 1. 我们的输入，是一个基于传输层自定义的应用层协议规范。 这里的输入该怎么理解呢？ 2. 在阻塞 I/O 模型下，并等所有数据就绪后，将数据从内核空间拷贝到用户空间，最后系统调用从内核空间返回。为什么不是用户空间返回呢？ 3. 文中的非阻塞 I/O 模型架构图中的：EAGAIN/EWOULDBLOCK 这几个英文单词是什么意思，没查出来。

    作者回复: 很高兴又看到lesserror回来学习了！ 我来说说你提出的问题。 1. 输入：指的是我们要实现的tcp服务器的输入，就是服务器要接收的数据。这些数据符合某种应用层协议的规范。 2. 系统调用后，线程便进入内核空间执行了，即进入内核态。在内核态的系统调用代码将获得的数据从内核层的缓存中copy到用户层的内存中，执行结束后，从内核态返回用户态。用户便可以在用户层的内存中看到已经返回的数据了。可以参考一下《深入理解计算机系统3rd》这本书对计算机整体做了一个全面深入了解。 3. EAGAIN/EWOULDBLOCK 是两个系统级的错误。E是前缀，以EAGAIN为例，即Error Again，即告知调用者重试。

    
    2
  • Calvin
    2022-01-26
    老师，文章中“I/O 多路复用框架”的举例中： 1、libev 的链接点击没反应（是 http://software.schmorp.de/pkg/libev.html 这个链接吗？）； 2、libuv 的链接对应的 github 仓库貌似已经迁移到 https://github.com/libuv/libuv 了。

    作者回复: 1. 是的，文中链接好像多了一个空格，导致无效了。 2. 确实。感谢提醒。我让编辑老师改一下。

    共 2 条评论
    2
  • 罗杰
    2022-01-24
    并发往 socket 中写数据时，需要一次 write 操作完整的写入一个“业务包”，这实现有点难呀，万一只成功写入一部分，这可不能回滚呀。

    作者回复: 你的业务场景中有并发写一个conn的情况么？

    共 3 条评论
    2