而且1。3T發動機配合CVT變速箱，動力也平順。起步的動力不算強，不過挺平順的，像我這些開車不急的人，它的動力夠用了。我的遠景SUV行駛了有3200公里，平均油耗只有8。3L，這個表現讓人滿意。車主：彩色購買車型：1。3T CVT豪華型裸車價格：9。

吉利汽車-遠景SUV

指導價：7.49-10.19萬

車主：南通達人

購買車型：1.8L 手動尊貴型

裸車價格：8.49萬

最滿意的是它的做工質感很不錯，落鎖就自動關閉天窗這個功能很實用！空間夠用，座椅也舒適。動力方面，一擋、二擋起步很有推背感，手動變速箱的手感也不差。

就是發動機怠速時聲音有點大，還有音響的音質一般般，後排座椅不能完全放平，不過空間真的夠大。

目前我的車行駛了2410公里，平均的百公里油耗是8.17L，因為是SUV，所以不算高。

車主：北方的小強

購買車型：1.3T CVT旗艦型

裸車價格：10.19萬

遠景SUV空間大、底盤高。日常溫柔駕駛很舒適！內飾用了很多軟質材料，摸着舒服。而且1.3T發動機配合CVT變速箱，動力也平順。

起步的動力不算強，不過挺平順的，像我這些開車不急的人，它的動力夠用了！

我的遠景SUV行駛了有3200公里，平均油耗只有8.3L，這個表現讓人滿意。

車主：彩色

購買車型：1.3T CVT豪華型

裸車價格：9.49萬

空間大、價格不高、油耗不高！是我選擇它的原因。車子在150km/h內都比較穩，不發飄。轉向也比較精準，回饋力度也合適。

尾部設計有些不夠大氣，不過尾燈卻挺好看的。高速過彎的時候側傾會有一點明顯，不過這麼高的一輛SUV,當然以舒適性位為主。

現在我的車開了2900公里了，平時愛激烈駕駛，所以油耗一般要9.6L，比其他車主都要高！

編者點評：

遠景SUV的空間、用料、配置都表現不錯，加上一個不高的售價讓它性價比表現出色！而1.3T發動機在平順駕駛的情況下還是比較省油的。喜歡這款車型的話，快去4S店試駕一番吧。本站聲明:網站內容來源於http://www.auto6s.com/,如有侵權,請聯繫我們,我們將及時處理

【其他文章推薦】

※網頁設計一頭霧水該從何著手呢? 台北網頁設計公司幫您輕鬆架站!

※網頁設計公司推薦不同的風格，搶佔消費者視覺第一線

※想知道購買電動車哪裡補助最多?台中電動車補助資訊懶人包彙整

※南投搬家公司費用,距離,噸數怎麼算?達人教你簡易估價知識!

※教你寫出一流的銷售文案?

※超省錢租車方案

價格也比較實惠，開出去一點也不像幾萬塊錢的車子。配置很豐富，主副駕氣囊必不可少，還有前排側氣囊、ESp、上坡輔助、天窗、真皮方向盤、仿皮座椅、中控大屏等等，性價比很高。不滿意的：開了這麼久發動機有一絲咕嚕聲，其它沒問題，不過這應該也是小問題，其他車主沒有遇到我這樣的問題，回頭有空了開去4S點給它檢查一下，治治病。

最近身邊一個朋友想買一台七座的MpV，預算在7萬到10萬，問我選擇什麼比較好，我毫不猶豫的推薦了寶駿730。

他問我為什麼那麼直接就推薦了730，我答道：因為車主們對730很滿意。

上汽通用五菱-寶駿730

指導價：6.08-9.28萬

車主一：小羅

購買車型：2016款 1.5L 手動超值型 7座

裸車價格：5.98萬

車主點評：外形大氣，很多購買730的車友們就是看中他大氣的外觀，而且很有商務氣息，特別是車尾，感覺有那麼一絲GL8的影子。引擎蓋比較長，看上去協調不少，再加上是前置前驅，噪音比后驅車小！

