dubbo源码-服务发现

本是古典 何须时尚 2021-11-22 13:44 476阅读 0赞

服务消费者

  1. <!-- consumer's application name, used for tracing dependency relationship (not a matching criterion),
  2.     don't set it same as provider -->
  3.     <dubbo:application name="dubbo-consumer"/>
  5.     <!-- protocol="zookeeper"必须有 -->
  6.     <dubbo:registry protocol="zookeeper" address="${dubbo.registry.address}"/>
  8.     <!-- generate proxy for the remote service, then demoService can be used in the same way as the
  9.     local regular interface -->
  10.     <dubbo:reference id="userService" check="false" interface="com.study.dubbo.userapi.service.UserService" loadbalance="consistenthash"/>

ReferenceBean

  1. public class ReferenceBean<T> extends ReferenceConfig<T> implements FactoryBean, ApplicationContextAware, InitializingBean, DisposableBean {
  3.     private static final long serialVersionUID = 213195494150089726L;
  5.     private transient ApplicationContext applicationContext;
  7.     public ReferenceBean() {
  8.         super();
  9.     }
  11.     public ReferenceBean(Reference reference) {
  12.         super(reference);
  13.     }
  15.     public void setApplicationContext(ApplicationContext applicationContext) {
  16.         this.applicationContext = applicationContext;
  17.         SpringExtensionFactory.addApplicationContext(applicationContext);
  18.     }
  20.     public Object getObject() throws Exception {
  21.         return get();
  22.     }
  24.     public Class<?> getObjectType() {
  25.         return getInterfaceClass();
  26.     }
  28.     @Parameter(excluded = true)
  29.     public boolean isSingleton() {
  30.         return true;
  31.     }
  33.     @SuppressWarnings({"unchecked"})
  34.     public void afterPropertiesSet() throws Exception {
  35.         if (getConsumer() == null) {
  36.             Map<String, ConsumerConfig> consumerConfigMap = applicationContext == null ? null : BeanFactoryUtils.beansOfTypeIncludingAncestors(applicationContext, ConsumerConfig.class, false, false);
  37.             if (consumerConfigMap != null && consumerConfigMap.size() > 0) {
  38.                 ConsumerConfig consumerConfig = null;
  39.                 for (ConsumerConfig config : consumerConfigMap.values()) {
  40.                     if (config.isDefault() == null || config.isDefault().booleanValue()) {
  41.                         if (consumerConfig != null) {
  42.                             throw new IllegalStateException("Duplicate consumer configs: " + consumerConfig + " and " + config);
  43.                         }
  44.                         consumerConfig = config;
  45.                     }
  46.                 }
  47.                 if (consumerConfig != null) {
  48.                     setConsumer(consumerConfig);
  49.                 }
  50.             }
  51.         }
  52.         if (getApplication() == null
  53.                 && (getConsumer() == null || getConsumer().getApplication() == null)) {
  54.             Map<String, ApplicationConfig> applicationConfigMap = applicationContext == null ? null : BeanFactoryUtils.beansOfTypeIncludingAncestors(applicationContext, ApplicationConfig.class, false, false);
  55.             if (applicationConfigMap != null && applicationConfigMap.size() > 0) {
  56.                 ApplicationConfig applicationConfig = null;
  57.                 for (ApplicationConfig config : applicationConfigMap.values()) {
  58.                     if (config.isDefault() == null || config.isDefault().booleanValue()) {
  59.                         if (applicationConfig != null) {
  60.                             throw new IllegalStateException("Duplicate application configs: " + applicationConfig + " and " + config);
  61.                         }
  62.                         applicationConfig = config;
  63.                     }
  64.                 }
  65.                 if (applicationConfig != null) {
  66.                     setApplication(applicationConfig);
  67.                 }
  68.             }
  69.         }
  70.         if (getModule() == null
  71.                 && (getConsumer() == null || getConsumer().getModule() == null)) {
  72.             Map<String, ModuleConfig> moduleConfigMap = applicationContext == null ? null : BeanFactoryUtils.beansOfTypeIncludingAncestors(applicationContext, ModuleConfig.class, false, false);
  73.             if (moduleConfigMap != null && moduleConfigMap.size() > 0) {
  74.                 ModuleConfig moduleConfig = null;
  75.                 for (ModuleConfig config : moduleConfigMap.values()) {
  76.                     if (config.isDefault() == null || config.isDefault().booleanValue()) {
  77.                         if (moduleConfig != null) {
  78.                             throw new IllegalStateException("Duplicate module configs: " + moduleConfig + " and " + config);
  79.                         }
  80.                         moduleConfig = config;
  81.                     }
  82.                 }
  83.                 if (moduleConfig != null) {
  84.                     setModule(moduleConfig);
  85.                 }
  86.             }
  87.         }
  88.         if ((getRegistries() == null || getRegistries().isEmpty())
  89.                 && (getConsumer() == null || getConsumer().getRegistries() == null || getConsumer().getRegistries().isEmpty())
  90.                 && (getApplication() == null || getApplication().getRegistries() == null || getApplication().getRegistries().isEmpty())) {
  91.             Map<String, RegistryConfig> registryConfigMap = applicationContext == null ? null : BeanFactoryUtils.beansOfTypeIncludingAncestors(applicationContext, RegistryConfig.class, false, false);
  92.             if (registryConfigMap != null && registryConfigMap.size() > 0) {
  93.                 List<RegistryConfig> registryConfigs = new ArrayList<RegistryConfig>();
  94.                 for (RegistryConfig config : registryConfigMap.values()) {
  95.                     if (config.isDefault() == null || config.isDefault().booleanValue()) {
  96.                         registryConfigs.add(config);
  97.                     }
  98.                 }
  99.                 if (registryConfigs != null && !registryConfigs.isEmpty()) {
  100.                     super.setRegistries(registryConfigs);
  101.                 }
  102.             }
  103.         }
  104.         if (getMonitor() == null
  105.                 && (getConsumer() == null || getConsumer().getMonitor() == null)
  106.                 && (getApplication() == null || getApplication().getMonitor() == null)) {
  107.             Map<String, MonitorConfig> monitorConfigMap = applicationContext == null ? null : BeanFactoryUtils.beansOfTypeIncludingAncestors(applicationContext, MonitorConfig.class, false, false);
  108.             if (monitorConfigMap != null && monitorConfigMap.size() > 0) {
  109.                 MonitorConfig monitorConfig = null;
  110.                 for (MonitorConfig config : monitorConfigMap.values()) {
  111.                     if (config.isDefault() == null || config.isDefault().booleanValue()) {
  112.                         if (monitorConfig != null) {
  113.                             throw new IllegalStateException("Duplicate monitor configs: " + monitorConfig + " and " + config);
  114.                         }
  115.                         monitorConfig = config;
  116.                     }
  117.                 }
  118.                 if (monitorConfig != null) {
  119.                     setMonitor(monitorConfig);
  120.                 }
  121.             }
  122.         }
  123.         Boolean b = isInit();
  124.         if (b == null && getConsumer() != null) {
  125.             b = getConsumer().isInit();
  126.         }
  127.         if (b != null && b.booleanValue()) {
  128.             getObject();
  129.         }
  130.     }
  132.     @Override
  133.     public void destroy() {
  134.         // do nothing
  135.     }
  136. }

