JAVA网页设计怎样给 Log4j 配上数据库毗连池

主要缺点就是:速度比较慢,没有C和C++快数据|数据库|数据库毗连　　我们都晓得log4j是一个优异的开源日记纪录项目，我们不但能够对输入的日记的格局自界说，还能够本人界说日记输入的目标地，好比：屏幕，文本文件，数据库，乃至能经由过程socket输入。
　　
　　如今让我们对日记输入到数据库来举行设置
　　
　　设置以下：
　　
　　#---JDBC---输入到数据库
　　#JDBCAppenderlog4j.propertiesfile
　　#log4j.rootCategory=WARN,JDBC
　　#APPENDERJDBC
　　log4j.appender.JDBC=org.apache.log4j.jdbc.JDBCAppender
　　log4j.appender.JDBC.driver=com.mysql.jdbc.Driver
　　log4j.appender.JDBC.URL=jdbc:mysql://localhost:3306/test
　　log4j.appender.JDBC.user=use
　　log4j.appender.JDBC.password=password
　　log4j.appender.JDBC.layout=org.apache.log4j.PatternLayout
　　log4j.appender.JDBC.sql=INSERTINTOLOGGING(log_date,log_level,location,message)VALUES(%d{ISO8601},%-5p,%C,%L,%m)
　　
　　表布局以下：
　　
　　log_date　varchar2(50)
　　log_level　varchar2(5)
　　location　varchar2(100)
　　message　　varchar2(1000)
　　
　　笔者照做，但没有运转乐成，并且此种办法是使用传统的数据库毗连办法，关于数据库的办理和效力严峻不敷，在如今这个毗连池横行的时期,为何我们不克不及给给Log4j配上毗连池，让Log4j使用数据毗连池的毗连和数据库举行通信。现检察Log4j的Api,发明JDBCAppender这个类有以下几段话：WARNING:ThisversionofJDBCAppenderisverylikelytobecompletelyreplacedinthefuture.Moreoever,itdoesnotlogexceptions.TheJDBCAppenderprovidesforsendinglogeventstoadatabase.
　　
　　Foruseasabaseclass:
　　
　　OverridegetConnection()topassanyconnectionyouwant.Typicallythisisusedtoenableapplicationwideconnectionpooling.
　　OverridecloseConnection(Connectioncon)--ifyouoverridegetConnectionmakesuretoimplementcloseConnectiontohandletheconnectionyougenerated.Typicallythiswouldreturntheconnectiontothepoolitcamefrom.
　　OverridegetLogStatement(LoggingEventevent)toproducespecializedordynamicstatements.Thedefaultusesthesqloptionvalue.
　　
　　本来log4j倡议我们把其供应的JDBCAppender作为基类来利用，然后Override三个父类的办法：getConnection(),closeConnection(Connectioncon)和getLogStatement(LoggingEventevent)。
　　
　　本来云云，那就写一个子类JDBCPoolAppender来替换这个JDBCAppender
　　
　　JDBCPoolAppender代码和其相干代码以下：
　　
　　JDBCPoolAppender.java:
　　
　　packagecommon.log;
　　importjava.sql.Connection;
　　importorg.apache.log4j.spi.LoggingEvent;
　　importjava.sql.SQLException;
　　importjava.sql.Statement;
　　importjava.util.Iterator;
　　importorg.apache.log4j.spi.ErrorCode;
　　importorg.apache.log4j.PatternLayout;
　　importcommon.sql.MyDB;
　　importcommon.sql.GeneralDb;
　　
　　publicclassJDBCPoolAppenderextendsorg.apache.log4j.jdbc.JDBCAppender{
　　
　　privateMyDBmydb=null;
　　protectedStringsqlname="";//增添一个数据库jndiName的属性
　　
　　protectedConnectionconnection=null;
　　protectedStringsqlStatement="";
　　/**
　　*sizeofLoggingEventbufferbeforewrittingtothedatabase.
　　*Defaultis1.
　　*/
　　protectedintbufferSize=1;
　　
　　publicJDBCPoolAppender(){
　　super();
　　}
　　
　　/**
　　*ArrayListholdingthebufferofLoggingEvents.
　　*/
　　publicvoidappend(LoggingEventevent){
　　buffer.add(event);
　　if(buffer.size()>=bufferSize)
　　flushBuffer();
　　}
　　
　　/**
　　*BydefaultgetLogStatementsendstheeventtotherequiredLayoutobject.
　　*ThelayoutwillformatthegivenpatternintoaworkableSQLstring.
　　*
　　*OverridingthisprovidesdirectaccesstotheLoggingEvent
　　*whenconstructingtheloggingstatement.
　　*
　　*/
　　protectedStringgetLogStatement(LoggingEventevent){
　　returngetLayout().format(event);
　　}
　　
　　/**
　　*
　　*Overridethistoprovideanalertnatemethodofgetting
　　*connections(suchascaching).　Onemethodtofixthisistoopen
　　*connectionsatthestartofflushBuffer()andclosethematthe
　　*end.　IuseaconnectionpooloutsideofJDBCAppenderwhichis
　　*accessedinanoverrideofthismethod.
　　**/
　　protectedvoidexecute(Stringsql)throwsSQLException{
　　Connectioncon=null;
　　Statementstmt=null;
　　try{
　　con=getConnection();
　　stmt=con.createStatement();
　　stmt.executeUpdate(sql);
　　}catch(SQLExceptione){
　　if(stmt!=null)
　　stmt.close();
　　throwe;
　　}
　　stmt.close();
　　closeConnection(con);
　　//System.out.println("Execute:"+sql);
　　}
　　
　　/**
　　*Overridethistoreturntheconnectiontoapool,ortocleanupthe
　　*resource.
　　*
　　*Thedefaultbehaviorholdsasingleconnectionopenuntiltheappender
　　*isclosed(typicallywhengarbagecollected).
　　*/
　　protectedvoidcloseConnection(Connectioncon){
　　mydb=null;
　　try{
　　if(connection!=null&&!connection.isClosed())
　　connection.close();
　　}catch(SQLExceptione){
　　errorHandler.error("Errorclosingconnection",e,
　　ErrorCode.GENERIC_FAILURE);
　　}
　　
　　}
　　
　　/**
　　*Override此函数来使用毗连池前往一个Connetion对象
　　*
　　*/
　　protectedConnectiongetConnection()throwsSQLException{
　　try{
　　mydb=GeneralDb.getInstance(sqlname);
　　connection=mydb.getConnection();
　　}catch(Exceptione){
　　errorHandler.error("Erroropeningconnection",e,ErrorCode.GENERIC_FAILURE);
　　}
　　returnconnection;
　　}
　　
　　/**
　　*Closestheappender,flushingthebufferfirstthenclosingthedefault
　　*connectionifitisopen.
　　*/
　　publicvoidclose(){
　　flushBuffer();
　　
　　try{
　　if(connection!=null&&!connection.isClosed())
　　connection.close();
　　}catch(SQLExceptione){
　　errorHandler.error("Errorclosingconnection",e,
　　ErrorCode.GENERIC_FAILURE);
　　}
　　this.closed=true;
　　}
　　
　　/**
　　*loopsthroughthebufferofLoggingEvents,getsa
　　*sqlstringfromgetLogStatement()andsendsittoexecute().
　　*ErrorsaresenttotheerrorHandler.
　　*
　　*IfastatementfailstheLoggingEventstaysinthebuffer!
　　*/
　　publicvoidflushBuffer(){
　　//Dotheactuallogging
　　removes.ensureCapacity(buffer.size());
　　for(Iteratori=buffer.iterator();i.hasNext();){
　　try{
　　LoggingEventlogEvent=(LoggingEvent)i.next();
　　Stringsql=getLogStatement(logEvent);
　　execute(sql);
　　removes.add(logEvent);
　　}catch(SQLExceptione){
　　errorHandler.error("Failedtoexcutesql",e,
　　ErrorCode.FLUSH_FAILURE);
　　}
　　}
　　
　　//removefromthebufferanyeventsthatwerereported
　　buffer.removeAll(removes);
　　
　　//clearthebufferofreportedevents
　　removes.clear();
　　}
　　
　　/**closestheappenderbeforedisposal*/
　　publicvoidfinalize(){
　　close();
　　}
　　
　　/**
　　*JDBCAppenderrequiresalayout.
　　**/
　　publicbooleanrequiresLayout(){
　　returntrue;
　　}
　　
　　/**
　　*
　　*/
　　publicvoidsetSql(Strings){
　　sqlStatement=s;
　　if(getLayout()==null){
　　this.setLayout(newPatternLayout(s));
　　}else{
　　((PatternLayout)getLayout()).setConversionPattern(s);
　　}
　　}
　　
　　/**
　　*Returnspre-formatedstatementeg:insertintoLogTable(msg)values("%m")
　　*/
　　publicStringgetSql(){
　　returnsqlStatement;
　　}
　　
　　publicvoidsetSqlname(Stringsqlname){
　　sqlname=sqlname;
　　}
　　
　　publicStringgetSqlname(){
　　returnsqlname;
　　}
　　
　　publicvoidsetBufferSize(intnewBufferSize){
　　bufferSize=newBufferSize;
　　buffer.ensureCapacity(bufferSize);
　　removes.ensureCapacity(bufferSize);
　　}
　　
　　publicintgetBufferSize(){
　　returnbufferSize;
　　}
　　}
　　
　　MyDB.java:
　　packagecommon.sql;
　　importjava.sql.*;
　　importcom.codestudio.sql.*;　//引进开源项目Poolman数据库毗连池的包
　　
　　publicclassMyDB{
　　publicstaticfinalStringmodule=MyDB.class.getName();
　　privateStringdbName="";
　　privatePoolManplmn=null;
　　
　　publicMyDB(StringdbName){
　　try{
　　if(plmn==null){
　　plmn=(PoolMan)Class.forName("com.codestudio.sql.PoolMan").
　　newInstance();
　　}
　　}catch(Exceptionec){
　　System.out.println(ec.toString()+module);
　　}
　　this.dbName=dbName;
　　}
　　
　　privateConnectiongetNewConnection(){
　　Connectionconn=null;
　　try{
　　conn=plmn.connect("jdbc:poolman://"+dbName);
　　conn.setAutoCommit(true);
　　}catch(Exceptionec){
　　System.out.println(ec.toString()+"First:Connectsqlseverfailed"+module);
　　try{
　　Thread.sleep(1000);
　　conn=plmn.connect("jdbc:poolman://"+dbName);
　　conn.setAutoCommit(true);
　　}catch(Exceptionecs){
　　System.out.println(ecs.toString()+"Again:Connectsqlseverfaile"+module);
　　}
　　}
　　returnconn;
　　}
　　
　　publicConnectiongetConnection(){
　　returngetNewConnection();
　　}
　　}
　　GeneralDb.java:
　　
　　packagecommon.sql;
　　
　　packagecommon.sql;
　　importjava.util.*;
　　
　　publicclassGeneralDb{
　　privatestaticHashtabledbPool;
　　publicstaticMyDBgetInstance(Stringdbname){
　　if(dbPool==null){
　　dbPool=newHashtable();
　　}
　　MyDBdb=(MyDB)dbPool.get(dbname);
　　if(db==null){
　　db=newMyDB(dbname);
　　dbPool.put(dbname,db);
　　}
　　returndb;
　　}
　　}
　　
　　Log4j数据库毗连池的设置以下：
　　log4j.appender.JDBC=common.log.JDBCPoolAppender
　　log4j.appender.JDBC.sqlname=log
　　log4j.appender.JDBC.layout=org.apache.log4j.PatternLayout
　　log4j.appender.JDBC.sql=INSERTINTOLOGGING(log_date,log_level,location,message)VALUES(%d{ISO8601},%-5p,%C,%L,%m)
　　
　　poolman.xml设置以下：
　　
　　〈?xmlversion="1.0"encoding="UTF-8"?>
　　〈poolman>
　　〈management-mode>local〈/management-mode>
　　〈datasource>
　　〈dbname>log〈/dbname>
　　〈jndiName>log〈/jndiName>
　　〈driver>com.mysql.jdbc.Driver〈/driver>
　　〈url>jdbc:mysql://localhost:3306/test〈/url>
　　〈username>use〈/username>
　　〈password>password〈/password>
　　〈minimumSize>0〈/minimumSize>
　　〈maximumSize>10〈/maximumSize>
　　〈logFile>logs/mysql.log〈/logFile>
　　〈/datasource>
　　
　　〈/poolman>
　　
　　运转乐成！关于JDBCPoolAppender的属性（好比sqlname属性）我们能够使用Log4j的反射机制任意增加，只需在设置文件给其附上值便可使用，而本来的父类内里的一些属性（username甚么的)和其get,set办法因为在毗连池中不必要，以是删除。而在JDBCPoolAppender类中，我也只是将getConnection办法Override，在这个办法中我们能够依据必要天生我们的Connection对象，别的两个办法人人能够依据需求来决意如何Override。：）
还得说上一点，就java本质而言，是面相对象的，但是你有没有发现，java也不全是，比如说基本类型，int，那他就是整型而不是对象，转换类型是还得借助包装类。

你现在最缺的是实际的工作经验，而不是书本上那些凭空想出来的程序。

J2SE开发桌面应用软件比起 VC,VB,DEPHI这些传统开发语言来说，优势好象并不明显。J2ME对于初学者来说，好象又有点深奥，而且一般开发者很难有开发环境。

设计模式是高级程序员真正掌握面向对象核心思想的必修课。设计模式并不是一种具体"技术",它讲述的是思想，它不仅仅展示了接口或抽象类在实际案例中的灵活应用和智慧

还好，SUN提供了Javabean可以把你的JSP中的 Java代码封装起来，便于调用也便于重用。

是一种由美国SUN计算机公司(Sun Microsystems, Inc.)所研究而成的语言

其实说这种话的人就如当年小日本号称“三个月拿下中国”一样大言不惭。不是Tomjava泼你冷水，你现在只是学到了Java的骨架，却还没有学到Java的精髓。接下来你得研究设计模式了。

J2SE开发桌面应用软件比起 VC,VB,DEPHI这些传统开发语言来说，优势好象并不明显。J2ME对于初学者来说，好象又有点深奥，而且一般开发者很难有开发环境。

科学超级计算机、移动电话和互联网，同时拥有全球最大的开发者专业社群。