spring 异步返回结果_使用Spring Integration聚合异步结果

spring 异步返回结果

嗨,我遇到了一个问题,该问题使用Spring Integration解决方案非常好。 很多时候,我们需要一种将消息分发到未知数量的目的地的方案。 为此,我们使用主题方法。 但是有时,我们还希望从收到消息的所有目的地接收答案,并将其汇总为单个结果答案。 为此,我们可以使用结合了Aggregator和ReleaseStrategy接口的渠道。 在这篇文章中,我不会专注于“渠道实施”。

假设我们有一个生产者将其消息发送到主题。 现在我们有一个接收该消息的消费者。 使用网关和处理器接口,我们可以以任何所需的类型发送该消息:

public interface Processor
{public void sendResponse(String response);
}

消费者代码:

@Override public void onMessage(Message message)
{String resultMessage = "";try{processor.sendResponse(resultMessage);}catch (Exception e){log.error("Error while processing message in channel consumer. errorMsg=" + e.getMessage(), e);}
}

现在,该消息将被传递到一个通道(“在通道中”)。我们可以向该消息添加额外的信息(如果我们有不同的消息组)。 添加了额外的信息后,我们将该消息发送到另一个通道(“ Out通道”),这就是魔术:我们创建了两个pojo,稍后将使用XML配置将其绑定到接口。 发行策略:

