Eureka架构中,有两类微服务角色:
创建项目,
pom.xml
文件中导入spring-cloud-starter-netflix-eureka-server依赖。
<dependencies>
<!--eureka服务端-->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
</dependency>
</dependencies>
编写SpringBoot工程的启动类,添加上注解
@EnableEurekaServer
,以此开启Eureka服务。
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;
@EnableEurekaServer//重点,开启Eureka服务。
@SpringBootApplication
public class EurekaApplication {
public static void main(String[] args) {
SpringApplication.run(EurekaApplication.class, args);
}
}
在SpringBoot工程的application.yml配置文件中,添加以下配置信息。
server:
port: 10086 # 服务端口
spring:
application:
name: eurekaserver # eureka的服务名称
eureka:
client:
service-url: # eureka的地址信息
defaultZone: http://127.0.0.1:10086/eureka
浏览器访问我们上一步配置的eureka的地址信息链接:
http://127.0.0.1:10086/eureka
,就能打开spring Eureka管理界面,查看EurekaServer的一些基本信息。
在服务提供者微服务的
pom.xml
文件中引入spring-cloud-starter-netflix-eureka-client依赖
<!--eureka客户端依赖-->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
在服务提供者微服务的SpringBoot工程配置文件application.yml配置文件中,添加下述配置信息。
spring:
application: #eureka客户端 —— 服务提供者Provider的服务名称
name: userservice
eureka:
client:
service-url: # eureka的地址信息
defaultZone: http://127.0.0.1:10086/eureka
在服务消费者微服务的
pom.xml
文件中引入spring-cloud-starter-netflix-eureka-client依赖
<!--eureka客户端依赖-->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
在服务消费者微服务的SpringBoot工程配置文件application.yml配置文件中,添加下述配置信息。
spring:
application: #eureka客户端 —— 服务消费者Consumer的服务名称
name: orderservice
eureka:
client:
service-url: # eureka的地址信息
defaultZone: http://127.0.0.1:10086/eureka
服务消费者与服务提供者的信息注册步骤基本一致… 即:无论是消费者还是提供者,只要引入eureka-client依赖,配置了eureka地址信息后,都可以完成注册。
服务拉取
:基于服务名称,获取服务列表,然后对服务列表做负载均衡,挑选一个服务进行使用。@Service
public class OrderService {
@Autowired
private OrderMapper orderMapper;
@Autowired
private RestTemplate restTemplate;
public Order queryOrderById(Long orderId) {
// 1.查询订单
Order order = orderMapper.findById(orderId);
// 2.利用RestTemplate发起http请求,查询用户
// 2.1.url路径
//String url = "http://localhost:8081/user/" + order.getUserId();
//使用服务提供者的服务名userservice代替ip、端口:
String url = "http://userservice/user/" + order.getUserId();
// 2.2.发送http请求,实现远程调用
User user = restTemplate.getForObject(url, User.class);
// 3.封装user到Order
order.setUser(user);
// 4.返回
return order;
}
}
重点在这里
:
// 2.1.url路径
//String url = "http://localhost:8081/user/" + order.getUserId();
//使用服务提供者的服务名userservice代替ip、端口:
String url = "http://userservice/user/" + order.getUserId();
@LoadBalanced
@MapperScan("cn.itcast.order.mapper")
@SpringBootApplication
@EnableFeignClients(clients = UserClient.class,defaultConfiguration = DefaultFeignConfiguration.class)
public class OrderApplication {
public static void main(String[] args) {
SpringApplication.run(OrderApplication.class, args);
}
/**
* 创建RestTemplate并注入Spring容器
*/
@Bean
@LoadBalanced//@LoadBalanced注解,实现负载均衡
public RestTemplate restTemplate() {
return new RestTemplate();
}
}
@EnableEurekaServer
—— 使用在SpringBoot工程启动类上,可开启Eureka服务。@LoadBalanced
—— 使用在@Bean方法注入的RestTemplate实例上,用于实现负载均衡算法。