Feign的使用優化和抽取方式的服務構建。
一、Feign的抽取使用方式
將Feign的Client抽取為獨立模塊,並且把接口有關的POJO、默認的Feign配置都放到這個模塊中,提供給所有消費者使用。
項目結構如下:
- cloud-demo (父工程)
- feign-api (子模塊)
- order-service (子模塊)
- user-service (子模塊)
案例使用Nacos進行發現、配置和管理微服務
父工程依賴如下:
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
<java.version>1.8</java.version>
<spring-cloud.version>Hoxton.SR10</spring-cloud.version>
<mysql.version>5.1.47</mysql.version>
<mybatis.version>2.1.1</mybatis.version>
</properties>
<dependencyManagement>
<dependencies>
<!-- springCloud -->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-dependencies</artifactId>
<version>${spring-cloud.version}</version>
<type>pom</type>
<scope>import</scope>
</dependency>
<!-- mysql驅動 -->
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>${mysql.version}</version>
</dependency>
<!--mybatis-->
<dependency>
<groupId>org.mybatis.spring.boot</groupId>
<artifactId>mybatis-spring-boot-starter</artifactId>
<version>${mybatis.version}</version>
</dependency>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-api</artifactId>
<version>1.7.36</version>
</dependency>
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-alibaba-dependencies</artifactId>
<version>2.2.6.RELEASE</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>
<dependencies>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
</dependency>
</dependencies>
1)抽取
首先創建一個模塊,命名為feign-api:
在feign-api中引入feign的starter依賴:
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>
然後,將服務消費者order-service中編寫的UserClient、User、DefaultFeignConfiguration都複製到feign-api項目中:
UserClient:
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
@FeignClient("userservice")
public interface UserClient {
@GetMapping("/user/{id}")
public User getById(@PathVariable("id") Long id);
}
Feign的日誌級別配置DefaultFeignConfiguration:
import feign.Logger;
import org.springframework.context.annotation.Bean;
public class DefaultFeignConfiguration {
@Bean
public Logger.Level feignLogLevel(){
return Logger.Level.BASIC; // 日誌級別為BASIC
}
}
User實體類:
import lombok.Data;
@Data
public class User {
private Long id;
private String username;
private String address;
}
2)在order-service中使用feign-api
首先,刪除order-service中的UserClient、User、DefaultFeignConfiguration等類或接口。
修改order-service中的所有與上述三個組件有關的導包部分,改成導入feign-api中的包。
在order-service的pom文件中中引入feign-api的依賴:
<dependency>
<groupId>cloud-demo</groupId>
<artifactId>feign-api</artifactId>
<version>1.0</version>
</dependency>
3)在order-service啓動類中指定掃描包
@Slf4j
//開啓feign功能
@EnableFeignClients(
clients = {UserClient.class},
defaultConfiguration = DefaultFeignConfiguration.class
) //指定需要加載的Client接口 和 全局生效默認配置(日誌級別的配置)
@SpringBootApplication
public class OrderApplication {
public static void main(String[] args) {
SpringApplication.run(OrderApplication.class, args);
log.info("項目已經啓動!");
}
}
或者,直接使用包掃描,指定feign-api模塊中clients所在包路徑:
@EnableFeignClients(basePackages = "com.zp.feign.clients")
4) 測試
order-service模塊下的 OrderController:
@RestController
@RequestMapping("order")
public class OrderController {
@Autowired
private OrderService orderService;
@GetMapping("{orderId}")
public Order queryOrderByUserId(@PathVariable("orderId") Long orderId) {
// 根據id查詢訂單並返回
return orderService.queryOrderById(orderId);
}
}
order-service模塊下的 OrderService:
@Service
public class OrderService {
@Autowired
private OrderMapper orderMapper;
@Autowired
private UserClient userClient;
/**
* 使用Feign客户端進行遠程調用
* @param orderId
* @return
*/
public Order queryOrderById(Long orderId) {
// 1.查詢訂單
Order order = orderMapper.findById(orderId);
// 2.遠程調用
User user = userClient.getById(order.getUserId());
// 3.存入order
order.setUser(user);
// 4.返回
return order;
}
}
order-service模塊下的 OrderMapper:
@Mapper
public interface OrderMapper {
@Select("select * from tb_order where id = #{id}")
Order findById(Long id);
}
order-service模塊下的 Order實體類:
@Data
public class Order {
private Long id;
private Long price;
private String name;
private Integer num;
private Long userId;
private User user;
}
order-service模塊下的 application.yml配置文件 Feign相關配置:
#無
啓動order-service服務和user-service服務,進行測試。
二、Feign的使用優化
Feign底層發起http請求,依賴於其它的框架。
其底層客户端實現包括:
- URLConnection:默認實現,不支持連接池
- Apache HttpClient :支持連接池
- OKHttp:支持連接池
因此提高Feign的性能主要手段就是使用連接池代替默認的URLConnection。
這裏我們用Apache的HttpClient來演示。
步驟:
① 引入feign-httpClient依賴
② 配置文件開啓httpClient功能,設置連接池參數
1)引入依賴
在order-service模塊的pom文件中引入Apache的HttpClient依賴:
<!--httpClient的依賴 -->
<dependency>
<groupId>io.github.openfeign</groupId>
<artifactId>feign-httpclient</artifactId>
</dependency>
2)配置連接池
在order-service模塊的application.yml中添加配置:
feign:
httpclient:
enabled: true # 開啓feign對HttpClient的支持
max-connections: 200 # 最大的連接數
max-connections-per-route: 50 # 每個路徑的最大連接數
3) 測試
接下來,在FeignClientFactoryBean中的loadBalance方法中打斷點。
Debug方式啓動order-service服務,可以看到這裏的client,底層就是Apache HttpClient:
4) 總結
Feign的優化:
- 日誌級別儘量用basic
- 使用HttpClient或OKHttp代替URLConnection