Log4j 是一个使用 Java 语言编写的，可靠、快速、灵活的日志框架（API），使用 Apache Software License 授权。它被移植到 C、C++、C#、Perl、Python、Ruby 和 Eiffel 语言中。
Log4j 是高度可配置的，在运行期使用外部的配置文件对其进行配置。它按照优先级别记录日志，并可将日志信息定向输出到各种介质，比如数据库、文件、控制台、Unix Syslog等。
Log4j 主要由三部分组成：
- loggers：负责采集日志信息。
- appenders：负责将日志信息发布到不同地方。
- layouts：负责以各种风格格式化日志信息。
确认版本
Logstash配置
- 你需要知道logstash服务的IP和端口
- 你需要知道写日志是通过什么协议：TCP，还是UDP
在我向logstash写日志之前，已经有同事向Logstash写过日志了。当时只是知道logstash的ip和端口，没有搞清楚协议，所以没有写进去。
logger
// 获取配置文件中logstash的IP地址和端口
var {logHost,logPort} = require('../config/index.js')
if (!logHost || !logPort) {
console.log('ERROR not config logstash_host or logstash_port')
}
log4js.configure({
appenders: {
console: { type: 'console' },logstash: {
// 因为我们的logstash暴露的是tcp写日志的端口，所以我用了log4js-logstash-tcp，
// 这个需要安装 https://github.com/Aigent/log4js-logstash-tcp
// 如果你的logstash使用UDP的，参考 https://github.com/log4js-node/logstashUDP
type: 'log4js-logstash-tcp',host: logHost,port: parseInt(logPort)
}
},categories: {
default: { appenders: ['logstash'],level: 'debug' }
}
})
const logger = log4js.getLogger('default')
app.js
var {proxyTable,maxAge} = require('./config/index.js')
...
Object.keys(proxyTable).forEach(function (context) {
if (!proxyTable[context].ws) {
// 这里我是用的反向代理，当代理响应时，开始写日志
proxyTable[context].onProxyRes = writeLog
}
app.use(proxyMiddleware(context,proxyTable[context]))
})
...
// 主要谢日日志的就是这里
function writeLog (proxyRes,req,res) {
var baseLog = ${req.method} ${proxyRes.statusCode} ${req.cookies.email} ${req.url}
var msgObj = {
method: req.method,statusCode: proxyRes.statusCode,url: req.url,email: req.cookies.email || '',sessionId: req.cookies.sessionId || '',instanceId: 'newTm',nodeName: 'newTm'
}
if (proxyRes.statusCode < 400) {
logger.info(baseLog,msgObj)
} else {
logger.error(baseLog,msgObj)
}
}
在kibana中输入关键词：nodeName:newTm
可以搜到如下的记录
注意
- 要注意写日志是用UDP还是TCP
- 如果要用，Logstash (UDP and HTTP) appender，该功能已经被移动到 https://github.com/log4js-node/logstashUDP 最好要单独安装