afterPropertiesSet初始化，调用getObject方法获取bean

ReferenceConfig

  1. public synchronized T get() {
  2.         if (destroyed) {
  3.             throw new IllegalStateException("Already destroyed!");
  4.         }
  5.         if (ref == null) {
  6.             init();
  7.         }
  8.         return ref;
  9.     }
  12.     private void init() {
  13.         if (initialized) {
  14.             return;
  15.         }
  16.         initialized = true;
  17.         if (interfaceName == null || interfaceName.length() == 0) {
  18.             throw new IllegalStateException("<dubbo:reference interface=\"\" /> interface not allow null!");
  19.         }
  20.         // get consumer's global configuration
  21.         checkDefault();
  22.         appendProperties(this);
  23.         if (getGeneric() == null && getConsumer() != null) {
  24.             setGeneric(getConsumer().getGeneric());
  25.         }
  26.         if (ProtocolUtils.isGeneric(getGeneric())) {
  27.             interfaceClass = GenericService.class;
  28.         } else {
  29.             try {
  30.                 interfaceClass = Class.forName(interfaceName, true, Thread.currentThread()
  31.                         .getContextClassLoader());
  32.             } catch (ClassNotFoundException e) {
  33.                 throw new IllegalStateException(e.getMessage(), e);
  34.             }
  35.             checkInterfaceAndMethods(interfaceClass, methods);
  36.         }
  37.         String resolve = System.getProperty(interfaceName);
  38.         String resolveFile = null;
  39.         if (resolve == null || resolve.length() == 0) {
  40.             resolveFile = System.getProperty("dubbo.resolve.file");
  41.             if (resolveFile == null || resolveFile.length() == 0) {
  42.                 File userResolveFile = new File(new File(System.getProperty("user.home")), "dubbo-resolve.properties");
  43.                 if (userResolveFile.exists()) {
  44.                     resolveFile = userResolveFile.getAbsolutePath();
  45.                 }
  46.             }
  47.             if (resolveFile != null && resolveFile.length() > 0) {
  48.                 Properties properties = new Properties();
  49.                 FileInputStream fis = null;
  50.                 try {
  51.                     fis = new FileInputStream(new File(resolveFile));
  52.                     properties.load(fis);
  53.                 } catch (IOException e) {
  54.                     throw new IllegalStateException("Unload " + resolveFile + ", cause: " + e.getMessage(), e);
  55.                 } finally {
  56.                     try {
  57.                         if (null != fis) fis.close();
  58.                     } catch (IOException e) {
  59.                         logger.warn(e.getMessage(), e);
  60.                     }
  61.                 }
  62.                 resolve = properties.getProperty(interfaceName);
  63.             }
  64.         }
  65.         if (resolve != null && resolve.length() > 0) {
  66.             url = resolve;
  67.             if (logger.isWarnEnabled()) {
  68.                 if (resolveFile != null && resolveFile.length() > 0) {
  69.                     logger.warn("Using default dubbo resolve file " + resolveFile + " replace " + interfaceName + "" + resolve + " to p2p invoke remote service.");
  70.                 } else {
  71.                     logger.warn("Using -D" + interfaceName + "=" + resolve + " to p2p invoke remote service.");
  72.                 }
  73.             }
  74.         }
  75.         if (consumer != null) {
  76.             if (application == null) {
  77.                 application = consumer.getApplication();
  78.             }
  79.             if (module == null) {
  80.                 module = consumer.getModule();
  81.             }
  82.             if (registries == null) {
  83.                 registries = consumer.getRegistries();
  84.             }
  85.             if (monitor == null) {
  86.                 monitor = consumer.getMonitor();
  87.             }
  88.         }
  89.         if (module != null) {
  90.             if (registries == null) {
  91.                 registries = module.getRegistries();
  92.             }
  93.             if (monitor == null) {
  94.                 monitor = module.getMonitor();
  95.             }
  96.         }
  97.         if (application != null) {
  98.             if (registries == null) {
  99.                 registries = application.getRegistries();
  100.             }
  101.             if (monitor == null) {
  102.                 monitor = application.getMonitor();
  103.             }
  104.         }
  105.         checkApplication();
  106.         checkStubAndMock(interfaceClass);
  107.         Map<String, String> map = new HashMap<String, String>();
  108.         Map<Object, Object> attributes = new HashMap<Object, Object>();
  109.         map.put(Constants.SIDE_KEY, Constants.CONSUMER_SIDE);
  110.         map.put(Constants.DUBBO_VERSION_KEY, Version.getVersion());
  111.         map.put(Constants.TIMESTAMP_KEY, String.valueOf(System.currentTimeMillis()));
  112.         if (ConfigUtils.getPid() > 0) {
  113.             map.put(Constants.PID_KEY, String.valueOf(ConfigUtils.getPid()));
  114.         }
  115.         if (!isGeneric()) {
  116.             String revision = Version.getVersion(interfaceClass, version);
  117.             if (revision != null && revision.length() > 0) {
  118.                 map.put("revision", revision);
  119.             }
  121.             String[] methods = Wrapper.getWrapper(interfaceClass).getMethodNames();
  122.             if (methods.length == 0) {
  123.                 logger.warn("NO method found in service interface " + interfaceClass.getName());
  124.                 map.put("methods", Constants.ANY_VALUE);
  125.             } else {
  126.                 map.put("methods", StringUtils.join(new HashSet<String>(Arrays.asList(methods)), ","));
  127.             }
  128.         }
  129.         map.put(Constants.INTERFACE_KEY, interfaceName);
  130.         appendParameters(map, application);
  131.         appendParameters(map, module);
  132.         appendParameters(map, consumer, Constants.DEFAULT_KEY);
  133.         appendParameters(map, this);
  134.         String prefix = StringUtils.getServiceKey(map);
  135.         if (methods != null && !methods.isEmpty()) {
  136.             for (MethodConfig method : methods) {
  137.                 appendParameters(map, method, method.getName());
  138.                 String retryKey = method.getName() + ".retry";
  139.                 if (map.containsKey(retryKey)) {
  140.                     String retryValue = map.remove(retryKey);
  141.                     if ("false".equals(retryValue)) {
  142.                         map.put(method.getName() + ".retries", "0");
  143.                     }
  144.                 }
  145.                 appendAttributes(attributes, method, prefix + "." + method.getName());
  146.                 checkAndConvertImplicitConfig(method, map, attributes);
  147.             }
  148.         }
  150.         String hostToRegistry = ConfigUtils.getSystemProperty(Constants.DUBBO_IP_TO_REGISTRY);
  151.         if (hostToRegistry == null || hostToRegistry.length() == 0) {
  152.             hostToRegistry = NetUtils.getLocalHost();
  153.         } else if (isInvalidLocalHost(hostToRegistry)) {
  154.             throw new IllegalArgumentException("Specified invalid registry ip from property:" + Constants.DUBBO_IP_TO_REGISTRY + ", value:" + hostToRegistry);
  155.         }
  156.         map.put(Constants.REGISTER_IP_KEY, hostToRegistry);
  158.         //attributes are stored by system context.
  159.         StaticContext.getSystemContext().putAll(attributes);
  160.         ref = createProxy(map);
  161.         ConsumerModel consumerModel = new ConsumerModel(getUniqueServiceName(), this, ref, interfaceClass.getMethods());
  162.         ApplicationModel.initConsumerModel(getUniqueServiceName(), consumerModel);
  163.     }

