Springcloud alibaba Nacos作为服务注册中心

Nacos服务提供者注册

新建微服务提供者cloudalibaba-provider-payment9001(模拟支付提供模块)

引入pom所需要的相关的依赖

与之前学习Eureka注册中心相比来说。多了nacos的相关依赖

 <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>

        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-devtools</artifactId>
            <scope>runtime</scope>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
        </dependency>
    </dependencies>

在这之后我们修改yaml配置文件

server:
 port: 9001

spring:
  application:
    name: nacos-provider
  cloud:
   nacos:
    discovery:
     server-addr: 127.0.0.1:8848 #配置Nacos地址

# 暴露要监控的
management:
  endpoints:
   web:
    exposure:
      include: '*'

创建一个主启动类(注意开启@EnableDiscoveryClient客户端服务发现注解)

package com.dzu.sprinhcloud.alibaba;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;

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

在controller中编写核心的业务类信息

package com.dzu.sprinhcloud.alibaba.controller;

import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;

/**
 * @author chenruxu
 * @date
 */
@RestController
public class PaymentController {
    @Value("${server.port}")
    private String serverPort;

    @GetMapping(value = "/payment/nacos/{id}")
    public String getPyment(@PathVariable("id") Integer id){
        return "nacos register ,serverPort: "+serverPort+"\t id: "+id;
    }
}

服务提供者测试

首先启动nacos服务注册中心。然后在启动9001的项目进行访问测试

访问成功之后，在nacos的可视化界面中就可以看到这个服务已经被注册进去了，到这个时候将服务提供者注册进入nacos的操作已经完成了。

nacos自带负载均衡的功能，为了进行测试我们建立一个完全相同的cloudalibaba-provider-payment9002的模块进行测试。

完成9002模块之后启动9001和9002两个项目进行测试。nacos中便会出现两个注册实例。

基于Nacos的消费者的创建

新建一个消费者的模块cloudalibaba-consumer-nacos-order83

pom文件与上面相同

修改yaml的配置文件。

server:
  port: 83

Spring:
  application:
    name: nacos-order-consumer

  cloud:
    nacos:
      discovery:
        server-addr: localhost:8848

# 消费者将要去访问的微服务名称（注册成功进nacos的微服务提供者）
service-url:
  nacos-user-service: http://nacos-provider

主启动类

package com.dzu.springcloud.alibaba;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;

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

新建RestTemplate配置类，nacos里面集成了ribbon可以通过restTemplate完成负载均衡的相关的配置和操作

package com.dzu.springcloud.alibaba.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;

@Configuration
public class ApplicationContextConfig {
    @Bean
    @LoadBalanced// resttemplate 结合ribbon做负载均衡的时候 要加入注解
    public RestTemplate getRestTemplate(){
        return new RestTemplate();
    }
}

创建controller类完成核心调用业务的编写工作

package com.dzu.springcloud.alibaba.controller;

import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;

import javax.annotation.Resource;

@RestController
@Slf4j
public class OrderNacosController {
    @Resource
    private RestTemplate restTemplate;

    @Value("${service-url.nacos-user-service}")
    private String serverUrl;

    @GetMapping(value = "/consumer/payment/nacos/{id}")
    public String paymeentInfo(@PathVariable("id") Long id){
        return restTemplate.getForObject(serverUrl+"/payment/nacos/"+id,String.class );
    }
}

编写完成之后开启83服务完成测试，此时通过消费者模块调用,可以通过端口号观察负载均衡的相关功能。

此时通过nacos搭建的rest微服务项目可以通过消费者对服务提供者进行访问了。