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

2）需求分析：

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

? ? 1．安裝telnet工具

yum install telnet

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

sudo netstat -tunlp | grep 44444

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

基本語法：netstat [選項]

選項參數(shù)：

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

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

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

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

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

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

在flume目錄下創(chuàng)建job文件夾并進入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/ ?：表示配置文件存儲在conf/目錄

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

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

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

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

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

總結

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

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