SPI常用动态自适应代理类源码

Protocol$Adaptive

public class Protocol$Adaptive implements Protocol {public void destroy() {throw new UnsupportedOperationException("The method public abstract void org.apache.dubbo.rpc.Protocol.destroy() of interface org.apache.dubbo.rpc.Protocol is not adaptive method!");}public int getDefaultPort() {throw new UnsupportedOperationException("The method public abstract int org.apache.dubbo.rpc.Protocol.getDefaultPort() of interface org.apache.dubbo.rpc.Protocol is not adaptive method!");}public Exporter export(Invoker arg0) throws org.apache.dubbo.rpc.RpcException {if (arg0 == null) throw new IllegalArgumentException("org.apache.dubbo.rpc.Invoker argument == null");if (arg0.getUrl() == null)throw new IllegalArgumentException("org.apache.dubbo.rpc.Invoker argument getUrl() == null");URL url = arg0.getUrl();String extName = (url.getProtocol() == null ? "dubbo" : url.getProtocol());if (extName == null)throw new IllegalStateException("Failed to get extension (org.apache.dubbo.rpc.Protocol) name from url (" + url.toString() + ") use keys([protocol])");Protocol extension = (Protocol) ExtensionLoader.getExtensionLoader(Protocol.class).getExtension(extName);return extension.export(arg0);}public org.apache.dubbo.rpc.Invoker refer(java.lang.Class arg0, org.apache.dubbo.common.URL arg1) throws org.apache.dubbo.rpc.RpcException {if (arg1 == null) throw new IllegalArgumentException("url == null");URL url = arg1;String extName = (url.getProtocol() == null ? "dubbo" : url.getProtocol());if (extName == null)throw new IllegalStateException("Failed to get extension (org.apache.dubbo.rpc.Protocol) name from url (" + url.toString() + ") use keys([protocol])");Protocol extension = (Protocol) ExtensionLoader.getExtensionLoader(Protocol.class).getExtension(extName);return extension.refer(arg0, arg1);}
}

Cluster$Adaptive

public class Cluster$Adaptive implements Cluster {public Invoker join(Directory arg0) throws RpcException {if (arg0 == null) throw new IllegalArgumentException("org.apache.dubbo.rpc.cluster.Directory argument == null");if (arg0.getUrl() == null) throw new IllegalArgumentException("org.apache.dubbo.rpc.cluster.Directory argument getUrl() == null");URL url = arg0.getUrl();String extName = url.getParameter("cluster", "failover");if(extName == null) throw new IllegalStateException("Failed to get extension (org.apache.dubbo.rpc.cluster.Cluster) name from url (" + url.toString() + ") use keys([cluster])");Cluster extension = (Cluster)ExtensionLoader.getExtensionLoader(Cluster.class).getExtension(extName);return extension.join(arg0);}
}

ProxyFactory$Adaptive

public class ProxyFactory$Adaptive implements  ProxyFactory {public Object getProxy( Invoker arg0) throws RpcException {if (arg0 == null) throw new IllegalArgumentException("org.apache.dubbo.rpc.Invoker argument == null");if (arg0.getUrl() == null)throw new IllegalArgumentException("org.apache.dubbo.rpc.Invoker argument getUrl() == null");URL url = arg0.getUrl();String extName = url.getParameter("proxy", "javassist");if (extName == null)throw new IllegalStateException("Failed to get extension (org.apache.dubbo.rpc.ProxyFactory) name from url (" + url.toString() + ") use keys([proxy])");ProxyFactory extension = (ProxyFactory) ExtensionLoader.getExtensionLoader(ProxyFactory.class).getExtension(extName);return extension.getProxy(arg0);}public Object getProxy(Invoker arg0, boolean arg1) throws RpcException {if (arg0 == null) throw new IllegalArgumentException("org.apache.dubbo.rpc.Invoker argument == null");if (arg0.getUrl() == null)throw new IllegalArgumentException("org.apache.dubbo.rpc.Invoker argument getUrl() == null");URL url = arg0.getUrl();String extName = url.getParameter("proxy", "javassist");if (extName == null)throw new IllegalStateException("Failed to get extension (org.apache.dubbo.rpc.ProxyFactory) name from url (" + url.toString() + ") use keys([proxy])");ProxyFactory extension = (ProxyFactory) ExtensionLoader.getExtensionLoader(ProxyFactory.class).getExtension(extName);return extension.getProxy(arg0, arg1);}public Invoker getInvoker(Object arg0, java.lang.Class arg1, URL arg2) throws org.apache.dubbo.rpc.RpcException {if (arg2 == null) throw new IllegalArgumentException("url == null");URL url = arg2;String extName = url.getParameter("proxy", "javassist");if (extName == null)throw new IllegalStateException("Failed to get extension (org.apache.dubbo.rpc.ProxyFactory) name from url (" + url.toString() + ") use keys([proxy])");ProxyFactory extension = (ProxyFactory) ExtensionLoader.getExtensionLoader(ProxyFactory.class).getExtension(extName);return extension.getInvoker(arg0, arg1, arg2);}
}

