Quartz注解方式怎么配置

本篇内容主要讲解“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
   

10. 
    

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
    

21. 
    

22. 
    

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
    

29. 
    

30. redis.pool.maxActive=1024
    

31. redis.pool.maxIdle=200
    

32. redis.pool.maxWait=1000
    

33. redis.pool.testOnBorrow=true
    

34. 
    

35. 
    

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

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

38. 
    

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. #=======================================================================================
   

2. 
   

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 {
   

8. 
   

9. }

1. @Configuration
   

2. public class CachingElConfig {
   

3. 
   

4.     @Autowired
   

5.     @Qualifier("jedisConnectionFactory")
   

6.     private JedisConnectionFactory jedisConnectionFactory;
   

7. 
   

8.     @Autowired
   

9.     @Qualifier("keySerializer")
   

10.     private StringRedisSerializer keySerializer;
    

11. 
    

12.     @Autowired
    

13.     @Qualifier("valueSerializer")
    

14.     private JdkSerializationRedisSerializer valueSerializer;
    

15. 
    

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.     }
    

27. 
    

28.     @Bean
    

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

30.         RedisCacheManager cacheManager = new RedisCacheManager(redisTemplate);
    

31.         // 设置过期时间
    

32.        // cacheManager.setDefaultExpiration(10);
    

33.         return cacheManager;
    

34. 
    

35.     }
    

36. }

1. @Configuration
   

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

3. public class DataSourceElConfig {
   

4. 
   

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

6. 
   

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;
    

25. 
    

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;
    

44. 
    

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;
    

51. 
    

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;
    

62. 
    

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;
    

76. 
    

77.     @Autowired
    

78.     private Environment environment;
    

79. 
    

80.     @Bean
    

81.     public static PropertySourcesPlaceholderConfigurer propertyConfigure() {
    

82.         return new PropertySourcesPlaceholderConfigurer();
    

83.     }
    

84. 
    

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.     }
     

111. 
     

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.     }
     

138. 
     

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.     }
     

153. 
     

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.     }
     

166. 
     

167.     @Bean(name = "keySerializer")
     

168.     public StringRedisSerializer keySerializer() {
     

169.         return new StringRedisSerializer();
     

170.     }
     

171. 
     

172.     @Bean(name = "valueSerializer")
     

173.     public JdkSerializationRedisSerializer valueSerializer() {
     

174.         return new JdkSerializationRedisSerializer();
     

175.     }
     

176. 
     

177.     /**
     

178.      * MongoDB 配置
     

179.      *
     

180.      * @return
     

181.      */
     

182.     @Bean(name = "mongoDbFactory")
     

183.     public MongoDbFactory mongoDbFactory() throws Exception {
     

184. 
     

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.     }
     

192. 
     

193.     @Bean(name="mongoConverter")
     

194.     public MongoConverter mongoConverter(MongoDbFactory mongoDbFactory) {
     

195. 
     

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 {
   

4. 
   

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

6. 
   

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;
    

25. 
    

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;
    

44. 
    

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;
    

51. 
    

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;
    

62. 
    

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;
    

76. 
    

77.     @Autowired
    

78.     private Environment environment;
    

79. 
    

80.     @Bean
    

81.     public static PropertySourcesPlaceholderConfigurer propertyConfigure() {
    

82.         return new PropertySourcesPlaceholderConfigurer();
    

83.     }
    

84. 
    

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.     }
     

111. 
     

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.     }
     

138. 
     

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.     }
     

153. 
     

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.     }
     

166. 
     

167.     @Bean(name = "keySerializer")
     

168.     public StringRedisSerializer keySerializer() {
     

169.         return new StringRedisSerializer();
     

170.     }
     

171. 
     

172.     @Bean(name = "valueSerializer")
     

173.     public JdkSerializationRedisSerializer valueSerializer() {
     

174.         return new JdkSerializationRedisSerializer();
     

175.     }
     

176. 
     

177.     /**
     

178.      * MongoDB 配置
     

179.      *
     

180.      * @return
     

181.      */
     

182.     @Bean(name = "mongoDbFactory")
     

