我正在使用 Eureka、Zuul 和 FeignClient 构建一个 Spring Cloud 项目(带有 Spring Boot 1.3.1 的 Brixton.M4),我正在尝试添加多租户支持(租户由子域标识:tenant1.myservice.com)。为此,我想以某种方式将原始子域与通过 Feign 从服务转发到另一个服务的请求一起传递,但我似乎无法找到正确的方法来做到这一点。
我所拥有的是一个客户端,它公开了一个@RestController,它调用一个@FeignClient 来与我的后端通信,该后端通过它自己的@RestController 向客户端公开服务器操作。
@FeignClient 在服务器上使用与我的@RestController 相同的接口:
@FeignClient(name = "product")
public interface ProductService extends IProductService {
}
我目前正在尝试做的是在 RequestInterceptor 中设置一个标头:
@Component
public class MultiTenancyRequestInterceptor implements RequestInterceptor {
private CurrentTenantProvider currentTenantProvider;
@Autowired
public MultiTenancyRequestInterceptor(CurrentTenantProvider currentTenantProvider) {
this.currentTenantProvider = currentTenantProvider;
}
@Override
public void apply(RequestTemplate template) {
try {
template.header("TENANT", currentTenantProvider.getTenant());
} catch (Exception e) {
// "oops"
}
}
}
我的提供者类是一个简单的组件,我试图在其中注入请求/会话范围 bean:
@Component
public class CurrentTenantProvider {
@Autowired
private CurrentTenant currentTenant;
//...
}
bean(我尝试了会话和请求范围):
@Bean
@Scope(value = WebApplicationContext.SCOPE_SESSION, proxyMode = ScopedProxyMode.TARGET_CLASS)
public CurrentTenant currentTenant() {
return new CurrentTenant();
}
在服务器上,我使用 Hibernate 多租户提供程序,它应该捕获标头值并使用它来定义要连接到哪个数据库:
@Autowired
private HttpServletRequest httpRequest;
@Override
public String resolveCurrentTenantIdentifier() {
return httpRequest.getHeader("TENANT");
}
似乎对服务器的 Feign 调用是在另一个线程中完成的,并且超出了传入的请求范围,所以我不确定如何传递该值。
当我在 RequestInterceptor 中对租户值进行硬编码时,一切正常,所以我知道其余部分工作正常。
我还查看了许多其他关于 Zuul “X-Forwaded-For” 标头的帖子,但在服务器上收到的请求中找不到它。我也尝试添加一个 ZuulFilter 以将主机名传递给下一个请求,但我看到的是 ZuulFilter 接收了对客户端的原始请求,我可以添加但当 Feign 请求发送到后端服务时不能添加,即使我在zuul中映射它(我想这是有意的?)。
我不太确定下一步是什么,希望能得到一些建议。