學(xué)習(xí)自定義SMTPAppender中的源碼

2019-11-18 13:03:59

字體：大中小

供稿：網(wǎng)友

　　package piv.zheng.log4j.test;
　　
　　import org.apache.log4j.AppenderSkeleton;
　　import org.apache.log4j.Layout;
　　import org.apache.log4j.helpers.LogLog;
　　import org.apache.log4j.spi.LoggingEvent;
　　import org.apache.log4j.spi.ErrorCode;
　　import java.util.PRoperties;
　　import java.util.Date;
　　
　　import javax.mail.session;
　　import javax.mail.Transport;
　　import javax.mail.Message;
　　import javax.mail.MessagingException;
　　import javax.mail.internet.MimeMessage;
　　import javax.mail.Multipart;
　　import javax.mail.internet.MimeMultipart;
　　import javax.mail.internet.MimeBodyPart;
　　import javax.mail.internet.InternetAddress;
　　import javax.mail.internet.AddressException;
　　
　　public class SMTPAppender extends AppenderSkeleton {
　　private String to; //收件人
　　private String from; // 發(fā)件人
　　private String subject; //郵件標(biāo)題
　　private String smtpHost; //郵件服務(wù)器
　　private String auth; //身份驗證標(biāo)識
　　private String username; //用戶
　　private String passWord; //密碼
　　private boolean locationInfo = false;
　　
　　protected Session ses;
　　protected Message msg;
　　protected Properties props;
　　
　　public SMTPAppender() {}
　　
　　public SMTPAppender(Layout layout) {
　　
　　this.layout = layout;
　　
　　}
　　
　　//應(yīng)用設(shè)置
　　public void activateOptions() {
　　props = new Properties(System.getProperties());
　　if (smtpHost != null) {
　　props.put("mail.smtp.host", smtpHost);
　　}
　　if (auth != null) {
　　props.put("mail.smtp.auth", auth);
　　}
　　if (username != null) {
　　props.put("username", username);
　　}
　　if (password != null) {
　　props.put("password", password);
　　}
　　ses = Session.getInstance(props); //創(chuàng)建session
　　
　　msg = new MimeMessage(ses); //創(chuàng)建message
　　
　　try {
　　//為message設(shè)置發(fā)件人
　　if (from != null) {
　　msg.setFrom(getAddress(from));
　　} else {
　　msg.setFrom();
　　}
　　
　　//為message設(shè)置收件人
　　if (to != null) {
　　msg.setRecipients(Message.RecipientType.TO, parseAddress(to));
　　}
　　
　　//為message設(shè)置標(biāo)題
　　if (subject != null) {
　　msg.setSubject(subject);
　　}
　　} catch (MessagingException e) {
　　LogLog.error("Could not activate SMTPAppender options.", e);
　　}
　　}
　　
　　//重寫執(zhí)行方法，當(dāng)執(zhí)行日志輸出時會被調(diào)用
　　public void append(LoggingEvent event) {
　　//檢查message及l(fā)ayout
　　if (!checkEntryConditions()) {
　　return;
　　}
　　
　　event.getThreadName();
　　event.getNDC();
　　if (locationInfo) {
　　event.getLocationInformation();
　　}
　　
　　//發(fā)送郵件
　　sendBuffer(event);
　　}
　　
　　protected boolean checkEntryConditions() {
　　if (this.msg == null) {
　　errorHandler.error("Message object not configured.");
　　return false;
　　}
　　
　　if (this.layout == null) {
　　errorHandler.error("No layout set for appender named [" + name + "].");
　　return false;
　　}
　　return true;
　　}
　　
　　synchronized public void close() {
　　this.closed = true;
　　}
　　
　　InternetAddress getAddress(String addressStr) {
　　try {
　　return new InternetAddress(addressStr);
　　} catch (AddressException e) {
　　errorHandler.error("Could not parse address [" + addressStr + "].", e, ErrorCode.ADDRESS_PARSE_FAILURE);
　　return null;
　　}
　　}
　　
　　InternetAddress[] parseAddress(String addressStr) {
　　try {
　　return InternetAddress.parse(addressStr, true);
　　} catch (AddressException e) {
　　errorHandler.error("Could not parse address [" + addressStr + "].", e, ErrorCode.ADDRESS_PARSE_FAILURE);
　　return null;
　　}
　　}
　　
　　public boolean requiresLayout() {
　　return true;
　　}
　　
　　//發(fā)送郵件
　　protected void sendBuffer(LoggingEvent event) {
　　try {
　　//將日志信息設(shè)置到message中
　　MimeBodyPart part = new MimeBodyPart();
　　
　　StringBuffer sbuf = new StringBuffer();
　　String t = layout.getHeader();
　　if (t != null) {
　　sbuf.append(t);
　　}
　　sbuf.append(layout.format(event));
　　if (layout.ignoresThrowable()) {
　　String[] s = event.getThrowableStrRep();
　　if (s != null) {
　　for (int j = 0; j < s.length; j++) {
　　sbuf.append(s[j]);
　　}
　　}
　　}
　　t = layout.getFooter();
　　if (t != null) {
　　sbuf.append(t);
　　}
　　part.setContent(sbuf.toString(), layout.getContentType());
　　
　　Multipart mp = new MimeMultipart();
　　mp.addBodyPart(part);
　　
　　msg.setContent(mp); //為message設(shè)置內(nèi)容，即日志信息
　　msg.setSentDate(new Date()); //為message設(shè)置發(fā)送時間
　　
　　//發(fā)送郵件
　　Transport tr = ses.getTransport("smtp");
　　tr.connect(smtpHost, username, password);
　　tr.sendMessage(msg, msg.getRecipients(Message.RecipientType.TO));
　　tr.close();
　　} catch (Exception e) {
　　LogLog.error("Error occured while sending e-mail notification.", e);
　　}
　　}
　　
　　public void setTo(String to) {
　　this.to = to;
　　}
　　
　　public String getTo() {
　　return to;
　　}
　　
　　public void setFrom(String from) {
　　this.from = from;
　　}
　　
　　public String getFrom() {
　　return from;
　　}
　　
　　public String getSubject() {
　　return subject;
　　}
　　
　　public void setSubject(String subject) {
　　this.subject = subject;
　　}
　　
　　public void setSMTPHost(String smtpHost) {
　　this.smtpHost = smtpHost;
　　}
　　
　　public String getSMTPHost() {
　　return smtpHost;
　　}
　　
　　public void setAuth(String auth) {
　　this.auth = auth;
　　}
　　
　　public String getAuth() {
　　return auth;
　　}
　　
　　public void setUsername(String username) {
　　this.username = username;
　　}
　　
　　public String getUsername() {
　　return username;
　　}
　　
　　public void setPassword(String password) {
　　this.password = password;
　　}
　　
　　public String getPassword() {
　　return password;
　　}
　　
　　public void setLocationInfo(boolean locationInfo) {
　　this.locationInfo = locationInfo;
　　}
　　
　　public boolean getLocationInfo() {
　　return locationInfo;
　　}
　　}

上一篇：在Wicket里面使用一個自己WebSession

下一篇：MC4J遠(yuǎn)程監(jiān)測Tomcat集群-JMX助Tomcat1(圖)