单例模式(3)
实现集群环境下的分布式单例类
如何理解单例模式中的唯一性?
- 单例模式创建的对象是进程唯一的。以springboot应用程序为例,他是一个进程,可能包含多个线程,单例代表在这个进程的某个类是唯一的,在不同的线程中类是相同的。
如何实现线程唯一的单例?
/*** 线程中的单例*/
public class ThreadIdGenrator {private static final Map<Long, ThreadIdGenrator> map = new ConcurrentHashMap<>();private AtomicInteger id = new AtomicInteger(0);public static ThreadIdGenrator getInstance() {long threadId = Thread.currentThread().getId();ThreadIdGenrator threadIdGenrator = map.putIfAbsent(threadId, new ThreadIdGenrator());return threadIdGenrator;}public int nextInt() {return id.incrementAndGet();}
}
如何实现集群环境下的单例?
-
我们需要把这个单例对象序列化并存储到外部共享存储区(比如文件)。进程在使用这个单例对象的时候,需要先从外部共享存储区中将它读取到内存,并反序列化成对象,然后再使用,使用完成之后还需要再存储回外部共享存储区。
-
为了保证任何时刻,在进程间都只有一份对象存在,一个进程在获取到对象之后,需要对对象加锁,避免其他进程再将其获取。在进程使用完这个对象之后,还需要显式地将对象从内存中删除,并且释放对对象的加锁。
-
问题:这里为什么要加锁
- 理由:如果多个进程读取同一份序列化文件,得到的对象的地址是不一样的,这样子就无法保证全局的唯一性;
- 序列化后的对象与原对象只是值相等但是对象的地址是不相等的
- 为了保证全局的唯一性,必须保证在集群下,在使用单例对象时,需要加锁,当多线程使用时,只有一个线程可以使用成功,其他线程必须阻塞
import java.util.concurrent.atomic.AtomicLong;public class IdGenerator {private AtomicLong id = new AtomicLong(0);private static IdGenerator instance;private static SharedObjectStorage storage = FileSharedObjectStorage(/* 入参省略 */);private static DistributedLock lock = new DistributedLock();private IdGenerator() {}public static IdGenerator getInstance() {if (instance == null) {lock.lock();instance = storage.load(IdGenerator.class);lock.unlock(); // 放置于try-finally块内确保解锁}return instance;}public void freeInstance() {lock.lock();try {storage.save(this, IdGenerator.class);instance = null; // 释放对象} finally {lock.unlock();}}public long getId() {return id.incrementAndGet();}
}
如何实现一个多例模式?
- 多例的理解
- “多例”指的就是,一个类可以创建多个对象,但是个数是有限制的
- 同一类型的只能创建一个对象,不同类型的可以创建多个对象
- 类型:同一个 name 获取到的对象实例是相同的
- 以ID生成器为例:我希望在用户注册时使用的是一个ID生成器;在增加商品时,使用的是另一个ID生成器,即根据场景划分使用不同的ID生成器
public class DuoLiIdGenertor {private static final Map<String, DuoLiIdGenertor> map = new ConcurrentHashMap<>();private AtomicInteger id = new AtomicInteger(0);public static DuoLiIdGenertor getInstance(String name) {map.putIfAbsent(name, new DuoLiIdGenertor());return map.get(name);}public int nextInt() {return id.incrementAndGet();}}public static void main(String[] args) {DuoLiIdGenertor user = getInstance("user");DuoLiIdGenertor goods = getInstance("goods");DuoLiIdGenertor user1 = getInstance("user");System.out.println(user.hashCode());System.out.println(goods.hashCode());System.out.println(user1.hashCode());}