ssh项目实战----Spring计时器任务 Spring整合JavaMail（邮件发送）

时间  2019-11-16
标签 ssh 项目 实战 spring 计时器 任务 整合 javamail 邮件 发送 栏目 Spring 繁體版
原文   原文链接

1、经常使用数据频度维护

对于系统使用度较高的数据，客户在查看时但愿这些数据最好先出现，此时须要为其添加排序规则。在进行排序时，使用次数成为排序的依据。所以须要设置一个字段用来描述某种数据的使用次数，也就是所谓的使用频度。
本系统中，商品数据是总体数据流的核心数据，为商品数据添加频度字段。
好好学java
该字段的值默认为0，每使用一次，将其值自增一。可是若是每次使用都修改该表的对应字段，操做量无疑是巨大的，而且还牵扯到数据库操做的隔离级问题，须要防止并发带来的错误操做。
系统中常常会出现此类任务，即须要修改某些数据的值，可是此数据并不须要具备很强的即时性。只须要在某一个特定时刻，将该值修改便可。
基于上述分析，须要一种机制保障，在特定时间点，将对应商品的使用次数修改成当前已使用的总次数便可。最终数据排序时，以该字段做为排序依据便可。
上述问题须要完成两个任务便可javascript

  • 规定时间内循环执行某任务
  • 执行特殊的SQL语句，完成修改使用次数字段的任务

2、Spring定时做业调度

Spring提供了定时器任务，用于在规定时间执行对应的任务。html

1.定义定时做业任务Bean，及其做业任务对应的操做html5

/**
* 设备一数据插入(小时)
 */
public void insertHourService1(){
    realmEbi = (RealmEbi) ApplicationContextUtil.getBean("realmEbi");
    realmEbi.insertHour(RealmApplianceModel.sendData3);
}
复制代码

2.将其配置为Spring管理的Beanjava

<!-- 定义一个定时bean -->
<bean id="timerTask" class="org.sihai.soilmoni.soilrealm.web.SoilRealmAction">
</bean>
复制代码

3.定义做业任务web

<!-- 设备二数据定时插入(天) -->
<bean id="jobTask4" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
    <property name="targetObject" ref="timerTask"/>
    <property name="targetMethod" value="insertDayService2"/>
</bean>
复制代码

4.定义做业任务的执行时间周期redis

<bean id="doTime4" class="org.springframework.scheduling.quartz.CronTriggerBean">
    <property name="jobDetail" ref="jobTask4"/>
 <property name="cronExpression" value="0 59 23 * * ?"/>
</bean>
复制代码

5.设置该任务加入定时任务spring

<bean class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
        <property name="triggers">
            <list>
                <ref bean="doTime"/>
                <ref bean="doTime2"/>
                <ref bean="doTime3"/>
                <ref bean="doTime4"/>
            </list>
        </property>
</bean>
复制代码

6.修改执行的时间周期值，参看：资源/定时调度Quartz/Cron表达式.txtsql

设置执行周期为每10秒一次
0/10 * * * * ?    每10秒一次
0/10 * * ? * *    每10秒一次
复制代码

