天达云 科技型企业 | 亚太互联网络信息中心(APNIC)成员 | 注册免费体验
天达云首页 > 互联网学习教程 > 开发技术 > Quartz注解方式怎么配置

Quartz注解方式怎么配置
更新：HHH   时间：2023-1-7

本篇内容主要讲解“Quartz注解方式怎么配置”，感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷，实用性强。下面就让小编来带大家学习“Quartz注解方式怎么配置”吧!

一：目录结构

二：统一配置文件

context-datasource.properties


  1. workDesk.jdbc.driverclass=com.mysql.jdbc.Driver

  2. workDesk.jdbc.url=jdbc:mysql://10.243.3.18:3306/system?userUnicode=true&characterEncoding=UTF-8

  3. workDesk.jdbc.username=root

  4. workDesk.jdbc.password=$Fortune2015

  5. workDesk.jdbc.poolsize.max=3

  6. workDesk.jdbc.poolsize.min=3

  7. workDesk.jdbc.poolsize.initial=2

  8. workDesk.jdbc.idletime.max=25000

  9. workDesk.jdbc.idleConnectionTestPeriod=18000


  11. #-------workDesk jdbc--------

  12. workDesk.read.jdbc.driverclass=com.mysql.jdbc.Driver

  13. workDesk.read.jdbc.url=jdbc:mysql://10.243.3.18:3306/system?userUnicode=true&characterEncoding=UTF-8

  14. workDesk.read.jdbc.username=root

  15. workDesk.read.jdbc.password=$Fortune2015

  16. workDesk.read.jdbc.poolsize.max=3

  17. workDesk.read.jdbc.poolsize.min=3

  18. workDesk.read.jdbc.poolsize.initial=2

  19. workDesk.read.jdbc.idletime.max=25000

  20. workDesk.read.jdbc.idleConnectionTestPeriod=18000



  23. #--------------redis conf------------

  24. redis.ip=10.243.3.18

  25. redis.port=6379

  26. redis.password=$Fortune2015

  27. redis.default.db=0

  28. redis.timeout=30000


  30. redis.pool.maxActive=1024

  31. redis.pool.maxIdle=200

  32. redis.pool.maxWait=1000

  33. redis.pool.testOnBorrow=true



  36. #------------------jms server-------------

  37. activeMq=failover:(tcp://10.243.3.18:61616,tcp://10.243.3.18:61616)?randomize=false


  39. #--------------mongodb conf------------

  40. mongodb.host=10.243.3.27

  41. mongodb.port=27017

  42. mongodb.database=gmap

  43. mongodb.username=mongodb

  44. mongodb.password=$Fortune2016

systemConfig.properties

点击(此处)折叠或打开

  1. #=======================================================================================


  3. #MailSender Config

  4. #=======================================================================================

  5. mail.host=smtp.mxhichina.com

三：配置文件


  1. @Configuration

  2. @EnableScheduling

  3. @EnableCaching

  4. @EnableTransactionManagement(proxyTargetClass = true)

  5. @ComponentScan("com.gemdale,com.enjoylink")

  6. @Import({DataSourceElConfig.class,TransactionManagerElConfig.class,CachingElConfig.class,MongoElConfig.class,JmsElConfig.class})

  7. public class AppConfig {


  9. }

  1. @Configuration

  2. public class CachingElConfig {


  4.     @Autowired

  5.     @Qualifier("jedisConnectionFactory")

  6.     private JedisConnectionFactory jedisConnectionFactory;


  8.     @Autowired

  9.     @Qualifier("keySerializer")

  10.     private StringRedisSerializer keySerializer;


  12.     @Autowired

  13.     @Qualifier("valueSerializer")

  14.     private JdkSerializationRedisSerializer valueSerializer;


  16.     @Bean(name = "redisTemplate")

  17.     public RedisTemplate<String, Object> redisTemplate() {

  18.         RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();

  19.         redisTemplate.setConnectionFactory(jedisConnectionFactory);

  20.         redisTemplate.setKeySerializer(keySerializer);

  21.         redisTemplate.setHashKeySerializer(keySerializer);

  22.         redisTemplate.setValueSerializer(valueSerializer);

  23.         redisTemplate.setHashValueSerializer(valueSerializer);

  24.         redisTemplate.afterPropertiesSet();

  25.         return redisTemplate;

  26.     }


  28.     @Bean

  29.     public CacheManager cacheManager(RedisTemplate<String, Object> redisTemplate) {

  30.         RedisCacheManager cacheManager = new RedisCacheManager(redisTemplate);

  31.         // 设置过期时间

  32.        // cacheManager.setDefaultExpiration(10);

  33.         return cacheManager;


  35.     }

  36. }


  1. @Configuration

  2. @PropertySource("classpath:context-datasource.properties")

  3. public class DataSourceElConfig {


  5.     private static Logger logger = Logger.getLogger(DataSourceElConfig.class);


  7.     @Value("${workDesk.jdbc.driverclass}")

  8.     private String driverClass;

  9.     @Value("${workDesk.jdbc.url}")

  10.     private String jdbcUrl;

  11.     @Value("${workDesk.jdbc.username}")

  12.     private String user;

  13.     @Value("${workDesk.jdbc.password}")

  14.     private String password;

  15.     @Value("${workDesk.jdbc.poolsize.max}")

  16.     private int maxPoolSize;

  17.     @Value("${workDesk.jdbc.poolsize.min}")

  18.     private int minPoolSize;

  19.     @Value("${workDesk.jdbc.poolsize.initial}")

  20.     private int initialPoolSize;

  21.     @Value("${workDesk.jdbc.idletime.max}")

  22.     private int maxIdleTime;

  23.     @Value("${workDesk.jdbc.idleConnectionTestPeriod}")

  24.     private int idleConnectionTestPeriod;


  26.     @Value("${workDesk.read.jdbc.driverclass}")

  27.     private String readDriverClass;

  28.     @Value("${workDesk.read.jdbc.url}")

  29.     private String readJdbcUrl;

  30.     @Value("${workDesk.read.jdbc.username}")

  31.     private String readUser;

  32.     @Value("${workDesk.read.jdbc.password}")

  33.     private String readPassword;

  34.     @Value("${workDesk.read.jdbc.poolsize.max}")

  35.     private int readMaxPoolSize;

  36.     @Value("${workDesk.read.jdbc.poolsize.min}")

  37.     private int readMinPoolSize;

  38.     @Value("${workDesk.read.jdbc.poolsize.initial}")

  39.     private int readInitialPoolSize;

  40.     @Value("${workDesk.read.jdbc.idletime.max}")

  41.     private int readMaxIdleTime;

  42.     @Value("${workDesk.read.jdbc.idleConnectionTestPeriod}")

  43.     private int readIdleConnectionTestPeriod;


  45.     @Value("${redis.pool.maxActive}")

  46.     private int maxTotal;

  47.     @Value("${redis.pool.maxIdle}")

  48.     private int maxIdle;

  49.     @Value("${redis.pool.maxWait}")

  50.     private long maxWaitMillis;


  52.     @Value("${redis.ip}")

  53.     private String redisIp;

  54.     @Value("${redis.port}")

  55.     private int redisPort;

  56.     @Value("${redis.password}")

  57.     private String redisPassword;

  58.     @Value("${redis.timeout}")

  59.     private int redisTimeout;

  60.     @Value("${redis.default.db}")

  61.     private int redisDb;


  63.     @Value("${mongodb.host}")

  64.     private String mongoHost;

  65.     @Value("${mongodb.port}")

  66.     private int mongoPort;

  67.     @Value("${mongodb.database}")

  68.     private String mongoUserName;

  69.     @Value("${mongodb.username}")

  70.     private String mongoDB;

  71.     @Value("${mongodb.password}")

  72.     private String mongoPassword;

  73.     

  74.     @Value("${activeMq}")

  75.     private String activeMq;


  77.     @Autowired

  78.     private Environment environment;


  80.     @Bean

  81.     public static PropertySourcesPlaceholderConfigurer propertyConfigure() {

  82.         return new PropertySourcesPlaceholderConfigurer();

  83.     }


  85.     /**

  86.      * MySql Master 写库数据源

  87.      *

  88.      * @return

  89.      */

  90.     @Bean(name = "platformTomcat", destroyMethod = "close")

  91.     public ComboPooledDataSource platformTomcat() {

  92.         ComboPooledDataSource dataSource = new ComboPooledDataSource();

  93.         try {

  94.             dataSource.setDriverClass(driverClass);

  95.         }

  96.         catch (PropertyVetoException e) {

  97.             logger.error("数据源配置，无法找到配置类", e);

  98.         }

  99.         dataSource.setJdbcUrl(jdbcUrl);

  100.         dataSource.setUser(user);

  101.         dataSource.setPassword(password);

  102.         dataSource.setMaxPoolSize(maxPoolSize);

  103.         dataSource.setMinPoolSize(minPoolSize);

  104.         dataSource.setInitialPoolSize(initialPoolSize);

  105.         dataSource.setMaxIdleTime(maxIdleTime);

  106.         dataSource.setTestConnectionOnCheckin(true);

  107.         dataSource.setPreferredTestQuery("SELECT 1");

  108.         dataSource.setIdleConnectionTestPeriod(idleConnectionTestPeriod);

  109.         return dataSource;

  110.     }


  112.     /**

  113.      * MySql Slave 读库数据源

  114.      *

  115.      * @return

  116.      */

  117.     @Bean(name = "platformReadTomcat", destroyMethod = "close")

  118.     public ComboPooledDataSource platformReadTomcat() {

  119.         ComboPooledDataSource dataSource = new ComboPooledDataSource();

  120.         try {

  121.             dataSource.setDriverClass(readDriverClass);

  122.         }

  123.         catch (PropertyVetoException e) {

  124.             logger.error("数据源配置，无法找到配置类", e);

  125.         }

  126.         dataSource.setJdbcUrl(readJdbcUrl);

  127.         dataSource.setUser(readUser);

  128.         dataSource.setPassword(readPassword);

  129.         dataSource.setMaxPoolSize(readMaxPoolSize);

  130.         dataSource.setMinPoolSize(readMinPoolSize);

  131.         dataSource.setInitialPoolSize(readInitialPoolSize);

  132.         dataSource.setMaxIdleTime(readMaxIdleTime);

  133.         dataSource.setTestConnectionOnCheckin(true);

  134.         dataSource.setPreferredTestQuery("SELECT 1");

  135.         dataSource.setIdleConnectionTestPeriod(readIdleConnectionTestPeriod);

  136.         return dataSource;

  137.     }


  139.     /**

  140.      * Redis 连接池配置信息

  141.      *

  142.      * @return

  143.      */

  144.     @Bean(name = "jedisPoolConfig")

  145.     public JedisPoolConfig jedisPoolConfig() {

  146.         JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();

  147.         jedisPoolConfig.setMaxTotal(maxTotal);

  148.         jedisPoolConfig.setMaxIdle(maxIdle);

  149.         jedisPoolConfig.setMaxWaitMillis(maxWaitMillis);

  150.         jedisPoolConfig.setTestOnBorrow(true);

  151.         return jedisPoolConfig;

  152.     }


  154.     @Bean(name = "jedisConnectionFactory")

  155.     public JedisConnectionFactory jedisConnectionFactory(JedisPoolConfig jedisPoolConfig) {

  156.         JedisConnectionFactory jedisConnectionFactory = new JedisConnectionFactory(jedisPoolConfig);

  157.         jedisConnectionFactory.setUsePool(true);

  158.         jedisConnectionFactory.setHostName(redisIp);

  159.         jedisConnectionFactory.setPort(redisPort);

  160.         jedisConnectionFactory.setPassword(redisPassword);

  161.         jedisConnectionFactory.setTimeout(redisTimeout);

  162.         jedisConnectionFactory.setDatabase(redisDb);

  163.         jedisConnectionFactory.afterPropertiesSet();

  164.         return jedisConnectionFactory;

  165.     }


  167.     @Bean(name = "keySerializer")

  168.     public StringRedisSerializer keySerializer() {

  169.         return new StringRedisSerializer();

  170.     }


  172.     @Bean(name = "valueSerializer")

  173.     public JdkSerializationRedisSerializer valueSerializer() {

  174.         return new JdkSerializationRedisSerializer();

  175.     }


  177.     /**

  178.      * MongoDB 配置

  179.      *

  180.      * @return

  181.      */

  182.     @Bean(name = "mongoDbFactory")

  183.     public MongoDbFactory mongoDbFactory() throws Exception {


  185.         MongoCredential credential = MongoCredential.createCredential(mongoUserName, mongoDB,

  186.                 mongoPassword.toCharArray());

  187.         ServerAddress serverAddress = new ServerAddress(mongoHost, mongoPort);

  188.         MongoClient mongoClient = new MongoClient(serverAddress, Arrays.asList(credential));

  189.         SimpleMongoDbFactory mongoDbFactory = new SimpleMongoDbFactory(mongoClient, mongoDB);

  190.         return mongoDbFactory;

  191.     }


  193.     @Bean(name="mongoConverter")

  194.     public MongoConverter mongoConverter(MongoDbFactory mongoDbFactory) {


  196.         MappingMongoConverter mongoConverter = new MappingMongoConverter(new DefaultDbRefResolver(mongoDbFactory),

  197.                 new MongoMappingContext());

  198.         // 不插入_class

  199.         mongoConverter.setTypeMapper(new DefaultMongoTypeMapper(null));

  200.         return mongoConverter;

  201.     }

  202.     

  203.     

  204.     /**

  205.      * Jms 配置

  206.      * @return

  207.      */

  208.     @Bean(name="activeMQConnectionFactory")

  209.     public ActiveMQConnectionFactory activeMQConnectionFactory()

  210.     {

  211.         ActiveMQConnectionFactory activeMQConnectionFactory = new ActiveMQConnectionFactory();

  212.         activeMQConnectionFactory.setUseAsyncSend(false);

  213.         activeMQConnectionFactory.setBrokerURL(activeMq);

  214.         return activeMQConnectionFactory;

  215.     }

  216.     

  217.     @Bean(name="cachingConnectionFactory")

  218.     public CachingConnectionFactory cachingConnectionFactory(ActiveMQConnectionFactory targetConnectionFactory)

  219.     {

  220.         CachingConnectionFactory cachingConnectionFactory = new CachingConnectionFactory(targetConnectionFactory);

  221.         cachingConnectionFactory.setSessionCacheSize(10);

  222.         return cachingConnectionFactory;

  223.     }

  224. }

点击(此处)折叠或打开

  1. @Configuration

  2. @PropertySource("classpath:context-datasource.properties")

  3. public class DataSourceElConfig {


  5.     private static Logger logger = Logger.getLogger(DataSourceElConfig.class);


  7.     @Value("${workDesk.jdbc.driverclass}")

  8.     private String driverClass;

  9.     @Value("${workDesk.jdbc.url}")

  10.     private String jdbcUrl;

  11.     @Value("${workDesk.jdbc.username}")

  12.     private String user;

  13.     @Value("${workDesk.jdbc.password}")

  14.     private String password;

  15.     @Value("${workDesk.jdbc.poolsize.max}")

  16.     private int maxPoolSize;

  17.     @Value("${workDesk.jdbc.poolsize.min}")

  18.     private int minPoolSize;

  19.     @Value("${workDesk.jdbc.poolsize.initial}")

  20.     private int initialPoolSize;

  21.     @Value("${workDesk.jdbc.idletime.max}")

  22.     private int maxIdleTime;

  23.     @Value("${workDesk.jdbc.idleConnectionTestPeriod}")

  24.     private int idleConnectionTestPeriod;


  26.     @Value("${workDesk.read.jdbc.driverclass}")

  27.     private String readDriverClass;

  28.     @Value("${workDesk.read.jdbc.url}")

  29.     private String readJdbcUrl;

  30.     @Value("${workDesk.read.jdbc.username}")

  31.     private String readUser;

  32.     @Value("${workDesk.read.jdbc.password}")

  33.     private String readPassword;

  34.     @Value("${workDesk.read.jdbc.poolsize.max}")

  35.     private int readMaxPoolSize;

  36.     @Value("${workDesk.read.jdbc.poolsize.min}")

  37.     private int readMinPoolSize;

  38.     @Value("${workDesk.read.jdbc.poolsize.initial}")

  39.     private int readInitialPoolSize;

  40.     @Value("${workDesk.read.jdbc.idletime.max}")

  41.     private int readMaxIdleTime;

  42.     @Value("${workDesk.read.jdbc.idleConnectionTestPeriod}")

  43.     private int readIdleConnectionTestPeriod;


  45.     @Value("${redis.pool.maxActive}")

  46.     private int maxTotal;

  47.     @Value("${redis.pool.maxIdle}")

  48.     private int maxIdle;

  49.     @Value("${redis.pool.maxWait}")

  50.     private long maxWaitMillis;


  52.     @Value("${redis.ip}")

  53.     private String redisIp;

  54.     @Value("${redis.port}")

  55.     private int redisPort;

  56.     @Value("${redis.password}")

  57.     private String redisPassword;

  58.     @Value("${redis.timeout}")

  59.     private int redisTimeout;

  60.     @Value("${redis.default.db}")

  61.     private int redisDb;


  63.     @Value("${mongodb.host}")

  64.     private String mongoHost;

  65.     @Value("${mongodb.port}")

  66.     private int mongoPort;

  67.     @Value("${mongodb.database}")

  68.     private String mongoUserName;

  69.     @Value("${mongodb.username}")

  70.     private String mongoDB;

  71.     @Value("${mongodb.password}")

  72.     private String mongoPassword;

  73.     

  74.     @Value("${activeMq}")

  75.     private String activeMq;


  77.     @Autowired

  78.     private Environment environment;


  80.     @Bean

  81.     public static PropertySourcesPlaceholderConfigurer propertyConfigure() {

  82.         return new PropertySourcesPlaceholderConfigurer();

  83.     }


  85.     /**

  86.      * MySql Master 写库数据源

  87.      *

  88.      * @return

  89.      */

  90.     @Bean(name = "platformTomcat", destroyMethod = "close")

  91.     public ComboPooledDataSource platformTomcat() {

  92.         ComboPooledDataSource dataSource = new ComboPooledDataSource();

  93.         try {

  94.             dataSource.setDriverClass(driverClass);

  95.         }

  96.         catch (PropertyVetoException e) {

  97.             logger.error("数据源配置，无法找到配置类", e);

  98.         }

  99.         dataSource.setJdbcUrl(jdbcUrl);

  100.         dataSource.setUser(user);

  101.         dataSource.setPassword(password);

  102.         dataSource.setMaxPoolSize(maxPoolSize);

  103.         dataSource.setMinPoolSize(minPoolSize);

  104.         dataSource.setInitialPoolSize(initialPoolSize);

  105.         dataSource.setMaxIdleTime(maxIdleTime);

  106.         dataSource.setTestConnectionOnCheckin(true);

  107.         dataSource.setPreferredTestQuery("SELECT 1");

  108.         dataSource.setIdleConnectionTestPeriod(idleConnectionTestPeriod);

  109.         return dataSource;

  110.     }


  112.     /**

  113.      * MySql Slave 读库数据源

  114.      *

  115.      * @return

  116.      */

  117.     @Bean(name = "platformReadTomcat", destroyMethod = "close")

  118.     public ComboPooledDataSource platformReadTomcat() {

  119.         ComboPooledDataSource dataSource = new ComboPooledDataSource();

  120.         try {

  121.             dataSource.setDriverClass(readDriverClass);

  122.         }

  123.         catch (PropertyVetoException e) {

  124.             logger.error("数据源配置，无法找到配置类", e);

  125.         }

  126.         dataSource.setJdbcUrl(readJdbcUrl);

  127.         dataSource.setUser(readUser);

  128.         dataSource.setPassword(readPassword);

  129.         dataSource.setMaxPoolSize(readMaxPoolSize);

  130.         dataSource.setMinPoolSize(readMinPoolSize);

  131.         dataSource.setInitialPoolSize(readInitialPoolSize);

  132.         dataSource.setMaxIdleTime(readMaxIdleTime);

  133.         dataSource.setTestConnectionOnCheckin(true);

  134.         dataSource.setPreferredTestQuery("SELECT 1");

  135.         dataSource.setIdleConnectionTestPeriod(readIdleConnectionTestPeriod);

  136.         return dataSource;

  137.     }


  139.     /**

  140.      * Redis 连接池配置信息

  141.      *

  142.      * @return

  143.      */

  144.     @Bean(name = "jedisPoolConfig")

  145.     public JedisPoolConfig jedisPoolConfig() {

  146.         JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();

  147.         jedisPoolConfig.setMaxTotal(maxTotal);

  148.         jedisPoolConfig.setMaxIdle(maxIdle);

  149.         jedisPoolConfig.setMaxWaitMillis(maxWaitMillis);

  150.         jedisPoolConfig.setTestOnBorrow(true);

  151.         return jedisPoolConfig;

  152.     }


  154.     @Bean(name = "jedisConnectionFactory")

  155.     public JedisConnectionFactory jedisConnectionFactory(JedisPoolConfig jedisPoolConfig) {

  156.         JedisConnectionFactory jedisConnectionFactory = new JedisConnectionFactory(jedisPoolConfig);

  157.         jedisConnectionFactory.setUsePool(true);

  158.         jedisConnectionFactory.setHostName(redisIp);

  159.         jedisConnectionFactory.setPort(redisPort);

  160.         jedisConnectionFactory.setPassword(redisPassword);

  161.         jedisConnectionFactory.setTimeout(redisTimeout);

  162.         jedisConnectionFactory.setDatabase(redisDb);

  163.         jedisConnectionFactory.afterPropertiesSet();

  164.         return jedisConnectionFactory;

  165.     }


  167.     @Bean(name = "keySerializer")

  168.     public StringRedisSerializer keySerializer() {

  169.         return new StringRedisSerializer();

  170.     }


  172.     @Bean(name = "valueSerializer")

  173.     public JdkSerializationRedisSerializer valueSerializer() {

  174.         return new JdkSerializationRedisSerializer();

  175.     }


  177.     /**

  178.      * MongoDB 配置

  179.      *

  180.      * @return

  181.      */

  182.     @Bean(name = "mongoDbFactory")

  183.     public MongoDbFactory mongoDbFactory() throws Exception {


  185.         MongoCredential credential = MongoCredential.createCredential(mongoUserName, mongoDB,

  186.                 mongoPassword.toCharArray());

  187.         ServerAddress serverAddress = new ServerAddress(mongoHost, mongoPort);

  188.         MongoClient mongoClient = new MongoClient(serverAddress, Arrays.asList(credential));

  189.         SimpleMongoDbFactory mongoDbFactory = new SimpleMongoDbFactory(mongoClient, mongoDB);

  190.         return mongoDbFactory;

  191.     }


  193.     @Bean(name="mongoConverter")

  194.     public MongoConverter mongoConverter(MongoDbFactory mongoDbFactory) {


  196.         MappingMongoConverter mongoConverter = new MappingMongoConverter(new DefaultDbRefResolver(mongoDbFactory),

  197.                 new MongoMappingContext());

  198.         // 不插入_class

  199.         mongoConverter.setTypeMapper(new DefaultMongoTypeMapper(null));

  200.         return mongoConverter;

  201.     }

  202.     

  203.     

  204.     /**

  205.      * Jms 配置

  206.      * @return

  207.      */

  208.     @Bean(name="activeMQConnectionFactory")

  209.     public ActiveMQConnectionFactory activeMQConnectionFactory()

  210.     {

  211.         ActiveMQConnectionFactory activeMQConnectionFactory = new ActiveMQConnectionFactory();

  212.         activeMQConnectionFactory.setUseAsyncSend(false);

  213.         activeMQConnectionFactory.setBrokerURL(activeMq);

  214.         return activeMQConnectionFactory;

  215.     }

  216.     

  217.     @Bean(name="cachingConnectionFactory")

  218.     public CachingConnectionFactory cachingConnectionFactory(ActiveMQConnectionFactory targetConnectionFactory)

  219.     {

  220.         CachingConnectionFactory cachingConnectionFactory = new CachingConnectionFactory(targetConnectionFactory);

  221.         cachingConnectionFactory.setSessionCacheSize(10);

  222.         return cachingConnectionFactory;

  223.     }

  224. }

点击(此处)折叠或打开

  1. @Configuration

  2. public class JmsElConfig {


  4.     @Autowired

  5.     @Qualifier("cachingConnectionFactory")

  6.     private CachingConnectionFactory cachingConnectionFactory;


  8.     @Bean(name = "jmsTemplate")

  9.     public JmsTemplate jmsTemplate() {

  10.         JmsTemplate jmsTemplate = new JmsTemplate();

  11.         jmsTemplate.setConnectionFactory(cachingConnectionFactory);

  12.         return jmsTemplate;

  13.     }


  15.     @Bean(name = "serviceDemoDestination")

  16.     public Destination serviceDemoDestination() {

  17.         ActiveMQQueue serviceDemoQueue = new ActiveMQQueue("serviceDemoQueue");

  18.         return serviceDemoQueue;


  20.     }


  22.     @Bean(name = "jmsListenerContainerFactory")

  23.     public JmsListenerContainerFactory<DefaultMessageListenerContainer> jmsListenerContainerFactory() {

  24.         DefaultJmsListenerContainerFactory jmsListenerContainerFactory = new DefaultJmsListenerContainerFactory();

  25.         jmsListenerContainerFactory.setConnectionFactory(cachingConnectionFactory);

  26.         return jmsListenerContainerFactory;

  27.     }


  29. }

点击(此处)折叠或打开

  1. @Configuration

  2. public class MongoElConfig {


  4.     @Autowired

  5.     @Qualifier("mongoDbFactory")

  6.     private MongoDbFactory mongoDbFactory;


  8.     @Autowired

  9.     @Qualifier("mongoConverter")

  10.     private MongoConverter mongoConverter;


  12.     @Bean(name = "mongoTemplate")

  13.     public MongoTemplate mongoTemplate() {

  14.         MongoTemplate mongoTemplate = new MongoTemplate(mongoDbFactory, mongoConverter);

  15.         return mongoTemplate;


  17.     }


  19. }

点击(此处)折叠或打开

  1. @Configuration

  2. @PropertySource("classpath:systemConfig.properties")

  3. public class SystemElConfig {


  5.     @Value("${mail.host}")

  6.     private String mailHost;


  8.     @Autowired

  9.     private Environment environment;


  11.     @Bean

  12.     public static PropertySourcesPlaceholderConfigurer propertyConfigure() {

  13.         return new PropertySourcesPlaceholderConfigurer();

  14.     }


  16.     /**

  17.      * @return the mailHost

  18.      */

  19.     public String getMailHost() {

  20.         return mailHost;

  21.     }


  23.     /**

  24.      * @param mailHost

  25.      *            the mailHost to set

  26.      */

  27.     public void setMailHost(String mailHost) {

  28.         this.mailHost = mailHost;

  29.     }


  31. }

点击(此处)折叠或打开

  1. @Configuration

  2. @PropertySource("classpath:systemConfig.properties")

  3. public class SystemElConfig {


  5.     @Value("${mail.host}")

  6.     private String mailHost;


  8.     @Autowired

  9.     private Environment environment;


  11.     @Bean

  12.     public static PropertySourcesPlaceholderConfigurer propertyConfigure() {

  13.         return new PropertySourcesPlaceholderConfigurer();

  14.     }


  16.     /**

  17.      * @return the mailHost

  18.      */

  19.     public String getMailHost() {

  20.         return mailHost;

  21.     }


  23.     /**

  24.      * @param mailHost

  25.      *            the mailHost to set

  26.      */

  27.     public void setMailHost(String mailHost) {

  28.         this.mailHost = mailHost;

  29.     }


  31. }

点击(此处)折叠或打开

  1. @Configuration

  2. public class TransactionManagerElConfig {


  4.     @Autowired

  5.     @Qualifier("platformTomcat")

  6.     private DataSource platformTomcat;


  8.     @Autowired

  9.     @Qualifier("platformReadTomcat")

  10.     private DataSource platformReadTomcat;


  12.     @Bean(name = "jdbcTemplate")

  13.     public JdbcTemplate jdbcTemplate() {

  14.         JdbcTemplate jdbcTemplate = new JdbcTemplate();

  15.         jdbcTemplate.setDataSource(platformTomcat);

  16.         return jdbcTemplate;

  17.     }


  19.     @Bean(name = "jdbcReadTemplate")

  20.     public JdbcTemplate jdbcReadTemplate() {

  21.         JdbcTemplate jdbcReadTemplate = new JdbcTemplate();

  22.         jdbcReadTemplate.setDataSource(platformReadTomcat);

  23.         return jdbcReadTemplate;

  24.     }


  26.     @Bean(name = "transactionManager")

  27.     public DataSourceTransactionManager transactionManager() {

  28.         DataSourceTransactionManager transactionManager = new DataSourceTransactionManager();

  29.         transactionManager.setDataSource(platformTomcat);

  30.         return transactionManager;

  31.     }


  33. }



四：Demo


点击(此处)折叠或打开

  1. public class App {

  2.     public static void main(String[] args) {

  3.         AnnotationConfigApplicationContext context = new AnnotationConfigApplicationContext(AppConfig.class);


  5.         System.out.println(null == context.getBean("platformTomcat"));

  6.         System.out.println(null == context.getBean("transactionManager"));

  7.         System.out.println(null == context.getBean("redisTemplate"));

  8.         System.out.println(null == context.getBean("mongoTemplate"));

  9.         System.out.println(null == context.getBean("jmsTemplate"));


  11.         System.out.println(context.getBean(SystemElConfig.class).getMailHost());


  13.         context.getBean(ServiceDemo.class).print();


  15.     }

  16. }

点击(此处)折叠或打开

  1. @Service

  2. public class ServiceDemo {


  4.     @Value("#{systemElConfig.mailHost}")

  5.     private String mailHost;


  7.     public void print() {

  8.         System.out.println("=======" + mailHost);

  9.     }


  11. }

点击(此处)折叠或打开

  1. @Service

  2. public class ServiceDemo {


  4.     @Value("#{systemElConfig.mailHost}")

  5.     private String mailHost;


  7.     public void print() {

  8.         System.out.println("=======" + mailHost);

  9.     }


  11. }

点击(此处)折叠或打开

  1. @Service

  2. public class ServiceDemo {


  4.     @Value("#{systemElConfig.mailHost}")

  5.     private String mailHost;


  7.     public void print() {

  8.         System.out.println("=======" + mailHost);

  9.     }


  11. }

点击(此处)折叠或打开

  1. @Component

  2. @EnableJms

  3. public class ServiceDemoListener extends AbstractListener {


  5.     @JmsListener(containerFactory = "jmsListenerContainerFactory", destination = "serviceDemoQueue")

  6.     public void onMessage(Message message) {


  8.         try {

  9.             if (message instanceof ObjectMessage) {

  10.  

  11.             }

  12.         }

  13.         catch (Exception e) {

  14.             logger.error("消息处理异常", e);

  15.         }

  16.     }


  18. }

点击(此处)折叠或打开

  1. @Component

  2. @EnableJms

  3. public class ServiceDemoListener extends AbstractListener {


  5.     @JmsListener(containerFactory = "jmsListenerContainerFactory", destination = "serviceDemoQueue")

  6.     public void onMessage(Message message) {


  8.         try {

  9.             if (message instanceof ObjectMessage) {

  10.  

  11.             }

  12.         }

  13.         catch (Exception e) {

  14.             logger.error("消息处理异常", e);

  15.         }

  16.     }


  18. }

点击(此处)折叠或打开

  1. @Component

  2. public class ServiceDemoSchedule {


  4.     @Autowired

  5.     private GmcSmsInfoBo gmcSmsInfoBo;


  7.     @Scheduled(cron = "0 0/1 * * * ?")

  8.     public void work() {

  9.         System.out.println("========Good byte!!=======");


  11.         GmcSmsInfo smsInfo = new GmcSmsInfo();

  12.         smsInfo.setChannel("test");

  13.         smsInfo.setContent("test");

  14.         smsInfo.setStatus("01");

  15.         smsInfo.setCreateDate(Calendar.getInstance().getTime());

  16.         smsInfo.setMobile("99999999999");


  18.         try {

  19.             gmcSmsInfoBo.add(smsInfo);

  20.             

  21.             System.out.println(null==gmcSmsInfoBo.query(11386));

  22.             System.out.println(null==gmcSmsInfoBo.query(11401));

  23.         }

  24.         catch (BusinessServiceException e) {

  25.             e.printStackTrace();

  26.         }


  28.     }


  30. }

  1. @Service("gmcSmsInfoBo")

  2. public class GmcSmsInfoBo extends AbstractBusinessObject {


  4.     @Autowired

  5.     private GmcSmsInfoDAO gmcSmsInfoDaoImpl;


  7.     @CachePut(value = "GmcSmsInfoCache", key = "'GmcSmsInfo_'+#result.smsId")

  8.     @Transactional(rollbackFor={Exception.class,RuntimeException.class})

  9.     public GmcSmsInfo add(GmcSmsInfo smsInfo) throws BusinessServiceException {

  10.         System.out.println("=============add==========");

  11.         try {

  12.             smsInfo.setSmsId(gmcSmsInfoDaoImpl.save(smsInfo));

  13.         }

  14.         catch (FrameworkDAOException e) {

  15.             throw new BusinessServiceException(e);

  16.         }

  17.         return smsInfo;

  18.     }


  20.     @Cacheable(value="GmcSmsInfoCache",key="'GmcSmsInfo_'+#smsId")

  21.     public GmcSmsInfo query(Integer smsId) throws BusinessServiceException {

  22.         System.out.println("=============query==========");

  23.         try {

  24.             return gmcSmsInfoDaoImpl.findById(GmcSmsInfo.class, smsId);

  25.         }

  26.         catch (Exception e) {

  27.             throw new BusinessServiceException(e);

  28.         }

  29.     }


  31. }

到此，相信大家对“Quartz注解方式怎么配置”有了更深的了解，不妨来实际操作一番吧！这里是天达云网站，更多相关内容可以进入相关频道进行查询，关注我们，继续学习！
返回开发技术教程...
400-837-6568
7 * 24小时全天全国服务热线400电话
天达云·专业的云计算服务平台 全国400服务电话：400-837-6568
Copyright © 2011-2025 Tdyun.com. All Rights Reserved. 天达云 版权所有 粤ICP备18083267号-7