黑马程序员-JAVA-银行业务调度系统

2024-01-02 19:08
文章标签 java 系统 程序员 黑马 调度 银行业务

本文主要是介绍黑马程序员-JAVA-银行业务调度系统，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

——Java培训、Android培训、iOS培训、.Net培训、期待与您交流！ ——-

引

传智播客中有一个面试题目项目就是这个银行业务调度系统，今天也来实现一把。

需求分析

  1. 这家银行有6个业务窗口，其中4个是普通窗口，1个快速窗口，1个VIP窗口，银行的客户比例为普通：快速：VIP=6：3：1，各个类型用户安排到对应窗口，快速和VIP窗口在空闲时也可以服务普通用户，用户业务办理时间是随机的，有最小值，但快速用户永远是最小值。模拟无需GUI，通过log显示结果
  2. 假定最小业务办理时间为30秒，最大600秒
  3. 快速和VIP窗口仅在普通窗口全忙时才接收普通用户
  4. 用户通过取号器来排队,窗口就绪后由号码排队系统分配客户

第一轮设计

  1. 通过一个模拟执行程序执行，执行程序 生成一个银行（6个窗口），一个用户模拟（取号），为了方便，采用100倍速模拟。
  2. 业务窗口有3种类型，行为上并无不同，仅仅标记的用户偏向不同，采用一个enum业务类型来标识。
  3. 用户有明确的业务目的，也就视为：有特定的业务办理时间（假定银行窗口业务员素质相同），有特定的业务类型（普通/快速/VIP），进入银行就有自己的排队号码（未进入设定为-1）。
  4. 业务类型有最小和最大办理时间，普通和VIP为（30，600），快速为（30，30）
  5. 银行取号系统负责给用户分配排队号码，并给空闲的窗口分配客户。

第二轮设计

  1. 窗口应该知道当前服务的客户，窗口应该属于银行，窗口应该有准备就绪开始，计划停止（服务完当前客户）的方法，以通知取号系统。
  2. 取号系统应该在没有排队用户时阻塞，取号系统应该为每个窗口尽快分配用户，按：用户采用3个阻塞队列，快速/VIP窗口轮询特有队列和普通队列。普通窗口直接阻塞取普通队列

实现

代码如下：
业务类型

/*** 银行业务分类* @author lz**/
public enum BusinessType {/*** 普通业务 耗时30秒到10分钟*/Normal(30,600),/*** 快速业务 耗时30秒*/Quick(30,30),/*** VIP业务 耗时30秒到10分钟 */VIP(30,600);/*** 最小和最大耗时*/public int minTime,maxTime;private BusinessType(int minTime, int maxTime) {this.minTime = minTime;this.maxTime = maxTime;}
}

客户


/*** 银行客户* @author lz**/
public class BankUser {/*** 来办业务的类型*/public final BusinessType biz;/*** 业务耗时*/public final int bizTime;/*** 排队号码*/public String queueNum;@Overridepublic String toString() {return "BankUser [biz=" + biz + ", bizTime=" + bizTime + ", queueNum="+ queueNum + "]";}public String shortInfo() {return queueNum+"("+bizTime+")";}public BankUser(BusinessType biz, int bizTime) {super();this.biz = biz;this.bizTime = bizTime;}/*** 进入银行排队* @param bank 银行*/public void enQueue(Bank bank){this.queueNum=bank.offerNum(this);Logger.getLogger("BankQueue").info("新客户："+this);}
}

银行，包括窗口和调度系统


