首先我们需要下载此次任务所需要的工具Xshell与flume的压缩包
链接：https://pan.baidu.com/s/1iXBWhVDVFUaAt6TUKgiwLA
提取码：wc9i
一、压缩包的传输
1、使用xshell连接到虚拟机后点击“帮助”下方的XFTP插件图标的（不会使用xhell远程连接的可以参考这篇文章）
2、找到下载好的filme的tar包双击开始传输到虚拟机上
二、解压
1、在xshell上或者是虚拟机的终端输入命令：tar -zvxf apache-flume-1.7.0-bin.tar.gz开始解压tar包
2、输入命令：ll 就可以查看已经解压好的内容了，接着输入命令：cd apache-flume-1.7.0-bin/conf/进入conf文件下
三、配置文件与环境变量
1、输入命令：nano flume-env.sh （或者vi flume-env.sh）, 添加JDK安装路径（如没有，则需安装JDK） export JAVA_HOME=/home/yt/jdk18.0.2.1（这里为自己服务器上JDK的位置）
2、在conf下创建一个flume.conf的文件夹
3、输入命令:ls看是否创建成功
4、输入命令：nano /etc/profile配置环境改变量，输入以下内容
export FLUME_HOM=...........(这里为自己flume的安装路径)
export PATH=$PATH:$FLUME_HOME/bin(ctrl+x+Y保存)
5、输入命令：source /etc/profile加载环境变量使它生效
四、查看版本信息
输入命令：flume-ng version查看版本信息
五、创建并启动agent
1、首先我们需要安装netcat网络工具，在这之前先把镜像改为阿里云的镜像， 输入命令：vim /etc/yum.repos.d/CentOS-Base.repo编辑里面内容
2、将原来的[base]以下的内容全部换成以下内容
[base]
name=CentOS-6.10
baseurl=http://mirrors.aliyun.com/centos-vault/6.10/os/$basearch/
gpgcheck=0
enabled=1
gpgkey=http://vault.centos.org/RPM-GPG-KEY-CentOS-6
#released updates
[updates]
name=CentOS-6.10
baseurl=http://mirrors.aliyun.com/centos-vault/6.10/updates/$basearch/
gpgcheck=0
enabled=1
gpgkey=http://vault.centos.org/RPM-GPG-KEY-CentOS-6
#additional packages that may be useful
[extras]
name=CentOS-6.10
baseurl=http://mirrors.aliyun.com/centos-vault/6.10/extras/$basearch/
gpgcheck=0
enabled=1
gpgkey=http://vault.centos.org/RPM-GPG-KEY-CentOS-6
4、保存后输入如下命令
5、接下来就可以使用命令：yum install -y nc下载网络工具
出现如图即为完成
6、接着在解压好的fulme文件下创建通过jobs文件
7、创建好jobs文件以后输入命令：nano netcat-flume-logger.conf编辑里面内容
输入内容为
# example.conf: A single-node Flume configuration
# Name the components on this agent
# yt:表示 agent 的名称
# r1:表示 yt 的 Source 的名称
# k1:表示 yt 的 Sink 的名称
# c1:表示 yt 的 Channel 的名称
yt.sources = r1
yt.sinks = k1
yt.channels = c1
# Describe/configure the source
# 表示 yt 的输入源类型为 netcat 端口类型
yt.sources.r1.type = netcat
# 表示 a1 的监听的主机
yt.sources.r1.bind = localhost
# 表示 yt 的监听的端口号
yt.sources.r1.port = 44444
# Describe the sink
# 表示 yt 的输出目的地是控制台 logger 类型
yt.sinks.k1.type = logger
# Use a channel which buffers events in memory
# 表示 yt 的 channel 类型是 memory 内存型
yt.channels.c1.type = memory
# 表示 yt 的 channel 总容量 1000 个
event yt.channels.c1.capacity = 1000
# 表示 yt 的 channel 传输时收集到了 100 条 event 以后再去提交事务 yt.channels.c1.transactionCapacity = 100
# Bind the source and sink to the channel
# 表示将 r1 和 c1 连接起来
yt.sources.r1.channels = c1
# 表示将 k1 和 c1 连接起来
yt.sinks.k1.channel = c1
8、完成什么步骤后输入命令flume-ng agent -c conf/ -n yt -f jobs/netcat-flume-logger.conf -Dflume.root.logger=INFO,console启动agent
六、验证
1、在虚拟机的终端上输入命令：nc localhost 44444+enter在输入内容hello
2、打开xhell发现已经监听到我们输入分内容。
如图就全部完成了
文章来源：https://uudwc.com/A/AAXP4
文章来源地址https://uudwc.com/A/AAXP4
