lizixuan
/
m2pool_web_backend
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

update 接口测试完成,新增ip限制链接 + 最大连接数配置.文件上传模块，路径修改

This commit is contained in:
yyb 2025-04-16 16:15:53 +08:00
parent 476cb6711e
commit 2d8088c6cb
24 changed files with 313 additions and 106 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
m2pool-modules/m2pool-chat/src/main/java/com/m2pool/chat/config/CustomWebSocketConfig.java Normal file
View File

@ -0,0 +1,16 @@
package com.m2pool.chat.config;
import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Configuration;
@Data
@Configuration
@ConfigurationProperties(prefix = "websocket.transport")
public class CustomWebSocketConfig {
private int messageSizeLimit;
private int sendTimeLimit;
private int sendBufferSizeLimit;
private int timeToFirstMessage;
private int maxConnections;
}

23
m2pool-modules/m2pool-chat/src/main/java/com/m2pool/chat/config/WebSocketBrokerConfig.java
View File

@ -12,7 +12,9 @@ import org.springframework.scheduling.concurrent.DefaultManagedTaskScheduler;
import org.springframework.web.socket.config.annotation.EnableWebSocketMessageBroker;
import org.springframework.web.socket.config.annotation.StompEndpointRegistry;
import org.springframework.web.socket.config.annotation.WebSocketMessageBrokerConfigurer;
import org.springframework.web.socket.config.annotation.WebSocketTransportRegistration;
import javax.annotation.Resource;
import java.util.List;
/**
@ -24,6 +26,11 @@ import java.util.List;
@EnableWebSocketMessageBroker
public class WebSocketBrokerConfig implements WebSocketMessageBrokerConfigurer {
@Resource
private CustomWebSocketConfig customWebSocketConfig;
/**
* 注册 Stomp的端点 可以注册多个端点
* addEndpoint：添加STOMP协议的端点。客户端访问地址
@ -62,6 +69,20 @@ public class WebSocketBrokerConfig implements WebSocketMessageBrokerConfigurer {
}
/**
* 最大消息字节数,发送超时时间,发送缓冲区大小,首次连接超时时间
* @param registration
*/
@Override
public void configureWebSocketTransport(WebSocketTransportRegistration registration) {
registration
.setMessageSizeLimit(customWebSocketConfig.getMessageSizeLimit())
.setSendTimeLimit(customWebSocketConfig.getSendTimeLimit())
.setSendBufferSizeLimit(customWebSocketConfig.getSendBufferSizeLimit())
// 首次连接超时时间.正常情况下，前端订阅 和 心跳包的影响 不会超时断连
.setTimeToFirstMessage(customWebSocketConfig.getTimeToFirstMessage());
}
/**
@ -75,7 +96,7 @@ public class WebSocketBrokerConfig implements WebSocketMessageBrokerConfigurer {
.maxPoolSize(20)
.keepAliveSeconds(60);
// 拦截器配置
registration.interceptors(new WebsocketChannelInterceptor());
registration.interceptors(new WebsocketChannelInterceptor(customWebSocketConfig));
}
/**

23
m2pool-modules/m2pool-chat/src/main/java/com/m2pool/chat/constant/CustomHeader.java Normal file
View File

@ -0,0 +1,23 @@
package com.m2pool.chat.constant;
/**
* @ClassName CustomHeader
* @Description 自定义请求头
* @Author yyb
* @Date 2025/4/16 13:34
*/
public class CustomHeader {
/**
* 用户类型
*/
public static final String TYPE = "type";
/**
* 用户邮箱
*/
public static final String EMAIL = "email";
/**
* 客服端ip地址请求头
*/
public static final String IPADDR = "ipAddr";
}

7
m2pool-modules/m2pool-chat/src/main/java/com/m2pool/chat/constant/Destination.java
View File

@ -25,10 +25,5 @@ public class Destination {
/**
* stomp 默认发送消息前缀。
*/
public static final String SEND_PREFIX = "/message";
/**
* 游客标识
*/
public static final String VISITOR_PREFIX = "visitor";
public static final String SEND_PREFIX = "/point";
}