183.     public MongoDbFactory mongoDbFactory() throws Exception {
     

184. 
     

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.     }
     

192. 
     

193.     @Bean(name="mongoConverter")
     

194.     public MongoConverter mongoConverter(MongoDbFactory mongoDbFactory) {
     

195. 
     

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 {
   

3. 
   

4.     @Autowired
   

5.     @Qualifier("cachingConnectionFactory")
   

6.     private CachingConnectionFactory cachingConnectionFactory;
   

7. 
   

8.     @Bean(name = "jmsTemplate")
   

9.     public JmsTemplate jmsTemplate() {
   

10.         JmsTemplate jmsTemplate = new JmsTemplate();
    

11.         jmsTemplate.setConnectionFactory(cachingConnectionFactory);
    

12.         return jmsTemplate;
    

13.     }
    

14. 
    

15.     @Bean(name = "serviceDemoDestination")
    

16.     public Destination serviceDemoDestination() {
    

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

18.         return serviceDemoQueue;
    

19. 
    

20.     }
    

21. 
    

22.     @Bean(name = "jmsListenerContainerFactory")
    

23.     public JmsListenerContainerFactory<DefaultMessageListenerContainer> jmsListenerContainerFactory() {
    

24.         DefaultJmsListenerContainerFactory jmsListenerContainerFactory = new DefaultJmsListenerContainerFactory();
    

25.         jmsListenerContainerFactory.setConnectionFactory(cachingConnectionFactory);
    

26.         return jmsListenerContainerFactory;
    

27.     }
    

28. 
    

29. }

点击(此处)折叠或打开

1. @Configuration
   

2. public class MongoElConfig {
   

3. 
   

4.     @Autowired
   

5.     @Qualifier("mongoDbFactory")
   

6.     private MongoDbFactory mongoDbFactory;
   

7. 
   

8.     @Autowired
   

9.     @Qualifier("mongoConverter")
   

10.     private MongoConverter mongoConverter;
    

11. 
    

12.     @Bean(name = "mongoTemplate")
    

13.     public MongoTemplate mongoTemplate() {
    

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

15.         return mongoTemplate;
    

16. 
    

17.     }
    

18. 
    

19. }

点击(此处)折叠或打开

1. @Configuration
   

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

3. public class SystemElConfig {
   

4. 
   

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

6.     private String mailHost;
   

7. 
   

8.     @Autowired
   

9.     private Environment environment;
   

10. 
    

11.     @Bean
    

12.     public static PropertySourcesPlaceholderConfigurer propertyConfigure() {
    

13.         return new PropertySourcesPlaceholderConfigurer();
    

14.     }
    

15. 
    

16.     /**
    

17.      * @return the mailHost
    

18.      */
    

19.     public String getMailHost() {
    

20.         return mailHost;
    

21.     }
    

22. 
    

23.     /**
    

24.      * @param mailHost
    

25.      *            the mailHost to set
    

26.      */
    

27.     public void setMailHost(String mailHost) {
    

28.         this.mailHost = mailHost;
    

29.     }
    

30. 
    

31. }

点击(此处)折叠或打开

1. @Configuration
   

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

3. public class SystemElConfig {
   

4. 
   

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

6.     private String mailHost;
   

7. 
   

8.     @Autowired
   

9.     private Environment environment;
   

10. 
    

11.     @Bean
    

12.     public static PropertySourcesPlaceholderConfigurer propertyConfigure() {
    

13.         return new PropertySourcesPlaceholderConfigurer();
    

14.     }
    

15. 
    

16.     /**
    

17.      * @return the mailHost
    

18.      */
    

19.     public String getMailHost() {
    

20.         return mailHost;
    

21.     }
    

22. 
    

23.     /**
    

24.      * @param mailHost
    

25.      *            the mailHost to set
    

26.      */
    

27.     public void setMailHost(String mailHost) {
    

28.         this.mailHost = mailHost;
    

29.     }
    

30. 
    

31. }

点击(此处)折叠或打开

1. @Configuration
   

2. public class TransactionManagerElConfig {
   

3. 
   

4.     @Autowired
   

5.     @Qualifier("platformTomcat")
   

6.     private DataSource platformTomcat;
   

7. 
   

8.     @Autowired
   

9.     @Qualifier("platformReadTomcat")
   

10.     private DataSource platformReadTomcat;
    

11. 
    

12.     @Bean(name = "jdbcTemplate")
    

13.     public JdbcTemplate jdbcTemplate() {
    

14.         JdbcTemplate jdbcTemplate = new JdbcTemplate();
    

15.         jdbcTemplate.setDataSource(platformTomcat);
    

16.         return jdbcTemplate;
    

17.     }
    

18. 
    

19.     @Bean(name = "jdbcReadTemplate")
    

20.     public JdbcTemplate jdbcReadTemplate() {
    

21.         JdbcTemplate jdbcReadTemplate = new JdbcTemplate();
    

22.         jdbcReadTemplate.setDataSource(platformReadTomcat);
    

23.         return jdbcReadTemplate;
    

24.     }
    

25. 
    

26.     @Bean(name = "transactionManager")
    

27.     public DataSourceTransactionManager transactionManager() {
    

28.         DataSourceTransactionManager transactionManager = new DataSourceTransactionManager();
    

29.         transactionManager.setDataSource(platformTomcat);
    

30.         return transactionManager;
    

31.     }
    

32. 
    

33. }

四：Demo

点击(此处)折叠或打开

1. public class App {
   

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

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

4. 
   

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"));
   

10. 
    

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

12. 
    

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

14. 
    

15.     }
    

16. }