ReferenceConfig创建代理

  1. @SuppressWarnings({"unchecked", "rawtypes", "deprecation"})
  2.     private T createProxy(Map<String, String> map) {
  3.         URL tmpUrl = new URL("temp", "localhost", 0, map);
  4.         final boolean isJvmRefer;
  5.         if (isInjvm() == null) {
  6.             if (url != null && url.length() > 0) { // if a url is specified, don't do local reference
  7.                 isJvmRefer = false;
  8.             } else if (InjvmProtocol.getInjvmProtocol().isInjvmRefer(tmpUrl)) {
  9.                 // by default, reference local service if there is
  10.                 isJvmRefer = true;
  11.             } else {
  12.                 isJvmRefer = false;
  13.             }
  14.         } else {
  15.             isJvmRefer = isInjvm().booleanValue();
  16.         }
  18.         if (isJvmRefer) {
  19.             URL url = new URL(Constants.LOCAL_PROTOCOL, NetUtils.LOCALHOST, 0, interfaceClass.getName()).addParameters(map);
  20.             invoker = refprotocol.refer(interfaceClass, url);
  21.             if (logger.isInfoEnabled()) {
  22.                 logger.info("Using injvm service " + interfaceClass.getName());
  23.             }
  24.         } else {
  25.             if (url != null && url.length() > 0) { // user specified URL, could be peer-to-peer address, or register center's address.
  26.                 String[] us = Constants.SEMICOLON_SPLIT_PATTERN.split(url);
  27.                 if (us != null && us.length > 0) {
  28.                     for (String u : us) {
  29.                         URL url = URL.valueOf(u);
  30.                         if (url.getPath() == null || url.getPath().length() == 0) {
  31.                             url = url.setPath(interfaceName);
  32.                         }
  33.                         if (Constants.REGISTRY_PROTOCOL.equals(url.getProtocol())) {
  34.                             urls.add(url.addParameterAndEncoded(Constants.REFER_KEY, StringUtils.toQueryString(map)));
  35.                         } else {
  36.                             urls.add(ClusterUtils.mergeUrl(url, map));
  37.                         }
  38.                     }
  39.                 }
  40.             } else { // assemble URL from register center's configuration
  41.                 List<URL> us = loadRegistries(false);
  42.                 if (us != null && !us.isEmpty()) {
  43.                     for (URL u : us) {
  44.                         URL monitorUrl = loadMonitor(u);
  45.                         if (monitorUrl != null) {
  46.                             map.put(Constants.MONITOR_KEY, URL.encode(monitorUrl.toFullString()));
  47.                         }
  48.                         urls.add(u.addParameterAndEncoded(Constants.REFER_KEY, StringUtils.toQueryString(map)));
  49.                     }
  50.                 }
  51.                 if (urls == null || urls.isEmpty()) {
  52.                     throw new IllegalStateException("No such any registry to reference " + interfaceName + " on the consumer " + NetUtils.getLocalHost() + " use dubbo version " + Version.getVersion() + ", please config <dubbo:registry address=\"...\" /> to your spring config.");
  53.                 }
  54.             }
  56.             if (urls.size() == 1) {
  57.                 invoker = refprotocol.refer(interfaceClass, urls.get(0));
  58.             } else {
  59.                 List<Invoker<?>> invokers = new ArrayList<Invoker<?>>();
  60.                 URL registryURL = null;
  61.                 for (URL url : urls) {
  62.                     invokers.add(refprotocol.refer(interfaceClass, url));
  63.                     if (Constants.REGISTRY_PROTOCOL.equals(url.getProtocol())) {
  64.                         registryURL = url; // use last registry url
  65.                     }
  66.                 }
  67.                 if (registryURL != null) { // registry url is available
  68.                     // use AvailableCluster only when register's cluster is available
  69.                     URL u = registryURL.addParameter(Constants.CLUSTER_KEY, AvailableCluster.NAME);
  70.                     invoker = cluster.join(new StaticDirectory(u, invokers));
  71.                 } else { // not a registry url
  72.                     invoker = cluster.join(new StaticDirectory(invokers));
  73.                 }
  74.             }
  75.         }
  77.         Boolean c = check;
  78.         if (c == null && consumer != null) {
  79.             c = consumer.isCheck();
  80.         }
  81.         if (c == null) {
  82.             c = true; // default true
  83.         }
  84.         if (c && !invoker.isAvailable()) {
  85.             throw new IllegalStateException("Failed to check the status of the service " + interfaceName + ". No provider available for the service " + (group == null ? "" : group + "/") + interfaceName + (version == null ? "" : ":" + version) + " from the url " + invoker.getUrl() + " to the consumer " + NetUtils.getLocalHost() + " use dubbo version " + Version.getVersion());
  86.         }
  87.         if (logger.isInfoEnabled()) {
  88.             logger.info("Refer dubbo service " + interfaceClass.getName() + " from url " + invoker.getUrl());
  89.         }
  90.         // create service proxy
  91.         return (T) proxyFactory.getProxy(invoker);
  92.     }

