SpringBoot+Eureka实现微服务负载均衡的示例代码

2023-08-09 12:59:04 76

1，什么是Eureka，什么是服务注册与发现

SpringBoot作为目前最火爆的web框架。那么它与Eureka又有什么关联呢？

Eureka是Netflix开源的一个RESTful服务，主要用于服务的注册发现。
Eureka由两个组件组成：Eureka服务器和Eureka客户端。Eureka服务器用作服务注册服务器。
Eureka客户端是一个java客户端，用来简化与服务器的交互、作为轮询负载均衡器，并提供服务的故障切换支持。
Netflix在其生产环境中使用的是另外的客户端，它提供基于流量、资源利用率以及出错状态的加权负载均衡。

2，先创建一个Eureka-Server服务注册中心

这里需要用到spring-cloud的Eureka模块，他是一个服务的注册和发现模块

如图我们先new一个Spring-boot工程引入EurekaServer

Next>>>>Finish完成

我们来看看构建好的Eureka-Server的pom.xml代码



4.0.0
com.eureka
server
0.0.1-SNAPSHOT
jar
server
DemoprojectforSpringBoot

org.springframework.boot
spring-boot-starter-parent
2.0.2.RELEASE



UTF-8
UTF-8
1.8
Finchley.RC2




org.springframework.cloud
spring-cloud-starter-netflix-eureka-server


org.springframework.boot
spring-boot-starter-test
test


org.springframework.boot
spring-boot-autoconfigure





org.springframework.cloud
spring-cloud-dependencies
${spring-cloud.version}
pom
import






org.springframework.boot
spring-boot-maven-plugin





spring-milestones
SpringMilestones
https://repo.spring.io/milestone

false

我们看到这里与普通的Spring-boot项目不同的是，这里引用了一个Eureka-Server包。

那么我们怎么使用它呢，怎么启动它呢？

这里只需要启动一个注解就可以啦，我们在Spring-Boot工程的启动类上加>>>>>>@EnableEurekaServer

代码如下：

packagecom.eureka.server;
importorg.springframework.boot.SpringApplication;
importorg.springframework.boot.autoconfigure.SpringBootApplication;
importorg.springframework.cloud.netflix.eureka.server.EnableEurekaServer;
/**
*启动一个服务注册中心
*/
@EnableEurekaServer
@SpringBootApplication
publicclassServerApplication{

publicstaticvoidmain(String[]args){
SpringApplication.run(ServerApplication.class,args);
}
}

差点忘了，我们还需要配置application.yml

Eureka是一个高可用的组件，每一个实例注册之后需要向注册中心发送心跳包，在默认情况下erurekaserver也是一个eurekaclient,必须要指定一个server。

eurekaserver的配置文件appication.yml：

server:
port:8081#服务注册中心端口号
eureka:
instance:
hostname:127.0.0.1#服务注册中心IP地址
client:
registerWithEureka:false#是否向服务注册中心注册自己
fetchRegistry:false#是否检索服务
serviceUrl:#服务注册中心的配置内容，指定服务注册中心的位置
defaultZone:http://${eureka.instance.hostname}:${server.port}/eureka/

我们来启动一下吧

我们在浏览器上输入http://127.0.0.1:8081/飞机直达

我们可以看到它的可视化界面

细心的朋友会发现，这里没有发现服务？？？Noinstanceavailable

why？因为我们还没有服务向注册中心注册服务，所以找不到啊

3，先创建一个Eureka-Client客户端也就是服务提供者

客户端在向注册中心它会提供一些元数据，例如主机和端口，URL，主页等。Eurekaserver从每个client实例接收心跳消息。如果心跳超时，则通常将该实例从注册server中删除。

创建客户端和服务端差不多，只是启动注解有点不一样，还有yml配置文件

Next>>>Finish完成啦

打开会发现pom.xml其实和Server注册中心的类似



4.0.0
com.eureka
provider
0.0.1-SNAPSHOT
jar
provider
DemoprojectforSpringBoot

org.springframework.boot
spring-boot-starter-parent
2.0.2.RELEASE



UTF-8
UTF-8
1.8
Finchley.RC2



org.springframework.boot
spring-boot-starter-web


org.springframework.cloud
spring-cloud-starter-netflix-eureka-server


