前言
这几年微服务可能用的比较多,大多都是使用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