如何在Spring框架中实现UDP

Question

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

Answer 1

如果您想使用 TCP and UDP Support of Spring Integration，假设您只是收到一条 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 集成有很多有趣的功能，例如消息路由和转换。建议准确查看官方文档

如何在Spring框架中实现UDP

How to implement UDP in Spring framework

java

spring

udp

创建消息消费者

可选：使用一些属性

创建配置文件

如何在Spring框架中实现UDP

How to implement UDP in Spring framework

java

spring

udp

创建消息消费者

可选：使用一些 属性

创建配置文件

可选：使用一些属性