SpringCloud微服务实现生产者消费者+ribbon负载均衡

一、生产者springcloud_eureka_provider

  (1)目录展示

    

  (2)导入依赖

    

<dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-web</artifactId>
    </dependency>

      <!--eureka依赖-->
      <dependency>
          <groupId>org.springframework.cloud</groupId>
          <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
      </dependency>

 <dependencyManagement>
        <dependencies>
            <!--springCloud依赖-->
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>Greenwich.RELEASE</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>

  (3)配置文件application.yml

##应用名称
spring:
  application:
    name: eureka-provider
##声明当前eurekaservice的端口号
server:
  port: 8890

##配置eureka
eureka:
  client:
    service-url:
      defaultZone: http://localhost:8888/eureka   

  (4)IDoSomeService

package com.zn.service;

public interface IDoSomeService {
    public String doSome();
}

  (5)IDoSomeServiceImpl

package com.zn.service.impl;

import com.zn.service.IDoSomeService;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class IDoSomeServiceImpl implements IDoSomeService {

    @RequestMapping("/doSome")

    @Override
    public String doSome() {
        System.out.println("服务提供者!");
        return "eureka到达页面hhhh";
    }
}

  (6)启动类

    

二、生产者springcloud_eureka_consumer

  (1)目录展示

    

  (2)导入依赖

    

<!--eureka依赖-->
    <dependency>
      <groupId>org.springframework.cloud</groupId>
      <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
    </dependency>

<dependencyManagement>
    <dependencies>
      <!--springCloud依赖-->
      <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-dependencies</artifactId>
        <version>Greenwich.RELEASE</version>
        <type>pom</type>
        <scope>import</scope>
      </dependency>
    </dependencies>
  </dependencyManagement>

  (3)配置文件application.yml

##应用名称
spring:
  application:
    name: eureka-consumer
##声明当前eurekaservice的端口号
server:
  port: 8891

##配置eureka
eureka:
  client:
    service-url:
      defaultZone: http://localhost:8888/eureka

  (4)IDoSomeController

package com.zn.controller;

import com.zn.service.IDoSomeService;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;

import javax.annotation.Resource;

@RestController
public class IDoSomeController {

    @Resource
    RestTemplate restTemplate;

    /*@Resource
    IDoSomeService iDoSomeService;
*/
    @RequestMapping("/doSome")
    public String doSome(){
        System.out.println("ConsumerController");

        return restTemplate.getForObject("http://eureka-provider/doSome",String.class);
        //return iDoSomeService.doSome();
    }
}

  (5)StartEurekaConsumer启动类

package com.zn;

import com.netflix.loadbalancer.IRule;
import com.netflix.loadbalancer.RandomRule;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;
import org.springframework.cloud.openfeign.EnableFeignClients;
import org.springframework.context.annotation.Bean;
import org.springframework.web.client.RestTemplate;

@SpringBootApplication
public class StartEurekaConsumer {
    public static void main(String[] args) {
        SpringApplication.run(StartEurekaConsumer.class,args);
    }

    @Bean
    @LoadBalanced  //实现负载均衡
    RestTemplate restTemplate(){
        return new RestTemplate();
    }
}

  (6)效果

    

    

三、ribbon负载均衡

  (1)导入依赖

 <!--feign依赖-->
    <dependency>
      <groupId>org.springframework.cloud</groupId>
      <artifactId>spring-cloud-starter-openfeign</artifactId>
    </dependency>

(2)IDoSomeService

package com.zn.service;

import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.RequestMapping;

@FeignClient("eureka-provider")
public interface IDoSomeService {
    @RequestMapping("/doSome")
    public String doSome();
}

  (3)启动类StartEurekaConsumer

package com.zn.controller;

import com.zn.service.IDoSomeService;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;

import javax.annotation.Resource;

@RestController
public class IDoSomeController {

    //@Resource
    //RestTemplate restTemplate;

    @Resource
    IDoSomeService iDoSomeService;

    @RequestMapping("/doSome")
    public String doSome(){
        System.out.println("ConsumerController");

        //return restTemplate.getForObject("http://eureka-provider/doSome",String.class);
        return iDoSomeService.doSome();
    }
}

  (4)效果

    

    

     

  

原文地址:https://www.cnblogs.com/Zzzzn/p/12055571.html

时间: 2024-11-06 07:31:47

SpringCloud微服务实现生产者消费者+ribbon负载均衡的相关文章

SpringCloud:Ribbon负载均衡

1.概述 Spring Cloud Ribbon是基于Netflix Ribbon实现的一套客户端       负载均衡的工具. 简单的说,Ribbon是Netflix发布的开源项目,主要功能是提供客户端的软件负载均衡算法,将Netflix的中间层服务连接在一起. Ribbon客户端组件提供一系列完善的配置项如连接超时,重试等. 简单的说,就是在配置文件中列出Load Balancer(简称LB)后面所有的机器,Ribbon会自动的帮助你基于某种规则(如简单轮询,随机连接等)去连接这些机器. 我