7.源码数据库

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
 xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 xsi:schemaLocation="
 http://www.springframework.org/schema/beans 
 http://www.springframework.org/schema/beans/spring-beans.xsd
 ">  
    <bean class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
        <property name="triggers">
            <list>
                <ref bean="doTime"/>
                <ref bean="doTime2"/>
                <ref bean="doTime3"/>
                <ref bean="doTime4"/>
            </list>
        </property>
    </bean>
    <!-- 做业任务 -->
    <bean id="doTime" class="org.springframework.scheduling.quartz.CronTriggerBean">
        <property name="jobDetail" ref="jobTask"/>
        <property name="cronExpression" value="0 59 23 * * ?"/>
    </bean>
    <bean id="doTime2" class="org.springframework.scheduling.quartz.CronTriggerBean">
        <property name="jobDetail" ref="jobTask2"/>
        <property name="cronExpression" value="0 59 23 * * ?"/>
    </bean>
    <bean id="doTime3" class="org.springframework.scheduling.quartz.CronTriggerBean">
        <property name="jobDetail" ref="jobTask3"/>
        <property name="cronExpression" value="0 59 23 * * ?"/>
    </bean>
    <bean id="doTime4" class="org.springframework.scheduling.quartz.CronTriggerBean">
        <property name="jobDetail" ref="jobTask4"/>
        <property name="cronExpression" value="0 59 23 * * ?"/>
    </bean>
    <!-- 定义做业任务 -->
    <!-- 设备一数据定时插入(小时) -->
    <bean id="jobTask" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
        <property name="targetObject" ref="timerTask"/>
        <property name="targetMethod" value="insertHourService1"/>
    </bean>
    <!-- 设备二数据定时插入(小时) -->
    <bean id="jobTask2" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
        <property name="targetObject" ref="timerTask"/>
        <property name="targetMethod" value="insertHourService2"/>
    </bean>
    <!-- 设备一数据定时插入(天) -->
    <bean id="jobTask3" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
        <property name="targetObject" ref="timerTask"/>
        <property name="targetMethod" value="insertDayService1"/>
    </bean>
    <!-- 设备二数据定时插入(天) -->
    <bean id="jobTask4" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
        <property name="targetObject" ref="timerTask"/>
        <property name="targetMethod" value="insertDayService2"/>
    </bean>
    <!-- 定义一个定时bean -->
    <bean id="timerTask" class="org.sihai.soilmoni.soilrealm.web.SoilRealmAction">
    </bean>
</beans>    
复制代码

3、经常使用数据频度维护

使用Spring数据频度调度维护，配置需改数据操做，完成商品使用量频度维护安全

1.定义维护商品使用频度的SQL语句，执行并验证执行效果

update tbl_goods g set g.useNum = (select count(odm.uuid) from tbl_detail_order odm where odm.goodsUuid = g.uuid)
复制代码

2.将上述任务转化为定时任务方法
好好学java
注入对应的数据层Bean，并开启事务

3.设置该任务的执行周期
好好学java

4、库存预警功能

库存预警功能是对库存商品数量进行报警的一种机制。当库存商品数量高于或低于指定的预警数量时，产生报警信息。
报警信息能够是以下方案之一

  • 发邮件
  • 发短信
  • 给手机发送消息
  • 发出警报消息（ERP系统内发送给主管：主管再将该任务派发到人员：实现方式ServletContext范围内的数据共享，建立集合（必须是多线程安全的）页面设计定时器定时获取该集合数据，每隔一段时间发送AJAX请求，获取预警信息
    报警操做必须时刻监控库存商品的数量。若是到达报警临界值，进行指定方式的信息报警。此处使用Email形式进行报警。

1.设置报警定时器任务，当库存商品总数量低于最低值或高于最高值时，发送Email到仓库管理员，进行预警报警。
好好学java
2.设置库存预警定时做业调度任务
好好学java
3.测试定时做业是否成功
4.获取引起预警信息的数据
对库存明细数据进行分组统计求和，若是数量超出对应商品的库存预警值，将该商品加入库存预警信息

select 
gm.uuid,
    gm.goodsName,
    sum(sdm.now)>=gm.maxNum ,
    sum(sdm.now)<=gm.minNum 
from 
    tbl_detail_store sdm,
    tbl_goods gm 
where  
    sdm.goodsUuid = gm.uuid 
group by 
    sdm.goodsUuid
复制代码

5.获取数据后判断是否须要发送库存预计信息
好好学java

5、Spring整合JavaMail

Spring提供对JavaMail的整合技术，配置JavaMail发送器为Spring管理的Bean，实现Spring管理资源的机制。
1.配置Spring管理的JavaMail发送器对象

