SpringBoot 整合 Spring Cloud Alibaba Nacos 連通性+負載均衡
2022-09-06 22:55:26

父工程依賴添加
```bash
     <!--服務注冊發(fā)現(xiàn)-->
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
        </dependency>

    <dependencyManagement>
        <dependencies>
            <!--spring-cloud-alibaba 版本控制-->
            <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>

server:
  port: 8000
spring:
  cloud:
    nacos:
      discovery:
        service: order-serv
      server-addr: localhost:8848

package com.gblfy;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.context.annotation.Bean;
import org.springframework.web.client.RestTemplate;

@SpringBootApplication
@EnableDiscoveryClient
public class OrderApplication {

    @Bean
    @LoadBalanced//負載均衡+動態(tài)路路由
    public RestTemplate restTemplate() {
        return new RestTemplate();
    }

    public static void main(String[] args) {
        SpringApplication.run(OrderApplication.class);
    }
}

server:
  port: 9000
spring:
  cloud:
    nacos:
      discovery:
        service: product-serv
      server-addr: localhost:8848

server:
  port: 15000
spring:
  cloud:
    nacos:
      discovery:
        service: user-serv
      server-addr: localhost:8848

server:
  port: 11000
spring:
  cloud:
    nacos:
      discovery:
        service: stock-serv
      server-addr: localhost:8848

server:
  port: 12000
spring:
  cloud:
    nacos:
      discovery:
        service: shop-cart-serv
      server-addr: localhost:8848

package com.gblfy.controller;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;

@RestController
public class OrderController {

    @Autowired
    private RestTemplate restTemplate;

    //http://localhost:8000/order/create?productId=11&userId=11222
    @GetMapping("/order/create")
    public String createOrder(Integer productId, Integer userId) {

        // 調(diào)用商品服務，通過商品ID獲取商品名稱
        String productNmae = restTemplate.getForObject("http://product-serv/product/" + productId, String.class);

        // 調(diào)用用戶服務，通過用戶ID獲取用戶名稱
        String userNmae = restTemplate.getForObject("http://user-serv/user/" + userId, String.class);

        // 調(diào)用扣庫存服務，通過商品ID將已購買的商品從庫存中刪除
        String result = restTemplate.getForObject("http://stock-serv/stock/reduce/" + productId, String.class);

        // 調(diào)用個購物車服務，通過商品ID和用戶ID將已購買的商品從購物車中移除
        String shopCartResult = restTemplate.getForObject("http://shop-cart-serv/shopcart/remove?productId=" + productId + "&userId=" + userId, String.class);
        return "[用戶]: " + userNmae + " 購買商品 " + productNmae + " " + result + " " + shopCartResult;
    }
}

package com.gblfy.controller;

import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class ProductController {

    //http://localhost:9000/product/" + productId
    @GetMapping("/product/{productId}")
    public String getProductName(@PathVariable Integer productId) {
        return "IPhone 12";
    }
}

package com.gblfy.controller;

import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class UserController {

    @GetMapping("/user/{userId}")
    public String getUserName(@PathVariable Integer userId) {
        return "gblfy專家";
    }
}

package com.gblfy.controller;

import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class StockController {

    @GetMapping("/stock/reduce/{productId}")
    public String reduce(@PathVariable Integer productId) {
        System.out.println("減庫存一個成功");
        return "減庫存一個成功！";
    }
}

package com.gblfy.controller;

import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class ShopCartController {


    @GetMapping("/shopcart/remove")
    public String remove(Integer productId, Integer userId) {
        return "移除購物車成功！";
    }
}

http://localhost:9000/order/create?productId=11&userId=11222

http://localhost:9000/order/create?productId=11&userId=11222

http://localhost:9000/order/create?productId=11&userId=11222