Dubbo+zookeeper實現分佈式服務框架

【Java中高級課程推薦-所有免費】

http://www.majiaxueyuan.com/

消息中間件，支付寶，Nginx高可用，Redis高可用，SpringBoot，SpringCloud，真實分佈式微服務項目，全套教程看完百分之百大幅度漲薪。

什麼是Dubbo？？

Dubbo也是一套微服務框架，他與SpringCloud的區別就是，他支持多種協議，而SpringCloud只支持Http協議。若是沒有分佈式，那麼他是不存在的。

Dubbo底層架構圖

首先Provider生成服務將服務註冊到zookeeper（具體實現下面有代碼），而後zookeeper接收到事後底層會觸發zookeeper監聽事件（不懂請看前一節），而後告訴Consumer能夠消費了，可是Provider關閉事後zookeeper不會刪除節點，由於是存儲的持久化節點，不是臨時節點。而後會有一個專門的模塊來監聽服務的調用，統計模塊調用次數和反饋信息。

Dubbo有哪些做用： ①：Dubbo有服務治理的能力：透明化的遠程方法調用，就像調用本地方法同樣調用遠程方法，只需簡單 配置，沒有任何API侵入。 ②：集羣容錯：軟負載均衡及容錯機制，可在內網替代F5等硬件負鞭均衡器，下降成本，減小單點。 ③：自動發現：服務自動註冊與發現，再也不須要寫死服務提供方地址，註冊中心基於接口名查詢服務提供者的IP地址，而且可以平滑添加或刪除服務提供者。 另外：Dubbo採用全Spring 配置方式，功明化接入應用，對應用沒有任何API侵只需用Spring加載Dubbo的配置便可，Dubbo基FSpring的Schema擴入，展進行加載。

---

下面實現Dubbo+zookeeper在本地環境中的測試

這裏咱們採用windows上面的zookeeper做爲測試使用，下載地址：http://pan.baidu.com/s/1pLuoSC7

下載後直接到bin目錄，點擊zkServer就能夠啓動zookeeper服務。

首先咱們搭建一個Dubbo服務類（該類主要是寫接口供生產者和消費者引用並繼承。主要緣由是爲了不消費者和生產者都去寫一次相同的接口類）

建立項目名稱：dubbo-common

在per.lx.service包下新建UserService接口

public interface UserService {
	
	String getUser(Integer id);
}

若是須要更多的服務的話，都在dubbo-common包下進行新建，而後在生產者中去實現它的內部方法並註冊到zookeeper

下面建立服務提供者和消費者，都須要引入相同的依賴pom.xml：

<dependencies>
		<dependency>
			<groupId>com.alibaba</groupId>
			<artifactId>dubbo</artifactId>
			<version>2.5.6</version>
		</dependency>
		<!-- 添加zk客戶端依賴 -->
		<dependency>
			<groupId>com.github.sgroschupf</groupId>
			<artifactId>zkclient</artifactId>
			<version>0.1</version>
		</dependency>
                <!-- 添加對dubbo-common的依賴，使用UserService -->
		<dependency>
			<groupId>per.lx</groupId>
			<artifactId>dubbo-common</artifactId>
			<version>0.0.1-SNAPSHOT</version>
		</dependency>
	</dependencies>

建立項目名稱服務提供者：dubbo-producer

新建一個UserServiceImpl去實現dubbo-common中的UserService接口

public class UserServiceImpl implements UserService{

	@Override
	public String getUser(Integer id) {
		System.out.println("進入到getUser服務實現內  id："+id);
		if(id==1){
			return "Hello,LLL丶禾羊,id:"+id;
		}
		if(id==2){
			return "Hello,OSC,id:"+id;
		}
		if(id==3){
			return "Hello,開源中國！,id:"+id;
		}
		return null;
	}
}

而且在resources下面新建配置文件provider.xml

<?xml version="1.0" encoding="utf-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
	xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd           http://code.alibabatech.com/schema/dubbo           http://code.alibabatech.com/schema/dubbo/dubbo.xsd ">

	<!-- 提供方應用信息，用於計算依賴關係 -->
	<dubbo:application name="provider" />
	<!-- 使用zookeeper註冊中心暴露服務地址 -->
	<dubbo:registry address="zookeeper://127.0.0.1:2181" />
	<!-- 用dubbo協議在29014端口暴露服務 -->
	<dubbo:protocol name="dubbo" port="29014" />
	<!-- 聲明須要暴露的服務接口 -->
	<dubbo:service interface="per.lx.service.UserService" ref="userService" />
	<!-- 具體的實現bean -->
	<bean id="userService" class="per.lx.service.impl.UserServiceImpl" />
</beans>

最後新建一個啓動類StartProducer

public class StartProducer {
	public static void main(String[] args) throws IOException {
		ClassPathXmlApplicationContext app = new ClassPathXmlApplicationContext("provider.xml");
		app.start();
		System.out.println("服務發佈成功...");
		System.in.read();//讓程序阻塞。
	}
}

這裏直接啓動主函數，能夠直接在控制檯看到服務發佈成功。以後打開zookeeper查看工具能夠查看到服務信息（以下圖，工具是ZooInspector.jar，開源的，百度可下載）。

---

寫完生產者，消費者更加簡單。

新建消費者項目dubbo-consumer

在resources中新建consumer.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
	xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
	<!-- 消費方應用名，用於計算依賴關係，不是匹配條件，不要與提供方同樣 -->
	<dubbo:application name="consumer" />
	<!-- 使用multicast廣播註冊中心暴露發現服務地址 -->
	<dubbo:registry protocol="zookeeper" address="zookeeper://127.0.0.1:2181" />
	<!-- 生成遠程服務代理，能夠和本地bean同樣使用demoService -->
	<dubbo:reference id="userService" interface="per.lx.service.UserService" />
</beans>

而後直接新建啓動類StartConsumer

public class StartConsumer {

	public static void main(String[] args)  throws IOException{
		ClassPathXmlApplicationContext app = new ClassPathXmlApplicationContext("consumer.xml");
		app.start();
		UserService userService = (UserService) app.getBean("userService");
		String name = userService.getUser(1);
		System.out.println("消費端從生產者獲取到 name:" + name);
                System.in.read();//讓程序阻塞。
	}
}

啓動以後能夠發現從控制檯打印輸出圖中內容，表示發佈成功。