Spring Cloud Task, развернутый на PCF, не завершается при завершении TaskExecution

Я пытаюсь разместить приложение облачных задач Spring на PCF и запускать задачу ежечасно с помощью заданий CRON планировщика PCF. Однако в рамках задачи я должен опубликовать сообщение на бирже RabbitMQ. Экземпляр RabbitMQ - это RabbitMQ в службе PCF, которая привязана к приложению задачи. Когда я запускаю задачу, выполнение задачи завершается, но приложение не закрывается, в результате чего экземпляр задачи постоянно находится в рабочем состоянии.

Это код моего класса приложения.

package com.example.demo;

import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.CommandLineRunner;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.task.configuration.EnableTask;

@EnableTask
@SpringBootApplication
public class DemoApplication implements CommandLineRunner {

    final String topicExchangeName = "demo-exchange";

    @Autowired
    RabbitTemplate rabbitTemplate;

    public static void main(String[] args) {

        SpringApplication.run(DemoApplication.class, args).close();
    }

    @Override
    public void run(String... args) throws Exception {

        System.out.println("Hello Task Demo!");
            rabbitTemplate.convertAndSend(topicExchangeName, "HLT", "Hello Task!");
        }

    }

Это файл application.properties

logging.level.org.springframework.cloud.task=DEBUG
spring.application.name=helloTaskApp
spring.cloud.task.closecontext_enable=true
spring.cloud.task.events.enabled=false

Ниже приведены журналы запуска задачи.