不滿意的：我的車型是超值型，可能是價格已經做的夠低了，所以沒有ESp，這樣讓我跑高速的時候心有餘悸。希望730可以全系標配ESp。

車主一：隔壁老王

購買車型：2016款 1.5L 手動豪華型 7座

裸車價格：7.86萬

車主點評：最滿意的就是空間非常大，既能載人又能拉貨，外觀高端大氣上檔次，到了裏面乘坐很舒服，特別是中間兩個座椅最舒服。價格也比較實惠，開出去一點也不像幾萬塊錢的車子。配置很豐富，主副駕氣囊必不可少，還有前排側氣囊、ESp、上坡輔助、天窗、真皮方向盤、仿皮座椅、中控大屏等等，性價比很高。

不滿意的：開了這麼久發動機有一絲咕嚕聲，其它沒問題，不過這應該也是小問題，其他車主沒有遇到我這樣的問題，回頭有空了開去4S點給它檢查一下，治治病。

車主三：小喇叭

購買車型：2016款 1.5T 手動豪華型 7座

裸車價格：8.38萬

車主點評：當時試駕的是1.5L車型，感覺不是很給力，我是個急性子，受不了較弱的動力。正好730推出了1.5T車型，1.5T豪華型和1.5L豪華型指導價就差2000元，其它配置基本一樣，相當於多花2000塊買了一個渦輪發動機。絕對很值得。動力充足，爆發力強，外觀大氣，空間巨大，配置很高，口碑很好，絕對值得入手，

不滿意的：A柱盲區有點大，左轉受影響較大，1擋不是很好掛，中控台防水能力較差，做工比較一般。

總結：在這個價位，730的性價比可以說是比價高的，無論外觀還是內飾、配置、舒適性都有着很好的表現，確實是一個家用好幫手。本站聲明:網站內容來源於http://www.auto6s.com/,如有侵權,請聯繫我們,我們將及時處理

【其他文章推薦】

※廣告預算用在刀口上，台北網頁設計公司幫您達到更多曝光效益

※別再煩惱如何寫文案,掌握八大原則!

※教你寫出一流的銷售文案?

※超省錢租車方案

※廣告預算用在刀口上，台北網頁設計公司幫您達到更多曝光效益

※產品缺大量曝光嗎?你需要的是一流包裝設計!

在傳統思維上，也許你覺得智能化和皮卡根本毫無瓜葛。T60打破了這種陳建，首創在皮卡上開發了Normal/Eco/power三種駕駛模式。在輕載或行駛在平坦路面時，選擇ECO模式，以達到更好的燃油經濟性。在山路、工地等複雜路況或重載時，選擇power模式，帶來更強勁的動力。

在中國，皮卡一直以邊緣車型處在一個尷尬境地，各類歧視性政策更是讓實用價值很高的皮卡被人們敬而遠之，和國外濃厚的皮卡文化相比，我們仍然處於一個嬰兒般的市場狀態，如何培育，如何增長，如何推廣，都成了皮卡的廠商一個大難題，而且中國皮卡造型多以中庸的外觀出現，講究皮實耐用，與國內80后、90后追求外觀、個性的性格有些格格不入，所以，皮卡車企如何適應當前社會潮流，推出適合當下年輕人喜歡的中高端皮卡，將是刺激當前皮卡市場的一劑強心劑，也是一個對於廠商來說一個最大的突破口。

縱觀國內皮卡市場，雖然每年有着40萬輛左右的銷量，但產品的各方面整體較落後，市場上缺少一款性能卓越，讓用戶滿意的產品。在此背景下，上汽T60的誕生就是為了引領並推動國內皮卡市場。

