单例模式（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());
}
