用于多个节点的 spring 集成 jdbc 适配器
我正在使用 jdbc inbound-channel-adapter 和如下典型配置来从 MYSQL DB 中检索记录.问题是如何让jdbc inbound-channel-adapter在多节点环境下工作?不同的节点将有机会获得一个相同的记录进行处理.我知道这可能是一个老问题，但到目前为止我找不到解决方案.
..
spring-integration相关内容
Spring 集成和 http 入站适配器，如何提取主要用户?
这是我要替换的控制器: @RequestMapping("/user")公共@ResponseBody UserRsp callUserService(Principal principal) {String authenticationdUsername = principal.getName();返回 userService.getUser(authenticatedUsername);}
..
spring 集成 aws s3 删除本地文件
我正在使用 spring 集成从 s3 读取文件，但是这有效但我的本地目录已满我想在从 s3 处理文件后从本地目录中删除文件?
..
设计:Spring 集成 jdbc 最佳实践
在一个项目中使用 Spring Integration 后，我的观察是只在流程的开始或结束时使用 jdbc 适配器或网关.如果我们在流程中使用它们，那么它会变得过于冗长和复杂. 例如:
..
存储过程出站网关无法执行有效的存储过程
我们在项目中使用 spring-integration.我正在使用 int-jdbc:stored-proc-outbound-gateway 来执行存储过程.当我使用 Spring-Integration 层命中存储过程时出现以下错误.但奇怪的是，相同的存储过程从 SQL Developer 成功执行并将所需的行插入表中. 2016-07-01 11:45:49,254 DEBUG http-
..
处理多条消息
我有一个 spring xd 源模块，它从 s3 中提取文件并逐行拆分.我的 spring 配置如下.但我有 3 个容器和 1 个管理服务器.现在我看到每个容器正在处理重复的消息他们每个人都在那里下载自己的副本.我可以通过将源 s3 模块部署计为 1 来解决，但我的消息处理速度变慢了.?有任何输入可以解决这个问题吗?
..
Spring 集成将入站 HTTP 网关与出站 Websocket 网关连接起来
我想创建一个 REST 服务来打开灯.我想要的架构如下: 许多嵌入式系统每个都连接到一个灯实例 每个嵌入式系统都有一个 websocket 客户端，它连接到我的服务器 我的服务器拥有一项 REST 服务，允许网络客户端选择一个轻量级实例并将其打开 REST 服务将有一个参数来指定一个灯实例的引用，连接到系统并将消息发送到 websocket 客户端，等待来自客户端的确认消息，并返回 R
..
setOnFailureExpression 不适用于 #root 和 #exception
@Beanpublic ExpressionEvaluatingRequestHandlerAdvice after() {logger.debug("评估表达式建议.");ExpressionEvaluatingRequestHandlerAdvice 建议 = new ExpressionEvaluatingRequestHandlerAdvice();建议.setTrapException(
..
如何将此弹簧集成配置从 XML 转换为 Java?
在应用程序中而不是在 XML 中实现这一特定部分是有意义的，因为它是整个集群中的常量，而不是本地化到单个作业. 从剖析 XSD 来看，在我看来，int-kafka:outbound-channel-adapter 的 xml 构造了一个 KafkaProducerMessageHandler. 没有可见的方式来设置频道、主题或大多数其他属性. 请注意潜在的downvoters -
..
使用 Java DSL 的 Spring Batch 集成配置
Spring 集成 Java DSL 参考 和 Spring Batch Java 配置文档展示了如何使用 Java Configuration for Spring Integration 和 Spring Batch. 但他们没有展示如何为 Spring Batch 集成配置它.如何使用 DSL 配置 JobLaunchingGateway? 干杯，门诺 解决方案 JobL
..
将 2/n 个(多个)参数传递给“int-jdbc:stored-proc-outbound-gateway"
大家好，我需要帮助:) 以前当我试图只传递一个变量时，它工作正常.现在，只要我尝试使用 Spring Integration 传递 2/n 个参数，就会出现以下“有效负载"异常，我不清楚. 我得到的异常如下: [2014-10-31 12:12:43,943][WARN]GatewayProxyFactoryBean$MethodInvocationGateway.doSendAnd
..
使用 Spring Batch 集成为 AWS S3 中的每个新文件启动 JobLaunchRequest
我正在关注文档:Spring Batch Integration 结合 集成 AWS 用于汇集 AWS S3. 但是在某些情况下，每个文件的批处理执行不起作用. AWS S3 池工作正常，所以当我放置一个新文件或当我启动应用程序并且存储桶中有文件时，应用程序与本地目录同步: @Bean公共 S3SessionFactory s3SessionFactory(AmazonS3 pAm
..
Spring Integration:如何拦截所有 spring 集成组件并获取要记录的属性值
我需要在运行时拦截所有 Spring Integration 组件，并且应该能够获取属性值以记录有意义的消息.例如:
..
将重命名的文件作为输入传递给出站适配器/网关
在 spring-boot-integration 应用程序中，编写了一个自定义储物柜以在锁定之前重命名原始文件(fileToLock.getAbsolutePath() + ".lock")和预期锁定文件，以便任何其他实例将无法处理同一个文件. 当文件重命名时，它对原始文件和附加文件的内容进行了处理，使用filename.lock创建了内容，原始文件也存在，大小为0 kb，没有内容.
..
使用 Spring 集成实现 MongoDB 入站流
我们将有一个包含多个工作单元的 Mongo 集合.我的想法是文档将有一个包含四个选项的状态字段:未处理、正在处理、已完成、已失败.Spring Integration 将被配置为从此数据库读取并处理存储在那里的消息. 入站 Mongo DSL 流将根据 UNPROCESSED 的值从集合中读取: MongoDbMessageSource messageSource = new MongoD
..
Spring Integration dsl - HTTP 入站网关使用 multipart/form-data
我想通过 http 入站网关使用 multipart/form-data.第一部分是作为 json 的对象，我想通过内容类型将其序列化为对象:application/json.第二部分是pdf文件.是否可以简单地序列化?我需要我的自定义消息转换器吗? RAW 请求: POST http://localhost:18080/api/v2/attachments HTTP/1.1内容类型:多部
..
有没有办法使用 DSL 来分叉 Spring IntegrationFlow?
我想做这样的事情，其中网关有效负载是一个字符串和 serviceA &serviceB 两个返回列表. final IntegrationFlow flowA = flow ->流量.handle(serviceA).handle((payload, headers) -> payload);//列表最终的IntegrationFlow flowB = flow ->流量.handle(s
..
Spring DSL Integration Flow 在出站适配器出错后发布消息
我有一个集成流程. IntegrationFlows.from(Sftp.inboundAdapter(inboundSftp).localDirectory(this.getlocalDirectory(config.getId())).deleteRemoteFiles(真).autoCreateLocalDirectory(true).filter(new CompositeFileLis
..
Spring Integration HTTP 出站网关标头不是连续请求的转发器
我在以下流程中挣扎: .enrichHeaders(h -> h.headerFunction(“ocp-apim-subscription-key", m ->“xxx")).handle(Http.outboundGateway(“https://northeurope.api.cognitive.microsoft.com/vision/v3"+“.0/read/analyzeResult
..
由于接收超时和任务执行器失调而导致内存泄漏
我正在阅读 spring 集成参考文档和第 10.1.8 节 异步轮询 它写道，失调的 conf 会导致内存泄漏. 根据下面的文档是不合时宜的 conf :
..