perl邮件群发脚本(V0.2从数据库内取邮件地址版)

#!/usr/bin/perl -w
#
######################################################################################################
#requirement:
#rpm -ivh http://dag.wieers.com/rpm/packages/rpmforge-release/rpmforge-release-0.3.6-1.el5.rf.i386.rpm
#yum -y install perl-Authen-SASL perl-MIME-Base64 perl-DBI
#
#脚本功能: 邮件群发脚本
#
#作    者: Luo Hui(farmer.luo at gmail.com)
#最后时间: 2008.12.02
#版    本：Ver 0.2
#
#版本历史：
#0.2(2008.12.02):1)更新由脚本自动到数据库内取邮件地址,不再从文件文件中取.
#                2)邮件内容文件由脚本参数设定，方便使用
#
#0.1(2008.12.01):1)初始版本
#
#######################################################################################################

use strict;
use warnings;
use DBI();
use File::Basename;
use MIME::Base64;
use Net::SMTP;


#发送服务器
my smtp_server = ‘mail.test.com’;
#认证用户名
my username = ‘mailto:service@test.com’;
#认证密码
my password = ‘test’;
#发件人
my from_mail = ‘mailto:service@test.com’;
#查询邮件地址的sql语句
#my strsql = “SELECT email FROM uc_members WHERE username = ‘farmerluo’ LIMIT 0 , 30 “;
my strsql = “SELECT email FROM uc_members“;
#邮件主题
my subject = encode_base64( ‘每日内容精选’, ‘ ‘ );

my argvnum = @ARGV;
die “Usage:n” , basename( 0 ) , “ Mail Body File n” unless ( argvnum >= 1 );

my mailfile = ARGV[0];

if ( ! -e mailfile ) {
    print “mail body file no exists!n”;
    exit(1);
}


#连接数据库的资料可在这改
my dbh = DBI->connect( “DBI:mysql:database=ucenter;host=10.11.0.1”,
                        “root”, “test”,
                        {‘RaiseError’ => 1} );
                       
my sth = dbh->prepare( strsql );
sth->execute();
my email = sth->fetchall_arrayref or die “sth->errstrn”;
sth->finish();

my ( i, @to_mails );

for i ( 0 .. #{email} ) {
    #print email->[i][0];
    push( @to_mails , email->[i][0] );
}

open(FHMF, mailfile) or die “!”;
local(/) = undef;
my mail_body = ;
close( FHMF );
/ = “n”;

mail_body = encode_base64( mail_body, ‘ ‘ );

my smtp = Net::SMTP -> new( Host => smtp_server,
#            Debug => 1,
            Hello => smtp_server,
            ) || die “Can’t connect smtp_server !n”;

smtp -> auth( username, password ) || die “Can’t authenticate: !n”;

i = 0;
foreach my to_mail( @to_mails )
{
    chomp(to_mail);
    smtp -> mail( from_mail );
    smtp -> to( to_mail );
    smtp -> data( );

    # send mail head
    smtp -> datasend( “From: from_mailn” );
    smtp -> datasend( “To: to_mailn” );
    smtp -> datasend( “MIME-Version: 1.0 n” );
    smtp -> datasend( “Content-Type: text/html; charset=gb2312 n” );
    smtp -> datasend( “Content-Transfer-Encoding: base64n” );
    smtp -> datasend( “Subject: =?gb2312?B?subject?=nn”);
   
    # send mail body
    smtp -> datasend( mail_body );
    smtp -> dataend();

    i++;
    print “send mail:i mail to:to_mailn”;
}

smtp -> quit();