重构客户注册-基于ActiveMQ实现短信验证码生产者

重构目标：将bos_fore项目中的CustomerAction作为短信消息生产者，将消息发给ActiveMQ,创建一个单独的SMS项目，作为短信息的消费者，从ActiveMQ获取短信消息，调用第三方接口完成短信发送。 
CustomerAction完整代码：

@ParentPackage("json-default")
@Namespace("/")
@Controller
@Scope("prototype")
public class CustomerAction extends BaseAction<Customer> {
    @Autowired
    @Qualifier("jmsQueueTemplate")
    private JmsTemplate jmsTemplate;

    @Action(value = "customer_sendSms")
    public String sendSms() throws IOException {
        // 手机号保存在Customer对象
        // 生成短信验证码
        String randomCode = RandomStringUtils.randomNumeric(4);
        // 将短信验证码 保存到session
        ServletActionContext.getRequest().getSession()
                .setAttribute(model.getTelephone(), randomCode);

        System.out.println("生成手机验证码为：" + randomCode);
        // 编辑短信内容
        final String msg = "尊敬的用户您好，本次获取的验证码为：" + randomCode
                + ",服务电话：4007654321";

        // 调用MQ服务，发送一条消息
        jmsTemplate.send("bos_sms", new MessageCreator() {
            @Override
            public Message createMessage(Session session) throws JMSException {
                MapMessage mapMessage = session.createMapMessage();
                mapMessage.setString("telephone", model.getTelephone());
                mapMessage.setString("msg", msg);
                return mapMessage;
            }
        });
        return NONE;

    }

    // 属性驱动
    private String checkcode;

    public void setCheckcode(String checkcode) {
        this.checkcode = checkcode;
    }

    @Autowired
    private RedisTemplate<String, String> redisTemplate;

    @Action(value = "customer_regist", results = {
            @Result(name = "success", type = "redirect", location = "signup-success.html"),
            @Result(name = "input", type = "redirect", location = "signup.html") })
    public String regist() {
        // 先校验短信验证码，如果不通过，调回注册页面
        // 从session获取 之前生成验证码
        String checkcodeSession = (String) ServletActionContext.getRequest()
                .getSession().getAttribute(model.getTelephone());
        if (checkcodeSession == null || !checkcodeSession.equals(checkcode)) {
            System.out.println("短信验证码错误...");
            // 短信验证码错误
            return INPUT;
        }
        // 调用webService 连接CRM 保存客户信息
        WebClient
                .create("http://localhost:9002/crm_management/services"
                        + "/customerService/customer")
                .type(MediaType.APPLICATION_JSON).post(model);
        System.out.println("客户注册成功...");

        // 发送一封激活邮件
        // 生成激活码
        String activecode = RandomStringUtils.randomNumeric(32);

        // 将激活码保存到redis，设置24小时失效
        redisTemplate.opsForValue().set(model.getTelephone(), activecode, 24,
                TimeUnit.HOURS);

        // 调用MailUtils发送激活邮件
        String content = "尊敬的客户您好，请于24小时内，进行邮箱账户的绑定，点击下面地址完成绑定:<br/><a href='"
                + MailUtils.activeUrl + "?telephone=" + model.getTelephone()
                + "&activecode=" + activecode + "'>速运快递邮箱绑定地址</a>";
        MailUtils.sendMail("速运快递激活邮件", content, model.getEmail());

        return SUCCESS;
    }

    // 属性驱动
    private String activecode;

    public void setActivecode(String activecode) {
        this.activecode = activecode;
    }

    @Action("customer_activeMail")
    public String activeMail() throws IOException {
        ServletActionContext.getResponse().setContentType(
                "text/html;charset=utf-8");
        // 判断激活码是否有效
        String activecodeRedis = redisTemplate.opsForValue().get(
                model.getTelephone());
        if (activecodeRedis == null || !activecodeRedis.equals(activecodeRedis)) {
            // 激活码无效
            ServletActionContext.getResponse().getWriter()
                    .println("激活码无效，请登录系统，重新绑定邮箱！");
        } else {
            // 激活码有效
            // 防止重复绑定
            // 调用CRM webService 查询客户信息，判断是否已经绑定
            Customer customer = WebClient
                    .create("http://localhost:9002/crm_management/services"
                            + "/customerService/customer/telephone/"
                            + model.getTelephone())
                    .accept(MediaType.APPLICATION_JSON).get(Customer.class);
            if (customer.getType() == null || customer.getType() != 1) {
                // 没有绑定,进行绑定
                WebClient.create(
                        "http://localhost:9002/crm_management/services"
                                + "/customerService/customer/updatetype/"
                                + model.getTelephone()).get();
                ServletActionContext.getResponse().getWriter()
                        .println("邮箱绑定成功！");
            } else {
                // 已经绑定过
                ServletActionContext.getResponse().getWriter()
                        .println("邮箱已经绑定过，无需重复绑定！");
            }

            // 删除redis的激活码
            redisTemplate.delete(model.getTelephone());
        }
        return NONE;
    }

}

