SpringCloud如何使用Eureka实现服务之间的传递数据

SpringCloud如何使用Eureka实现服务之间的传递数据

相信大家最关心的肯定不是什么一大堆的破理论，然后还似懂非懂的，最关心得莫过于服务之间的参数传递，数据获取。

Ok，今天就告诉大家三种微服务之间传输数据的方式，分别是：

1、最基本的利用Ip端口进行请求访问接口实现数据的传输

2、使用Eureka取代Ip（硬编码）的方式实现数据的传输

3、使用Feign更加快捷"分服务"的方式实现微服务之间的数据传输（对Feign一点不了解的暂时不用理解，就是SpringCloud的组成的一部分后期会进行详细讲解，在此处讲解只是为自己mark一下）

前提：搭建好Eureka注册中心，假设现在有一个订单微服务（服务消费者），一个用户微服务（服务提供者），然后需要订单微服务调用用户微服务，获取用户的信息，并且两个服务都能正常运行，为了方便此处使用SpringJpa的方式获取数据。

一、使用RestTemplate+Ip方式：

1、传递数据大部分就是以集合和对象的形式进行传递，所以在这里就用集合和对象的方式为例

在用户微服务（服务提供者）中写好被调用的查询方法

@RestController

@RequestMapping("/user")

public class UserController {

@Resource

private UserRepository userRepository;

@GetMapping("/getallUser")

public List getUserPage(){

return userRepository.findAll();

}

@GetMapping("/getUser")

public User getUser(Long userId){

return userRepository.getOne(userId);

}

}

@Repository

public interface UserRepository extends JpaRepository {

}

@Entity

@Table(name="TM_USER")

@jsonIgnoreProperties(value={"hibernateLazyInitializer","handler","fieldHandler"})

public class User implements Serializable, Cloneable {

@Id

@GeneratedValue(strategy= GenerationType.AUTO)

private Long userId;

/**

* 登录名

*/

@Column(name = "USER_NAME")

private String userName;

ZJYQJFeQtf /**

* 用户名

*/

@Column

private String name;

/**

* 薪水

*/

@Column

private BigDecimal balance;

/**

* 年龄 get set方法已省略 自行添加

*/

@Column

private int age;}

Ok,服务提供者已经写好，下面开始编写服务消费者

2、在订单微服务（服务消费者）的启动类中添加生成RestTemplate的Bean

@SpringBootApplication

@EnableEurekaClient //启用eureka客户端

public class MicroserviceSimplecConsumerOrderServerApplication {

@Bean

public RestTemplate restTemplate(){

return new RestTemplate();

}

public static void main(String[] args) {

SpringApplication.run(MicroserviceSimplecConsumerOrderServerApplication.class, args);

}

}

在订单微服务（服务消费者）配置文件yml中添加，其中localhost:9021改为用户微服务（服务提供者的Ip和端口）

user:

urlPath: http://localhost:9021

订单服务控制层编写，此处的User为用户微服务的复制然后去掉@Column、@Table等注释只是一个临时存储对象和数据库没有任何关联

@RestController

@RequestMapping("/order")

public class OrderServerController {

@Autowired

private RestTemplate restTemplate;

@Value("${user.urlPath}")

private String urlPath;

//获取集合方式

@GetMapping("/allUser")

private List getAllUser(){

ResponseEntity> responseEntity = restTemplate.exchange("urlPath"+/user/getallUser?",

HttpMethod.GET, null, new ParameterizedTypeReference>() {});

return responseEntity.getBody();

}

//获取单个对象方式

@GetMapping("/getUser")

private User getUser(Long userId){

User user = restTemplate.getForObject("urlPath"+/user/getUser?userId="+userId,User.class);

return user;

}

}

二、使用Eureka的方式获取

很简单就是直接把订单微服务（服务消费者）OrderServerController中的userPath替换为注册Eureka上面的服务名即可就是这么简单。假设用户微服务的服务名为：microservice-privider-user

spring:

application:

name: microservice-privider-user

然后就可以直接进行替换处理，即：

@GetMapping("/allUser") //返回集合

private List getAllUser(){

ResponseEntity> responseEntity = restTemplate.exchange("microservice-privider-user"+"/user/getallUser", HttpMethod.GET, null, new ParameterizedTypeReference>() {});

return responseEntity.getBody();

}

//返回对象

@GetMapping("/getUser")

private User getUser(Long userId){

User user = restTemplate.getForObject("microservice-privider-user"+/user/getUser?userId="+userId,User.class);

return user;

}

Ok，使用第二种方式已经编写完成

使用服务名替换了固定的ip，解决了Ip硬编码不容易维护的问题

至于第三种Feign的方式会在以后讲解“Feign：声明性Rest客户端”的时候进行详细讲解

github地址：https://github.com/mackjie/microservice-spring-cloud因为配置了RabbitMQ，所以请先阅读ReadMe然后进行启动项目，否则会启动报错

springcloud学习之Eureka Client搭建和服务间调用

Eureka Client搭建：

一、引入pom依赖

org.springframework.cloud

spring-cloud-starter-netflix-eureka-client

二、启动类推荐添加@EnableEurekaClient注解

就是如果选用的注册中心是eureka，那么就推荐@EnableEurekaClient，

如果是其他的注册中心（zookeeper，consul等），那么推荐使用@EnableDiscoveryClient。

三、配置文件添加：

#eureka

spring.application.name=producer

#注册中心地址

eureka.client.service-url.defaultZone=http://localhost:8761/eureka

#是否把自己注册

eureka.client.register-with-eureka=true

#是否搜索服务信息

eureka.client.fetch-registry=true

#使用ip地址注册

eureka.instance.prefer-ip-address=true

#注册中心列表显示的状态

eureka.instance.instance-id=${spring.cloud.client.ip-address}:${server.port}

服务调用：

有两种方式：

一、ribbon（负载均衡）+restTemplate

启动类添加：

@Bean

@LoadBalanced//负载均衡

public RestTemplate initRestTemplate() {

return new RestTemplate();//

}

ZJYQJFeQtf @Bean//负载均衡的规则，下面的是其中之一：随机，还有权重，轮询等

public IRule initIRule() {

return new RandomRule();

}

RandomRule表示随机策略

RoundRobinRule表示轮询策略（默认）

WeightedResponseTimeRule表示加权策略

BestAvailableRule表示请求数最少策略

然后在controller中自动装配RestTemplate后使用 restTemplate.getForObject()调用。

二、feign（推荐）

1、引入pom依赖

org.springframework.cloud

spring-cloud-starter-openfeign

2.1.1.RELEASE

2、启动类添加@EnableFeignClients注解

3、创建一个接口，

package com.sumengnan.test.web;

import org.springframework.cloud.openfeign.FeignClient;

import org.springframework.web.bind.annotation.GetMapping;

@FeignClient(name = "eureka",fallback = HtystrixEurekaFallback.class)//调用失败后回滚执行方法

public interface EurekaServiceApi {

@GetMapping("test")

String test();

}

回滚的方法：

package com.sumengnan.test.web;

/**

* eureka熔断回调类

*/

public class HtystrixEurekaFallback implements EurekaServiceApi {

@Override

public String test() {

return "连接失败，请稍后再试！";

}

}

4、然后在controller中自动装配EurekaServiceApi后使用eurekaServiceApi.test()调用。

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。