ZookeeperTransporter$Adaptive

public class ZookeeperTransporter$Adaptive implements ZookeeperTransporter {public ZookeeperClient connect(URL arg0) {if (arg0 == null) throw new IllegalArgumentException("url == null");URL url = arg0;String extName = url.getParameter("client", url.getParameter("transporter", "curator"));if (extName == null)throw new IllegalStateException("Failed to get extension (org.apache.dubbo.remoting.zookeeper.ZookeeperTransporter) name from url (" + url.toString() + ") use keys([client, transporter])");ZookeeperTransporter extension = (ZookeeperTransporter) ExtensionLoader.getExtensionLoader(ZookeeperTransporter.class).getExtension(extName);return extension.connect(arg0);}
}

RegistryFactory$Adaptive

public class RegistryFactory$Adaptive implements RegistryFactory {public Registry getRegistry(URL arg0) {if (arg0 == null) throw new IllegalArgumentException("url == null");URL url = arg0;String extName = (url.getProtocol() == null ? "dubbo" : url.getProtocol());if (extName == null)throw new IllegalStateException("Failed to get extension (org.apache.dubbo.registry.RegistryFactory) name from url (" + url.toString() + ") use keys([protocol])");RegistryFactory extension = (RegistryFactory) ExtensionLoader.getExtensionLoader(RegistryFactory.class).getExtension(extName);return extension.getRegistry(arg0);}
}

RouterFactory$Adaptive

import org.apache.dubbo.common.URL;
import org.apache.dubbo.common.extension.ExtensionLoader;
import org.apache.dubbo.rpc.cluster.Router;
import org.apache.dubbo.rpc.cluster.RouterFactory;public class RouterFactory$Adaptive implements org.apache.dubbo.rpc.cluster.RouterFactory {public Router getRouter(URL arg0) {if (arg0 == null) throw new IllegalArgumentException("url == null");org.apache.dubbo.common.URL url = arg0;String extName = url.getProtocol();if (extName == null)throw new IllegalStateException("Failed to get extension (org.apache.dubbo.rpc.cluster.RouterFactory) name from url (" + url.toString() + ") use keys([protocol])");RouterFactory extension = (RouterFactory) ExtensionLoader.getExtensionLoader(RouterFactory.class).getExtension(extName);return extension.getRouter(arg0);}
}

ConfiguratorFactory$Adaptive

import org.apache.dubbo.common.URL;
import org.apache.dubbo.common.extension.ExtensionLoader;
import org.apache.dubbo.rpc.cluster.Configurator;
import org.apache.dubbo.rpc.cluster.ConfiguratorFactory;public class ConfiguratorFactory$Adaptive implements ConfiguratorFactory {public Configurator getConfigurator(URL arg0) {if (arg0 == null) throw new IllegalArgumentException("url == null");URL url = arg0;String extName = url.getProtocol();if (extName == null)throw new IllegalStateException("Failed to get extension (org.apache.dubbo.rpc.cluster.ConfiguratorFactory) name from url (" + url.toString() + ") use keys([protocol])");ConfiguratorFactory extension = ExtensionLoader.getExtensionLoader(ConfiguratorFactory.class).getExtension(extName);return extension.getConfigurator(arg0);}
}