12月21日，上汽大通邀經銷商夥伴聚集海南博鰲，回顧輝煌業績，共贏未來。回望2016年，在今年的廣州車展上，上汽大通推出了“划時代皮卡”——T60，當時只是公布了售價區間為9.98-19.98萬元。

與會期間，上汽大通為大家揭開了最後的謎底，官方公布T60各款車型的價格

T60柴油兩驅低底盤價格表

T60柴油兩驅高底盤價格表

T60柴油四驅高底盤價格表

突破傳統，時尚觀感遇見智能互聯

T60在外觀造型上有了重大突破，在我們之前的印象中，皮卡一向講求“內修”只要實用，空間大，力量足就行，但是T60確實是做到了“內外兼修”摒棄此前皮卡車過於單調、落後的特點，用迎合年輕一代用車群體的需求作為設計出發點，這款T60皮卡有着眾多獨特個性與亮點，稜角分明的前臉造型線條十分豐富，直瀑式進氣格柵突出了皮卡車型硬朗風格的同時也融入現代SUV的時尚元素。多邊形前大燈組造型，近光燈帶有透鏡結構，保險杠底部的霧燈則顯得十分秀氣。直觀的感受，T60帶來一款讓人耳目一新的皮卡。

在內飾設計上，T60整體造型顯得十分簡潔，全車黑色搭配銀色鍍鉻飾條，T形對稱式中控檯布局，大尺寸的液晶显示屏搭載了上汽與阿里共同開發的YunOS車聯網系統，提供智能車管家、在線互聯、遠程控制、語音識別等智能功能，這些科技的配置完全不輸一台B級車的配置了，而且皮卡上配備了pEpS無鑰匙進入一鍵啟動功能，這樣的皮卡配置確實有些無敵了。

作為一款皮卡，動力方面是其必須具備的，畢竟它的主要角色擔當是裝載及運輸，所以對於動力的要求會很高，那T60搭載了來自意大利VM的2.8T柴油發動機，其最大功率為110千瓦，最大扭矩360牛米，這樣的動力是足夠消費者輕鬆應對各種繁重任務了。

值得一提的，T60首次在皮卡上配備了6AT自動變速箱，這讓其在彎道或變速方面更加應付自如。

在傳統思維上，也許你覺得智能化和皮卡根本毫無瓜葛。T60打破了這種陳建，首創在皮卡上開發了Normal/Eco/power三種駕駛模式。在輕載或行駛在平坦路面時，選擇ECO模式，以達到更好的燃油經濟性；在山路、工地等複雜路況或重載時，選擇power模式，帶來更強勁的動力。這種改變，大大滿足了越來越多的年輕用戶希望有更輕鬆的駕駛體驗的需求。

最後，不得不提是T60在安全配置方面的專家級表現，T60以澳洲A-NCAp五星碰撞安全標準進行設計，首次將熱成型技術運用於皮卡，並通過激光焊接，大幅提升車身強度；T60還率先採用6安全氣囊，為駕乘人員提供全方位的保護。

T60首次在皮卡上配備，AFS隨動轉向LED大燈，根據車輛轉向，自動調節大燈照射角度，為用戶夜晚行車，提供更寬闊的照明視野。

在面對雨雪泥濘、崎嶇山路行駛時出現甩尾、側滑等險情時， T60採用BOSCH 9.0，ESp車身穩定控制系統，給皮卡用戶在各種工況下，帶來更好的行車穩定性。並把360環視影像、LDW車道偏離預警、疲勞駕駛提醒，等多項安全配置，首次應用在皮卡上，提供全方位的安全保障。

在美國，皮卡代表了張揚、自由與個性，涵蓋了美國英雄主義的西部文化，駕駛皮卡犹如之前的騎馬一樣輕鬆自然，而在中國恰恰缺少美國一樣的皮卡文化。

