| 编辑推荐: |
本文主要介绍 Ribbon 在微服务中的作用，并结合项目案例讲解Ribbon 中对于集群的服务采用的负载均衡的策略，希望对您的学习有所帮助。
本文来自于云社区，由火龙果软件Alice编辑、推荐。 |
|
一、 Ribbon 在微服务中的作用
1 什么是 Ribbon
Ribbon 是一个基于 Http 和 TCP 的客服端负载均衡工具，它是基于 Netflix Ribbon
实现的。
它不像 spring cloud 服务注册中心、配置中心、API 网关那样独立部署，但是它几乎存在于每个
spring cloud 微服务中。包括 feign 提供的声明式服务调用也是基于该 Ribbon实现的。
ribbon 默认提供很多种负载均衡算法，例如 轮询、随机 等等。甚至包含自定义的负载均衡算法。
2 Ribbon 解决了什么问题
他解决并提供了微服务的负载均衡的问题。
二、 集中式与进程内负载均衡的区别
1 负载均衡解决方案的分类
目前业界主流的负载均衡方案可分成两类：
第一类：集中式负载均衡, 即在 consumer 和 provider 之间使用独立的负载均衡设施(可以是硬件，如
F5, 也可以是软件，如 nginx), 由该设施负责把 访问请求 通过某种策略转发至 provider；
第二类：进程内负载均衡，将负载均衡逻辑集成到 consumer，consumer 从服务注册中心获知有哪些地址可用，然后自己再从这些地址中选择出一个合适的
provider。Ribbon 就属于后者，它只是一个类库，集成于 consumer 进程，consumer
通过它来获取到 provider 的地址。
2 两种负载均衡方式结构图
三、 Ribbon 的入门案例
Ribbon 中对于集群的服务采用的负载均衡的策略默认的是轮询,本案例的项目结构
1.provider
1.1将 provider 打包。部署到 linux 环境中
1.2创建启动脚本 server.sh
注意修改 JAR_NAME
#!/bin/bash
cd `dirname $0`
CUR_SHELL_DIR=`pwd`
CUR_SHELL_NAME=`basename ${BASH_SOURCE}`
JAR_NAME="springcloud-eureka-ribbon-provider-0.0.1-SNAPSHOT.jar"
JAR_PATH=$CUR_SHELL_DIR/$JAR_NAME
#JAVA_MEM_OPTS=" -server -Xms1024m -Xmx1024m
-XX:PermSize=128m"
JAVA_MEM_OPTS=""
#SPRING_PROFILES_ACTIV="-Dspring.profiles.active=配置文件变量名称"
SPRING_PROFILES_ACTIV=""
LOG_DIR=$CUR_SHELL_DIR/logs
LOG_PATH=$LOG_DIR/${JAR_NAME%..log
echo_help()
{
echo -e "syntax: sh $CUR_SHELL_NAME start|stop"
}
if [ -z $1 ];then
echo_help
exit 1
fi
if [ ! -d "$LOG_DIR" ];then
mkdir "$LOG_DIR"
fi
if [ ! -f "$LOG_PATH" ];then
touch "$LOG_DIR"
fi
if [ "$1" == "start" ];then
# check server
PIDS=`ps --no-heading -C java -f --width 1000
| grep $JAR_NAME | awk '{print $2}'`
if [ -n "$PIDS" ]; then
echo -e "ERROR: The $JAR_NAME already started
and the PID is ${PIDS}."
exit 1
fi
echo "Starting the $JAR_NAME..."
# start
nohup java $JAVA_MEM_OPTS -jar $SPRING_PROFILES_ACTIV
$JAR_PATH >> $LOG_PATH 2>&1 &
COUNT=0
while [ $COUNT -lt 1 ]; do
sleep 1
COUNT=`ps --no-heading -C java -f --width 1000
| grep "$JAR_NAME" | awk '{print $2}'
| wc -l`
if [ $COUNT -gt 0 ]; then
break
fi
done
PIDS=`ps --no-heading -C java -f --width 1000
| grep "$JAR_NAME" | awk '{print $2}'`
echo "${JAR_NAME} Started and the PID is
${PIDS}."
echo "You can check the log file in ${LOG_PATH}
for details."
elif [ "$1" == "stop" ];then
PIDS=`ps --no-heading -C java -f --width 1000
| grep $JAR_NAME | awk '{print $2}'`
if [ -z "$PIDS" ]; then
echo "ERROR:The $JAR_NAME does not started!"
exit 1
fi
echo -e "Stopping the $JAR_NAME..."
for PID in $PIDS; do
kill $PID > /dev/null 2>&1
done
COUNT=0
while [ $COUNT -lt 1 ]; do
sleep 1
COUNT=1
for PID in $PIDS ; do
PID_EXIST=`ps --no-heading -p $PID`
if [ -n "$PID_EXIST" ]; then
COUNT=0
break
fi
done
done
echo -e "${JAR_NAME} Stopped and the PID
is ${PIDS}."
else
echo_help
exit 1
fi |
授权
然后通过脚本启动服务。
2.consumer
消费者主要是注意service中的服务调用，代码如下
/**
* @program: springcloud-eureka-consumer
* @description: 用户的业务处理
* @author: 波波烤鸭
* @create: 2019-05-28 17:43
*/
@Service
public class UserService {
/**
* ribbon 负载均衡
* LoadBalancerClient 通过服务名称可以获取对应的服务的相关信息 ip
port等
*/
@Autowired
private LoadBalancerClient loadBalancerClient;
public List<User> getUsers(){
// ServiceInstance 封装的有服务的基本信息 IP和端口等
ServiceInstance si = this.loadBalancerClient.choose("eureka-ribbon-provider");
StringBuilder sb = new StringBuilder();
sb.append("http://")
.append(si.getHost())
.append(":")
.append(si.getPort())
.append("/user");
System.out.println("服务地址:"+sb.toString());
// SpringMVC RestTemplate
RestTemplate rt = new RestTemplate();
ParameterizedTypeReference<List<User>>
type = new ParameterizedTypeReference<List<User>>()
{};
// ResponseEntity:封装了返回值的信息
ResponseEntity<List<User>> response
= rt.exchange(sb.toString(), HttpMethod.GET,null,type);
List<User> list = response.getBody();
return list;
}
} |
注意配置文件中注册中心同样需要认证！
启动消费者，然后去注册中心查看
3.测试
访问消费者提供的服务
多次访问查看控制台输出
通过输出我们能发现负载均衡是通过轮询的方式实现的(默认)
注意在Windows下的hosts中添加对应的主机名和ip的映射关系！
|
