歡迎訪問我的GitHub
https://github.com/zq2599/blog_demos
內容：所有原創文章分類匯總及配套原始碼，涉及Java、Docker、Kubernetes、DevOPS等；
IDEA是常用的IDE，我們撰寫的flink任務代碼如果能直接在IDEA運行，會給學習和開發帶來很大便利，例如改完代碼立即運行不用部署、斷點、單步除錯等；
環境資訊
- 電腦：2019版13寸MacBook Pro，2.3 GHz 四核Intel Core i5，8 GB 2133 MHz LPDDR3
- 作業系統：macOS Catalina 10.15.3
- JDK：1.8.0_211
- Maven：3.6.0
- IDEA：2018.3.5 (Ultimate Edition)
- Flink版本：1.9.2
關于正版IDEA
如何免費使用正版IDEA，可以參考《免費申請和使用IntelliJ IDEA商業版License指南》
開發
- 首先確保您電腦上maven已裝好；
- 創建一個flink任務的maven工程，找個干凈目錄執行以下命令：
mvn \
archetype:generate \
-DarchetypeGroupId=org.apache.flink \
-DarchetypeArtifactId=flink-quickstart-java \
-DarchetypeVersion=1.9.2
- 按提示輸入groupId、artifactId、version、package等內容：
4. 現在maven工程已生成，用IDEA匯入這個工程，如下圖：
5. 以maven的型別匯入：
6. 匯入成功后的樣子：
7. 修改StreamingJob.java，加入功能是監聽本地18081埠，得到的字串做word count操作，完整代碼在此下載：https://raw.githubusercontent.com/zq2599/blog_demos/master/files/StreamingJob.java
8. 現在的代碼已經能運行，但flink網頁卻還不能訪問，會顯示以下錯誤資訊，需要繼續做些設定：
9. 下載flink-1.9.2安裝包，這里面有flink網頁服務用到的一個jar，地址是：https://www-eu.apache.org/dist/flink/flink-1.9.2/flink-1.9.2-bin-scala_2.11.tgz
10. flink-1.9.2-bin-scala_2.11.tgz下載后解壓，在lib目錄下有個flink-dist_2.11-1.9.2.jar檔案，記住此檔案的位置，稍后會用到；
11. 回到IDEA，在專案上點擊右鍵，點擊選單Open Module Settings：
12. 在彈出的視窗做如下操作，目的是給專案中增加jar：
13. 彈出選擇檔案的視窗，請選擇剛才準備好的檔案flink-dist_2.11-1.9.2.jar：
14. 設定作業已經完成，由于StreamingJob的作業是讀取本機18081埠的資料，所以我們要把18081埠的服務啟動起來，不然StreamingJob運行時是連不上埠的，打開一個控制臺，執行命令：nc -l 18081
15. 現在可以將StreamingJob運行起來，如下圖，右鍵點擊StreamingJob，選擇Run 'StreamingJob.main()'：即可啟動flink任務，如果想打斷點除錯，請選擇Debug 'StreamingJob.main()'
16. 回到剛才執行nc命令的控制臺，輸入一些字串，例如"aaa bbb aaa"，然后回車；
17. 再回到IDEA，可見StreamingJob已經從18081埠讀到了資料并且輸出了統計結果：
18. 在IDEA的控制臺搜索關鍵字localhost，如下圖紅框，可以查到flink網頁的埠，我這里是62641：
19. 瀏覽器訪問http://localhost:62641，如下圖，可見flink網頁已經正常顯示，正在運行的任務也能看到：
至此，最簡單的IDEA運行flink任務的實戰就完成了，如果您也在學習flink，希望本文能給您一些參考；
歡迎關注公眾號：程式員欣宸
微信搜索「程式員欣宸」，我是欣宸，期待與您一同暢游Java世界...
https://github.com/zq2599/blog_demos
轉載請註明出處，本文鏈接：https://www.uj5u.com/houduan/195052.html
標籤：Java
上一篇：Java9系列第九篇-對HTTP2協議的支持與非阻塞HTTP-API
下一篇：python 安裝 whl檔案