聊聊PowerJob日志的上报及存储

2024-02-03 23:44
文章标签 日志 存储 聊聊 上报 powerjob

本文主要是介绍聊聊PowerJob日志的上报及存储，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

序

本文主要研究一下PowerJob的日志上报及存储

OmsLoggerFactory.build

tech/powerjob/worker/log/OmsLoggerFactory.java

public class OmsLoggerFactory {public static OmsLogger build(Long instanceId, String logConfig, WorkerRuntime workerRuntime) {LogConfig cfg;if (StringUtils.isEmpty(logConfig)) {cfg = new LogConfig();} else {try {cfg = JsonUtils.parseObject(logConfig, LogConfig.class);} catch (Exception ignore) {cfg = new LogConfig();}}switch (LogType.of(cfg.getType())) {case LOCAL:return new OmsLocalLogger(cfg);case STDOUT:return new OmsStdOutLogger(cfg);case NULL:return new OmsNullLogger();case LOCAL_AND_ONLINE:return new OmsServerAndLocalLogger(cfg, instanceId, workerRuntime.getOmsLogHandler());default:return new OmsServerLogger(cfg, instanceId, workerRuntime.getOmsLogHandler());}}
}

默认logConfig为null，cfg是new LogConfig()，其build出来的是OmsServerLogger

OmsServerLogger

tech/powerjob/worker/log/impl/OmsServerLogger.java

public class OmsServerLogger extends AbstractOmsLogger {private final long instanceId;private final OmsLogHandler omsLogHandler;public OmsServerLogger(LogConfig logConfig, long instanceId, OmsLogHandler omsLogHandler) {super(logConfig);this.instanceId = instanceId;this.omsLogHandler = omsLogHandler;}@Overridepublic void debug0(String messagePattern, Object... args) {process(LogLevel.DEBUG, messagePattern, args);}@Overridepublic void info0(String messagePattern, Object... args) {process(LogLevel.INFO, messagePattern, args);}@Overridepublic void warn0(String messagePattern, Object... args) {process(LogLevel.WARN, messagePattern, args);}@Overridepublic void error0(String messagePattern, Object... args) {process(LogLevel.ERROR, messagePattern, args);}private void process(LogLevel level, String messagePattern, Object... args) {String logContent = genLogContent(messagePattern, args);omsLogHandler.submitLog(instanceId, level, logContent);}}

OmsServerLogger的process方法调用的是OmsLogHandler的submitLog方法

submitLog

tech/powerjob/worker/background/OmsLogHandler.java

@Slf4j
public class OmsLogHandler {private final String workerAddress;private final Transporter transporter;private final ServerDiscoveryService serverDiscoveryService;// 处理线程，需要通过线程池启动public final Runnable logSubmitter = new LogSubmitter();// 上报锁，只需要一个线程上报即可private final Lock reportLock = new ReentrantLock();// 生产者消费者模式，异步上传日志private final BlockingQueue<InstanceLogContent> logQueue = Queues.newLinkedBlockingQueue(10240);// 每次上报携带的数据条数private static final int BATCH_SIZE = 20;// 本地囤积阈值private static final int REPORT_SIZE = 1024;public OmsLogHandler(String workerAddress, Transporter transporter, ServerDiscoveryService serverDiscoveryService) {this.workerAddress = workerAddress;this.transporter = transporter;this.serverDiscoveryService = serverDiscoveryService;}/*** 提交日志* @param instanceId 任务实例ID* @param logContent 日志内容*/public void submitLog(long instanceId, LogLevel logLevel, String logContent) {if (logQueue.size() > REPORT_SIZE) {// 线程的生命周期是个不可循环的过程，一个线程对象结束了不能再次start，只能一直创建和销毁new Thread(logSubmitter).start();}InstanceLogContent tuple = new InstanceLogContent(instanceId, System.currentTimeMillis(), logLevel.getV(), logContent);boolean offerRet = logQueue.offer(tuple);if (!offerRet) {log.warn("[OmsLogHandler] [{}] submit log failed, maybe your log speed is too fast!", instanceId);}}//......
}

OmsLogHandler的submitLog方法每次先判断logQueue大小是否大于REPORT_SIZE(1024)，是则启动logSubmitter线程，否则放入logQueue队列

LogSubmitter

