如何在spring boot中创建一个Tcp Connection来接受连接?
我经历过这 并明白我需要创建一个 TcpReceivingChannelAdapter 来接受连接.但我不知道如何处理. 有人可以指导我吗? 解决方案 见tcp-client-server 示例 使用 XML 配置的一些指针. 用于Java配置；这是一个简单的 Spring Boot 应用程序... package com.example;导入 java.net.Socket
..
spring-integration相关内容
Spring Integration - 外部化 JDBC 查询
有没有一种简单的方法可以将来自 jdbc 出站网关的大型 sql 查询外部化，而不是内联它?原因是我们必须进行许多大查询，而且我们希望将它们放在自己的文件中，或者至少在 bean 中将它们外部化. 一些注意事项: 我无法控制数据库，因此无法创建任何内容那里(例如存储过程) 我不想仅仅为此创建类，我只想稍微组织/重构它，而不是让它变得更复杂介绍许多其他步骤 我更喜欢创建裸 .sql
..
确认后反复收到来自Google Pub/Sub订阅的消息[Heisenbug]
我想注意的是，我将描述的场景很少发生，而且在大多数情况下，一切都按预期进行. 我在 Pub/Sub 端有 1 个主题和 1 个订阅. 我的 Java 应用程序侦听订阅，进行一些处理并将确认发回.由于 google Pub/Sub 保证至少交付一次，我们根据 objectGeneration 标头和 'objectId' 标头在我们这边进行消息重复数据删除. 有时我们会看到我们的应
..
使用 2 个消费者配置时消费者吞吐量缓慢
使用 spring-integration-kafka 扩展和以下配置:
..
maprsteam 与 spring 集成 java 客户端
我正在寻找将 maprstream 与 spring 集成一起使用的解决方案.我可以创建流和主题，还可以使用流:主题组合使用/发布消息.通过参考链接使用了Kafka客户端::> 但是努力使用 Spring 集成来消费/发布消息，并且看不到任何解释相同的示例程序.有人可以帮我解决这个问题吗? 解决方案 spring-integration-kafka 2.0(通过 spring-kaf
..
maprsteam 与 spring 集成 java 客户端
我正在寻找将 maprstream 与 spring 集成一起使用的解决方案.我可以创建流和主题，还可以使用流:主题组合使用/发布消息.通过参考链接使用了Kafka客户端::> 但是努力使用 Spring 集成来消费/发布消息，并且看不到任何解释相同的示例程序.有人可以帮我解决这个问题吗? 解决方案 spring-integration-kafka 2.0(通过 spring-kaf
..
我需要当前易于遵循的说明来从 XML 配置 spring 集成 kafka
spring 集成 kafka 模型已经发生了足够的变化，因为它已经被处理和简化，现有的演示、手册和说明不再起作用.目前官方的demo都是围绕注解构建的，虽然很酷，但基本上不可读，不适合我的架构，作业与java代码分开部署和管理. 是否有当前 (2019) 教程，用于在 XML 中配置 spring 集成生产者和消费者? 作为参考，这里是我 POM 的摘录，详细说明了我正在使用的版本:
..
使用来自 MQ 的消息并在 Spring JMS 中合并
我使用 spring + MQ + Websphere 应用服务器. 我想异步使用来自 MQ 的消息并将这些消息组合起来，以便在每次提交中轻松将 N 个实体持久化到数据库中.(没有强调我的目标 Oracle 数据库太多提交) 我使用 DefaultMessageListenerContainer 并使 onMessage 方法同步以添加消息(直到批量大小)，并创建线程以等待条件满足(时
..
我需要当前易于遵循的说明来从 XML 配置 spring 集成 kafka
spring 集成 kafka 模型已经发生了足够的变化，因为它已经被处理和简化，现有的演示、手册和说明不再起作用.目前官方的demo都是围绕注解构建的，虽然很酷，但基本上不可读，不适合我的架构，作业与java代码分开部署和管理. 是否有当前 (2019) 教程，用于在 XML 中配置 spring 集成生产者和消费者? 作为参考，这里是我 POM 的摘录，详细说明了我正在使用的版本:
..
Spring-Kafka 集成 1.0.0.RELEASE 问题与生产者
我无法使用 Spring Kafka 集成发布消息，但我的 Kafka Java 客户端工作正常. Java 代码运行在 Windows 上，Kafka 运行在 Linux 机器上. KafkaProducerContextkafkaProducerContext = new KafkaProducerContext();ProducerMetadataproducerMetadata
..
spring kafka:同一主题上的不同 json 有效负载
我需要在不使用父类的情况下在同一个 Kafka Topic(例如，Foo、Bar、Car ...)上发送不同的 JSON 负载 基于 spring kafka 文档，我可以在类级别使用 @KafkaListener 并在方法级别指定 @KafkaHandler ( doc ) @KafkaListener(topics = "myTopic")静态类 MultiListenerBean {
..
使用 2 个消费者配置时消费者吞吐量缓慢
使用 spring-integration-kafka 扩展和以下配置:
..
Kafka Spring 集成:标题不适合 kafka 消费者
我正在使用 Kafka Spring Integration 来使用 kafka 发布和使用消息.我看到有效负载正确地从生产者传递给消费者，但标题信息在某处被覆盖. @ServiceActivator(inputChannel = "fromKafka")public void processMessage(Message message) 抛出 InterruptedException，执行异
..
TCP 套接字的连接池和多线程?
我有一个 Java 应用程序(比如 A)，它通过 TCP 套接字与一个应用程序(比如 B)通信.我的 java 应用程序是多线程的，最多可以处理 100 个线程.在 A 之间进行通信 -->B 我们有 10 个套接字. 挑战 - 连接池 - 需要连接池机制来处理 n(比如 100)个线程(应用程序 A)，与应用程序 B 通过 x(比如 10)个 TCP 套接字. 多线程 - 两个
..
处理 ws:outbound-gateway 中的 404 错误
是否可以在使用 Spring 集成 4.3.5 的 ws:outbound-gateway 中处理 404 错误下面的错误， [org.springframework.jms.listener.DefaultMessageListenerContainer] (jmsIn.container-1) JMS 消息侦听器执行失败，并且没有设置 ErrorHandler.:org.springfr
..
消息应该如何作为响应
我已阅读并遵循了 http 中的示例://docs.spring.io/spring-integration/reference/html/ip.html#ip-correlation 我有一个弹簧集成服务器 我正在向连接的客户端发送消息 Mapheaders = new H
..
我使用 spring 集成的 tcp 客户端无法获得响应
我使用 spring 集成创建了 tcp 客户端，我能够收到我的发送消息的响应.但是当我使用 localDateTime.now() 记录时间时，我无法收到 send message 的响应.我知道这可以通过使用时间设置使线程等待来解决.由于我是 spring 集成的新手，所以请帮助我如何做. @Configuration@ComponentScan@EnableAutoConfiguratio
..
如何使用 spring 集成在 TCP 连接上实现保持活动连接?
我有一个使用 spring 集成 TCP 构建的 TCP 客户端，并且服务器支持保持活动消息(ping/pong 样式).连接是使用 CachingClientConnectionFactory 配置的，我想利用此服务器功能.这是我的 bean 配置: private static final int SERIALIZER_HEADER_SIZE = 2;/*** 连接工厂用于发送和接收消息的序
..
Spring jms 无法连接到 Websphere MQ - 资源异常
问题: 在尝试连接到 websphere mq 以使用 spring 获取 jms 消息的运行时出现资源异常.我只是无法确定我错过了什么? 说明:尝试在此处设置示例.用于 Websphere MQ 的 Spring MDP 激活规范. http://stackoverflow.com/questions/14523572/spring-jms-and-websphere-mq M
..
Spring Integration 通过 errorChannel throw 重新传递与 JmsTransactionManager 不支持最大重新传递
与 SO 问题相关:Spring Integration Java DSL using JMS重试/重发 对 connectionFactory 使用事务处理轮询器和 JmsTransactionManager 并将 maximumRedeliveries 设置为 3 会导致实际重发尝试次数增加一倍. 我怎样才能让它遵守连接工厂的重新传递设置? 我的 connectionFact
..