spirngcloud使用ribbon+RestTemplate实现负载均衡

水深无声 2022-04-25 09:58 183阅读 0赞

**话不多少，直接上图上代码**

一，总项目结构图

demo是一个maven项目，什么东西都不要填，直接创建就好。eureka-server，eureka-client1，eureka-client2，eureka-ribbon都是四个springboot项目。demo的pom.xml文件里面也是什么都没有。

![20190531111503683.jpg][]

二，eureka-server结构图

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDQ5OTM5NA_size_16_color_FFFFFF_t_70][]

二（1） eureka-server的pom.xml文件

**需要进行的依赖选择**

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDQ5OTM5NA_size_16_color_FFFFFF_t_70 1][]

<?xml version="1.0" encoding="UTF-8"?>
    <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>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <version>2.1.5.RELEASE</version>
            <relativePath/> 
        </parent>
        <groupId>com.dr</groupId>
        <artifactId>eureka-server</artifactId>
        <version>0.0.1-SNAPSHOT</version>
        <name>eureka-server</name>
        <description>Demo project for Spring Boot</description>
    
        <properties>
            <java.version>1.8</java.version>
            <spring-cloud.version>Greenwich.SR1</spring-cloud.version>
        </properties>
    
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
            </dependency>
    
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
            </dependency>
        </dependencies>
    
        <dependencyManagement>
            <dependencies>
                <dependency>
                    <groupId>org.springframework.cloud</groupId>
                    <artifactId>spring-cloud-dependencies</artifactId>
                    <version>${spring-cloud.version}</version>
                    <type>pom</type>
                    <scope>import</scope>
                </dependency>
            </dependencies>
        </dependencyManagement>
    
        <build>
            <plugins>
                <plugin>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-maven-plugin</artifactId>
                </plugin>
            </plugins>
        </build>
    
    </project>

二(2) eureka-server的 application.properties文件

server.port=8761
    eureka.instance.hostname=localhost
    #表示是否注册Eureka服务器,因为自身作为服务注册中心，所以为false
    eureka.client.register-with-eureka=false
    #是否从eureka上获取注册信息，同上
    eureka.client.fetch-registry=false
    eureka.client.service-url.defaultZone=http://${eureka.instance.hostname}:${server.port}/eureka

二(3) eureka-server 的 EurekaServerApplication文件

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

三 eureka-client1结构图

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDQ5OTM5NA_size_16_color_FFFFFF_t_70 2][]

三(1)eureka-client1的pom.xml

**需要的依赖选择**

**![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDQ5OTM5NA_size_16_color_FFFFFF_t_70 3][]**

<?xml version="1.0" encoding="UTF-8"?>
    <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>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <version>2.1.5.RELEASE</version>
            <relativePath/> 
        </parent>
        <groupId>com.dr</groupId>
        <artifactId>eureka-client1</artifactId>
        <version>0.0.1-SNAPSHOT</version>
        <name>eureka-client1</name>
        <description>Demo project for Spring Boot</description>
    
        <properties>
            <java.version>1.8</java.version>
            <spring-cloud.version>Greenwich.SR1</spring-cloud.version>
        </properties>
    
        <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
            </dependency>
    
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
            </dependency>
        </dependencies>
    
        <dependencyManagement>
            <dependencies>
                <dependency>
                    <groupId>org.springframework.cloud</groupId>
                    <artifactId>spring-cloud-dependencies</artifactId>
                    <version>${spring-cloud.version}</version>
                    <type>pom</type>
                    <scope>import</scope>
                </dependency>
            </dependencies>
        </dependencyManagement>
    
        <build>
            <plugins>
                <plugin>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-maven-plugin</artifactId>
                </plugin>
            </plugins>
        </build>
    
    </project>

三(2) eureak-client1的application.properties文件

server.port=8762
    #服务名
    spring.application.name=service-client
    eureka.client.service-url.defaultZone=http://localhost:8761/eureka/

三(3)eureka-clie的EurekaClient1Application文件

package com.dr;
    
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
    import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RestController;
    
    @SpringBootApplication
    @EnableEurekaClient
    @RestController
    public class EurekaClient1Application {
    
        public static void main(String[] args) {
            SpringApplication.run(EurekaClient1Application.class, args);
        }
    
    
        @Value("${server.port}")
        String port;
    
        @RequestMapping("/hi")
        public String client(){
            return "第一个客户端的port"+port;
        }
    
    }

**四 eureka-client2的结构图和eureka-client1的结构图一样，eureka-client2的pom.xml文件和eureka-client1的pom.xml文件           也是一 样的 ，只有application.properties文件和启动类不同**

四（1) eureka-client2的application.properties文件

只是改了其中的端口

server.port=8763
    spring.application.name=service-client
    eureka.client.service-url.defaultZone=http://localhost:8761/eureka/

四(2) eureka-client2的 EurekaClient2Application文件

package com.dr;
    
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
    import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RestController;
    
    @SpringBootApplication
    @EnableEurekaClient
    @RestController
    public class EurekaClient2Application {
    
        public static void main(String[] args) {
            SpringApplication.run(EurekaClient2Application.class, args);
        }
    
        @Value("${server.port}")
        String port;
    
        @RequestMapping("/hi")
        public String client(){
            return "第二个客户端的port"+port;
        }
    
    }

