XML到java DSL的spring集成，包括UDP通道适配器

Question

我想将我的XML配置转换为Java dsl，但我找不到Java dsl中int-ip:udp-inbound-channel-adapter的示例。TCP有TcpNetServerConnectionFactory，但UDP没有。只有这个类是AbstractServerConnectionFactory的子类。与spring集成相关的XML配置如下:

<int-ip:udp-inbound-channel-adapter
        id="receiverChannel" channel="udpReceivedChannel" port="1206" multicast="false"
        check-length="false" lookup-host="false" pool-size="20"/>
    <int:transformer id="convertTransformer" input-channel="convertChannel"
        output-channel="toProcessChannel" ref="transformer" method="transform">
    </int:transformer>
    <int:service-activator id="accumulateActivator" input-channel="udpReceivedChannel"
                           output-channel="convertChannel"
                           ref="accumulator" method="accumulate">
    </int:service-activator>
    <int:service-activator id="cssenderAcivator" input-channel="sendToCMSChannel"
                           ref="cssender" method="sendToCS">
    </int:service-activator>
    <int:service-activator id="jackpotRaiseActivator" input-channel="toProcessChannel"
                           ref="jackpotraise" method="raise" >
    </int:service-activator>
    <int:service-activator id="jackpotScreenActivator" input-channel="jackpotScreenChannel"
                           ref="jackpotscreen" method="updateJackpotsOnDisplay" >
    </int:service-activator>
    <int:channel id="udpReceivedChannel">
        <int:dispatcher task-executor="accumulateExecutor"/>
        <!--<int:queue message-store="redisMessageStore"/>--> <!-- ovo nam ne treba bez da nesto externo trpa u redis-->
    </int:channel>
    <int:channel id="toProcessChannel">
        <int:dispatcher task-executor="jackpotRaiseExecutor"/>
        <int:interceptors>
            <int:wire-tap channel="sendToCMSChannel"/>
        </int:interceptors>
    </int:channel>
    <int:channel id="convertChannel">
        <int:dispatcher task-executor="transformerExecutor"/>
    </int:channel>
    <int:channel id="sendToCMS">
        <int:dispatcher task-executor="cmsSenderExecutor"/>
    </int:channel>
    <int:channel id="jackpotScreenChannel">
        <int:dispatcher task-executor="jackpotScreenExecutor"/>
    </int:channel>
    <task:executor id="accumulateExecutor" pool-size="20" keep-alive="120" />
    <task:executor id="jackpotRaiseExecutor" pool-size="20" keep-alive="120" />
    <task:executor id="transformerExecutor" pool-size="20" keep-alive="120" />
    <task:executor id="cmsSenderExecutor" pool-size="20" keep-alive="120" />
    <task:executor id="jackpotScreenExecutor" pool-size="400" keep-alive="500" />

Answer 1

这是一个快速启动应用程序，它创建一个适配器并向它发送数据包…

@SpringBootApplication
public class So40286815Application {
    public static void main(String[] args) throws Exception {
        ConfigurableApplicationContext context = SpringApplication.run(So40286815Application.class, args);
        DatagramSocket socket = new DatagramSocket();
        DatagramPacket packet = new DatagramPacket("foo".getBytes(), 3);
        packet.setAddress(InetAddress.getLocalHost());
        packet.setPort(1206);
        socket.send(packet);
        Thread.sleep(10000);
        socket.close();
        context.close();
    }
    @Bean
    public UnicastReceivingChannelAdapter inbound() {
        UnicastReceivingChannelAdapter adapter = new UnicastReceivingChannelAdapter(1206);
        adapter.setOutputChannelName("foo");
        return adapter;
    }
    @ServiceActivator(inputChannel = "foo")
    public void handle(byte[] bytes) {
        System.out.println(new String(bytes));
    }
}

和DSL…

@Bean
public UnicastReceivingChannelAdapter inbound() {
    return new UnicastReceivingChannelAdapter(1206);
}
@Bean
public IntegrationFlow flow() {
    return IntegrationFlows.from(inbound())
            .handle(System.out::println)
            .get();
}

,或者只是…

@Bean
public IntegrationFlow flow() {
    return IntegrationFlows.from(new UnicastReceivingChannelAdapter(1206))
            .transform(new ObjectToStringTransformer())
            .handle(m -> System.out.println(m.getPayload()))
            .get();
}