DubboProtocol

  1. public <T> Invoker<T> refer(Class<T> serviceType, URL url) throws RpcException {
  2.         optimizeSerialization(url);
  3.         // create rpc invoker.
  4.         DubboInvoker<T> invoker = new DubboInvoker<T>(serviceType, url, getClients(url), invokers);
  5.         invokers.add(invoker);
  6.         return invoker;
  7.     }

DubboInvoker

  1. public class DubboInvoker<T> extends AbstractInvoker<T> {
  2.     public DubboInvoker(Class<T> serviceType, URL url, ExchangeClient[] clients, Set<Invoker<?>> invokers) {
  3.         super(serviceType, url, new String[]{Constants.INTERFACE_KEY, Constants.GROUP_KEY, Constants.TOKEN_KEY, Constants.TIMEOUT_KEY});
  4.         this.clients = clients;
  5.         // get version.
  6.         this.version = url.getParameter(Constants.VERSION_KEY, "0.0.0");
  7.         this.invokers = invokers;
  8.     }
  10.     @Override
  11.     protected Result doInvoke(final Invocation invocation) throws Throwable {
  12.         RpcInvocation inv = (RpcInvocation) invocation;
  13.         final String methodName = RpcUtils.getMethodName(invocation);
  14.         inv.setAttachment(Constants.PATH_KEY, getUrl().getPath());
  15.         inv.setAttachment(Constants.VERSION_KEY, version);
  17.         ExchangeClient currentClient;
  18.         if (clients.length == 1) {
  19.             currentClient = clients[0];
  20.         } else {
  21.             currentClient = clients[index.getAndIncrement() % clients.length];
  22.         }
  23.         try {
  24.             boolean isAsync = RpcUtils.isAsync(getUrl(), invocation);
  25.             boolean isOneway = RpcUtils.isOneway(getUrl(), invocation);
  26.             int timeout = getUrl().getMethodParameter(methodName, Constants.TIMEOUT_KEY, Constants.DEFAULT_TIMEOUT);
  27.             if (isOneway) {
  28.                 boolean isSent = getUrl().getMethodParameter(methodName, Constants.SENT_KEY, false);
  29.                 currentClient.send(inv, isSent);
  30.                 RpcContext.getContext().setFuture(null);
  31.                 return new RpcResult();
  32.             } else if (isAsync) {
  33.                 ResponseFuture future = currentClient.request(inv, timeout);
  34.                 RpcContext.getContext().setFuture(new FutureAdapter<Object>(future));
  35.                 return new RpcResult();
  36.             } else {
  37.                 RpcContext.getContext().setFuture(null);
  38.                 return (Result) currentClient.request(inv, timeout).get();
  39.             }
  40.         } catch (TimeoutException e) {
  41.             throw new RpcException(RpcException.TIMEOUT_EXCEPTION, "Invoke remote method timeout. method: " + invocation.getMethodName() + ", provider: " + getUrl() + ", cause: " + e.getMessage(), e);
  42.         } catch (RemotingException e) {
  43.             throw new RpcException(RpcException.NETWORK_EXCEPTION, "Failed to invoke remote method: " + invocation.getMethodName() + ", provider: " + getUrl() + ", cause: " + e.getMessage(), e);
  44.         }
  45.     }

AbstractInvoker

  1. public Result invoke(Invocation inv) throws RpcException {
  2.         if (destroyed.get()) {
  3.             throw new RpcException("Rpc invoker for service " + this + " on consumer " + NetUtils.getLocalHost()
  4.                     + " use dubbo version " + Version.getVersion()
  5.                     + " is DESTROYED, can not be invoked any more!");
  6.         }
  7.         RpcInvocation invocation = (RpcInvocation) inv;
  8.         invocation.setInvoker(this);
  9.         if (attachment != null && attachment.size() > 0) {
  10.             invocation.addAttachmentsIfAbsent(attachment);
  11.         }
  12.         Map<String, String> context = RpcContext.getContext().getAttachments();
  13.         if (context != null) {
  14.             invocation.addAttachmentsIfAbsent(context);
  15.         }
  16.         if (getUrl().getMethodParameter(invocation.getMethodName(), Constants.ASYNC_KEY, false)) {
  17.             invocation.setAttachment(Constants.ASYNC_KEY, Boolean.TRUE.toString());
  18.         }
  19.         RpcUtils.attachInvocationIdIfAsync(getUrl(), invocation);
  22.         try {
  23.             return doInvoke(invocation);
  24.         } catch (InvocationTargetException e) { // biz exception
  25.             Throwable te = e.getTargetException();
  26.             if (te == null) {
  27.                 return new RpcResult(e);
  28.             } else {
  29.                 if (te instanceof RpcException) {
  30.                     ((RpcException) te).setCode(RpcException.BIZ_EXCEPTION);
  31.                 }
  32.                 return new RpcResult(te);
  33.             }
  34.         } catch (RpcException e) {
  35.             if (e.isBiz()) {
  36.                 return new RpcResult(e);
  37.             } else {
  38.                 throw e;
  39.             }
  40.         } catch (Throwable e) {
  41.             return new RpcResult(e);
  42.         }
  43.     }

doInvoke模板方法，子类DubboInvoker实现

Invoker接口，核心是invoke方法

  1. public interface Invoker<T> extends Node {
  3.     /**
  4.      * get service interface.
  5.      *
  6.      * @return service interface.
  7.      */
  8.     Class<T> getInterface();
  10.     /**
  11.      * invoke.
  12.      *
  13.      * @param invocation
  14.      * @return result
  15.      * @throws RpcException
  16.      */
  17.     Result invoke(Invocation invocation) throws RpcException;
  19. }

然后看createProxy方法的最后面,getProxy
AbstractProxyFactory

  1. public abstract class AbstractProxyFactory implements ProxyFactory {
  3.     public <T> T getProxy(Invoker<T> invoker) throws RpcException {
  4.         Class<?>[] interfaces = null;
  5.         String config = invoker.getUrl().getParameter("interfaces");
  6.         if (config != null && config.length() > 0) {
  7.             String[] types = Constants.COMMA_SPLIT_PATTERN.split(config);
  8.             if (types != null && types.length > 0) {
  9.                 interfaces = new Class<?>[types.length + 2];
  10.                 interfaces[0] = invoker.getInterface();
  11.                 interfaces[1] = EchoService.class;
  12.                 for (int i = 0; i < types.length; i++) {
  13.                     interfaces[i + 1] = ReflectUtils.forName(types[i]);
  14.                 }
  15.             }
  16.         }
  17.         if (interfaces == null) {
  18.             interfaces = new Class<?>[]{invoker.getInterface(), EchoService.class};
  19.         }
  20.         return getProxy(invoker, interfaces);
  21.     }
  23.     public abstract <T> T getProxy(Invoker<T> invoker, Class<?>[] types);
  25. }

JavassistProxyFactory

  1. public class JavassistProxyFactory extends AbstractProxyFactory {
  3.     @SuppressWarnings("unchecked")
  4.     public <T> T getProxy(Invoker<T> invoker, Class<?>[] interfaces) {
  5.         return (T) Proxy.getProxy(interfaces).newInstance(new InvokerInvocationHandler(invoker));
  6.     }
  8.     public <T> Invoker<T> getInvoker(T proxy, Class<T> type, URL url) {
  9.         // TODO Wrapper cannot handle this scenario correctly: the classname contains '$'
  10.         final Wrapper wrapper = Wrapper.getWrapper(proxy.getClass().getName().indexOf('$') < 0 ? proxy.getClass() : type);
  11.         return new AbstractProxyInvoker<T>(proxy, type, url) {
  12.             @Override
  13.             protected Object doInvoke(T proxy, String methodName,
  14.                                       Class<?>[] parameterTypes,
  15.                                       Object[] arguments) throws Throwable {
  16.                 return wrapper.invokeMethod(proxy, methodName, parameterTypes, arguments);
  17.             }
  18.         };
  19.     }
  21. }

发表评论

表情：
评论列表 （有 0 条评论，476人围观）

还没有评论，来说两句吧...

相关阅读