如何动态更改tcp ibound网关使用的端口

Question

有没有办法动态更改tcp-inbing-网关使用的端口？我想根据数据库中持久化的配置设置tcp-inbing-网关使用的端口和超时，并且能够在不重新启动应用程序的情况下动态更改它们。为了做到这一点，我决定使用“发布-订阅者”模式和扩展的TcpInoundGateway类：

public class RuntimeInboundGateway extends TcpInboundGateway implements SettingsSubscriber {

    @Autowired
    private Settings settings;

    @PostConstruct
    public void subscribe() {
        settings.subscribe(this);
    }

    @Override
    public void onSettingsChanged(Settings settings) {
        this.stop();
        AbstractByteArraySerializer serializer = new ByteArrayLfSerializer();
        TcpNetServerConnectionFactory connectionFactory = new TcpNetServerConnectionFactory(settings.getPort());
        connectionFactory.setSerializer(serializer);
        connectionFactory.afterPropertiesSet();
        this.setConnectionFactory(connectionFactory);
        this.afterPropertiesSet();
        this.start();
    }
}

设置对象是一个单例bean，当它被更改时，tcp入站网关确实开始侦听新端口，但看起来它不会在流中进一步发送入站消息。以下是xml配置的摘录：

<int-ip:tcp-connection-factory id="connFactory" type="server" port="${port}"
                                   serializer="serializer"
                                   deserializer="serializer"/>

    <bean id="serializer" class="org.springframework.integration.ip.tcp.serializer.ByteArrayLfSerializer"/>

    <bean id="inboundGateway" class="com.example.RuntimeInboundGateway">
        <property name="connectionFactory" ref="connFactory"/>
        <property name="requestChannel" ref="requestChannel"/>
        <property name="replyChannel" ref="responseChannel"/>
        <property name="errorChannel" ref="exceptionChannel"/>
        <property name="autoStartup" value="true"/>
    </bean>

配置中有日志记录通道适配器，用于记录对服务的任何请求，而不会出现任何问题，直到更改设置。之后，它没有，我看到没有收到任何消息，尽管我能够通过telnet本地主机连接到新端口




Answer 1

匿名用户

问题的原因是我。因为上面的代码中没有指定反序列化程序，所以使用了默认的反序列化程序并且它无法从输入字节流中划分入站消息。只有一行＜code＞connectionFactory。setDeserializer（序列化器）解决了我花了一天时间解决的问题。

Answer 2

快速查看您的代码表明它应该可以正常工作，所以我刚刚编写了一个快速的Spring Boot应用程序，它对我来说效果很好……

@SpringBootApplication
public class So40084223Application {

    public static void main(String[] args) throws Exception {
        ConfigurableApplicationContext ctx = SpringApplication.run(So40084223Application.class, args);
        Socket socket = SocketFactory.getDefault().createSocket("localhost", 1234);
        socket.getOutputStream().write("foo\r\n".getBytes());
        socket.close();
        QueueChannel queue = ctx.getBean("queue", QueueChannel.class);
        System.out.println(queue.receive(10000));
        ctx.getBean(MyInboundGateway.class).recycle(1235);
        socket = SocketFactory.getDefault().createSocket("localhost", 1235);
        socket.getOutputStream().write("fooo\r\n".getBytes());
        socket.close();
        System.out.println(queue.receive(10000));
        ctx.close();
    }

    @Bean
    public TcpNetServerConnectionFactory cf() {
        return new TcpNetServerConnectionFactory(1234);
    }

    @Bean
    public MyInboundGateway gate(TcpNetServerConnectionFactory cf) {
        MyInboundGateway gate = new MyInboundGateway();
        gate.setConnectionFactory(cf);
        gate.setRequestChannel(queue());
        return gate;
    }

    @Bean
    public QueueChannel queue() {
        return new QueueChannel();
    }

    public static class MyInboundGateway extends TcpInboundGateway implements ApplicationEventPublisherAware {

        private ApplicationEventPublisher applicationEventPublisher;

        @Override
        public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher) {
            this.applicationEventPublisher = applicationEventPublisher;
        }

        public void recycle(int port) {
            stop();
            TcpNetServerConnectionFactory sf = new TcpNetServerConnectionFactory(port);
            sf.setApplicationEventPublisher(this.applicationEventPublisher);
            sf.afterPropertiesSet();
            setConnectionFactory(sf);
            afterPropertiesSet();
            start();
        }

    }

}

我会打开调试日志，看看它是否能给你任何线索。

您可能还想尝试使用新的DSL动态流注册。tcp-Dynamic-client展示了如何使用该技术即时添加/删除流片段。它在客户端，但在服务器端可以使用类似的技术来注册/取消注册您的网关和连接工厂。