SpringCloud笔记#

注册流程#

1.启动微服务

2.引入服务发现依赖

<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
</dependency>

3.配置Nacos地址：地址端口默认如下

spring:
  application:
    name: service-order
  cloud:
    nacos:
      discovery:
        server-addr: 127.0.0.1:8848

server:
  port: 8000

4.查看注册中心效果：启动微服务，查看Nacos管理页面

5.集群模式启动测试

通过复制配置的方式传入端口参数在不同端口启动相同程序形成集群

--server.port=8002

服务发现#

想要获取到在Nacos中注册的所有服务以及其对应的IP端口可以通过以下步骤实现

1.开启服务发现功能：@EnableDiscoveryClient，这个根据有些版本可以自动开启服务发现，无需手动配置

@EnableDiscoveryClient
@SpringBootApplication
public class OrderMainApplication {
    public static void main(String[] args) {
        SpringApplication.run(OrderMainApplication.class, args);
    }
}

2.测试服务发现API： DiscoveryClient

@SpringBootTest
class OrderMainApplicationTest {
    @Autowired
    DiscoveryClient discoveryClient;

    @Test
    void contextLoads() {
        List<String> services = discoveryClient.getServices();
        for (String service : services) {
            System.out.println("service:"+ service);
        /*  获取服务
            service:service-order
s           service:service-product
         */
        }
        //更具服务名称获取对应实例
        List<ServiceInstance> instances = discoveryClient.getInstances("service-order");
        for (ServiceInstance instance : instances) {
            /*
                 ip:192.168.20.29
                 port:8000
             */
            System.out.println("ip:"+ instance.getHost());
            System.out.println("port:"+ instance.getPort());
            System.out.println();
        }
    }
}

3.测试服务发现API： NacosServiceDiscovery和上面的同理，只能使用引入Nacos注册的服务

远程调用#

可以通过服务名称获取对应的实例，任取一个通过http请求url获取数据

Rest Template是一个线程安全的对象，也可以配置放入Bean中注入使用

@GetMapping("{userId}/{proId}")
public String order(@PathVariable int userId, @PathVariable int proId) {
    Product product = getProduct(proId);
    Order order = new Order();
    order.setUserId(userId);
    order.setPrice(product.getPrice());
    orderService.save(order);
    return order.toString();
}

private Product getProduct(int proId) {
    List<ServiceInstance> instances = discoveryClient.getInstances("service-product");
    ServiceInstance instance = instances.get(0);
    //拼接url
    String url = "http://" + instance.getHost() + ":" + instance.getPort() + "/product/" + proId;
    RestTemplate restTemplate = new RestTemplate();
    return restTemplate.getForObject(url, Product.class);
}

负载均衡#

我们在上述方式中采用的是服务实例的第一个服务，不能负载均衡，我们只需要调整调用的实例方式就可以实现负载均衡，在实际中使用LoadBalancerClient实现，自带负载均衡获取到实例

loadBalancerClient实现

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-loadbalancer</artifactId>
</dependency>

@Autowired
LoadBalancerClient loadBalancerClient;
@Test
void test() {
    ServiceInstance instance = loadBalancerClient.choose("service-product");
    System.out.println(instance.getHost() + ":" + instance.getPort());
    instance = loadBalancerClient.choose("service-product");
    System.out.println(instance.getHost() + ":" + instance.getPort());
}

注解实现

放入一个负载均衡的RestTemplate

@Configuration
public class CloudConfig {
    @LoadBalanced
    @Bean
    public RestTemplate restTemplate() {
        return new RestTemplate();
    }
}

直接在ip端口写服务名称，会被动态替换为对应负载均衡后的ip端口

@Autowired
RestTemplate restTemplate;

private Product getProduct(int proId) {
    String url = "http://service-product/product/" + proId;
    return restTemplate.getForObject(url, Product.class);
}

配置流程#

启动Nacos，引入依赖

<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
</dependency>

在application中指定Nacos地址

spring:
  config:
    import: nacos:service-order.properties

创建data_id，在其中编写配置文件

order.timeout=40

之后我们就可以使用配置文件的注解将其注入到字段中即可使用

@Value("${order.timeout}")
private int timeout;

我们现在尝试更改配置中兴参数数据，发现注入的参数并没有被修改，我们还需要在Controller上加一个注解@RefreshScope实现发布后参数的自动更新

@RefreshScope
@RestController
@RequestMapping("order")
public class OrderController {
    @Autowired
    DiscoveryClient discoveryClient;

    @Autowired
    OrderService orderService;

    @Autowired
    LoadBalancerClient loadBalancerClient;

    @Value("${order.timeout}")
    private int timeout;
    ...

如果我们的有一个服务不需要使用到Nacos配置中心的参数，但是没有导入config.import配置，就会发生报错，我们这个使用需要手动禁用配置的检查功能

spring:
  cloud:
    nacos:
      config.import-check.enabled: false

批量绑定#

当我们配置的数据项过多的时候，我们也可以使用ConfigurationProperties注解进行批量绑定

@ConfigurationProperties(prefix = "order")
@Data
@Component
public class OrderProperties {
    Integer timeout;
    Integer year;
}

同时也无需使用RefreshScope注解刷新

监听配置#

创建ApplicationRunner在项目启动时会开始运行方法，在方法中用Manager获取配置服务，向服务中添加监听器，传入配置对象，配置组，以及被重写的Listener对象

@EnableDiscoveryClient
@SpringBootApplication
public class OrderMainApplication {
    public static void main(String[] args) {
        SpringApplication.run(OrderMainApplication.class, args);
    }

    @Bean
    ApplicationRunner applicationRunner(NacosConfigManager  nacosConfigManager) {
        return args -> {
            System.out.println("启动时添加监听器================");
            ConfigService service = nacosConfigManager.getConfigService();
            service.addListener("service-order.properties",
                    "DEFAULT_GROUP", new Listener() {
                        @Override
                        public Executor getExecutor() {
                            return Executors.newFixedThreadPool(10);
                        }

                        @Override
                        public void receiveConfigInfo(String s) {
                            System.out.println("变化配置：" + s);
                        }
                    });
        };
    }

}

变化配置：order.timeout=4
order.year=2001

在配置重复的时候以Nacos配置为先

数据隔离#

spring:
  config:
    import:
#    - nacos:service-order.properties
    - nacos:common.properties?group=order
    #指定指定对应组
  application:
    name: service-order
  datasource:
    url: jdbc:mysql://thrinisty.top:3306/cloud?useSSL=false&serverTimezone=UTC&characterEncoding=UTF-8
    username: root
    password: 771113
    driver-class-name: com.mysql.cj.jdbc.Driver
  cloud:
    nacos:
      config:
        namespace: dev
        #设置命名空间，后续只需要改这个即可
      discovery:
        server-addr: 127.0.0.1:8848


server:
  port: 8000