我们可以在spring批处理中为请求/回复用例使用AmqpItemReader和AmqpItermWriter吗？
我已经看到了AmqpJobSample
http://docs.spring.io/spring-batch/spring-batch-samples/#AMQPJobFunctionalTests
有没有使用消息传递（例如RabbiyMq）进行远程分块和分区的示例？
如何使用AmqpItemReader和AmqpItemWriter实现这一点？我需要使用请求/答复吗？我可以设置回复队列吗？做这件事最好的方法是什么？
共有1个答案
听起来你应该改用远程分块。
-
但它不止一次地使用消息。有没有人面对过这个问题。此外，使用上述配置，使用者总是在一个批处理中只接收到一个消息。我尝试增加和，但没有任何影响。 在对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语句总是突然完成
-
我们使用RESTEasy编写了Web API。我们希望以Google Batch请求处理的方式为Batch请求处理提供支持。 以下是目前使用的方法， 我们有一个过滤器，它接受传入的多部分请求。然后，此过滤器创建多个模拟请求和响应对象，然后调用链。doFilter使用这些模拟请求。 MockHttpServletResponse类返回一个虚拟的OutputStream，它将通过TearayoutPu
-
问题内容： 我有这个控制器方法： 但是，当我向该端点发送发布请求时，得到以下信息 当我从注释中删除params参数时，我得到了一个更一般的错误，它将说它找不到第一个必需的参数（开始），而实际上它与参数end，hours和username一起发送。 如何在Spring MVC中获取方法中的参数？ 我在这篇文章中读到了只能用于get方法的内容，但是如果我删除并坚持使用批注的params参数，它仍然无法