1 CREATE TABLE tb_user(
2   uid CHAR(32) PRIMARY KEY,/*主键*/
3   email VARCHAR(50) NOT NULL,/*邮箱*/
4   `code` CHAR(64) NOT NULL,/*激活码*/
5   state BOOLEAN/*用户状态，有两种是否激活*/
6 );

  1 package cn.kmust.mail.web.servlet;
  2
  3
  4 import java.io.IOException;
  5 import java.text.MessageFormat;
  6 import java.util.Properties;
  7
  8
  9 import javax.mail.MessagingException;
 10 import javax.mail.Session;
 11 import javax.servlet.ServletException;
 12 import javax.servlet.http.HttpServletRequest;
 13 import javax.servlet.http.HttpServletResponse;
 14
 15 import cn.itcast.commons.CommonUtils;
 16 import cn.itcast.mail.Mail;
 17 import cn.itcast.mail.MailUtils;
 18 import cn.itcast.servlet.BaseServlet;
 19 import cn.kmust.mail.domin.User;
 20 import cn.kmust.mail.exception.UserException;
 21 import cn.kmust.mail.service.UserService;
 22
 23 public class UserServlet extends BaseServlet {
 24     private UserService userService = new UserService();
 25     /**
 26      * 注册
 27      *    邮件发送到指定邮箱
 28      * @param request
 29      * @param response
 30      * @return
 31      * @throws ServletException
 32      * @throws IOException
 33      */
 34     public  String regist(HttpServletRequest request, HttpServletResponse response)
 35             throws ServletException, IOException {
 36
 37         User form = CommonUtils.toBean(request.getParameterMap(), User.class);
 38         /*
 39          * 补齐code
 40          */
 41         form.setCode(CommonUtils.uuid()+CommonUtils.uuid());
 42         /*
 43          * 调用service的注册功能
 44          */
 45             userService.regist(form);
 46         /*
 47          * 发送邮件，（包含"缺少收不到重发"功能）
 48          *    准备配置文件email_template.properties
 49          *    发送的邮件方信息放在配置文件中
 50          *       发送内容为一个超链接，超链接到该类的active方法
 51          *          <a href ="http://localhost:8080/项目名字/UserServlet?method=active&code={0}">点击这里完成激活    </a>
 52          *    获取配置文件的内容
 53          *    加载配置文件到props中
 54          *    获取主机、发送用户、授权密码、发送邮件、发件人、发件主题、发送内容
 55          *    得到Session
 56          *    创建邮件对象
 57          *    发邮件
 58          */
 59             Properties props = new Properties();
 60             props.load(this.getClass().getClassLoader().
 61                     getResourceAsStream("email_template.properties"));
 62             String host = props.getProperty("host");
 63             String uname = props.getProperty("uname");
 64             String pwd = props.getProperty("pwd");
 65             String from = props.getProperty("from");
 66             String to = form.getEmail();
 67             String subject = props.getProperty("subject");
 68             String content = props.getProperty("content");
 69             content = MessageFormat.format(content, form.getCode());//替换｛0｝占位符
 70
 71             Session session = MailUtils.createSession(host, uname, pwd);
 72             Mail mail = new Mail(from,to,subject,content);
 73             try {
 74                 MailUtils.send(session, mail);
 75             } catch (MessagingException e) {
 76             }
 77         /*
 78          * 保存成功信息到msg.jsp
 79          */
 80         request.setAttribute("msg", "恭喜您，注册成功！请马上到邮箱激活！");
 81         return "f:/msg.jsp";
 82     }
 83     /**
 84      * 激活功能
 85      * @功能 当用户点击邮件中的完成激活连接时，访问这个方法
 86      *      调用service的激活方法修改用户状态
 87      * @param request
 88      * @param response
 89      * @return
 90      * @throws ServletException
 91      * @throws IOException
 92      * @throws
 93      */
 94     public String active(HttpServletRequest request, HttpServletResponse response)
 95             throws ServletException, IOException  {
 96         /*
 97          * 1. 获取参数激活码
 98          * 2. 调用service方法完成激活
 99          *      如果出现异常，保存异常信息到request域中，转发到msg.jsp
100          * 3. 成功，保存成功信息到request域，转发msg.jsp
101          */
102         String code = request.getParameter("code");
103         try {
104             userService.active(code);
105             request.setAttribute("msg", "恭喜，您激活成功！请登陆");
106         } catch (UserException e) {
107             request.setAttribute("msg", e.getMessage());
108         }
109         return "f:/msg.jsp" ;
110     }
111
112 }

 1 package cn.kmust.mail.service;
 2
 3 import cn.kmust.mail.dao.UserDao;
 4 import cn.kmust.mail.domin.User;
 5 import cn.kmust.mail.exception.UserException;
 6
 7 public class UserService {
 8     private UserDao userDao = new UserDao();
 9     /**
10      *  激活功能
11      * @param code
12      * @throws UserException
13      */
14    public void active(String code) throws UserException {
15        /*
16         * 1. 按激活码查询用户
17         * 2. user不存在，激活码错误
18         * 3. 校验用户状态，如果已激活，说明二次激活，抛出异常
19         * 4. 第一次激活，则修改用户状态为true,表明已经激活
20         */
21        User user = userDao.findByCode(code);
22        System.out.println("激活状态测试："+user.isState());
23        if(user == null )
24            throw new UserException("激活码无效！");
25        if(user.isState())
26            throw new UserException("您已经激活过了！");
27        userDao.updataState(user.getUid(),true);
28
29    }
30    /**
31     * 注册功能
32     * @param form
33     */
34     public void regist(User form) {
35         userDao.add(form);
36     }
37 }

 1 package cn.kmust.mail.dao;
 2
 3 import java.sql.SQLException;
 4 import org.apache.commons.dbutils.QueryRunner;
 5 import org.apache.commons.dbutils.handlers.BeanHandler;
 6
 7 import cn.itcast.jdbc.TxQueryRunner;
 8 import cn.kmust.mail.domin.User;
 9
10 public class UserDao {
11     private QueryRunner qr = new TxQueryRunner();
12     /**
13      * 通过激活码查询用户
14      * @param code
15      * @return
16      */
17     public User findByCode(String code) {
18         try{
19             String sql = "select * from tb_user where code=?" ;
20             return qr.query(sql, new BeanHandler<User>(User.class),code);
21         }catch(SQLException e){
22             throw new RuntimeException(e);
23         }
24     }
25     /**
26      *  添加用户
27      * @param form
28      */
29     public void add(User user) {
30         try{
31             String sql = "insert into tb_user value(?,?,?,?)";
32             Object[] params ={user.getUid(),user.getEmail(),user.getCode(),user.isState()};
33             qr.update(sql,params);
34         }catch(SQLException e){
35             throw new RuntimeException(e);
36         }
37
38     }
39     /**
40      * 成功激活后修改状态为已激活
41      * @param uid
42      * @param b
43      */
44     public void updataState(String uid, boolean state) {
45         try{
46             String sql = "update tb_user set state=? where uid=?";
47             qr.update(sql,state,uid);
48         }catch(SQLException e){
49             throw new RuntimeException(e);
50         }
51
52     }
53
54 }