Label parsing
Dubbo jar package dependencies inside, you can see two files:
spring.schemas
http\://dubbo.apache.org/schema/dubbo/dubbo.xsd=META-INF/dubbo.xsd
http\://code.alibabatech.com/schema/dubbo/dubbo.xsd=META-INF/compat/dubbo.xsd
Copy the codespring.handlers
http\://dubbo.apache.org/schema/dubbo=org.apache.dubbo.config.spring.schema.DubboNamespaceHandler <! Class to parse tags -->
http\://code.alibabatech.com/schema/dubbo=org.apache.dubbo.config.spring.schema.DubboNamespaceHandler
Copy the codeDubboNamespaceHandler.java
@Override
public void init(a) {
DubboBeanDefinitionParser.java
/** * Dubbo tag parser constructor *@paramThe type encapsulated by the beanClass tag attribute readout value *@paramRequired specifies whether the ID attribute is required */ in the current tag
public DubboBeanDefinitionParser(Class<? > beanClass,boolean required) {
this.beanClass = beanClass;
this.required = required;
}
/** * parses the specified tag *@paramElement The label element * to parse@paramParserContext Parsing context, which contains parsing information * for all other tags in the current configuration file@paramBeanClass Is a physical encapsulation of the type encapsulated by the tag attribute readout value@paramRequired specifies whether the ID attribute is a required * in the current tag@returnParse the object. That is, the Bean definition instance */ of the "logical instance" ultimately resolved by the current tag
@SuppressWarnings("unchecked")
private static BeanDefinition parse(Element element, ParserContext parserContext, Class<? > beanClass,boolean required) {
/ / = = = = = = = = = = = = = = = = = = = = = = = = = = 1 create and initialize the analysis object = = = = = = = = = = = = = = = =
RootBeanDefinition beanDefinition = new RootBeanDefinition();
beanDefinition.setBeanClass(beanClass);
beanDefinition.setLazyInit(false);// Whether to enable lazy loading
/ / = = = = = = = = = = = = = = = = = = = = = = = = = = 2 id problem: the problem of empty and repeat = = = = = = = = = = = = = = = =
// Get the id attribute in the current tag
String id = element.getAttribute("id");
if (StringUtils.isEmpty(id) && required) {
// Get the name attribute of the current tag
String generatedBeanName = element.getAttribute("name");
if (StringUtils.isEmpty(generatedBeanName)) {
// If the current parse label is
Important interface
Invocation.java
// Encapsulates information about RPC remote calls
public interface Invocation {
* get method name. **@return method name.
* @serial* /
String getMethodName(a);
/** Parameter types (line arguments) * get parameter types@return parameter types.
* @serial* /Class<? >[] getParameterTypes();/** arguments * get arguments. **@return arguments.
* @serial* /
Object[] getArguments();
/** * attachments. **@return attachments.
* @serial* /
Map<String, String> getAttachments(a);
void setAttachment(String key, String value);
void setAttachmentIfAbsent(String key, String value);
/**
* get attachment by key.
*
* @return attachment value.
* @serial* /
String getAttachment(String key);
/**
* get attachment by key with default value.
*
* @return attachment value.
* @serial* /
String getAttachment(String key, String defaultValue);
* get the invoker in current context. **@return invoker.
* @transient* /Invoker<? > getInvoker(); }Copy the codeInvoker.java
/** If inherited from Node, the URL can be obtained through getUrl() method, that is, Invoker can be used as a parameter of the Adaptive method. * is the proxy object of the provider provider, which represents the provider in the code. In particular, when a consumer makes a remote call, it looks for Invoker through mechanisms such as service routing, load balancing, and cluster fault tolerance. You can make a remote call when you find the Invoker instance it needs *. * * /
public interface Invoker<T> extends Node {
/** * get service interface@return service interface.
*/
Class<T> getInterface(a);
/** invoke. * Executes the call and returns the result *@param invocation
* @return result
* @throws RpcException
*/
Result invoke(Invocation invocation) throws RpcException;
}
Copy the codeExporter.java
/** * Service exposure object. It contains an important method, getInvoker(), that gets the remote invocation instance Invoker contained in the current service exposure instance, that is, the remote invocation that can be made. * /
public interface Exporter<T> {
/**
* get invoker.
*
* @return invoker
*/
Invoker<T> getInvoker(a);
/** * unexport. * * * getInvoker().destroy(); * */
void unexport(a);
}
Copy the codeDirectory.java
// Directory contains an important method list()
// It returns a List
.
Directory can be understood as a list of invokers that provide a specific service
public interface Directory<T> extends Node {
/**
* get service type.
*
* @return service type.
*/
Class<T> getInterface(a);
/**
* list invokers.
*
* @return invokers
*/
List<Invoker<T>> list(Invocation invocation) throws RpcException;
}
Copy the code