org.springframework.boot
spring-boot-starter-test
test





org.springframework.cloud
spring-cloud-dependencies
${spring-cloud.version}
pom
import






org.springframework.boot
spring-boot-maven-plugin





spring-milestones
SpringMilestones
https://repo.spring.io/milestone

false

怎么证明它是Client呢

很简单

在Spring-boot的启动类上通过注解@EnableEurekaClient表明自己是一个eurekaclient.

packagecom.eureka.provider;
importorg.springframework.boot.SpringApplication;
importorg.springframework.boot.autoconfigure.SpringBootApplication;
importorg.springframework.cloud.netflix.eureka.EnableEurekaClient;
importorg.springframework.web.bind.annotation.GetMapping;
importorg.springframework.web.bind.annotation.RequestParam;
importorg.springframework.web.bind.annotation.ResponseBody;
importorg.springframework.web.bind.annotation.RestController;
importjava.util.HashMap;
importjava.util.Map;
/**
*Eureka客户端
*/
@RestController
@EnableEurekaClient
@SpringBootApplication
publicclassProviderApplication{

publicstaticvoidmain(String[]args){
SpringApplication.run(ProviderApplication.class,args);
}


/**
*假如这个客户端要提供一个getUser的方法
*@return
*/
@GetMapping(value="/getUser")
@ResponseBody
publicMapgetUser(@RequestParamIntegerid){
Mapdata=newHashMap<>();
data.put("id",id);
data.put("userName","admin");
data.put("from","provider-A");
returndata;
}

}

虽然加好了@EnableEurekaClient，总感觉差点什么，对了，配置文件yml

eureka:
client:
serviceUrl:#注册中心的注册地址
defaultZone:http://127.0.0.1:8081/eureka/
server:
port:8082#服务端口号
spring:
application:
name:service-provider#服务名称--调用的时候根据名称来调用该服务的方法

我们来启动看看吧

我们看到这个客户端已经向注册中心注册服务了，那么我们打开Eureka-server飞机直达

我们看到我们启动的服务是不是加进去了呢

我们看到我们的服务是不是加进去了呢。

那么有人会问，那一大堆飙红的什么意思啊。因为注册的服务都是高可用的，这里只检测到一个服务，产生的预警，不影响使用，等下我们启动多个实例就不会了。

我们先来测试下客户端的方法是否可用http://127.0.0.1:8082/getUser?id=1

显然是没有问题，那么我们提供好了服务，sei来消费呢？

下面我们就来建立一个消费者

为了更简单易懂，我还是一步一步出图吧。

来，贴上pom.xml



4.0.0

com.eureka
consumer
0.0.1-SNAPSHOT
jar

consumer
DemoprojectforSpringBoot


org.springframework.boot
spring-boot-starter-parent
2.0.2.RELEASE




UTF-8
UTF-8
1.8
Finchley.RC2




org.springframework.boot
spring-boot-starter-web


org.springframework.cloud
spring-cloud-starter-netflix-eureka-server



org.springframework.boot
spring-boot-starter-test
test






org.springframework.cloud
spring-cloud-dependencies
${spring-cloud.version}
pom
import







org.springframework.boot
spring-boot-maven-plugin






spring-milestones
SpringMilestones
https://repo.spring.io/milestone

false

主要是启动类，里面内容就丰富啦，都在注释里

packagecom.eureka.consumer;

importorg.springframework.beans.factory.annotation.Autowired;
importorg.springframework.boot.SpringApplication;
importorg.springframework.boot.autoconfigure.SpringBootApplication;
importorg.springframework.cloud.client.loadbalancer.LoadBalanced;
importorg.springframework.cloud.netflix.eureka.EnableEurekaClient;
importorg.springframework.context.annotation.Bean;
importorg.springframework.web.bind.annotation.GetMapping;
importorg.springframework.web.bind.annotation.RequestParam;
importorg.springframework.web.bind.annotation.ResponseBody;
importorg.springframework.web.bind.annotation.RestController;
importorg.springframework.web.client.RestTemplate;

importjava.util.HashMap;
importjava.util.Map;

