一、生成scribe客户端 A. 如果之前没设置ANT_HOME 和 PATH 请先设置这两个环境变量 cd /usr/local/scribeInstall/thrift-0.2.0/contrib/fb303/java ant 执行成功后 libfb303.jar 会出现在/usr/local/scribeInstall/contrib/fb303/java/build/lib下 二、创建项目，运行测试
C.在项目中添加gen-java 文件夹里的三个java类。package com.logtest; import org.apache.log4j.AsyncAppender; /** * log4j 的scribe appender * 用ScribeAppender 类连接scribe服务器，并把日志写如scribe * @author ninja */ public class AsyncScribeAppender extends AsyncAppender { private String hostname; private String scribeHost; private int scribePort; private String scribeCategory; private String encoading; public String getHostname() { return hostname; } public void setHostname(String hostname) { this .hostname = hostname; } public String getScribeHost() { return scribeHost; } public void setScribeHost(String scribeHost) { this .scribeHost = scribeHost; } public int getScribePort() { return scribePort; } public void setScribePort( int scribePort) { this .scribePort = scribePort; } public String getScribeCategory() { return scribeCategory; } public void setScribeCategory(String scribeCategory) { this .scribeCategory = scribeCategory; } public String getEncoading() { return encoading; } public void setEncoading(String encoading) { this .encoading = encoading; } @Override public void activateOptions() { super .activateOptions(); synchronized ( this ) { ScribeAppender scribeAppender = new ScribeAppender(); scribeAppender.setLayout(getLayout()); scribeAppender.setHostname(getHostname()); scribeAppender.setScribeHost(getScribeHost()); scribeAppender.setScribePort(getScribePort()); scribeAppender.setScribeCategory(getScribeCategory()); scribeAppender.setEncoding(getEncoading()); scribeAppender.activateOptions(); addAppender(scribeAppender); } } @Override public boolean requiresLayout() { return true ; } } package com.logtest; import net.scribe.LogEntry; import net.scribe.scribe; import org.apache.log4j.WriterAppender; import org.apache.log4j.spi.LoggingEvent; import org.apache.thrift.protocol.TBinaryProtocol; import org.apache.thrift.transport.TFramedTransport; import org.apache.thrift.transport.TSocket; import org.apache.thrift.transport.TTransportException; import java.util.List; import java.util.ArrayList; import java.net.Socket; import java.net.UnknownHostException; import java.net.InetAddress; import java.io.IOException; /** * 继承WriterAppender * 实现了scribe 服务器的链接和日志的发送。 * @author ninja */ public class ScribeAppender extends WriterAppender { private String hostname; private String scribeHost; private int scribePort; private String scribeCategory; private String encoding; private List<LogEntry> logEntries; private scribe.Client client; private TFramedTransport transport; public String getHostname() { return hostname; } public void setHostname(String hostname) { this .hostname = hostname; } public String getScribeHost() { return scribeHost; } public void setScribeHost(String scribeHost) { this .scribeHost = scribeHost; } public int getScribePort() { return scribePort; } public void setScribePort( int scribePort) { this .scribePort = scribePort; } public String getScribeCategory() { return scribeCategory; } public void setScribeCategory(String scribeCategory) { this .scribeCategory = scribeCategory; } public String getEncoding() { return encoding; } public void setEncoding(String encoding) { this .encoding = encoding; } /* * Activates this Appender by opening a transport to the Scribe server. */ @Override public void activateOptions() { try { synchronized ( this ) { if (hostname == null ) { try { hostname = InetAddress.getLocalHost() .getCanonicalHostName(); } catch (UnknownHostException e) { // can't get hostname } } System.out.println(scribeHost + scribePort + scribeCategory + encoding); // Thrift boilerplate code logEntries = new ArrayList<LogEntry>( 1 ); TSocket sock = new TSocket( new Socket(scribeHost, scribePort)); transport = new TFramedTransport(sock); TBinaryProtocol protocol = new TBinaryProtocol(transport, false , false ); client = new scribe.Client(protocol, protocol); // This is commented out because it was throwing Exceptions for // no good reason. // transport.open(); } } catch (TTransportException e) { e.printStackTrace(); } catch (UnknownHostException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } catch (Exception e) { e.printStackTrace(); } } /* * Appends a log message to Scribe */ @Override public void append(LoggingEvent event) { synchronized ( this ) { try { String message = String.format("%s %s" , hostname, layout .format(event)); LogEntry entry = new LogEntry(scribeCategory, message); logEntries.add(entry); client.Log(logEntries); } catch (Exception e) { e.printStackTrace(); } finally { logEntries.clear(); } } } @Override public void close() { if (transport != null ) { transport.close(); } } @Override public boolean requiresLayout() { return true ; } } # 1 \u5b9a\u4e49\u4e86\u4e24\u4e2a\u8f93\u51fa\u7aef log4j.rootLogger = DEBUG,CONSOLE,scribe log4j.addivity.org.apache=true log4j.appender.CONSOLE = org.apache.log4j.ConsoleAppender log4j.appender.CONSOLE.layout = org.apache.log4j.PatternLayout log4j.appender.CONSOLE.layout.ConversionPattern = %-4r [%t] %-5p %c - %m%n log4j.logger.com.vmars= DEBUG, scribe log4j.appender.scribe= com.logtest.AsyncScribeAppender log4j.appender.scribe.encoading=utf-8 log4j.appender.scribe.hostname=scribe log4j.appender.scribe.scribeHost=192.168 . 2.221 log4j.appender.scribe.scribePort=1463 log4j.appender.scribe.hostname=ninja log4j.appender.scribe.scribeCategory=scribe log4j.appender.scribe.layout=org.apache.log4j.PatternLayout log4j.appender.scribe.layout.ConversionPattern=%d{yy/MM/dd HH:mm:ss} %p %c{2 }: %m%n package com.logtest; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; public class LogTest { private static Log log = LogFactory.getLog(LogTest. class ); public static void main(String[] args) { log.error("this is a charactor test " ); log.debug("这是中文测试" ); log.fatal("fatal error 致命错误！！" ); } }
运维网声明
1、欢迎大家加入本站运维交流群:群②:261659950 群⑤:202807635 群⑦870801961 群⑧679858003运维网
QQ群⑧：
窥视卡
雷达卡
发表于 2015-11-28 17:15:59
提升卡
置顶卡
沉默卡
喧嚣卡
变色卡
千斤顶
显身卡