隨着皮卡市場的春天來臨，大家對皮卡的關注與討論與日俱增。同時，上汽大通T60更是憑藉行業首創的C2B理念，提供最全面的產品型譜和組合，上汽大通T60作為一輛外觀時尚、性能卓越、注重安全的皮卡，將會引領皮卡市場走向宜商宜家的高端路線。這樣一款划時代的皮卡，讓我們更加期待其精彩的市場表現。本站聲明:網站內容來源於http://www.auto6s.com/,如有侵權,請聯繫我們,我們將及時處理

【其他文章推薦】

※別再煩惱如何寫文案,掌握八大原則!

※網頁設計一頭霧水該從何著手呢? 台北網頁設計公司幫您輕鬆架站!

※超省錢租車方案

※教你寫出一流的銷售文案?

※網頁設計最專業,超強功能平台可客製化

※產品缺大量曝光嗎?你需要的是一流包裝設計!

98萬的價格。而且RV80型譜包含B型和C型房車，擁有短軸/長軸/加長軸，低頂/中頂/高頂多種車身形式，用戶可通過C2B線上交互平台，可直接在線訂製房車，OTD高效透明，消費者可參与試駕、試住等全體驗式互動，享受真正的價值和樂趣。

買一輛房車，開到郊外，給自己一個遠離城市堵車和污染的樂土,傍晚一邊欣賞湖邊那一抹落日一邊和家人烹制一頓可口的晚餐；晚上透過大大的天窗看沒有污染的星空；亦或把車停在海邊，換上泳衣下海衝浪，回來后在寬敞的洗澡間沖個熱水澡這份嚮往其實不僅僅是一輛車，而是一種生活方式更是一種房車生活的文化，這才是一種說走就走的旅行，因為不用規劃路線，不用訂酒店，風景在那，走到那，家在路上。

近日，一場融新款房車上市發布、房車露營大會、草地音樂狂歡節、美酒佳肴於一體的“全體驗式”上市發布會登陸海南博鰲，由“中國房車第一品牌”上汽大通打造的2016“新旅程·心享受”房車之夜暨房車新品上市發布會亮相南海之濱，全新房車RV80在萬眾期待中揭開神秘面紗。

當晚，配合現場炫目的燈光秀，國內首款滿足國五排放標準的高端房車——上汽大通全新房車RV80正式發布。

新款房車憑藉六大產品優勢，定義房車行業新標杆，其搭載源自歐洲的VM柴油發動機，最高功率110KW，綜合油耗百公里僅為8.3L；全系國5排放標準；在國內房車行業中率先使用AMT技術；而且全車座椅是達乘用級安全標準。

消費者最為關心的價格也在上市會上正式揭曉，售：26.98萬至51.98萬的價格。

而且RV80型譜包含B型和C型房車，擁有短軸/長軸/加長軸，低頂/中頂/高頂多種車身形式，用戶可通過C2B線上交互平台，可直接在線訂製房車，OTD高效透明，消費者可參与試駕、試住等全體驗式互動，享受真正的價值和樂趣。

雖然國內房車起步晚，房車少、營地少，在心往來說，移動露營來說比較難實現，但隨着房車市場近幾年的發展，房車露營地的逐漸增多，露營地的規劃與擬建逐漸完善，移動露營的實現，在今天已經變的越來越便利了。

房車，又稱“車輪上的家”，兼具“房”與“車”兩大功能，但其屬性還是車，相比普通汽車，房車上的居家設施有爐具、冰箱、櫥櫃、沙發、餐桌椅、盥洗設施、空調、電視、音響等傢具和電器等，隨心而行，隨景而歇，這是一種房車的生活狀態。

購買房車的理由可以很多，可能是為了帶着父母去旅行，也可能是為了滿足夫妻雙方共同的旅行夢想，也可以一群朋友同事用懷揣探索的心踏上未知的旅途，無論是兩個人駕駛房車出行，要過一次久違的二人世界或帶着一家人遠離都市的喧鬧，這都是我們嚮往的生活，而房車是對於這種嚮往的一個載體，一個最適合的載體。