import java.time.Instant;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.TimeUnit;
import java.util.logging.Logger;import static cc.sisel.util.Quic.*;/*** 银行抽象，包括窗口和业务调度系统 默认构造包含6个窗口 其中一个VIP一个快速，其他普通* * @author lz**/
public class Bank implements Runnable {final BankUserHandler banksys;List<BusinessWindow> servWindows;public Bank(BankUserHandler banksys, List<BusinessWindow> servWindows) {super();this.banksys = banksys;this.servWindows = servWindows;}public Bank() {super();this.banksys = new BankUserHandler();this.servWindows = new ArrayList<Bank.BusinessWindow>(6);this.servWindows.add(new BusinessWindow(BusinessType.VIP));this.servWindows.add(new BusinessWindow(BusinessType.Quick));this.servWindows.add(new BusinessWindow(BusinessType.Normal));this.servWindows.add(new BusinessWindow(BusinessType.Normal));this.servWindows.add(new BusinessWindow(BusinessType.Normal));this.servWindows.add(new BusinessWindow(BusinessType.Normal));}@Overridepublic void run() {ExecutorService exes = Executors.newFixedThreadPool(servWindows.size());for (BusinessWindow businessWindow : servWindows) {exes.execute(businessWindow);businessWindow.readyToService();}// 演示用，控制台输出客户状态Executors.newSingleThreadScheduledExecutor().scheduleAtFixedRate((() -> sp("等待客户：" + this.banksys.watingSum() + " 今日客户总数："+ this.banksys.cameUserSum())), 1, 5, TimeUnit.SECONDS);}/*** 取号* * @param bankUser*            取号的用户* @return 号码条*/public String offerNum(BankUser bankUser) {return this.banksys.accept(bankUser);}/*** 业务调度系统 负责分派客户到窗口 并监视银行中等待客户的队列 记录今日来访的客户计数 生成号码条* * @author lz**//*** @author lz**/public class BankUserHandler {BlockingQueue<BankUser> normalQueue = new LinkedBlockingQueue<BankUser>(),quickQueue = new LinkedBlockingQueue<BankUser>(),vipQueue = new LinkedBlockingQueue<BankUser>();private int vipn = 0, quickn = 0, normaln = 0;public int watingSum() {return this.normalQueue.size() + this.quickQueue.size()+ this.vipQueue.size();}public int cameUserSum() {return this.normaln + this.quickn + this.vipn;}/*** 生成号码条* * @param bankUser*            用户* @return 号码条*/private String accept(BankUser bankUser) {switch (bankUser.biz) {case VIP:this.vipQueue.offer(bankUser);return "V" + vipn++;case Quick:this.quickQueue.offer(bankUser);return "Q" + quickn++;case Normal:this.normalQueue.offer(bankUser);return "N" + normaln++;}return null;}/*** 为窗口分派用户，若当前没有则等待1秒* * @param businessWindow*            待分配的窗口* @return 客户*/public BankUser offerUser(BusinessWindow businessWindow) {BankUser offer = null;while (offer == null) {switch (businessWindow.offerType) {case VIP:return this.offerVIP();case Quick:return this.offerQuick();case Normal:return this.offerNormal();}ts(10);}return offer;}/*** 为快速窗口查找匹配的客户* * @return 合适的客户*/private BankUser offerQuick() {if (!this.quickQueue.isEmpty()) {try {return this.quickQueue.take();} catch (InterruptedException e) {e.printStackTrace();}return null;} else if (!this.normalQueue.isEmpty()) {try {return this.normalQueue.take();} catch (InterruptedException e) {e.printStackTrace();}return null;} return null;}/*** 为VIP窗口查找匹配的客户* * @return 合适的客户*/private BankUser offerVIP() {if (!this.vipQueue.isEmpty()) {try {return this.vipQueue.take();} catch (InterruptedException e) {e.printStackTrace();}return null;} else if (!this.normalQueue.isEmpty()) {try {return this.normalQueue.take();} catch (InterruptedException e) {e.printStackTrace();}return null;} return null;}/*** 为普通窗口查找匹配的客户* 这个方法是阻塞的* @return 合适的客户*/private BankUser offerNormal() {try {return this.normalQueue.take();} catch (InterruptedException e) {e.printStackTrace();}return null;}}/*** 服务窗口* @author lz**/public class BusinessWindow implements Runnable {/*** 窗口序号*/public final int serial;/*** 是否接续服务*/private boolean keepWorking;/*** 当前服务客户*/private BankUser currentServing;/*** 窗口服务类型*/public final BusinessType offerType;public BusinessWindow(BusinessType offerType) {super();this.offerType = offerType;this.serial = Bank.this.servWindows.size();}@Overridepublic String toString() {return "Window[" + offerType.toString().charAt(0) + serial + "]";}public String shortInfo() {return "W[" + offerType.toString().charAt(0) + serial + "]";}/*** 就绪，可以服务*/public void readyToService() {this.keepWorking = true;}/*** 停止，服务完成当前用户就停止*/public void scheduleStop() {this.keepWorking = false;}/*** @return 是否正在服务*/public boolean isBusy() {return currentServing != null;}/*** 服务过程* 服务完成会使当前客户离开*/private void handle() {if (currentServing != null) {// Logger.getLogger("BankQueue").info(this.shortInfo() +// " 开始服务：" + currentServing.shortInfo() + " @" +Instant.now());// sp(this + " 开始服务：" + currentServing + " @" +Instant.now());ts(currentServing.bizTime * 10);Logger.getLogger("BankQueue").info(this.shortInfo() +" 服务完毕：" + currentServing.shortInfo() + " @" +Instant.now());sp(this + " 服务完毕：" + currentServing + " @" + Instant.now());this.currentServing = null;}}/*** 取一个用户*/private void next() {this.currentServing = Bank.this.banksys.offerUser(this);}@Overridepublic void run() {while (true) {if (this.keepWorking) {if(this.currentServing == null){this.next();}this.handle();} else {ts(1000);}}}}
}

模拟器，包括用户生成器


/*** 模拟器* @author lz**/
public class Simulator {public static void main(String[] args) {Logger.getLogger("BankQueue").setLevel(Level.ALL);Bank bank = new Bank();new Thread(bank).start();BankUserGenerator gen=new BankUserGenerator();Executors.newSingleThreadScheduledExecutor().scheduleAtFixedRate((() -> gen.randomGen().enQueue(bank)), 100, 300, TimeUnit.MILLISECONDS);}}/*** 模拟银行用户生成器* @author lz**/
class BankUserGenerator{Random r=new Random();BankUser randomGen(){BusinessType biz;int rnum=r.nextInt(10);if(rnum>8){biz=BusinessType.VIP;}else if(rnum>5){biz=BusinessType.Quick;}else{biz=BusinessType.Normal;}return new BankUser(biz, biz.minTime+r.nextInt(biz.maxTime-biz.minTime+1));}
}

分析

这里的快速队列和VIP队列采用了轮询的方式，效率偏低，如果可以，用标记多头阻塞队列是理想的，但是这个容器难度颇大，就没有实现。
而且客户的取号系统基本没有在分配中用上，实际应该维持一个映射，系统应该只对号码操作。
窗口的开关功能虽然实现了，但是没有模拟。

扩展讨论

一个用户在办理业务的时候可能多次往返窗口，这样重新拿号势必麻烦，而银行业务人员有时又需要传递用户，序列操作，最后，这个系统中可以加入用户等待时间统计，预估一个等待时间，提高客户体验，银行的窗口分配策略也可以动态修改就更好了。
这些需求，初步分析，可以通过内部号码生成与插队，动态代理调度系统并传递数据的方式完成，而统计就比较简单了，实现的方式很多。

这篇关于黑马程序员-JAVA-银行业务调度系统的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/563380。

相关文章

JVM 的类初始化机制

JVM 的类初始化机制

前言 当你在 Java 程序中new对象时，有没有考虑过 JVM 是如何把静态的字节码（byte code）转化为运行时对象的呢，这个问题看似简单，但清楚的同学相信也不会太多，这篇文章首先介绍 JVM 类初始化的机制，然后给出几个易出错的实例来分析，帮助大家更好理解这个知识点。 JVM 将字节码转化为运行时对象分为三个阶段，分别是：loading 、Linking、initialization
阅读更多...
Spring Security 基于表达式的权限控制

Spring Security 基于表达式的权限控制

前言 spring security 3.0已经可以使用spring el表达式来控制授权，允许在表达式中使用复杂的布尔逻辑来控制访问的权限。 常见的表达式 Spring Security可用表达式对象的基类是SecurityExpressionRoot。 表达式描述hasRole([role])用户拥有制定的角色时返回true （Spring security默认会带有ROLE_前缀）,去
阅读更多...
浅析Spring Security认证过程

浅析Spring Security认证过程

类图 为了方便理解Spring Security认证流程，特意画了如下的类图，包含相关的核心认证类 概述 核心验证器 AuthenticationManager 该对象提供了认证方法的入口，接收一个Authentiaton对象作为参数; public interface AuthenticationManager {Authentication authenticate(Authenti
阅读更多...
Spring Security--Architecture Overview

Spring Security--Architecture Overview

1 核心组件 这一节主要介绍一些在Spring Security中常见且核心的Java类，它们之间的依赖，构建起了整个框架。想要理解整个架构，最起码得对这些类眼熟。 1.1 SecurityContextHolder SecurityContextHolder用于存储安全上下文（security context）的信息。当前操作的用户是谁，该用户是否已经被认证，他拥有哪些角色权限…这些都被保
阅读更多...
Spring Security基于数据库验证流程详解

Spring Security基于数据库验证流程详解

Spring Security 校验流程图 相关解释说明（认真看哦） AbstractAuthenticationProcessingFilter 抽象类 /*** 调用 #requiresAuthentication(HttpServletRequest, HttpServletResponse) 决定是否需要进行验证操作。* 如果需要验证，则会调用 #attemptAuthentica
阅读更多...
Spring Security 从入门到进阶系列教程

Spring Security 从入门到进阶系列教程

Spring Security 入门系列 《保护 Web 应用的安全》 《Spring-Security-入门（一）：登录与退出》 《Spring-Security-入门（二）：基于数据库验证》 《Spring-Security-入门（三）：密码加密》 《Spring-Security-入门（四）：自定义-Filter》 《Spring-Security-入门（五）：在 Sprin
阅读更多...
Java架构师知识体认识

Java架构师知识体认识

源码分析 常用设计模式 Proxy代理模式Factory工厂模式Singleton单例模式Delegate委派模式Strategy策略模式Prototype原型模式Template模板模式 Spring5 beans 接口实例化代理Bean操作 Context Ioc容器设计原理及高级特性Aop设计原理Factorybean与Beanfactory Transaction 声明式事物
阅读更多...
不懂推荐算法也能设计推荐系统

不懂推荐算法也能设计推荐系统

本文以商业化应用推荐为例，告诉我们不懂推荐算法的产品，也能从产品侧出发， 设计出一款不错的推荐系统。 相信很多新手产品，看到算法二字，多是懵圈的。 什么排序算法、最短路径等都是相对传统的算法（注：传统是指科班出身的产品都会接触过）。但对于推荐算法，多数产品对着网上搜到的资源，都会无从下手。特别当某些推荐算法 和 “AI”扯上关系后，更是加大了理解的难度。 但，不了解推荐算法，就无法做推荐系
阅读更多...
基于人工智能的图像分类系统

基于人工智能的图像分类系统

目录 引言项目背景环境准备 硬件要求软件安装与配置系统设计 系统架构关键技术代码示例 数据预处理模型训练模型预测应用场景结论 1. 引言 图像分类是计算机视觉中的一个重要任务，目标是自动识别图像中的对象类别。通过卷积神经网络（CNN）等深度学习技术，我们可以构建高效的图像分类系统，广泛应用于自动驾驶、医疗影像诊断、监控分析等领域。本文将介绍如何构建一个基于人工智能的图像分类系统，包括环境
阅读更多...
水位雨量在线监测系统概述及应用介绍

水位雨量在线监测系统概述及应用介绍

在当今社会，随着科技的飞速发展，各种智能监测系统已成为保障公共安全、促进资源管理和环境保护的重要工具。其中，水位雨量在线监测系统作为自然灾害预警、水资源管理及水利工程运行的关键技术，其重要性不言而喻。 一、水位雨量在线监测系统的基本原理 水位雨量在线监测系统主要由数据采集单元、数据传输网络、数据处理中心及用户终端四大部分构成，形成了一个完整的闭环系统。 数据采集单元：这是系统的“眼睛”，
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2