基于 Apache Camel 的 Udp 服务器

Question

我正在尝试使用 Apache Camel 创建使用系统日志消息的 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 服务器的完整示例，它使用所有传入消息的简单文本解码？

Answer 1

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

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

基于 Apache Camel 的 Udp 服务器

Apache Camel based Udp server

apache-camel

netty

spring-boot