Nacos基础-服务注册&服务调用

前言:本文是基础应用Nacos的文章,全是基础内容,已熟悉的建议跳过。

零、本文纲要

一、基础的服务调用
二、Nacos服务注册&发现
三、Nacos整合Dubbo
四、Nacos整合OpenFeign

一、基础的服务调用

注意:Nacos是客户端的负载均衡调用,所以涉及到消费的请在consumer处理响应的逻辑。

1. 基础依赖

spring-boot-starter-web:web开发,暴露服务接口;

<!--web开发相关依赖-->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
</dependency>

2. 编写服务提供方

① application.yml

server:
  port: 56010

② ProviderController

@RestController
@RequestMapping("/provider")
public class ProviderController {
    @GetMapping("/service")
    public String providerService() {
        return "Hello, consumer.";
    }
}

③ 启动类

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

3. 编写服务消费方

① application.yml

server:
  port: 56020

② ConsumerController

使用Spring web开发提供的RestTemplate客户端对象调用远程服务,如下:

@RestController
@RequestMapping("/consumer")
public class ConsumerController {
    /**
     * 使用基本的客户端方法调用远程服务
     *
     * @return 响应结果
     */
    @GetMapping("/hello")
    public String basicConsume() {
        //0. 获取客户端对象
        RestTemplate restTemplate = new RestTemplate();
        //1. 获取服务提供方地址
        final String URI = "http://127.0.0.1:56010";
        final String SERVICE_PATH = "/provider/service";
        //2. 使用客户端模拟访问
        String result = restTemplate.getForObject(URI + SERVICE_PATH, String.class);
        //3. 返回响应结果
        return "Consumer got message from provider, and message is: [" + result + "]";
    }
}

③ 启动类

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

4. 测试

基础调用测试.png
基础调用测试返回结果.png

二、Nacos服务注册&发现

注意:Nacos是客户端的负载均衡调用,所以涉及到消费的请在consumer处理响应的逻辑。

引入Nacos服务注册&发现中心

1. 基础依赖

增加Nacos服务注册&发现的依赖

<!--Nacos服务注册与发现的依赖-->
<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
</dependency>

2. 修改配置文件

添加Nacos相关配置,将服务注册至Nacos

① 服务提供方

spring:
  application:
    name: nacos-restful-provider
  cloud:
    nacos:
      discovery:
        server-addr: 127.0.0.1:8848

② 服务消费方

spring:
  application:
    name: nacos-restful-consumer
  cloud:
    nacos:
      discovery:
        server-addr: 127.0.0.1:8848

3. 修改服务消费方代码

使用LoadBalancerClient调用服务实例ServiceInstance,轮询获取实例对象;
然后通过ServiceInstance实例对象获取URI,此处URI即为http://192.168.253.128:56010

private static final String SERVICE_ID = "nacos-restful-provider";

@Autowired
private LoadBalancerClient loadBalancerClient;

/**
 * 使用 Nacos 提供的方法调用远程服务
 *
 * @return 响应结果
 */
@GetMapping("/nacos")
public String useNacos() {
    //1. 获取客户端对象
    RestTemplate restTemplate = new RestTemplate();

    //2. 获取服务提供对象
    ServiceInstance serviceInstance = loadBalancerClient.choose(SERVICE_ID);

    //3. 通过服务实现对象获取其具体的URI
    URI serviceInstanceUri = serviceInstance.getUri();

    //4. 通过 URI+具体服务 进行远程调用
    final String SERVICE_PATH = "/provider/service";
    String result = restTemplate.getForObject(serviceInstanceUri + SERVICE_PATH, String.class);

    //5. 返回响应结果
    return "serviceInstanceUri is: [" + serviceInstanceUri + "] and result is: [" + result + "]";
}

4. 重启服务

Nacos服务注册&发现.png
nacos服务调用.png
nacos服务调用结果.png

补充:负载均衡策略配置

此处我们配置了nacos-restful-provider服务的负载均衡策略,如下:

# 在消费方配置某一具体服务的负载均衡策略
nacos-restful-provider:
  ribbon:
    NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule

三、Nacos整合Dubbo

注意:Nacos是客户端的负载均衡调用,所以涉及到消费的请在consumer处理响应的逻辑。

1. 基础依赖

添加Dubbo服务相关依赖

<!--Dubbo服务-->
<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-dubbo</artifactId>
</dependency>

2. 编写配置文件

编写bootstrap.yml配置文件,注意两个配置文件端口、应用名等区分开,如下:

server:
  port: 56040
spring:
  application:
    name: nacos-dubbo-service2
  cloud:
    nacos:
      discovery:
        server-addr: 127.0.0.1:8848
  main:
    allow-bean-definition-overriding: true
