1. 案列需求
首先，Flume监控本机44444端口，然后通过Telnet工具向44444端口发送消息，最后Flume将监听的数据实时显示在控制台。
2. 需求分析
Dflume 动态修改参数。
3.实现步骤：
1）. 安装Telnet工具
a．检测telnet-server的rpm包是否安装
[ck@hadoop102 ~]$ rpm -qa telnet-server
b. 安装xinetd 、telnet、telnet-server
[ck@hadoop102 software]$ sudo rpm -ivh xinetd-2.3.15-14.el7.x86_64.rpm [ck@hadoop102 software]$ sudo rpm -ivh telnet-0.17-65.el7_8.x86_64.rpm [ck@hadoop102 software]$ sudo rpm -ivh telnet-server-0.17-64.el7.x86_64.rpm
2). 判断44444端口是否被占用
[ck@hadoop102 software]$ sudo netstat -tunlp | grep 44444
功能描述：netstat命令是一个监控TCP/IP网络的非常有用的工具，它可以显示路由表、实际网络连接以及每一个网络接口设备的状态信息。
基本语法：netstat[选项]
选项参数：
-t或--tcp：显示TCP传输协议的连接状况。
-u或--udp：显示UDP传输协议的连线状况；
-n或--numeric：直接使用ip地址，而不通过域名服务器；
-l或--listening：显示监控中的服务器的Socket；
-p或--programs：显示正在使用Socket的程序识别和程序名称；
3). 创建Flume Agent配置文件flume-telnet-logger.conf
在flume目录下创建job文件夹并进入job文件夹。
[ck@hadoop102 flume-1.9.0]$ mkdir job [ck@hadoop102 flume-1.9.0]$ cd job
在job文件夹下创建Flume Agent配置文件flume-telnet-logger.conf
[ck@hadoop102 job]$ touch flume-telnet-logger.conf
在flume-telnet-logger.conf文件中添加如下内容。
[ck@hadoop102 job]$ vim flume-telnet-logger.conf
添加内容如下：
# Name the components on this agent #a1:标识agent的名称 a1.sources = r1 #r1：标识a1的输入源 a1.sinks = k1 #k1：表示a1的输出目的地 a1.channels = c1 #c1：表示a1的缓冲区 # Describe/configure the source a1.sources.r1.type = netcat #表示a1的输入源类型为netcat端口类型 a1.sources.r1.bind = localhost #表示a1的监听的主机 a1.sources.r1.port = 44444 #表示a1的监听的端口号 # Describe the sink a1.sinks.k1.type = logger #表示a1的输出目的地是控制台logger类型 # Use a channel which buffers events in memory a1.channels.c1.type = memory #表示a1的channel类型是memory内存型 a1.channels.c1.capacity = 1000 #表示a1的channel总容量是1000个event a1.channels.c1.transactionCapacity = 100 #表示a1的channel传输时收集到了100条event以后再去提交事务 # Bind the source and sink to the channel a1.sources.r1.channels = c1 # 表示将r1 和c1连接起来 a1.sinks.k1.channel = c1 # 表示将k1 和c1连接起来
4).先开启flume监听端口
[ck@hadoop102 flume-1.9.0]$ bin/flume-ng agent --conf conf/ --name a1 --conf-file job/flume-telnet-logger.conf -Dflume.root.logger=INFO,console
参数说明：
--conf conf/：表示配置文件存储在conf/目录
--name a1 ：表示给agent起名为a1
--conf-file job/flume-telnet-logger.conf：flume本次启动读取的配置文件是在job文件下的 flume-telnet-logger.conf文件。
-Dflume.root.logger=INFO,console ：-D表示flume运行是动态修改flume.root.logger参数属性值，并将控制台日志打印级别设置为INFO级别。日志级别包括：log、info、warn、error。
5). 使用Telnet工具向本机的44444端口发送内容。
[ck@hadoop102 etc]$ telnet localhost 44444
6).在Flume监听页面观察接收数据情况
案例源于atguigu视频