<?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:p="http://www.springframework.org/schema/p" 
 xmlns:context="http://www.springframework.org/schema/context" 
 xmlns:tx="http://www.springframework.org/schema/tx" 
 xmlns:aop="http://www.springframework.org/schema/aop" 
 xsi:schemaLocation="http://www.springframework.org/schema/beans 
 http://www.springframework.org/schema/beans/spring-beans.xsd 
 http://www.springframework.org/schema/aop 
 http://www.springframework.org/schema/aop/spring-aop.xsd 
 http://www.springframework.org/schema/tx 
 http://www.springframework.org/schema/tx/spring-tx.xsd 
 http://www.springframework.org/schema/context 
 http://www.springframework.org/schema/context/spring-context.xsd">
    <description>JavaMail的配置文件</description>
    <!-- 加载mail.properties配置文件 -->
    <context:property-placeholder location="classpath:mail.properties"/>
    <!-- 简单消息对象建立 -->
    <bean id="mailMessage" class="org.springframework.mail.SimpleMailMessage">
         <property name="from" value="${mail.from}"></property>
    </bean>
    <!-- 2.建立发送器 -->    
    <bean id="mailSender" class="org.springframework.mail.javamail.JavaMailSenderImpl">
         <property name="host" value="${mail.host}"></property>
         <property name="username" value="${mail.username}"></property>
         <property name="password" value="${mail.password}"></property>
         <property name="defaultEncoding" value="UTF-8"></property>
         <property name="javaMailProperties">
            <props>
                 <prop key="mail.smtp.auth">true</prop>
                 <prop key="mail.debug">true</prop>
                 <prop key="mail.smtp.timeout">0</prop>
            </props>
         </property>
    </bean>
</beans>
复制代码

2.设置发送邮件相关内容

//spring整合javaMail须要注入：
    private SimpleMailMessage mailMessage;
    private JavaMailSender mailSender;
    public void setMailMessage(SimpleMailMessage mailMessage) {
        this.mailMessage = mailMessage;
    }
    public void setMailSender(JavaMailSender mailSender) {
        this.mailSender = mailSender;
    }
public void saveOrUpdate(final User entity) {       
        if(UtilFuns.isEmpty(entity.getId())){
            //判断id是否有值
            //说明id没有值，说明保存 
            entity.setState(1);  //1表明可用
            String id = UUID.randomUUID().toString();
            entity.setId(id);
            entity.getUserinfo().setId(id);
            //设置初始密码 须要将默认的密码加密后保存到数据库
            entity.setPassword(Encrypt.md5(SysConstant.DEFAULT_PASS, entity.getUserName()));
//final就是延长对象的生命周期，否则entity只能在saveOrUpdate中使用，使用完成后方法弹栈，而run方法内就没法再使用以前定义好的entity。
//使用spring与javaMail实现新员工入职时邮件的发送
//使用线程并try-catch的目的就是若是邮件发送失败，也不影响信息保存到数据库。邮件发送成为了一个独立的过程。
            Thread th = new Thread(new Runnable(){
                public void run(){
                    try {
                        mailMessage.setTo(entity.getUserinfo().getEmail());
                        mailMessage.setSubject("新员工入职信息");
                        mailMessage.setText("欢迎"+entity.getUserinfo().getName()+"加入廊坊思创志远科技有限公司，您在公司的帐号："+entity.getUserName()+",密码："+SysConstant.DEFAULT_PASS);
                        mailSender.send(mailMessage);
                    } catch (MailException e) {
                        e.printStackTrace();
                    }
                }
            });
            th.start();
        }
        baseDao.saveOrUpdate(entity);
    }   
复制代码

3.设置发送邮件的消息内容
好好学java
4.发送邮件
好好学java

若是想获取更多源码或者视频教程，欢迎关注个人微信公众号 好好学java，在公众号里，回复：java基础、html五、javaEE基础、struts二、spring、redis、luncene、oracle等，将可得到以上的优质视频教程及源码。
这里写图片描述

相关文章
相关标签/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公众号
   欢迎关注本站公众号,获取更多信息
联系我们 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程