Nacos整合SpringCloud | 帶你讀《Spring Cloud Alibaba（2019）》之四

本文來自於《精通Spring Cloud Alibaba》課程的整理，講師為餘勝軍，點擊查看視頻內容。
本文系志願者整理，供配合學習中心課程使用，不做商業用途。

Maven依賴信息

<parent>     <groupId>org.springframework.boot</groupId>     <artifactId>spring-boot-starter-parent</artifactId>     <version>2.0.0.RELEASE</version>

 </parent><dependencies>    <!--  springboot 整合web組件-->    <dependency>        <groupId>org.springframework.boot</groupId>        <artifactId>spring-boot-starter-web</artifactId>    </dependency>    <dependency>        <groupId>org.springframework.cloud</groupId>        <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>        <version>0.2.2.RELEASE</version>    </dependency></dependencies>

創建工程，需要選擇1.8

如何實現服務的註冊？

接口完成後，對會員進行註冊。
拿到配置文件，對項目命名

再進行代碼測試，自動實現對服務進行註冊

會員服務(生產者)

服務接口

@RestControllerpublic class MemberService {    @Value("${server.port}")    private String serverPort;    /**     * 會員服務提供的接口

 *     * @param userId     * @return     */    @RequestMapping("/getUser")    public String getUser(Integer userId) {        return "每特教育,端口號:" + serverPort;    }}

配置文件

application.yml文件

spring:  cloud:    nacos:      discovery:        ###服務註冊地址        server-addr: 127.0.0.1:8848  application:    name: mayikt-memberserver:  port: 8081

訂單服務(消費者)

訂單調用會員服務

@RestControllerpublic class OrderService {    @Autowired    private RestTemplate restTemplate;    @Autowired    private DiscoveryClient discoveryClient;    @Autowired    private LoadBalancer loadBalancer;

   /**     * 訂單調用會員服務     *     * @return     *///    @RequestMapping("/orderToMember")//    public String orderToMember() {//        // 從註冊中心上獲取該註冊服務列表//        List<ServiceInstance> serviceInstanceList = discoveryClient.getInstances("mayikt-member");//        ServiceInstance serviceInstance = serviceInstanceList.get(0);//        URI rpcMemberUrl = serviceInstance.getUri();//        // 使用本地rest形式實現rpc調用//        String result = restTemplate.getForObject(rpcMemberUrl + "/getUser", String.class);//        return "訂單調用會員獲取結果:" + result;//    }    @RequestMapping("/orderToMember")    public String orderToMember() {        // 從註冊中心上獲取該註冊服務列表        List<ServiceInstance> serviceInstanceList = discoveryClient.getInstances("mayikt-member");        ServiceInstance serviceInstance = loadBalancer.getSingleAddres(serviceInstanceList);        URI rpcMemberUrl = serviceInstance.getUri();        // 使用本地rest形式實現rpc調用        String result = restTemplate.getForObject(rpcMemberUrl + "/getUser", String.class);        return "訂單調用會員獲取結果:" + result;    }}

新建項目之後，第一步，根據服務名稱從註冊中心獲取集群列表地址
；第二步，根據列表任意選擇一個實現本地rpc調用rest

注意：RestTeanmlate它不是SpringCloud寫的，本身Spring支持Http協議調用實現Http 調用

負載均衡算法

public interface LoadBalancer {    /**     * 根據多個不同的地址 返回單個調用rpc地址     *     * @param serviceInstances     * @return     */    ServiceInstance getSingleAddres(List<ServiceInstance> serviceInstances);}

@Componentpublic class RotationLoadBalancer implements LoadBalancer {    private AtomicInteger atomicInteger = new AtomicInteger(0);    @Override    public ServiceInstance getSingleAddres(List<ServiceInstance> serviceInstances) {        int index = atomicInteger.incrementAndGet() % 2;        ServiceInstance serviceInstance = serviceInstances.get(index);        return serviceInstance;    }}

Rpc遠程調用設計到本地負載均衡算法

1、從註冊中心獲取服務集群的列表
2、從列表選擇一個負載均衡算法有哪些
A、一致性hash計算
B、輪訓、權重
C、隨機

採用什麼設計模式策略模式

假設我們兩臺服務器集群
訪問次數%集群size

1%2=1
2%2=0
3%2=1
4%2=0

1%1=0