2019-02-11T17:20:47.468+05:30 [APP/TASK/sample-task/0] [OUT] :: Spring Boot :: (v2.1.2.RELEASE)
2019-02-11T17:20:47.468+05:30 [APP/TASK/sample-task/0] [OUT] =========|_|==============|___/=/_/_/_/
2019-02-11T17:20:47.468+05:30 [APP/TASK/sample-task/0] [OUT] ' |____| .__|_| |_|_| |_\__, | / / / /
2019-02-11T17:20:47.468+05:30 [APP/TASK/sample-task/0] [OUT] \\/ ___)| |_)| | | | | || (_| | ) ) ) )
2019-02-11T17:20:47.468+05:30 [APP/TASK/sample-task/0] [OUT] ( ( )\___ | '_ | '_| | '_ \/ _` | \ \ \ \
2019-02-11T17:20:47.468+05:30 [APP/TASK/sample-task/0] [OUT] /\\ / ___'_ __ _ _(_)_ __ __ _ \ \ \ \
2019-02-11T17:20:47.468+05:30 [APP/TASK/sample-task/0] [OUT] . ____ _ __ _ _
2019-02-11T17:20:47.652+05:30 [APP/TASK/sample-task/0] [OUT] 2019-02-11 11:50:47.649 INFO 10 --- [ main] pertySourceApplicationContextInitializer : 'cloud' property source added
2019-02-11T17:20:47.653+05:30 [APP/TASK/sample-task/0] [OUT] 2019-02-11 11:50:47.653 INFO 10 --- [ main] nfigurationApplicationContextInitializer : Reconfiguration enabled
2019-02-11T17:20:47.661+05:30 [APP/TASK/sample-task/0] [OUT] 2019-02-11 11:50:47.661 INFO 10 --- [ main] com.example.demo.DemoApplication : The following profiles are active: cloud
2019-02-11T17:20:47.661+05:30 [APP/TASK/sample-task/0] [OUT] 2019-02-11 11:50:47.660 INFO 10 --- [ main] com.example.demo.DemoApplication : Starting DemoApplication on 91defac2-7964-41f1-8b39-096c9e32ca32 with PID 10 (/home/vcap/app/BOOT-INF/classes started by vcap in /home/vcap/app)
2019-02-11T17:20:48.304+05:30 [APP/TASK/sample-task/0] [OUT] 2019-02-11 11:50:48.303 INFO 10 --- [ main] o.c.reconfiguration.CloudServiceUtils : 'rabbitConnectionFactory' bean of type with 'org.springframework.amqp.rabbit.connection.ConnectionFactory' reconfigured with 'rabbit-1' bean
2019-02-11T17:20:48.327+05:30 [APP/TASK/sample-task/0] [OUT] 2019-02-11 11:50:48.327 INFO 10 --- [ main] trationDelegate$BeanPostProcessorChecker : Bean 'org.springframework.amqp.rabbit.annotation.RabbitBootstrapConfiguration' of type [org.springframework.amqp.rabbit.annotation.RabbitBootstrapConfiguration$$EnhancerBySpringCGLIB$$ec22c458] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
2019-02-11T17:20:48.505+05:30 [APP/TASK/sample-task/0] [OUT] 2019-02-11 11:50:48.505 DEBUG 10 --- [ main] o.s.c.t.c.DefaultTaskConfigurer : No DataSource was found, using ResourcelessTransactionManager
2019-02-11T17:20:48.505+05:30 [APP/TASK/sample-task/0] [OUT] 2019-02-11 11:50:48.505 DEBUG 10 --- [ main] o.s.c.t.c.SimpleTaskAutoConfiguration : Using org.springframework.cloud.task.configuration.DefaultTaskConfigurer TaskConfigurer
2019-02-11T17:20:48.864+05:30 [APP/TASK/sample-task/0] [OUT] 2019-02-11 11:50:48.863 DEBUG 10 --- [ main] o.s.c.t.r.support.SimpleTaskRepository : Creating: TaskExecution{executionId=0, parentExecutionId=null, exitCode=null, taskName='helloTaskApp', startTime=Mon Feb 11 11:50:48 UTC 2019, endTime=null, exitMessage='null', externalExecutionId='null', errorMessage='null', arguments=[]}
2019-02-11T17:20:48.872+05:30 [APP/TASK/sample-task/0] [OUT] 2019-02-11 11:50:48.872 INFO 10 --- [ main] com.example.demo.DemoApplication : Started DemoApplication in 1.742 seconds (JVM running for 2.43)
2019-02-11T17:20:48.873+05:30 [APP/TASK/sample-task/0] [OUT] Hello Task Demo!
2019-02-11T17:20:48.876+05:30 [APP/TASK/sample-task/0] [OUT] 2019-02-11 11:50:48.876 INFO 10 --- [ main] o.s.a.r.c.CachingConnectionFactory : Attempting to connect to: [*****]
2019-02-11T17:20:49.017+05:30 [APP/TASK/sample-task/0] [OUT] 2019-02-11 11:50:49.016 INFO 10 --- [ main] o.s.a.r.c.CachingConnectionFactory : Created new connection: SpringAMQP#fdefd3f:0/SimpleConnection@527e5409 [delegate=amqp://[email protected]:5672/ac4af8cd-c6ff-4da2-a645-b14f27eea150, localPort= 55422]
2019-02-11T17:20:49.051+05:30 [APP/TASK/sample-task/0] [OUT] 2019-02-11 11:50:49.051 DEBUG 10 --- [ main] o.s.c.t.r.support.SimpleTaskRepository : Updating: TaskExecution with executionId=0 with the following {exitCode=0, endTime=Mon Feb 11 11:50:49 UTC 2019, exitMessage='null', errorMessage='null'}

Я использую команду ".java-buildpack / open_jdk_jre / bin / java org.springframework.boot.loader.JarLauncher" для запуска задачи.

Он работает нормально на локальном компьютере, но добавление RabbitTemplate, похоже, каким-то образом не позволяет закрыть контекст приложения. Может ли кто-нибудь помочь мне понять, почему это происходит?


spring-boot rabbitmq spring-cloud-task
person sohamangoes    schedule 11.02.2019    source источник

Ответы (2)


arrow_upward
1
arrow_downward

Не уверен, что это проблема, но мы столкнулись с этим после весеннего обновления одной из наших задач. Основная причина вашей / нашей проблемы, похоже, связана с этим изменением . Я предполагаю, что проблема, связанная с этим, - 462.

Имея это в виду, вы были близки к решению, за исключением того, что свойство должно было быть таким

spring.cloud.task.closecontextEnabled=true

Вы можете ссылаться на класс TaskProperties

person naav    schedule 02.04.2019
comment
Пробовал, похоже, не сработало. Я добавлю то, что я сделал, в качестве обходного пути, в список ответов - person sohamangoes; 25.06.2019
comment
У меня аналогичная проблема, и свойство closecontextEnabled, похоже, не помогает мне. @SohamBasu, что вы сделали? - person Zetten; 11.03.2020
comment
@Zetten Немедленным обходным путем, который мы сделали, было явное уничтожение нашего bean-компонента RabbitTemplate сразу после завершения выполнения Task. Это сработало хорошо, но нам также нужен был bean-компонент репозитория Spring Data Cassandra, поэтому это означало бы, что любая зависимость, настроенная облачным профилем в пакете сборки, должна быть явно уничтожена. Я опубликовал фактическое исправление в ответе, вы можете проверить это. Если вы предпочитаете обходной путь, просто обратитесь к этому примеру - person sohamangoes; 07.04.2020

arrow_upward
0
arrow_downward

Это связано с тем, что «облачный» профиль добавляется пакетом сборки на PCF. То же самое вы можете увидеть в моих журналах и в вопросе.

Добавление этой переменной среды в manifest.yml

env:
    JBP_CONFIG_SPRING_AUTO_RECONFIGURATION: '{enabled: false}'

Это предотвратило загрузку сборочного пакета jar-файлов автоконфигурации облака и остановку приложения после запуска задачи. Оглядываясь назад, можно сказать, что это скорее проблема с пакетом сборки Cloudfoundry, чем с весенней облачной задачей.

person sohamangoes    schedule 07.04.2020