spring的配置文件applicationContext-mq.xml完整代码：

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:aop="http://www.springframework.org/schema/aop"
    xmlns:context="http://www.springframework.org/schema/context"
    xmlns:jdbc="http://www.springframework.org/schema/jdbc" xmlns:tx="http://www.springframework.org/schema/tx"
    xmlns:jpa="http://www.springframework.org/schema/data/jpa" xmlns:task="http://www.springframework.org/schema/task"
    xmlns:amq="http://activemq.apache.org/schema/core"
    xmlns:jms="http://www.springframework.org/schema/jms"
    xsi:schemaLocation="
        http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.1.xsd
        http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-4.1.xsd
        http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.1.xsd
        http://www.springframework.org/schema/jdbc http://www.springframework.org/schema/jdbc/spring-jdbc-4.1.xsd
        http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.1.xsd
        http://www.springframework.org/schema/data/jpa 
        http://www.springframework.org/schema/data/jpa/spring-jpa.xsd
        http://www.springframework.org/schema/jms
        http://www.springframework.org/schema/jms/spring-jms.xsd
        http://activemq.apache.org/schema/core
        http://activemq.apache.org/schema/core/activemq-core-5.8.0.xsd ">

    <!-- ActiveMQ 连接工厂 -->
    <!-- 真正可以产生Connection的ConnectionFactory，由对应的 JMS服务厂商提供-->
    <!-- 如果连接网络：tcp://ip:61616；未连接网络：tcp://localhost:61616 以及用户名，密码-->
    <amq:connectionFactory id="amqConnectionFactory"
        brokerURL="tcp://localhost:61616" userName="admin" password="admin"  />

    <!-- Spring Caching连接工厂 -->
    <!-- Spring用于管理真正的ConnectionFactory的ConnectionFactory -->  
    <bean id="mqConnectionFactory" class="org.springframework.jms.connection.CachingConnectionFactory">
        <!-- 目标ConnectionFactory对应真实的可以产生JMS Connection的ConnectionFactory -->  
        <property name="targetConnectionFactory" ref="amqConnectionFactory"></property>
        <!-- 同上，同理 -->
        <!-- <constructor-arg ref="amqConnectionFactory" /> -->
        <!-- Session缓存数量 -->
        <property name="sessionCacheSize" value="100" />
    </bean>

     <!-- Spring JmsTemplate 的消息生产者 start-->

    <!-- 定义JmsTemplate的Queue类型 -->
    <bean id="jmsQueueTemplate" class="org.springframework.jms.core.JmsTemplate">
        <!-- 这个connectionFactory对应的是我们定义的Spring提供的那个ConnectionFactory对象 -->  
        <constructor-arg ref="mqConnectionFactory" />
        <!-- 非pub/sub模型（发布/订阅），即队列模式 -->
        <property name="pubSubDomain" value="false" />
    </bean>

    <!-- 定义JmsTemplate的Topic类型 -->
    <bean id="jmsTopicTemplate" class="org.springframework.jms.core.JmsTemplate">
         <!-- 这个connectionFactory对应的是我们定义的Spring提供的那个ConnectionFactory对象 -->  
        <constructor-arg ref="mqConnectionFactory" />
        <!-- pub/sub模型（发布/订阅） -->
        <property name="pubSubDomain" value="true" />
    </bean>

    <!--Spring JmsTemplate 的消息生产者 end--> 
</beans>

maven的pom文件完整代码：

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  <modelVersion>4.0.0</modelVersion>

  <parent>
     <groupId>cn.niwotaxuexiba.maven</groupId>
     <artifactId>common_parent</artifactId>
     <version>0.0.1-SNAPSHOT</version>
  </parent>  

  <artifactId>bos_fore</artifactId>
  <packaging>war</packaging>
  <name>bos_fore</name>
  <description>物流前端系统</description>

  <build>
    <plugins>
        <plugin>
            <groupId>org.codehaus.mojo</groupId>
            <artifactId>tomcat-maven-plugin</artifactId>
            <version>1.1</version>
            <configuration>
                <port>9003</port>
            </configuration>
        </plugin>
        <plugin>
            <groupId>org.apache.maven.plugins</groupId>
            <artifactId>maven-compiler-plugin</artifactId>
            <version>2.3.2</version>
            <configuration>
                <source>1.8</source>
                <target>1.8</target>
            </configuration>
        </plugin>
    </plugins>
  </build>
  <dependencies>
    <dependency>
        <groupId>cn.niwotaxuexiba.maven</groupId>
        <artifactId>crm_domain</artifactId>
        <version>0.0.1-SNAPSHOT</version>
    </dependency>
  </dependencies>
</project>