0
私はX秒ごとにいくつかのタスクを実行しようとしていますが、タスクはtwiseを実行しています。私は春の4.2.5を使用しています - 。最新バージョンは、ここSpring 4 @スケジューリングされたタスクはタスクを2回実行しています
@Service
@Transactional
@EnableScheduling
public class PaymentServices {
@Autowired
private MMTransactionDAO mmTransactionDAO;
@Scheduled(fixedDelay=230000)
public void getListOfPenddingTransactions() throws MambuApiException {
System.out.println("JOB Started");
List<MMPayTransaction> listOfPenddingTransaction = mmTransactionDAO.getListOfPenddingTransaction();
for(MMPayTransaction transaction : listOfPenddingTransaction){
if (transaction.getErrorcode().equals("-6")){
cancelTransactionInMambu(transaction.getMambuClientID(),transaction.getPaymentAmount(),transaction.getFeeAmount());
transaction.setFinalStatus(TansactionStatus.FAILED);
}else if(transaction.getErrorcode().equals("-21")){
cancelTransactionInMambu(transaction.getMambuClientID(),transaction.getPaymentAmount(),transaction.getFeeAmount());
transaction.setFinalStatus(TansactionStatus.FAILED);
}else if(transaction.getErrorcode().equals("-18")){
cancelTransactionInMambu(transaction.getMambuClientID(),transaction.getPaymentAmount(),transaction.getFeeAmount());
transaction.setFinalStatus(TansactionStatus.FAILED);
}else if (transaction.getErrorcode().equals("-37")){
cancelTransactionInMambu(transaction.getMambuClientID(),transaction.getPaymentAmount(),transaction.getFeeAmount());
transaction.setFinalStatus(TansactionStatus.FAILED);
}
else{
check(transaction.getOperationID());
}
}
}
}
（私は4.05同じ結果でそれをしようと試みたが）を更新し、私のweb.xmlの
<web-app version="2.4"
xmlns="http://java.sun.com/xml/ns/j2ee" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://java.sun.com/xml/ns/j2ee
http://java.sun.com/xml/ns/j2ee/web-app_2_4.xsd">
<display-name>Spring MVC Application</display-name>
<servlet>
<servlet-name>mvc-dispatcher</servlet-name>
<servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>
<load-on-startup>1</load-on-startup>
</servlet>
<servlet-mapping>
<servlet-name>mvc-dispatcher</servlet-name>
<url-pattern>/</url-pattern>
</servlet-mapping>
<filter>
<filter-name>CharacterEncodingFilter</filter-name>
<filter-class>org.springframework.web.filter.CharacterEncodingFilter</filter-class>
<init-param>
<param-name>encoding</param-name>
<param-value>UTF-8</param-value>
</init-param>
<init-param>
<param-name>forceEncoding</param-name>
<param-value>true</param-value>
</init-param>
</filter>
<filter-mapping>
<filter-name>CharacterEncodingFilter</filter-name>
<url-pattern>/*</url-pattern>
</filter-mapping>
<filter>
<filter-name>encodingFilter</filter-name>
<filter-class>org.springframework.web.filter.CharacterEncodingFilter</filter-class>
<init-param>
<param-name>encoding</param-name>
<param-value>UTF-8</param-value>
</init-param>
<init-param>
<param-name>forceEncoding</param-name>
<param-value>true</param-value>
</init-param>
</filter>
<filter-mapping>
<filter-name>encodingFilter</filter-name>
<url-pattern>/*</url-pattern>
</filter-mapping>
です
ここは私のアプリケーションの設定です。
@EnableWebMvc
@Configuration
@ComponentScan({"ge.kapi.*"})
@EnableTransactionManagement
public class AppConfig extends WebMvcConfigurerAdapter {
@Bean
public LocalContainerEntityManagerFactoryBean entityManagerFactory()
{
LocalContainerEntityManagerFactoryBean factory = new LocalContainerEntityManagerFactoryBean();
HibernateJpaVendorAdapter vendorAdapter = new HibernateJpaVendorAdapter();
vendorAdapter.setGenerateDdl(Boolean.TRUE);
vendorAdapter.setShowSql(Boolean.TRUE);
factory.setDataSource(dataSource());
factory.setJpaVendorAdapter(vendorAdapter);
factory.setPackagesToScan("ge.kapi");
Properties jpaProperties = getHibernateProperties();
factory.setJpaProperties(jpaProperties);
factory.afterPropertiesSet();
factory.setLoadTimeWeaver(new InstrumentationLoadTimeWeaver());
return factory;
}
private Properties getHibernateProperties() {
Properties prop = new Properties();
prop.put("hibernate.show_sql", "true");
prop.put("hibernate.dialect","ge.kapi.config.SQLServerUnicodeDialect");
return prop;
}
@Bean(name = "dataSource")
public BasicDataSource dataSource() {
BasicDataSource ds = new BasicDataSource();
ds.setDriverClassName("com.microsoft.sqlserver.jdbc.SQLServerDriver");
ds.setUrl("jdbc:sqlserver://host;useUnicode=true;characterEncoding=UTF-8;DatabaseName=Base");
ds.setUsername("user");
ds.setPassword("pass");
return ds;
}
@Bean
public StringHttpMessageConverter stringHttpMessageConverter() {
return new StringHttpMessageConverter(Charset.forName("UTF-8"));
}
@Bean
public PlatformTransactionManager transactionManager()
{
EntityManagerFactory factory = entityManagerFactory().getObject();
return new JpaTransactionManager(factory);
}
@Bean
public InternalResourceViewResolver viewResolver() {
InternalResourceViewResolver viewResolver
= new InternalResourceViewResolver();
viewResolver.setViewClass(JstlView.class);
viewResolver.setContentType("text/html; charset=UTF-8");
viewResolver.setPrefix("/WEB-INF/views/");
viewResolver.setSuffix(".jsp");
return viewResolver;
}
@Override
public void addResourceHandlers(ResourceHandlerRegistry registry) {
registry.addResourceHandler("/resources/**").addResourceLocations("/resources/");
}
なぜ毎回TWICEが実行されますか？事前に
おかげ
- 見つかりソリューション -
このスキャンもから開始されたので、私はAppConfig.javaから@ComponentScan（{ "ge.kapi *を"}）削除されましたmvc-dispatcher-servlet.xmlは次のようになります。
<context:component-scan base-package="ge.kapi"/>
今すぐジョブが開始されます。
ありがとうございました！
どのような種類の展開環境を使用していますか？クラスタ化された環境にデプロイしている場合は、サーバーごとに@Scheduledメソッドが起動されます –
実際には、今私はIntellij IDEの - tomcat 8で実行しています。 – Irakli
本当に2回実行されているか、メッセージを2回だけ印刷するようにロギングをミスしたことがありますか？ – questionare