Class HotModule

ZezeJava/ZezeJava/src/main/java/Zeze/Hot/HotModule.java:20–202

// 1. 目录是一个模块目录时，开启一个新的热更单位；
// 2. 目录不是模块目录时，它就属于往上级目录方向的最近的热更模块。
public class HotModule extends ClassLoader implements Closeable {
	private static final Logger logger = LogManager.getLogger(HotModule.class);
	private final File jarFile;
	private JarFile jar; // 模块的class（interface除外）必须打包成一个jar，只支持一个。
	private final Class<?> moduleClass;
	private HotService service;
	private final boolean isLoadSchemas;

	// 每个版本的接口一个上下文。
	private final ConcurrentHashMap<Class<?>, HotModuleContext<?>> contexts = new ConcurrentHashMap<>();
	public final ConcurrentHashSet<Action1<HotModule>> stopEvents = new ConcurrentHashSet<>();

	// 为了支持批量装载redirect.class，构造只初始化moduleClass，service下一步处理。
	public HotModule(HotManager parent, String namespace, File jarFile) throws Exception {
		super(namespace, parent);
		this.jarFile = jarFile;
		this.jar = new JarFile(jarFile);
		// App.ModuleClassName：MySolution.MyName.ModuleMyName，namespace=MySolution.MyName
		// MyName 一般就叫模块名字。
		var moduleClassName = namespace + ".Module" + last(namespace);
		this.moduleClass = loadClass(moduleClassName);
		this.isLoadSchemas = false;
	}

	// 用于装载 Schemas. 借用这个类实现单独的装载。
	HotModule(File jarFile) throws Exception {
		this.jarFile = jarFile;
		this.jar = new JarFile(jarFile);
		this.moduleClass = null;
		this.isLoadSchemas = true;
	}

	public String getJarFileName() {
		return jar.getName();
	}

	JarFile getJarFile() {
		return jar;
	}

	Class<?> getModuleClass() {
		return moduleClass;
	}

	void setService(IModule service) {
		this.service = (HotService)service;
	}

	private static String last(String namespace) {
		var ns = namespace.split("\\.");
		return ns[ns.length - 1];
	}

	@SuppressWarnings("unchecked")
	public <T extends HotService> HotModuleContext<T> getContext(Class<T> serviceClass) {
		return (HotModuleContext<T>)contexts.computeIfAbsent(serviceClass, (key) -> new HotModuleContext<T>(this));
	}