openfeign介紹
在微服務設計里,服務之間的調用是很正常的,通常我們使用httpClient來實現對遠程資源的調用,而這種方法需要知識服務的地址,業務接口地址等,而且需要等他開發完成后你才可以去調用它,這對於集成開發來說,不是什么好事 ,產生了A業務與B業務的強依賴性,那么我們如何進行解耦呢,答案就是openfeign框架,它與是springcloudy里的一部分。
springcloud的服務消費者指的就是服務間的調用,實現的方式有兩種:一種就是上一章講的restTemplate+ribbon,另一種就是本章要講的feign,feign默認集成了ribbon,所以feign也默認實現了負載均衡。
服務發現/注冊里的服務名
通過服務名來進行請求的發送要比配置域名發http更直觀,並且你不需要知道它的域名和端口,這也是各個微服務之前直觀調用的一種方式,而且A服務可以不依賴於B服務,只要知道接口簽名即可。
graph TD
B(服務b)-->C(eureka注冊中心)
D-->|在服務a中建立client服務名為服務b|E(openfeign服務端)
A(服務a)-->|配置某個服務中心的服務名稱|D(調用服務b的某個接口)
D-->C
添加包引用
'org.springframework.cloud:spring-cloud-starter-openfeign'
添加配置bootstrap.yml
feign:
client:
config:
default:
connectTimeout: 2000
readTimeout: 10000
2 定義profile相關配置
//默認的一些文件路徑的配置
sourceSets {
integTest {
java.srcDir file('src/test/java')
resources.srcDir file('src/test/resources')
}
}
task integTest(type: Test) {
testClassesDirs = sourceSets.test.output.classesDirs
classpath = sourceSets.test.runtimeClasspath
}
定義服務接口
定義偽方法,就是服務里的方法,你要知識方法參數和它的返回值,實現不用管,只在單元測試里MOCK就可以.
package test.lind.javaLindDay.feignClientDemo;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.context.annotation.Profile;
import org.springframework.web.bind.annotation.GetMapping;
/**
* 模擬其他服務.
*/
@Profile("!integTest")
@FeignClient(name = "serviceName",primary=false)
public interface MockClient {
@GetMapping(path = "/balanceSheet/{clientCode}")
String balanceSheet(String clientCode);
}
Profile的作用
profile就是環境變量,你在類上通過ActiveProfile去激活它,在使用它時,有過Profile注解來使用上,上面代碼中MockClient對象不能在integTest環境下使用。
添加MOCK實現,它是自動注入的,所以聲明@Bean注解
它是為了在單元測試環境下使用client,而又不希望與外部 網絡資源通訊,所以需要mock一下本地資源去實現client.
package test.lind.javaLindDay;
import static org.mockito.ArgumentMatchers.anyString;
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.when;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Profile;
import test.lind.javaLindDay.feignClientDemo.MockClient;
@Configuration
@Profile("integTest")
public class MockClientTest {
@Bean
@Primary
public MockClient mockClient() {
MockClient client = mock(MockClient.class);
when(client.balanceSheet(
anyString()))
.thenReturn("OK");
return client;
}
}
添加單元測試,注意在單元測試上一定要指定它的環境變量
package test.lind.javaLindDay;
import static org.junit.Assert.assertEquals;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.ActiveProfiles;
import org.springframework.test.context.junit4.SpringRunner;
import test.lind.javaLindDay.feignClientDemo.MockClient;
@RunWith(SpringRunner.class)
@SpringBootTest
//指定profile環境
@ActiveProfiles("integTest")
public class JavaLindDayApplicationTests {
@Autowired
MockClient mockClient;
@Test
public void testMockClient() {
assertEquals(mockClient.balanceSheet("OK"), "OK");
}
}
運行測試后,MockClient將會被注入,它將使用Mock實現類,因為只有Mock實現類的Profile是指向integtest環境的。
有了openfeign,以后開發服務對服務調用就可以解耦了!
feignClient發送multipart/form-data請求
- 需要先安裝插件,默認是不能發送文件流的
<dependencies>
...
<dependency>
<groupId>io.github.openfeign.form</groupId>
<artifactId>feign-form</artifactId>
<version>3.3.0</version>
</dependency>
<dependency>
<groupId>io.github.openfeign.form</groupId>
<artifactId>feign-form-spring</artifactId>
<version>3.3.0</version>
</dependency>
...
</dependencies>
- 添加bean
@FeignClient(name = "file-upload-service", configuration = FileUploadServiceClient.MultipartSupportConfig.class)
public interface FileUploadServiceClient extends IFileUploadServiceClient {
public class MultipartSupportConfig {
@Autowired
private ObjectFactory<HttpMessageConverters> messageConverters;
@Bean
public Encoder feignFormEncoder() {
return new SpringFormEncoder(new SpringEncoder(messageConverters));
}
}
}
如果不需要Spring標准的編碼,也可以這樣實現
@FeignClient(name = "file-upload-service", configuration = FileUploadServiceClient.MultipartSupportConfig.class)
public interface FileUploadServiceClient extends IFileUploadServiceClient {
public class MultipartSupportConfig {
@Bean
public Encoder feignFormEncoder() {
return new SpringFormEncoder();
}
}
}
- 添加注解
// File parameter
@RequestLine("POST /send_photo")
@Headers("Content-Type: multipart/form-data")
void sendPhoto (@Param("is_public") Boolean isPublic, @Param("photo") File photo);
// byte[] parameter
@RequestLine("POST /send_photo")
@Headers("Content-Type: multipart/form-data")
void sendPhoto (@Param("is_public") Boolean isPublic, @Param("photo") byte[] photo);
// FormData parameter
@RequestLine("POST /send_photo")
@Headers("Content-Type: multipart/form-data")
void sendPhoto (@Param("is_public") Boolean isPublic, @Param("photo") FormData photo);