并行-Guarded Suspension模式

核心思想:    

      Guarded Suspension的意思是暂停保护,该模式的核心思想是仅当服务器准备好时,才提供服务。就是当大量客户请求到来,而我们不能放弃任何一个请求,必须让客户请求排队,由服务器一个一个去处理。


适用场景:

      服务器请求多,但服务器程序不能丢弃任何一个客户的请求。


     Guarded Suspension模式:既可以最大限度的保护服务器在大量用户访问时不挂掉,同时也能一个一个处理用户的请求 ,保证所有客户端请求均不丢失。


实例:

       Request封装客户端请求。RequestQueue表示客户端请求队列(充当中间缓存,存放未处理的请求),由Client端和Server端共同维护。Client端负责不断发起请求,并将请求对象放入队列中。Server端则根据自身状态,在有能力的情况下,从RequestQueue队列中提取请求对象并进行处理。

    


Request类

public class Request {
    private String name;
    public Request(String name){
        this.name = name;
    }
    public String getName(){
        return name;
    }

    public String toString(){
        return "[ Request " + name + " ]";
    }

}

RequestQueue类

public class RequestQueue {
    private LinkedList queue = new LinkedList();

    public synchronized Request getRequest(){
        while(queue.size() == 0){
            try {
                wait(); //等待直到有新的Request加入
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }

        return (Request) queue.remove(); //返回Request队列中的第一个请求
    }

    public synchronized void addRequest(Request request){
        queue.add(request);
        notifyAll();
    }

}

Server端

public class ServerThread extends Thread {
    //请求队列
    private RequestQueue requestQueue;
    public ServerThread(RequestQueue requestQueue,String name){
        super(name);
        this.requestQueue =requestQueue;
    }

    @Override
    public void run() {
        while(true){
            final Request request = requestQueue.getRequest();//得到请求
            try {
                //模拟请求处理耗时
                Thread.sleep(100);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println(Thread.currentThread().getName() + " handles " + request);
        }
    }
}

Client端

public class ClientThread extends Thread {
    private RequestQueue requestQueue;

    public ClientThread(RequestQueue requestQueue,String name){
        super(name);
        this.requestQueue = requestQueue;
    }

    public void run(){
        for(int i =0 ;i< 10 ;i++){
            Request request = new Request("RequestID:" + i +
                    " Thread_Name:" + Thread.currentThread().getName());
            System.out.println(Thread.currentThread().getName() + " requests " + request);

            //提交请求
            requestQueue.addRequest(request);

            try {
                Thread.sleep(10);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println("ClientThread Name is:" + Thread.currentThread().getName());
        }
        System.out.println(Thread.currentThread().getName() + " request end");
    }
    
    public static void main(String[] args){    
        RequestQueue requestQueue = new RequestQueue();

        //服务器开启
        for(int i = 0; i < 10; i++){
            new ServerThread(requestQueue,"ServerThread" +i).start();
        }

        //客户端请求开启
        for(int i = 0; i < 10; i++){
            new ClientThread(requestQueue,"ClientThread" +i).start();
        }
    } 
}

结果:

       


总结:

      从上述输出过程可以看出,客户端请求过快,服务端并没有一下全部处理,而是当Client请求全部运行结束后,Server端并没有停止工作,继续处理RequestQueue中的请求,RequestQueue充当了中间缓存,这样既可以处理客户端请求,也不至于让服务端挂掉。但是又有一个问题,客户端一个个请求,此时不能获取服务器的返回结果,这个留待下一节讨论?




        

版权声明:本文为u013038643原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
本文链接:https://blog.csdn.net/u013038643/article/details/76431450

智能推荐

单链表+单链表代码(链表最基础)

链表 链表是有顺序的表,在内存中存储: 链表是以节点的方式存储的 每个节点包括data域,next域:指向下一个节点 如图:发现链表的各个节点不一定是连续存放的,有跳跃的,不是连续存储 链表分为带头节点的链表和没有头结点的链表 添加: 1.先创建一个head头结点,作用就是单链表的头 2.后面每添加一个节点,就直接加入到链表最后 遍历: 代码 添加节点到链表里: 这里借助于temp节点,通过循环找...

Rtthread学习笔记(十三)RT-Thread Studio开启硬件看门狗Watchdog

一、开启硬件看门狗Watchdog 1、配置RT-Thread Settings 2、开启stm32f1xx_hal_conf.h中的宏定义 3.使用RT接口函数初始化硬件看门狗...

TYVJ 4864 天天去哪吃 || 清北学堂金秋杯大奖赛

题目描述: 记录一下i这个值上次出现的位置在哪里,就是pre...

java反编译

jvm 把Boolean类型的值flag当做int类型处理。​​​ Foo.java: 由 class 文件生成 jasm 文件:java -jar asmtools.jar jdis Foo.class > Foo.jasm  修改jasm文件: 执行反编译: java -jar jd-gui-1.6.6.jar File 打开Foo.class文件:b修改为2 重新执行java...

【学习笔记】03-v-html的学习和示例

v-html的认识和使用 示例: 显示结果: 注意:v-html是有复制的...

猜你喜欢

Java实现在线考试系统(系统介绍)

1.和现在有的考试系统有以下几种优势: a.和现在有的系统比较起来,本系统有科目、章节、老师、学生、班级等信息的管理,还有批阅试卷查看已批阅试卷等。传统的考试系统划分并不细,业务功能简单。 b.和学校的考试系统还有外面的考试系统比较起来,本系统是B/S结构,学校的考试系统一般为C/S结构,性能方面不如B/S结构,并且C/S接口需要安装客户端,客户端压力很大,我的系统只需要电脑具有浏览器,在同一局域...

计算机视觉--多视几何初步尝试

基础矩阵的原理 K和K’分别是两个相机的参数矩阵。p和p’是X在平面π的坐标表示。所以可以得出 具体计算过程 代码: #!/usr/bin/env python coding: utf-8 from PIL import Image from numpy import * from pylab import * import numpy as np from imp ...

java初学者怎么学习才可以快速入门

java初学者怎么学习才可以快速入门 一、了解JAVA 我们要知道:Java是由Sun Microsystems公司于1995年5月推出的Java面向对象程序设计语言。 Java之父:詹姆斯·高斯林 1.1 java的三个体系 Java SE(Java Platform Standard Edition)。Java SE 以前称为 J2SE。它允许开发和部署在桌面、服务器、嵌入式环境...

字段属性之主键&增删改查&自增长&唯一键约束

字段属性之主键&自增长&唯一键约束 主键 主键:primary key 主要的键 一张表中只有一个字段可以使用对应的键,用来唯一的约束该字段里面的数据,不能重复,这种称之为主键 一张表只能最多一个主键 增加主键 SQL操作中有多种方式增加主键大体分为三种 1.在创建表的时候直接在字段之后跟primary key关键字(主键本身不允许为空) 优点:非常直接:缺点:只能使用一个字段作为...

linux下 基于libmad的socket多用户mp3音频在线播放服务器

在众多大神的帮助下,这个在线播放流媒体服务器终于完成啦。。。。 这个mp3流媒体服务器设计的思路是,服务器程序server用多线程实现和多个客户端的通信(这是必然的),然后发送给客户端当前的音频列表公客户端选择,之后根据k客户端的选择给多个客户端传输相应mp3文件的数据,同时,客户端进行实时地音频解码并播放。 关于libmad开源mp3音频解码库的使用,见上一篇博客吧。。。。 在服务器程序这一端,...