微服务实现之Spring Cloud

微服务实现之Spring Cloud前言这几年微服务可能用的比较多,大多都是使用Dubbo和SpringCloud实现,至于优缺点不做评价,看下图:本文主要介绍:eureka实现服务注册及服务发现feign声明式服务调用zuul实现简单的APIGateway注册中心<dependency><groupId>org.springframew…

前言

这几年微服务可能用的比较多,大多都是使用Dubbo和Spring Cloud实现,至于优缺点不做评价,看下图:

这里写图片描述

本文主要介绍:

eureka 实现服务注册及服务发现
feign 声明式服务调用
zuul 实现简单的API Gateway

注册中心

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-eureka-server</artifactId>
</dependency>
server:
  port: 8761

eureka:
  client:
    register-with-eureka: false  #是否需要注册到注册中心,因为该项目本身作为服务注册中心,所以为false
    fetch-registry: false #是否需要从注册中心获取服务列表,原因同上,为false
    service-url.defaultZone:  http://localhost:${server.port}/eureka/
/** * 注册中心服务 **/

@EnableEurekaServer
@SpringBootApplication
public class WmsRegistryApplication { 
   

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

上面服务运行之后,打开页面localhost:8761,可以看到注册中心服务已经开启,不过还没有服务注册进来:

这里写图片描述

服务注册

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-eureka</artifactId>
</dependency>
server:
  port: 8091

spring:
  application:
    name: service-provider   # 此处就是service_id

eureka:
  client:
    service-url.defaultZone:  http://localhost:8761/eureka/  # 此处是注册中心地址,可以有多个
@RestController
@RequestMapping("/user")
public class UserController { 
   

    @Autowired
    private UserService userService;

    @PostMapping("/add")
    public long add(User user) {
        return userService.add(user).getId();
    }

    @GetMapping("/{id}")
    public ResponseEntity<User> findById(@PathVariable("id") long id) {
        return ResponseEntity.ok().body(userService.findById(id));
    }

    @GetMapping("/findAll")
    public ResponseEntity<List<User>> findAll() {
        return ResponseEntity.ok().body(userService.findAll());
    }
}
@EnableDiscoveryClient
@SpringBootApplication
public class WmsServiceProviderApplication { 
   

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

上面服务开启之后就会将服务到上面已开启的注册中心:

WmsRegistryApplication log : Registered instance SERVICE-PROVIDER/DESKTOP-NT6L80B:service-provider:8091 with status UP (replication=true)

WmsServiceProviderApplication log : DiscoveryClient_SERVICE-PROVIDER/DESKTOP-NT6L80B:service-provider:8091 – registration status: 204

这里写图片描述

服务发现

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-eureka</artifactId>
</dependency>
server:
  port: 8081

spring:
  application:
    name: service-consumer


eureka:
  client:
    service-url.defaultZone:  http://localhost:8761/eureka/
@EnableDiscoveryClient
@SpringBootApplication
public class WmsAdminApplication { 
   


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


    @Bean
    @LoadBalanced
    public RestTemplate restTemplate() {   //此处类似于http 客户端,去调用服务,@LoadBalanced提供负载均衡
        return new RestTemplate();
    }
}
@RestController
@RequestMapping("/user")
public class UserController { 
   

    @Autowired
    private RestTemplate restTemplate;

    @GetMapping("/findAll")
    public ResponseEntity<List<User>> findAll() {
        return restTemplate.getForEntity("http://SERVICE-PROVIDER/user/findAll", ResponseEntity.class).getBody();
    }
}

上面这样是可以调用服务的,不过有点冗余,下面会进行改造,服务启动之后的情况如下:

WmsRegistryApplication logger: Registered instance SERVICE-CONSUMER/DESKTOP-NT6L80B:service-consumer:8081 with status UP (replication=true)

WmsAdminApplication logger: DiscoveryClient_SERVICE-CONSUMER/DESKTOP-NT6L80B:service-consumer:8081 – registration status: 204

这里写图片描述

声明式服务调用

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-feign</artifactId>
</dependency>
@EnableDiscoveryClient
@EnableFeignClients    //这里加个注解
@SpringBootApplication
public class WmsAdminApplication { 
   


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

//RestTemplate可以不要了
// @Bean
// @LoadBalanced
// public RestTemplate restTemplate() { 
   
// return new RestTemplate();
// }
}
/** * 声明式服务调用 **/
@FeignClient("${service.provider.name}")
public interface UserHandler { 
   

    @RequestMapping(value = "/user/add", method = RequestMethod.POST)
    long add(User user);

    @RequestMapping("/user/{id}")
    ResponseEntity<User> findById(@PathVariable("id") long id);

    @RequestMapping("/user/findAll")
    ResponseEntity<List<User>> findAll();
}
@RestController
@RequestMapping("/user")
public class UserController { 
   

    @Autowired
    private UserHandler userHandler;

    @GetMapping("/findAll")
    public ResponseEntity<List<User>> findAll() {
        return userHandler.findAll();
    }
}

上面好像比之前的减少了一些代码冗余,通过声明式的调用,而不用再写一遍接口实现,同时也提供了负载均衡(LoadBalanced)和断路器的功能(Hystrix)。

API Gateway

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-zuul</artifactId>
</dependency>
service:
  provider:
    name: SERVICE-PROVIDER

zuul:
  routes:
    apis:
      path: /api/**
      service-id: ${service.provider.name}    

这样配置之后,启动服务器调用接口http://localhost:8081/api/user/findAll 相等于调用了服务提供者的接口http://localhost:9091/user/findAll

zuul还有很多功能,如权限控制,限流,监控等,这里就不一一介绍了。

今天的文章微服务实现之Spring Cloud分享到此就结束了,感谢您的阅读,如果确实帮到您,您可以动动手指转发给其他人。

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。
如需转载请保留出处:http://bianchenghao.cn/26853.html

(0)
编程小号编程小号

相关推荐

发表回复

您的电子邮箱地址不会被公开。 必填项已用 * 标注