@FeignClient(name = "test", url="http://xxxx")
我如何在运行时更改feign的URL(url="http://xxxx")?因为URL只能在运行时确定。
@FeignClient(name = "test", url="http://xxxx")
我如何在运行时更改feign的URL(url="http://xxxx")?因为URL只能在运行时确定。
您可以添加一个未注释的URI参数(可能在运行时确定),并且该参数将作为请求的基本路径。例如:
您可以添加一个未注释的 URI 参数(可能在运行时确定),并且该参数将成为用于请求的基本路径。例如:
@FeignClient(name = "dummy-name", url = "https://this-is-a-placeholder.com")
public interface MyClient {
@PostMapping(path = "/create")
UserDto createUser(URI baseUrl, @RequestBody UserDto userDto);
}
然后使用方法如下:
@Autowired
private MyClient myClient;
...
URI determinedBasePathUri = URI.create("https://my-determined-host.com");
myClient.createUser(determinedBasePathUri, userDto);
这将向https://my-determined-host.com/create
发送一个POST
请求(来源)。
Feign有一种方法,在运行时提供动态的URL和端点。
必须按照以下步骤进行:
FeignClient
接口中,我们必须删除URL参数。 我们必须使用@RequestLine
注释来指定REST方法(GET、PUT、POST等):
@FeignClient(name="customerProfileAdapter")
public interface CustomerProfileAdaptor {
// @RequestMapping(method=RequestMethod.GET, value="/get_all")
@RequestLine("GET")
public List<Customer> getAllCustomers(URI baseUri);
// @RequestMapping(method=RequestMethod.POST, value="/add")
@RequestLine("POST")
public ResponseEntity<CustomerProfileResponse> addCustomer(URI baseUri, Customer customer);
@RequestLine("DELETE")
public ResponseEntity<CustomerProfileResponse> deleteCustomer(URI baseUri, String mobile);
}
@RestController
@Import(FeignClientsConfiguration.class)
public class FeignDemoController {
CustomerProfileAdaptor customerProfileAdaptor;
@Autowired
public FeignDemoController(Decoder decoder, Encoder encoder) {
customerProfileAdaptor = Feign.builder().encoder(encoder).decoder(decoder)
.target(Target.EmptyTarget.create(CustomerProfileAdaptor.class));
}
@RequestMapping(value = "/get_all", method = RequestMethod.GET)
public List<Customer> getAllCustomers() throws URISyntaxException {
return customerProfileAdaptor
.getAllCustomers(new URI("http://localhost:8090/customer-profile/get_all"));
}
@RequestMapping(value = "/add", method = RequestMethod.POST)
public ResponseEntity<CustomerProfileResponse> addCustomer(@RequestBody Customer customer)
throws URISyntaxException {
return customerProfileAdaptor
.addCustomer(new URI("http://localhost:8090/customer-profile/add"), customer);
}
@RequestMapping(value = "/delete", method = RequestMethod.POST)
public ResponseEntity<CustomerProfileResponse> deleteCustomer(@RequestBody String mobile)
throws URISyntaxException {
return customerProfileAdaptor
.deleteCustomer(new URI("http://localhost:8090/customer-profile/delete"), mobile);
}
}
@Value
或 @ConfigurationProperties
进行注入吗?我找不到如何做到这一点。 - WesternGun我不知道你是否根据多个配置文件使用Spring,例如像(dev、beta、prod等)。如果你依赖不同的yml或者properties文件,你可以这样定义FeignClient
:(@FeignClient(url = "${feign.client.url.TestUrl}", configuration = FeignConf.class)
)。
然后,你就可以定义:
...(以下内容需要补充)
feign:
client:
url:
TestUrl: http://dev:dev
在你的应用程序-dev.yml文件中
定义
feign:
client:
url:
TestUrl: http://beta:beta
在你的应用程序-beta.yml文件中(我更喜欢yml格式)。
......
感谢上帝。享受吧。
使用 feign.Target.EmptyTarget
@Bean
public BotRemoteClient botRemoteClient(){
return Feign.builder().target(Target.EmptyTarget.create(BotRemoteClient.class));
}
public interface BotRemoteClient {
@RequestLine("POST /message")
@Headers("Content-Type: application/json")
BotMessageRs sendMessage(URI url, BotMessageRq message);
}
botRemoteClient.sendMessage(new URI("http://google.com"), rq)
@Import(FeignClientsConfiguration.class)
class FooController {
private FooClient fooClient;
private FooClient adminClient;
@Autowired
public FooController(ResponseEntityDecoder decoder, SpringEncoder encoder, Client client) {
this.fooClient = Feign.builder().client(client)
.encoder(encoder)
.decoder(decoder)
.requestInterceptor(new BasicAuthRequestInterceptor("user", "user"))
.target(FooClient.class, "http://PROD-SVC");
this.adminClient = Feign.builder().client(client)
.encoder(encoder)
.decoder(decoder)
.requestInterceptor(new BasicAuthRequestInterceptor("admin", "admin"))
.target(FooClient.class, "http://PROD-SVC");
}
}
根据文档,可以手动创建Feign客户端。在接口中,您可以通过Spring注释更改URL。基本URI在yml Spring配置中进行配置。
@FeignClient(
name = "some.client",
url = "${some.serviceUrl:}",
configuration = FeignClientConfiguration.class
)
public interface SomeClient {
@GetMapping("/metadata/search")
String search(@RequestBody SearchCriteria criteria);
@GetMapping("/files/{id}")
StreamingResponseBody downloadFileById(@PathVariable("id") UUID id);
}
// source code of feign
Request targetRequest(RequestTemplate template) {
for (RequestInterceptor interceptor : requestInterceptors) {
interceptor.apply(template);
}
return target.apply(template);
}
public Request apply(RequestTemplate input) {
if (input.url().indexOf("http") != 0) {
input.target(url());
}
return input.request();
}
public class DynamicFeignUrlInterceptor implements RequestInterceptor {
@Override
public void apply(RequestTemplate template) {
if (isNotDynamicPath(template)) {
return;
}
template.target(getHost());
}
private boolean isNotDynamicPath(RequestTemplate template) {
// TODO Determine whether it is dynamic according to your logic
return false;
}
private String getHost() {
// use any host you want, host must be contained key word of 'http'
return "http://example.com";
}
}
像这样使用@PathVariable:
@Service
@FeignClient(name = "otherservicename", decode404 = true)
public interface myService {
@RequestMapping(method = RequestMethod.POST, value = "/basepath/{request-path}")
ResponseEntity<String> getResult(@RequestHeader("Authorization") String token,
@RequestBody HashMap<String, String> reqBody,
@PathVariable(value = "request-path") String requestPath);
}
然后从服务中构建动态URL路径并发送请求:
String requestPath = "approve-req";
ResponseEntity<String> responseEntity = myService.getResult(
token, reqBody, requestPath);
您的请求URL将为:"/basepath/approve-req"
我更喜欢通过配置构建Feign客户端,在运行时传递URL(在我的情况下,我从Consul发现服务中获取服务名称)
因此,我将扩展Feign目标类如下:
public class DynamicTarget<T> implements Target<T> {
private final CustomLoadBalancer loadBalancer;
private final String serviceId;
private final Class<T> type;
public DynamicTarget(String serviceId, Class<T> type, CustomLoadBalancer loadBalancer) {
this.loadBalancer = loadBalancer;
this.serviceId = serviceId;
this.type = type;
}
@Override
public Class<T> type() {
return type;
}
@Override
public String name() {
return serviceId;
}
@Override
public String url() {
return loadBalancer.getServiceUrl(name());
}
@Override
public Request apply(RequestTemplate requestTemplate) {
requestTemplate.target(url());
return requestTemplate.request();
}
}
var target = new DynamicTarget<>(Services.service_id, ExamsAdapter.class, loadBalancer);
package commxx;
import java.net.URI;
import java.net.URISyntaxException;
import feign.Client;
import feign.Feign;
import feign.RequestLine;
import feign.Retryer;
import feign.Target;
import feign.codec.Encoder;
import feign.codec.Encoder.Default;
import feign.codec.StringDecoder;
public class FeignTest {
public interface someItfs {
@RequestLine("GET")
String getx(URI baseUri);
}
public static void main(String[] args) throws URISyntaxException {
String url = "http://www.baidu.com/s?wd=ddd"; //ok..
someItfs someItfs1 = Feign.builder()
// .logger(new FeignInfoLogger()) // 自定义日志类,继承 feign.Logger
// .logLevel(Logger.Level.BASIC)// 日志级别
// Default(long period, long maxPeriod, int maxAttempts)
.client(new Client.Default(null, null))// 默认 http
.retryer(new Retryer.Default(5000, 5000, 1))// 5s超时,仅1次重试
// .encoder(Encoder)
// .decoder(new StringDecoder())
.target(Target.EmptyTarget.create(someItfs.class));
// String url = "http://localhost:9104/";
//
System.out.println(someItfs1.getx(new URI(url)));
}
}
path
(例如/create
)是否也可以是动态的? - lily@PathVariable
。更多信息请参见这里。 - Robert Jakubowski