当前位置: 首页 > 知识库问答 >
问题:

我们可以在spring批处理中为请求/回复用例使用AmqpItemReader和AmqpItermWriter吗?

华星驰
2023-03-14

我已经看到了AmqpJobSample

http://docs.spring.io/spring-batch/spring-batch-samples/#AMQPJobFunctionalTests

有没有使用消息传递(例如RabbiyMq)进行远程分块和分区的示例

如何使用AmqpItemReader和AmqpItemWriter实现这一点?我需要使用请求/答复吗?我可以设置回复队列吗?做这件事最好的方法是什么?

共有1个答案

弓温书
2023-03-14

听起来你应该改用远程分块。

 类似资料:
  • 但它不止一次地使用消息。有没有人面对过这个问题。此外,使用上述配置,使用者总是在一个批处理中只接收到一个消息。我尝试增加和,但没有任何影响。 在对ConcurrentKafkaListenerContainerFactory进行如下更改后,批处理配置的问题得到了解决: factory.getContainerProperties().SetackMode(org.springFramework.k

  • 我有几个单独的规则。例如,现在我有3套不同的规则要执行。根据输入参数,在任何时候都要执行一组规则。假设第一组有5条规则,第二组有7条规则,第三组有5条规则。现在,所有这些集合可能都有公共规则,我想引用它们,而不是在每个集合中编写3次规则。如何在流口水时做到这一点?明天,如果我进行了更新,我应该只能对规则进行一次更改,并且此更改应反映在所有集合中。请就此提出建议。。。。。 谢谢

  • 根据Spring batch文档,是作为Spring batch 3.0的一部分引入的。但是,看起来JobScope注释在Spring Batch3.0JAR中不可用。我在中指定了依赖项,如下所示: 当我将更改为时,注释会按预期找到。我的理解是是作为spring Batch3.0的一部分引入的,因此应该可以在从3.0.0开始的任何spring batch jar中使用。 为什么注释在3.0.0版中

  • 问题内容: 我们可以在 finally 块中使用return语句吗?这会引起任何问题吗? 问题答案: 从块内部返回会导致丢失。 finally块中的return语句将导致任何在try或catch块中引发的异常都将被丢弃。 根据 Java语言规范: 如果由于任何其他原因R导致try块的执行突然完成,则执行finally块,然后可以选择: 注意:根据 JLS 14.17 ,return语句总是突然完成

  • 问题内容: 我有这个控制器方法: 但是,当我向该端点发送发布请求时,得到以下信息 当我从注释中删除params参数时,我得到了一个更一般的错误,它将说它找不到第一个必需的参数(开始),而实际上它与参数end,hours和username一起发送。 如何在Spring MVC中获取方法中的参数? 我在这篇文章中读到了只能用于get方法的内容,但是如果我删除并坚持使用批注的params参数,它仍然无法