无法发送 UDP 消息的响应 [英] Can not send response for UDP message
问题描述
我正在尝试通过以下方式发送消息:
I am trying to send message with:
netcat -u localhost 11111abcd
我只需要客户端得到答复:OK 它得到消息并尝试回答 OK.但它无限地将其写入应用程序日志:
I just need that the client get answer: OK It get the message and try to answer with OK. But it writes this infinitely to application log:
Message: GenericMessage [payload=byte[2], headers={ip_packetAddress=127.0.0.1/127.0.0.1:49489, ip_address=127.0.0.1, id=8db6aa3b-b56b-6dce-9554-c7b4port=127.0.0.1/127.0.0.1:49489, ip_hostname=127.0.0.1, 时间戳=1494442285767}]
Message: GenericMessage [payload=byte[2], headers={ip_packetAddress=127.0.0.1/127.0.0.1:49489, ip_address=127.0.0.1, id=8db6aa3b-b56b-6dce-9554-c7b0ce050142, ip_port=49489, ip_hostname=127.0.0.1, timestamp=1494442285767}]
消息负载:好的
配置:
<?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">
<int:channel id="sendUdp"/>
<int-ip:udp-outbound-channel-adapter id="udpOut" host="localhost" port="11111"
multicast="false" check-length="false"
channel="sendUdp" />
<int-ip:udp-inbound-channel-adapter id="udpIn" port="11111" receive-buffer-size="500"
multicast="false" check-length="false"
channel="receiveUdp"/>
<int:service-activator id="updHandler" input-channel="receiveUdp" output-channel="sendUdp" ref="listener"/>
</beans>
@ServiceActivator
public String handle(Message<?> message) {
System.out.println("*** Message: " + message);
String command = new String((byte[]) message.getPayload());
System.out.println("*** Message Payload: "
+ command);
String response = "OK";
return response;
}
推荐答案
您的出站适配器正在向入站适配器发送消息.如果要回复数据包,则需要配置套接字和目标表达式.请参阅文档.
Your outbound adapter is sending messages to the inbound adapter. If you want to reply to a packet, you need to configure the socket and destination expressions. See the documentation.
<int-ip:udp-inbound-channel-adapter id="inbound" port="11111" channel="in" />
<int:channel id="in" />
<int:transformer expression="new String(payload).toUpperCase()"
input-channel="in" output-channel="out"/>
<int:channel id="out" />
<int-ip:udp-outbound-channel-adapter id="outbound"
socket-expression="@inbound.socket"
destination-expression="headers['ip_packetAddress']"
channel="out" />
这篇关于无法发送 UDP 消息的响应的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持IT屋!