ArrayBlockingQueue是Queue的一个子类,可以作为消息队列来进行使用 ArrayBlockingQueue底层是有数组来进行实现的,存在队列的参数不能为空,否则会抛出一个空指针异常 在进行初始创建ArrayBlockingQueue时,可以指定两个参数 public ArrayBlockingQueue(int capacity, boolean fair) { } 一个是创建队列的长度,如果不指定的话默认值为int的最大长度 也就是20多亿条 另外一个是一个布尔值,这个值是指定锁的类型,这里锁分…

activemq是由Apache出品对应java的jms的消息中间件,能够做到很好的分布式系统模块解耦异步通知而无需进行线程等待,下面是activemq与springboot的整合; 安装: 首先需要下载activemq,本次是基于windows环境下的安装下载地址 .下载之后 解压后进入bin目录下,直接启动activemq.bat批处理文件; 可以验证一下,进入activemq的后台查看http://localhost:8161/admin,账号密码都是admin; 下面开始进行整合,新建两个模块 然后是pom…