使用FeignClient调用远程服务时整合本地方法

简介: 使用FeignClient调用远程服务时整合本地方法

背景

包装一个用户服务,一部分功能需要调用远程服务,而另一部分功能调用本地方法,如:

@FeignClient(value="USER-SERVICE")
public interface RemoteUserService{
  @GetMapping("getUserByUserId")
  public User getUserByUserId(String userId);
}

public interface LocalUserService{
  public String getUserId();
}

@Service
public class LocalUserServiceImpl implements LocalUserService{
  @Autowired
  private HttpServletRequest request;
  public String getUserId(){
    return (String)request.getSession().getAttribute("user-id");
  }
}

为了简化篇幅,并没有处理异常。

当使用者使用这两个用户相关的服务,就需要自动装载两个Service:

@Autowired
private LocalUserService localUserService;

@Autowired
private RemoteUserService remoteUserService;

能不能简化一下呢?将两个服务整合。

尝试将本地方法加入Feign接口

@FeignClient(value="USER-SERVICE",fallback=UserServiceHystrix.class)
public interface UserService{
  @GetMapping("getUserByUserId")
  public User getUserByUserId(String userId);

  public String getUserId();
}

@Service
public class UserServiceHystrix implements UserService{
  @Autowired
  private HttpServletRequest request;

  public User getUserByUserId(String userId){
    return null;
  }

  public String getUserId(){
    return (String)request.getSession().getAttribute("user-id");
  }
}

Fail:

测试发现,UserService 接口中定义本地方法 getUserId() 编译器直接报错了,要求必须有Mapping注解。

尝试通过实现两个接口

换一个思路,回到最初,在熔断器中实现两个接口:

@FeignClient(value="USER-SERVICE",fallback=UserServiceHystrix.class)
public interface UserService{
  @GetMapping("getUserByUserId")
  public User getUserByUserId(String userId);
}

public interface LocalUserService extends RemoteUserService{
  public String getUserId();
}

@Service
public class UserServiceHystrix implements LocalUserService,RemoteUserService{
  @Autowired
  private HttpServletRequest request;

  public User getUserByUserId(String userId){
    return null;
  }

  public String getUserId(){
    return (String)request.getSession().getAttribute("user-id");
  }
}

Fail:

测试发现,本地方法正常,远程方法根本无效,好像就是一个本地方法,直接走到了熔断方法中。

IS -> HAS

让 RemoteUserService is LocalUserService 既然不行,那么就试试让 LocalUserService has RemoteUserService。

@FeignClient(value="USER-SERVICE",fallback=UserServiceHystrix.class)
public interface UserService{
  @GetMapping("getUserByUserId")
  public User getUserByUserId(String userId);
}

public interface LocalUserService extends RemoteUserService{
  public String getUserId();
}

@Service
public class UserServiceImpl implements LocalUserService,RemoteUserService{
  @Autowired
  private HttpServletRequest request;
  @Autowire
  private RemoteUserService remoteUserService;

  public User getUserByUserId(String userId){
    return remoteUserService.getUserByUserId(userId);
  }

  public String getUserId(){
    return (String)request.getSession().getAttribute("user-id");
  }
}

这样是可以的。编码时稍微麻烦了一点,使用时就清晰多了。

目录
相关文章
|
3月前
|
负载均衡 网络协议 Java
Eureka注册的服务间调用方法
【8月更文挑战第12天】Eureka注册的服务间调用方法
39 1
|
6月前
|
数据中心
Feign调用
Feign调用
31 0
|
6月前
|
XML JSON 网络协议
RPC远程服务如何调用
【2月更文挑战第12天】一个完整的 RPC 调用框架包括:通信框架、通信协议、序列化和反序列化三部分。
|
负载均衡 Java 数据处理
案例03-fegin调用报404问题
fegin调用报404问题
151 0
|
Java Spring 容器
Feign源码分析-接口如何发现并生成代理类
Feign源码分析-接口如何发现并生成代理类
188 0
Feign源码分析-接口如何发现并生成代理类
|
Dubbo Java 应用服务中间件
没有接口实现类代理
没有接口实现类代理
141 0
没有接口实现类代理
|
负载均衡 Nacos
一起用feign来调用接口(有源码)
nacos很好的兼容了feign,feign默认集成了Ribbon,所以Nacos下使用Feign就默认实现了负载均衡 一、测试结果
131 0
一起用feign来调用接口(有源码)
JDK动态代理为什么只能代理有接口的类?
JDK动态代理为什么只能代理有接口的类?
|
Dubbo Java 应用服务中间件
服务提供者里实现接口
服务提供者里实现接口
89 0