5
m2pool-modules/m2pool-chat/src/main/java/com/m2pool/chat/dto/ChatMessageDto.java
View File

@ -1,10 +1,11 @@
package com.m2pool.chat.dto;
import cn.hutool.core.date.DateTime;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import java.time.LocalDateTime;
/**
* @ClassName ChatMessageDto
* @Description 聊天消息返回对象
@ -29,5 +30,5 @@ public class ChatMessageDto {
private String content;
@ApiModelProperty(value = "发送时间", example = "")
private DateTime createTime;
private LocalDateTime createTime;
}

7
m2pool-modules/m2pool-chat/src/main/java/com/m2pool/chat/dto/ChatRoomDto.java
View File

@ -1,8 +1,9 @@
package com.m2pool.chat.dto;
import cn.hutool.core.date.DateTime;
import lombok.Data;
import java.time.LocalDateTime;
/**
* @ClassName ChatRoomDto
* @Description 客服 聊天室列表返回对象
@ -34,10 +35,10 @@ public class ChatRoomDto {
/**
* 用户回复时间
*/
private DateTime lastUserSendTime;
private LocalDateTime lastUserSendTime;
/**
* 客服回复时间
*/
private DateTime lastCustomerSendTime;
private LocalDateTime lastCustomerSendTime;
}

7
m2pool-modules/m2pool-chat/src/main/java/com/m2pool/chat/entity/ChatMessage.java
View File