public class ReleaseStrategy
{public boolean canRelease(List results){// check if all 5  subscribers sent responsesif (results.size() == 5){return true;}return false;}
}

聚合器:

public class Aggregator
{public String aggregate(List results){String finalResult= "SUCCESS_RESULT";for (String result: results) {if (result.equals("ERROR_RESULT")) {finalResult= "ERROR_RESULT";break;}}return finalResult;}
}

基本上,这里发生的事情是,在我们通过ReleaseStrategy接口的canRelease方法返回“ true”值之后,聚合器将能够接收聚合的消息并将单个结果分派到最终目的地(可能是另一个消息使用者将获得的队列并处理结果)Xml配置:

< ?xml version="1.0" encoding="UTF-8"?>

参考: IdanFridman.com博客上的JCG合作伙伴 Idan Fridman 使用Spring Integration聚合异步结果 。

翻译自: https://www.javacodegeeks.com/2013/06/aggregating-async-results-using-spring-integration.html

spring 异步返回结果

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/348145.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

ValueError( Shape(4, ?, 1, 20) and () are incompatible

报错&#xff1a; 解决&#xff1a; 将文件中的return tf.concat(axis, tensors) 改为&#xff1a;return tf.concat(tensors, axis)问题完美解决

adadelta算法_对C++用户比较友好的机器学习算法库

由于疫情影响&#xff0c;这几天在家学习编程&#xff0c;整理了基于c语言的机器学习算法库。目前大部分机器学习库都是面向pyhton语言的&#xff0c;尽管很python包的底层语言是c&#xff0c;但c用户使用起来很麻烦&#xff0c;这里整理了一些对c比较优化的机器学习算法库&…

不解析,使用解析对象

将面向对象的后端与外部系统集成的传统方式是通过数据传输对象 &#xff0c;这些对象在外出之前先序列化为JSON&#xff0c;然后在返回时反序列化。 这种方法很流行&#xff0c;而且是错误的。 序列化部分应该由打印机代替&#xff0c;我在前面已经解释过。 这是我对反序列化的…

yaml报错TypeError: load() missing 1 required positional argument: ‘Loader‘

添加一下命令即可&#xff1a; 我的操作&#xff1a; return yaml.load(config)改为 return yaml.full_load(config)问题完美解决

3d制作中需要注意的问题_珠宝首饰工艺篇-戒指3D造型设计制作注意要点

1、戒指的常规手寸数据和戒指外围周长计算公式应用参考如下图&#xff1a;戒指手寸内直径大小说明图1、戒指手寸规格有14号、15号、16号、17号、18号、19号、20号、&#xff0c;但是从开发角度来说比较常见规格是17号18号19号这几种规格比较多&#xff0c;那我们电脑3D建模的时…

微信推送封面尺寸_连封面图都搞不明白,做什么新时代的新媒体人?

嘿&#xff0c;胖友们大家好呀&#xff0c;我是三儿。又是精(bu)神(xiang)满(shang)满(ban)的周一啦&#xff0c;胖友们准备好开始迎接新的一周了吗&#xff01;为了迎接这个崭新的周一&#xff0c;三儿特意为你们准备的一些实用的小工具教学&#xff0c;帮助你们快速的完成工作…

2021总结

去年做了复盘&#xff0c;感觉很良好。以后希望把这个每年复盘一次的习惯能够好好坚持下去&#xff0c;再加上年初的规划就更好啦&#xff01;2021年&#xff0c;比起2020来说&#xff0c;就相对平静了很多&#xff0c;没经历过大风大浪&#xff0c;心智还是有所变化&#xff0…

java queue使用_使用Java使用Amazon Simple Queue Service

java queue使用Amazon Simple Queue Service或SQS是Amazon Webservice堆栈提供的高度可扩展的托管消息队列。 Amazon SQS可用于完全解耦系统内不同组件的操作&#xff0c;这些组件否则将交换数据以执行独立的任务。 Amazon SQS还可以帮助我们保存在应用程序关闭或组件之一不可用…

latex学习篇【一】论文中的图片技巧QA

第一篇论文总算收尾了&#xff0c;整理一波latex写论文的Q&A。 LATEX专栏第一篇&#xff1a;在Latex模板中引入各种图片的问题。 工具&#xff1a;overleaf网站&#xff1a;https://www.overleaf.com/project/60e9ceb20f8db14efa31dc80在overleaf上面插入图片什么形式最好…

配置HTTPS以与Servlet一起使用

要配置Java EE应用程序以通过HTTPS进行通信&#xff0c;需要在web.xml文件中使用几行XML。 web.xml文件位于项目的WEB-INF目录中&#xff0c;通常在IDE生成Java EE Web应用程序时自动创建。 如果不是&#xff0c;您可以自己创建它。 HTTPS的动机 为Web应用程序配置安全连接的…

LATEX学习篇【二】:论文中的公式技巧QA

写论文免不了写好多好多公式&#xff0c;众所周知啊latex的公式是很难编辑的&#xff0c;有没有简便一点的办法呢&#xff1f;有的&#xff0c;让我们继续读下去吧&#xff01; 写公式时会用到的一些奇奇怪怪的符号大全&#xff08;来自百度&#xff09; 2. 写公式好用的工具…

latex学习篇【三】论文中的表格技巧QA

latex中表格是一个大头 和公式一样&#xff0c;推荐一个好用的工具&#xff01; https://www.tablesgenerator.com/latex_tables 这个网站可以在线编辑表格&#xff0c;直接生成代码&#xff0c;粘贴过去就可以啦&#xff01;&#xff01;&#xff01; 但是关于细节还有很多要调…

JRebel适用于Gradle Spring Boot应用程序

关于如何将JRebel添加到使用Gradle作为构建工具的Spring Boot应用程序中&#xff0c;有一些文档 。 它是基本的&#xff0c;但是效果很好。 您所要做的就是在build.gradle中添加几行&#xff1a; if (project.hasProperty(rebelAgent)) {bootRun.jvmArgs rebelAgent }然后在…

MADDPG中环境怎么配置,multiagent包解决

一、环境提供 MADDPG&#xff1a; https://github.com/starry-sky6688/MADDPG (pytorch版本) MPE环境&#xff1a;https://github.com/openai/multiagent-particle-envs 论文&#xff1a;《Multi-Agent Actor-Critic for Mixed Cooperative-Competitive Environments》https…

使用RabbitMQ的SpringBoot消息传递

RabbitMQ是流行的消息代理解决方案之一&#xff0c;并提供可用于各种编程语言的客户端库&#xff0c;包括Java&#xff0c;Scala&#xff0c;.NET&#xff0c;Go&#xff0c;Python&#xff0c;Ruby&#xff0c;PHP等。在本教程中&#xff0c;我们将学习如何使用RabbitMQ消息代…

1.0jpa 2.0_在JPA 2.1中使用@Convert正确完成映射枚举

1.0jpa 2.0如果您曾经在JPA中使用过Java枚举&#xff0c;那么您肯定会意识到它们的局限性和陷阱。 使用enum作为Entity的属性通常是一个很好的选择&#xff0c;但是2.1之前的JPA不能很好地处理它们。 它给了您2 1个选择&#xff1a; 托肖夫达林 Enumerated(EnumType.ORDINAL…

Drools可执行模型还活着

总览 可执行模型的目的是提供规则集的纯基于Java的表示&#xff0c;以及方便的Java DSL以编程方式创建这种模型。 该模型是低级别的&#xff0c;旨在为用户提供所需的所有信息&#xff0c;例如用于索引评估的lambda。 这样可以使其保持快速运行&#xff0c;并避免在此级别上进行…

java ee cdi_Java EE CDI依赖注入(@Inject)教程

java ee cdi在本教程中&#xff0c;我们将向您展示如何在CDI管理的Bean中实现依赖注入。 特别是&#xff0c;我们将利用CDI API提供的Inject批注将CDI bean注入另一个bean。 通过这种方式&#xff0c;可以在应用程序&#xff08;例如JavaServer Faces应用程序&#xff09;中使用…

Java 8中的可重复注释

使用Java 8&#xff0c;您可以对声明或类型重复相同的注释。 例如&#xff0c;要注册一个类仅应由特定角色在运行时访问&#xff0c;则可以编写如下内容&#xff1a; Role("admin") Role("manager") public class AccountResource { }注意&#xff0c;现在…

java sax解析xml_在Java中使用DOM,SAX和StAX解析器解析XML

java sax解析xml我碰巧通读了有关Java中XML解析和构建API的章节。 我试用了样本XML上的其他解析器。 然后&#xff0c;我想在我的博客上分享它&#xff0c;这样我就可以得到该代码的参考以及任何阅读此代码的参考。 在本文中&#xff0c;我将在不同的解析器中解析相同的XML&…