SpringBoot+zk+dubbo架构实践（四）：sb+zk+dubbo框架搭建（内附源码GitHub地址）

野性酷女 2022-05-23 10:53 142阅读 0赞

往期回顾

[SpringBoot+zk+dubbo架构实践（一）：本地部署zookeeper][SpringBoot_zk_dubbo_zookeeper]  
[SpringBoot+zk+dubbo架构实践（二）：SpringBoot 集成 zookeeper][SpringBoot_zk_dubbo_SpringBoot _ zookeeper]  
[SpringBoot+zk+dubbo架构实践（三）：部署Dubbo-admin管理平台][SpringBoot_zk_dubbo_Dubbo-admin]

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

**sb+zk+dubbo实现效果**

![e037811e2919fb8f620b57dfdfd1b7e8.gif][]

模拟了一个provider服务提供方和PC、Web两个服务消费方.gif

前言

先看一下上面的图有个简单的概念，然后开始编码。只需完成2件事情。
    1、Spring boot + zk + dubbo 框架搭建（1个主项目4个子模块）
    2、编写测试类，实现暴露服务的服务提供方、调用远程服务的服务消费方和服务注册与发现的注册中心 功能。

![1ab0f89d8e9ad8fb762ad0441c64f194.png][]

dubbo.jpeg

项目目录和结构图

![7793441f209a3af7c742d52edce5e6b3.png][]

项目目录.png

项目说明

weixin-shop 主项目
    shop-api 公共接口
    shop-ds 服务提供方（provider)
    shop-pc 服务消费方1（consumer)-模拟PC端请求入口
    shop-web 服务消费方2（consumer)-模拟移动端请求入口

项目结构

![cbae1828cdd3febe031d54456f2cb9f9.png][]

项目结构.png

备注：目录结构仅供参考，但是配置文件是必不可少的。

weixin-shop 主项目

pom.xml

shop-api 公共接口-子项目

pom.xml

DemoService 接口

package com.itunion.shop.service; /** * 测试demo * Created by lin on 2018年04月16日21:38:07 */ public interface DemoService { String sayHello(String name); }

shop-ds 服务提供方-子项目

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>
            <artifactId>weixin-shop</artifactId>
            <groupId>com.itunion</groupId>
            <version>1.0-SNAPSHOT</version>
        </parent>
        <modelVersion>4.0.0</modelVersion>
    
        <artifactId>shop-ds</artifactId>
        <packaging>jar</packaging>
        <name>${project.artifactId}</name>
        <properties>
            <skip_maven_deploy>false</skip_maven_deploy>
        </properties>
        <dependencies>
            <dependency>
                <groupId>com.itunion</groupId>
                <artifactId>shop-api</artifactId>
                <version>${project.parent.version}</version>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
                    
            <dependency>
                <groupId>com.alibaba</groupId>
                <artifactId>dubbo</artifactId>
                <version>2.6.0</version>
            </dependency>
    
            <dependency>
                <groupId>com.101tec</groupId>
                <artifactId>zkclient</artifactId>
                <version>0.10</version>
            </dependency>
    
            <dependency>
                <groupId>org.apache.curator</groupId>
                <artifactId>curator-framework</artifactId>
                <version>4.0.0</version>
            </dependency>
        </dependencies>
    </project>

DemoServiceImpl 测试接口实现

package com.itunion.shop.service.impl; import com.alibaba.dubbo.common.logger.Logger; import com.alibaba.dubbo.common.logger.LoggerFactory; import com.alibaba.dubbo.rpc.RpcContext; import com.itunion.shop.service.DemoService; import java.text.SimpleDateFormat; import java.util.Date; /** * 测试demo-服务提供方 * Created by lin on 2018年04月16日21:38:07 */ public class DemoServiceImpl implements DemoService { private final static Logger LOGGER = LoggerFactory.getLogger(DemoServiceImpl.class); @Override public String sayHello(String name) { System.out.println("[" + new SimpleDateFormat("HH:mm:ss").format(new Date()) + "] Hello " + name + ", request from consumer: " + RpcContext.getContext().getRemoteAddress()); return "Hello " + name + ", response form provider: " + RpcContext.getContext().getLocalAddress(); } }

