SpringBoot+zk+dubbo架构实践（二）：SpringBoot 集成 zookeeper

你的名字 2022-05-23 08:16 131阅读 0赞

IT实战联盟博客：[http://blog.100boot.cn][http_blog.100boot.cn]

![20180605145107757][]

上一篇：[SpringBoot+zk+dubbo架构实践（一）：本地部署zookeeper][SpringBoot_zk_dubbo_zookeeper]

前言

这是第二篇了，本篇我们完成两件事情。
    1、搭建SpringBoot 框架；
    2、基于spring boot框架访问zookeeper。

搭建SpringBoot框架

其实之前“IT实战联盟”已经出了该系列文章，今天我们简单搭建一下（详细的步骤可以参考[架构实战篇（一）-Spring Boot+MyBatis基础架构搭建][-Spring Boot_MyBatis]）

基于开发工具（IntelliJ IDEA），创建名为zkboot的Maven工程

项目目录

![20180605145205831][]

pom.xml

<?xml version="1.0" encoding="UTF-8"?><project xmlns="http://maven.apache.org/POM/4.0.0"
             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">
        <parent>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <version>1.5.10.RELEASE</version>
        </parent>
        <modelVersion>4.0.0</modelVersion>
    
        <groupId>com.itunion.zkboot</groupId>
        <artifactId>zkboot</artifactId>
        <version>1.0-SNAPSHOT</version>
        <properties>
            <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
            <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
            <java.version>1.8</java.version>
            <maven.test.skip>true</maven.test.skip>
            <aliyun.oss.version>3.1.0</aliyun.oss.version>
        </properties>
    
        <repositories>
            <repository>
                <id>clojars</id>
                <url>http://clojars.org/repo/</url>
            </repository>
        </repositories>
    
        <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-devtools</artifactId>
                <scope>runtime</scope>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
            </dependency>
            <dependency>
                <groupId>org.apache.zookeeper</groupId>
                <artifactId>zookeeper</artifactId>
                <version>3.4.12</version>
            </dependency>
            <dependency>
                <groupId>org.apache.commons</groupId>
                <artifactId>commons-io</artifactId>
                <version>1.3.2</version>
            </dependency>
            <dependency>
                <groupId>org.apache.commons</groupId>
                <artifactId>commons-lang3</artifactId>
                <version>3.4</version>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-thymeleaf</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
        </dependencies>
    
        <build>
            <finalName>zkboot</finalName>
            <plugins>
                <plugin>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-maven-plugin</artifactId>
                </plugin>
                
                <plugin>
                    <groupId>org.apache.maven.plugins</groupId>
                    <artifactId>maven-war-plugin</artifactId>
                    <version>2.1.1</version>
                    <configuration>
                        <failOnMissingWebXml>false</failOnMissingWebXml>
                    </configuration>
                </plugin>
            </plugins>
        </build></project>

备注：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 节点和值，如果没有可以参考上一篇文章！

执行结果

![20180605145220830][]

备注

简单的SpringBoot集成zookeeper已经完成了，如果可以深入了解可以继续自行深入学习。

关注我们

IT实战联盟博客：[http://blog.100boot.cn][http_blog.100boot.cn]

更多精彩内容请关注“IT实战联盟”公\*众\*号，如果需要源码的话可以关注公众号留言（zkboot源码+邮箱），也可以加入交流群和作者互撩哦~~~

[http_blog.100boot.cn]: http://blog.100boot.cn/
[20180605145107757]: /images/20220523/8f503a560c0d42f2adbc522fe523669a.png
[SpringBoot_zk_dubbo_zookeeper]: https://mp.weixin.qq.com/s?__biz=MzU2NDMyNDE0Mg==&mid=2247484537&idx=1&sn=1b8641a3985b8b86afcca6b535051b7f&chksm=fc4df638cb3a7f2ea1fcd0930122a767f3bd43441160ad494dd2ed72962e71839a4be1eab649&mpshare=1&scene=21&srcid=0605GOEH535CMid34dOJpYn4&key=3332a8052bd4f6aff338925284b371fbd6271ff68a635d7cb78c782317adb73481b2be17b62018412de1df52a15093eac1760b5a52c2b7084c34f68e525bccd2496d99991813c5f51910e8ac1c3c5e0f&ascene=0&uin=Mjg2MDM5ODQwMg==&devicetype=iMac%20MacBookPro12,1%20OSX%20OSX%2010.11.3%20build%2815D21%29&version=11020201&lang=zh_CN&pass_ticket=BAL3RWPvIa2vcjQJ6D0/x6pmjSDg/pWZ0erMycJ46GDCUqF8fXDrTR490zFw5qHc#wechat_redirect
[-Spring Boot_MyBatis]: https://mp.weixin.qq.com/s?__biz=MzU2NDMyNDE0Mg==&mid=2247484023&idx=1&sn=80fcff20366617411aeb5df72e782475&chksm=fc4df036cb3a792041413ee6f97b097f00dc877ae7fd2d9cca1db0de222ca19ecb3c9f70ecf4&mpshare=1&scene=21&srcid=0605BvTYdyCLWRFBzeqR0onH&key=793a120e65a6f28385ecc6d025953e293318acd60a36d3285c50fea142ae242ca1104ee20ab3b7f26c88ce1ff15570274bf1530d325aac1801e1b814b26dff97e64159e070fe427da3df5bd76cea4741&ascene=0&uin=Mjg2MDM5ODQwMg==&devicetype=iMac%20MacBookPro12,1%20OSX%20OSX%2010.11.3%20build%2815D21%29&version=11020201&lang=zh_CN&pass_ticket=BAL3RWPvIa2vcjQJ6D0/x6pmjSDg/pWZ0erMycJ46GDCUqF8fXDrTR490zFw5qHc#wechat_redirect
[20180605145205831]: /images/20220523/a1e9673494aa4556a1b7f7c4ccac2b31.png
[20180605145220830]: /images/20220523/ddec93e0aa5b4f8d81e0c92afffc5c13.png