如何在 Spring 框架中实现 UDP

Question

我已经用 spring 框架实现了一个 Web 应用程序。现在我需要一个接收来自客户端（安卓设备）的传入消息的 udp 服务器。如何将此功能添加到我的基于弹簧的项目中？谢谢。

Answer 1

如果你想使用Spring Integration的TCP和UDP支持，假设你只收到一条UDP消息并对该消息执行一些操作，你应该按照以下步骤操作：

创建消息使用者

package com.example.udp;
import org.springframework.messaging.Message;
public class UDPConsumer {
    @Autowire what you want, this will be a Spring Bean
    @ServiceActivator
    public void consume(Message message) {
         ... do something with message ...
    }
}

可选：创建一个带有某些属性的 udp-server.properties

udp-server.threads=10
udp-server.port=4000
udp-server.buffer-size=500
...

创建配置文件

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:int="http://www.springframework.org/schema/integration"
    xmlns:int-ip="http://www.springframework.org/schema/integration/ip"
    xmlns:context="http://www.springframework.org/schema/context"
    xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
        http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd
        http://www.springframework.org/schema/integration http://www.springframework.org/schema/integration/spring-integration.xsd
        http://www.springframework.org/schema/integration/ip http://www.springframework.org/schema/integration/ip/spring-integration-ip.xsd">
    <context:property-placeholder location="classpath:udp-server.properties" />
    <bean id="udpConsumer" class="com.example.udp.UDPConsumer" />
    <int:channel id="inputChannel">
        <int:queue />
    </int:channel>
    <int-ip:udp-inbound-channel-adapter id="udpReceiver"
        channel="inputChannel"
        port="${udp-server.port}"
        pool-size="${udp-server.threads}"
        receive-buffer-size="${udp-server.buffer-size}"
        multicast="false"
        check-length="true"/>
    <int:service-activator input-channel="inputChannel"
        ref="udpConsumer" />
    <int:poller default="true" fixed-rate="500" />
</beans>

注意：Spring 集成有很多有趣的功能，比如消息路由和转换。我建议准确查看官方文档。