Mercurial Hosting > luan
changeset 1583:1cc6c7fa803d
mail work
author | Franklin Schmidt <fschmidt@gmail.com> |
---|---|
date | Sun, 07 Mar 2021 02:22:09 -0700 |
parents | f28cc30d56cb |
children | d3728e3e5af3 |
files | src/goodjava/mail/Message.java src/goodjava/mail/Smtp.java src/goodjava/util/GoodUtils.java |
diffstat | 3 files changed, 130 insertions(+), 13 deletions(-) [+] |
line wrap: on
line diff
--- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/src/goodjava/mail/Message.java Sun Mar 07 02:22:09 2021 -0700 @@ -0,0 +1,76 @@ +package goodjava.mail; + +import java.util.Map; +import java.util.LinkedHashMap; +import java.util.regex.Pattern; +import java.util.regex.Matcher; +import goodjava.util.GoodUtils; + +import java.net.Socket; + + +public class Message { + public final Map<String,String> headers = new LinkedHashMap<String,String>(); + public final String content; + public final String contentType; + private static Pattern line = Pattern.compile("(?m)^.*$"); + + public Message(String content) { + this(content,"text/plain"); + } + + public Message(String content,String contentType) { + this.content = content; + this.contentType = contentType; + } + + public String toText() { + StringBuilder sb = new StringBuilder(); + for( Map.Entry<String,String> entry : headers.entrySet() ) { + String name = entry.getKey(); + if( name.equalsIgnoreCase("bcc") ) + continue; + String value = entry.getValue(); + sb.append( name ).append( ": " ).append( value ).append( "\r\n" ); + } + sb.append( "Content-Type: " ).append( contentType ).append( "; charset=\"UTF-8\"\r\n" ); + boolean isAscii = content.matches("\\p{ASCII}*"); + if( !isAscii ) + sb.append( "Content-Transfer-Encoding: base64\r\n" ); + sb.append( "\r\n" ); + if( isAscii ) { + Matcher m = line.matcher(content); + while( m.find() ) { + sb.append(m.group()).append("\r\n"); + } + } else { + String s = GoodUtils.base64Encode(content); + int n = s.length() - 76; + int i; + for( i=0; i<n; i+=76 ) { + sb.append(s.substring(i,i+76)).append("\r\n"); + } + sb.append(s.substring(i)).append("\r\n"); + } + return sb.toString(); + } + + public static void main(String[] args) throws Exception { + String text = "" + +"testm 2\n" + +"x\n" +// +"产品\n" + +"rg; ;lrg dsl rgj errlgerrg neskrjg skrg rdsg drskrg sd;gr s;kgr skrg skrg sdg ds fg;ks gegr erg ;sg sd; g;sdr gsklrg sg s;kkrg s;hg ;slrg ;elrg ;reg r;g ;r g;er g;ler g;e g; g;r g rg; srkd fjl kj kklsjrg lsk gskdf;rs gkrj glj grekjs lksjgkjn kjslg rklrg ;rsd; kj drsg akrglk kalrgklrsdnrgkgj;r ;s ns b;n;sn ;njslk r;n\r\n" + ; + Message msg = new Message(text); + msg.headers.put("From","smtp@luan.software"); + msg.headers.put("To","fschmidt@gmail.com"); + msg.headers.put("Subject","test"); + Socket socket = new Socket("smtpcorp.com",2525); + Smtp smtp = new Smtp(socket); + smtp.authenticate("smtp@luan.software","luanhost"); + smtp.send(msg); + smtp.close(); + System.out.println("done msg"); + } +}
--- a/src/goodjava/mail/Smtp.java Sat Mar 06 21:13:34 2021 -0700 +++ b/src/goodjava/mail/Smtp.java Sun Mar 07 02:22:09 2021 -0700 @@ -6,7 +6,8 @@ import java.io.OutputStreamWriter; import java.io.IOException; import java.net.Socket; -import java.util.Base64; +import java.util.Map; +import goodjava.util.GoodUtils; public class Smtp { @@ -29,6 +30,35 @@ throw new SmtpException(ehlo); } + public String authenticate(String username,String password) throws IOException, SmtpException { + String s = "\0" + username + "\0" + password; + s = GoodUtils.base64Encode(s); + write( "AUTH PLAIN " + s + "\r\n" ); + String r = read(); + if( !r.startsWith("235") ) + throw new SmtpException(r); + return r; + } + + public void send(Message msg) throws IOException, SmtpException { + for( Map.Entry<String,String> entry : msg.headers.entrySet() ) { + String name = entry.getKey(); + String value = entry.getValue(); + if( name.equalsIgnoreCase("from") ) { + from(value); + } + if( name.equalsIgnoreCase("to") + || name.equalsIgnoreCase("cc") + || name.equalsIgnoreCase("bcc") + ) { + for( String s : value.split(",") ) { + to(s); + } + } + } + data( msg.toText() ); + } + public void close() throws IOException, SmtpException { write( "QUIT\r\n" ); String s = read(); @@ -37,16 +67,6 @@ socket.close(); } - public String authenticate(String username,String password) throws IOException, SmtpException { - String s = "\0" + username + "\0" + password; - s = Base64.getEncoder().encodeToString(s.getBytes()); - write( "AUTH PLAIN " + s + "\r\n" ); - String r = read(); - if( !r.startsWith("235") ) - throw new SmtpException(r); - return r; - } - public String from(String address) throws IOException, SmtpException { write( "MAIL FROM: " + address + "\r\n" ); String r = read(); @@ -93,11 +113,12 @@ Smtp smtp = new Smtp(socket); smtp.authenticate("smtp@luan.software","luanhost"); smtp.from("smtp@luan.software"); - smtp.to("fschmidt@gmail.com"); + smtp.to(" fschmidt@gmail.com"); String text = "\r\n" - +"test2\r\n" + +"test3\r\n" +".q\r\n" +"x\r\n" + +"rg; ;lrg dsl rgj errlgerrg neskrjg skrg rdsg drskrg sd;gr s;kgr skrg skrg sdg ds fg;ks gegr erg ;sg sd; g;sdr gsklrg sg s;kkrg s;hg ;slrg ;elrg ;reg r;g ;r g;er g;ler g;e g; g;r g rg; srkd fjl kj kklsjrg lsk gskdf;rs gkrj glj grekjs lksjgkjn kjslg rklrg ;rsd; kj drsg akrglk kalrgklrsdnrgkgj;r ;s ns b;n;sn ;njslk r;n\r\n" ; smtp.data(text); smtp.close();
--- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/src/goodjava/util/GoodUtils.java Sun Mar 07 02:22:09 2021 -0700 @@ -0,0 +1,20 @@ +package goodjava.util; + +import java.io.UnsupportedEncodingException; +import java.util.Base64; + + +public final class GoodUtils { + + public static byte[] getBytes(String s,String charsetName) { + try { + return s.getBytes(charsetName); + } catch(UnsupportedEncodingException e) { + throw new RuntimeException(e); + } + } + + public static String base64Encode(String s) { + return Base64.getEncoder().encodeToString(getBytes(s,"UTF-8")); + } +}