Ribbon 框架简介及搭建（没有与SpringCloud整合，独立使用）

ribbon简介

1.  负载均衡框架，支持可插拔式的负载均衡规则

2.  支持多种协议，如http、udp等

3.  提供负载均衡客户端

ribbon子模块

1.  ribbon-core（ribbon的核心，主要包含负载均衡器、负载均衡接口、客户端接口、内置负载均衡实现api）

2.  ribbon-eureka（为eureka客户端提供的客户端实现类）

3.  ribbon-httpclient（为负载均衡提供了rest客户端）

负载均衡器组件

1.  一个负载均衡器，至少提供以下功能

1.1  要维护各个服务器的ip等信息

1.2  根据特定逻辑选取服务器

2.  为了实现基本的负载均衡功能，ribbon的负载均衡器有三大子模块

2.1  rule

2.2  ping

2.3  serverlist

 

至于负载均衡的机制和规则，笔者会在下一章的 “ribbon负载均衡机制” 中进行讲解，那么在这里就不多说了。

 

 

由于本次的教程是没有与springcloud整合的，是用来单独使用的，下面就教大家怎么搭建ribbon程序 并 调用服务。

 

1：创建ribbon服务器（一个单纯的springboot程序）

pom.xml

<dependencies>
    <dependency>
        <groupid>org.springframework.boot</groupid>
        <artifactid>spring-boot-starter-web</artifactid>
        <version>1.5.7.release</version>
    </dependency>
</dependencies>

 

为了方便ribbon客户端测试，在这里建一个实体类：person.java

public class person {
    private string url;// 处理请求的服务器url
    private string message;// 提示信息
    
    public string geturl() {
        return url;
    }
    public void seturl(string url) {
        this.url = url;
    }
    public string getmessage() {
        return message;
    }
    public void setmessage(string message) {
        this.message = message;
    }
}

 

personcontroller.java

@restcontroller
public class personcontroller {

    @requestmapping(value="/getperson", method=requestmethod.get, produces=mediatype.application_json_value)
    public person getperson(httpservletrequest request){
        person p = new person();
        p.setmessage("请求成功");
        p.seturl(request.getrequesturl().tostring());
        return p;
    }
}

 

启动类：application.java（因为要测试负载均衡，所有这里需要启动多个服务，以下配置以手动输入端口号方式启动）

@springbootapplication
public class application {

    public static void main(string[] args) {
        scanner scan = new scanner(system.in);
        string port = scan.nextline();
        new springapplicationbuilder(application.class).properties("server.port="+port).run(args);
    }
}

 

本次启动以端口：8080、8081分别启动，稍后我们配置完客户端 统一测试（配置后，将服务启动）

 

2：创建ribbon客户端

 pom.xml 中只需要引入核心及客户端的依赖即可

<dependency>
    <groupid>com.netflix.ribbon</groupid>
    <artifactid>ribbon-core</artifactid>
    <version>2.2.5</version>
</dependency>
<dependency>
    <groupid>com.netflix.ribbon</groupid>
    <artifactid>ribbon-httpclient</artifactid>
    <version>2.2.5</version>
</dependency>

 

编写main方法测试，调用服务（服务列表也可以直接在配置文件中配置，本次用setproperty进行配置）其中的my-client，这个名称可以任意起，因为这个名称是用来命名配置创建客户端的。

public static void main(string[] args) {
    try {
        // 写入服务列表
        configurationmanager.getconfiginstance().setproperty("my-client.ribbon.listofservers", "localhost:8080,localhost:8081");
        // 输出服务列表
        system.out.println("服务列表：" + configurationmanager.getconfiginstance().getproperty("my-client.ribbon.listofservers"));
        // 获取客户端（如果获取不到，可通过getnamedclient方法自动创建）
        restclient client = (restclient) clientfactory.getnamedclient("my-client");
        // 创建request对象
        httprequest request = httprequest.newbuilder().uri(new uri("/getperson")).build();// 写入将要访问的接口
        // 多次访问测试
        for (int i = 0; i < 10; i++) {
            // 创建response对象
            httpresponse response = client.executewithloadbalancer(request);
            // 接收请求结果
            string json = response.getentity(string.class);
            // 打印结果
            system.out.println(json);
        }
    } catch (exception e) {
        e.printstacktrace();
    }
}

 

以上就是ribbon单独使用的全部过程，下面大家看一下ribbon负载均衡默认的轮询规则

服务列表：[localhost:8080, localhost:8081]
{"url":"http://localhost:8081/getperson","message":"请求成功"}
{"url":"http://localhost:8080/getperson","message":"请求成功"}
{"url":"http://localhost:8081/getperson","message":"请求成功"}
{"url":"http://localhost:8080/getperson","message":"请求成功"}
{"url":"http://localhost:8081/getperson","message":"请求成功"}
{"url":"http://localhost:8080/getperson","message":"请求成功"}
{"url":"http://localhost:8081/getperson","message":"请求成功"}
{"url":"http://localhost:8080/getperson","message":"请求成功"}
{"url":"http://localhost:8081/getperson","message":"请求成功"}
{"url":"http://localhost:8080/getperson","message":"请求成功"}