main
HuangHai 2 months ago
parent d3c9456735
commit 91e95f68fd

@ -1,9 +1,9 @@
package com.dsideal.gw.Handler; package com.dsideal.gw.Handler;
import com.dsideal.Config.GatewayConfig;
import com.dsideal.gw.Bean.RetBean; import com.dsideal.gw.Bean.RetBean;
import com.dsideal.gw.GwApplication; import com.dsideal.gw.GwApplication;
import com.dsideal.gw.Util.JwtUtil; import com.dsideal.gw.Util.JwtUtil;
import com.dsideal.gw.Config.GatewayConfig;
import com.jfinal.handler.Handler; import com.jfinal.handler.Handler;
import com.jfinal.kit.StrKit; import com.jfinal.kit.StrKit;
import com.jfinal.upload.MultipartRequest; import com.jfinal.upload.MultipartRequest;
@ -15,7 +15,6 @@ import org.apache.commons.io.IOUtils;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import javax.servlet.http.Cookie;
import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse; import javax.servlet.http.HttpServletResponse;
import java.io.*; import java.io.*;
@ -240,22 +239,9 @@ public class RouterHandler extends Handler {
} }
// 处理Cookie // 处理Cookie
javax.servlet.http.Cookie[] cookies = req.getCookies(); String cookie = req.getHeader(Constants.HEADER_COOKIE);
if (cookies != null && cookies.length > 0) { if (!StrKit.isBlank(cookie)) {
StringBuilder cookieString = new StringBuilder(); builder.addHeader(Constants.HEADER_COOKIE, cookie);
for (Cookie cookie : cookies) {
if (cookieString.length() > 0) {
cookieString.append("; ");
}
cookieString.append(cookie.getName()).append("=").append(cookie.getValue());
}
builder.addHeader(Constants.HEADER_COOKIE, cookieString.toString());
}
// 如果还有Cookie头也添加进去
String cookieHeader = req.getHeader(Constants.HEADER_COOKIE);
if (!StrKit.isBlank(cookieHeader)) {
builder.addHeader(Constants.HEADER_COOKIE, cookieHeader);
} }
// 添加其他重要头信息 // 添加其他重要头信息

@ -7,7 +7,7 @@ import org.neo4j.driver.Record;
import org.neo4j.driver.types.Node; import org.neo4j.driver.types.Node;
public class Neo4jDemoController extends Controller { public class Neo4jDemoController extends Controller {
private Neo4jConfig neo4jConfig = new Neo4jConfig(); private final Neo4jConfig neo4jConfig = Neo4jConfig.getInstance();
public void index() { public void index() {
// 获取 Neo4j 驱动 // 获取 Neo4j 驱动
@ -25,5 +25,6 @@ public class Neo4jDemoController extends Controller {
System.out.println(node.get("name").asString()); System.out.println(node.get("name").asString());
} }
} }
renderText("数据读取成功!");
} }
} }

@ -4,11 +4,36 @@ import org.neo4j.driver.AuthTokens;
import org.neo4j.driver.Driver; import org.neo4j.driver.Driver;
import org.neo4j.driver.GraphDatabase; import org.neo4j.driver.GraphDatabase;
import org.neo4j.driver.Session;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
public class Neo4jConfig { public class Neo4jConfig {
private static Neo4jConfig instance;
private Driver driver; private Driver driver;
private static final Logger logger = LoggerFactory.getLogger(Neo4jConfig.class);
private Neo4jConfig() {}
public static Neo4jConfig getInstance() {
if (instance == null) {
instance = new Neo4jConfig();
}
return instance;
}
public void init(String uri, String user, String password) { public void init(String uri, String user, String password) {
driver = GraphDatabase.driver(uri, AuthTokens.basic(user, password)); try {
driver = GraphDatabase.driver(uri, AuthTokens.basic(user, password));
// 验证连接
try (Session session = driver.session()) {
session.run("RETURN 1").consume();
logger.info("Neo4j连接成功");
}
} catch (Exception e) {
logger.error("Neo4j初始化失败: " + e.getMessage(), e);
throw new RuntimeException("Neo4j初始化失败", e);
}
} }
public Driver getDriver() { public Driver getDriver() {

@ -22,10 +22,11 @@ import org.slf4j.LoggerFactory;
import java.io.File; import java.io.File;
public class ResApplication extends JFinalConfig { public class ResApplication extends JFinalConfig {
// 将字段改为静态
private static final Neo4jConfig neo4jConfig = Neo4jConfig.getInstance();
private static final Logger logger = LoggerFactory.getLogger(ResApplication.class); private static final Logger logger = LoggerFactory.getLogger(ResApplication.class);
private final Neo4jConfig neo4jConfig = new Neo4jConfig();
public static void main(String[] args) { public static void main(String[] args) {
System.out.println("当前环境: " + PropKit.getEnvPrefix()); System.out.println("当前环境: " + PropKit.getEnvPrefix());
UndertowServer.create(ResApplication.class, "undertow.properties").start(); UndertowServer.create(ResApplication.class, "undertow.properties").start();
@ -93,7 +94,17 @@ public class ResApplication extends JFinalConfig {
me.add(redis); me.add(redis);
// 配置 Neo4j // 配置 Neo4j
neo4jConfig.init("bolt://localhost:7687", "neo4j", "DsideaL4r5t6y7u"); try {
String url = PropKit.get("neo4j.url");
String username = PropKit.get("neo4j.username");
String password = PropKit.get("neo4j.password");
logger.info("正在初始化Neo4j连接: url={}", url);
neo4jConfig.init(url, username, password);
} catch (Exception e) {
logger.error("Neo4j配置失败", e);
throw new RuntimeException("Neo4j配置失败", e);
}
} }
/** /**
@ -135,9 +146,6 @@ public class ResApplication extends JFinalConfig {
public void onStart() { public void onStart() {
//打印 启动Logo //打印 启动Logo
System.out.println(FileUtil.readUtf8String("logo.txt")); System.out.println(FileUtil.readUtf8String("logo.txt"));
// JFinal 启动时初始化 Neo4j 配置
//neo4jConfig.init("bolt://localhost:7687", "neo4j", "password");
} }
@Override @Override

@ -55,3 +55,7 @@ excel:
# 导入excel 的模板配置路径 # 导入excel 的模板配置路径
ExcelImportTemplatePathSuffix: /ExcelImportTemplate/ ExcelImportTemplatePathSuffix: /ExcelImportTemplate/
neo4j:
url: bolt://localhost:7687
username: neo4j
password: DsideaL4r5t6y7u

@ -54,3 +54,7 @@ excel:
# 导入excel 的模板配置路径 # 导入excel 的模板配置路径
ExcelImportTemplatePathSuffix: /ExcelImportTemplate/ ExcelImportTemplatePathSuffix: /ExcelImportTemplate/
neo4j:
url: bolt://localhost:7687
username: neo4j
password: DsideaL4r5t6y7u
Loading…
Cancel
Save