Transporter$Adaptive

import org.apache.dubbo.common.URL;
import org.apache.dubbo.common.extension.ExtensionLoader;
import org.apache.dubbo.remoting.ChannelHandler;
import org.apache.dubbo.remoting.Client;
import org.apache.dubbo.remoting.RemotingException;
import org.apache.dubbo.remoting.Server;
import org.apache.dubbo.remoting.Transporter;public class Transporter$Adaptive implements Transporter {public Client connect(URL arg0, ChannelHandler arg1) throws RemotingException {if (arg0 == null) throw new IllegalArgumentException("url == null");URL url = arg0;String extName = url.getParameter("client", url.getParameter("transporter", "netty"));if (extName == null)throw new IllegalStateException("Failed to get extension (org.apache.dubbo.remoting.Transporter) name from url (" + url.toString() + ") use keys([client, transporter])");Transporter extension = ExtensionLoader.getExtensionLoader(Transporter.class).getExtension(extName);return extension.connect(arg0, arg1);}public Server bind(URL arg0, ChannelHandler arg1) throws RemotingException {if (arg0 == null) throw new IllegalArgumentException("url == null");URL url = arg0;String extName = url.getParameter("server", url.getParameter("transporter", "netty"));if (extName == null)throw new IllegalStateException("Failed to get extension (org.apache.dubbo.remoting.Transporter) name from url (" + url.toString() + ") use keys([server, transporter])");Transporter extension = (Transporter) ExtensionLoader.getExtensionLoader(Transporter.class).getExtension(extName);return extension.bind(arg0, arg1);}
}

Dispatcher$Adaptive

public class Dispatcher$Adaptive implements Dispatcher {public ChannelHandler dispatch(ChannelHandler arg0, URL arg1) {if (arg1 == null) throw new IllegalArgumentException("url == null");URL url = arg1;String extName = url.getParameter("dispatcher", url.getParameter("dispather", url.getParameter("channel.handler", "all")));if (extName == null)throw new IllegalStateException("Failed to get extension (org.apache.dubbo.remoting.Dispatcher) name from url (" + url.toString() + ") use keys([dispatcher, dispather, channel.handler])");Dispatcher extension = (Dispatcher) ExtensionLoader.getExtensionLoader(Dispatcher.class).getExtension(extName);return extension.dispatch(arg0, arg1);}
}

ThreadPool$Adaptive

public class ThreadPool$Adaptive implements ThreadPool {public Executor getExecutor(URL arg0) {if (arg0 == null) throw new IllegalArgumentException("url == null");URL url = arg0;String extName = url.getParameter("threadpool", "fixed");if (extName == null)throw new IllegalStateException("Failed to get extension (org.apache.dubbo.common.threadpool.ThreadPool) name from url (" + url.toString() + ") use keys([threadpool])");ThreadPool extension = (ThreadPool) ExtensionLoader.getExtensionLoader(ThreadPool.class).getExtension(extName);return extension.getExecutor(arg0);}
}

MonitorFactory$Adaptive

public class MonitorFactory$Adaptive implements MonitorFactory {public Monitor getMonitor(URL arg0) {if (arg0 == null) throw new IllegalArgumentException("url == null");URL url = arg0;String extName = (url.getProtocol() == null ? "dubbo" : url.getProtocol());if (extName == null)throw new IllegalStateException("Failed to get extension (org.apache.dubbo.monitor.MonitorFactory) name from url (" + url.toString() + ") use keys([protocol])");MonitorFactory extension = (MonitorFactory) ExtensionLoader.getExtensionLoader(MonitorFactory.class).getExtension(extName);return extension.getMonitor(arg0);}
}