本次和大家分享的是dubbo框架應用的初略配置和zookeeper註冊中心的使用;說到註冊中心現在我使用過的只有兩種:zookeeper和Eureka,zk我結合dubbo來使用,而Eureka結合springcloud使用,因此後面將和大家分享一些關於微服務的一些篇章,希望對你有好的幫助。 安裝註 ...
本次和大家分享的是dubbo框架應用的初略配置和zookeeper註冊中心的使用;說到註冊中心現在我使用過的只有兩種:zookeeper和Eureka,zk我結合dubbo來使用,而Eureka結合springcloud使用,因此後面將和大家分享一些關於微服務的一些篇章,希望對你有好的幫助。
安裝註冊中心zookeeper
dubbo框架之provider和consumer
dubbo-admin部署
安裝註冊中心zookeeper
首先,我們需要在網上搜索下zookeeper下載地址,我這裡是linux系統,所以下載了zookeeper-3.3.6.tar.gz包,通過 tar -zxvf zookeeper-3.3.6.tar.gz 解壓出來,需要註意的是一般的包裡面配置文件都是預設的sample版本,zookeeper預設配置文件名只zoo.cfg,為了不每次指定文件名來運行,因此需要我們自己在conf目錄下創建一個名稱為zoo.cfg的配置文件,文件內容可以從zoo_sample.cfg拷貝或者把這個文件重命名都行,內容如下 vim zoo.cfg :
1 # The number of milliseconds of each tick 2 tickTime=2000 #心跳頻率 3 # The number of ticks that the initial 4 # synchronization phase can take 5 initLimit=10 #限制連接 6 # The number of ticks that can pass between 7 # sending a request and getting an acknowledgement 8 syncLimit=5 9 # the directory where the snapshot is stored. 10 dataDir=/tmp/zookeeper #數據存儲文件夾 11 # the port at which the clients will connect 12 clientPort=2081 #zookeeper對外的埠
這裡就不修改參數信息了,採用預設;簡單介紹下linux下怎麼編輯文件內容的常用的幾個命令:
vim zoo.cfg:查看文件內容
insert:執行插入命令
esc:取消命令,再接著按:q:退出,:wq:保存並退出
當有了zoo.cfg後,我們只需要進入她的bin目錄裡面查找zkServer.sh文件,通過執行: ./zkServer.sh start 命令啟動zookeeper註冊中心,正常啟動提示如:
通常情況是zookeeper作為註冊中心在單獨的一臺伺服器上,而程式(這裡指我本地)需要調用另外註冊中心需要檢查zookeeper開放的埠是否能通,我本地是window10因此可以不需要通過zookeeper客戶端去驗證埠,只需要通過 telnet ip 2081 就能檢測出是否埠開放;
dubbo框架之provider和consumer
首先為了方便,我們需要定義一個統一的介面,該介面就是業務抽出來的公用介面,我們單獨對這種介面包裝成一個module,我這裡是dubbo_api,我們在這個module中定義如下的介面:
1 public interface UserService { 2 3 List<MoUser> getUsers(); 4 }
然後,創建一個provider模塊,這個模塊去依賴dubbo_api模塊,並且實現UserService介面,代碼如:
1 public class UserServiceImpl implements UserService { 2 3 @Value("${server.port}") 4 private int port; 5 6 /** 7 * @return 8 */ 9 @Override 10 public List<MoUser> getUsers() { 11 12 List<MoUser> list = new ArrayList<>(); 13 for (int i = 0; i < 5; i++) { 14 MoUser user = new MoUser(); 15 user.setUserName("shenniu" + i); 16 user.setUserPwd("埠:" + port); 17 list.add(user); 18 } 19 return list; 20 } 21 }
作為服務提供者,要使用dubbo框架就需要先引入dubbo,然後再做一些配置,首先我們需要在dubbo_provider模塊通過maven引入dubbo依賴,註冊中心用的zookeeper所以也需要通過maven引入相應的依賴:
1 <dependency> 2 <groupId>org.apache.zookeeper</groupId> 3 <artifactId>zookeeper</artifactId> 4 <version>3.4.8</version> 5 </dependency> 6 <dependency> 7 <groupId>com.101tec</groupId> 8 <artifactId>zkclient</artifactId> 9 <version>0.3</version> 10 </dependency> 11 <dependency> 12 <groupId>com.alibaba</groupId> 13 <artifactId>dubbo</artifactId> 14 <version>2.5.3</version> 15 <exclusions> 16 <exclusion> 17 <groupId>org.springframework</groupId> 18 <artifactId>spring</artifactId> 19 </exclusion> 20 </exclusions> 21 </dependency> 22 <dependency> 23 <groupId>com.example</groupId> 24 <artifactId>dubbo_api</artifactId> 25 <version>0.0.1-SNAPSHOT</version> 26 </dependency>
完成依賴後,剩下的就是對dubbo的provider的配置了,創建resources/dubbo-conf/server.xml的配置文件,文件內容:
1 <?xml version="1.0" encoding="UTF-8"?> 2 <beans xmlns="http://www.springframework.org/schema/beans" 3 xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo" 4 xsi:schemaLocation="http://www.springframework.org/schema/beans 5 http://www.springframework.org/schema/beans/spring-beans.xsd 6 http://code.alibabatech.com/schema/dubbo 7 http://code.alibabatech.com/schema/dubbo/dubbo.xsd"> 8 9 <!-- 提供者名稱 --> 10 <dubbo:application name="demo-provider" /> 11 12 <!-- zookeeper註冊中心的服務地址 --> 13 <dubbo:registry protocol="zookeeper" address="192.168.168.168:2081" /> 14 15 <!-- 用dubbo協議在20880埠暴露服務,協議通信埠 --> 16 <dubbo:protocol name="dubbo" port="20880" /> 17 18 <!-- 用戶服務介面 --> 19 <dubbo:service interface="service.UserService" ref="userService" /> 20 21 <!-- 用戶服務介面實現 --> 22 <bean id="userService" class="com.example.demo.service.UserServiceImpl"/> 23 </beans>
在DubboProviderApplication入口增加資源導入 @ImportResource("classpath:dubbo-conf/*.xml") ,到這裡我們的服務提供端就完成了,查看下啟動日誌:
服務提供者啟動暫無異常,再來看調用方創建一個dubbo_consumer的moduel,同樣去引入dubbo_api公共介面的模塊依賴,然後創建一個UserController,並暴露一個get的user介面:
1 @RestController 2 public class UserController { 3 @Autowired 4 private UserService userService; 5 6 @GetMapping("/users") 7 public List<MoUser> getUsers(){ 8 9 return userService.getUsers(); 10 } 11 }
這裡的UserService是公共介面的註入;編碼完成後剩下的就是consumer端引入dubbo和zookeeper依賴了:
1 <dependency> 2 <groupId>org.apache.zookeeper</groupId> 3 <artifactId>zookeeper</artifactId> 4 <version>3.4.8</version> 5 </dependency> 6 <dependency> 7 <groupId>com.101tec</groupId> 8 <artifactId>zkclient</artifactId> 9 <version>0.3</version> 10 </dependency> 11 <dependency> 12 <groupId>com.alibaba</groupId> 13 <artifactId>dubbo</artifactId> 14 <version>2.5.3</version> 15 <exclusions> 16 <exclusion> 17 <groupId>org.springframework</groupId> 18 <artifactId>spring</artifactId> 19 </exclusion> 20 </exclusions> 21 </dependency>
我們同樣創建名稱resources/dubbo-conf/client.xml的配置文件,併在application入口引入這個資源:
1 @ImportResource("classpath:dubbo-conf/*.xml") 2 @SpringBootApplication 3 public class DubboConsumerApplication { 4 public static void main(String[] args) { 5 SpringApplication.run(DubboConsumerApplication.class, args); 6 } 7 }
client.xml的配置內容如:
1 <?xml version="1.0" encoding="UTF-8"?> 2 <beans xmlns="http://www.springframework.org/schema/beans" 3 xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo" 4 xsi:schemaLocation="http://www.springframework.org/schema/beans 5 http://www.springframework.org/schema/beans/spring-beans.xsd 6 http://code.alibabatech.com/schema/dubbo 7 http://code.alibabatech.com/schema/dubbo/dubbo.xsd"> 8 9 <!-- 服務名 --> 10 <dubbo:application name="demo-consumer" /> 11 12 <!-- zookeeper註冊中心暴露服務地址 --> 13 <dubbo:registry protocol="zookeeper" address="192.168.168.168:2081" /> 14 15 <!-- 用戶服務介面 --> 16 <dubbo:reference id="userService" interface="service.UserService" /> 17 18 </beans>
這個時候一個簡單的服務提供者,服務調用者配置和編碼都完成了,3個module如下:
然後分別啟動provider,consumer;再通過consumer暴露的controller介面請求介面,我這裡的地址是 http://localhost:8082/users :
效果是Consumer通過註入的UserService介面依賴調用getUsers()拿到了Provider返回的結果,也表示此次dubbo框架的簡單使用算成功了。
dubbo-admin部署
作為一個流行的rpc框架dubbo有這一個開源的監控工具dubbo-admin,不得不說現在網上現成的dubbo-admin.war包要麼現在下來不能用要麼就是下載需要csdn積分,版本多種多樣有點坑啊,果斷去git拉源碼自己打包,git地址: https://github.com/apache/incubator-dubbo-ops ,拉下來後我們只需要關註dubbo-admin工程,其他的暫可忽略;打開項目後,我們需要改的地方只有如下截圖配置(也可以對打包後的配置文件修改):
1 #zookeeper配置地址和埠 2 dubbo.registry.address=zookeeper://127.0.0.1:2081 3 #後臺登錄密碼 4 dubbo.admin.root.password=root 5 dubbo.admin.guest.password=guest
執行打包後,能得到名稱:dubbo-admin-2.0.0.war包,然後放在tomcat中,再通過瀏覽器瀏覽,賬號和密碼:都是root;登錄後能看到我們之前的啟動的provider和consumer在裡面,這就是dubbo-admin監控註冊中心服務的界面,能夠直接對這些服務做點擊操作,其他的不多說自行嘗試吧。