# dubbo 服务相关配置
dubbo:
  scan:
    # dubbo 服务扫描基准包
    base-packages: com.itheima.service.impl
  protocol:
    name: dubbo
    port: 20891
  registry:
    address: nacos://127.0.0.1:8848
  application:
    qos-enable: false # dubbo 运维服务是否开启
  consumer:
    check: false # 启动时就否检查依赖的服务,false的话启动顺序不会影响服务正常启动

3. 编写api接口、服务实现

DDD设计模块
nacos-dubbo-service1
|__service-api1
|__service-server1

nacos-dubbo-service2
|__service-api2
|__service-server2

① service1

/**
 * 服务接口
 */
public interface Service1Api {
    public String dubboService1();
}

/**
 * 服务实现类
 */
@Component
@Service(interfaceClass = Service1Api.class)
public class Service1ApiImpl implements Service1Api {
    @Reference
    private Service2Api service2Api;
    @Override
    public String dubboService1() {
        String service2Result = service2Api.dubboService2();
        return "Dubbo service1 | " + service2Result;
    }
}

/**
 * 启动类
 */
@SpringBootApplication
public class Service1Application {
    public static void main(String[] args) {
        SpringApplication.run(Service1Application.class, args);
    }
}

② service2

/**
 * 服务接口
 */
public interface Service2Api {
    public String dubboService2();
}

/**
 * 服务接口
 */
@Component
@Service(interfaceClass = Service2Api.class)
public class Service2ApiImpl implements Service2Api {
    @Override
    public String dubboService2() {
        return "Dubbo Service2.";
    }
}

/**
 * 服务接口
 */
@SpringBootApplication
public class Service2Application {
    public static void main(String[] args) {
        SpringApplication.run(Service2Application.class, args);
    }
}

4. 编写消费代码

注意:消费方需要添加dubbo服务的依赖,以及对应service-api接口的依赖;

@Reference
private Service1Api service1Api;

@Reference
private Service2Api service2Api;

@GetMapping("/dubbo")
public String useDubbo() {
    return service1Api.dubboService1() + " | " + service2Api.dubboService2();
}

5. 测试

Dubbo对比基本的Nacos服务.png
Nacos整合Dubbo.png
Nacos整合Dubbo测试响应.png

四、Nacos整合OpenFeign

注意:Nacos是客户端的负载均衡调用,所以涉及到消费的请在consumer处理响应的逻辑。

1. 添加依赖

<!--OpenFeign-->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>
<dependency>
    <groupId>io.github.openfeign</groupId>
    <artifactId>feign-slf4j</artifactId>
</dependency>

2. 编写OpenFeign客户端

@FeignClient(name = "nacos-restful-provider", path = "/provider")
public interface ProviderClient {
    @GetMapping("/service")
    public String providerService();
}

3. 开启OpenFegin的支持

在启动类上添加@EnableFeignClients注解

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

4. 编写消费代码

@Autowired
private ProviderClient providerClient;

@GetMapping("/openfeign")
public String openFeign() {
    return "OpenFeign msg: " + providerClient.providerService();
}

5. 测试

Nacos整合OpenFeign.png
Nacos整合OpenFeign响应结果.png

补充:简单对比Feign和Dubbo

区别点 Dubbo特点 Feign特点
协议 支持多种传输协议(Dubbo、Rmi、http、redis等等);
默认的Dubbo协议:利用Netty,TCP传输,单一、异步、长连接;
适合数据量小、高并发和服务提供者远远少于消费者的场景;
基于Http传输协议,短连接,不适合高并发的访问;
负载均衡 支持4种算法(随机、轮询、活跃度、Hash一致性),含有权重概念;
支持代码、控制台配置,可以精确到某个服务某个方法;
轮询、随机、ResponseTime加权;
负载均衡算法是Client级别的,即精确到某个服务;
容错策略 支持多种容错策略:failover、failfast、brodecast、forking等;
引入了retry次数、timeout等配置参数。
利用熔断机制来实现容错的。

五、结尾

以上即为Nacos基础-服务注册&服务调用的基础内容,感谢阅读。

©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 216,651评论 6 501
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 92,468评论 3 392
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 162,931评论 0 353
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 58,218评论 1 292
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 67,234评论 6 388
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 51,198评论 1 299
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 40,084评论 3 418
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 38,926评论 0 274
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 45,341评论 1 311
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 37,563评论 2 333
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 39,731评论 1 348
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 35,430评论 5 343
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 41,036评论 3 326
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 31,676评论 0 22
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,829评论 1 269
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 47,743评论 2 368
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 44,629评论 2 354

推荐阅读更多精彩内容