文章目錄

• 需求
• 工程
• java代碼實(shí)現(xiàn)細(xì)粒度配置 （不推薦）
• 配置實(shí)現(xiàn)細(xì)粒度配置 （推薦）
• 源碼

---

需求

假設(shè)我們有個(gè)場(chǎng)景:

Order-Center 需要采用隨機(jī)算法調(diào)用產(chǎn)品中心 ， 而采用輪詢算法調(diào)用其他中心微服務(wù)

---

工程

---

java代碼實(shí)現(xiàn)細(xì)粒度配置 （不推薦）

注意事項(xiàng)： PayCenterRibbonConfig，ProductCenterRibbonConfig不能被放在我們主啟動(dòng)類所在包以及子包下，不然就起不到細(xì)粒度配置

【支付中心對(duì)應(yīng)的Ribbon訪問策略】

package com.globalconfig;import com.netflix.loadbalancer.IRule; import com.netflix.loadbalancer.RoundRobinRule; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration;/*** @author 小工匠* @version 1.0* @description: TODO* @date 2022/2/2 19:42* @mark: show me the code , change the world*/ @Configuration public class PayCenterRibbonConfig {@Beanpublic IRule roundRobinRule() {return new RoundRobinRule();} }

【產(chǎn)品中心對(duì)應(yīng)的Ribbon訪問策略】

package com.globalconfig;import com.netflix.loadbalancer.IRule; import com.netflix.loadbalancer.RandomRule; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration;/*** @author 小工匠* @version 1.0* @description: TODO* @date 2022/2/2 19:45* @mark: show me the code , change the world*/ @Configuration public class ProductCenterRibbonConfig {@Beanpublic IRule randomRule() {return new RandomRule();} }

---

【帶有@LoadBalanced的RestTemplate】

package com.artisan.config;import org.springframework.cloud.client.loadbalancer.LoadBalanced; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.web.client.RestTemplate;/*** @author 小工匠* @version 1.0* @description: TODO* @date 2022/2/2 15:47* @mark: show me the code , change the world*/ @Configuration public class WebConfig {@Bean@LoadBalancedpublic RestTemplate restTemplate() {return new RestTemplate();}}

【為每個(gè)服務(wù)分配 訪問策略 】

package com.artisan.config;import org.springframework.cloud.netflix.ribbon.RibbonClient; import org.springframework.cloud.netflix.ribbon.RibbonClients; import org.springframework.context.annotation.Configuration;/*** @author 小工匠* @version 1.0* @description: TODO* @date 2022/2/2 19:51* @mark: show me the code , change the world*/@Configuration @RibbonClients(value = {@RibbonClient(name = "artisan-product-center",configuration = com.globalconfig.ProductCenterRibbonConfig.class),@RibbonClient(name = "artisan-pay-center",configuration = com.globalconfig.PayCenterRibbonConfig.class) }) public class CustomRibbonConfig { }

【Controller 】

import com.artisan.common.entity.OrderInfo; import com.artisan.common.entity.PayInfo; import com.artisan.common.entity.ProductInfo; import com.artisan.common.vo.OrderAndPayVo; import com.artisan.common.vo.OrderVo; import com.artisan.mapper.OrderInfoMapper; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.http.ResponseEntity; import org.springframework.web.bind.annotation.PathVariable; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; import org.springframework.web.client.RestTemplate;/*** @author 小工匠* @version 1.0* @description: TODO* @date 2022/2/2 03:20* @mark: show me the code , change the world*/ @RestController @Slf4j public class OrderInfoController {@Autowiredprivate RestTemplate restTemplate;@Autowiredprivate OrderInfoMapper orderInfoMapper;/*** 調(diào)用地址， 注冊(cè)中心 地址*/public static final String PRODUCT_URI = "http://artisan-product-center/selectProductInfoById/";public static final String PAY_URI = "http://artisan-pay-center/selectPayInfoByOrderNo/";@RequestMapping("/v2/selectOrderInfoById/{orderNo}")public Object selectOrderInfoById(@PathVariable("orderNo") String orderNo) {OrderInfo orderInfo = orderInfoMapper.selectOrderInfoById(orderNo);if (null == orderInfo) {return "根據(jù)orderNo:" + orderNo + "查詢沒有該訂單";}// 發(fā)起遠(yuǎn)程Http調(diào)用ResponseEntity<ProductInfo> responseEntity = restTemplate.getForEntity(PRODUCT_URI + orderInfo.getProductNo(), ProductInfo.class);ProductInfo productInfo = responseEntity.getBody();if (productInfo == null) {return "沒有對(duì)應(yīng)的商品";}OrderVo orderVo = new OrderVo();orderVo.setOrderNo(orderInfo.getOrderNo());orderVo.setUserName(orderInfo.getUserName());orderVo.setProductName(productInfo.getProductName());orderVo.setProductNum(orderInfo.getProductCount());return orderVo;}@RequestMapping("/getOrderAndPayInfoByOrderNo/{orderNo}")public Object getOrderAndPayInfoByOrderNo(@PathVariable("orderNo") String orderNo) {OrderInfo orderInfo = orderInfoMapper.selectOrderInfoById(orderNo);if (null == orderInfo) {return "根據(jù)orderNo:" + orderNo + "查詢沒有該訂單";}ResponseEntity<PayInfo> responseEntity = restTemplate.getForEntity(PAY_URI + orderInfo.getProductNo(), PayInfo.class);PayInfo payInfo = responseEntity.getBody();if (payInfo == null) {return "沒有對(duì)應(yīng)的支付信息";}OrderAndPayVo orderAndPayVo = new OrderAndPayVo();orderAndPayVo.setOrderNo(orderNo);orderAndPayVo.setProductNo(orderInfo.getProductNo());orderAndPayVo.setProductCount(orderInfo.getProductCount());orderAndPayVo.setPayNo(payInfo.getPayNo());orderAndPayVo.setPayTime(payInfo.getPayTime());orderAndPayVo.setUserName(orderInfo.getUserName());return orderAndPayVo;}}

可以看到，實(shí)現(xiàn)了我們最開始的需求 。

---

配置實(shí)現(xiàn)細(xì)粒度配置 （推薦）

接著上面的工程，首先屏蔽掉 CustomRibbonConfig

然后再 artisan-cloud-customcfg-ribbon-order 子模塊的配置文件 application.yml

增加

#自定義Ribbon的細(xì)粒度配置 artisan-pay-center:ribbon:NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RoundRobinRuleartisan-product-center:ribbon:NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule

然后啟動(dòng)多個(gè)Pay和Product服務(wù)進(jìn)行測(cè)試

結(jié)果如下：

訪問4次

訪問 10次

---

源碼

https://github.com/yangshangwei/SpringCloudAlibabMaster

總結(jié)

以上是生活随笔為你收集整理的Spring Cloud Alibaba - 08 Ribbon 两种方式实现细粒度自定义配置控制微服务的负载均衡策略的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。