國內消費者對待房車的消費觀念正在發生轉變，讓目前的房車市場顯得更為火爆，現在很多人的旅遊觀念都在轉變，更加傾向於自駕出遊，而非報團旅行。而自駕的長途旅行，使得房車成為了旅行者的首選。

但相應的配套設施卻略顯單薄，最大的制約就是目前國內房車露營地較少，無法為房車提供停放場所。畢竟在房車內生活，做飯、取暖、照明等都需要電力和水源，雖然房車裡自帶有蓄電池和水源儲蓄，但容量的限制最多只能保證一兩個晚上的生活需求，這也是制約房車發展最重要的一個條件。

對於現在房車的各方面使用性來說，可能有些人覺的買了回來，使用率比較低，上汽大通也在2017年投入超過1200輛房車，試水房車租賃市場，與運營夥伴在全國鋪開租賃網絡。

讓用戶輕鬆體驗到大通房車落地自駕的樂趣；開發了“房車生活家”平台，為房車用戶和潛客用戶提供“@房車”、“@生活”、“@家”三個方面的服務，構建多個使用和體驗場景，實現在線房車自駕游線路推薦和預訂、營地推薦和預訂，閱讀攻略遊記、預約試駕體驗、參加自駕活動等功能。

也可掃二維碼了解更多房車生活及房車租賃信息，而且還有很多優惠信息喔!

@房車生活家本站聲明:網站內容來源於http://www.auto6s.com/,如有侵權,請聯繫我們,我們將及時處理

【其他文章推薦】

※教你寫出一流的銷售文案?

※廣告預算用在刀口上，台北網頁設計公司幫您達到更多曝光效益

※回頭車貨運收費標準

※別再煩惱如何寫文案,掌握八大原則!

※超省錢租車方案

※產品缺大量曝光嗎?你需要的是一流包裝設計!

但相信2765mm的軸距將會給用戶一個滿意的乘坐空間。後排無論在橫向還是縱向空間都是足夠大而舒適，頭部空間則因車頂後排頭頂位置為內凹設計，也是很讓人滿意。“低”價格，高配置啟辰T90的內飾給人的感覺跟外觀還是有些不一樣，整體的風格偏向於穩重，但穩重中也沒有忽略運動感的塑造。

在目前的國內市場，SUV尤其的火爆，可以這麼說，當人們有需求的時候，市場就會自動做出調整生產符合消費者要求的產品。在這種情況下，很多廠家也紛紛都將矛頭指向了緊湊型的SUV，以及二胎政策捧紅的7座中型SUV。然而，啟辰獨辟蹊徑，瞄準了85后消費群體，打造了溜背式的中型SUV啟辰T90，憑藉媲美合資車的生產品質、顛覆傳統的驚艷設計、充滿競爭力的價格，勢必成為中型SUV現有市場格局的全新標杆。

12月25日，啟辰全新中型SUV啟辰T90正式上市，售價區間為10.98—15.48萬元，共推出6款車型。

個性時尚的外觀

啟辰T90最大的亮點可以說是外觀造型，無論是前臉還是性感的“背影”，開這麼一款SUV在路上，回頭率都會是極高的。其採用了全新的家族式前臉和溜背式SUV的風雕美學設計。不是華麗的簡單堆砌，而是經過設計師無數次對細節完美追求的結果。總體來看，不管是在研發設計還是產品定位上，啟辰T90的設計感並不亞於一些合資品牌。

寬敞舒適的空間

說到這裏，也許有人會問，採用溜背造型的設計，其後排空間會不會就因此受到影響，要說完全沒有，這個有點不現實。但相信2765mm的軸距將會給用戶一個滿意的乘坐空間。後排無論在橫向還是縱向空間都是足夠大而舒適，頭部空間則因車頂後排頭頂位置為內凹設計，也是很讓人滿意。

“低”價格，高配置

