事不宜遲，我們馬上來看這21道最受歡迎，提問率最高的系統(tǒng)設(shè)計(jì)+面向?qū)ο蟮拿嬖囶}，這些問題的分析能讓你輕松應(yīng)對項(xiàng)目設(shè)計(jì)的面試。
1. 如何用Java設(shè)計(jì)自動(dòng)售貨機(jī)？ （解決方案）
你需要編寫代碼來設(shè)計(jì)自動(dòng)售貨機(jī)，該自動(dòng)售貨機(jī)售賣如巧克力，糖果，冷飲之類的產(chǎn)品，需要投入硬幣進(jìn)行購買，例如5分、10分、25分，50分、1元等。確保插入硬幣獲得產(chǎn)品 ，然后退回零錢。 另外，編寫單元測試以證明這些常見用例有效。 如果遇到困難，可以閱讀有關(guān)解決這些經(jīng)典系統(tǒng)設(shè)計(jì)問題的兩部分文章（第1部分和第2部分）。
2. 如何設(shè)計(jì)類似Goo.gl或Bit.Ly的URL縮短服務(wù)？（解決方案）
這是一個(gè)常見的系統(tǒng)設(shè)計(jì)問題。 你給了一個(gè)普通長度的URL，你將如何設(shè)計(jì)為其生成較短且唯一的別名的服務(wù)？ 如果你不熟悉URL縮短程序服務(wù)，請查看一些常用的例子，例如Google的goo.gl和Twitter使用的bit.ly。確保在一些設(shè)計(jì)決策后提供數(shù)據(jù)庫模式和基本原理，例如保留數(shù)據(jù)多長時(shí)間，如何獲取統(tǒng)計(jì)信息和分析等。如果遇到問題，可以參照關(guān)于Educative上“系統(tǒng)設(shè)計(jì)面試課程”中給出的解決方案。
3.你如何設(shè)計(jì)交通控制系統(tǒng)？
經(jīng)典系統(tǒng)設(shè)計(jì)問題仍然提及頻率。 確保你知道如何從一種狀態(tài)過渡到另一種狀態(tài)，例如從紅色過渡到綠色，從綠色過渡到橙色再過渡到紅色等。
4. 如何設(shè)計(jì)限價(jià)單？ （解決方案）
限價(jià)訂單簿在證券交易所中用于根據(jù)價(jià)格和時(shí)間優(yōu)先級將買入訂單與賣出訂單進(jìn)行匹配。 你會(huì)怎么做？ 你將使用哪種數(shù)據(jù)結(jié)構(gòu)？ 請記住，匹配的速度是關(guān)鍵，也是可靠的。 如果你需要復(fù)習(xí)數(shù)據(jù)結(jié)構(gòu)，則可以查看Java課程中的數(shù)據(jù)結(jié)構(gòu)和算法，如果你遇到困難，可以在這里查看我的解決方案。
5. 你如何設(shè)計(jì)類似Pastebin的網(wǎng)站？
Pastebin允許你粘貼文本或代碼，然后在任意位置共享指向該代碼的鏈接。它不是在線代碼編輯器，但是你可以使用它來存儲(chǔ)任何類型的文本。
6. 你將如何創(chuàng)建自己的Instagram？ （解決方案）
Instagram是一個(gè)照片共享應(yīng)用程序，它提供了一些自定義濾鏡以提高照片質(zhì)量。你的應(yīng)用程序應(yīng)該具有照片上傳功能，為搜索標(biāo)記照片以及一些基本的過濾器。如果你可以添加共享或社交網(wǎng)絡(luò)，那就太好不過了。順便說一句，如果你遇到困難，還可以在Educative的如何準(zhǔn)備系統(tǒng)設(shè)計(jì)面試課程中看到免費(fèi)的解決方案。
7. 你如何設(shè)計(jì)像Google Drive或Dropbox這樣的全局文件共享和存儲(chǔ)應(yīng)用程序？
這些用于存儲(chǔ)和共享文件，照片和其他媒體。你如何設(shè)計(jì)諸如允許用戶上傳/查看/搜索/共享文件或照片之類的東西？跟蹤文件共享的權(quán)限，并允許多個(gè)用戶編輯同一文檔？
8. 你如何設(shè)計(jì)類似Whatsapp或Facebook Messenger的聊天應(yīng)用程序？
你肯定使用過WhatsApp和Facebook？沒有？如果沒有，我告訴你聊天應(yīng)用程序允許你向你的朋友發(fā)送消息。這是點(diǎn)對點(diǎn)的連接。你保留一個(gè)朋友列表，查看他們的狀態(tài)并聊天。在WhatsApp中，你也可以連接組，但適用于高級和經(jīng)驗(yàn)豐富的開發(fā)人員。至少，你應(yīng)該提供一種設(shè)計(jì)來保留好友列表并從中發(fā)送和接收消息。
9. 你如何設(shè)計(jì)Twitter克隆？
Twitter是一種流行的消息服務(wù)，可讓你向所有關(guān)注者廣播消息。你發(fā)布推文，你的關(guān)注者可以看到這些消息，他們可以喜歡或轉(zhuǎn)發(fā)。確保實(shí)現(xiàn)了諸如粉絲關(guān)注，主題標(biāo)簽，發(fā)博，刪除等常用功能。如果你覺得自己有點(diǎn)困難，則可以按照如何應(yīng)對系統(tǒng)設(shè)計(jì)面試的課程解決方案進(jìn)行操作。
10. 如何設(shè)計(jì)像YouTube或Netflix這樣的全球視頻流服務(wù)？
設(shè)計(jì)像NetFlix或YouTube這樣的視頻流服務(wù)時(shí)，關(guān)鍵是順暢和緩沖以及在低帶寬連接上的功能，如何應(yīng)對這些挑戰(zhàn)？
11. 如何設(shè)計(jì)ATM機(jī)？
ATM機(jī)允許用戶存入和提取現(xiàn)金。它還允許用戶查看其余額。你如何設(shè)計(jì)這樣的系統(tǒng)？你面臨的主要挑戰(zhàn)是什么？
12. 如何設(shè)計(jì)API速率限制器？
13. 你如何設(shè)計(jì)Twitter搜索？
14. 如何設(shè)計(jì)類似于Google的網(wǎng)絡(luò)爬蟲？
網(wǎng)絡(luò)搜尋器可以訪問網(wǎng)站并像Google一樣搜尋所有鏈接并將它們編入索引，以便它們以后可以出現(xiàn)在搜索結(jié)果中。爬網(wǎng)程序還可用于在一組目錄中搜索特定文件，你如何設(shè)計(jì)此類文件？主要挑戰(zhàn)是什么？
15. 如何設(shè)計(jì)Facebook的Newsfeed？你將使用哪種算法？
新聞源是Facebook的重要組成部分，它使用戶可以查看他的世界正在發(fā)生的事情，包括朋友和家人，他喜歡的頁面，他關(guān)注的組以及Facebook廣告。
Newsfeed算法的作用是顯示對用戶來說最重要的消息，并且可以產(chǎn)生很高的參與度。顯然，來自朋友和家人的消息應(yīng)該優(yōu)先處理。如果你覺得陷入困境，則可以按照如何做好系統(tǒng)設(shè)計(jì)面試的課程所提出解決答案。
16. 如何設(shè)計(jì)Yelp或Nearby Friends?
17. 如何設(shè)計(jì)全球乘車服務(wù)E.G. Uber，Grab或Ola后端？
優(yōu)步（Uber）和奧拉（Ola）是最受歡迎的兩種乘車服務(wù)，它將駕駛員和乘客都組合到一起。你如何設(shè)計(jì)讓乘客看到附近的出租車并進(jìn)行預(yù)訂？
18. 如何設(shè)計(jì)BookMyShow？
一個(gè)允許你預(yù)訂電影院和活動(dòng)門票的網(wǎng)站。這實(shí)際上是一家運(yùn)轉(zhuǎn)良好的印度創(chuàng)業(yè)公司。
19. 如何設(shè)計(jì)Quora，Reddit或Hackernews等社交網(wǎng)絡(luò)+留言板服務(wù)網(wǎng)站？
Reddit，Quora和HackerNews是一些最受歡迎的社交網(wǎng)站，用戶可以在其中發(fā)布問題或共享鏈接。其他用戶可以回答問題或?qū)蚕礞溄影l(fā)表評論。
20. 你如何設(shè)計(jì)類似Airbnb的應(yīng)用程序？
它允許某些用戶上傳房間出租，而其他用戶則出租。某些功能僅適用于管理員，發(fā)布者和訂閱者。
21. 你如何設(shè)計(jì)電梯系統(tǒng)？
我們大多數(shù)人都使用電梯，你在一些大型辦公大樓中，你可以看到3到4部電梯。你需要為此設(shè)計(jì)軟件，以便可以在不同樓層快速使用。你可以假設(shè)你有兩部電梯和一棟10層樓的建筑。
如果你需要一些幫助，那么我建議你可在Udemy上學(xué)習(xí)如何做好系統(tǒng)設(shè)計(jì)面試課程，Rajat Mehta在那里有一個(gè)完整的案例研究來解決這個(gè)問題。你還將在那里學(xué)習(xí)高級系統(tǒng)設(shè)計(jì)，低級系統(tǒng)設(shè)計(jì)和數(shù)據(jù)庫設(shè)計(jì)。
ssh-keygen 產(chǎn)生公鑰與私鑰對.
ssh-copy-id 將本機(jī)的公鑰復(fù)制到遠(yuǎn)程機(jī)器的authorized_keys文件中，ssh-copy-id也能讓你有到遠(yuǎn)程機(jī)器的home, ~./ssh , 和 ~/.ssh/authorized_keys的權(quán)利
第一步:在本地機(jī)器上使用ssh-keygen產(chǎn)生公鑰私鑰對
- zhz@zhz:~/$ ssh-keygen
Generating public/private rsa key pair.
Enter file in which to save the key (/home/zhz/.ssh/id_rsa): - Enter passphrase (empty for no passphrase): [Press enter key
- same passphrase again: [Pess enter key]
- Your identification has been saved in /home/zhz/.ssh/id_rsa.
- Your public key has been saved in /home/zhz/.ssh/id_rsa.pub.
- The key fingerprint is:
- 用cat命令查看是否生成產(chǎn)生公鑰私鑰對
- zhz@zhz:~$ cat .ssh/id_rsa.pub
ssh-rsa AAAAB3NzaC1yc2EAAAADAQABAAABAQCl9N5+xboqSIagBx02rdZ2fkROCPW8iW7hl6Gu+2hkBYYy/b1qcOm8RF/AMyas3i0QEK7Hcu9H51l2lulVbS5n9M9FaWIyYzssaS012x2mg9iA6MxPMlaXFsZ5jnVrGicndzf3VUu9kCErp5q0OzzMjsG3PKQevzWZJSBaFgc8NF5ZJ+VT54BN8ktMTHVwOo15I2Uai+bs4eP0NsuwIJmGyYIUOuvTuUtJxGV3hZ+tcjhupupqVCwYOE+cDz8VkFBGtnKsdE69hWoY2VUfEOAfHZptra7Ce9dXfDgx9jxuuNiJYtGo/bZDfe+UJ5HUv8wrL+hFeRIihdmP2CKJD8j5 zhz@zhz
第二步:用ssh-copy-id將公鑰復(fù)制到遠(yuǎn)程機(jī)器中
- zhz@zhz:~$ ssh-copy-id -i .ssh/id_rsa.pub 用戶名字@192.168.x.xxx
注意: ssh-copy-id 將key寫到遠(yuǎn)程機(jī)器的 ~/ .ssh/authorized_key.文件中
第三步:
登錄到遠(yuǎn)程機(jī)器不用輸入密碼
- zhz@zhz:~$ ssh 用戶名字@192.168.x.xxx
- Last login: Sun Nov 16 17:22:33 2008 from 192.168.1.2
常見問題：
上述是給eucalyptus用戶賦予無密碼登陸的權(quán)利
- /usr/bin/ssh-copy-id: ERROR: No identities found
使用選項(xiàng) -i ，當(dāng)沒有值傳遞的時(shí)候或者 如果 ~/.ssh/identity.pub 文件不可訪問（不存在）, ssh-copy-id 將顯示上述的錯(cuò)誤信息 （ -i選項(xiàng)會(huì)優(yōu)先使用將ssh-add -L的內(nèi)容）
ssh命令
1、復(fù)制SSH密鑰到目標(biāo)主機(jī)，開啟無密碼SSH登錄
ssh-copy-id user@host
如果還沒有密鑰，請使用ssh-keygen命令生成。
2、從某主機(jī)的80端口開啟到本地主機(jī)2001端口的隧道
ssh -N -L2001:localhost:80 somemachine
現(xiàn)在你可以直接在瀏覽器中輸入http://localhost:2001訪問這個(gè)網(wǎng)站。
3、將你的麥克風(fēng)輸出到遠(yuǎn)程計(jì)算機(jī)的揚(yáng)聲器
dd if=/dev/dsp | ssh -c arcfour -C username@host dd of=/dev/dsp
這樣來自你麥克風(fēng)端口的聲音將在SSH目標(biāo)計(jì)算機(jī)的揚(yáng)聲器端口輸出，但遺憾的是，聲音質(zhì)量很差，你會(huì)聽到很多嘶嘶聲。
4、比較遠(yuǎn)程和本地文件
ssh user@host cat /path/to/remotefile | diff /path/to/localfile –
在比較本地文件和遠(yuǎn)程文件是否有差異時(shí)這個(gè)命令很管用。
5、通過SSH掛載目錄/文件系統(tǒng)
sshfs name@server:/path/to/folder /path/to/mount/point
從http://fuse.sourceforge.net/sshfs.html下載sshfs，它允許你跨網(wǎng)絡(luò)安全掛載一個(gè)目錄。
6、通過中間主機(jī)建立SSH連接
ssh -t reachable_host ssh unreachable_host
Unreachable_host表示從本地網(wǎng)絡(luò)無法直接訪問的主機(jī)，但可以從reachable_host所在網(wǎng)絡(luò)訪問，這個(gè)命令通過到reachable_host的“隱藏”連接，創(chuàng)建起到unreachable_host的連接。
7、將你的SSH公鑰復(fù)制到遠(yuǎn)程主機(jī)，開啟無密碼登錄 – 簡單的方法
ssh-copy-id username@hostname
8、直接連接到只能通過主機(jī)B連接的主機(jī)A
ssh -t hostA ssh hostB
當(dāng)然，你要能訪問主機(jī)A才行。
9、創(chuàng)建到目標(biāo)主機(jī)的持久化連接
ssh -MNf <user>@<host>
在后臺創(chuàng)建到目標(biāo)主機(jī)的持久化連接，將這個(gè)命令和你~/.ssh/config中的配置結(jié)合使用：
Host host ControlPath ~/.ssh/master-%r@%h:%p ControlMaster no
所有到目標(biāo)主機(jī)的SSH連接都將使用持久化SSH套接字，如果你使用SSH定期同步文件（使用rsync/sftp/cvs/svn），這個(gè)命令將非常有用，因?yàn)槊看未蜷_一個(gè)SSH連接時(shí)不會(huì)創(chuàng)建新的套接字。
10、通過SSH連接屏幕
ssh -t remote_host screen –r
直接連接到遠(yuǎn)程屏幕會(huì)話（節(jié)省了無用的父bash進(jìn)程）。
11、端口檢測（敲門）
knock <host> 3000 4000 5000 && ssh -p <port> user@host && knock <host> 5000 4000 3000
在一個(gè)端口上敲一下打開某個(gè)服務(wù)的端口（如SSH），再敲一下關(guān)閉該端口，需要先安裝knockd，下面是一個(gè)配置文件示例。
[options] logfile = /var/log/knockd.log [openSSH] sequence = 3000,4000,5000 seq_timeout = 5 command = /sbin/iptables -A INPUT -i eth0 -s %IP% -p tcp –dport 22 -j ACCEPT tcpflags = syn [closeSSH] sequence = 5000,4000,3000 seq_timeout = 5 command = /sbin/iptables -D INPUT -i eth0 -s %IP% -p tcp –dport 22 -j ACCEPT tcpflags = syn
12、刪除文本文件中的一行內(nèi)容，有用的修復(fù)
ssh-keygen -R <the_offending_host>
在這種情況下，最好使用專業(yè)的工具。
13、通過SSH運(yùn)行復(fù)雜的遠(yuǎn)程shell命令
ssh host -l user $(<cmd.txt)
更具移植性的版本：
ssh host -l user “`cat cmd.txt`”
14、通過SSH將MySQL數(shù)據(jù)庫復(fù)制到新服務(wù)器
mysqldump –add-drop-table –extended-insert –force –log-error=error.log -uUSER -pPASS OLD_DB_NAME | ssh -C user@newhost “mysql -uUSER -pPASS NEW_DB_NAME”
通過壓縮的SSH隧道Dump一個(gè)MySQL數(shù)據(jù)庫，將其作為輸入傳遞給mysql命令，我認(rèn)為這是遷移數(shù)據(jù)庫到新服務(wù)器最快最好的方法。
15、刪除文本文件中的一行，修復(fù)“SSH主機(jī)密鑰更改”的警告
sed -i 8d ~/.ssh/known_hosts
16、從一臺沒有SSH-COPY-ID命令的主機(jī)將你的SSH公鑰復(fù)制到服務(wù)器
cat ~/.ssh/id_rsa.pub | ssh user@machine “mkdir ~/.ssh; cat >> ~/.ssh/authorized_keys”
如果你使用Mac OS X或其它沒有ssh-copy-id命令的*nix變種，這個(gè)命令可以將你的公鑰復(fù)制到遠(yuǎn)程主機(jī)，因此你照樣可以實(shí)現(xiàn)無密碼SSH登錄。
17、實(shí)時(shí)SSH網(wǎng)絡(luò)吞吐量測試
yes | pv | ssh $host “cat > /dev/null”
通過SSH連接到主機(jī)，顯示實(shí)時(shí)的傳輸速度，將所有傳輸數(shù)據(jù)指向/dev/null，需要先安裝pv。
如果是Debian：
apt-get install pv
如果是Fedora：
yum install pv
（可能需要啟用額外的軟件倉庫）。
18、如果建立一個(gè)可以重新連接的遠(yuǎn)程GNU screen
ssh -t user@some.domain.com /usr/bin/screen –xRR
人們總是喜歡在一個(gè)文本終端中打開許多shell，如果會(huì)話突然中斷，或你按下了“Ctrl-a d”，遠(yuǎn)程主機(jī)上的shell不會(huì)受到絲毫影響，你可以重新連接，其它有用的screen命令有“Ctrl-a c”（打開新的shell）和“Ctrl-a a”（在shell之間來回切換），請?jiān)L問http://aperiodic.net/screen/quick_reference閱讀更多關(guān)于screen命令的快速參考。
19、繼續(xù)SCP大文件
rsync –partial –progress –rsh=ssh $file_source $user@$host:$destination_file
它可以恢復(fù)失敗的rsync命令，當(dāng)你通過VPN傳輸大文件，如備份的數(shù)據(jù)庫時(shí)這個(gè)命令非常有用，需要在兩邊的主機(jī)上安裝rsync。
rsync –partial –progress –rsh=ssh $file_source $user@$host:$destination_file local -> remote
或
rsync –partial –progress –rsh=ssh $user@$host:$remote_file $destination_file remote -> local
20、通過SSH W/ WIRESHARK分析流量
ssh root@server.com ‘tshark -f “port !22″ -w -' | wireshark -k -i –
使用tshark捕捉遠(yuǎn)程主機(jī)上的網(wǎng)絡(luò)通信，通過SSH連接發(fā)送原始pcap數(shù)據(jù)，并在wireshark中顯示，按下Ctrl+C將停止捕捉，但也會(huì)關(guān)閉wireshark窗口，可以傳遞一個(gè)“-c #”參數(shù)給tshark，讓它只捕捉“#”指定的數(shù)據(jù)包類型，或通過命名管道重定向數(shù)據(jù)，而不是直接通過SSH傳輸給wireshark，我建議你過濾數(shù)據(jù)包，以節(jié)約帶寬，tshark可以使用tcpdump替代：
ssh root@example.com tcpdump -w – ‘port !22′ | wireshark -k -i –
21、保持SSH會(huì)話永久打開
autossh -M50000 -t server.example.com ‘screen -raAd mysession’
打開一個(gè)SSH會(huì)話后，讓其保持永久打開，對于使用筆記本電腦的用戶，如果需要在Wi-Fi熱點(diǎn)之間切換，可以保證切換后不會(huì)丟失連接。
22、更穩(wěn)定，更快，更強(qiáng)的SSH客戶端
ssh -4 -C -c blowfish-cbc
強(qiáng)制使用IPv4，壓縮數(shù)據(jù)流，使用Blowfish加密。
23、使用cstream控制帶寬
tar -cj /backup | cstream -t 777k | ssh host ‘tar -xj -C /backup’
使用bzip壓縮文件夾，然后以777k bit/s速率向遠(yuǎn)程主機(jī)傳輸。Cstream還有更多的功能，請?jiān)L問http://www.cons.org/cracauer/cstream.html#usage了解詳情，例如：
echo w00t, i’m 733+ | cstream -b1 -t2
24、一步將SSH公鑰傳輸?shù)搅硪慌_機(jī)器
ssh-keygen; ssh-copy-id user@host; ssh user@host
這個(gè)命令組合允許你無密碼SSH登錄，注意，如果在本地機(jī)器的~/.ssh目錄下已經(jīng)有一個(gè)SSH密鑰對，ssh-keygen命令生成的新密鑰可能會(huì)覆蓋它們，ssh-copy-id將密鑰復(fù)制到遠(yuǎn)程主機(jī)，并追加到遠(yuǎn)程賬號的~/.ssh/authorized_keys文件中，使用SSH連接時(shí)，如果你沒有使用密鑰口令，調(diào)用ssh user@host后不久就會(huì)顯示遠(yuǎn)程shell。
25、將標(biāo)準(zhǔn)輸入（stdin）復(fù)制到你的X11緩沖區(qū)
ssh user@host cat /path/to/some/file | xclip
你是否使用scp將文件復(fù)制到工作用電腦上，以便復(fù)制其內(nèi)容到電子郵件中？xclip可以幫到你，它可以將標(biāo)準(zhǔn)輸入復(fù)制到X11緩沖區(qū)，你需要做的就是點(diǎn)擊鼠標(biāo)中鍵粘貼緩沖區(qū)中的內(nèi)容。
如果你還有其它SSH命令技巧，歡迎在本文評論中帖出。
原文：http://blog.urfix.com/25-ssh-commands-tricks/
SPRING BATCH中的REMOTE CHUNKING JOB，由于是基于MASTER/SLAVE的架構(gòu)，其中某個(gè)STEP是會(huì)在遠(yuǎn)程機(jī)器中執(zhí)行，如果要停止這個(gè)JOB，需要考慮兩個(gè)問題：
1、什么時(shí)候發(fā)出停止指令
2、如何等待遠(yuǎn)程STEP的完成
一般停止JOB，可用JobOperator.stop(long executionId)來停止，但這個(gè)無法確定什么時(shí)候發(fā)出停止指令，如果是在CHUNK的處理中途發(fā)出，則會(huì)出現(xiàn)回滾的現(xiàn)象。
BATCH_STEP_EXECUTION
thead tr {background-color: ActiveCaption; color: CaptionText;}
th, td {vertical-align: top; font-family: "Tahoma", Arial, Helvetica, sans-serif; font-size: 8pt; padding: 4px; }
table, td {border: 1px solid silver;}
table {border-collapse: collapse;}
thead .col0 {width: 173px;}
.col0 {text-align: right;}
thead .col1 {width: 82px;}
.col1 {text-align: right;}
thead .col2 {width: 282px;}
thead .col3 {width: 164px;}
.col3 {text-align: right;}
thead .col4 {width: 161px;}
thead .col5 {width: 161px;}
thead .col6 {width: 109px;}
thead .col7 {width: 127px;}
.col7 {text-align: right;}
thead .col8 {width: 109px;}
.col8 {text-align: right;}
thead .col9 {width: 118px;}
.col9 {text-align: right;}
thead .col10 {width: 117px;}
.col10 {text-align: right;}
thead .col11 {width: 142px;}
.col11 {text-align: right;}
thead .col12 {width: 150px;}
.col12 {text-align: right;}
thead .col13 {width: 166px;}
.col13 {text-align: right;}
thead .col14 {width: 137px;}
.col14 {text-align: right;}
thead .col15 {width: 109px;}
thead .col16 {width: 156px;}
thead .col17 {width: 161px;}
| STEP_EXECUTION_ID |
VERSION |
STEP_NAME |
JOB_EXECUTION_ID |
START_TIME |
END_TIME |
STATUS |
COMMIT_COUNT |
READ_COUNT |
FILTER_COUNT |
WRITE_COUNT |
READ_SKIP_COUNT |
WRITE_SKIP_COUNT |
PROCESS_SKIP_COUNT |
ROLLBACK_COUNT |
EXIT_CODE |
EXIT_MESSAGE |
LAST_UPDATED |
| 2304 |
169 |
step2HandleXXX |
434 |
2020-06-22 16:27:54 |
2020-06-22 16:32:46 |
STOPPED |
167 |
5010 |
0 |
4831 |
0 |
155 |
0 |
161 |
STOPPED |
org.springframework.batch.core.JobInterruptedException |
2020-06-22 16:32:46 |
另外SPRING BATCH也不會(huì)等遠(yuǎn)程STEP執(zhí)行完成，就將JOB的狀態(tài)設(shè)為Complete。
發(fā)出停止的指令應(yīng)通過ChunkListener達(dá)成：
public class ItemMasterChunkListener extends ChunkListenerSupport{
private static final Logger log = LoggerFactory.getLogger(ItemMasterChunkListener.class);
@Override
public void beforeChunk(ChunkContext context) {
log.info("ItemMasterProcessor.beforeChunk");
}
@Override
public void afterChunk(ChunkContext context) {
log.info("ItemMasterProcessor.afterChunk");
if(XXXX.isStoppingOrPausing()) {
log.info("context.getStepContext().getStepExecution().setTerminateOnly()");
context.getStepContext().getStepExecution().setTerminateOnly();
}
}
@Override
public void afterChunkError(ChunkContext context) {
log.info("ItemMasterProcessor.afterChunkError");
}
}
配置BEAN：
@Bean
@StepScope
public ItemMasterChunkListener novaXItemMasterChunkListener() {
return new ItemMasterChunkListener();
}
this.masterStepBuilderFactory
.<X, X>get("step2Handle")
.listener(itemMasterChunkListener())
.build();
由于是在CHUNK完成的時(shí)候發(fā)出停止指令，就不會(huì)出現(xiàn)ROLLBACK的情況。
等待遠(yuǎn)程STEP完成，通過讀取MQ上的MESSAGE是否被消費(fèi)完成，PENDDING的MESSAGE為0的條件即可。
public class JobExecutionListenerSupport implements JobExecutionListener {
/* (non-Javadoc)
* @see org.springframework.batch.core.domain.JobListener#afterJob()
*/
@Override
public void afterJob(JobExecution jobExecution) {
Integer totalPendingMessages = 0;
String queueName = "";
String messageSelector = "JOB_EXECUTION_ID=" + jobExecution.getJobInstance().getInstanceId();
do{
totalPendingMessages =
this.jmsTemplate.browseSelected(queueName, messageSelector,
(session, browser) ->
Collections.list(browser.getEnumeration()).size()
);
String brokerURL = null;
if(jmsTemplate.getConnectionFactory() instanceof JmsPoolConnectionFactory) {
JmsPoolConnectionFactory connectionFactory =
(JmsPoolConnectionFactory)jmsTemplate.getConnectionFactory();
ActiveMQConnectionFactory activeMQConnectionFactory =
(ActiveMQConnectionFactory)connectionFactory.getConnectionFactory();
brokerURL = activeMQConnectionFactory.getBrokerURL();
} else if(jmsTemplate.getConnectionFactory() instanceof CachingConnectionFactory) {
CachingConnectionFactory connectionFactory =
(CachingConnectionFactory)jmsTemplate.getConnectionFactory();
ActiveMQConnectionFactory activeMQConnectionFactory =
(ActiveMQConnectionFactory)connectionFactory.getTargetConnectionFactory();
brokerURL = activeMQConnectionFactory.getBrokerURL();
}
LOGGER.info("queueName = {}, {}, totalPendingMessages = {}, url={}",
queueName, messageSelector, totalPendingMessages, brokerURL);
Assert.notNull(totalPendingMessages, "totalPendingMessages must not be null.");
try {
Thread.sleep(5_000);
} catch (InterruptedException e) {
LOGGER.error(e.getMessage(), e);
}
} while(totalPendingMessages.intValue() > 0);
}
/* (non-Javadoc)
* @see org.springframework.batch.core.domain.JobListener#beforeJob(org.springframework.batch.core.domain.JobExecution)
*/
@Override
public void beforeJob(JobExecution jobExecution) {
}
}
這樣整個(gè)JOB就能無異常地停止，且會(huì)等待遠(yuǎn)程STEP完成。
Reference:
https://docs.spring.io/spring-batch/docs/4.1.3.RELEASE/reference/html/common-patterns.html#stoppingAJobManuallyForBusinessReasons
https://stackoverflow.com/questions/13603949/count-number-of-messages-in-a-jms-queue
https://stackoverflow.com/questions/55499965/spring-batch-stop-job-execution-from-external-class
https://stackoverflow.com/questions/34621885/spring-batch-pollable-channel-with-replies-contains-chunkresponses-even-if-job