Eureka注册中心管理服务方，消费方通过Ribbon负载均衡访问（1）

逃离我推掉我的手 2022-03-30 05:17 145阅读 0赞

这里我们有三个服务，Eureka注册中心服务，服务方服务，消费方服务，如下图：  
![在这里插入图片描述][2019010422364823.png]  
首先说一下这这三个服务还有Eureka，Ribbon：  
Eureka是服务注册中心，主要来管理所有的服务，为消费方提供服务，我们将服务注册到Eureka中，然后消费方通过Ribbon负载均衡利用服务名来访问服务，而不是IP。

## 1 Eureka服务 microservicecloud-Eureka-7001 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3d1MjM3NDYzMzU4Mw_size_16_color_FFFFFF_t_70]  
pom.xml

application.yml

server:
      port: 7001
    
    eureka:
      instance:
        hostname: localhost  #eureka服务端的实例名称
      client:
        register-with-eureka: false #false表示不向注册中心注册自己。
        fetch-registry: false #false表示自己端就是注册中心，我的职责就是维护服务实例，并不需要去检索服务
        service-url:
          defaultZone: http://${ eureka.instance.hostname}:${ server.port}/eureka/    #设置与Eureka Server交互的地址查询服务和注册服务都需要依赖这个地址。

EurekaServer7001\_App.java

package com.wuk;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;
    
    @SpringBootApplication
    @EnableEurekaServer //EurekaServer服务器端启动类,接受其它微服务注册进来
    public class EurekaServer7001_App { 
    
    	public static void main(String[] args) { 
    		
    		SpringApplication.run(EurekaServer7001_App.class, args);
    	}
    
    }

## 2 服务方 microservicecloud-dept-8888 ##

主要涉及到的配置就是要将服务方注册到eureka中  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3d1MjM3NDYzMzU4Mw_size_16_color_FFFFFF_t_70 1]  
pom.xml

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    	<modelVersion>4.0.0</modelVersion>
    	<parent>
    		<groupId>com.wuk.springcloud</groupId>
    		<artifactId>microservicecloud</artifactId>
    		<version>0.0.1-SNAPSHOT</version>
    	</parent>
    	<artifactId>microservicecloud-dept-8888</artifactId>
    	<dependencies>
    		<dependency>
    			<groupId>com.wuk.springcloud</groupId>
    			<artifactId>microservicecloud-api</artifactId>
    			<version>${project.version}</version>
    		</dependency>
    		<dependency>
    			<groupId>junit</groupId>
    			<artifactId>junit</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>mysql</groupId>
    			<artifactId>mysql-connector-java</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>com.alibaba</groupId>
    			<artifactId>druid</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>ch.qos.logback</groupId>
    			<artifactId>logback-core</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>org.mybatis.spring.boot</groupId>
    			<artifactId>mybatis-spring-boot-starter</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-jetty</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-web</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-test</artifactId>
    		</dependency>
    		
    		<dependency>
    			<groupId>org.springframework</groupId>
    			<artifactId>springloaded</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-devtools</artifactId>
    		</dependency>
    		
    	   <dependency>
    	     <groupId>org.springframework.cloud</groupId>
    	     <artifactId>spring-cloud-starter-eureka</artifactId>
    	   </dependency>
    	   <dependency>
    	     <groupId>org.springframework.cloud</groupId>
    	     <artifactId>spring-cloud-starter-config</artifactId>
    	   </dependency>
    	</dependencies>
    </project>

application.yml

server:
      port: 8888
      
    mybatis:
      config-location: classpath:mybatis/mybatis.cfg.xml        # mybatis配置文件所在路径
      type-aliases-package: com.wuk.entity    # 所有Entity别名类所在包
      mapper-locations: 
      - classpath:mybatis/mapper/**/*.xml
       
    spring:
       application:
        name: microservicecloud-dept 
       datasource:
        type: com.alibaba.druid.pool.DruidDataSource            # 当前数据源操作类型
        driver-class-name: org.gjt.mm.mysql.Driver              # mysql驱动包
        url: jdbc:mysql://127.0.0.1:3306/cloudDB01              # 数据库名称
        username: root
        password: root
        dbcp2:
          min-idle: 5 # 数据库连接池的最小维持连接数
          initial-size: 5 # 初始化连接数
          max-total: 5 # 最大连接数
          max-wait-millis: 200 # 等待连接获取的最大超时时间
          
    eureka:
      client: #客户端注册进eureka服务列表内
        service-url: 
          defaultZone: http://localhost:7001/eureka
      instance:
        instance-id: microservicecloud-dept  #自定义服务名称 
        prefer-ip-address: true #显示服务ip

