SpringBoot+zk+dubbo架構實踐（二）：SpringBoot 集成 zookeeper

上一篇：

前言

這是第二篇了，本篇我們完成兩件事情。
1、搭建SpringBoot 框架；
2、基於spring boot框架訪問zookeeper。

搭建SpringBoot框架

其實之前“IT實戰聯盟”已經出了該系列文章，今天我們簡單搭建一下（詳細的步驟可以參考 ）

基於開發工具（IntelliJ IDEA），創建名為zkboot的Maven工程

項目目錄

pom.xml

 xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
 
 org.springframework.boot
 spring-boot-starter-parent
 1.5.10.RELEASE
 
 4.0.0
 com.itunion.zkboot
 zkboot
 1.0-SNAPSHOT
 
 UTF-8
 UTF-8
 1.8
 true
  
3.1.0
 
 
 
 clojars
 http://clojars.org/repo/
 
 
 
 
 org.springframework.boot
 spring-boot-devtools
 runtime
 
 
 org.springframework.boot
 spring-boot-starter-web
 
 
 org.springframework.boot
 spring-boot-starter-test 

 test
 
 
 org.apache.zookeeper
 zookeeper
 3.4.12
 
 
 org.apache.commons
 commons-io
 1.3.2
 
 
 org.apache.commons
 commons-lang3
 3.4
 
 
 org.springframework.boot 

 spring-boot-starter-thymeleaf
 
 
 org.springframework.boot
 spring-boot-starter-web
 
 
 
 zkboot
 
 
 org.springframework.boot
 spring-boot-maven-plugin
 
 
 
 org.apache.maven.plugins
 maven-war-plugin
 2.1.1
  

 false
 
 
 
 

備註：groupId、artifactId 根據自己需要修改

application.properties

#設置服務端口
server.port=8089
server.context-path=/zkboot

Application 啟動入口

package com.itunion.zkboot;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.web.support.SpringBootServletInitializer;
/**
 * 啟動入口
 * @author lin
 * @date 2018年06月05日14:21:49
 */@SpringBootApplicationpublic class Application extends SpringBootServletInitializer { 
public static void main(String[] args) throws Exception {
 SpringApplication.run(Application.class, args);
 }
}

RestZkController 獲取設置的zookeeper node節點信息方法

package com.itunion.zkboot.web.controller;
import org.apache.zookeeper.WatchedEvent;
import org.apache.zookeeper.Watcher;
import org.apache.zookeeper.ZooKeeper;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;/**
 * Created by lin on 2018年06月05日14:23:36
 */
@RestControllerpublic class RestZkController { 
@RequestMapping(value = "/zkGet",method = RequestMethod.GET) 
public String zkGet(){
 Watcher watcher= new Watcher(){ 
 public void process(WatchedEvent event) {
 System.out.println("receive event："+event);
 }
 };
 String value = null; 
 try { 
 final ZooKeeper zookeeper = new ZooKeeper("127.0.0.1:2181", 999999, watcher); 
 final byte[] data = zookeeper.getData("/node_1", watcher, null);
 value = new String(data);
 zookeeper.close();
 }catch(Exception e){
 e.printStackTrace();
 } 
 return "獲取 node_1 節點值為 [" + value + "]";
 }
}

啟動項目並測試

訪問地址：http://127.0.0.1:8089/zkboot/zkGet
備註：大家要保證 zookeeper 服務正常啟動，並且創建了node_1 節點和值，如果沒有可以參考上一篇文章！

執行結果

備註

簡單的SpringBoot集成zookeeper已經完成了，如果可以深入瞭解可以繼續自行深入學習。

關注我們

更多精彩內容請關注“IT實戰聯盟”，如果需要源碼的話可以留言（zkboot源碼+郵箱），也可以加入交流群和作者互撩哦~~~

閱讀更多 IT實戰聯盟 的文章

關鍵字: IntelliJ IDEA 技術