SpringCloud(4):服务消费方

简介: 搭建前言接着前面的几文章我们已经搭建好了注册中心和服务的生产者,这篇文章我们来搭建服务的消费方。SpringBoot版本:2.0 2.0.4.RELEASEspring-cloud-dependencies 版本:Finchley.

搭建前言

接着前面的几文章我们已经搭建好了注册中心和服务的生产者,这篇文章我们来搭建服务的消费方。
SpringBoot版本:2.0 2.0.4.RELEASE
spring-cloud-dependencies 版本:Finchley.SR1

pom:

 <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-openfeign</artifactId>
        </dependency>

配置文件

spring.application.name=eureka-consumer 
# Eureka  注册中心地址
eureka.client.service-url.defaultZone=http://localhost:10000/eureka/

management.endpoints.web.exposure.include=refresh,health,info,env,loggers,metrics,trace,dump
management.endpoint.health.show-details=always
# Ϊ11000  11001  11002 ...
server.port= 8080

启动类

@EnableFeignClients
@SpringBootApplication
@ComponentScan(value = "cn.lpck.eurekaconsumerfeign")
public class EurekaConsumerFeignApplication {

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

注解解释:
@EnableFeignClients:由于我们使用的试Feign 组件 ,我们需要在SpringBoot的启动类里面去开启Feign 组件的客户端,在启动时即注册。
@ComponentScan(value = "cn.lpck.eurekaconsumerfeign"): 组件扫描,识别feign组件

SpringCloud 发展至今提供了很多组件,我们去官方查看大概是有二十几个组件.使用Feign的好处就是他其实是封装了Http请求,简化了原本复杂的框架,实现了类似于Dubbo的@Refrence注解的作用,但是二者实现的原理却大不一样。

消费使用

到了这里我们其实就已经实现整个SpringCloud框架种最核心的SOA思想,搭建不同的生产者与消费者就可以实现业务拆分.

消费者的服务请求接口
/**
 * @Author: Liupu
 * @Date: 2018/9/12 0012 上午 11:46
 * @Description:
 * @Version 1.0
 */
@Component
@FeignClient(name = "eureka-producer")
public interface HelloService {
    @GetMapping("/hello/")
    String hello(@RequestParam(value= "name") String name);

   /* @RequestMapping("/hello/{user}")
    String getHello(@PathVariable("user") String user);*/

   @GetMapping("/hello/name")
    List<String> getNames(@RequestParam("name") String name);

}

下面贴上我们之前搭建好的生产者的Controller

/**
 * @Author: Liupu
 * @Date: 2018/9/11 0011 下午 4:52
 * @Description:
 * @Version 1.0
 */
@RestController
@RequestMapping("/hello")
public class HelloController {

    @Autowired
    private UserService userService;

    @GetMapping("/")
    public String getHello(@RequestParam String name){

        return "hello,"+ name +" "+ new Date();
    }

    /*@RequestMapping("/user")
    public String helloUser(@RequestParam String name){
        return "hello,"+ name +"aboyliupu"+ new Date();
    }*/

    @GetMapping("/name")
    public List<String> getList(@RequestParam String name){
        ArrayList<String> names = new ArrayList<>();
        names.add("aaa");
        names.add(name);
        return names;
    }
}

分析:消费者接口中的子父Mapping 与生产者中的子父Mapping一样,然后通过注解@FeignClient(name = "eureka-producer")指向我们的消费者中心找到整个消费者然后就请求接口中的数据.
如果抛开整个生产者和注册中心来看,这个项目就像是一个数据表现层,没有自己获取数据的能力,所有数据由第三方的接口提供。
然后再看整个项目 SOA的思想已经通过 生产者-----注册中心-----消费者 体现的淋漓尽致。我们学习分布式框架的目的也就是为了理解这样的一套架构思想。

最后再看下 消费者的Controller

/**
 * @Author: Liupu
 * @Date: 2018/9/12 0012 上午 11:44
 * @Description:feign 可以实现负载均衡 :@Value("${config.producer.instance:0}")
 *                          需要打包启动 类似注册中心集群
 * @Version 1.0
 */
@RestController
@RequestMapping("/hello")
public class HelloController {

