1）案例需求：首先，Flume監(jiān)控本機(jī)44444端口，然后通過telnet工具向本機(jī)44444端口發(fā)送消息，最后Flume將監(jiān)聽的數(shù)據(jù)實(shí)時(shí)顯示在控制臺(tái)。

2）需求分析：

3）實(shí)現(xiàn)步驟：

? ? 1．安裝telnet工具

yum install telnet

2．判斷44444端口是否被占用

sudo netstat -tunlp | grep 44444

功能描述：netstat命令是一個(gè)監(jiān)控TCP/IP網(wǎng)絡(luò)的非常有用的工具，它可以顯示路由表、實(shí)際的網(wǎng)絡(luò)連接以及每一個(gè)網(wǎng)絡(luò)接口設(shè)備的狀態(tài)信息。?

基本語法：netstat [選項(xiàng)]

選項(xiàng)參數(shù)：

-t或--tcp：顯示TCP傳輸協(xié)議的連線狀況；

-u或--udp：顯示UDP傳輸協(xié)議的連線狀況；

-n或--numeric：直接使用ip地址，而不通過域名服務(wù)器；

-l或--listening：顯示監(jiān)控中的服務(wù)器的Socket；

-p或--programs：顯示正在使用Socket的程序識(shí)別碼和程序名稱；

3．創(chuàng)建Flume Agent配置文件flume-telnet-logger.conf

在flume目錄下創(chuàng)建job文件夾并進(jìn)入job文件夾。

mkdir job cd job/ ll touch flume-telnet-logger.conf vi flume-telnet-logger.conf # Name the components on this agent a1.sources = r1 a1.sinks = k1 a1.channels = c1# Describe/configure the source a1.sources.r1.type = netcat a1.sources.r1.bind = henu1 a1.sources.r1.port = 44444# Describe the sink a1.sinks.k1.type = logger# Use a channel which buffers events in memory a1.channels.c1.type = memory a1.channels.c1.capacity = 1000 a1.channels.c1.transactionCapacity = 100# Bind the source and sink to the channel a1.sources.r1.channels = c1 a1.sinks.k1.channel = c1

各參數(shù)的意義：

? ? ?4. 先開啟flume監(jiān)聽端口

flume-ng agent --conf conf/ --name a1 --conf-file /opt/flume/job/flume-telnet-logger.conf -Dflume.root.logger=INFO,console

參數(shù)說明：

--conf conf/ ?：表示配置文件存儲(chǔ)在conf/目錄

--name a1 ：表示給agent起名為a1

--conf-file job/flume-telnet.conf ：flume本次啟動(dòng)讀取的配置文件是在job文件夾下的flume-telnet.conf文件。

-Dflume.root.logger==INFO,console ：-D表示flume運(yùn)行時(shí)動(dòng)態(tài)修改flume.root.logger參數(shù)屬性值，并將控制臺(tái)日志打印級(jí)別設(shè)置為INFO級(jí)別。日志級(jí)別包括:log、info、warn、error。

5．使用telnet工具向本機(jī)的44444端口發(fā)送內(nèi)容

6．在Flume監(jiān)聽頁面觀察接收數(shù)據(jù)情況

總結(jié)

以上是生活随笔為你收集整理的Flume实操（一）【监控端口数据官方案例】的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。