美文网首页
让我们的socket服务支持多线程http访问,模拟webser

让我们的socket服务支持多线程http访问,模拟webser

作者: 在路上phper | 来源:发表于2018-01-30 17:29 被阅读171次

    首先简单回顾一下上节课的内容


    image.png

    通过浏览器访问我们自己做的socket服务 初步触摸了http协议 通过在浏览器中访问地址 可以刷新出访问的页面
    原理是通过http协议截取请求头里面的地址 然后用程序检查相应目录下是否有此文件 如果有 就返回出来
    下面我们看下代码
    在我们的ServerClient里面 循环监听 一旦连接关闭也没关系 还会继续监听 但是却是单线程处理


    image.png
    因此我们访问localhost:9000 和localhost:9000/abc.html
    是要按照顺序访问的 必须一个运行完之后才能运行另外一个

    接下来代码演示一下为什么是单线程的
    为了演示代码 我们新建了一个Requester1.java文件 做了一些异常处理(在Requester基础上修改的)


    image.png
    这里做了异常处理
    在我们的ServerClient中写入测试代码
    image.png
    运行结果
    image.png
    我们输入localhost:9000时候 无论如何刷新线程都不会卡顿
    image.png
    我们输入localhost:9000/abc.html时候 会看见线程卡顿了 一直在转圈
    如果这时在6s内刷新localhost:9000 也会出现卡顿
    如下
    image.png

    是因为abc.html文件还没执行完 不能运行默认的index文件 所以说是单线程处理的
    接下来还有一个问题
    我们在代码里面写入了循环监听 也就是说这个线程是一直卡在这循环监听的 如果这个线程处理一些复杂的业务 那么该线程会占用大量的内存 如果不结束该线程 会出现资源无法释放
    接下来我们处理上面的两个问题
    1.加入多线程处理
    2.取消循环监听线程
    首先我们在Http包下面创建一个HttpThread线程


    image.png
    代码如下
    image.png
    前面学习过如何运行线程
    下面修改一下ServerClient代码
    image.png
    运行一下ServerClient
    image.png
    可以发现正在监听
    这时我们浏览器输入localhost:9000/abc.html(这个是延时6s的)
    image.png
    可以发现线程卡住6s
    然后6s内运行localhost:9000(默认的index.html)
    image.png
    可以看见我们的index.html是可以运行的 说明二者可以同时运行
    然后6s过后再次运行index.html
    出现如下
    image.png
    是因为我们的线程已经结束了
    接下来考虑如何解决这个问题
    需要涉及到一些新的工具包
    image.png
    首先我们看下TimeUnit
    image.png
    可以看见存在java.util.concurrent包下面
    接下来我们把延时6s代码改下
    image.png

    接下来看下concurrent工具包下面的一些核心类


    image.png
    下面我们用代码实现下
    先演示下创建单线程
    image.png
    浏览器输入localhost:9000
    运行结果
    image.png
    这时在运行localhost:9000/abc.html
    image.png
    可以发现运行不了 因为我们创建的是个单线程 当执行完默认首页的线程 整个线程就关闭了
    下面我们把单线程改为多线程
    ServerClient中修改代码如下
    image.png
    表示开启两个线程并执行
    运行结果
    先运行localhost:9000/abc.html 页面卡顿6s
    同时运行localhost:9000 可以发现页面直接运行了
    6s结束后abc.html运行结束 线程关闭了
    再次刷新页面 发现页面不能运行了 因为我们线程已经关闭了
    下面我们解决下循环监听的问题
    可以通过在写一个线程来解决 这个线程专门用于检查活跃线程数是否在我们的可控范围内(可以设置一个最小线程数)
    接下来创建一个HttpCheck类 也是个线程 专门用于检查线程数的 小于两个就创建一个 始终保持线程数为2
    在这个类中获取当前线程的活跃数 所以写个构造函数 将ServerClient类中的executorService传过来
    代码如下
    image.png
    image.png
    在ServerClient中
    image.png
    运行结果
    image.png
    浏览器中输入localhost:9000
    image.png
    控制台结果
    image.png
    浏览器输入localhost:9000/abc.html
    image.png
    同时再刷新index页面
    image.png
    可以同时运行
    接着刷新同样可以运行 所以简单的解决了循环监听的问题
    从运行结果可以看出 线程有卡顿的情况 因为有5s时间检查 检查过程中线程结束了的话如果线程不够了,需要等待5s创建新线程
    所以一般webserver中的最小线程数如果设置过小会出现线程卡顿的情况(因为需要等待时间去创建新的线程) 同时线程数也不能设置过大 否则会无缘无故创建很多的线程监听
    image.png
    这时为了避免我们可以为线程设置最大请求书
    HttpThread代码
    image.png
    再次运行
    image.png
    浏览器输入localhost:9000
    image.png
    浏览器输入localhost:9000/abc.html
    image.png
    在不断刷新两个页面
    可以发现两个页面都可以访问
    控制台结果如下
    image.png
    这是因为我们为每个线程设置了最大请求数 请求10次才将线程关闭

    相关文章

      网友评论

          本文标题:让我们的socket服务支持多线程http访问,模拟webser

          本文链接:https://www.haomeiwen.com/subject/avuczxtx.html