其他的文件就和上一篇一致，不做展示。

## 3 消费方 microservicecloud-consumer-dept-80 ##

主要是将其设置为EurekaClient端，然后利用ribbon进行负载均衡访问，这里我们利用ribbon只是简单的访问，不做其他，下一篇进行真正的负载均衡。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3d1MjM3NDYzMzU4Mw_size_16_color_FFFFFF_t_70 2]  
pom.xml

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    	<modelVersion>4.0.0</modelVersion>
    	<parent>
    		<groupId>com.wuk.springcloud</groupId>
    		<artifactId>microservicecloud</artifactId>
    		<version>0.0.1-SNAPSHOT</version>
    	</parent>
    	<artifactId>microservicecloud-consumer-dept-80</artifactId>
    	<description>部门微服务消费者</description>
    	<dependencies>
    		<dependency>
    			<groupId>com.wuk.springcloud</groupId>
    			<artifactId>microservicecloud-api</artifactId>
    			<version>${project.version}</version>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-web</artifactId>
    		</dependency>
    		
    		<dependency>
    			<groupId>org.springframework</groupId>
    			<artifactId>springloaded</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-devtools</artifactId>
    		</dependency>
    
    		
    		<dependency>
    			<groupId>org.springframework.cloud</groupId>
    			<artifactId>spring-cloud-starter-eureka</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework.cloud</groupId>
    			<artifactId>spring-cloud-starter-ribbon</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework.cloud</groupId>
    			<artifactId>spring-cloud-starter-config</artifactId>
    		</dependency>
    	</dependencies>
    
    </project>

application.yml

server:
      port: 80
      
    eureka:
      client:
        register-with-eureka: false
        service-url: 
          defaultZone: http://127.0.0.1:7001/eureka/

ConfigBean.java

主要配置@LoadBalanced注解

package com.wuk.cfgbeans;
    
    import org.springframework.cloud.client.loadbalancer.LoadBalanced;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.web.client.RestTemplate;
    
    
    @Configuration
    public class ConfigBean { 
    	/** * RestTemplate提供了多种便捷访问远程Http服务的方法， 是一种简单便捷的访问restful服务模板类，是Spring提供的用于访问Rest服务的客户端模板工具集 * @return */
    	@LoadBalanced
    	@Bean
    	public RestTemplate getRestTemplate() { 
    		return new RestTemplate();
    	}
    
    }

DeptController\_Consumer.java

package com.wuk.controller;
    
    import java.util.List;
    
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.web.bind.annotation.PathVariable;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RestController;
    import org.springframework.web.client.RestTemplate;
    
    import com.wuk.entity.Dept;
    
    @RestController
    public class DeptController_Consumer { 
    	//之前我们采用的是ip+端口，现在直接采用服务名
    	private static final String REST_URL_PREFIX = "http://MICROSERVICECLOUD-DEPT";
    
    	@Autowired
    	private RestTemplate restTemplate;
    
    	@RequestMapping(value = "/consumer/dept/add")
    	public boolean add(Dept dept) { 
    		return restTemplate.postForObject(REST_URL_PREFIX + "/dept/add", dept, Boolean.class);
    	}
    	
    	@RequestMapping(value = "/consumer/dept/get/{id}")
    	public Dept get(@PathVariable("id") Long id) { 
    		return restTemplate.getForObject(REST_URL_PREFIX + "/dept/get/" + id, Dept.class);
    	}
    
    	@SuppressWarnings("unchecked")
    	@RequestMapping(value = "/consumer/dept/list")
    	public List<Dept> list() { 
    		return restTemplate.getForObject(REST_URL_PREFIX + "/dept/list", List.class);
    	}
    }

CusumerDeptApplication.java

package com.wuk;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
    
    @SpringBootApplication
    @EnableEurekaClient
    public class CusumerDeptApplication { 
    
    	public static void main(String[] args) { 
    		
    		SpringApplication.run(CusumerDeptApplication.class, args);
    	}
    }

[代码案例][Link 1]

[2019010422364823.png]: /images/20220330/fabdb32e42604eb6b844b9fa66966cf8.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3d1MjM3NDYzMzU4Mw_size_16_color_FFFFFF_t_70]: /images/20220330/c54a7a0e3b284ebfa9ed145849e70303.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3d1MjM3NDYzMzU4Mw_size_16_color_FFFFFF_t_70 1]: /images/20220330/116af1870f204c68b2c7874a9a2eafb9.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3d1MjM3NDYzMzU4Mw_size_16_color_FFFFFF_t_70 2]: /images/20220330/acc1d6db91144de4b486ad393958d200.png
[Link 1]: https://download.csdn.net/download/wu2374633583/10897350