spring-boot - 基于 Apache Camel 的 Udp 服务器

Question

我正在尝试使用 Apache Camel 创建使用 syslog 消息的 udp 服务器。

没有如何正确执行此操作的示例。

我编写了以下路线，它使用自定义 serverInitializerFactory。

@Component
public class MainRoute extends RouteBuilder {

@Override
public void configure() throws Exception {
  from("netty4:udp://{{app.server.host}}:{{app.server.port}}?serverInitializerFactory=#udpSyslogFlowFactory&sync=false&textline=true")
    .to("seda:rowLogs");

  from("seda:rowLogs?concurrentConsumers={{app.concurrent-processors}}")
    .to("bean:logParser");
}

}

工厂代码：

@Component
public class UdpSyslogFlowFactory extends ServerInitializerFactory {

  private int maxLineSize = 1024;

  private NettyConsumer consumer;

  public UdpSyslogFlowFactory() {
    super();
  }

  public UdpSyslogFlowFactory(NettyConsumer consumer) {
    this();
    this.consumer = consumer;
  }

  @Override
  protected void initChannel(Channel ch) throws Exception {
    ChannelPipeline channelPipeline = ch.pipeline();
    channelPipeline.addLast("encoder-SD", new StringEncoder(StandardCharsets.UTF_8));
    channelPipeline.addLast("decoder-DELIM",
        new DelimiterBasedFrameDecoder(maxLineSize, true, Delimiters.lineDelimiter()));
    channelPipeline.addLast("decoder-SD", new StringDecoder(StandardCharsets.UTF_8));
    channelPipeline.addLast("handler", new ServerChannelHandler(consumer));
  }

  @Override
  public ServerInitializerFactory createPipelineFactory(NettyConsumer consumer) {
    return new UdpSyslogFlowFactory(consumer);
  }

}

看起来传入的 udp 消息没有被引用 StringDecoder 处理。

任何人都可以提供使用 Camel 对所有传入消息进行简单文本解码的 UDP 服务器的完整示例？

标签： spring-bootapache-camelnetty

Answer 1

与其自己构建 syslog-consumer 和解码器，不如看看Camel syslog DataFormat。

在链接的文档页面上，您可以找到带有netty和mina组件的 syslog-consumer 示例。