dubbo+zookeeper+springboot構建服務

  本次和你們分享的是dubbo框架應用的初略配置和zookeeper註冊中心的使用;說到註冊中心如今我使用過的只有兩種:zookeeper和Eureka,zk我結合dubbo來使用,而Eureka結合springcloud使用,所以後面將和你們分享一些關於微服務的一些篇章,但願對你有好的幫助。linux

  安裝註冊中心zookeepergit

  dubbo框架之provider和consumergithub

  dubbo-admin部署spring

安裝註冊中心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 :apache

 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

  vim zoo.cfg:查看文件內容api

  insert:執行插入命令瀏覽器

  esc:取消命令,再接着按:q:退出,:wq:保存並退出tomcat

  當有了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監控註冊中心服務的界面,可以直接對這些服務作點擊操做,其餘的很少說自行嘗試吧。

  

相關文章
相關標籤/搜索