一、创建出代理类
1.在加载bean的时候扫描含@Reference注解的属性2.注入代理对象 二、创建出的代理类如何完成的调用总结
一、创建出代理类 1.在加载bean的时候扫描含@Reference注解的属性
ReferenceAnnotationBeanPostProcessor间接实现InstantiationAwareBeanPostProcessor接口，重写postProcessPropertyValues方法
protected void populateBean(String beanName, RootBeanDefinition mbd, BeanWrapper bw) {
......
// 这里的getBeanPostProcessors()能拿到dubbo的Processor
for (BeanPostProcessor bp : getBeanPostProcessors()) {
if (bp instanceof InstantiationAwareBeanPostProcessor) {
InstantiationAwareBeanPostProcessor ibp = (InstantiationAwareBeanPostProcessor) bp;
// 走dubbo的Processor
pvs = ibp.postProcessPropertyValues(pvs, filteredPds, bw.getWrappedInstance(), beanName);
if (pvs == null) {
return;
}
}
}
......
}
寻找被标记的属性或者方法
private Injectionmetadata findReferencemetadata(String beanName, Class clazz, PropertyValues pvs) {
// Fall back to class name as cache key, for backwards compatibility with custom callers.
String cacheKey = (StringUtils.hasLength(beanName) ? beanName : clazz.getName());
// Quick check on the concurrent map first, with minimal locking.
ReferenceInjectionmetadata metadata = this.injectionmetadataCache.get(cacheKey);
if (Injectionmetadata.needsRefresh(metadata, clazz)) {
synchronized (this.injectionmetadataCache) {
metadata = this.injectionmetadataCache.get(cacheKey);
if (Injectionmetadata.needsRefresh(metadata, clazz)) {
if (metadata != null) {
metadata.clear(pvs);
}
try {
// 解析类中被@Reference标注的field或者method
metadata = buildReferencemetadata(clazz);
// 注入代理类对象
this.injectionmetadataCache.put(cacheKey, metadata);
} catch (NoClassDefFoundError err) {
throw new IllegalStateException("Failed to introspect bean class [" + clazz.getName() +
"] for reference metadata: could not find class that it depends on", err);
}
}
}
}
return metadata;
}
基操，勿6
private ReferenceInjectionmetadata buildReferencemetadata(final Class beanClass) {
Collection fieldElements = findFieldReferencemetadata(beanClass);
Collection methodElements = findMethodReferencemetadata(beanClass);
return new ReferenceInjectionmetadata(beanClass, fieldElements, methodElements);
}
2.注入代理对象
ReferenceAnnotationBeanPostProcessor.ReferenceFieldElement#inject
protected void inject(Object bean, String beanName, PropertyValues pvs) throws Throwable {
Class referenceClass = field.getType();
referenceBean = buildReferenceBean(reference, referenceClass);
ReflectionUtils.makeAccessible(field);
// 为Reference范型对象生成代理
field.set(bean, referenceBean.getObject());
}
生成Reference对象
private ReferenceBean buildReferenceBean(Reference reference, Class referenceClass) throws Exception {
String referenceBeanCacheKey = generateReferenceBeanCacheKey(reference, referenceClass);
ReferenceBean referenceBean = referenceBeansCache.get(referenceBeanCacheKey);
if (referenceBean == null) {
ReferenceBeanBuilder beanBuilder = ReferenceBeanBuilder
.create(reference, classLoader, applicationContext)
.interfaceClass(referenceClass);
// lookup
referenceBean = beanBuilder.build();
referenceBeansCache.putIfAbsent(referenceBeanCacheKey, referenceBean);
}
return referenceBean;
}
public final B build() throws Exception {
checkDependencies();
// 这里
B bean = doBuild();
configureBean(bean);
if (logger.isInfoEnabled()) {
logger.info(bean + " has been built.");
}
return bean;
}
protected ReferenceBean doBuild() {
// 生成范型空对象
return new ReferenceBean
填充属性
protected void configureBean(B bean) throws Exception {
// 注解上的所有key value都赋予给此bean
preConfigureBean(annotation, bean);
// todo 这些只要看懂一个就行了
configureRegistryConfigs(bean);
configureMonitorConfig(bean);
configureApplicationConfig(bean);
configureModuleConfig(bean);
postConfigureBean(annotation, bean);
}
ReferenceAnnotationBeanPostProcessor.ReferenceMethodElement#inject->ReferenceBean.getObject()->ReferenceConfig#init
private void init() {
if (initialized) {
return;
}
initialized = true;
if (interfaceName == null || interfaceName.length() == 0) {
throw new IllegalStateException(" map = new HashMap();
Map attributes = new HashMap();
map.put(Constants.SIDE_KEY, Constants.CONSUMER_SIDE);
map.put(Constants.DUBBO_VERSION_KEY, Version.getProtocolVersion());
map.put(Constants.TIMESTAMP_KEY, String.valueOf(System.currentTimeMillis()));
if (ConfigUtils.getPid() > 0) {
map.put(Constants.PID_KEY, String.valueOf(ConfigUtils.getPid()));
}
if (!isGeneric()) {
String revision = Version.getVersion(interfaceClass, version);
if (revision != null && revision.length() > 0) {
map.put("revision", revision);
}
String[] methods = Wrapper.getWrapper(interfaceClass).getMethodNames();
if (methods.length == 0) {
logger.warn("NO method found in service interface " + interfaceClass.getName());
map.put("methods", Constants.ANY_VALUE);
} else {
map.put("methods", StringUtils.join(new HashSet(Arrays.asList(methods)), ","));
}
}
map.put(Constants.INTERFACE_KEY, interfaceName);
// todo 看看这个接口干了啥
appendParameters(map, application);
appendParameters(map, module);
appendParameters(map, consumer, Constants.DEFAULT_KEY);
appendParameters(map, this);
String prefix = StringUtils.getServiceKey(map);
if (methods != null && !methods.isEmpty()) {
for (MethodConfig method : methods) {
appendParameters(map, method, method.getName());
String retryKey = method.getName() + ".retry";
if (map.containsKey(retryKey)) {
String retryValue = map.remove(retryKey);
if ("false".equals(retryValue)) {
map.put(method.getName() + ".retries", "0");
}
}
appendAttributes(attributes, method, prefix + "." + method.getName());
checkAndConvertImplicitConfig(method, map, attributes);
}
}
String hostToRegistry = ConfigUtils.getSystemProperty(Constants.DUBBO_IP_TO_REGISTRY);
if (hostToRegistry == null || hostToRegistry.length() == 0) {
hostToRegistry = NetUtils.getLocalHost();
} else if (isInvalidLocalHost(hostToRegistry)) {
throw new IllegalArgumentException("Specified invalid registry ip from property:" + Constants.DUBBO_IP_TO_REGISTRY + ", value:" + hostToRegistry);
}
map.put(Constants.REGISTER_IP_KEY, hostToRegistry);
//attributes are stored by system context.
StaticContext.getSystemContext().putAll(attributes);
// very important！！！ 最终无非就是通过proxyFactory.getProxy(invoker)生成代理类
ref = createProxy(map);
ConsumerModel consumerModel = new ConsumerModel(getUniqueServiceName(), this, ref, interfaceClass.getMethods());
ApplicationModel.initConsumerModel(getUniqueServiceName(), consumerModel);
}
二、创建出的代理类如何完成的调用 总结
