一、實例
1、配置feign
添加依賴
在maven的pom中添加feign
<code> <dependency>
<groupid>org.springframework.cloud/<groupid>
<artifactid>spring-cloud-starter-feign/<artifactid>
/<dependency>/<code>
配置啟用
在Application啟動類中添加@EnableFeignClients註解。
<code>@EnableEurekaClient
@EnableFeignClients
public class Application {
public static void main(String[] args) {
SpringApplication.run(Application.class, args);
}
}/<code>
2、新建feign
<code>@FeignClient(name = "SERVICE-NAME", url = "${***}")
public interface TestFeign {
}/<code>其中： name：微服務的名稱，一定要以eureka後臺配置的保持一致。 url：可以手動指定feign的調用地址 fallback：標記容錯後執行的類
在feign中定義接口的方式與正常接口並無差異，需注意參數名稱等保持一致。如：
<code> @RequestMapping(value = "/user/message", method = RequestMethod.POST)
JSONObject sendMessage(@RequestParam("userId") String userId, @RequestParam("content") String content);/<code>
3、調用feign
在ServiceImpl中注入feign接口，正常使用即可。
<code> @Autowired
TestFeign testFeign;/<code>
二、原理
如果不使用springcloud的相關組件，調用服務需要要走http，配置請求head、body，然後才能發起請求。獲得響應體後，還需解析等操作，十分繁瑣。
那為什麼feign的使用如此簡單輕量呢？
1、如何啟用
啟動配置上檢查是否有@EnableFeignClients註解，如果有該註解，則開啟包掃描，掃描為@FeignClient註解接口。掃描出該註解後，通過beanDefinition注入到IOC容器中，方便後續被調用使用。
在FeignClientsRegistrar中，registerFeignClients()完成了註冊feign的操作。
<code>public void registerFeignClients(AnnotationMetadata metadata, BeanDefinitionRegistry registry) {
ClassPathScanningCandidateComponentProvider scanner = this.getScanner();
scanner.setResourceLoader(this.resourceLoader);
Map<string> attrs = metadata.getAnnotationAttributes(EnableFeignClients.class.getName());
......
//遍歷該項目所需調用的服務
Iterator var17 = ((Set)basePackages).iterator();
while(var17.hasNext()) {
String basePackage = (String)var17.next();
Set<beandefinition> candidateComponents = scanner.findCandidateComponents(basePackage);
Iterator var21 = candidateComponents.iterator();
while(var21.hasNext()) {
BeanDefinition candidateComponent = (BeanDefinition)var21.next();
if (candidateComponent instanceof AnnotatedBeanDefinition) {
AnnotatedBeanDefinition beanDefinition = (AnnotatedBeanDefinition)candidateComponent;
//獲取feign中的詳細信息
AnnotationMetadata annotationMetadata = beanDefinition.getMetadata();
Map<string> attributes = annotationMetadata.getAnnotationAttributes(FeignClient.class.getCanonicalName());
String name = this.getClientName(attributes);
//註冊配置信息
this.registerClientConfiguration(registry, name, attributes.get("configuration"));
//註冊feign客戶端
this.registerFeignClient(registry, annotationMetadata, attributes);
}
}
}
}/<string>/<beandefinition>/<string>/<code>註冊feign客戶端，包括使用註解時配置的所有信息。
<code>private void registerFeignClient(BeanDefinitionRegistry registry, AnnotationMetadata annotationMetadata, Map<string> attributes) {
String className = annotationMetadata.getClassName();
BeanDefinitionBuilder definition = BeanDefinitionBuilder.genericBeanDefinition(FeignClientFactoryBean.class);
this.validate(attributes);
definition.addPropertyValue("url", this.getUrl(attributes));
definition.addPropertyValue("path", this.getPath(attributes));
String name = this.getName(attributes);
definition.addPropertyValue("name", name);
definition.addPropertyValue("type", className);
definition.addPropertyValue("decode404", attributes.get("decode404"));
definition.addPropertyValue("fallback", attributes.get("fallback"));
definition.addPropertyValue("fallbackFactory", attributes.get("fallbackFactory"));
definition.setAutowireMode(2);
String alias = name + "FeignClient";
AbstractBeanDefinition beanDefinition = definition.getBeanDefinition();
boolean primary = ((Boolean)attributes.get("primary")).booleanValue();
beanDefinition.setPrimary(primary);
String qualifier = this.getQualifier(attributes);
if (StringUtils.hasText(qualifier)) {
alias = qualifier;
}
BeanDefinitionHolder holder = new BeanDefinitionHolder(beanDefinition, className, new String[]{alias});
BeanDefinitionReaderUtils.registerBeanDefinition(holder, registry);
}/<string>/<code>2、如何發起請求
ReflectiveFeign內部使用了jdk的動態代理為目標接口生成了一個動態代理類，這裡會生成一個InvocationHandler(jdk動態代理原理)統一的方法攔截器，同時為接口的每個方法生成一個SynchronousMethodHandler攔截器，並解析方法上的 元數據，生成一個http請求模板。
在SynchronousMethodHandler類中生成RequestTemplate發起請求。
<code>public Object invoke(Object[] argv) throws Throwable {
RequestTemplate template = buildTemplateFromArgs.create(argv);
Retryer retryer = this.retryer.clone();
while (true) {
try {
return executeAndDecode(template);
} catch (RetryableException e) {
retryer.continueOrPropagate(e);
if (logLevel != Logger.Level.NONE) {
logger.logRetry(metadata.configKey(), logLevel);
}
continue;
}
}
}/<code><code>Object executeAndDecode(RequestTemplate template) throws Throwable {
Request request = targetRequest(template);
Response response;
long start = System.nanoTime();
try {
response = client.execute(request, options);
// ensure the request is set. TODO: remove in Feign 10
response.toBuilder().request(request).build();
} catch (IOException e) {
if (logLevel != Logger.Level.NONE) {
logger.logIOException(metadata.configKey(), logLevel, e, elapsedTime(start));
}
throw errorExecuting(request, e);
}
}/<code>發送http請求
<code> @Override
public Response execute(Request request, Options options) throws IOException {
HttpURLConnection connection = convertAndSend(request, options);
return convertResponse(connection).toBuilder().request(request).build();
}
HttpURLConnection convertAndSend(Request request, Options options) throws IOException {
final HttpURLConnection
connection =
(HttpURLConnection) new URL(request.url()).openConnection();
if (connection instanceof HttpsURLConnection) {
HttpsURLConnection sslCon = (HttpsURLConnection) connection;
if (sslContextFactory != null) {
sslCon.setSSLSocketFactory(sslContextFactory);
}
if (hostnameVerifier != null) {
sslCon.setHostnameVerifier(hostnameVerifier);
}
}
connection.setConnectTimeout(options.connectTimeoutMillis());
connection.setReadTimeout(options.readTimeoutMillis());
connection.setAllowUserInteraction(false);
connection.setInstanceFollowRedirects(true);
connection.setRequestMethod(request.method());
Collection<string> contentEncodingValues = request.headers().get(CONTENT_ENCODING);
boolean
gzipEncodedRequest =
contentEncodingValues != null && contentEncodingValues.contains(ENCODING_GZIP);
boolean
deflateEncodedRequest =
contentEncodingValues != null && contentEncodingValues.contains(ENCODING_DEFLATE);
boolean hasAcceptHeader = false;
Integer contentLength = null;
for (String field : request.headers().keySet()) {
if (field.equalsIgnoreCase("Accept")) {
hasAcceptHeader = true;
}
for (String value : request.headers().get(field)) {
if (field.equals(CONTENT_LENGTH)) {
if (!gzipEncodedRequest && !deflateEncodedRequest) {
contentLength = Integer.valueOf(value);
connection.addRequestProperty(field, value);
}
} else {
connection.addRequestProperty(field, value);
}
}
}
// Some servers choke on the default accept string.
if (!hasAcceptHeader) {
connection.addRequestProperty("Accept", "*/*");
}
if (request.body() != null) {
if (contentLength != null) {
connection.setFixedLengthStreamingMode(contentLength);
} else {
connection.setChunkedStreamingMode(8196);
}
connection.setDoOutput(true);
OutputStream out = connection.getOutputStream();
if (gzipEncodedRequest) {
out = new GZIPOutputStream(out);
} else if (deflateEncodedRequest) {
out = new DeflaterOutputStream(out);
}
try {
out.write(request.body());
} finally {
try {
out.close();
} catch (IOException suppressed) { // NOPMD
}
}
}
return connection;
}/<string>/<code>
三、小結
約定大於配置
JAVA進階架構程序員福利：我這裡還總結整理了比較全面的JAVA相關的面試資料，都已經整理成了
PDF版，這些都可以分享給大家，關注私信我：【806】，免費領取！
分享到:
閱讀更多 欣然1013 的文章