/**
*Eureka客户端-消费者
*/
@RestController
@EnableEurekaClient
@SpringBootApplication
publicclassConsumerApplication{

@Autowired
RestTemplaterestTemplate;

publicstaticvoidmain(String[]args){
SpringApplication.run(ConsumerApplication.class,args);
}

/**
*实例化RestTemplate
*@return
*/
@LoadBalanced
@Bean
publicRestTemplaterest(){
returnnewRestTemplate();
}

/**
*Rest服务端使用RestTemplate发起http请求,然后得到数据返回给前端----gotoUser是为了区分getUser怕小伙伴晕头
*@paramid
*@return
*/
@GetMapping(value="/gotoUser")
@ResponseBody
publicMapgetUser(@RequestParamIntegerid){
Mapdata=newHashMap<>();
/**
*小伙伴发现没有，地址居然是http://service-provider
*居然不是http://127.0.0.1:8082/
*因为他向注册中心注册了服务，服务名称service-provider,我们访问service-provider即可
*/
data=restTemplate.getForObject("http://service-provider/getUser?id="+id,Map.class);
returndata;
}
}

配置文件和

eureka:
client:
serviceUrl:#注册中心的注册地址
defaultZone:http://127.0.0.1:8081/eureka/
server:
port:8083#服务端口号
spring:
application:
name:service-consumer#服务名称--调用的时候根据名称来调用该服务的方法

我们启动看看效果吧

看看我们的提供者和消费者是不是都进来了

那么我们看看我们消费者的方法是否可用飞机直达

哈哈，是不是很神奇

下面介绍个更神奇的东西--实现微服务负载均衡

我们把服务提供者复制一个工程出来，我们再做下小小的修改，看看是否能实现负载均衡。

我们需要修改两个文件

一个是启动类，改了哪些呢？看看就晓得咯

packagecom.eureka.provider;

importorg.springframework.boot.SpringApplication;
importorg.springframework.boot.autoconfigure.SpringBootApplication;
importorg.springframework.cloud.netflix.eureka.EnableEurekaClient;
importorg.springframework.web.bind.annotation.GetMapping;
importorg.springframework.web.bind.annotation.RequestParam;
importorg.springframework.web.bind.annotation.ResponseBody;
importorg.springframework.web.bind.annotation.RestController;

importjava.util.HashMap;
importjava.util.Map;

/**
*Eureka客户端
*/
@RestController
@EnableEurekaClient
@SpringBootApplication
publicclassProviderApplication{

publicstaticvoidmain(String[]args){
SpringApplication.run(ProviderApplication.class,args);
}


/**
*假如这个客户端要提供一个getUser的方法
*@return
*/
@GetMapping(value="/getUser")
@ResponseBody
publicMapgetUser(@RequestParamIntegerid){
Mapdata=newHashMap<>();
data.put("id",id);
data.put("userName","admin");
data.put("from","provider-B");//改这里是为了让大家更能理解它负载均衡的机制
returndata;
}

}

还有就是yml配置文件

eureka:
client:
serviceUrl:#注册中心的注册地址
defaultZone:http://127.0.0.1:8081/eureka/
server:
port:8088#服务端口号--该端口不要冲突
spring:
application:
name:service-provider#服务名称--调用的时候根据名称来调用该服务的方法--名字绝对不能改，改了就访问不到了

我们来启动一下吧

看看Eureka-server后台的效果ServerAServerB

这个叫做Service-provider是不是有两个实例啊

那么，我们分别访问一下，看看效果怎么样

看到了吗，8082端口，from是provider-A，8088端口，from是provider-B.

那么我们访问消费者的服务器看看会出现什么样的情况呢飞机直达

一开始是fromA,你刷新一下，诶？变成fromB了。

说明这个时候两台提供者在交替工作，从而达到了一个负载均衡的作用。

来来来，我给你画个图

每个微服务都是一个Eureka-Client，我们把每个app（SpringBootApplication）都向注册中心注册一个服务。

有时候，某个服务的工作量比较大的时候，我们可以多注册几个同名称的微服务，从而让他们交替工作，减轻单个服务的压力。

写到这里就结束咯。

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。

声明：本文内容来源于网络，版权归原作者所有，内容由互联网用户自发贡献自行上传，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任。如果您发现有涉嫌版权的内容，欢迎发送邮件至：czq8825#qq.com（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。

SpringBoot+Eureka实现微服务负载均衡的示例代码

热门推荐

随机推荐