Nacos-Service Consumer (Feign) Spring Cloud Alibaba

Spring Cloud

I. Обзор

Feign — это декларативный псевдо-HTTP-клиент, упрощающий написание Http-клиентов. С Feign вам нужно только создать интерфейс и аннотировать его. Он имеет подключаемую функцию аннотаций, которая может использовать аннотации Feign и аннотации JAX-RS. Feign поддерживает подключаемые кодировщики и декодеры. Feign по умолчанию интегрирует Ribbon, Nacos также очень совместим с Feign и по умолчанию обеспечивает эффект балансировки нагрузки.

  • Feign использует аннотации на основе интерфейса
  • Feign интегрирует ленту

2. ПОМ

Создайте проект с именемhello-spring-cloud-alibaba-nacos-consumer-feignпроект потребителя услуг,pom.xmlКонфигурация выглядит следующим образом:

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <parent>
        <groupId>com.funtl</groupId>
        <artifactId>hello-spring-cloud-alibaba-dependencies</artifactId>
        <version>1.0.0-SNAPSHOT</version>
        <relativePath>../hello-spring-cloud-alibaba-dependencies/pom.xml</relativePath>
    </parent>

    <artifactId>hello-spring-cloud-alibaba-nacos-consumer-feign</artifactId>
    <packaging>jar</packaging>

    <name>hello-spring-cloud-alibaba-nacos-consumer-feign</name>
    <url>http://www.funtl.com</url>
    <inceptionYear>2018-Now</inceptionYear>

    <dependencies>
        <!-- Spring Boot Begin -->
        <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>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        <!-- Spring Boot End -->

        <!-- Spring Cloud Begin -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-openfeign</artifactId>
        </dependency>
        <!-- Spring Cloud End -->
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
                <configuration>
                    <mainClass>com.funtl.hello.spring.cloud.alibaba.nacos.consumer.feign.NacosConsumerFeignApplication</mainClass>
                </configuration>
            </plugin>
        </plugins>
    </build>
</project>

В основном увеличилосьorg.springframework.cloud:spring-cloud-starter-openfeignполагаться

3. Применение

пройти через@EnableFeignClientsАннотация для включения функции Feign

package com.funtl.hello.spring.cloud.alibaba.nacos.consumer.feign;

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

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

В-четвертых, создайте интерфейс Feign

пройти через@FeignClient("服务名")Аннотация, указывающая, какую службу вызывать. код показывает, как показано ниже:

package com.funtl.hello.spring.cloud.alibaba.nacos.consumer.feign.service;

import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;

@FeignClient(value = "nacos-provider")
public interface EchoService {

    @GetMapping(value = "/echo/{message}")
    String echo(@PathVariable("message") String message);
}

5. Контроллер

package com.funtl.hello.spring.cloud.alibaba.nacos.consumer.feign.controller;

import com.funtl.hello.spring.cloud.alibaba.nacos.consumer.feign.service.EchoService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class NacosConsumerFeignController {

    @Autowired
    private EchoService echoService;

    @GetMapping(value = "/echo/hi")
    public String echo() {
        return echoService.echo("Hi Feign");
    }
}

6. приложение.yml

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

server:
  port: 9092

management:
  endpoints:
    web:
      exposure:
        include: "*"

7. Запустите проект

Доступ через браузерhttp://localhost:8848/nacos, URL-адрес сервера Nacos

[Не удалось передать изображение по внешней ссылке, исходный сайт может иметь механизм защиты от пиявки, рекомендуется сохранить изображение и загрузить его напрямую (img-mKqSwRCv-1599814862579)(/assets/Lusifer_20190106143035.png)]

Вы найдете доп.nacos-consumer-feignуслуга

Открой сейчасhttp://localhost:9092/echo/hiВы увидите на своем браузере:

Hello Nacos Discovery Hi Feign

Восемь, тестовая балансировка нагрузки

  • начать несколькоconsumer-providerНапример, схема эффекта выглядит следующим образом:

[Не удалось передать изображение по внешней ссылке, исходный сайт может иметь механизм защиты от пиявки, рекомендуется сохранить изображение и загрузить его напрямую (img-2iuzeH3w-1599814862583)(/assets/Lusifer_20190106144323.png)]

  • Исправлятьconsumer-providerв проектеControllerКод для определения того, что балансировка нагрузки действует

    package com.funtl.hello.spring.cloud.alibaba.nacos.provider;

    import org.springframework.beans.factory.annotation.Value; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.cloud.client.discovery.EnableDiscoveryClient; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.PathVariable; import org.springframework.web.bind.annotation.RestController;

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

    @Value("${server.port}")
private String port;

@RestController
public class EchoController {
    @GetMapping(value = "/echo/{message}")
    public String echo(@PathVariable String message) {
        return "Hello Nacos Discovery " + message + " i am from port " + port;
    }
}

    }

  • Несколько посещений в браузереhttp://localhost:9092/echo/hi, браузер поочередно отображает:

    Hello Nacos Discovery Hi Feign i am from port 8081 Hello Nacos Discovery Hi Feign i am from port 8082

Посмотреть подробности или получить полнуюМикросервисная архитектура Java,весеннее семейное ведро видеоКонечно, нажмите здесь, чтобы получить весенний обучающий видеокурс по микросервисам.

Категории