数据中心-数据隔离-名称空间

This commit is contained in:
bunny 2025-05-26 16:19:06 +08:00
parent a76dd2227e
commit 6ee93a581c
7 changed files with 308 additions and 225 deletions

View File

@ -1,4 +1,241 @@
# 微服务文档
# 微服务
## 环境搭建
### Docker镜像源设置
```bash
# 创建目录
sudo mkdir -p /etc/docker
# 写入配置文件
sudo tee /etc/docker/daemon.json <<-'EOF'
{
"registry-mirrors": [
"https://docker-0.unsee.tech",
"https://docker-cf.registry.cyou",
"https://docker.1panel.live"
]
}
EOF
# 重启docker服务
sudo systemctl daemon-reload && sudo systemctl restart docker
```
使用docker-compose有的时候会因为版本不同但是配置文件主要内容就是这些。需要注意版本问题
### 配置相关
#### MySQL配置问题
| **特性** | `**my.cnf**` | `**conf.d**` **目录** |
|----------|:--------------------|:-------------------:|
| **文件类型** | 单个文件 | 目录,包含多个 `.cnf` 文件 |
| **配置方式** | 集中式配置 | 分布式配置 |
| **优先级** | 高(覆盖 `conf.d` 中的配置) | 低(被 `my.cnf` 覆盖) |
| **适用场景** | 全局配置,核心配置 | 模块化配置,便于扩展和维护 |
#### MongoDB配置
```bash
sudo mkdir -p ~/docker/docker_data/mongo/conf
sudo mkdir -p ~/docker/docker_data/mongo/logs
sudo chmod 777 ~/docker/docker_data/mongo/logs
sudo chmod 777 ~/docker/docker_data/mongo/conf
cd ~/docker/docker_data/mongo/logs
sudo touch mongod.log
sudo chmod 777 mongod.log
cd ~/docker/docker_data/mongo/conf
sudo vim mongod.conf
cd ~
```
##### 配置文件
```bash
# 数据库文件存储位置
dbpath = /data/db
# log文件存储位置
logpath = /data/log/mongod.log
# 使用追加的方式写日志
logappend = true
# 是否以守护进程方式运行
# fork = true
# 全部ip可以访问
bind_ip = 0.0.0.0
# 端口号
port = 27017
# 是否启用认证
auth = true
# 设置oplog的大小(MB)
oplogSize=2048
```
##### 设置账户密码
```shell
#进入容器
docker exec -it mongodb /bin/bash
#进入mongodb shell
mongosh --port 27017
#切换到admin库
use admin
#创建账号/密码
db.createUser({ user: 'admin', pwd: '02120212', roles: [ { role: "root", db: "admin" } ] });
# db.createUser({ user: 'admin', pwd: '123456', roles: [ { role: "userAdminAnyDatabase", db: "admin" } ] });
```
### docker-compose.yml
如果休要所有的微服务环境,可以直接复制下面的内容,看清楚目录是否和自己需要的一样。
| 功能 | 旧版 (docker-compose) | 新版 (docker compose) |
|--------------|-------------------------|-------------------------|
| **启动服务** | docker-compose up -d | docker compose up -d |
| **停止服务** | docker-compose down | docker compose down |
| **查看日志** | docker-compose logs -f | docker compose logs -f |
| **列出容器** | docker-compose ps | docker compose ps |
| **停止不删除容器** | docker-compose stop | docker compose stop |
| **启动已停止的容器** | docker-compose start | docker compose start |
| **重启服务** | docker-compose restart | docker compose restart |
| **构建镜像** | docker-compose build | docker compose build |
```yaml
name: cloud-services
services:
mysql:
container_name: mysql_master
image: mysql:8.0.33
ports:
- "3306:3306"
environment:
- MYSQL_ROOT_PASSWORD=123456
- TZ=Asia/Shanghai
volumes:
# - ~/docker/docker_data/mysql/mysql_master/etc/my.cnf:/etc/my.cnf # 如果需要创建配置文件
- ~/docker/docker_data/mysql/mysql_master/etc/mysql:/etc/mysql/conf.d
- ~/docker/docker_data/mysql/mysql_master/data:/var/lib/mysql
- ~/docker/docker_data/mysql/mysql_master/backup:/backup
command:
- "--log-bin=mysql-bin"
- "--server-id=1"
- "--collation-server=utf8mb4_unicode_ci"
- "--character-set-server=utf8mb4"
- "--lower-case-table-names=1"
restart: always
privileged: true
networks:
- cloud
redis:
container_name: redis_master
image: redis:7.0.10
ports:
- "6379:6379"
volumes:
# - ~/docker/docker_data/redis_master/redis.conf:/etc/redis/redis.conf # 需要创建配置文件
- ~/docker/docker_data/redis_master:/etc/redis # 之后要配置文件可以直接在这里创建 redis.conf
- ~/docker/docker_data/redis_master/data:/data
command:
- "--appendonly yes"
- "--daemonize no"
- "--requirepass 123456"
- "--tcp-keepalive 300"
restart: always
networks:
- cloud
minio:
image: minio/minio
container_name: minio_master
ports:
- "9000:9000"
- "9090:9090"
volumes:
- ~/docker/docker_data/minio/data:/data
environment:
- MINIO_ROOT_USER=bunny
- MINIO_ROOT_PASSWORD=02120212
command: "server /data --console-address :9090"
restart: always
networks:
- cloud
mongodb:
image: mongo:latest
container_name: mongodb
restart: always
privileged: true
ports:
- "27017:27017"
volumes:
- ~/docker/docker_data/mongo/data:/data/db
- ~/docker/docker_data/mongo/conf:/data/configdb
- ~/docker/docker_data/mongo/logs:/data/log
command: "mongod --config /data/configdb/mongod.conf"
networks:
- cloud
rabbitmq:
image: rabbitmq:management
container_name: rabbitmq
restart: unless-stopped
ports:
- "5672:5672"
- "15672:15672"
volumes:
- ~/docker/docker_data/rabbitmq/data:/var/lib/rabbitmq
- ~/docker/docker_data/rabbitmq/conf:/etc/rabbitmq
- ~/docker/docker_data/rabbitmq/log:/var/log/rabbitmq
environment:
- RABBITMQ_DEFAULT_USER=admin
- RABBITMQ_DEFAULT_PASS=admin
- RABBITMQ_DEFAULT_VHOST=/
networks:
- cloud
nacos:
image: nacos/nacos-server:v2.4.3
container_name: nacos
ports:
- "8848:8848"
- "9848:9848"
environment:
- MODE=standalone
restart: always
networks:
- cloud
sentinel:
image: bladex/sentinel-dashboard:1.8.8
container_name: sentinel
ports:
- "8858:8858"
privileged: true
restart: always
networks:
- cloud
seata-server:
image: apache/seata-server:2.3.0.jdk21
container_name: seata-server
ports:
- "8091:8091"
restart: always
networks:
- cloud
networks: # 定义网络
cloud: # 定义名为 auth 的网络
name: cloud # 网络名称为 auth
driver: bridge # 使用 bridge 驱动(默认)
```
## 注册中心
@ -18,25 +255,24 @@ public class DiscoveryTest {
@Test
void discoveryClientTest() {
// 使用Spring Cloud标准DiscoveryClient
for (String service : discoveryClient.getServices()) {
System.out.println("服务名称: " + service);
System.out.println(service);
for (ServiceInstance instance : discoveryClient.getInstances(service)) {
System.out.println("实例IP地址: " + instance.getHost());
System.out.println("实例端口号: " + instance.getPort());
System.out.println("IP地址" + instance.getHost());
System.out.println("端口号" + instance.getPort());
}
}
System.out.println("----------------------------------------------");
// 使用Nacos专用DiscoveryClient
// 两个方式一样DiscoveryClient 是 Spring自带的 NacosDiscoveryClient是 Nacos
for (String service : nacosDiscoveryClient.getServices()) {
System.out.println("服务名称: " + service);
System.out.println(service);
for (ServiceInstance instance : nacosDiscoveryClient.getInstances(service)) {
System.out.println("实例IP地址: " + instance.getHost());
System.out.println("实例端口号: " + instance.getPort());
System.out.println("IP地址" + instance.getHost());
System.out.println("端口号" + instance.getPort());
}
}
}
@ -45,11 +281,11 @@ public class DiscoveryTest {
### 远程调用
订单模块调用远程商品模块,使用Nacos作为注册中心可以使用`RestTemplate`进行远程调用。`RestTemplate`是线程安全的,只需注册一次即可全局使用。
订单模块调用远程商品模块,使用了nacos可以使用`RestTemplate`,其中`RestTemplate`是线程安全的,只要注册一次全局都是可以使用。
**RestTemplate线程安全说明**
**RestTemplate源码**
`RestTemplate`继承了`InterceptingHttpAccessor`,其中使用了单例模式保证线程安全:
继承了`InterceptingHttpAccessor`,在`InterceptingHttpAccessor`中,使用了单例模式。
```java
public ClientHttpRequestFactory getRequestFactory() {
@ -60,6 +296,7 @@ public ClientHttpRequestFactory getRequestFactory() {
factory = new InterceptingClientHttpRequestFactory(super.getRequestFactory(), interceptors);
this.interceptingRequestFactory = factory;
}
return factory;
} else {
return super.getRequestFactory();
@ -69,9 +306,9 @@ public ClientHttpRequestFactory getRequestFactory() {
#### 实现远程调用
##### 基础调用方式
##### 普通方式调用
1. 注册`RestTemplate` Bean
注册`RestTemplate`
```java
@Bean
@ -80,27 +317,26 @@ public RestTemplate restTemplate() {
}
```
2. 实现远程调用:
如果我们的服务启动了多个,在下面代码中即使一个服务宕机也可以做到远程调用。
```java
private Product getProductFromRemote(Long productId) {
// 获取商品服务所有实例
// 获取商品服务所有及其的 IP+port
List<ServiceInstance> instances = discoveryClient.getInstances("service-product");
if (instances.isEmpty()) {
throw new RuntimeException("未找到可用的商品服务实例");
}
ServiceInstance instance = instances.get(0);
// 远程URL
String url = "http://" + instance.getHost() + ":" + instance.getPort() + "/api/product/" + productId;
log.info("远程调用商品服务: {}", url);
// 2. 远程发送请求
log.info("远程调用:{}", url);
return restTemplate.getForObject(url, Product.class);
}
```
##### 负载均衡调用
1. 注册`RestTemplate` Bean
注册`RestTemplate`
```java
@Bean
@ -109,32 +345,39 @@ public RestTemplate restTemplate() {
}
```
2. 使用`LoadBalancerClient`实现负载均衡:
使用负载均衡`LoadBalancerClient`,通过负载均衡算法动态调用远程服务。
```java
/**
* 使用负载均衡调用远程商品服务
* 远程调用商品模块 --- 负载均衡
*
* @param productId 商品ID
* @return 商品信息
* @param productId 商品id
* @return 商品对象
*/
private Product getProductFromRemoteWithLoadBalancer(Long productId) {
// 1. 获取商品服务所有及其的 IP+port
ServiceInstance instance = loadBalancerClient.choose("service-product");
// 远程URL
String url = "http://" + instance.getHost() + ":" + instance.getPort() + "/api/product/" + productId;
log.info("负载均衡远程调用商品服务: {}", url);
// 2. 远程发送请求
log.info("负载均衡远程调用:{}", url);
return restTemplate.getForObject(url, Product.class);
}
```
##### 注解式负载均衡调用
##### 负载均衡注解调用
> [!TIP]
> 关于注册中心宕机的影响:
> - 已调用过的服务:可以继续调用,因为客户端有缓存
> - 未调用过的服务:首次调用会失败,因为需要从注册中心获取服务列表
>
> 如果远程注册中心宕机是否可以调用?
>
> 调用过:远程调用不在依赖注册中心,可以通过。
>
> 没调用过:第一次发起远程调用;不能通过。
1. 注册带负载均衡的`RestTemplate`
在`RestTemplate`上加上`@LoadBalanced`注解使用负载均衡。
```java
@Bean
@ -144,220 +387,60 @@ public RestTemplate restTemplate() {
}
```
2. 直接使用服务名进行调用:
在实际的调用中并不需要再显式调用将URL替换成服务名称即可。
```java
/**
* 使用注解式负载均衡调用远程商品服务
* 远程调用商品模块 --- 负载均衡注解调用
*
* @param productId 商品ID
* @return 商品信息
* @param productId 商品id
* @return 商品对象
*/
private Product getProductFromRemoteWithLoadBalancerAnnotation(Long productId) {
// 远程URL实现动态替换
String url = "http://service-product/api/product/" + productId;
log.info("负载均衡注解调用商品服务: {}", url);
// 远程发送请求
log.info("负载均衡注解调用:{}", url);
return restTemplate.getForObject(url, Product.class);
}
```
### 远程配置管理
## 数据中心-数据隔离
#### 基础配置
![image-20250526160251551](C:\Users\13199\AppData\Roaming\Typora\typora-user-images\image-20250526160251551.png)
1. 添加依赖:
### 名称空间
```xml
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
</dependency>
```
2. 在Nacos中配置
配置内容示例:
```yaml
order:
timeout: 30min
auto-confirm: true
```
3. 创建配置读取接口:
```java
@RestController
@RequestMapping("/api/order")
@RequiredArgsConstructor
public class OrderController {
@Value("${order.timeout}")
private String timeout;
@Value("${order.auto-confirm}")
private String autoConfirm;
@Operation(summary = "读取配置")
@GetMapping("config")
public String config() {
return "timeout: " + timeout + "\nautoConfirm: " + autoConfirm;
}
}
```
4. 应用配置:
```yaml
server:
port: 8000
spring:
application:
name: service-order
profiles:
active: dev
config:
import:
- nacos:service-order.yml
cloud:
nacos:
server-addr: 192.168.95.135:8848
config:
import-check:
enabled: false
```
> [!CAUTION]
> 注意事项:
> - 不要在`server-addr`中使用变量引用如`${nacos.server-addr}`,这可能导致连接失败
> - 对于不需要动态配置的模块,可以禁用配置检查
#### 动态刷新配置
1. 添加`@RefreshScope`注解:
```java
@SpringBootApplication
@EnableDiscoveryClient
@RefreshScope
public class ProductServiceApplication {
public static void main(String[] args) {
SpringApplication.run(ProductServiceApplication.class, args);
}
}
```
#### 批量配置绑定
#### 创建命名空间
> [!TIP]
> 使用`@ConfigurationProperties`批量绑定配置:
> - 无需`@RefreshScope`即可实现动态刷新
> - 支持中划线命名自动转为驼峰命名
>
> 如果需要导入和我一样的命名空间可以在项目目录下的samples文件找到相关配置
1. 创建配置类:
分别创建test、prod、dev
```java
@Configuration
@ConfigurationProperties(prefix = "order")
public class OrderProperties {
private String timeout;
private String autoConfirm;
// getters and setters
}
![image-20250526160457765](./images/image-20250526160457765.png)
![image-20250526160718723](./images/image-20250526160718723.png)
之后到配置列表中创建配置dev命名空间
![image-20250526160709930](./images/image-20250526160709930.png)
```yml
order:
timeout: 1min
auto-confirm: 1h
```
2. 使用配置:
![image-20250526160842062](./images/image-20250526160842062.png)
```java
@RestController
@RequestMapping("/api/order")
@RequiredArgsConstructor
public class OrderController {
private final OrderProperties orderProperties;
@Operation(summary = "读取配置")
@GetMapping("config")
public String config() {
return "timeout: " + orderProperties.getTimeout() +
"\nautoConfirm: " + orderProperties.getAutoConfirm();
}
}
```yml
order:
db-url: order_dev
```
#### 高级配置管理
1. 多环境配置:
```yaml
spring:
profiles:
active: @profileActive@
config:
import:
- nacos:service-order-${spring.profiles.active}.yml
```
2. 共享配置:
```yaml
spring:
config:
import:
- nacos:common-config.yml
- nacos:service-order.yml
```
3. 命名空间和分组:
```yaml
cloud:
nacos:
config:
namespace: dev
group: DEFAULT_GROUP
```
4. 配置优先级:
- 应用名-profile.yml (最高优先级)
- 应用名.yml
- 扩展配置
- 共享配置 (最低优先级)
### 配置监听
![f69073a0-a94a-437a-b555-1abe9914556f](./images/f69073a0-a94a-437a-b555-1abe9914556f.png)
#### 实现配置监听
1. 项目启动时注册监听器:
```java
@SpringBootApplication
@EnableDiscoveryClient
public class OrderServiceApplication {
public static void main(String[] args) {
SpringApplication.run(OrderServiceApplication.class, args);
}
@Bean
public ApplicationRunner runner(NacosConfigManager nacosConfigManager) {
return args -> {
ConfigService configService = nacosConfigManager.getConfigService();
configService.addListener("service-order.yml", "DEFAULT_GROUP", new Listener() {
@Override
public Executor getExecutor() {
return Executors.newFixedThreadPool(10);
}
@Override
public void receiveConfigInfo(String configInfo) {
System.out.println("配置变更内容: " + configInfo);
// 实现配置变更后的处理逻辑
System.out.println("发送配置变更通知邮件...");
}
});
System.out.println("订单服务启动完成,配置监听已注册");
};
}
}
```
#### 克隆命名空间
![image-20250526161104319](./images/image-20250526161104319.png)

Binary file not shown.

After

Width:  |  Height:  |  Size: 36 KiB

Binary file not shown.

After

Width:  |  Height:  |  Size: 20 KiB

Binary file not shown.

After

Width:  |  Height:  |  Size: 16 KiB

Binary file not shown.

After

Width:  |  Height:  |  Size: 19 KiB

Binary file not shown.

After

Width:  |  Height:  |  Size: 50 KiB