    @Autowired
    HelloService helloService;

    @GetMapping("/{name}")
    public String index(@PathVariable("name") String name) {
        return helloService.hello(name + "!");
    }

    @GetMapping("/name/{name}")
    public List<String> getNames(@PathVariable("name") String name){
        List<String> names = helloService.getNames(name);
        return names;
    }
}

目录
相关文章
|
1月前
|
存储 数据可视化 Java
基于MicrometerTracing门面和Zipkin实现集成springcloud2023的服务追踪
Sleuth将会停止维护,Sleuth最新版本也只支持springboot2。作为替代可以使用MicrometerTracing在微服务中作为服务追踪的工具。
81 1
|
3月前
|
缓存 NoSQL Java
【Azure Redis 缓存】示例使用 redisson-spring-boot-starter 连接/使用 Azure Redis 服务
【Azure Redis 缓存】示例使用 redisson-spring-boot-starter 连接/使用 Azure Redis 服务
|
2月前
|
消息中间件 存储 Java
SpringCloud基础9——服务异步通信-高级篇
消息可靠性、死信交换机、惰性队列、MQ集群
SpringCloud基础9——服务异步通信-高级篇
|
2月前
|
Java API 对象存储
微服务魔法启动!Spring Cloud与Netflix OSS联手,零基础也能创造服务奇迹!
这段内容介绍了如何使用Spring Cloud和Netflix OSS构建微服务架构。首先,基于Spring Boot创建项目并添加Spring Cloud依赖项。接着配置Eureka服务器实现服务发现,然后创建REST控制器作为API入口。为提高服务稳定性,利用Hystrix实现断路器模式。最后,在启动类中启用Eureka客户端功能。此外,还可集成其他Netflix OSS组件以增强系统功能。通过这些步骤,开发者可以更高效地构建稳定且可扩展的微服务系统。
50 1
|
30天前
|
负载均衡 Java API
【Spring Cloud生态】Spring Cloud Gateway基本配置
【Spring Cloud生态】Spring Cloud Gateway基本配置
34 0
|
3月前
|
负载均衡 监控 Java
SpringCloud常见面试题(一):SpringCloud 5大组件,服务注册和发现,nacos与eureka区别,服务雪崩、服务熔断、服务降级,微服务监控
SpringCloud常见面试题(一):SpringCloud 5大组件,服务注册和发现,nacos与eureka区别,服务雪崩、服务熔断、服务降级,微服务监控
SpringCloud常见面试题(一):SpringCloud 5大组件,服务注册和发现,nacos与eureka区别,服务雪崩、服务熔断、服务降级,微服务监控
|
3月前
|
Java Spring
【Azure Spring Cloud】Spring Cloud Azure 4.0 调用Key Vault遇见认证错误 AADSTS90002: Tenant not found.
【Azure Spring Cloud】Spring Cloud Azure 4.0 调用Key Vault遇见认证错误 AADSTS90002: Tenant not found.
|
3月前
|
运维 Java Nacos
Spring Cloud应用框架:Nacos作为服务注册中心和配置中心
Spring Cloud应用框架:Nacos作为服务注册中心和配置中心
|
3月前
|
Java Spring 容器
【Azure Spring Cloud】在Azure Spring Apps上看见 App Memory Usage 和 jvm.menory.use 的指标的疑问及OOM
【Azure Spring Cloud】在Azure Spring Apps上看见 App Memory Usage 和 jvm.menory.use 的指标的疑问及OOM
|
3月前
|
存储 Java Spring
【Azure Spring Cloud】Azure Spring Cloud服务,如何获取应用程序日志文件呢?
【Azure Spring Cloud】Azure Spring Cloud服务,如何获取应用程序日志文件呢?