13. Fluentd输出插件：in_forward用法详解

in_forward插件通常用于从其他节点接收日志事件，这些节点包括其他Fluentd实例、fluent-cat命令行或者Fluentd客户端程序。这是目前效率最高的日志事件接收方法。

in_forward插件会在本地打开一个tcp监听socket，用于接收日志事件。同时，它也会开启一个udp端口用于接收和对端的心跳保活消息。

in_forward可接收json或MessagePack格式的数据，它会自动探测源数据是哪种格式。MessagePack是Fluentd内部使用的数据封装格式，因其效率高于json。

in_forward插件内置于Fluentd，无须安装。

1.示例配置

<source>

  @type forward

  port 24224

  bind 0.0.0.0

</source>

2.参数说明

<source>

  @type forward

  add_tag_prefix prod

</source>

如此配置，in_forward产生的事件tag为prod.INCOMING_TAG，比如prod.app.log。

<transport tls>

  cert_path /path/to/fluentd.crt

  # 这里还需要其他参数，请参见Fluentd官网说明

</transport>

<system>

  workers 3

</system>

<source>

  @type forward

  port 24224

</source>

这里，24224端口接收的事件会被自动路由到3个worker进程中。

in_forward主要是为了高效传输日志，并不像in_tail一样可以通过<parse>来配置对数据的解析方法。

如果想解析收到的数据，可在事件路由链中添加合适的过滤器。

巴特西