啟辰T90的內飾給人的感覺跟外觀還是有些不一樣，整體的風格偏向於穩重，但穩重中也沒有忽略運動感的塑造。值得一提的還有，中控台上12.3英寸的大屏，從布局上就可以看得出設計的用心，其呈環抱式位置分佈，主駕駛席無需起身即可完成所有操作；真皮座椅，搭配着藍色的氛圍燈，精密的雙縫線，各處接縫的高度契合，使內飾整體更有質感，是現代年輕一代受眾所青睞的。

除了以上提到的，還有智能互聯、高科技配置和安全配置等方面，啟辰T90也展示出非凡的實力，可以說是智超所值。IT-COMMANDER旋鈕式信息控制系統堪稱同級SUV罕有的“鼠標”式車載控制系統，集便利性、簡易性、精美性於一體，觸控隨心所欲；全彩3D平視信息显示系統以駕駛者為中心，操控簡潔。啟辰T90還具備駕駛提醒、胎壓監測、泊車輔助等功能，在白色高亮質感照明和多功能方向盤按鍵控制下，能夠帶來更清晰、更科技、更好操作的显示效果。

總結：如今中型SUV市場，早已是一片紅海，啟辰T90無論是獨樹一幟的外觀，還是空間、配置，以及親民的價格，都可以說，將會讓它在這片紅海中，逆襲上位、脫穎而出，成為業內的一個新標杆。期待在未來，啟辰T90成為下一个中型SUV爆款。本站聲明:網站內容來源於http://www.auto6s.com/,如有侵權,請聯繫我們,我們將及時處理

【其他文章推薦】

※超省錢租車方案

※別再煩惱如何寫文案,掌握八大原則!

※回頭車貨運收費標準

※教你寫出一流的銷售文案?

※產品缺大量曝光嗎?你需要的是一流包裝設計!

※廣告預算用在刀口上，台北網頁設計公司幫您達到更多曝光效益

本文源碼：GitHub·點這裏 || GitEE·點這裏

一、Kafka集群環境

1、環境版本

版本：kafka2.11，zookeeper3.4

注意：這裏zookeeper3.4也是基於集群模式部署。

2、解壓重命名

tar -zxvf kafka_2.11-0.11.0.0.tgz
mv kafka_2.11-0.11.0.0 kafka2.11

創建日誌目錄

[root@en-master kafka2.11]# mkdir logs

注意：以上操作需要同步到集群下其他服務上。

3、添加環境變量

vim /etc/profile
export KAFKA_HOME=/opt/kafka2.11
export PATH=$PATH:$KAFKA_HOME/bin
source /etc/profile

4、修改核心配置

[root@en-master /opt/kafka2.11/config]# vim server.properties
-- 核心修改如下
# 唯一編號
broker.id=0
# 開啟topic刪除
delete.topic.enable=true
# 日誌地址
log.dirs=/opt/kafka2.11/logs
# zk集群
zookeeper.connect=zk01:2181,zk02:2181,zk03:2181

注意：broker.id安裝集群服務個數編排即可，集群下不能重複。

5、啟動kafka集群

# 啟動命令
[root@node02 kafka2.11]# bin/kafka-server-start.sh -daemon config/server.properties
# 停止命令
[root@node02 kafka2.11]# bin/kafka-server-stop.sh
# 進程查看
[root@node02 kafka2.11]# jps

注意：這裏默認啟動了zookeeper集群服務，並且集群下的kafka分別啟動。

6、基礎管理命令

創建topic

bin/kafka-topics.sh --zookeeper zk01:2181 \
--create --replication-factor 3 --partitions 1 --topic one-topic

參數說明：

• replication-factor 定義副本個數
• partitions 定義分區個數
• topic：定義topic名稱

查看topic列表

bin/kafka-topics.sh --zookeeper zk01:2181 --list

修改topic分區

bin/kafka-topics.sh --zookeeper zk01:2181 --alter --topic one-topic --partitions 5