五  eureka-ribbon项目结构图

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDQ5OTM5NA_size_16_color_FFFFFF_t_70 4][]

五(1)  eureka-ribbon的pom.xml文件

**需要的依赖选择 **

**![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDQ5OTM5NA_size_16_color_FFFFFF_t_70 5][]**

<?xml version="1.0" encoding="UTF-8"?>
    <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>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <version>2.1.5.RELEASE</version>
            <relativePath/> 
        </parent>
        <groupId>com.dr</groupId>
        <artifactId>eureka-ribbon</artifactId>
        <version>0.0.1-SNAPSHOT</version>
        <name>eureka-ribbon</name>
        <description>Demo project for Spring Boot</description>
    
        <properties>
            <java.version>1.8</java.version>
            <spring-cloud.version>Greenwich.SR1</spring-cloud.version>
        </properties>
    
        <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-netflix-ribbon</artifactId>
            </dependency>
    
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
            </dependency>
        </dependencies>
    
        <dependencyManagement>
            <dependencies>
                <dependency>
                    <groupId>org.springframework.cloud</groupId>
                    <artifactId>spring-cloud-dependencies</artifactId>
                    <version>${spring-cloud.version}</version>
                    <type>pom</type>
                    <scope>import</scope>
                </dependency>
            </dependencies>
        </dependencyManagement>
    
        <build>
            <plugins>
                <plugin>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-maven-plugin</artifactId>
                </plugin>
            </plugins>
        </build>
    
    </project>

五(2) eureka-ribbon的application.properties文件

server.port=8764
    spring.application.name=service-ribbon
    eureka.client.service-url.defaultZone=http://localhost:8761/eureka/

五(3)eureka-ribbon的EurekaRibbonApplication文件

package com.dr;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
    
    @SpringBootApplication
    @EnableDiscoveryClient
    public class EurekaRibbonApplication {
    
        public static void main(String[] args) {
            SpringApplication.run(EurekaRibbonApplication.class, args);
        }
    
    }

五(3)eureka-ribbon的RibbonService文件

package com.dr.ribbonService;
    
    import org.springframework.beans.factory.annotation.Autowired;
    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 RibbonService {
    
        /**
         * Configuration  代表这是一个RestTemplate配置
         *
         * Bean  应用在方法上，用来将方法返回值设为为bean
         *
         * LoadBalanced  实现负载均衡，一定要加
         *
         * @return
         */
    
        @Bean
        @LoadBalanced
        public RestTemplate restTemplate(){
            return new RestTemplate();
        }
    }

五(4)eureka-ribbon的RibbonRestTemplate文件

package com.dr.ribbonController;
    
    
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RestController;
    import org.springframework.web.client.RestTemplate;
    
    @RestController
    public class RibbonRestTemplate {
    
    
        @Autowired
        RestTemplate restTemplate;
    
        @RequestMapping("/hi")
        public String sayClient(){
            return  restTemplate.getForObject("http://service-client/hi/",String.class);
        }
    
    }

**至此项目写完，接下来测试。依次开启eureka-server    eureka-client1   eureka-client2    eureka-ribbon**

**看到的画面如下**

**![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDQ5OTM5NA_size_16_color_FFFFFF_t_70 6][]**

**然后以端口号8764进行测试，刷新两次，会看到如下画面的效果**

**[http://localhost:8764/hi][http_localhost_8764_hi] 进行访问**

**![20190531120228408.jpg][]**

![20190531120244558.jpg][]

**至此就实现了ribbon和RestTemplate的负载均衡**

[20190531111503683.jpg]: /images/20220125/1df05646ce1b4c3c9e833c7556eb5b1d.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDQ5OTM5NA_size_16_color_FFFFFF_t_70]: /images/20220125/8bdc210a20844a748b9497bb81d6e7f5.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDQ5OTM5NA_size_16_color_FFFFFF_t_70 1]: /images/20220125/6e88e979d2b74f7aafb704fd0fad7292.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDQ5OTM5NA_size_16_color_FFFFFF_t_70 2]: /images/20220125/71ffa40136d545ce8ae52fe8fc089919.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDQ5OTM5NA_size_16_color_FFFFFF_t_70 3]: /images/20220125/3640640d02ca46608417d86bafe6ce84.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDQ5OTM5NA_size_16_color_FFFFFF_t_70 4]: /images/20220125/18565ed7095f478394d79a997e387cf7.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDQ5OTM5NA_size_16_color_FFFFFF_t_70 5]: /images/20220125/add57f15cc6644bf9cccac06059da992.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDQ5OTM5NA_size_16_color_FFFFFF_t_70 6]: /images/20220125/ab7276a197d849bab021c06b86886d99.png
[http_localhost_8764_hi]: http://localhost:8764/hi
[20190531120228408.jpg]: /images/20220125/5d7d1b13122c4b86ba0f7cba8bb178fb.png
[20190531120244558.jpg]: /images/20220125/db57f4577eec47d7943611119e7ef46f.png