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 redisTemplate() {
    

18. RedisTemplate 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 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 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注解方式怎么配置"有了更深的了解，不妨来实际操作一番吧！这里是网站，更多相关内容可以进入相关频道进行查询，关注我们，继续学习！