查看topic

bin/kafka-topics.sh --zookeeper zk01:2181 \
--describe --topic one-topic

發送消息

bin/kafka-console-producer.sh \
--broker-list 192.168.72.133:9092 --topic one-topic

消費消息

bin/kafka-console-consumer.sh \
--bootstrap-server 192.168.72.133:9092 --from-beginning --topic one-topic

刪除topic

bin/kafka-topics.sh --zookeeper zk01:2181 \
--delete --topic first

7、Zk集群用處

Kafka集群中有一個broker會被選舉為Controller，Controller依賴Zookeeper環境，管理集群broker的上下線，所有topic的分區副本分配和leader選舉等工作。

二、消息攔截案例

1、攔截器簡介

Kafka中間件的Producer攔截器主要用於實現消息發送的自定義控制邏輯。用戶可以在消息發送前以及回調邏輯執行前有機會對消息做一些自定義，比如消息修改等，發送狀態監控等，用戶可以指定多個攔截器按順序執行攔截。

核心方法

• configure：獲取配置信息和初始化數據時調用；
• onSend：消息被序列化以及和計算分區前調用該方法，可以對消息做操作；
• onAcknowledgement：消息發送到Broker之後，或發送過程失敗時調用；
• close：關閉攔截器調用，執行一些資源清理工作；

注意：這裏說的攔截器是針對消息發送流程。

2、自定義攔截

定義方式：實現ProducerInterceptor接口即可。

攔截器一：在onSend方法中，對攔截的消息進行修改。

@Component
public class SendStartInterceptor implements ProducerInterceptor<String, String> {

    private final Logger LOGGER = LoggerFactory.getLogger("SendStartInterceptor");
    @Override
    public void configure(Map<String, ?> configs) {
        LOGGER.info("configs...");
    }
    @Override
    public ProducerRecord<String, String> onSend(ProducerRecord<String, String> record) {
        // 修改消息內容
        return new ProducerRecord<>(record.topic(), record.partition(),
                                    record.timestamp(), record.key(),
                              "onSend：{" + record.value()+"}");
    }
    @Override
    public void onAcknowledgement(RecordMetadata metadata, Exception exception) {
        LOGGER.info("onAcknowledgement...");
    }
    @Override
    public void close() {
        LOGGER.info("SendStart close...");
    }
}

攔截器二：在onAcknowledgement方法中，判斷消息是否發送成功。

@Component
public class SendOverInterceptor implements ProducerInterceptor<String, String> {

    private final Logger LOGGER = LoggerFactory.getLogger("SendOverInterceptor");
    @Override
    public void configure(Map<String, ?> configs) {
        LOGGER.info("configs...");
    }

    @Override
    public ProducerRecord<String, String> onSend(ProducerRecord<String, String> record) {
        LOGGER.info("record...{}", record.value());
        return record ;
    }

    @Override
    public void onAcknowledgement(RecordMetadata metadata, Exception exception) {
        if (exception != null){
            LOGGER.info("Send Fail...exe-msg",exception.getMessage());
        }
        LOGGER.info("Send success...");
    }

    @Override
    public void close() {
        LOGGER.info("SendOver close...");
    }
}

加載攔截器：基於一個KafkaProducer配置Bean，加入攔截器。

@Configuration
public class KafkaConfig {

    @Bean
    public Producer producer (){
        Properties props = new Properties();
        // 省略其他配置...
        // 添加攔截器
        List<String> interceptors = new ArrayList<>();
        interceptors.add("com.kafka.cluster.interceptor.SendStartInterceptor");
        interceptors.add("com.kafka.cluster.interceptor.SendOverInterceptor");
        props.put(ProducerConfig.INTERCEPTOR_CLASSES_CONFIG, interceptors);
        return new KafkaProducer<>(props) ;
    }
}

3、代碼案例

