首页 站长快讯正文

Springcloud实战遇到的问题及解决方式

admin 站长快讯 2022-11-18 14:12:43 1092 0

​​​目录

1.Feign与hystrix使用不会看到错误信息代理检测线程异常,需要先屏蔽。

2.springcloud之Feign、hystrix、ribbon设置超时时间和重试机制(微服务)。

3.feign调用远程服务,并发数量达到一定时会出直接触发hystrix fallbanck方法,原因为hystrix线程池配置问题。

4.ribbom重试MaxAutoRetriesNextServer会带来幂等性问题,尽量慎用。

5.zuul超时配置。

6.zuul中hystrix熔断器配置。

7.高可用配置中心失效

1.Feign与hystrix使用不会看到错误信息,需要先屏蔽。

2.springcloud之Feign、hystrix、ribbon设置超时时间和重试机制(微服务)。

protected static int getRibbonTimeout(IClientConfig config, String commandKey) {		
  int ribbonTimeout;		
  if (config == null) {			
    ribbonTimeout = RibbonClientConfiguration.DEFAULT_READ_TIMEOUT + RibbonClientConfiguration.DEFAULT_CONNECT_TIMEOUT;		
  } else {			
    int ribbonReadTimeout = getTimeout(config, commandKey, "ReadTimeout",	IClientConfigKey.Keys.ReadTimeout, RibbonClientConfiguration.DEFAULT_READ_TIMEOUT);			
    int ribbonConnectTimeout = getTimeout(config, commandKey, "ConnectTimeout",	IClientConfigKey.Keys.ConnectTimeout, RibbonClientConfiguration.DEFAULT_CONNECT_TIMEOUT);			
    int maxAutoRetries = getTimeout(config, commandKey, "MaxAutoRetries",	IClientConfigKey.Keys.MaxAutoRetries, DefaultClientConfigImpl.DEFAULT_MAX_AUTO_RETRIES);			
    int maxAutoRetriesNextServer = getTimeout(config, commandKey, "MaxAutoRetriesNextServer",	IClientConfigKey.Keys.MaxAutoRetriesNextServer, DefaultClientConfigImpl.DEFAULT_MAX_AUTO_RETRIES_NEXT_SERVER);			
    ribbonTimeout = (ribbonReadTimeout + ribbonConnectTimeout) * (maxAutoRetries + 1) * (maxAutoRetriesNextServer + 1);		
  }		
  return ribbonTimeout;	
}

公式:

ribbonTimeout = (ribbonReadTimeout + ribbonConnectTimeout) * (maxAutoRetries + 1) * (maxAutoRetriesNextServer + 1);

下面就是:ribbon重试 (3000+3000)*(1+1)*(1+1)=24秒(hystrix的24秒)

#hystrix的超时时间
hystrix:    
     command:        
          default:            
               execution:              
                   timeout:                
                      enabled: true              
                      isolation:                    
                         thread:                        
                            timeoutInMilliseconds: 24000 #超时时间24秒
ribbon:  
    ReadTimeout: 3000 #时间3秒  
    ConnectTimeout: 3000  
    MaxAutoRetries: 1 
    #同一台实例最大重试次数,不包括首次调用  
    MaxAutocRetriesNextServer: 1 
    #重试负载均衡其他的实例最大重试次数,不包括首次调用  
    OkToRetryOnAllOperations: false  
    #是否所有操作都重试 

3.feign调用远程服务,并发数量达到一定时会出直接触发hystrix fallbanck方法,原因为hystrix线程池配置问题。

实战测试:

参数详解:

修改coreSize,maxQueueSize,queueSizeRejectionThreshold(主要)参数

ribbon:  
       #Ribbon允许最大连接数,即所有后端微服务实例请求并发数之和的最大值。  
       MaxTotalConnections: 500  
       #单个后端微服务实例能接收的最大请求并发数    
       MaxConnectionsPerHost: 500  
       ReadTimeout: 1000  
       ConnectTimeout: 1000  
       # 关闭Ribbon的重试机制  
       MaxAutoRetriesNextServer: 1  
       #hystrix 配置
