博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
Ribbon 框架简介及搭建
阅读量:6218 次
发布时间:2019-06-21

本文共 3814 字,大约阅读时间需要 12 分钟。

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

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

1:创建Ribbon服务器(一个单纯的SpringBoot程序)

pom.xml

org.springframework.boot
spring-boot-starter-web
1.5.7.RELEASE
复制代码

为了方便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

@RestControllerpublic 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(因为要测试负载均衡,所有这里需要启动多个服务,以下配置以手动输入端口号方式启动)

@SpringBootApplicationpublic 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 中只需要引入核心及客户端的依赖即可

com.netflix.ribbon
ribbon-core
2.2.5
com.netflix.ribbon
ribbon-httpclient
2.2.5
复制代码

编写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":"请求成功"}复制代码

转载地址:http://kflja.baihongyu.com/

你可能感兴趣的文章
ToRPC:一个双向RPC的Python实现
查看>>
我的友情链接
查看>>
nginx在reload时候报错invalid PID number
查看>>
神经网络和深度学习-第二周神经网络基础-第二节:Logistic回归
查看>>
Myeclipse代码提示及如何设置自动提示
查看>>
c/c++中保留两位有效数字
查看>>
ElasticSearch 2 (32) - 信息聚合系列之范围限定
查看>>
VS2010远程调试C#程序
查看>>
[MicroPython]TurniBit开发板DIY自动窗帘模拟系统
查看>>
由String类的Split方法所遇到的两个问题
查看>>
Python3.4 12306 2015年3月验证码识别
查看>>
从Handler.post(Runnable r)再一次梳理Android的消息机制(以及handler的内存泄露)
查看>>
自制操作系统Antz day11——实现shell(下)命令响应
查看>>
windows查看端口占用
查看>>
strongswan ikev2 server on ubuntu 14.04
查看>>
Yii用ajax实现无刷新检索更新CListView数据
查看>>
JDBC的事务
查看>>
linux服务器CPU参数/proc/cpuinfo
查看>>
haystack+Elasticsearch搜素引擎
查看>>
UEFI系统安装U盘的制作方式
查看>>