java - 使用 UnicastReceivingChannelAdapter 进行 UDP 处理以创建发布-订阅 channel

Question

我必须在一个 channel 中接收 UDP 并通过管道传输到 2 个订阅 channel 。为此，我有 2 个具有相同输入 channel 的 Serviceactivator 功能。

@Autowired
private PublishSubscribeChannel channel;

@Bean
public UnicastReceivingChannelAdapter udpIn() {
   final UnicastReceivingChannelAdapter adapter = new 
                      UnicastReceivingChannelAdapter(<port>);
   adapter.setPoolSize(6);
   adapter.setOutputChannel(channel); //Is it required?
   adapter.setOutputChannelName("udpInboundChannel");
   adapter.stop();
   return adapter;
}

@ServiceActivator(inputChannel = "udpInboundChannel")
    public void handleMessage(Message<?> message) throws MessagingException {
  ----
}

@ServiceActivator(inputChannel = "udpInboundChannel")
    public void handleMessageDifferently(Message<?> message) throws MessagingException {
  ---
}

我的问题，我需要像这样设置 channel adapter.setOutputChannel(channel)吗？或者 UnicastReceivingChannelAdapter 根据我的需要默认提供一个发布-订阅 channel ？

Answer 1

在您的配置中，udpInboundChannel 是 DirectChannel。如果您希望它成为 PubSub channel ，只需声明一个新 bean

 @Bean
 public MessageChannel udpInboundChannel() {
      return new PublishSubscribeChannel();
 }