|
@@ -43,11 +43,11 @@ dotenv.config();
|
|
|
const amqplib_1 = __importDefault(require("amqplib")); // 明确导入 Connection, Channel, Message 类型
|
|
const amqplib_1 = __importDefault(require("amqplib")); // 明确导入 Connection, Channel, Message 类型
|
|
|
const rfs = __importStar(require("rotating-file-stream")); // 👈 关键修复:使用 `import * as rfs`
|
|
const rfs = __importStar(require("rotating-file-stream")); // 👈 关键修复:使用 `import * as rfs`
|
|
|
const moment_1 = __importDefault(require("moment")); // 导入 moment (用于日志文件名生成)
|
|
const moment_1 = __importDefault(require("moment")); // 导入 moment (用于日志文件名生成)
|
|
|
-const path = __importStar(require("path")); // 导入 path 模块
|
|
|
|
|
// --- Environment Variables ---
|
|
// --- Environment Variables ---
|
|
|
const RABBITMQ_URL = process.env.RABBITMQ_URL || "amqp://coloring:coloring123.@localhost:5672";
|
|
const RABBITMQ_URL = process.env.RABBITMQ_URL || "amqp://coloring:coloring123.@localhost:5672";
|
|
|
const RABBITMQ_LOG_QUEUE = process.env.RABBITMQ_LOG_QUEUE || "log-event-queue"; // 日志服务订阅的队列
|
|
const RABBITMQ_LOG_QUEUE = process.env.RABBITMQ_LOG_QUEUE || "log-event-queue"; // 日志服务订阅的队列
|
|
|
-const LOG_DIR = process.env.LOG_DIR || path.join(__dirname, "..", "..", "logs", "coloring"); // 日志文件存储路径
|
|
|
|
|
|
|
+// const LOG_DIR = process.env.LOG_DIR || path.join(__dirname, "..", "..", "logs", "coloring"); // 日志文件存储路径
|
|
|
|
|
+const LOG_DIR = process.env.LOG_DIR || "/home/jccy/logs"; // 日志文件存储路径
|
|
|
let amqpConnection; // 使用 undefined 初始化,因为连接是异步的
|
|
let amqpConnection; // 使用 undefined 初始化,因为连接是异步的
|
|
|
let amqpChannel; // 使用 undefined 初始化,因为频道是异步的
|
|
let amqpChannel; // 使用 undefined 初始化,因为频道是异步的
|
|
|
// --- Log Rotation Setup ---
|
|
// --- Log Rotation Setup ---
|