1

我正在尝试使用spring集成和amqp（rabbitmq）在spring批处理中实现远程分块。

我无法理解 ChunkMessageChannelItemWriter 如何在下面的远程分块测试中收集回复

https://github.com/spring-projects/spring-batch/blob/master/spring-batch-integration/src/test/resources/org/springframework/batch/integration/chunk/RemoteChunkStepIntegrationTests-context.xml

它是如何工作的 ？它是否发送一条消息，等待其回复，接收其回复，然后再次发送第二条消息，等待第二条消息回复并接收第二条消息回复，依此类推？

或者它异步发送所有消息并等待回复，然后在回复通道到达回复时接收回复？

如果我们在这里参考远程分块文档

http://docs.spring.io/spring-batch/reference/html/springBatchIntegration.html#asynchronous-processors

它使用入站和出站适配器。如果 ChunkMessageChannelItemWriter 收到回复，为什么我们需要适配器？在从机端，为什么同时使用适配器和服务激活器？

任何人都可以帮助我理解它是如何工作的，因为它很难从文档中理解。

4

1 回答 1

1

这只是一个测试用例 - 一切都在本地运行 - 查看JMS 测试用例以获得更真实的示例。通道项编写器使用出站通道适配器将所有块发送到 JMS。

远程端（jms 侦听器容器）接收块，处理它们并将回复发送到replies队列。

每次调用 writer 写入块时，它都会检查回复并在必要时挂起，如果超过了节流限制。

当所有块都被写入时afterStep()，它会等待其余的结果。

这一切都与本地测试用例相同，因为块处理程序将回复写入队列通道。

于 2014-06-04T13:06:10.627 回答