22 feign 超时时间设置

关于雪崩效应：

默认情况下tomcat只有一个线程去处理客户端发送的所有请求。高并发情况下，如果客户端请求都在同一接口，tomcat的所有线程池去处理，导致其他接口服务访问不了，等待。

Tomcat有个线程池，每个线程去处理客户端发送每次请求。

1.业务描述
订单服务调用会员服务，服务服务处理逻辑代码中延迟1.5s，模拟处理业务逻辑

2.代码
2.1会员服务

package com.taotao.api.service.impl;
 
import com.fqyd.api.entity.User;
import com.fqyd.api.service.IMemberService;
import com.fqyd.util.BaseApiService;
import com.fqyd.util.BaseDataResult;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
 
/**
 * Description：
 * Author: wude
 * Date:  2019/7/25 15:36
 * Modified By:
 */
@RestController
public class MemberServiceImpl extends BaseApiService implements IMemberService {
 
    @RequestMapping("getUserInfo")
    @Override
    public BaseDataResult getUserInfo() {
        try {
            //延迟1.5s
            Thread.sleep(1500);
        } catch (Exception e) {
 
        }
        return setResultSuccess("订单服务调用会员接口成功...");
    }

package com.taotao.util;
 
/**
 * Description：
 * Author: wude
 * Date:  2019/8/6 12:01
 * Modified By:
 */
public class BaseApiService {
    public  BaseDataResult setResultErr(Integer code,String msg){
        return setResult(code,msg,null);
    }
 
    /**
     * 返回错误，可以传msg
     * @param msg
     * @return
     */
    public BaseDataResult setResultError(String msg){
        return setResult(500,msg,null);
    }
 
    /**
     * 返回成功，可以穿data
     * @param data
     * @return
     */
    public BaseDataResult setResultSuccess(Object data){
        return  setResult(200,"处理成功",data);
    }
 
    /**
     * 返回成功，没有data值
     * @return
     */
    public BaseDataResult setResultSuccess(){
        return  setResult(200,"处理成功",null);
    }
 
    public BaseDataResult setResultSuccess(String msg){
        return  setResult(200,msg,null);
    }
 
    public BaseDataResult setResult(Integer code,String msg,Object  data){
        return new BaseDataResult(code,msg,data);
    }
}

package com.taotao.api.service;
 
import com.fqyd.api.entity.User;
import com.fqyd.util.BaseDataResult;
import com.sun.xml.internal.org.jvnet.staxex.Base64Data;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
 
/**
 * Description：
 * Author: wude
 * Date:  2019/7/25 14:58
 * Modified By:
 */
@FeignClient("fqyd-member")
public interface IMemberService {
    /**
     * 获取会员信息
     * @param name
     * @return
     */
    @RequestMapping("getMember")
    public User getMember(@RequestParam("name") String name);
 
    @RequestMapping("/getUserInfo")
    public BaseDataResult getUserInfo();

fqyd-member会员服务的服务名

2.2订单服务

package com.taotao.api.feign;
 
import com.fqyd.api.entity.User;
import com.fqyd.api.service.IMemberService;
import org.springframework.cloud.openfeign.FeignClient;
 
/**
 * Description：
 * Author: wude
 * Date:  2019/8/1 10:35
 * Modified By:
 */
@FeignClient("fqyd-member")
public interface MemberServiceFeign  extends IMemberService {
 
}

package com.taotao.api.service.impl;
 
import com.fqyd.api.entity.User;
import com.fqyd.api.feign.MemberServiceFeign;
import com.fqyd.api.service.IOrderService;
import com.fqyd.util.BaseDataResult;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
 
/**
 * Description：
 * Author: wude
 * Date:  2019/7/25 17:39
 * Modified By:
 */
@RestController
public class OrderServiceImpl implements IOrderService {
    @Autowired
    private MemberServiceFeign memberServiceFeign;
 
 
    @RequestMapping("/orderToMemberUserInfo")
    @Override
    public BaseDataResult orderToMemberUserInfo() {
        return memberServiceFeign.getUserInfo();
    }
}

read time读取超时

解决方法：application.yml增加如下配置

###服务启动端口号
server:
  port: 8001
  tomcat:
    max-threads: 10
###服务名称(服务注册到eureka名称)
spring:
  application:
    name: app-itmayiedu-order
###服务注册到eureka地址
eureka:
  client:
    service-url:
      defaultZone: http://localhost:8100/eureka


    ###因为该应用为注册中心，不会注册自己
    register-with-eureka: true
    ###是否需要从eureka上获取注册信息
    fetch-registry: true
#ribbon的超时时间
ribbon:
  ReadTimeout: 5000
  ConnectTimeout: 5000