1. Что такое сервисный реестр
Реестр служб является основным компонентом регистрации и управления службами, аналогично роли служб каталогов, и в основном используется для хранения служебной информации, такой как строки URL-адресов поставщика служб, информация о маршрутизации и т. д. Реестр сервисов — одно из основных средств в архитектуре SOA.
1. Роль сервисного реестра
1. Регистрация услуг
2 Обнаружение службы
2. Общие реестры
1 Zookeeper, регистрационный центр Дубо
2 Эврика из SpringCloud
3. Какую проблему решает сервисный реестр
1. Управление услугами
2. Управление зависимостями сервисов
4. Что такое реестр Eureka
Eureka — это компонент обнаружения службы, разработанный Netflix.Это служба на основе Rest.SpringCloud интегрирует ее в свои подпроекты для реализации регистрации и обнаружения службы SpringCloud, а также обеспечивает балансировку нагрузки и регистрацию.
4.1 Три роли реестра Eureka
-
Eureka Server
Обеспечьте регистрацию и обнаружение службы с помощью таких интерфейсов, как «Регистрация», «Получить» и «Продлить».
-
Служба приложений (поставщик услуг)
поставщик услуг
Зарегистрируйте свой собственный экземпляр службы на Eureka Server
-
Клиент приложения (потребитель услуг)
вызывающий абонент
Получить список сервисов через Eureka Server и использовать сервисы
2. Корпус входа в Эврику
1. Создайте проект
1.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 https://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>1.5.13.RELEASE</version>
<relativePath /> <!-- lookup parent from repository -->
</parent>
<groupId>com.luyi</groupId>
<artifactId>springcloud-eureka-server</artifactId>
<version>0.0.1-SNAPSHOT</version>
<name>springcloud-eureka-server</name>
<description>Demo project for Spring Boot</description>
<properties>
<java.version>1.8</java.version>
</properties>
<dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-dependencies</artifactId>
<version>Dalston.SR5</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-config</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-eureka-server</artifactId>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
</project>
1.2 Изменить класс запуска
@EnableEurekaServer
@SpringBootApplication
public class EurekaApplication {
public static void main(String[] args) {
SpringApplication.run(EurekaApplication.class, args);
}
}
1.3 Изменить файл глобальной конфигурации
spring.application.name=eureka-server
#修改服务器端口
server.port=8761
#是否将自己注册到eureka-server中,默认为true
eureka.client.registerWithEureka=false
#是否从Eureka-server中获取服务信息,默认为true
eureka.client.fetchRegistry=false
1.4 Доступ к платформе управления услугами Eureka-Server через браузер
3. Создайте кластер Эврика
1. Создайте проект
1.1 Создать проект
springcloud-eureka-server-ha
1.2 Изменить файл конфигурации
При построении кластера Eureka вам необходимо добавить несколько файлов конфигурации и, используя метод конфигурации нескольких сред SpringBoot, добавить в кластер столько файлов конфигурации, сколько вам нужно.
1.3 Настройте узлы кластера в файле конфигурации
Eureka1
spring.application.name=eureka-server
#修改服务器端口
server.port=8761
#设置Eureka实例名称,以配置文件的变量为主
eureka.instance.hostname=eureka1
#设置服务注册中心地址,指向另一个注册中心
eureka.client.serviceUrl.defaultZone=http://eureka2:8761/eureka/
Eureka2
spring.application.name=eureka-server
#修改服务器端口
server.port=8761
#设置Eureka实例名称,以配置文件的变量为主
eureka.instance.hostname=eureka2
#设置服务注册中心地址,指向另一个注册中心
eureka.client.serviceUrl.defaultZone=http://eureka1:8761/eureka/
1.4 Добавить файл конфигурации журнала регистрации
<?xml version="1.0" encoding="UTF-8" ?>
<configuration>
<!--定义日志文件的存储地址 勿在 LogBack 的配置中使用相对路径-->
<property name="LOG_HOME" value="${catalina.base}/logs/" />
<!-- 控制台输出 -->
<appender name="Stdout" class="ch.qos.logback.core.ConsoleAppender">
<!-- 日志输出编码 -->
<layout class="ch.qos.logback.classic.PatternLayout">
<!--格式化输出:%d表示日期,%thread表示线程名,%-5level:级别从左显示5个字符宽度%msg:日志消息,%n是换行符-->
<pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{50} - %msg%n
</pattern>
</layout>
</appender>
<!-- 按照每天生成日志文件 -->
<appender name="RollingFile" class="ch.qos.logback.core.rolling.RollingFileAppender">
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
<!--日志文件输出的文件名-->
<FileNamePattern>${LOG_HOME}/server.%d{yyyy-MM-dd}.log</FileNamePattern>
<MaxHistory>30</MaxHistory>
</rollingPolicy>
<layout class="ch.qos.logback.classic.PatternLayout">
<!--格式化输出:%d表示日期,%thread表示线程名,%-5level:级别从左显示5个字符宽度%msg:日志消息,%n是换行符-->
<pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{50} - %msg%n
</pattern>
</layout>
<!--日志文件最大的大小-->
<triggeringPolicy class="ch.qos.logback.core.rolling.SizeBasedTriggeringPolicy">
<MaxFileSize>10MB</MaxFileSize>
</triggeringPolicy>
</appender>
<!-- 日志输出级别 -->
<root level="DEBUG">
<appender-ref ref="Stdout" />
<appender-ref ref="RollingFile" />
</root>
<!--日志异步到数据库 -->
<!-- <appender name="DB" class="ch.qos.logback.classic.db.DBAppender">
日志异步到数据库
<connectionSource class="ch.qos.logback.core.db.DriverManagerConnectionSource">
连接池
<dataSource class="com.mchange.v2.c3p0.ComboPooledDataSource">
<driverClass>com.mysql.jdbc.Driver</driverClass>
<url>jdbc:mysql://127.0.0.1:3306/databaseName</url>
<user>root</user>
<password>root</password>
</dataSource>
</connectionSource>
</appender> -->
</configuration>
1.5 Развертывание кластера Эврика
Среда развертывания: jdk1.8
-
упаковать проект
-
Загрузите пакет jar в папку /usr/local/eureka.
1.6 Написание сценариев запуска
#!/bin/bash
cd `dirname $0`
CUR_SHELL_DIR=`pwd`
CUR_SHELL_NAME=`basename ${BASH_SOURCE}`
JAR_NAME="项目名称"
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
Добавить разрешение
chmod -R 755 server.sh
1.7 Изменить файл hosts в Linux
vi /etc/hosts
192.168.234.130 eureka1
192.168.234.131 eureka2
1.8 Запустите реестр eureka
./server.sh start #启动
./server.sh stop #停止
В-четвертых, создайте службу Provider в высокодоступном реестре Eureka.
1. Создайте проект
springcloud-eureka-provider
1.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 https://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>1.5.13.RELEASE</version>
<relativePath /> <!-- lookup parent from repository -->
</parent>
<groupId>com.luyi</groupId>
<artifactId>springcloud-eureka-provider</artifactId>
<version>0.0.1-SNAPSHOT</version>
<name>springcloud-eureka-provider</name>
<description>Demo project for Spring Boot</description>
<properties>
<java.version>1.8</java.version>
</properties>
<dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-dependencies</artifactId>
<version>Dalston.SR5</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-config</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-eureka</artifactId>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
</project>
1.2 Изменить класс запуска
//表示Eureka的客户端
@EnableEurekaClient
@SpringBootApplication
public class EurekaApplication {
public static void main(String[] args) {
SpringApplication.run(EurekaApplication.class, args);
}
}
1.3 Изменить файл конфигурации провайдера
spring.application.name=eureka-provider
server.port=9090
#设置服务注册中心地址,向所有注册中心做注册
eureka.client.serviceUrl.defaultZone=http://eureka1:8761/eureka/,http://eureka2:8761/eureka/
1.4 Изменить хост-файл Windows
C:\Windows\System32\drivers\etc
192.168.234.130 eureka1 192.168.234.131 eureka2
1.5 Написание сервисного интерфейса
@RestController
public class UserController {
@RequestMapping("/user")
public List<User> getUsers(){
List<User> users = new ArrayList<>();
users.add(new User(1, "zhangsan", 20));
users.add(new User(2, "lisi", 22));
users.add(new User(3, "wangwu", 30));
return users;
}
}
1.6 Создание сущностей
/**
* Author: LuYi
* Date: 2019/11/6 12:30
* Description: 描述
*/
public class User {
private Integer userid;
private String username;
private Integer userage;
public User() {
}
public User(Integer userid, String username, Integer userage) {
this.userid = userid;
this.username = username;
this.userage = userage;
}
public Integer getUserid() {
return userid;
}
public void setUserid(Integer userid) {
this.userid = userid;
}
public String getUsername() {
return username;
}
public void setUsername(String username) {
this.username = username;
}
public Integer getUserage() {
return userage;
}
public void setUserage(Integer userage) {
this.userage = userage;
}
}
5. Создайте службу Consumer в высокодоступном реестре Eureka.
И потребители, и производители услуг должны быть зарегистрированы в реестре Eureka.
1. Создайте проект
1.1 файл конфигурации потребителя
spring.application.name=eureka-consumer
server.port=9091
#设置服务注册中心地址,向所有注册中心做注册
eureka.client.serviceUrl.defaultZone=http://eureka1:8761/eureka/,http://eureka2:8761/eureka/
1.2 Завершите сервисный вызов в Сервисе
@Service
public class UserService {
@Autowired
private LoadBalancerClient loadBalancerClient; //ribbon:负载均衡器
public List<User> getUsers(){
//选择调用的服务的名称
//ServiceInstance:封装了服务的基本信息,如:ip、端口号
ServiceInstance si = loadBalancerClient.choose("eureka-provider");
//拼接访问服务的url
StringBuffer sb = new StringBuffer();
//http://localhost:9090/user
sb.append("http://").append(si.getHost()).append(":").append(si.getPort()).append("/user");
//SpringMVC RestTemplate
RestTemplate restTemplate = new RestTemplate();
ParameterizedTypeReference<List<User>> type = new ParameterizedTypeReference<List<User>>() {
};
//ResponseEntity:封装了返回值信息
ResponseEntity<List<User>> entity = restTemplate.exchange(sb.toString(), HttpMethod.GET, null, type);
return entity.getBody();
}
}
1.3 Создать контроллер
@RestController
public class UserController {
@Autowired
private UserService userService;
@RequestMapping("/consumer")
public List<User> getUsers(){
return userService.getUsers();
}
}
Шесть, принцип архитектуры регистрационного центра Eureka
1. Схема архитектуры Эврика
- Регистрация (регистрация услуги): зарегистрируйте свой собственный IP и номер порта в Eureka.
- Renew (обновление службы): отправляйте пакеты сердцебиения каждые 30 секунд, чтобы сообщить Эврике, что он все еще жив.
- Отмена (сервис в автономном режиме): когда провайдер закрывается, он отправляет сообщение в Eureka, чтобы удалить себя из списка сервисов. Запретить потребителю вызывать несуществующие службы
- Получить реестр: получить список других служб
- Replicate (синхронизация данных в кластере): репликация данных и синхронизация в кластере Eureka
- Сделать удаленный вызов: завершить сервисный удаленный вызов
7. На основе теоремы распределенной колпачке проанализируют два основных рамочных рамки реестра: разница между Eureka и Zookeeper
1. Что такое принцип CAP
Принцип CAP, также известный как теорема CAP, относится к тому факту, что в распределенной системе согласованность, доступность и устойчивость к разделам несовместимы, и можно выбрать только два из трех.
CAP был предложен Эриком Брюэром на конференции PODC 2000 года. Гипотеза была доказана двумя годами позже и известна как известная теорема CAP.
2. Разница между Zookeeper и Eureka
Восемь, элегантная служба остановки Эврики
1. При каких обстоятельствах Эврика включит самозащиту
1.1 Условия самозащиты
В общем, после регистрации микросервиса в Eureka, он будет отправлять тактовый пакет каждые 30 с, и в то же время будет периодически удалять сервисы, которые не отправляют тактовый пакет в течение 90 с.
1.2 Есть две ситуации, из-за которых Eureka Server не получает пульс от микросервиса.
-
Причины самих микросервисов
-
Причины объединения микросервисов и Eureka в сеть
Если это происходит из-за сбоя микрослужбы, это не приведет к большому количеству сбоев при получении пакетов пульса, а вызовет только частичные сбои, в то время как сетевые сбои приведут к крупномасштабному отказу в получении пакетов пульса.
Принимая во внимание эту разницу, Eureka устанавливает пороговое значение: если в течение короткого периода времени пакеты пульсаций не будут получены в большом количестве, это будет расцениваться как сетевой сбой, поэтому Eureka не будет удалять сервисы с просроченными пульсациями.
-
Что такое порог
Определите, ниже ли он 85% в течение 15 минут
Во время работы Eureka Server будет определять, достигает ли частота отказов сердцебиения 85% в течение 15 минут.
Этот алгоритм называется режимом самозащиты Eureka Server.
2. Зачем защищать себя
- Поскольку лучше хранить ** «хорошие данные» и «плохие данные» одновременно, чем удалять все данные, если они входят в режим самозащиты из-за сбоя сети, когда неисправность устраняется, он автоматически выходит из самостоятельный режим защиты
- Стратегия балансировки нагрузки микросервисов автоматически устраняет мертвые узлы микросервисов.
3. Как отключить самозащиту
Измените файл конфигурации сервера Eureka.
#关闭自我保护:true为开启,false为关闭
eureka.server.enable-self-preservation=false
#清理间隔(单位:毫秒,默认是60*1000)
eureka.server.eviction-interval-timer-in-ms=60000
4. Как изящно остановить службу
4.1 Нет необходимости настраивать закрытую самозащиту в Eureka Server
4.2 В сервис необходимо добавить пакет act.jar
4.3 Изменить файл конфигурации
#启动shutdown
endpoints.shutdown.enabled=true
#禁用密码验证
endpoints.shutdown.sensitive=false
4.4 Отправка URL-запроса на закрытие службы
public class HttpClientUtil {
public static String doGet(String url, Map<String, String> param) {
// 创建Httpclient对象
CloseableHttpClient httpclient = HttpClients.createDefault();
String resultString = "";
CloseableHttpResponse response = null;
try {
// 创建uri
URIBuilder builder = new URIBuilder(url);
if (param != null) {
for (String key : param.keySet()) {
builder.addParameter(key, param.get(key));
}
}
URI uri = builder.build();
// 创建http GET请求
HttpGet httpGet = new HttpGet(uri);
// 执行请求
response = httpclient.execute(httpGet);
// 判断返回状态是否为200
if (response.getStatusLine().getStatusCode() == 200) {
resultString = EntityUtils.toString(response.getEntity(), "UTF-8");
}
} catch (Exception e) {
e.printStackTrace();
} finally {
try {
if (response != null) {
response.close();
}
httpclient.close();
} catch (IOException e) {
e.printStackTrace();
}
}
return resultString;
}
public static String doGet(String url) {
return doGet(url, null);
}
public static String doPost(String url, Map<String, String> param) {
// 创建Httpclient对象
CloseableHttpClient httpClient = HttpClients.createDefault();
CloseableHttpResponse response = null;
String resultString = "";
try {
// 创建Http Post请求
HttpPost httpPost = new HttpPost(url);
// 创建参数列表
if (param != null) {
List<NameValuePair> paramList = new ArrayList<>();
for (String key : param.keySet()) {
paramList.add(new BasicNameValuePair(key, param.get(key)));
}
// 模拟表单
UrlEncodedFormEntity entity = new UrlEncodedFormEntity(paramList,"utf-8");
httpPost.setEntity(entity);
}
// 执行http请求
response = httpClient.execute(httpPost);
resultString = EntityUtils.toString(response.getEntity(), "utf-8");
} catch (Exception e) {
e.printStackTrace();
} finally {
try {
response.close();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
return resultString;
}
public static String doPost(String url) {
return doPost(url, null);
}
public static String doPostJson(String url, String json) {
// 创建Httpclient对象
CloseableHttpClient httpClient = HttpClients.createDefault();
CloseableHttpResponse response = null;
String resultString = "";
try {
// 创建Http Post请求
HttpPost httpPost = new HttpPost(url);
// 创建请求内容
StringEntity entity = new StringEntity(json, ContentType.APPLICATION_JSON);
httpPost.setEntity(entity);
// 执行http请求
response = httpClient.execute(httpPost);
resultString = EntityUtils.toString(response.getEntity(), "utf-8");
} catch (Exception e) {
e.printStackTrace();
} finally {
try {
response.close();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
return resultString;
}
public static void main(String[] args) {
String url ="http://127.0.0.1:9090/shutdown";
//该url必须要使用doPost方式来发送
HttpClientUtil.doPost(url);
}
}
9. Как усилить сертификацию безопасности реестра Eureka
1. Добавьте пакет безопасности в EurekaServer.
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-security</artifactId>
</dependency>
2. Измените файл конфигурации сервера Eureka.
#开启 http basic 的安全认证
security.basic.enabled=true
security.user.name=user
security.user.password=123456
3. Измените URL-адрес для доступа к узлам кластера.
eureka.client.serviceUrl.defaultZone=http://user:123456@eureka2:8761/eureka/
4. Измените файл конфигурации, измените имя пользователя и пароль для доступа к центру регистрации.
spring.application.name=eureka-provider
server.port=9090
#设置服务注册中心地址,向所有注册中心做注册
eureka.client.serviceUrl.defaultZone=http://user:123456@eureka1:8761/eureka/,http://user:123456@eureka2:8761/eureka/
#启动shutdown
endpoints.shutdown.enabled=true
#禁用密码验证
endpoints.shutdown.sensitive=false