SpringBoot 整合 Spring Cloud Alibaba Nacos 连通性+负载均衡
2022-09-06 22:55:26

父工程依赖添加
```bash
     <!--服务注册发现-->
        <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//负载均衡+动态路路由
    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) {

        // 调用商品服务，通过商品ID获取商品名称
        String productNmae = restTemplate.getForObject("http://product-serv/product/" + productId, String.class);

        // 调用用户服务，通过用户ID获取用户名称
        String userNmae = restTemplate.getForObject("http://user-serv/user/" + userId, String.class);

        // 调用扣库存服务，通过商品ID将已购买的商品从库存中删除
        String result = restTemplate.getForObject("http://stock-serv/stock/reduce/" + productId, String.class);

        // 调用个购物车服务，通过商品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