tech/powerjob/worker/background/OmsLogHandler.java

    private class LogSubmitter implements Runnable {@Overridepublic void run() {boolean lockResult = reportLock.tryLock();if (!lockResult) {return;}try {final String currentServerAddress = serverDiscoveryService.getCurrentServerAddress();// 当前无可用 Serverif (StringUtils.isEmpty(currentServerAddress)) {if (!logQueue.isEmpty()) {logQueue.clear();log.warn("[OmsLogHandler] because there is no available server to report logs which leads to queue accumulation, oms discarded all logs.");}return;}List<InstanceLogContent> logs = Lists.newLinkedList();while (!logQueue.isEmpty()) {try {InstanceLogContent logContent = logQueue.poll(100, TimeUnit.MILLISECONDS);logs.add(logContent);if (logs.size() >= BATCH_SIZE) {WorkerLogReportReq req = new WorkerLogReportReq(workerAddress, Lists.newLinkedList(logs));// 不可靠请求，WEB日志不追求极致TransportUtils.reportLogs(req, currentServerAddress, transporter);logs.clear();}}catch (Exception ignore) {break;}}if (!logs.isEmpty()) {WorkerLogReportReq req = new WorkerLogReportReq(workerAddress, logs);TransportUtils.reportLogs(req, currentServerAddress, transporter);}}finally {reportLock.unlock();}}}

LogSubmitter不断地从logQueue.poll数据，在logs的大小大于等于BATCH_SIZE(20)时通过TransportUtils.reportLogs给server上报日志

reportLogs

tech/powerjob/worker/common/utils/TransportUtils.java

    public static void reportLogs(WorkerLogReportReq req, String address, Transporter transporter) {final URL url = easyBuildUrl(ServerType.SERVER, S4W_PATH, S4W_HANDLER_REPORT_LOG, address);transporter.tell(url, req);}

reportLogs请求S4W_HANDLER_REPORT_LOG

processWorkerLogReport

tech/powerjob/server/core/handler/AbWorkerRequestHandler.java

    @Override@Handler(path = S4W_HANDLER_REPORT_LOG, processType = ProcessType.NO_BLOCKING)public void processWorkerLogReport(WorkerLogReportReq req) {WorkerLogReportEvent event = new WorkerLogReportEvent().setWorkerAddress(req.getWorkerAddress()).setLogNum(req.getInstanceLogContents().size());try {processWorkerLogReport0(req, event);event.setStatus(WorkerLogReportEvent.Status.SUCCESS);} catch (RejectedExecutionException re) {event.setStatus(WorkerLogReportEvent.Status.REJECTED);} catch (Throwable t) {event.setStatus(WorkerLogReportEvent.Status.EXCEPTION);log.warn("[WorkerRequestHandler] process worker report failed!", t);} finally {monitorService.monitor(event);}}

server端的processWorkerLogReport接收WorkerLogReportReq，执行processWorkerLogReport0方法

WorkerRequestHandlerImpl

tech/powerjob/server/core/handler/WorkerRequestHandlerImpl.java

    protected void processWorkerLogReport0(WorkerLogReportReq req, WorkerLogReportEvent event) {// 这个效率应该不会拉垮吧...也就是一些判断 + Map#get 吧...instanceLogService.submitLogs(req.getWorkerAddress(), req.getInstanceLogContents());}

WorkerRequestHandlerImpl的processWorkerLogReport0执行的是instanceLogService.submitLogs

submitLogs

tech/powerjob/server/core/instance/InstanceLogService.java

    @Async(value = PJThreadPool.LOCAL_DB_POOL)public void submitLogs(String workerAddress, List<InstanceLogContent> logs) {List<LocalInstanceLogDO> logList = logs.stream().map(x -> {instanceId2LastReportTime.put(x.getInstanceId(), System.currentTimeMillis());LocalInstanceLogDO y = new LocalInstanceLogDO();BeanUtils.copyProperties(x, y);y.setWorkerAddress(workerAddress);return y;}).collect(Collectors.toList());try {CommonUtils.executeWithRetry0(() -> localInstanceLogRepository.saveAll(logList));}catch (Exception e) {log.warn("[InstanceLogService] persistent instance logs failed, these logs will be dropped: {}.", logs, e);}}

InstanceLogService的submitLogs是个异步方法，它将InstanceLogContent转换为LocalInstanceLogDO，然后执行localInstanceLogRepository.saveAll保存

LocalJpaConfig

tech/powerjob/server/persistence/config/LocalJpaConfig.java

@Configuration
@EnableTransactionManagement
@EnableJpaRepositories(// repository包名basePackages = LocalJpaConfig.LOCAL_PACKAGES,// 实体管理bean名称entityManagerFactoryRef = "localEntityManagerFactory",// 事务管理bean名称transactionManagerRef = "localTransactionManager"
)
public class LocalJpaConfig {public static final String LOCAL_PACKAGES = "tech.powerjob.server.persistence.local";private static Map<String, Object> genDatasourceProperties() {JpaProperties jpaProperties = new JpaProperties();jpaProperties.setOpenInView(false);jpaProperties.setShowSql(false);HibernateProperties hibernateProperties = new HibernateProperties();// 每次启动都删除数据（重启后原来的Instance已经通过故障转移更换了Server，老的日志数据也没什么意义了）hibernateProperties.setDdlAuto("create");return hibernateProperties.determineHibernateProperties(jpaProperties.getProperties(), new HibernateSettings());}@Bean(name = "localEntityManagerFactory")public LocalContainerEntityManagerFactoryBean initLocalEntityManagerFactory(@Qualifier("omsLocalDatasource") DataSource omsLocalDatasource,EntityManagerFactoryBuilder builder) {return builder.dataSource(omsLocalDatasource).properties(genDatasourceProperties()).packages(LOCAL_PACKAGES).persistenceUnit("localPersistenceUnit").build();}@Bean(name = "localTransactionManager")public PlatformTransactionManager initLocalTransactionManager(@Qualifier("localEntityManagerFactory") LocalContainerEntityManagerFactoryBean localContainerEntityManagerFactoryBean) {return new JpaTransactionManager(Objects.requireNonNull(localContainerEntityManagerFactoryBean.getObject()));}@Bean(name = "localTransactionTemplate")public TransactionTemplate initTransactionTemplate(@Qualifier("localTransactionManager") PlatformTransactionManager ptm) {TransactionTemplate tt =  new TransactionTemplate(ptm);// 设置隔离级别tt.setIsolationLevel(TransactionDefinition.ISOLATION_DEFAULT);return tt;}
}

LocalJpaConfig针对tech.powerjob.server.persistence.local的dao采用了omsLocalDatasource数据源

MultiDatasourceConfig

tech/powerjob/server/persistence/config/MultiDatasourceConfig.java

@Configuration
public class MultiDatasourceConfig {private static final String H2_DRIVER_CLASS_NAME = "org.h2.Driver";private static final String H2_JDBC_URL_PATTERN = "jdbc:h2:file:%spowerjob_server_db";private static final int H2_MIN_SIZE = 4;private static final int H2_MAX_ACTIVE_SIZE = 10;@Primary@Bean("omsRemoteDatasource")@ConfigurationProperties(prefix = "spring.datasource.core")public DataSource initOmsCoreDatasource() {return DataSourceBuilder.create().build();}@Bean("omsLocalDatasource")public DataSource initOmsLocalDatasource() {String h2Path = OmsFileUtils.genH2WorkPath();HikariConfig config = new HikariConfig();config.setDriverClassName(H2_DRIVER_CLASS_NAME);config.setJdbcUrl(String.format(H2_JDBC_URL_PATTERN, h2Path));config.setAutoCommit(true);// 池中最小空闲连接数量config.setMinimumIdle(H2_MIN_SIZE);// 池中最大连接数量config.setMaximumPoolSize(H2_MAX_ACTIVE_SIZE);// JVM 关闭时删除文件try {FileUtils.forceDeleteOnExit(new File(h2Path));}catch (Exception ignore) {}return new HikariDataSource(config);}
}

MultiDatasourceConfig定义了两个数据源，一个是远程的数据源，比如mysql，一个是本地的h2数据源

processFinishedInstance

tech/powerjob/server/core/instance/InstanceManager.java

    public void processFinishedInstance(Long instanceId, Long wfInstanceId, InstanceStatus status, String result) {log.info("[Instance-{}] process finished, final status is {}.", instanceId, status.name());// 上报日志数据HashedWheelTimerHolder.INACCURATE_TIMER.schedule(() -> instanceLogService.sync(instanceId), 60, TimeUnit.SECONDS);// workflow 特殊处理if (wfInstanceId != null) {// 手动停止在工作流中也认为是失败（理论上不应该发生）workflowInstanceManager.move(wfInstanceId, instanceId, status, result);}// 告警if (status == InstanceStatus.FAILED) {alert(instanceId, result);}// 主动移除缓存，减小内存占用instanceMetadataService.invalidateJobInfo(instanceId);}

InstanceManager的processFinishedInstance方法会延时60s执行instanceLogService.sync(instanceId)

sync

tech/powerjob/server/core/instance/InstanceLogService.java

    @Async(PJThreadPool.BACKGROUND_POOL)public void sync(Long instanceId) {Stopwatch sw = Stopwatch.createStarted();try {// 先持久化到本地文件File stableLogFile = genStableLogFile(instanceId);// 将文件推送到 MongoDBFileLocation dfsFL = new FileLocation().setBucket(Constants.LOG_BUCKET).setName(genMongoFileName(instanceId));try {dFsService.store(new StoreRequest().setLocalFile(stableLogFile).setFileLocation(dfsFL));log.info("[InstanceLog-{}] push local instanceLogs to mongoDB succeed, using: {}.", instanceId, sw.stop());}catch (Exception e) {log.warn("[InstanceLog-{}] push local instanceLogs to mongoDB failed.", instanceId, e);}}catch (Exception e) {log.warn("[InstanceLog-{}] sync local instanceLogs failed.", instanceId, e);}// 删除本地数据库数据try {instanceId2LastReportTime.remove(instanceId);CommonUtils.executeWithRetry0(() -> localInstanceLogRepository.deleteByInstanceId(instanceId));log.info("[InstanceLog-{}] delete local instanceLog successfully.", instanceId);}catch (Exception e) {log.warn("[InstanceLog-{}] delete local instanceLog failed.", instanceId, e);}}

InstanceLogService的sync方法先通过genStableLogFile将日志持久化到server端的本地日志文件，接着将该任务实例日志的元信息(哪个任务实例、在哪个server、本地日志文件的路径)存储到dFsService(它有oss、gridfs、minio、mysql四种实现，具体看server的配置文件是启动哪个，如果是mysql则是存储到powerjob_files表中)，最后通过localInstanceLogRepository.deleteByInstanceId清空该任务实例在h2中的LOCAL_INSTANCE_LOG表的记录

genStableLogFile

    private File genStableLogFile(long instanceId) {String path = genLogFilePath(instanceId, true);int lockId = ("stFileLock-" + instanceId).hashCode();try {segmentLock.lockInterruptibleSafe(lockId);return localTransactionTemplate.execute(status -> {File f = new File(path);if (f.exists()) {return f;}try {// 创建父文件夹（文件在开流时自动会被创建）FileUtils.forceMkdirParent(f);// 本地存在数据，从本地持久化（对应 SYNC 的情况）if (instanceId2LastReportTime.containsKey(instanceId)) {try (Stream<LocalInstanceLogDO> allLogStream = localInstanceLogRepository.findByInstanceIdOrderByLogTime(instanceId)) {stream2File(allLogStream, f);}}else {FileLocation dfl = new FileLocation().setBucket(Constants.LOG_BUCKET).setName(genMongoFileName(instanceId));Optional<FileMeta> dflMetaOpt = dFsService.fetchFileMeta(dfl);if (!dflMetaOpt.isPresent()) {OmsFileUtils.string2File("SYSTEM: There is no online log for this job instance.", f);return f;}dFsService.download(new DownloadRequest().setTarget(f).setFileLocation(dfl));}return f;}catch (Exception e) {CommonUtils.executeIgnoreException(() -> FileUtils.forceDelete(f));throw new RuntimeException(e);}});}finally {segmentLock.unlock(lockId);}}private static String genLogFilePath(long instanceId, boolean stable) {if (stable) {return OmsFileUtils.genLogDirPath() + String.format("%d-stable.log", instanceId);}else {return OmsFileUtils.genLogDirPath() + String.format("%d-temporary.log", instanceId);}}

genStableLogFile它先判断该server是否有存储该任务实例的日志文件(~/powerjob/server/online_log/%d-stable.log)，有则直接返回；否则判断该instanceId2LastReportTime是否包含该任务实例，包含则从localInstanceLogRepository拉取日志然后写入到文件；不包含则通过dFsService.fetchFileMeta拉取元信息，然后下载到本地再返回

相关表结构

LOCAL_INSTANCE_LOG

CREATE TABLE PUBLIC.LOCAL_INSTANCE_LOG (ID BIGINT NOT NULL AUTO_INCREMENT,INSTANCE_ID BIGINT,LOG_CONTENT CHARACTER VARYING,LOG_LEVEL INTEGER,LOG_TIME BIGINT,WORKER_ADDRESS CHARACTER VARYING(255),CONSTRAINT CONSTRAINT_8 PRIMARY KEY (ID)
);
CREATE INDEX IDXPJ6CD8W5EAW8QBKMD84I8KYS7 ON PUBLIC.LOCAL_INSTANCE_LOG (INSTANCE_ID);
CREATE UNIQUE INDEX PRIMARY_KEY_8 ON PUBLIC.LOCAL_INSTANCE_LOG (ID);

powerjob_files

CREATE TABLE `powerjob_files` (`id` bigint NOT NULL AUTO_INCREMENT COMMENT 'ID',`bucket` varchar(255) COLLATE utf8mb4_general_ci NOT NULL COMMENT '分桶',`name` varchar(255) COLLATE utf8mb4_general_ci NOT NULL COMMENT '文件名称',`version` varchar(255) COLLATE utf8mb4_general_ci NOT NULL COMMENT '版本',`meta` varchar(255) COLLATE utf8mb4_general_ci DEFAULT NULL COMMENT '元数据',`length` bigint NOT NULL COMMENT '长度',`status` int NOT NULL COMMENT '状态',`data` longblob NOT NULL COMMENT '文件内容',`extra` varchar(255) COLLATE utf8mb4_general_ci DEFAULT NULL COMMENT '其他信息',`gmt_create` datetime NOT NULL COMMENT '创建时间',`gmt_modified` datetime DEFAULT NULL COMMENT '更新时间',PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=6 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_general_ci;

小结

  • PowerJob的worker端的OmsServerLogger的process方法调用的是OmsLogHandler的submitLog方法，它每次先判断logQueue大小是否大于REPORT_SIZE(1024)，是则启动logSubmitter线程，否则放入logQueue队列LogSubmitter不断地从logQueue.poll数据，在logs的大小大于等于BATCH_SIZE(20)时通过TransportUtils.reportLogs给server上报日志
  • server端的AbWorkerRequestHandler的processWorkerLogReport接收WorkerLogReportReq，执行processWorkerLogReport0方法，它执行的是instanceLogService.submitLogs；InstanceLogService的submitLogs是个异步方法，它将InstanceLogContent转换为LocalInstanceLogDO，然后执行localInstanceLogRepository.saveAll保存；server端有两份数据源，一份是mysql，一份是h2，而localInstanceLog存储到的是h2的LOCAL_INSTANCE_LOG表
  • 另外server端在任务实例结束时会执行InstanceManager的processFinishedInstance方法，它会延时60s执行instanceLogService.sync(instanceId)；sync方法先通过genStableLogFile将日志持久化到server端的本地日志文件，接着将该任务实例日志的元信息(哪个任务实例、在哪个server、本地日志文件的路径)存储到dFsService(它有oss、gridfs、minio、mysql四种实现，具体看server的配置文件是启动哪个，如果是mysql则是存储到powerjob_files表中)，最后通过localInstanceLogRepository.deleteByInstanceId清空该任务实例在h2中的LOCAL_INSTANCE_LOG表的记录

这篇关于聊聊PowerJob日志的上报及存储的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/675794。

相关文章

异构存储（冷热数据分离）

异构存储（冷热数据分离）

异构存储主要解决不同的数据，存储在不同类型的硬盘中，达到最佳性能的问题。 异构存储Shell操作 （1）查看当前有哪些存储策略可以用 [lytfly@hadoop102 hadoop-3.1.4]$ hdfs storagepolicies -listPolicies （2）为指定路径（数据存储目录）设置指定的存储策略 hdfs storagepolicies -setStoragePo
阅读更多...
HDFS—存储优化（纠删码）

HDFS—存储优化（纠删码）

纠删码原理 HDFS 默认情况下，一个文件有3个副本，这样提高了数据的可靠性，但也带来了2倍的冗余开销。 Hadoop3.x 引入了纠删码，采用计算的方式，可以节省约50％左右的存储空间。 此种方式节约了空间，但是会增加 cpu 的计算。 纠删码策略是给具体一个路径设置。所有往此路径下存储的文件，都会执行此策略。 默认只开启对 RS-6-3-1024k
阅读更多...
flume系列之：查看flume系统日志、查看统计flume日志类型、查看flume日志

flume系列之：查看flume系统日志、查看统计flume日志类型、查看flume日志

遍历指定目录下多个文件查找指定内容 服务器系统日志会记录flume相关日志 cat /var/log/messages |grep -i oom 查找系统日志中关于flume的指定日志 import osdef search_string_in_files(directory, search_string):count = 0
阅读更多...
我在移动打工的日志

我在移动打工的日志

客户：给我搞一下录音 我：不会。不在服务范围。 客户：是不想吧 我：笑嘻嘻（气笑） 客户：小姑娘明明会，却欺负老人 我：笑嘻嘻 客户：那我交话费 我：手机号 客户：给我搞录音 我：不会。不懂。没搞过。 客户：那我交话费 我：手机号。这是电信的啊！！我这是中国移动！！ 客户：我不管，我要充话费，充话费是你们的 我：可是这是移动！！中国移动！！ 客户：我这是手机号 我：那又如何，这是移动！你是电信！！
阅读更多...
速了解MySQL 数据库不同存储引擎

速了解MySQL 数据库不同存储引擎

快速了解MySQL 数据库不同存储引擎 MySQL 提供了多种存储引擎，每种存储引擎都有其特定的特性和适用场景。了解这些存储引擎的特性，有助于在设计数据库时做出合理的选择。以下是 MySQL 中几种常用存储引擎的详细介绍。 1. InnoDB 特点： 事务支持：InnoDB 是一个支持 ACID（原子性、一致性、隔离性、持久性）事务的存储引擎。行级锁：使用行级锁来提高并发性，减少锁竞争
阅读更多...
Detectorn2预训练模型复现：数据准备、训练命令、日志分析与输出目录

Detectorn2预训练模型复现：数据准备、训练命令、日志分析与输出目录

Detectorn2预训练模型复现：数据准备、训练命令、日志分析与输出目录 在深度学习项目中，目标检测是一项重要的任务。本文将详细介绍如何使用Detectron2进行目标检测模型的复现训练，涵盖训练数据准备、训练命令、训练日志分析、训练指标以及训练输出目录的各个文件及其作用。特别地，我们将演示在训练过程中出现中断后，如何使用 resume 功能继续训练，并将我们复现的模型与Model Zoo中的
阅读更多...
ORACLE语法-包(package)、存储过程(procedure)、游标(cursor)以及java对Result结果集的处理

ORACLE语法-包(package)、存储过程(procedure)、游标(cursor)以及java对Result结果集的处理

陈科肇 示例： 包规范 CREATE OR REPLACE PACKAGE PACK_WMS_YX IS-- Author : CKZ-- Created : 2015/8/28 9:52:29-- Purpose : 同步数据-- Public type declarations，游标 退休订单TYPE retCursor IS REF CURSOR;-- RETURN vi_co_co
阅读更多...
SSM项目使用AOP技术进行日志记录

SSM项目使用AOP技术进行日志记录

本步骤只记录完成切面所需的必要代码 本人开发中遇到的问题： 切面一直切不进去，最后发现需要在springMVC的核心配置文件中中开启注解驱动才可以，只在spring的核心配置文件中开启是不会在web项目中生效的。 之后按照下面的代码进行配置，然后前端在访问controller层中的路径时即可观察到日志已经被正常记录到数据库，代码中有部分注释，看不懂的可以参照注释。接下来进入正题 1、导入m
阅读更多...
多数据源的事务处理总是打印很多无用的log日志

多数据源的事务处理总是打印很多无用的log日志

之前做了一个项目，需要用到多数据源以及事务处理，在使用事务处理，服务器总是打印很多关于事务处理的log日志（com.atomikos.logging.Slf4jLogger），但是我们根本不会用到这些log日志，反而使得查询一些有用的log日志变得困难。那要如何屏蔽这些log日志呢？ 之前的项目是提高项目打印log日志的级别，后来觉得这样治标不治本。 现在有一个更好的方法： 我使用的是log
阅读更多...
android两种日志获取log4j

android两种日志获取log4j

android   log4j 加载日志使用方法； 先上图： 有两种方式： 1：直接使用架包 加载（两个都要使用）； 架包：android-logging-log4j-1.0.3.jar 、log4j-1.2.15.jar  （说明：也可以使用架包：log4j-1.2.17.jar）  2：对架包输入日志的二次封装使用； 1:直接使用 log4j 日志框架获取日志信息： A:配置 日志 文
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2