@ -1,9 +1,10 @@
package com.m2pool.chat.entity;
import cn.hutool.core.date.DateTime;
import lombok.Builder;
import lombok.Data;
import java.time.LocalDateTime;
@Builder
@Data
public class ChatMessage {
@ -13,6 +14,6 @@ public class ChatMessage {
private String sendEmail;
private String content;
private Long roomId;
private DateTime createTime;
private DateTime updateTime;
private LocalDateTime createTime;
private LocalDateTime updateTime;
}

7
m2pool-modules/m2pool-chat/src/main/java/com/m2pool/chat/entity/ChatMessageHistory.java
View File

@ -1,8 +1,9 @@
package com.m2pool.chat.entity;
import cn.hutool.core.date.DateTime;
import lombok.Data;
import java.time.LocalDateTime;
@Data
public class ChatMessageHistory {
private Long id;
@ -10,6 +11,6 @@ public class ChatMessageHistory {
private String sendEmail;
private String content;
private Long roomId;
private DateTime createTime;
private DateTime updateTime;
private LocalDateTime createTime;
private LocalDateTime updateTime;
}

11
m2pool-modules/m2pool-chat/src/main/java/com/m2pool/chat/entity/ChatRoom.java
View File

@ -1,19 +1,20 @@
package com.m2pool.chat.entity;
import cn.hutool.core.date.DateTime;
import lombok.Builder;
import lombok.Data;
import java.time.LocalDateTime;
@Builder
@Data
public class ChatRoom {
private Long id;
private String userOneEmail;
private String userTwoEmail;
private DateTime lastUserSendTime;
private DateTime lastCustomerSendTime;
private LocalDateTime lastUserSendTime;
private LocalDateTime lastCustomerSendTime;
private Boolean flag;
private DateTime createTime;
private DateTime updateTime;
private LocalDateTime createTime;
private LocalDateTime updateTime;
private Boolean del;
}

8
m2pool-modules/m2pool-chat/src/main/java/com/m2pool/chat/entity/StompPrincipal.java
View File

@ -1,15 +1,21 @@
package com.m2pool.chat.entity;
import lombok.Data;
import java.security.Principal;
/**
* stomp用户身份信息
*/
@Data
public class StompPrincipal implements Principal {
String name;
public StompPrincipal(String name) {
Integer type;
public StompPrincipal(String name,Integer type) {
this.name = name;
this.type = type;
}
@Override

113
m2pool-modules/m2pool-chat/src/main/java/com/m2pool/chat/interceptor/WebsocketChannelInterceptor.java
View File

@ -1,12 +1,15 @@
package com.m2pool.chat.interceptor;
import com.m2pool.chat.config.CustomWebSocketConfig;
import com.m2pool.chat.entity.StompPrincipal;
import lombok.Data;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.lang.Nullable;
import org.springframework.messaging.Message;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.MessageDeliveryException;
import org.springframework.messaging.simp.SimpMessageHeaderAccessor;
import org.springframework.messaging.simp.stomp.StompCommand;
import org.springframework.messaging.simp.stomp.StompHeaderAccessor;
@ -15,6 +18,12 @@ import org.springframework.messaging.support.MessageHeaderAccessor;
import java.util.ArrayList;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.atomic.AtomicInteger;
import static com.m2pool.chat.constant.CustomHeader.*;
import static com.m2pool.chat.constant.UserType.CUSTOMER;
/**
* @ClassName WebsocketChannelInterceptor
@ -22,9 +31,30 @@ import java.util.Map;
* @Author yyb
* @Date 2025/4/10 15:44
*/
@Data
public class WebsocketChannelInterceptor implements ChannelInterceptor {
private static final Logger LOGGER = LoggerFactory.getLogger(WebsocketChannelInterceptor.class);
/**
* 当前加入链接的ip
*/
private static final ConcurrentHashMap<String, Boolean> ipConnectionCountMap = new ConcurrentHashMap<>();
/**
* 当前链接数
*/
private static final AtomicInteger connectionCount = new AtomicInteger(0);
/**
* websocket 一些配置
*/
private CustomWebSocketConfig customWebSocketConfig;
public WebsocketChannelInterceptor(CustomWebSocketConfig customWebSocketConfig) {
this.customWebSocketConfig = customWebSocketConfig;
}
/**
* websocket channel 通道拦截器
* @param message
@ -36,17 +66,21 @@ public class WebsocketChannelInterceptor implements ChannelInterceptor {
//获取链接建立时的请求头信息
StompHeaderAccessor accessor = StompHeaderAccessor.wrap(message);
if (accessor.getCommand() == StompCommand.CONNECT ) {
LOGGER.info("------------收到websocket的连接消息");
//获取channel 中的请求头信息
StompHeaderAccessor mha = MessageHeaderAccessor.getAccessor(message, StompHeaderAccessor.class);
Object raw = message.getHeaders().get(SimpMessageHeaderAccessor.NATIVE_HEADERS);
System.out.println("raw:"+raw);
if (raw instanceof Map) {
Object userInfo = ((Map) raw).get("email");
if(userInfo instanceof ArrayList){
mha.setUser(new StompPrincipal((String) ((ArrayList) userInfo).get(0)));
}
int type = Integer.parseInt(getConnectCustomHeaders(raw, TYPE));
String email = getConnectCustomHeaders(raw, EMAIL);
//最大链接数限制
maxConnectionsLimit();
//根据客服端ip + 用户类型限制连接数
ipLimit(accessor,type);
if(mha == null){
throw new MessageDeliveryException("get MessageHeaderAccessor failed,can not set Principal,connect failed");
}
//链接请求头中用户信息存入stomp中
mha.setUser(new StompPrincipal(email,type));
}
if (accessor.getCommand() == StompCommand.SEND) {
LOGGER.info("------------websocket send message");
@ -61,11 +95,74 @@ public class WebsocketChannelInterceptor implements ChannelInterceptor {
}
if (accessor.getCommand() == StompCommand.DISCONNECT){
disconnectHandler(accessor);
LOGGER.info("------------websocket disconnect");
}
return message;
}
/**
* 最大连接数限制
*/
private void maxConnectionsLimit(){
if(connectionCount.incrementAndGet() >= customWebSocketConfig.getMaxConnections()){
LOGGER.info("reach max connections,refuse connect");
throw new MessageDeliveryException("reach max connections,refuse connect");
}
}
/**
* ip 链接个数限制
* @param accessor
*/
private void ipLimit(StompHeaderAccessor accessor,int type){
Map<String, Object> sessionAttributes = accessor.getSessionAttributes();
if (sessionAttributes != null) {
String ipAddr = (String) sessionAttributes.get(IPADDR);
if(type != CUSTOMER && ipConnectionCountMap.get(ipAddr) != null){
throw new MessageDeliveryException("this ip maximum number of connections is reached");
}
ipConnectionCountMap.put(ipAddr,true);
}else{
throw new MessageDeliveryException("not find email and type headers");
}
}
/**
* 获取stomp自定义请求头
* @param raw
* @param headerKey
* @return
*/
private String getConnectCustomHeaders(Object raw,String headerKey){
String headerValue = "";
if (raw instanceof Map) {
Object value = ((Map<?, ?>) raw).get(headerKey);
if(value instanceof ArrayList){
headerValue = ((ArrayList<?>) value).get(0).toString();
}
}
return headerValue;
}
/**
* 断开链接处理
*/
private void disconnectHandler(StompHeaderAccessor accessor){
//连接数减一
connectionCount.decrementAndGet();
//断开链接的ip
Map<String, Object> sessionAttributes = accessor.getSessionAttributes();
if (sessionAttributes != null) {
String ipAddr = (String) sessionAttributes.get(IPADDR);
if(ipConnectionCountMap.get(ipAddr) != null){
ipConnectionCountMap.remove(ipAddr);
}
}else{
throw new MessageDeliveryException("not find email and type headers");
}
}
@Override
public void postSend(Message<?> message, MessageChannel channel, boolean sent) {

29
m2pool-modules/m2pool-chat/src/main/java/com/m2pool/chat/interceptor/WebsocketHandshakeInterceptor.java
View File

@ -1,15 +1,18 @@
package com.m2pool.chat.interceptor;
import com.m2pool.common.core.utils.ip.IpUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.http.server.ServerHttpRequest;
import org.springframework.http.server.ServerHttpResponse;
import org.springframework.http.server.ServletServerHttpRequest;
import org.springframework.web.socket.WebSocketHandler;
import org.springframework.web.socket.server.HandshakeInterceptor;
import javax.servlet.http.HttpServletRequest;
import java.util.Map;
import static com.m2pool.chat.constant.Destination.VISITOR_PREFIX;
import static com.m2pool.chat.constant.CustomHeader.IPADDR;
/**
@ -24,14 +27,18 @@ public class WebsocketHandshakeInterceptor implements HandshakeInterceptor {
@Override
public boolean beforeHandshake(ServerHttpRequest request, ServerHttpResponse response, WebSocketHandler wsHandler, Map<String, Object> attributes) throws Exception {
LOGGER.info("------------------WebsocketHandshakeInterceptor:beforeHandshake");
// 为游客生成一个唯一标识
// String s = generateVisitorId(request);
// attributes.put(VISITOR_PREFIX, s);
// response.getHeaders().add(VISITOR_PREFIX, s);
if (request instanceof ServletServerHttpRequest) {
ServletServerHttpRequest servletRequest = (ServletServerHttpRequest) request;
HttpServletRequest httpRequest = servletRequest.getServletRequest();
// 获取 客服端 IP 地址 并放入attributes 中
String ipAddr = IpUtils.getIpAddr(httpRequest);
attributes.put(IPADDR, ipAddr);
} else {
LOGGER.warn("Request is not an instance of ServletServerHttpRequest. Unable to extract HttpServletRequest.");
}
return true;
}
@ -40,14 +47,4 @@ public class WebsocketHandshakeInterceptor implements HandshakeInterceptor {
LOGGER.info("------------------WebsocketHandshakeInterceptor:afterHandshake");
}
/**
* 生成一个唯一标识
* @param request
* @return
*/
private String generateVisitorId(ServerHttpRequest request) {
String first = request.getHeaders().getFirst("sec-websocket-key");
String prefix = VISITOR_PREFIX;
return prefix + first;
}
}

3
m2pool-modules/m2pool-chat/src/main/java/com/m2pool/chat/service/impl/ChatMessageServiceImpl.java
View File

@ -56,6 +56,7 @@ public class ChatMessageServiceImpl implements ChatMessageService {
ChatRoom chatRoom = chatRoomMapper.selectById(roomId);
String username = SecurityUtils.getUsername();
if (chatRoom != null){
String updateUserEmail = "";
if( username.equals(chatRoom.getUserOneEmail())){
updateUserEmail = chatRoom.getUserTwoEmail();
@ -66,4 +67,6 @@ public class ChatMessageServiceImpl implements ChatMessageService {
new LambdaUpdateWrapper<ChatMessage>().eq(ChatMessage::getSendEmail, updateUserEmail).eq(ChatMessage::getRoomId, roomId));
return update > 0 ? AjaxResult.success("已读") : AjaxResult.error("消息读取失败");
}
return AjaxResult.error("聊天室不存在");
}
}

6
m2pool-modules/m2pool-chat/src/main/java/com/m2pool/chat/service/impl/ChatRoomServiceImpl.java
View File

@ -38,12 +38,14 @@ public class ChatRoomServiceImpl extends ServiceImpl<ChatRoomMapper, ChatRoom> i
List<ChatRoomDto> roomList = chatRoomMapper.findRoomList(SecurityUtils.getUsername());
List<String> userEmails = roomList.stream().map(ChatRoomDto::getUserEmail).collect(Collectors.toList());
//2.查询未读数量
if (!userEmails.isEmpty()){
Map<String, Integer> unReadNums = chatMessageMapper.findUnReadNums(userEmails);
for (ChatRoomDto room : roomList) {
Integer i = unReadNums.get(room.getUserEmail());
room.setUnReadNumber(i == null ? 0 : i);
}
}
return getDataTable(roomList);
}
@ -85,6 +87,6 @@ public class ChatRoomServiceImpl extends ServiceImpl<ChatRoomMapper, ChatRoom> i
if(i > 0){
return AjaxResult.success("修改成功");
}
return AjaxResult.error("修改失败");
return AjaxResult.error("修改失败,不存在该聊天室");
}
}

6
m2pool-modules/m2pool-chat/src/main/java/com/m2pool/chat/service/impl/StompServiceImpl.java
View File

@ -1,6 +1,5 @@
package com.m2pool.chat.service.impl;
import cn.hutool.core.date.DateTime;
import com.m2pool.chat.constant.Destination;
import com.m2pool.chat.dto.WebsocketMessageDto;
import com.m2pool.chat.entity.ChatMessage;
@ -17,6 +16,7 @@ import org.springframework.messaging.simp.user.SimpUserRegistry;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.time.LocalDateTime;
import static com.m2pool.chat.constant.UserType.CUSTOMER;
import static com.m2pool.chat.constant.UserType.TOURIST;
@ -88,9 +88,9 @@ public class StompServiceImpl implements StompService {
private void updateRoom(UserMessageVo userMessageVo){
ChatRoom room = ChatRoom.builder().id(userMessageVo.getRoomId()).build();
if (CUSTOMER.equals(userMessageVo.getSendUserType())) {
room.setLastCustomerSendTime(DateTime.now());
room.setLastCustomerSendTime(LocalDateTime.now());
} else {
room.setLastUserSendTime(DateTime.now());
room.setLastUserSendTime(LocalDateTime.now());
}
chatRoomMapper.insert(room);
}

11
m2pool-modules/m2pool-chat/src/main/resources/bootstrap-prod.yml
View File

@ -70,7 +70,10 @@ spring:
max-file-size: 2MB
max-request-size: 8MB
myenv:
domain: https://www.m2pool.com
path: /var/www/html/web
img: /img
websocket:
transport:
message-size-limit: 1500 # 消息大小限制 1.5k 约500汉字
send-time-limit: 5000 # 发送超时时间 5秒
send-buffer-size-limit: 65536 # 发送缓冲区大小 64K
time-to-first-message: 5000 # 首次消息超时时间 5秒
max-connections: 100 # 最大连接数

12
m2pool-modules/m2pool-chat/src/main/resources/bootstrap-test.yml
View File

@ -36,8 +36,10 @@ spring:
max-file-size: 2MB
max-request-size: 8MB
myenv:
domain: https://test.m2pool.com
path: /var/www/html/web_test
img: /imgpp
websocket:
transport:
message-size-limit: 1500 # 消息大小限制 1.5k 约500汉字
send-time-limit: 5000 # 发送超时时间 5秒
send-buffer-size-limit: 65536 # 发送缓冲区大小 64K
time-to-first-message: 5000 # 首次消息超时时间 5秒
max-connections: 100 # 最大连接数

6
m2pool-modules/m2pool-chat/src/main/resources/mapper/chat/ChatMessageMapper.xml
View File

@ -15,15 +15,15 @@
LIMIT #{pageNum}
</select>
<select id="findUnReadNums" resultType="java.util.Map">
SELECT user_email as userEmail,
SELECT send_email as userEmail,
count(*) as unReadNums
FROM chat_message
WHERE send_email IN
<foreach collection="userEmails" item="userEmail" open="(" separator="," close=")">
#{userEmail}
</foreach>
AND read_flag = false
GROUP BY user_email
AND `read` = false
GROUP BY send_email
</select>
</mapper>

5
m2pool-modules/m2pool-file/src/main/java/com/m2pool/file/config/ResourcesConfig.java
View File

@ -1,12 +1,13 @@
package com.m2pool.file.config;
import java.io.File;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.servlet.config.annotation.CorsRegistry;
import org.springframework.web.servlet.config.annotation.ResourceHandlerRegistry;
import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;
import java.io.File;
/**
* 通用映射配置
*
@ -18,7 +19,7 @@ public class ResourcesConfig implements WebMvcConfigurer
/**
* 上传文件存储在本地的根路径
*/
@Value("${file.path}")
@Value("${file.filepath}")
private String localFilePath;
/**

2
m2pool-modules/m2pool-file/src/main/java/com/m2pool/file/controller/SysFileController.java
View File

@ -32,7 +32,7 @@ public class SysFileController
/**
* 上传文件存储在本地的根路径
*/
@Value("${file.path}")
@Value("${file.filepath}")
private String localFilePath;
/**

4
m2pool-modules/m2pool-file/src/main/java/com/m2pool/file/service/LocalSysFileServiceImpl.java
View File

@ -20,7 +20,7 @@ public class LocalSysFileServiceImpl implements ISysFileService
/**
* 资源映射路径 前缀
*/
@Value("${file.prefix}")
@Value("${file.prefix")
public String localFilePrefix;
/**
@ -32,7 +32,7 @@ public class LocalSysFileServiceImpl implements ISysFileService
/**
* 上传文件存储在本地的根路径
*/
@Value("${file.path}")
@Value("${file.filepath}")
private String localFilePath;
/**

30
m2pool-modules/m2pool-file/src/main/resources/bootstrap-prod.yml Normal file
View File

@ -0,0 +1,30 @@
# Tomcat
server:
port: 9300
# Spring
spring:
application:
# 应用名称
name: m2pool-file
profiles:
# 环境配置
active: test
cloud:
nacos:
discovery:
# 服务注册地址
server-addr: 127.0.0.1:8808
config:
# 配置中心地址
server-addr: 127.0.0.1:8808
# 配置文件格式
file-extension: yml
# 共享配置
shared-configs:
- application-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension}
file:
domain: https://www.m2pool.com
path: /var/www/html/web
img: /img
filepath: /home/ubuntu/prod

28
m2pool-modules/m2pool-file/src/main/resources/bootstrap-test.yml Normal file
View File

@ -0,0 +1,28 @@
# Tomcat
server:
port: 9300
# Spring
spring:
application:
# 应用名称
name: m2pool-file
cloud:
nacos:
discovery:
# 服务注册地址
server-addr: 127.0.0.1:8848
config:
# 配置中心地址
server-addr: 127.0.0.1:8848
# 配置文件格式
file-extension: yml
# 共享配置
shared-configs:
- application-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension}
file:
domain: https://www.m2pool.com
path: /var/www/html/web-test
# img: /img
filepath: /home/ubuntu/web

24
m2pool-modules/m2pool-file/src/main/resources/bootstrap.yml
View File

@ -1,25 +1,3 @@
# Tomcat
server:
port: 9300
# Spring
spring:
application:
# 应用名称
name: m2pool-file
profiles:
# 环境配置
active: dev
cloud:
nacos:
discovery:
# 服务注册地址
server-addr: 127.0.0.1:8808
config:
# 配置中心地址
server-addr: 127.0.0.1:8808
# 配置文件格式
file-extension: yml
# 共享配置
shared-configs:
- application-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension}
active: test