点击(此处)折叠或打开

1. @Service
   

2. public class ServiceDemo {
   

3. 
   

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

5.     private String mailHost;
   

6. 
   

7.     public void print() {
   

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

9.     }
   

10. 
    

11. }

点击(此处)折叠或打开

1. @Service
   

2. public class ServiceDemo {
   

3. 
   

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

5.     private String mailHost;
   

6. 
   

7.     public void print() {
   

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

9.     }
   

10. 
    

11. }

点击(此处)折叠或打开

1. @Service
   

2. public class ServiceDemo {
   

3. 
   

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

5.     private String mailHost;
   

6. 
   

7.     public void print() {
   

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

9.     }
   

10. 
    

11. }

点击(此处)折叠或打开

1. @Component
   

2. @EnableJms
   

3. public class ServiceDemoListener extends AbstractListener {
   

4. 
   

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

6.     public void onMessage(Message message) {
   

7. 
   

8.         try {
   

9.             if (message instanceof ObjectMessage) {
   

10.  
    

11.             }
    

12.         }
    

13.         catch (Exception e) {
    

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

15.         }
    

16.     }
    

17. 
    

18. }

点击(此处)折叠或打开

1. @Component
   

2. @EnableJms
   

3. public class ServiceDemoListener extends AbstractListener {
   

4. 
   

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

6.     public void onMessage(Message message) {
   

7. 
   

8.         try {
   

9.             if (message instanceof ObjectMessage) {
   

10.  
    

11.             }
    

12.         }
    

13.         catch (Exception e) {
    

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

15.         }
    

16.     }
    

17. 
    

18. }

点击(此处)折叠或打开

1. @Component
   

2. public class ServiceDemoSchedule {
   

3. 
   

4.     @Autowired
   

5.     private GmcSmsInfoBo gmcSmsInfoBo;
   

6. 
   

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

8.     public void work() {
   

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

10. 
    

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");
    

17. 
    

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.         }
    

27. 
    

28.     }
    

29. 
    

30. }

1. @Service("gmcSmsInfoBo")
   

2. public class GmcSmsInfoBo extends AbstractBusinessObject {
   

3. 
   

4.     @Autowired
   

5.     private GmcSmsInfoDAO gmcSmsInfoDaoImpl;
   

6. 
   

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.     }
    

19. 
    

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.     }
    

30. 
    

31. }

到此，相信大家对“Quartz注解方式怎么配置”有了更深的了解，不妨来实际操作一番吧！这里是亿速云网站，更多相关内容可以进入相关频道进行查询，关注我们，继续学习！