Shulou(Shulou.com)06/02 Report--

This article mainly explains "what is the role of CachingSpringLoadBalancerFactory in spring cloud". The content of the explanation is simple and clear, and it is easy to learn and understand. Please follow the editor's train of thought to study and learn "what is the role of CachingSpringLoadBalancerFactory in spring cloud".

Order

This paper mainly studies the CachingSpringLoadBalancerFactory of spring cloud.

CachingSpringLoadBalancerFactory

SpringMurphy cloudlyopenfeignMuvecoreMuray 2.2.0.M1ripsources.jarmarketAccording orgAccording to springframeworkhand cloudhand openfeignbon ribbonCachingSpringLoadBalancerFactory.java

Public class CachingSpringLoadBalancerFactory {protected final SpringClientFactory factory; protected LoadBalancedRetryFactory loadBalancedRetryFactory = null; private volatile Map cache = new ConcurrentReferenceHashMap (); public CachingSpringLoadBalancerFactory (SpringClientFactory factory) {this.factory = factory;} public CachingSpringLoadBalancerFactory (SpringClientFactory factory, LoadBalancedRetryFactory loadBalancedRetryPolicyFactory) {this.factory = factory; this.loadBalancedRetryFactory = loadBalancedRetryPolicyFactory } public FeignLoadBalancer create (String clientName) {FeignLoadBalancer client = this.cache.get (clientName); if (client! = null) {return client;} IClientConfig config = this.factory.getClientConfig (clientName); ILoadBalancer lb = this.factory.getLoadBalancer (clientName) ServerIntrospector serverIntrospector = this.factory.getInstance (clientName, ServerIntrospector.class); client = this.loadBalancedRetryFactory! = null? New RetryableFeignLoadBalancer (lb, config, serverIntrospector, this.loadBalancedRetryFactory): new FeignLoadBalancer (lb, config, serverIntrospector); this.cache.put (clientName, client); return client;}}

The constructor of CachingSpringLoadBalancerFactory receives SpringClientFactory, LoadBalancedRetryFactory;, which provides a create method for creating a FeignLoadBalancer;, and its create method uses ConcurrentReferenceHashMap to cache the FeignLoadBalancer corresponding to each client.

LoadBalancerFeignClient

Springhouse cloudhouse openfeigncopyright corecome2.2.0.M1lysources.jarroomUniverse orgAccording frameworkhand cloudhand openfeignbon ribbonLoadBalancerFeignClient.java

Public class LoadBalancerFeignClient implements Client {static final Request.Options DEFAULT_OPTIONS = new Request.Options (); private final Client delegate; private CachingSpringLoadBalancerFactory lbClientFactory; private SpringClientFactory clientFactory; public LoadBalancerFeignClient (Client delegate, CachingSpringLoadBalancerFactory lbClientFactory, SpringClientFactory clientFactory) {this.delegate = delegate; this.lbClientFactory = lbClientFactory This.clientFactory = clientFactory;} static URI cleanUrl (String originalUrl, String host) {String newUrl = originalUrl; if (originalUrl.startsWith ("https://")) {newUrl = originalUrl.substring (0,8) + originalUrl.substring (8 + host.length () } else if (originalUrl.startsWith ("http")) {newUrl = originalUrl.substring (0,7) + originalUrl.substring (7 + host.length ());} StringBuffer buffer = new StringBuffer (newUrl) If ((newUrl.startsWith ("https://") & & newUrl.length () = = 8) | (newUrl.startsWith (" http://") & & newUrl.length () = = 7)) {buffer.append ("/");} return URI.create (buffer.toString () } @ Override public Response execute (Request request, Request.Options options) throws IOException {try {URI asUri = URI.create (request.url ()); String clientName = asUri.getHost (); URI uriWithoutHost = cleanUrl (request.url (), clientName) FeignLoadBalancer.RibbonRequest ribbonRequest = new FeignLoadBalancer.RibbonRequest (this.delegate, request, uriWithoutHost); IClientConfig requestConfig = getClientConfig (options, clientName); return lbClient (clientName) .executeWithLoadBalancer (ribbonRequest, requestConfig). ToResponse () } catch (ClientException e) {IOException io = findIOException (e); if (io! = null) {throw io;} throw new RuntimeException (e) }} IClientConfig getClientConfig (Request.Options options, String clientName) {IClientConfig requestConfig; if (options = = DEFAULT_OPTIONS) {requestConfig = this.clientFactory.getClientConfig (clientName);} else {requestConfig = new FeignOptionsClientConfig (options) } return requestConfig;} protected IOException findIOException (Throwable t) {if (t = = null) {return null;} if (t instanceof IOException) {return (IOException) t } return findIOException (t.getCause ());} public Client getDelegate () {return this.delegate;} private FeignLoadBalancer lbClient (String clientName) {return this.lbClientFactory.create (clientName) } static class FeignOptionsClientConfig extends DefaultClientConfigImpl {FeignOptionsClientConfig (Request.Options options) {setProperty (CommonClientConfigKey.ConnectTimeout, options.connectTimeoutMillis ()); setProperty (CommonClientConfigKey.ReadTimeout, options.readTimeoutMillis ()) } @ Override public void loadProperties (String clientName) {} @ Override public void loadDefaultValues () {}}

The lbClient method of LoadBalancerFeignClient uses the create method of CachingSpringLoadBalancerFactory to create the FeignLoadBalancer;, while the execute method calls the lbClient method to get the FeignLoadBalancer

Summary

The constructor of CachingSpringLoadBalancerFactory receives SpringClientFactory, LoadBalancedRetryFactory;, which provides a create method for creating a FeignLoadBalancer;, and its create method uses ConcurrentReferenceHashMap to cache the FeignLoadBalancer corresponding to each client.

Thank you for reading, the above is the content of "what is the role of CachingSpringLoadBalancerFactory in spring cloud". After the study of this article, I believe you have a deeper understanding of what the role of CachingSpringLoadBalancerFactory in spring cloud is, and the specific use needs to be verified in practice. Here is, the editor will push for you more related knowledge points of the article, welcome to follow!

Welcome to subscribe "Shulou Technology Information " to get latest news, interesting things and hot topics in the IT industry, and controls the hottest and latest Internet news, technology news and IT industry trends.