@RestController
public class SendMsgWeb {
    @Resource
    private KafkaProducer<String,String> producer ;
    @GetMapping("/sendMsg")
    public String sendMsg (){
        producer.send(new ProducerRecord<>("one-topic", "msgKey", "msgValue"));
        return "success" ;
    }
}

基於上述自定義Bean類型，進行消息發送，關注攔截器中打印日誌信息。

三、Kafka存儲分析

說明：該過程基於上述案例producer.send方法追蹤的源碼執行流程，源碼中的過程相對清楚，涉及的核心流程如下。

1、消息生成過程

Producer發送消息採用的是異步發送的方式,消息發送過程如下：

• Producer發送消息之後，經過攔截器，序列化，事務判斷；
• 流程執行后，消息內容放入容器中；
• 容器在指定時間內如果裝滿(size),會喚醒Sender線程;
• 容器如果在指定時間內沒有裝滿，也會執行一次Sender線程喚醒；
• 喚醒Sender線程之後，把容器數據拉取到topic中；

絮叨一句：讀這些中間件的源碼，不僅能開闊思維，也會讓自己意識到平時寫的代碼可能真的叫搬磚。

2、存儲機制

Kafka中消息是以topic進行標識分類，生產者面向topic生產消息，topic分區(partition)是物理上的存儲，基於消息日誌文件的方式。

• 每個partition對應於一個log文件,發送的消息不斷追加到該log文件末端；
• log文件中存儲的就是producer生產的消息數據，採用分片和索引機制；
• partition分為多個segment。每個segment對應兩個(.index)和(.log)文件；
• index文件類型存儲的索引信息；
• log文件存儲消息的數據；
• 索引文件中的元數據指向對應數據文件中message的物理偏移地址；
• 消費者組中的每個消費者，都會實時記錄消費的消息offset位置；
• 當然消息消費出錯時，恢復是從上次的記錄位置繼續消費；

3、事務控制機制

Kafka支持消息的事務控制

Producer事務

跨分區跨會話的事務原理，引入全局唯一的TransactionID，並將Producer獲得的PID和TransactionID綁定。Producer重啟后可以通過正在進行的TransactionID獲得原來的PID。
Kafka基於TransactionCoordinator組件管理Transaction，Producer通過和TransactionCoordinator交互獲得TransactionID對應的任務狀態。TransactionCoordinator將事務狀態寫入Kafka的內部Topic，即使整個服務重啟，進行中的事務狀態可以得到恢復。

Consumer事務

Consumer消息消費，事務的保證強度很低，無法保證消息被精確消費，因為同一事務的消息可能會出現重啟后已經被刪除的情況。

四、源代碼地址

GitHub·地址
https://github.com/cicadasmile/data-manage-parent
GitEE·地址
https://gitee.com/cicadasmile/data-manage-parent

推薦關聯閱讀：數據源管理系列

序號	標題
01	數據源管理：主從庫動態路由，AOP模式讀寫分離
02	數據源管理：基於JDBC模式，適配和管理動態數據源
03	數據源管理：動態權限校驗，表結構和數據遷移流程
04	數據源管理：關係型分庫分表，列式庫分佈式計算
05	數據源管理：PostGreSQL環境整合，JSON類型應用
06	數據源管理：基於DataX組件，同步數據和源碼分析
07	數據源管理：OLAP查詢引擎，ClickHouse集群化管理

本站聲明:網站內容來源於博客園,如有侵權,請聯繫我們,我們將及時處理

【其他文章推薦】

※網頁設計一頭霧水該從何著手呢? 台北網頁設計公司幫您輕鬆架站!

※網頁設計公司推薦不同的風格，搶佔消費者視覺第一線

※想知道購買電動車哪裡補助最多?台中電動車補助資訊懶人包彙整

※南投搬家公司費用,距離,噸數怎麼算?達人教你簡易估價知識!

※教你寫出一流的銷售文案?

※超省錢租車方案