Provider 测试执行main

package com.itunion.shop.service.impl; import org.springframework.context.support.ClassPathXmlApplicationContext; public class Provider { public static void main(String[] args) throws Exception { System.setProperty("java.net.preferIPv4Stack", "true"); ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(new String[]{ "shop-ds-rovider.xml"}); context.start(); System.out.println("服务提供方已经启动..."); System.in.read(); // press any key to exit } }

dubbo.properties

dubbo.qos.port=33333

log4j.properties（后面子项目一样用这个）

###set log levels### log4j.rootLogger=info, stdout ###output to the console### log4j.appender.stdout=org.apache.log4j.ConsoleAppender log4j.appender.stdout.Target=System.out log4j.appender.stdout.layout=org.apache.log4j.PatternLayout log4j.appender.stdout.layout.ConversionPattern=[%d{dd/MM/yy hh:mm:ss:sss z}] %t %5p %c{ 2}: %m%n

shop-ds-rovider.xml

<?xml version="1.0" encoding="UTF-8"?>
    <beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
           xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
           xmlns="http://www.springframework.org/schema/beans"
           xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
    
        
        
        <dubbo:application name="dubbo-provider" owner="dubbo-provider" />
        
        
        <dubbo:registry address="zookeeper://localhost:2181"/>
    
        
        <dubbo:protocol name="dubbo" port="20880"/>
    
        
        <bean id="demoService" class="com.itunion.shop.service.impl.DemoServiceImpl"/>
    
        
        <dubbo:service interface="com.itunion.shop.service.DemoService" ref="demoService"/>
    
    </beans>

shop-web 服务消费方-子项目

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>
            <artifactId>weixin-shop</artifactId>
            <groupId>com.itunion</groupId>
            <version>1.0-SNAPSHOT</version>
        </parent>
        <modelVersion>4.0.0</modelVersion>
        <artifactId>shop-web</artifactId>
        <packaging>jar</packaging>
        <name>${project.artifactId}</name>
        <properties>
            <skip_maven_deploy>false</skip_maven_deploy>
        </properties>
        <dependencies>
            <dependency>
                <groupId>com.itunion</groupId>
                <artifactId>shop-api</artifactId>
                <version>${project.parent.version}</version>
            </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>com.alibaba</groupId>
                <artifactId>dubbo</artifactId>
                <version>2.6.0</version>
            </dependency>
    
            <dependency>
                <groupId>com.101tec</groupId>
                <artifactId>zkclient</artifactId>
                <version>0.10</version>
            </dependency>
    
            <dependency>
                <groupId>org.apache.curator</groupId>
                <artifactId>curator-framework</artifactId>
                <version>4.0.0</version>
            </dependency>
        </dependencies>
    </project>

ConsumerWeb 移动消费者入口 测试执行main

package com.itunion.shop.web.controller; import com.itunion.shop.service.DemoService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.context.support.ClassPathXmlApplicationContext; public class ConsumerWeb { @Autowired DemoService demoService; public static void main(String[] args) { System.setProperty("java.net.preferIPv4Stack", "true"); ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(new String[]{ "shop-web-consumer.xml"}); context.start(); System.out.println("微商城移动端 消费方（Consumer）启动......"); DemoService demoService = (DemoService) context.getBean("demoService"); // get remote service proxy System.out.println("消费方（Consumer）"); while (true) { try { Thread.sleep(1000); String hello = demoService.sayHello("第2个：我是移动端"); // call remote method System.out.println(hello); // get result } catch (Throwable throwable) { throwable.printStackTrace(); } } } }

dubbo.properties

dubbo.qos.port=11111

log4j.properties（用上面shop-ds那个）

省略....

shop-web-consumer.xml

<?xml version="1.0" encoding="UTF-8"?>
    <beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
           xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
           xmlns="http://www.springframework.org/schema/beans"
           xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
    
        
        <dubbo:application name="shop-web-consumer" owner="programmer" organization="dubbed"/>
    
        
        
        <dubbo:registry address="zookeeper://localhost:2181"/>
    
        
        <dubbo:reference id="demoService" check="false" interface="com.itunion.shop.service.DemoService"/>
    </beans>

shop-pc 服务消费方-子项目

pom.xml（可以复制shop-web pom文件修改artifactId 即可）

<artifactId>shop-pc</artifactId>
        省略......

ConsumerPC PC消费之业务入口 测试执行main

package com.itunion.shop.web.controller; import com.itunion.shop.service.DemoService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.context.support.ClassPathXmlApplicationContext; public class ConsumerPC { @Autowired DemoService demoService; public static void main(String[] args) { System.setProperty("java.net.preferIPv4Stack", "true"); ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(new String[]{ "shop-pc-consumer.xml"}); context.start(); System.out.println("微商城PC端-消费方（Consumer）启动......"); DemoService demoService = (DemoService) context.getBean("demoService"); // get remote service proxy System.out.println("消费方（Consumer）"); while (true) { try { Thread.sleep(1000); String hello = demoService.sayHello("第1个：我是PC端消费方"); // call remote method System.out.println(hello); // get result } catch (Throwable throwable) { throwable.printStackTrace(); } } } }

dubbo.properties

dubbo.qos.port=22222

log4j.properties（用上面那个）

省略....

shop-pc-consumer.xml

好了我们的sb+zk+dubbo 框架已经搭建好了，接下来我们执行一下看看结果！（zookeeper 服务记得启动哈）

启动shop-ds 暴露服务的服务提供方

![76b7785b970df30563e5dfae4903b853.png][]

服务提供方启动.jpg

启动shop-pc 服务消费方 -PC端启动

![da4febfac1d7933edb29f6ad48b8dcfd.png][]

shop-pc消费方调用.jpg

启动shop-web 服务消费方 -移动端启动

![fdb805817df7799498dbf887f86999dc.png][]

shop-web消费方调用.jpg

**最后预告**

如上面几张控制台截图我们模拟的 shop-ds(服务提供方)、shop-web(移动)和shop-pc(PC)消费方 都已经跑起来了，效果也达到我们预期的目的，那么还剩下最后一部分内容 我们会在 spring boot + zookeeper + dubbo 框架基础上 集成 mybatis + swagger 来实现增、删、改、查业务。

**关注我们**

更多精彩内容请关注“IT实战联盟”公\*众\*号，如果需要源码的话可以关注\*公\*众\*号并留言（sb+zk+boot源码）会自动回复 源码GitHub地址，也可以加入交流群和作者互撩哦~~~

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

[SpringBoot_zk_dubbo_zookeeper]: https://www.jianshu.com/p/f4c81373094f
[SpringBoot_zk_dubbo_SpringBoot _ zookeeper]: https://www.jianshu.com/p/cc983c8dc47a
[SpringBoot_zk_dubbo_Dubbo-admin]: https://www.jianshu.com/p/e7c85b5d87cf
[http_blog.100boot.cn]: http://blog.100boot.cn/
[e037811e2919fb8f620b57dfdfd1b7e8.gif]: /images/20220523/5a60f6805f404ae68cbad773065d3ffa.png
[1ab0f89d8e9ad8fb762ad0441c64f194.png]: /images/20220523/fd40dc8b439c477b9f9e0cb2c15d97f1.png
[7793441f209a3af7c742d52edce5e6b3.png]: /images/20220523/35c8df0d71594725bde83c83150b407e.png
[cbae1828cdd3febe031d54456f2cb9f9.png]: /images/20220523/6adf8322db444d68b6f43ea3dc06208b.png
[76b7785b970df30563e5dfae4903b853.png]: /images/20220523/08e605d736454364a3f299b4ac889830.png
[da4febfac1d7933edb29f6ad48b8dcfd.png]: /images/20220523/76e610860e614469b5b5fba9cccbce67.png
[fdb805817df7799498dbf887f86999dc.png]: /images/20220523/0389b62d386343fbb134cae44e1e76a8.png