日韩性视频-久久久蜜桃-www中文字幕-在线中文字幕av-亚洲欧美一区二区三区四区-撸久久-香蕉视频一区-久久无码精品丰满人妻-国产高潮av-激情福利社-日韩av网址大全-国产精品久久999-日本五十路在线-性欧美在线-久久99精品波多结衣一区-男女午夜免费视频-黑人极品ⅴideos精品欧美棵-人人妻人人澡人人爽精品欧美一区-日韩一区在线看-欧美a级在线免费观看

歡迎訪問 生活随笔!

生活随笔

當前位置: 首頁 > 编程资源 > 编程问答 >内容正文

编程问答

springcloud 服务与服务之间实现灰度发布 基于Aspect

發布時間:2025/3/19 编程问答 31 豆豆
生活随笔 收集整理的這篇文章主要介紹了 springcloud 服务与服务之间实现灰度发布 基于Aspect 小編覺得挺不錯的,現在分享給大家,幫大家做個參考.

灰度發布定義可查看我上一篇文章:基于zuul實現灰度發布

1、創建工程

創建三個工程:分別為:訂單、eureka、user-server

(1)order服務


order服務提供方,提供兩個服務,端口分別為:8080、8081,配置如下:

server:port: 8080 eureka:instance:metadata-map:version: v1client:service-url:defaultZone: http://localhost:7900/eureka spring:application:name: order --- spring:profiles: 8081 server:port: 8081 eureka:instance:metadata-map: #自定義元數據區version: v2


order服務為了測試提供一個controller,打印出各自的端口,代表訪問到不同的機器。如下:

@SpringBootApplication @RestController public class OrderApplication {@Value("${server.port}")private String port;public static void main(String[] args) {SpringApplication.run(OrderApplication.class, args);}@RequestMappingpublic String test(){return "port:" + port;} }

(2)eureka工程,就是一個普通的eureka server
(3)user-server工程

是另一個服務提供者。

調用關系圖:

從圖可看出use-server需要調用order服務。在調用接口時候需要實現灰度發布。

pom.xml配置如下:

<?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.3.11.RELEASE</version><relativePath/> <!-- lookup parent from repository --></parent><groupId>com.kingdee</groupId><artifactId>user-server</artifactId><version>0.0.1-SNAPSHOT</version><name>user-server</name><description>Demo project for Spring Boot</description><properties><java.version>1.8</java.version><spring-cloud.version>Hoxton.SR11</spring-cloud.version></properties><dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-client</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope><exclusions><exclusion><groupId>org.junit.vintage</groupId><artifactId>junit-vintage-engine</artifactId></exclusion></exclusions></dependency><dependency><groupId>io.jmnarloch</groupId><artifactId>ribbon-discovery-filter-spring-cloud-starter</artifactId><version>2.1.0</version></dependency></dependencies><dependencyManagement><dependencies><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-dependencies</artifactId><version>${spring-cloud.version}</version><type>pom</type><scope>import</scope></dependency></dependencies></dependencyManagement><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId></plugin></plugins></build></project>

啟動類代碼如下:

@SpringBootApplication @RestController public class UserServerApplication {public static void main(String[] args) {SpringApplication.run(UserServerApplication.class, args);}@LoadBalanced@Beanpublic RestTemplate restTemplate(){return new RestTemplate();}@RequestMappingpublic String test(){return "user-server";} } 使用切面編程,增加RequestAspect類: @Aspect @Component public class RequestAspect {@Pointcut("execution(* com.kingdee.userserver.controller..*Controller*.*(..))")private void anyMehtod() {}@Before(value = "anyMehtod()")public void before(JoinPoint joinPoint) {HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest();String version = request.getHeader("version");// 灰度規則 匹配的地方 查db,redis ====if (version.trim().equals("v2")) {RibbonFilterContextHolder.getCurrentContext().add("version", "v2");} else if (version.trim().equals("v1")) {RibbonFilterContextHolder.getCurrentContext().add("version", "v1");}} }

此時可看出被調用服務是需要配置元數據,可查看order的yml配置(order其實就是普通的一個基礎服務,order其他配置可查看我的上一篇:基于zuul實現的灰度發布):

server:port: 8080eureka:instance:metadata-map:version: v1client:service-url:defaultZone: http://localhost:7900/eurekaspring:application:name: server-order--- spring:profiles: 8081 server:port: 8081 eureka:instance:metadata-map:version: v2

controller類:

@RestController @RequestMapping("/test") public class TestCallOrderController {@Autowiredprivate RestTemplate restTemplate;@GetMapping("/call")public String testCall() {ResponseEntity<String> forEntity = restTemplate.getForEntity("http://SERVER-ORDER/order/getPort", String.class);String body = forEntity.getBody();return body;} }

yml配置文件:

server:port: 8001 eureka:client:service-url:defaultZone: http://localhost:7900/eureka spring:application:name: user-server

2、測試

使用http://localhost:8001/test/call訪問order接口,且在header上配置version=v2,則系統會永遠只訪問order服務元數據配置了version: v2的服務,如果header中的version配置成v1,則只訪問order服務元數據配置了version: v1的服務,其他情況則使用默認的負載均衡規則(輪詢)。

?

如果有問題,歡迎大家留言,一起探討,一起進步。

?

總結

以上是生活随笔為你收集整理的springcloud 服务与服务之间实现灰度发布 基于Aspect的全部內容,希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯,歡迎將生活随笔推薦給好友。