浅谈SpringCloud (三) Ribbon负载均衡

什么是负载均衡 当一台服务器的单位时间内的访问量越大时,服务器压力就越大,大到超过自身承受能力时,服务器就会崩溃.为了避免服务器崩溃,让用户有更好的体验,我们通过负载均衡的方式来分担服务器压力. 我们可以建立很多很多服务器,组成一个服务器集群,当用户访问网站时,先访问一个中间服务器,在让这个中间服务器在服务器集群中选择一个压力较小的服务器,然后将该访问请求引入该服务器.如此以来,用户的每次访问,都会保证服务器集群中的每个服务器压力趋于平衡,分担了服务器压力,避免了服务器崩溃的情况. Ribbon

SpringCloud系列五:Ribbon 负载均衡(Ribbon 基本使用、Ribbon 负载均衡、自定义 Ribbon 配置、禁用 Eureka 实现 Ribbon 调用)

1.概念:Ribbon 负载均衡 2.具体内容 现在所有的服务已经通过了 Eureka 进行了注册,那么使用 Eureka 注册的目的是希望所有的服务都统一归属到 Eureka 之中进 行处理,但是现在的问题,所有的微服务汇集到了 Eureka 之中,而客户端的调用也应该通过 Eureka 完成.而这种调用就可以利用 Ribbon 技术来实现. Ribbon 是一个服务调用的组件,并且是一个客户端实现负载均衡处理的组件.服务器端实现负载均衡可以使用 Nginx. HAProxy.LVS 等. 2

Ribbon负载均衡及Feign消费者调用服务

微服务调用Ribbon 简介 前面讲了eureka服务注册与发现,但是结合eureka集群的服务调用没讲. 这里的话 就要用到Ribbon,结合eureka,来实现服务的调用: Ribbon是Netflix发布的负载均衡器,它有助于控制HTTP和TCP的客户端的行为.为Ribbon配置服务提供者地址后,Ribbon就可基于某种负载均衡算法,自动地帮助服务消费者去请求.Ribbon默认为我们提供了很多负载均衡算法,例如轮询.随机等.当然,我们也可为Ribbon实现自定义的负载均衡算法. 在Spri

SpringCloud之Ribbon负载均衡配置

一.负载均衡解决方案分类及特征 业界主流的负载均衡解决方案有: 1.1 集中式负载均衡 即在客户端和服务端之间使用独立的负载均衡设施(可以是硬件,如F5, 也可以是软件,如nginx), 由该设施负责把访问请求通过某种策略转发至服务端. 1.2 进程内负载均衡 将负载均衡逻辑集成到客户端组件中,客户端组件从服务注册中心获知有哪些地址可用,然后自己再从这些地址中选择出一个合适的服务端发起请求.Ribbon就是一个进程内的负载均衡实现. 二.Ribbon常用负载均衡策略 Ribbon就属于进程内负载

Ribbon 负载均衡

一.是什么 Spring Cloud Ribbon 是基于 Netfix Ribbon 实现的一套客户端(服务的消费者)负载均衡的工具 二.用法 服务消费者工程的 pom.xml 添加如下内容 <!-- Ribbon相关 --> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-eureka</artifact

spring cloud ribbon 负载均衡类1

Ribbon 在实现客户端负载均衡时,是通过Ribbo的ILoadBalancer接口实现的. AbstractLoadBalancer 是ILoadBalancer接口的抽象实现,定义了一个分组枚举类ServerGroup 还实现了一个chooseServer()方法,其中key为null,表示在选择具体实例时忽略key的条件判断 还定义了两个抽象方法 getServerList(ServerGroup serverGroup):根据分组类型获取不同的实例列表 getLoadBalancerS

Spring Cloud微服务Ribbon负载均衡/Zuul网关使用

客户端负载均衡,当服务节点出现问题时进行调节或是在正常情况下进行 服务调度.所谓的负载均衡,就是当服务提供的数量和调用方对服务进行 取舍的调节问题,在spring cloud中是通过Ribbon来解决的.还有另外一 种途径是通过服务端的负载均衡Nginx来解决.Ribbon是客户端的负载均 衡,通过Eureka来获取所有的服务的数量,客户端来调用服务时,Ribbon 通过一系列的算法来进行调节,选择哪个服务来进行调用.默认无需对 Ribbon进行配置,它会采用默认的算法进行负载均衡.可以对负载均

Spring-cloud微服务实战【五】:负载均衡ribbon

在实战三中,我们曾说到,我们需要一种机制,可以在访问服务的时候不需要关心IP,并且还能提供类似Nginx的负载均衡的功能,其实在上一篇文章中我们已经使用过spring-cloud的负载均衡功能了,还记得我们在配置restTemplate的时候加的注解吗? @LoadBalanced就是告诉restTemplate,需要使用负载均衡,并且,在eureka-client消费者消费服务的时候,只能通过@LoadBalanced才能使用eureka-server中的服务application-name来