下文給大家?guī)鞤ubbo背景介紹及Zookeeper、SpringMVC的整合和使用,希望能夠給大家在實際運(yùn)用中帶來一定的幫助,負(fù)載均衡涉及的東西比較多,理論也不多,網(wǎng)上有很多書籍,今天我們就用創(chuàng)新互聯(lián)在行業(yè)內(nèi)累計的經(jīng)驗來做一個解答。
創(chuàng)新互聯(lián)服務(wù)項目包括彭州網(wǎng)站建設(shè)、彭州網(wǎng)站制作、彭州網(wǎng)頁制作以及彭州網(wǎng)絡(luò)營銷策劃等。多年來,我們專注于互聯(lián)網(wǎng)行業(yè),利用自身積累的技術(shù)優(yōu)勢、行業(yè)經(jīng)驗、深度合作伙伴關(guān)系等,向廣大中小型企業(yè)、政府機(jī)構(gòu)等提供互聯(lián)網(wǎng)行業(yè)的解決方案,彭州網(wǎng)站推廣取得了明顯的社會效益與經(jīng)濟(jì)效益。目前,我們服務(wù)的客戶以成都為中心已經(jīng)輻射到彭州省份的部分城市,未來相信會繼續(xù)擴(kuò)大服務(wù)區(qū)域并繼續(xù)獲得客戶的支持與信任!
互聯(lián)網(wǎng)的發(fā)展,網(wǎng)站應(yīng)用的規(guī)模不斷擴(kuò)大,常規(guī)的垂直應(yīng)用架構(gòu)已無法應(yīng)對,分布式服務(wù)架構(gòu)以及流動計算架構(gòu)勢在必行,Dubbo是一個分布式服務(wù)框架,在這種情況下誕生的?,F(xiàn)在核心業(yè)務(wù)抽取出來,作為獨(dú)立的服務(wù),使前端應(yīng)用能更快速和穩(wěn)定的響應(yīng)。
第一:介紹Dubbo背景
大規(guī)模服務(wù)化之前,應(yīng)用可能只是通過RMI或Hessian等工具,簡單的暴露和引用遠(yuǎn)程服務(wù),通過配置服務(wù)的URL地址進(jìn)行調(diào)用,通過F5等硬件進(jìn)行負(fù)載均衡。
(1) 當(dāng)服務(wù)越來越多時,服務(wù)URL配置管理變得非常困難,F(xiàn)5硬件負(fù)載均衡器的單點(diǎn)壓力也越來越大。
此時需要一個服務(wù)注冊中心,動態(tài)的注冊和發(fā)現(xiàn)服務(wù),使服務(wù)的位置透明。
并通過在消費(fèi)方獲取服務(wù)提供方地址列表,實現(xiàn)軟負(fù)載均衡和Failover,降低對F5硬件負(fù)載均衡器的依賴,也能減少部分成本。
(2) 當(dāng)進(jìn)一步發(fā)展,服務(wù)間依賴關(guān)系變得錯蹤復(fù)雜,甚至分不清哪個應(yīng)用要在哪個應(yīng)用之前啟動,架構(gòu)師都不能完整的描述應(yīng)用的架構(gòu)關(guān)系。
這時,需要自動畫出應(yīng)用間的依賴關(guān)系圖,以幫助架構(gòu)師理清理關(guān)系。
(3) 接著,服務(wù)的調(diào)用量越來越大,服務(wù)的容量問題就暴露出來,這個服務(wù)需要多少機(jī)器支撐?什么時候該加機(jī)器?
為了解決這些問題,第一步,要將服務(wù)現(xiàn)在每天的調(diào)用量,響應(yīng)時間,都統(tǒng)計出來,作為容量規(guī)劃的參考指標(biāo)。
其次,要可以動態(tài)調(diào)整權(quán)重,在線上,將某臺機(jī)器的權(quán)重一直加大,并在加大的過程中記錄響應(yīng)時間的變化,直到響應(yīng)時間到達(dá)閥值,記錄此時的訪問量,再以此訪問量乘以機(jī)器數(shù)反推總?cè)萘俊?/p>
第二:Dubbo的簡介
節(jié)點(diǎn)角色說明:
Provider: 暴露服務(wù)的服務(wù)提供方。
Consumer: 調(diào)用遠(yuǎn)程服務(wù)的服務(wù)消費(fèi)方。
Registry: 服務(wù)注冊與發(fā)現(xiàn)的注冊中心。
Monitor: 統(tǒng)計服務(wù)的調(diào)用次調(diào)和調(diào)用時間的監(jiān)控中心。
Container: 服務(wù)運(yùn)行容器。
調(diào)用關(guān)系說明:
0. 服務(wù)容器負(fù)責(zé)啟動,加載,運(yùn)行服務(wù)提供者。
1. 服務(wù)提供者在啟動時,向注冊中心注冊自己提供的服務(wù)。
2. 服務(wù)消費(fèi)者在啟動時,向注冊中心訂閱自己所需的服務(wù)。
3. 注冊中心返回服務(wù)提供者地址列表給消費(fèi)者,如果有變更,注冊中心將基于長連接推送變更數(shù)據(jù)給消費(fèi)者。
4. 服務(wù)消費(fèi)者,從提供者地址列表中,基于軟負(fù)載均衡算法,選一臺提供者進(jìn)行調(diào)用,如果調(diào)用失敗,再選另一臺調(diào)用。
5. 服務(wù)消費(fèi)者和提供者,在內(nèi)存中累計調(diào)用次數(shù)和調(diào)用時間,定時每分鐘發(fā)送一次統(tǒng)計數(shù)據(jù)到監(jiān)控中心。
Dubbo提供了很多協(xié)議,Dubbo協(xié)議、RMI協(xié)議、Hessian協(xié)議,我們查看Dubbo源代碼,有各種協(xié)議的實現(xiàn),如圖所示:
我們之前沒用Dubbo之前時,大部分都使用Hessian來使用我們服務(wù)的暴露和調(diào)用,利用HessianProxyFactory調(diào)用遠(yuǎn)程接口。
上面是參考了Dubbo官方網(wǎng)介紹,接下來我們來介紹SpringMVC、Dubbo、Zookeeper整合使用。
第三:Dubbo與Zookeeper、SpringMVC整合使用
第一步:在Linux上安裝Zookeeper
Zookeeper作為Dubbo服務(wù)的注冊中心,Dubbo原先基于數(shù)據(jù)庫的注冊中心,沒采用Zookeeper,Zookeeper一個分布式的服務(wù)框架,是樹型的目錄服務(wù)的數(shù)據(jù)存儲,能做到集群管理數(shù)據(jù) ,這里能很好的作為Dubbo服務(wù)的注冊中心,Dubbo能與Zookeeper做到集群部署,當(dāng)提供者出現(xiàn)斷電等異常停機(jī)時,Zookeeper注冊中心能自動刪除提供者信息,當(dāng)提供者重啟時,能自動恢復(fù)注冊數(shù)據(jù),以及訂閱請求。我們先在linux上安裝Zookeeper,我們安裝最簡單的單點(diǎn),集群比較麻煩。
(2) 我們放到Linux下的一個文件夾,然后解壓:
#tar zxvf zookeeper-3.4.6.tar.gz
(3)然后在對應(yīng)的zookeeper-3.4.6/conf 下有一個文件zoo_sample.cfg的這個文件里面配置了監(jiān)聽客戶端連接的端口等一些信息,Zookeeper 在啟動時會找zoo.cfg這個文件作為默認(rèn)配置文件,所以我們復(fù)制一個名稱為zoo.cfg的文件,如圖所示:
我們查看一下這個文件的里面的一些配置信息,如圖所示:
說明:
clientPort:監(jiān)聽客戶端連接的端口。
tickTime:基本事件單元,以毫秒為單位。它用來控制心跳和超時,默認(rèn)情況下最小的會話超時時間為兩倍的 tickTime。
我們可以對配置文件的端口等或者進(jìn)行高級配置和集群配置例如:maxClientCnxns:限制連接到 ZooKeeper 的客戶端的數(shù)量等
(4)啟動Zookeeper 的服務(wù),如圖所示:
到這邊Zookeeper的安裝和配置完成
第二步:配置dubbo-admin的管理頁面,方便我們管理頁面
(1)下載dubbo-admin-2.4.1.war包,在Linux的tomcat部署,先把dubbo-admin-2.4.1放在tomcat的webapps/ROOT下,然后進(jìn)行解壓:
#jar -xvf dubbo-admin-2.4.1.war
(2)然后到webapps/ROOT/WEB-INF下,有一個dubbo.properties文件,里面指向Zookeeper ,使用的是Zookeeper 的注冊中心,如圖所示:
(3)然后啟動tomcat服務(wù),用戶名和密碼:root,并訪問服務(wù),顯示登陸頁面,說明dubbo-admin部署成功,如圖所示:
第三步:SpringMVC與Dubbo的整合,這邊使用的Maven的管理項目
第一:我們先開發(fā)服務(wù)注冊的,就是提供服務(wù),項目結(jié)構(gòu)如圖所示:
(1)test-maven-api項目加入了一個服務(wù)接口,代碼如下:
Java代碼
public interface TestRegistryService {
public String hello(String name);
}
(2)test-maven-console在pom.xml加入Dubbo和Zookeeper的jar包、引用test-maven-api的jar包,代碼如下:
Java代碼
(3)test-maven-console實現(xiàn)具體的服務(wù),代碼如下:
Java代碼
@Service("testRegistryService")
ublic class TestRegistryServiceImpl implements TestRegistryService {
public String hello(String name) {
return "hello"+name;
}
(4)我們服務(wù)以及實現(xiàn)好了,這時要暴露服務(wù),代碼如下:
Java代碼
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:jee="http://www.springframework.org/schema/jee"
xmlns:tx="http://www.springframework.org/schema/tx"
xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
xmlns:context="http://www.springframework.org/schema/context"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.1.xsd
http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.1.xsd
http://www.springframework.org/schema/jee http://www.springframework.org/schema/jee/spring-jee-3.1.xsd
http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd
http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.1.xsd"
default-lazy-init="false" >
說明:
dubbo:registry 標(biāo)簽一些屬性的說明:
1)register是否向此注冊中心注冊服務(wù),如果設(shè)為false,將只訂閱,不注冊。
2)check注冊中心不存在時,是否報錯。
3)subscribe是否向此注冊中心訂閱服務(wù),如果設(shè)為false,將只注冊,不訂閱。
4)timeout注冊中心請求超時時間(毫秒)。
5)address可以Zookeeper集群配置,地址可以多個以逗號隔開等。
dubbo:service標(biāo)簽的一些屬性說明:
1)interface服務(wù)接口的路徑
2)ref引用對應(yīng)的實現(xiàn)類的Bean的ID
3)registry向指定注冊中心注冊,在多個注冊中心時使用,值為
4)register 默認(rèn)true ,該協(xié)議的服務(wù)是否注冊到注冊中心。
(5)啟動項目,然后我們在Dubbo管理頁面上顯示,已經(jīng)暴露的服務(wù),但顯示還沒有消費(fèi)者,因為我們還沒實現(xiàn)消費(fèi)者服務(wù),如圖所示:
第二:我們在開發(fā)服務(wù)消費(fèi)者,就是調(diào)用服務(wù),我們在新建一個新的消費(fèi)者項目結(jié)構(gòu)如圖所示:
(1)test-maven-server-console的pom.xml引入Dubbo和Zookeeper的jar包、test-maven-api的jar包,因為引入test-maven-api的jar包,我們在項目中調(diào)用像在本地調(diào)用一樣。代碼如下:
Java代碼
(2)test-maven-server-console項目的具體實現(xiàn),代碼如下:
Java代碼
@Controller
public class IndexController {
@Autowired
private TestRegistryService testRegistryService;
@RequestMapping("/hello")
public String index(Model model){
String name=testRegistryService.hello("zz");
System.out.println("xx=="+name);
return "";
}
}
(3)我們要引用的地址,代碼如下:
Java代碼
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:jee="http://www.springframework.org/schema/jee"
xmlns:tx="http://www.springframework.org/schema/tx"
xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
xmlns:context="http://www.springframework.org/schema/context"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.1.xsd
http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.1.xsd
http://www.springframework.org/schema/jee http://www.springframework.org/schema/jee/spring-jee-3.1.xsd
http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd
http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.1.xsd"
default-lazy-init="false" >
說明:
dubbo:reference 的一些屬性的說明:
1)interface調(diào)用的服務(wù)接口
2)check 啟動時檢查提供者是否存在,true報錯,false忽略
3)registry 從指定注冊中心注冊獲取服務(wù)列表,在多個注冊中心時使用,值為
4)loadbalance 負(fù)載均衡策略,可選值:random,roundrobin,leastactive,分別表示:隨機(jī),輪循,最少活躍調(diào)用
(4)項目啟動,Dubbo管理頁面,能看到消費(fèi)者,如圖所示:
(5)然后訪問消費(fèi)者項目,Controller層能像調(diào)用本地一樣調(diào)用服務(wù)的具體實現(xiàn),如圖所示:
Dubbo提供了多種容錯方案,包括負(fù)載均衡這些,如圖所示:
1. 使用阿里巴巴Druid連接池(高效、功能強(qiáng)大、可擴(kuò)展性好的數(shù)據(jù)庫連接池、監(jiān)控數(shù)據(jù)庫訪問性能、支持Common-Logging、Log4j和JdkLog,監(jiān)控數(shù)據(jù)庫訪問)
2. 提供高并發(fā)JMS消息處理機(jī)制
3. 所有功能模塊化、所有模塊服務(wù)化、所有服務(wù)原子化的方式,提供可拓展的服務(wù)模型,使程序穩(wěn)定運(yùn)行,永不宕機(jī)
4. 提供Wink Rest、Webservice服務(wù),故可作為獨(dú)立服務(wù)平臺部署
框架整合:
Springmvc + Mybatis + Shiro(權(quán)限) + REST(服務(wù)) + WebService(服務(wù)) + JMS(消息) + Lucene(搜搜引擎) + Quartz(定時調(diào)度) + Bootstrap Html5(支持PC、IOS、Android)
框架簡介:
項目Maven構(gòu)建,真實大型互聯(lián)網(wǎng)架構(gòu),做到高并發(fā),大數(shù)據(jù)處理,整個項目使用定制化服務(wù)思想,提供模塊化、服務(wù)化、原子化的方案,將功能模塊進(jìn)行拆分,可以公用到所有的項目中。架構(gòu)采用分布式部署架構(gòu),所有模塊進(jìn)行拆分,使項目做到絕對解耦,穩(wěn)定壓倒一切~~
持續(xù)集成:
1. 我的待辦工作流服務(wù)(提供Webservice服務(wù))
2. 我的待辦工作流集成JMS消息服務(wù)(支持高并發(fā),可支持成千上萬系統(tǒng)集成)
3. 我的任務(wù)提供Rest服務(wù),完成日常的工作管理,通過定時調(diào)度平臺,動態(tài)生成我的任務(wù)、循環(huán)周期任務(wù)、定時郵催提醒完成任務(wù)等
4. 文件上傳、多線程下載服務(wù)化、發(fā)送郵件、短信服務(wù)化、部門信息服務(wù)化、產(chǎn)品信息服務(wù)化、信息發(fā)布服務(wù)化、我的訂閱服務(wù)化、我的任務(wù)服務(wù)化、公共鏈接、我的收藏服務(wù)化等
系統(tǒng)模塊:
1. 用戶管理:
用戶信息管理(添加、刪除、修改、用戶授權(quán)、用戶欄目管理、查詢等)
用戶組管理(添加、刪除、修改、用戶組欄目授權(quán),欄目授權(quán)、查詢、用戶組人員添加查詢等)
用戶角色管理(添加、刪除、修改、用戶角色授權(quán)、用戶角色欄目信息查詢設(shè)置等)
2. 文章管理:
欄目管理:查詢無限極欄目樹、創(chuàng)建無限極欄目樹分類(導(dǎo)航欄目、圖片列表欄目、文章列表欄目、文章內(nèi)容欄目等)、刪除、修改欄目信息。
文章管理:創(chuàng)建、刪除、修改文章,多維度文章查詢,包括已發(fā)布、未發(fā)布、所有文章等。文章富文本編輯器、文章多文件上傳、文章狀態(tài)控制等。
3. 系統(tǒng)設(shè)置:
數(shù)據(jù)字典管理:支持中、英文信息,支持無限級別分類配置,動態(tài)控制是否可用等。
部門信息管理:支持中、英文無限級別部門信息增加,刪除,修改操作,部門列表、樹心查詢等。
日志管理:系統(tǒng)日志列表查詢、在線查看、在線下載等
路線管理:集成百度地圖API,提供線路查詢管理功能
Druid Monitor(監(jiān)控):集成阿里巴巴連接池,提供在線連接池監(jiān)控程序,包括:數(shù)據(jù)源、SQL監(jiān)控、URL監(jiān)控、Session監(jiān)控、Spring監(jiān)控等
網(wǎng)站信息管理:通過系統(tǒng)配置文件進(jìn)行網(wǎng)站內(nèi)容操作,包括郵件云服務(wù)器配置、公司基本信息配置等。
4. 集成REST服務(wù),可以用作獨(dú)立服務(wù)平臺(提供大量實例及測試平臺,包括:文件上傳下載、郵件短信發(fā)送、部門、產(chǎn)品、公共連接、我的收藏、我的任務(wù)、信息發(fā)布等)
5. 集成Quartz調(diào)度,可以用作定時調(diào)度平臺(動態(tài)配置調(diào)度類、調(diào)度時間,使程序自動執(zhí)行某些業(yè)務(wù))
6. Lucene搜索引擎,可以將文件資料索引化,支持文件內(nèi)容搜索、關(guān)鍵字搜索、高亮關(guān)鍵字等,使信息在毫秒內(nèi)提取查詢出來
7. 用戶設(shè)置功能:包括修改用戶信息,修改密碼、發(fā)送消息,修改個人圖片,查看角色、查看用戶組,管理員修改角色、用戶、用戶組等。
8. 集成Webservice平臺,包括jaxws服務(wù)、CXF框架,配置雙加密的權(quán)限認(rèn)證。使服務(wù)集成更加安全。
9. Bootstrap html5提供了兩套前臺開環(huán)境,包括CMS和電子商務(wù)網(wǎng)站,使您的開發(fā)更加的簡潔。
技術(shù)點(diǎn):
1. Springmvc + Mybatis集成、SpringSecurity權(quán)限控制、Spring AOP事務(wù)處理。
2. Wink Rest服務(wù)、Webservice服務(wù):jaxws、CXF等
3. IO 流上傳下載文件,多線程操作
4. 發(fā)送郵件,配置郵件服務(wù)器,發(fā)基于html、純文本格式的郵件
5. MD5加密 (登陸密碼校驗加密等),用戶統(tǒng)一Session、Cookie管理,統(tǒng)一驗證碼校驗等。
6. 數(shù)據(jù)庫連接池統(tǒng)一配置
7. Quartz定時調(diào)度任務(wù)集成(直接通過配置即可)
8. Httpclient破解驗證碼,登陸聯(lián)通充值平臺
9. 漢字、英文拆分、可以用作文檔關(guān)鍵字搜索等。
10. Base64圖片處理,支持PC,Android,IOS
11. Service Socket 、Client Socket 通信技術(shù)(已經(jīng)做過GPRS數(shù)據(jù)獲取,并用到了項目中)
12. 提供大量工具類,可以直接使用
13. Maven項目構(gòu)建,您可以直接做架構(gòu),可以提升自己的學(xué)習(xí)能力,使您成為真正的架構(gòu)師。
看了以上關(guān)于Dubbo背景介紹及Zookeeper、SpringMVC的整合和使用,如果大家還有什么地方需要了解的可以在創(chuàng)新互聯(lián)行業(yè)資訊里查找自己感興趣的或者找我們的專業(yè)技術(shù)工程師解答的,創(chuàng)新互聯(lián)技術(shù)工程師在行業(yè)內(nèi)擁有十幾年的經(jīng)驗了。