| |
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; // 发件人
private string subject; //邮件标题
private string smtphost; //邮件服务器
private string auth; //身份验证标识
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;
}
//应用设置
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); //创建session
msg = new mimemessage(ses); //创建message
try {
//为message设置发件人
if (from != null) {
msg.setfrom(getaddress(from));
} else {
msg.setfrom();
}
//为message设置收件人
if (to != null) {
msg.setrecipients(message.recipienttype.to, parseaddress(to));
}
//为message设置标题
if (subject != null) {
msg.setsubject(subject);
}
} catch (messagingexception e) {
loglog.error("could not activate smtpappender options.", e);
}
}
//重写执行方法，当执行日志输出时会被调用
public void append(loggingevent event) {
//检查message及layout
if (!checkentryconditions()) {
return;
}
event.getthreadname();
event.getndc();
if (locationinfo) {
event.getlocationinformation();
}
//发送邮件
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;
}
//发送邮件
protected void sendbuffer(loggingevent event) {
try {
//将日志信息设置到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设置内容，即日志信息
msg.setsentdate(new date()); //为message设置发送时间
//发送邮件
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;
}
}
|
|
