環(huán)境準備：
| 插件 | 版本 |
| jdk | 21 |
| springboot | 3.0.11 |
| springcloud | 2022.0.4 |
| springcloudalibaba | 2022.0.0.0 |
| nacos | 2.2.3（穩(wěn)定版） |
| python | 3.8 |
nacos部署（docker）
先創(chuàng)建目錄，分別創(chuàng)建config，logs，data目錄，單獨創(chuàng)建一個容器
docker run -d \
-e MODE=standalone \
-p 8848:8848 \
-p 9848:9848 \
-p 7848:7848 \
-v /data/nacos/conf:/mnt/data3/dockerfiles/nacos/config \
-v /data/nacos/logs:/mnt/data3/dockerfiles/nacos/logs \
-v /data/nacos/data:/mnt/data3/dockerfiles/nacos/data \
--name nacos-mysql \
--restart=always \
nacos/nacos-server:v2.2.3?將配置文件拷貝出來(主要是application.properties和logback.xml)
docker cp nacos-mysql:/home/nacos/conf ./修改mysql的信息（修改文件application.properties）
再次運行
docker run -d \
-e MODE=standalone \
-p 8848:8848 \
-p 9848:9848 \
-p 7848:7848 \
-v /data/nacos/conf:/mnt/data3/dockerfiles/nacos/config \
-v /data/nacos/logs:/mnt/data3/dockerfiles/nacos/logs \
-v /data/nacos/data:/mnt/data3/dockerfiles/nacos/data \
--name nacos-mysql \
--restart=always \
nacos/nacos-server:v2.2.3開啟服務器端口：
centos開啟防火墻端口
?訪問 ip:port/nacos
出現(xiàn)此頁面即為安裝成功。
springboot注冊到nacos
先貼一個pom.xml
<?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>3.0.11</version>
<relativePath/> <!-- lookup parent from repository -->
</parent>
<groupId>com.example</groupId>
<artifactId>platform</artifactId>
<version>0.0.1-SNAPSHOT</version>
<name>platform</name>
<description>platform</description>
<properties>
<java.version>21</java.version>
<spring-cloud.version>2022.0.0</spring-cloud.version>
<spring-cloud-alibaba.version>2022.0.0.0</spring-cloud-alibaba.version>
</properties>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.mybatis.spring.boot</groupId>
<artifactId>mybatis-spring-boot-starter</artifactId>
<version>3.0.2</version>
</dependency>
<!-- <dependency>-->
<!-- <groupId>org.springframework.cloud</groupId>-->
<!-- <artifactId>spring-cloud-starter-openfeign</artifactId>-->
<!-- </dependency>-->
<dependency>
<groupId>com.baomidou</groupId>
<artifactId>mybatis-plus-boot-starter</artifactId>
<version>3.5.3.2</version>
</dependency>
<dependency>
<groupId>com.mysql</groupId>
<artifactId>mysql-connector-j</artifactId>
<scope>runtime</scope>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.mybatis.spring.boot</groupId>
<artifactId>mybatis-spring-boot-starter-test</artifactId>
<version>3.0.2</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<version>edge-SNAPSHOT</version>
</dependency>
<dependency>
<groupId>javax.validation</groupId>
<artifactId>validation-api</artifactId>
<version>2.0.1.Final</version>
</dependency>
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-lang3</artifactId>
</dependency>
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
</dependency>
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-bootstrap</artifactId>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
<version>2.0.41</version>
</dependency>
<dependency>
<groupId>com.auth0</groupId>
<artifactId>java-jwt</artifactId>
<version>4.4.0</version>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-loadbalancer</artifactId>
</dependency>
</dependencies>
<dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-dependencies</artifactId>
<version>${spring-cloud.version}</version>
<type>pom</type>
<scope>import</scope>
</dependency>
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-alibaba-dependencies</artifactId>
<version>${spring-cloud-alibaba.version}</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>
<repositories>
<repository>
<id>projectlombok.org</id>
<url>https://projectlombok.org/edge-releases</url>
</repository>
</repositories>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
</project>
配置文件bootstrap.yml
spring:
application:
name: platform
cloud:
nacos:
server-addr: ip:port
config:
file-extension: yml
group: DEFAULT_GROUP
prefix: ${sping.application.name}springboot啟動類
@SpringBootApplication
@EnableFeignClients
@EnableCaching
@EnableScheduling
@EnableDiscoveryClient
@RefreshScope
public class PlatformApplication {
public static void main(String[] args) {
SpringApplication.run(PlatformApplication.class, args);
}
}啟動后就可以將服務注冊到nacos中
python集成flask注冊到nacos
首先下載nacos的sdk包
pip install nacos-sdk-pythonpython代碼
import glob
import nacos
import threading
from flask import request, send_file
from flask import Flask, Response
# nacos注冊中心配置
SERVER_ADDRESS = "http://ip:port"
client = nacos.NacosClient(SERVER_ADDRESS)
def service_register():
"""
ephemeral參數(shù)：是否是臨時服務，應為false;
剛才上面也提到了，如果是 非臨時實例，客戶端就無需主動完成心跳檢測。
因此此處將服務注冊為 非臨時實例
"""
client.add_naming_instance(
"train", "ip", "port", ephemeral=False)
# 測試nacos
@app.route("/testNacos/<testId>", methods=["GET"])
def testNacos(testId):
resMap = {}
print("nacos: {}".format(testId))
resMap["code"] = "200"
resMap["message"] = "hello nacos"
resMap["data"] = str(testId)
response = Response(json.dumps(resMap), status=200,
content_type='application/json')
return response
if __name__ == "__main__":
# main()
threading.Timer(5, service_register).start()
app.run("0.0.0.0", 12352)啟動后就可以將服務注冊到nacos中
到這里，服務注冊到nacos已經(jīng)完成了
使用openfeign進行服務間的調(diào)用
@FeignClient("train")
public interface InferRpcService {
@GetMapping("/testNacos/{testId}")
VitsResponse testNacos(@PathVariable String testId);
}
測試類
@Test
public void testNacosPy(){
System.out.println(trainService.testNacos("232323"));
}執(zhí)行后
經(jīng)測試沒有問題
gateway網(wǎng)關服務
pom.xml
<?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>3.0.11</version>
<relativePath/> <!-- lookup parent from repository -->
</parent>
<groupId>com.example</groupId>
<artifactId>gateway</artifactId>
<version>0.0.1-SNAPSHOT</version>
<name>gateway</name>
<description>gateway</description>
<properties>
<java.version>21</java.version>
<spring-cloud.version>2022.0.4</spring-cloud.version>
<spring-cloud-alibaba.version>2022.0.0.0</spring-cloud-alibaba.version>
</properties>
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-gateway</artifactId>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
</dependency>
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-bootstrap</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-loadbalancer</artifactId>
</dependency>
<dependency>
<groupId>com.auth0</groupId>
<artifactId>java-jwt</artifactId>
<version>4.4.0</version>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
<version>2.0.41</version>
</dependency>
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-lang3</artifactId>
</dependency>
</dependencies>
<dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-dependencies</artifactId>
<version>${spring-cloud.version}</version>
<type>pom</type>
<scope>import</scope>
</dependency>
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-alibaba-dependencies</artifactId>
<version>${spring-cloud-alibaba.version}</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
</project>
配置文件（bootstrap.yml）
spring:
application:
name: gateway
cloud:
nacos:
server-addr: ip:port
config:
file-extension: yml
group: DEFAULT_GROUP
prefix: ${sping.application.name}
gateway:
# 下游服務https配置
httpclient:
ssl:
use-insecure-trust-manager: true
routes:
- id: platform
uri: lb://platform
predicates:
- Path=/api/platform/**
filters:
- StripPrefix=2啟動類
@RefreshScope
@EnableDiscoveryClient
@SpringBootApplication
public class GatewayApplication {
public static void main(String[] args) {
SpringApplication.run(GatewayApplication.class, args);
}
}jwt續(xù)約
工具類
import com.auth0.jwt.JWT;
import com.auth0.jwt.JWTCreator;
import com.auth0.jwt.algorithms.Algorithm;
import com.auth0.jwt.exceptions.JWTVerificationException;
import com.auth0.jwt.interfaces.DecodedJWT;
import lombok.extern.slf4j.Slf4j;
import java.time.LocalDateTime;
import java.util.*;
@Slf4j
public class JWTUtils {
private static final String SING = "auth";
public static String getToken(Map<String, String> map) {
Calendar instance = Calendar.getInstance();
instance.add(Calendar.MINUTE, 30);
JWTCreator.Builder builder = JWT.create();
map.forEach((k, v) -> {
builder.withClaim(k, v);
});
String token = builder.withExpiresAt(instance.getTime())
.sign(Algorithm.HMAC256(SING));
return token;
}
public static DecodedJWT verify(String token) {
return JWT.require(Algorithm.HMAC256(SING)).build().verify(token);
}
/**
* 查看是否需要續(xù)約
*
* @param jwtToken 前端的
* @return -1過期，不需要續(xù)約 0 不需要操作 1 需要續(xù)約
*/
public static int renewed(String jwtToken) {
DecodedJWT verify = null;
try {
verify = JWT.require(Algorithm.HMAC256(SING)).build().verify(jwtToken);
if (Objects.nonNull(verify)) {
log.info("過期時間: {}", verify.getExpiresAt());
Date date = verify.getExpiresAt();
if (date.before(new Date())) {
log.info("token已過期");
return -1;
} else if (DateUtils.toLocalDateTime(date).minusMinutes(15L).isAfter(LocalDateTime.now())) {
log.info("token處于正常狀態(tài)");
return 0;
} else if (DateUtils.toLocalDateTime(date).minusMinutes(15L).isBefore(LocalDateTime.now())) {
log.info("token需要續(xù)簽");
return 1;
}
}
} catch (JWTVerificationException | IllegalArgumentException e) {
log.info("token已過期");
return -1;
}
log.info("token已過期");
return -1;
}
public static String doRenewed(String number) {
Map<String, String> map = Collections.singletonMap("openid", number);
return getToken(map);
}
}
public class DateUtils {
public static LocalDateTime toLocalDateTime(Date date){
return date.toInstant().atZone(ZoneId.systemDefault()).toLocalDateTime();
}
}全局過濾器
import com.alibaba.fastjson.JSON;
import com.auth0.jwt.interfaces.DecodedJWT;
import com.example.gateway.constant.Constant;
import com.example.gateway.constant.LoginConstant;
import com.example.gateway.constant.VitsCloneConstant;
import com.example.gateway.dto.response.CommonResponse;
import com.example.gateway.utils.JWTUtils;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.cloud.gateway.filter.GatewayFilterChain;
import org.springframework.cloud.gateway.filter.GlobalFilter;
import org.springframework.core.Ordered;
import org.springframework.http.HttpStatus;
import org.springframework.http.server.reactive.ServerHttpRequest;
import org.springframework.http.server.reactive.ServerHttpResponse;
import org.springframework.stereotype.Component;
import org.springframework.web.server.ServerWebExchange;
import reactor.core.publisher.Mono;
@Slf4j
@Component
public class AuthFilter implements GlobalFilter, Ordered {
@Override
public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
ServerHttpRequest request = exchange.getRequest();
ServerHttpResponse response = exchange.getResponse();
// 獲取請求路徑
String path = request.getPath().toString();
log.info("path:{}", path);
// 當前過濾器
if (StringUtils.contains(path, VitsCloneConstant.API_PREFIX)) {
// 如果是登錄接口，直接放行
if (StringUtils.contains(path, LoginConstant.LOGIN_PATH)) {
return chain.filter(exchange);
}
// 獲取請求頭中的Authorization字段
String token = request.getHeaders().getFirst(LoginConstant.AUTHORIZATION_HEADER);
// 如果校驗失敗，返回未授權狀態(tài)
if (StringUtils.isEmpty(token)) {
CommonResponse<String> error = CommonResponse.error("無效的授權信息", "無效的授權信息");
response.setStatusCode(HttpStatus.UNAUTHORIZED);
return response.writeWith(Mono.just(response.bufferFactory().wrap(JSON.toJSONBytes(error))));
}
int renewed = JWTUtils.renewed(token);
if (renewed == -1) {
log.info("token已過期");
CommonResponse<String> error = CommonResponse.error("無效的授權信息", "無效的授權信息");
response.setStatusCode(HttpStatus.UNAUTHORIZED);
return response.writeWith(Mono.just(response.bufferFactory().wrap(JSON.toJSONBytes(error))));
} else if (renewed == 0) {
log.info("jwtToken狀態(tài)正常,無需操作");
DecodedJWT verify = JWTUtils.verify(token);
String openid = verify.getClaims().get("openid").asString();
ServerHttpRequest modifiedRequest = exchange.getRequest()
.mutate()
.header("openId", openid)
.build();
return chain.filter(exchange.mutate().request(modifiedRequest).build());
} else {
DecodedJWT verify = JWTUtils.verify(token);
String openid = verify.getClaims().get("openid").asString();
log.info("當前需要續(xù)約的jwtToken的用戶手機號碼: {}", openid);
token = JWTUtils.doRenewed(openid);
response.getHeaders().set(LoginConstant.AUTHORIZATION_HEADER, token);
ServerHttpRequest modifiedRequest = exchange.getRequest()
.mutate()
.header("openId", openid)
.build();
return chain.filter(exchange.mutate().request(modifiedRequest).build());
}
}
return chain.filter(exchange);
}
@Override
public int getOrder() {
return -900;
}
}常量類文章來源：http://www.zghlxwxcb.cn/news/detail-731760.html
public interface Constant {
String TOKEN = "token";
}public interface LoginConstant {
String LOGIN_PATH = "/login";
String AUTHORIZATION_HEADER = "token";
}public interface VitsCloneConstant {
String API_PREFIX="/api/platform/";
}啟動網(wǎng)關后，就可以通過網(wǎng)關訪問服務了文章來源地址http://www.zghlxwxcb.cn/news/detail-731760.html
到了這里，關于springboot和flask整合nacos，使用openfeign實現(xiàn)服務調(diào)用，使用gateway實現(xiàn)網(wǎng)關的搭建（附帶jwt續(xù)約的實現(xiàn)）的文章就介紹完了。如果您還想了解更多內(nèi)容，請在右上角搜索TOY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關文章，希望大家以后多多支持TOY模板網(wǎng)！