hystrix:  
      threadpool:    
          default:      
              coreSize: 20 
              #并发执行的最大线程数,默认10      
              maxQueueSize: 500 
              #BlockingQueue的最大队列数,默认值-1      
              queueSizeRejectionThreshold: 500 
              #即使maxQueueSize没有达到,达到queueSizeRejectionThreshold该值后,请求也会被拒绝,默认值5  
              command:    
                  default:      
                      execution:        
                          timeout:        
                             #如果enabled设置为false,则请求超时交给ribbon控制          
                             enabled: true        
                             isolation:          
                                 thread:            
                                     timeoutInMilliseconds: 4000

4.ribbom重试MaxAutoRetriesNextServer会带来幂等性问题代理检测线程异常,尽量慎用。

5.zuul超时配置。

官网:#_zuul_timeouts

8.14 Zuul TimeoutsIf you want to configure the socket timeouts and read timeouts for requests proxied through Zuul, you have two options, based on your configuration: If Zuul uses service discovery, you need to configure these timeouts with the ribbon.ReadTimeout and ribbon.SocketTimeout Ribbon properties.If you have configured Zuul routes by specifying URLs, you need to use zuul.host.connect-timeout-millis and zuul.host.socket-timeout-millis.

如果要配置通过zuul代理的请求的连接超时和读取超时,根据您的配置,
您有两个选项:
    如果zuul使用服务发现,则需要使用Ribbon.ReadTimeout和Ribbon.SocketTimeout功能区属性配置这些超时。 
    如果通过指定URL配置了zuul路由,则需要使用zuul.host.connect-timeout-millis和zuul.host.socket-timeout-millis。

6.zuul中hystrix熔断器配置。

package com.gateway.fallback; 
import java.io.ByteArrayInputStream;
import java.io.IOException;
import java.io.InputStream; 
import org.springframework.cloud.netflix.zuul.filters.route.FallbackProvider;
import org.springframework.http.HttpHeaders;
import org.springframework.http.HttpStatus;
import org.springframework.http.MediaType;
import org.springframework.http.client.ClientHttpResponse;
import org.springframework.stereotype.Component; 
import com.common.msg.CodeMsg;
import com.common.msg.RrcResponse;
import com.common.util.JsonUtil; 
import lombok.extern.slf4j.Slf4j; 
@Component
@Slf4j
public class CommonFallbackProvider implements FallbackProvider{ 	
  @Override	
  public String getRoute() {		return "*";	} 	
  @Override	
  public ClientHttpResponse fallbackResponse(String route, Throwable cause) {		
    return new ClientHttpResponse() {            
      @Override            
      public HttpStatus getStatusCode() throws IOException {                
        return HttpStatus.OK;            
      }             
      @Override            
      public int getRawStatusCode() throws IOException {                
        return 200;            
      }             
      @Override            
      public String getStatusText() throws IOException {                
        return "OK";            
      }             
      @Override            
      public void close() {             
      }             
      @Override            
      public InputStream getBody() throws IOException {            	
        //增加zuul找不到服务异常返回信息            	
        log.info("---zuul找不到服务器----");               
        return new ByteArrayInputStream(JsonUtil.toJson(new RrcResponse(CodeMsg.POC_ERROR_ZUUL.getCode(), CodeMsg.POC_ERROR_ZUUL.getMsg(), null)).getBytes("UTF-8"));           
      }             
      @Override            
      public HttpHeaders getHeaders() {                
        HttpHeaders headers = new HttpHeaders();                
        headers.setContentType(MediaType.APPLICATION_JSON_UTF8);                
        return headers;            
      }        
    };	
  }}

7.高可用配置中心失效

如果使用hosts配置,preferIpAddress=true,节约了地址解析的损耗。当preferIpAddress=false,不同ip地址相互配置进行高可用。

原文链接:

打赏
hystrix高可用
版权声明

本文仅代表作者观点,不代表本站立场。
本文系作者授权发表,未经许可,不得转载。

发表评论

评论列表(0人评论 , 1092人围观)
☹还没有评论,来说两句吧...