rockypeng
TA的个人档案
rockypeng个人页面-阿里云开发者社区
文章
130
问答
0
个人介绍
暂无个人介绍
擅长的技术
- Java
- 高分内容
- 最新动态
- 文章
- 问答
-
发表了文章 2018-07-13
ThreadPoolExecutor详解
Thread & ExecutorService & ThreadPoolExecutor 总览 ExecutorService 类方法 shutdown允许已经提交的任务（尚未开始执行和已经开始执行的）继续执行 shutdownNow尚未开始执行的任务不再执行，同时尝试终止正在执行的任务 无论是shutdown 还是shutdownNow，两个的执行都会阻止新的任务提交 一个ExecutorService一旦termination，表明没有正在执行的任务，没有等待执行的任务，也不会有新的任务可以被提交。 如果一个ExecutorService不再使用，应该调用shutdown方法来回收资源。 submit方法（三个重载方法） 返回的Future对象可以用来取消任务和等待任务执行完成 invokeAny和invokeAll方法 用户批量执行任务， invokeAny：会阻塞当前线程，直到某个任务完成。并返回这个任务相关的Future对象 invokeAll：会阻塞当前线程，直到所有任务完成。 isShutdown和isTerminated分别对应于两个状态：关闭状态，终结状态 两阶段shutdown 先执行shutdown方法 调用awaitTermination方法 再调用shutdownNow方法 void shutdownAndAwaitTermination(ExecutorService pool) { pool.shutdown(); // Disable new tasks from being submitted try { // Wait a while for existing tasks to terminate if (!pool.awaitTermination(60, TimeUnit.SECONDS)) { pool.shutdownNow(); // Cancel currently executing tasks // Wait a while for tasks to respond to being cancelled if (!pool.awaitTermination(60, TimeUnit.SECONDS)) System.err.println("Pool did not terminate"); } } catch (InterruptedException ie) { // (Re-)Cancel if current thread also interrupted pool.shutdownNow(); // Preserve interrupt status Thread.currentThread().interrupt(); } } Thread interrupt方法 如果执行a.interrupt方法后，如果a线程（注意是a线程，不是调用线程）抛出了InterruptedException异常，那么a的中断状态会被清除。如果不是抛出InterruptedException异常，那么a的中断状态都会被设置。 interrupted方法 执行a.interrupted方法会返回a线程的中断状态，同时会清除a线程的中断状态 isInterrupted方法 执行a.interrupted方法会返回a线程的中断状态，不会清除a线程的中断状态 ThreadPoolExecutor core pool size 及 max pool size 一个新的任务提交哪些情况下回创建新的线程： 1. 已创建的的线程数小于corePoolSize（即便有线程是空闲的） 2. 已创建的线程数大于corePoolSize小于maxPoolSize，同时任务队列已经满的情况下，也会创建新的线程 可以动态改变这两个的值：setCorePoolSize 以及 setMaximumPoolSize 如果corePoolSize==maxinumPoolSize，那么则创建了一个固定大小的线程池 keep alive time 如果已创建的线程大于了corePoolSize，并且如果有线程的空闲时间大于了keepAliveTime，那么这些线程会被kill掉直到剩下corePoolSize个线程。 可以动态设置：setKeepAliveTime方法 默认情况下keep-alive策略只会针对已创建线程数大于corePoolSize的情况下 可以通过执行allowCoreThreadTimeOut(boolean)让keep-alive策略应用在已创建线程数小于corePoolSize的情况下。 BlockingQueue 1. 如果已创建线程数小于corePoolSize，那么会创建新的线程来执行当前提交的任务，而不是进入阻塞队列 2. 如果已创建线程数大于等于corePoolSize,会尝试先进入阻塞队列，如果进入失败（其实就是队列已满），则会在maxPoolSize条件下创建新的线程来执行当前提交的任务。如果不满足maxPoolSize条件，那么就会执行 拒绝执行策略（默认的拒绝执行策略见下） 3. 通常有三种入队列策略 1. 直接传递给线程（Direct handoffs） 比如：SychronousQueue 感觉可以理解为这个入队列会总是失败，就相当于没有这个队列一样。这样就能在maxPoolSize条件下尽可能快的创建（或选择空闲的线程）来执行新提交的任务。 如果提交的任务有互相的依赖性，可以考虑使用这种队列。 public static ExecutorService newCachedThreadPool() { return new ThreadPoolExecutor(0, Integer.MAX_VALUE, 60L, TimeUnit.SECONDS, new SynchronousQueue<Runnable>()); } 2. 无界队列（Unbounded Queue） 比如：LinkedBlockingQueue 可以理解为如果有任务需要入队列，那么总会入队成功。 因此按照创建新线程的条件，理论上不会有超过corePoolSize个数的线程。也就是说理论上线程数最多为corePoolSize，因此maxPoolSize的设置也就显得没有意义了。 如果提交的任务互相间没有依赖性，可以考虑使用这种队列 3. 有界队列（Bounded Queue） 比如：ArrayBlockingQueue 如果使用有限个maxPoolSize,那么使用这种队列可以防止资源的耗尽。 使用长队列和小的线程池，可以降低CPU使用率，降低系统资源的消耗，以及降低线程上下文切换的消耗，但是会导致低吞吐量。如果任务频繁的阻塞，系统可能会创建比允许的线程数多的线程。 使用短队列和大的线程池，可以提高CPU使用率，但也有可能导致吞吐量下降。 拒绝执行策略 我自己的叫法，实际上就是 RejectedExceptionHandler 1. ThreadPoolExecutor.AbortPolicy 抛出RejectedExecutionException异常 public void rejectedExecution(Runnable r, ThreadPoolExecutor e) { throw new RejectedExecutionException("Task " + r.toString() + " rejected from " + e.toString()); } 2. ThreadPoolExecutor.CallerRunsPolicy 在调用线程上执行（哪个线程提交的任务就哪个线程执行） public void rejectedExecution(Runnable r, ThreadPoolExecutor e) { if (!e.isShutdown()) { r.run(); } } 3. ThreadPoolExecutor.DiscardPolicy 直接放弃 public void rejectedExecution(Runnable r, ThreadPoolExecutor e) { } 4. ThreadPoolExecutor.DiscardOldestPolicy 放弃当前队列中第一个任务 public void rejectedExecution(Runnable r, ThreadPoolExecutor e) { if (!e.isShutdown()) { e.getQueue().poll(); e.execute(r); } } Finalization 一个在程序中不再被引用的线程池如果同时没有剩余的线程，那么这个线程池会被自动的shutdown. 因此如果你想即便在忘记执行shutdown方法的时候仍能正常关闭线程池，那么建议设置一个有限的keepAliveTime（针对大于线程数大于corePoolSize的那些线程），同时也执行下 allowCoreThreadTimeOut(boolean) . 欢迎关注公众号
-
发表了文章 2018-07-12
线上FullGC频繁的排查
线上FullGC频繁的排查 问题 前段时间发现线上的一个dubbo服务Full GC比较频繁，大约每两天就会执行一次Full GC。 Full GC的原因 我们知道Full GC的触发条件大致情况有以下几种情况： 程序执行了System.gc() //建议jvm执行fullgc，并不一定会执行 执行了jmap -histo:live pid命令 //这个会立即触发fullgc 在执行minor gc的时候进行的一系列检查 执行Minor GC的时候，JVM会检查老年代中最大连续可用空间是否大于了当前新生代所有对象的总大小。 如果大于，则直接执行Minor GC（这个时候执行是没有风险的）。 如果小于了，JVM会检查是否开启了空间分配担保机制，如果没有开启则直接改为执行Full GC。 如果开启了，则JVM会检查老年代中最大连续可用空间是否大于了历次晋升到老年代中的平均大小，如果小于则执行改为执行Full GC。 如果大于则会执行Minor GC，如果Minor GC执行失败则会执行Full GC 使用了大对象 //大对象会直接进入老年代 在程序中长期持有了对象的引用 //对象年龄达到指定阈值也会进入老年代 对于我们的情况，可以初步排除1，2两种情况，最有可能是4和5这两种情况。为了进一步排查原因，我们在线上开启了 -XX:+HeapDumpBeforeFullGC。 注意： JVM在执行dump操作的时候是会发生stop the word事件的，也就是说此时所有的用户线程都会暂停运行。 为了在此期间也能对外正常提供服务，建议采用分布式部署，并采用合适的负载均衡算法 JVM参数的设置： 线上这个dubbo服务是分布式部署，在其中一台机子上开启了 -XX:HeapDumpBeforeFullGC，总体JVM参数如下： -Xmx2g -XX:+HeapDumpBeforeFullGC -XX:HeapDumpPath=. -Xloggc:gc.log -XX:+PrintGC -XX:+PrintGCDetails -XX:+PrintGCDateStamps -XX:+UseGCLogFileRotation -XX:NumberOfGCLogFiles=10 -XX:GCLogFileSize=100m -XX:HeapDumpOnOutOfMemoryError Dump文件分析 dump下来的文件大约1.8g，用jvisualvm查看，发现用char[]类型的数据占用了41%内存，同时另外一个com.alibaba.druid.stat.JdbcSqlStat类型的数据占用了35%的内存，也就是说整个堆中几乎全是这两类数据。如下图： 查看char[]类型数据，发现几乎全是sql语句。 接下来查看char[]的引用情况： 找到了JdbcSqlStat类，在代码中查看这个类的代码，关键代码如下： 构造函数只有这一个 public JdbcSqlStat(String sql){ this.sql = sql; this.id = DruidDriver.createSqlStatId(); } 查看这个函数的调用情况，找到com.alibaba.druid.stat.JdbcDataSourceStat#createSqlStat方法： public JdbcSqlStat createSqlStat(String sql) { lock.writeLock().lock(); try { JdbcSqlStat sqlStat = sqlStatMap.get(sql); if (sqlStat == null) { sqlStat = new JdbcSqlStat(sql); sqlStat.setDbType(this.dbType); sqlStat.setName(this.name); sqlStatMap.put(sql, sqlStat); } return sqlStat; } finally { lock.writeLock().unlock(); } } 这里用了一个map来存放所有的sql语句。 其实到这里也就知道什么原因造成了这个问题，因为我们使用的数据源是阿里巴巴的druid，这个druid提供了一个sql语句监控功能，同时我们也开启了这个功能。只需要在配置文件中把这个功能关掉应该就能消除这个问题，事实也的确如此，关掉这个功能后到目前为止线上没再触发FullGC 其他 如果用mat工具查看，建议把 "Keep unreachable objects" 勾上，否则mat会把堆中不可达的对象去除掉，这样我们的分析也许会变得没有意义。如下图：Window-->References 。另外jvisualvm对ool的支持不是很好，如果需要oql建议使用mat。
-
发表了文章 2018-07-12
云栖社区
我的博客即将入驻“云栖社区”，诚邀技术同仁一同入驻。
-
发表了文章 2016-12-21
AIO实现TimeServer
目标 - 实现返回当前服务器时间的功能 - 采用半双工模式（主要是因为采用telnet为客户端，然后telnet默认情况下是半双工） - 客户端连接后，可以发送 time,stop命令. 只有客户端发送stop命令后，服务段才主动断开链路。 - 不考虑读半包和写半包的情况 代码和注释 废话不多说，尽在代码中。直接拷贝即可运行（jdk7或以上） package com.aio; import java.io.IOException; import java.io.UnsupportedEncodingException; import java.net.InetSocketAddress; import java.nio.ByteBuffer; import java.nio.channels.AsynchronousServerSocketChannel; import java.nio.channels.AsynchronousSocketChannel; import java.nio.channels.CompletionHandler; import java.util.Date; import java.util.concurrent.CountDownLatch; /** * Author : Rocky * Date : 21/12/2016 15:17 * Description : * Test : */ public class TimeServer { public static void main(String[] args) throws InterruptedException { AsynchronousServerSocketChannel assc = null; try { assc = AsynchronousServerSocketChannel.open(); assc.bind(new InetSocketAddress(8888)); } catch (IOException e) { e.printStackTrace(); System.exit(1); } doAccept(assc); CountDownLatch latch = new CountDownLatch(1); latch.await(); } private static void doAccept(AsynchronousServerSocketChannel assc) { assc.accept(assc, new AcceptCompletionHandle()); } private static class AcceptCompletionHandle implements CompletionHandler<AsynchronousSocketChannel, AsynchronousServerSocketChannel> { @Override public void completed(AsynchronousSocketChannel result, AsynchronousServerSocketChannel assc) { //继续监听accept事件 assc.accept(assc, this); //开始监听可读时间 ByteBuffer readBuf = ByteBuffer.allocate(1024); result.read(readBuf, readBuf, new ReadCompletionHandler(result)); } @Override public void failed(Throwable exc, AsynchronousServerSocketChannel assc) { System.out.println("accept异常，继续accept"); assc.accept(assc, this); } } private static class ReadCompletionHandler implements CompletionHandler<Integer, ByteBuffer> { private AsynchronousSocketChannel asc; public ReadCompletionHandler(AsynchronousSocketChannel asc) { this.asc = asc; } @Override public void completed(Integer result, ByteBuffer readedData) { //如果对端链路关闭 if (result < 0) { try { asc.close(); } catch (IOException e) { e.printStackTrace(); } return; } //如果读取到对端发送过来的数据 if (result > 0) { readedData.flip(); byte[] data = new byte[readedData.remaining()]; readedData.get(data); String command = null; try { command = new String(data, "UTF-8"); if ("time\r\n".equalsIgnoreCase(command)) { doWrite(new Date().toString() + "\r\n"); } else if ("stop\r\n".equalsIgnoreCase(command)) { doWriteAndClose("bye.\r\n"); } else if ("\r\n".equalsIgnoreCase(command)) { doWrite("\r\n"); } else { doWrite("unknown command\r\n"); } } catch (UnsupportedEncodingException e) { e.printStackTrace(); doWrite("server error\r\n"); } } //如果未读取到数据 else { //继续尝试读取对端发送的数据 ByteBuffer readBuf = ByteBuffer.allocate(1024); asc.read(readBuf, readBuf, this); } } private void doWriteAndClose(String response) { ByteBuffer repBuf = null; try { repBuf = ByteBuffer.wrap(response.getBytes("UTF-8")); } catch (UnsupportedEncodingException e) { e.printStackTrace(); } if (repBuf != null) { asc.write(repBuf, repBuf, new CompletionHandler<Integer, ByteBuffer>() { @Override public void completed(Integer result, ByteBuffer repBuf) { if (repBuf.hasRemaining()) { asc.write(repBuf, repBuf, this); } //写完成后，关闭链路 else { try { asc.close(); } catch (IOException e) { e.printStackTrace(); } } } @Override public void failed(Throwable exc, ByteBuffer repBuf) { exc.printStackTrace(); try { asc.close(); } catch (IOException e) { e.printStackTrace(); } } }); } } private void doWrite(String response) { ByteBuffer repBuf = null; try { repBuf = ByteBuffer.wrap(response.getBytes("UTF-8")); } catch (UnsupportedEncodingException e) { e.printStackTrace(); } if (repBuf != null) { asc.write(repBuf, repBuf, new WriteCompletionHandler(asc, this)); } } @Override public void failed(Throwable exc, ByteBuffer readedData) { exc.printStackTrace(); try { asc.close(); } catch (IOException e) { e.printStackTrace(); } } } private static class WriteCompletionHandler implements CompletionHandler<Integer, ByteBuffer> { private AsynchronousSocketChannel asc; private ReadCompletionHandler rch; public WriteCompletionHandler(AsynchronousSocketChannel asc, ReadCompletionHandler rch) { this.asc = asc; this.rch = rch; } @Override public void completed(Integer result, ByteBuffer repBuf) { if (repBuf.hasRemaining()) { asc.write(repBuf, repBuf, this); } //写完成后(对端读取完成)，再尝试读（半双工模式） else { //继续尝试读取对端发送的数据 ByteBuffer readBuf = ByteBuffer.allocate(1024); asc.read(readBuf, readBuf, rch); } } @Override public void failed(Throwable exc, ByteBuffer repBuf) { exc.printStackTrace(); try { asc.close(); } catch (IOException e) { e.printStackTrace(); } } } } 测试 telnet 127.0.0.1 8888 Trying 127.0.0.1... Connected to localhost. Escape character is '^]'. time Wed Dec 21 17:05:44 CST 2016 time Wed Dec 21 17:07:44 CST 2016 s unknown command f unknown command stop bye. Connection closed by foreign host.
-
发表了文章 2016-09-19
Linux系统日志管理
Linux系统日志管理 日志分类: 1. 连接时间的日志 连接时间日志一般由/var/log/wtmp和/var/run/utmp这两个文件记录，不过这 两个文件无法直接cat查看，并且该文件由系统自动更新，可以通过如下： w/who/finger/id/last/lastlog/ac 进行查看 [root@xhot ~]# who root tty1 2010-10-06 22:56 root pts/0 2010-10-06 22:26 (218.192.87.4) root pts/1 2010-10-06 23:41 (218.192.87.4) root pts/3 2010-10-06 23:18 (218.192.87.4) [root@xhot ~]# w 01:01:02 up 2:36, 4 users, load average: 0.15, 0.03, 0.01 USER TTY FROM LOGIN@ IDLE JCPU PCPU WHAT root tty1 - 22:56 1:20m 0.16s 0.16s -bash root pts/0 218.192.87.4 22:26 2:05m 0.18s 0.18s -bash root pts/1 218.192.87.4 23:41 0.00s 0.41s 0.00s w root pts/3 218.192.87.4 23:18 1:38m 0.03s 0.03s -bash [root@xhot ~]# ac -p //查看每个用户的连接时间 u51 1.23 u55 0.04 root 95.21 //可以看到root连接时间最长吧 xhot 0.06 user1 3.93 total 100.48 [root@xhot ~]# ac -a //查看所有用户的连接时间 total 100.49 [root@xhot ~]# ac -d //查看用户每天的连接时间 Sep 24 total 0.14 Sep 25 total 14.60 Sep 26 total 13.71 Sep 27 total 21.47 Sep 28 total 11.74 Sep 29 total 6.60 Sep 30 total 8.81 Oct 1 total 9.04 Oct 2 total 0.47 //可以看到我国庆3、4、5号出去玩了 Oct 6 total 8.62 Today total 5.29 其他几个命令不做具体介绍了 2. 进程监控日志 进程统计监控日志在监控用户的操作指令是非常有效的。当服务器最近发现经常 无故关机或者无故被人删除文件等现象时，可以通过使用进程统计日志查看： [root@xhot ~]# accton /var/account/pacct //开启进程统计日志监控 [root@xhot ~]# lastcomm //查看进程统计日志情况 accton S root pts/1 0.00 secs Thu Oct 7 01:20 accton root pts/1 0.00 secs Thu Oct 7 01:20 ac root pts/1 0.00 secs Thu Oct 7 01:14 ac root pts/1 0.00 secs Thu Oct 7 01:14 free root pts/1 0.00 secs Thu Oct 7 01:10 lastcomm root pts/1 0.00 secs Thu Oct 7 01:09 bash F root pts/1 0.00 secs Thu Oct 7 01:09 lastcomm root pts/1 0.00 secs Thu Oct 7 01:09 ifconfig root pts/1 0.00 secs Thu Oct 7 01:09 lastcomm root pts/1 0.00 secs Thu Oct 7 01:09 lastcomm root pts/1 0.00 secs Thu Oct 7 01:09 lastcomm root pts/1 0.00 secs Thu Oct 7 01:09 accton S root pts/1 0.00 secs Thu Oct 7 01:09 [root@xhot ~]# accton //关闭进程统计日志监控 3. 系统和服务日志 系统日志服务是由一个名为syslog的服务管理的，如一下日志文件都是由syslog日志服务驱动的： /var/log/lastlog ：记录最后一次用户成功登陆的时间、登陆IP等信息 /var/log/messages ：记录Linux操作系统常见的系统和服务错误信息 /var/log/secure ：Linux系统安全日志，记录用户和工作组变坏情况、用户登陆认证情况 /var/log/btmp ：记录Linux登陆失败的用户、时间以及远程IP地址 /var/log/cron ：记录crond计划任务服务执行情况 …... [root@xhot ~]# cat /var/log/lastlog Lpts/0218.192.87.4 Lpts/1218.192.87.4 Lpts/1218.192.87.4 Lpts/0218.192.87.46 Lpts/0218.192.87.4 …... Linux日志服务介绍 １. 在Linux系统，大部分日志都是由syslog日志服务驱动和管理的 syslog服务由两个重要的配置文件控制管理，分别是/etc/syslog.conf主配置文件和/etc/sysconfig/syslog辅助 配置文件， /etc/init.d/syslog是启动脚本，这里主讲主配置文件/etc/syslog.conf： /etc/syslog.conf 语句结构： [root@xhot ~]# grep -v "#" /etc/syslog.conf //列出非#打头的每一行 *.info;mail.none;authpriv.none;cron.none /var/log/messages authpriv.* /var/log/secure mail.* -/var/log/maillog cron.* /var/log/cron *.emerg * uucp,news.crit /var/log/spooler local7.* /var/log/boot.log 选择域(消息类型.错误级别) 动作域 ２. 消息类型：auth,authpriv,security;cron,daemon,kern,lpr,mail, mark,news,syslog,user,uucp,local0~local7. 错误级别：(8级)debug,info,notice,warning|warn;err|error;crit,alert,emerg|panic 动作域：file,user,console,@remote_ip 举如上的/etc/syslog.conf文件三个例子： *.info;mail.none;authpriv.none;cron.none /var/log/messages 表示info级别的任何消息都发送到/var/log/messages日志文件，但邮件系统、验证系统 和计划任务的错误级别信息就除外，不发送（none表示禁止） cron.* /var/log/cron 表示所有级别的cron信息发到/var/log/cron文件 *.emerg * 表示emerg错误级别（危险状态）的所有消息类型发给所有用户 Linux日志服务器配置 此服务器的配置非常简单，只是修改一个文件的一个地方，然后重启服务即可： [root@xhot ~]# grep -v "#" /etc/sysconfig/syslog SYSLOGD_OPTIONS="-m 0 -r" //只要在这里添加“-r”就行咯 KLOGD_OPTIONS="-x" SYSLOG_UMASK=077 [root@xhot ~]# service syslog restart 关闭内核日志记录器： [确定] 关闭系统日志记录器： [确定] 启动系统日志记录器： [确定] 启动内核日志记录器： [确定] 对于发送消息到服务器的OS，只要在写/etc/syslog.conf主配置文件的时候，作用域 为@server-ip就行了，比如针对218.192.87.24这台日志服务器，把一台ubuntu系统的所有 info级别的auth信息发给日志服务器，那么对于ubuntu系统的/etc/syslog.conf文件最后一 行添加 auth.info @218.192.87.24 就OK了 日志转储服务 系统工作到了一定时间后，日志文件的内容随着时间和访问量的增加而越来越多， 日志文件也越来越大。而且当日志文件超过系统控制范围时候，还会对系统性能 造成影响。转储方式可以设为每年转储、每月转储、每周转储、达到一定大小转储。 在Linux系统，经常使用“logrotate”工具进行日志转储，结合cron计划任务，可以轻松 实现日志文件的转储。转储方式的设置由“/etc/logrotate.conf”配置文件控制： [root@xhot ~]# cat /etc/logrotate.conf # see "man logrotate" for details //可以查看帮助文档 # rotate log files weekly weekly //设置每周转储 # keep 4 weeks worth of backlogs rotate 4 //最多转储4次 # create new (empty) log files after rotating old ones create //当转储后文件不存储时创建它 # uncomment this if you want your log files compressed #compress //以压缩方式转储 # RPM packages drop log rotation information into this directory include /etc/logrotate.d //其他日志文件的转储方式，包含在该目录下 # no packages own wtmp -- we'll rotate them here /var/log/wtmp { //设置/var/log/wtmp日志文件的转储参数 monthly //每月转储 create 0664 root utmp //转储后文件不存在时创建它，文件所有者为root， 所属组为utmp，对应的权限为0664 rotate 1 //转储一次 } # system-specific logs may be also be configured here. 举两个例子： 为/var/log/news/目录下的所有文件设置转储参数，每周转储，转储2次，转储 时将老的日志文件放到/var/log/news/old目录下，若日志文件不存在，则跳过。完成后重启 news新闻组服务，转储时不压缩。那么可以在/etc/logrotate.conf文件的最后添加如下： /var/log/news/*{ monthly rotate 2 olddir /var/log/news/old missingok postrotate kill -HUP `cat /var/run/inn.pid` endscript nocompress } 另一个例子：为/var/log/httpd/access.log和/var/log/httpd/error.log日志设置转储参数。转储 5次，转储时发送邮件给root@localhost用户，当日志文件达到100KB时才转储，转储后重启 httpd服务，那么可以直接在/etc/logrotate.conf文件的最后添加如下： /var/log/httpd/access.log /var/log/http/error.log{ rotate 5 mail root@localhost size=100k sharedscripts /sbin/killall -HUP httpd endscript } 自定义日志转储（/etc/logrotate.d/*） 通过下面一个例子将所有类型错误级别为info的日志转储到/var/log/test.log日志文件中，并设置 /var/log/test.log达到50KB后进行转储，转储10次，转储时压缩，转储后重启syslog服务： 1、修改/etc/syslog.conf文件使得如下： [root@xhot ~]# tail -1 /etc/syslog.conf //查看该文件的最后一行 *.info /var/log/test.log 2、重启syslog服务： [root@xhot ~]# /sbin/service syslog restart 关闭内核日志记录器： [确定] 关闭系统日志记录器： [确定] 启动系统日志记录器： [确定] 启动内核日志记录器： [确定] 3、创建/etc/logrotate.d/test.log日志转储参数配置文件，添加如下： [root@xhot ~]# vim /etc/logrotate.d/test.log [root@xhot ~]# cat /etc/logrotate.d/test.log /var/log/test.log{ rotate 10 size = 50k compress postrotate killall -HUP syslog endscript } 4、查看文件/etc/cron.daily/logrotate确保如下： [root@xhot ~]# cat /etc/cron.daily/logrotate #!/bin/sh /usr/sbin/logrotate /etc/logrotate.conf EXITVALUE=$? if [ $EXITVALUE != 0 ]; then /usr/bin/logger -t logrotate "ALERT exited abnormally with [$EXITVALUE]" fi exit 0 5、查看转储后的文件 [root@xhot log]# pwd /var/log [root@xhot log]# ls test.log* …… //结果等要转储的时候会发现压缩文件和原本的test.log文件 原文链接：http://www.cnblogs.com/php5/archive/2010/11/10/1873206.html
滑动查看更多
暂无更多信息
-
发表了文章
2013-10-07
查找算法总结
-
发表了文章
2013-10-09
远程桌面使用方法
-
发表了文章
2013-10-09
PDB文件：每个开发人员都必须知道的
-
发表了文章
2013-10-09
C# 使用MarshalByRefObject跨程序调用方法
-
发表了文章
2013-10-09
C#之MemberwiseClone与Clone
-
发表了文章
2013-10-09
浅拷贝和深拷贝
-
发表了文章
2013-10-09
Installation Guide for SQL Server 2008 R2
-
发表了文章
2013-10-09
VS 2010 SP1 Installation frozed at KB-983509
-
发表了文章
2013-10-09
访问者模式
-
发表了文章
2013-10-09
MAT Memory Analyzer Tool 插件装配(图解)
-
发表了文章
2013-10-09
MySQL事务隔离级别详解
-
发表了文章
2013-10-09
Spring事务配置的五种方式
-
发表了文章
2013-10-09
hibernate 延迟加载
-
发表了文章
2013-10-09
Quartz中扩展MethodInvokingJobDetailFactoryBean实现对任务调度的拦截
-
发表了文章
2013-10-09
软件需求分析步骤方法
-
发表了文章
2013-10-09
用例之间的关系
-
发表了文章
2013-10-09
基于角色管理的系统访问控制
-
发表了文章
2013-10-09
JSP中include指令和include动作区别详解
-
发表了文章
2013-10-09
交通灯也许该升升级
-
发表了文章
2013-10-09
对新兴技术的一点想法
滑动查看更多
暂无更多信息