概述
用一个简单的例子演示Spring Cloud中EureKa和Ribbon的基本用法。
版本和环境
构建eureka server
在Spring Cloud,可以使用eureka来管理微服务,微服务可以注册到eureka中。
首先可以用IDEA的Spring Initialzr 来创建eureka server注册中心。
修改application.properties文件,添加如下内容
spring.application.name=eureka-server eureka.instance.hostname=localhost eureka.client.register-with-eureka=false eureka.client.fetch-registry=false server.port=8881
在Spring Boot为我们生成的启动类ServerApplication 中加入@EnableEurekaServer 注解
package com.springcloud.eureka; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer; @EnableEurekaServer @SpringBootApplication public class ServerApplication { public static void main(String[] args) { SpringApplication.run(ServerApplication.class, args); } }
在浏览器中输入http://localhost:8881/
可以看到如下界面:
可以看到暂时还没有服务注册上来。到此,一个简单的微服务注册中心就构建完了。
编写微服务userservice
接下来用rest构建一个微服务接口,并注册到注册中心上去。依然使用Spring Initialzr 来构建一个新的工程。使用方式跟上面的一样。
注意这次要勾选Eureka Discovery 组件。而不是Eureka Server 。
修改application.properties文件,添加如下内容:
spring.application.name=user server.port=8882 eureka.client.service-url.defaultZone=http://localhost:8881/eureka/
在Spring Boot 为我们生成的UserApplication 类中使用@EnableDiscoveryClient 注解。
package com.springcloud; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.cloud.client.discovery.EnableDiscoveryClient; @EnableDiscoveryClient @SpringBootApplication public class UserApplication { public static void main(String[] args) { SpringApplication.run(UserApplication.class, args); } }
创建一个rest full的微服务接口。
package com.springcloud; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.RestController; @RestController public class UserController { @GetMapping("/getUser") public String getUser() { return "I am user list."; } }
运行UserApplication后,再次访问http://localhost:8881/
会发现user这个服务已经注册上来了。
编写微服务order
接下来,我们再构建一个订单的微服务,并访问user这个微服务中的接口。
依然使用Spring Initialzr 来构建一个新工程。user这个微服务是可以部署到多台机器上的。客户端在访问这个服务的时候,请求可以路由到任何一台部署了user服务的机器。因此客户端需要使用一个路由算法来调度user这个服务。在Spring Cloud中,可以使用Ribbon组件来做客户端路由。Ribbon内部会去服务注册中心获取服务列表的,以便调用对应的服务。
这次除了勾选Eureka Discovery 组件。还需要勾选Ribbon 。
修改application.properties文件,添加如下内容:
spring.application.name=order server.port=8883 eureka.client.service-url.defaultZone=http://localhost:8881/eureka/
在Spring Boot 为我们生成的OrderApplication类中增加如下配置。
package com.springboot; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.cloud.client.discovery.EnableDiscoveryClient; import org.springframework.cloud.client.loadbalancer.LoadBalanced; import org.springframework.context.annotation.Bean; import org.springframework.web.client.RestTemplate; @EnableDiscoveryClient @SpringBootApplication public class OrderApplication { @Bean @LoadBalanced RestTemplate restTemplate() { return new RestTemplate(); } public static void main(String[] args) { SpringApplication.run(OrderApplication.class, args); } }
由于使用了Ribbon,这里需要使用@LoadBalanced注解。
编写OrderController。
package com.springboot; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.RestController; import org.springframework.web.client.RestTemplate; @RestController public class OrderController { @Autowired private RestTemplate restTemplate; @GetMapping("/getOrderUser") public String getOrderUser() { return restTemplate.getForEntity("http://user/getUser",String.class).getBody(); } }
运行OrderApplication后,访问http://localhost:8881/
会发现order这个服务也被注册到注册中心了。
接下来我们访问OrderController中的getOrderUser 方法,触发调用UserController的getUser方法。
在浏览器中输入:http://localhost:8883/getOrderUser
可以看到返回了:I am user list.
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持呐喊教程。
声明:本文内容来源于网络,版权归原作者所有,内容由互联网用户自发贡献自行上传,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任。如果您发现有涉嫌版权的内容,欢迎发送邮件至:notice#nhooo.com(发邮件时,请将#更换为@)进行举报,并提供相关证据,一经查实,本站将立刻删除涉嫌侵权内容。