发表于

本文概要

在AQS(1)中，从ReentrantLock入手，分析了获取和释放锁的源代码；在AQS(2)中，走了一遍Condition条件队列的等待与唤醒。 在两篇文章中，都只是找了典型的几个方法，如ReentrantLock的lock()/unlock(),以及 Condition的await()/signal()。事实上，还有带超时机制，和中断机制的方法，本文就来查漏补缺，大概过一遍 这几个方法。

阅读全文 »

发表于

Condition 简介

Condition的await()/signal()/signalAll()方法提供了Object的wait()/notify()/notifyAll()方法的替代品； 此外，还对其进行了增强：一个锁可以有多个Condition队列，以实现精准的唤醒。 本文主要通过源码来看看Condition在AQS里是怎么实现的。

阅读全文 »

发表于

AQS 简介

AbstractQueuedSynchronizer，抽象队列同步器，为JUC包中的各阻塞锁和同步器 提供了一个框架，其基于一个FIFO队列（CLH队列的一种变体），以模板设计模式，为大 多数同步器提供了一个基本的实现。

两个内部类

Node：队列节点类

Node类是AQS的FIFO等待队列的节点类，其主要有以下字段属性： ```java // 共享模式下等待的节点标记 static final Node SHARED = new Node(); // 独占模式下等待的节点标记 static final Node EXCLUSIVE = null;

1
2
3
4
5
6
7
8
9
10
// 等待状态值：当前节点的线程已取消等待（可能是因为超时、中断等原因，一旦标记则不再变化）
static final int CANCELLED =  1;
// 等待状态值：当前节点的后继节点需要唤醒（也可以理解成后继节点的状态，在当前节点取消或释放锁时进行唤醒操作）
static final int SIGNAL    = -1;
// 等待状态值：当前节点在条件队列中排队等待（被移入等待队列后会设置成0）
static final int CONDITION = -2;
// 等待状态值：下一个共享锁的获取操作将无条件扩散（没有理解）
static final int PROPAGATE = -3;
// 等待状态，取值为上4种，以及默认值0/
volatile int waitStatus;
阅读全文 »

发表于

RabbitMQ的高可用性

先说结论：采用集群+镜像队列的方式提高可用性

集群模式

在rabbitMQ的集群模式下，集群中所有节点都会备份所有的元数据信息，包括：

  1. 队列元数据：队列名称和属性
  2. 交换器元数据：交换器名称和属性
  3. 绑定关系元数据：队列和交换机的绑定关系
  4. vhost元数据：为其内的上三者提供命名空间和安全属性
阅读全文 »

发表于

适配器模式

适配器将被适配的类的方法适配成客户端所期待的方法；
或者说，适配器将不同类的方法统一成某个接口的一个方法，方便客户端进行调用；
如：客户端想调用类A的方法a，但是客户端的代码实现中只能调用接口B的b方法，此时可以用C类去实现B接口，并在b方法里，调用A类的a方法；

阅读全文 »