【发布时间】:2018-01-03 12:45:04
【问题描述】:
我学习了 Spring Cloud Task 并编写了简单的应用程序,该应用程序分为 3 个服务。第一个是TaskApplication,它只有main()并实现CommandLineRunner,第二个是TaskIntakeApplication,它接收请求并将它们发送到RabbitMQ,第三个服务是一个TaskLauncherApplication,它从RabbitMQ接收消息并运行任务接收到的参数。
@Component
@EnableBinding(Source.class)
public class TaskProcessor {
@Autowired
private Source source;
public void publishRequest(String arguments) {
final String url = "maven://groupId:artifatcId:jar:version";
final List<String> args = Arrays.asList(arguments.split(","));
final TaskLaunchRequest request = new TaskLaunchRequest(url, args, null, null, "TaskApplication");
final GenericMessage<TaskLaunchRequest> message = new GenericMessage<>(request);
source.output().send(message);
}
}
如您所见,我通过提供 maven url 来调用我构建的工件,但我想知道如何从另一个 docker 容器调用工件?
【问题讨论】:
标签: spring docker spring-cloud-stream spring-cloud-task