dubbo2.x helloworld

dubbo是使用非常广的分布式服务框架, 这就导致很长一段时间内，使用java技术栈的公司都是使用dubbo作为分布式服务框架。
而且中小型公司并没有维护dubbo底层层框架的能力,加上商业公司有个通病业务价值驱动技术更新，2.x版本已经足够日常业务使用,
没有足够的业务价值驱动版本升级,所以大部分这类公司沿用了dubbo的较低版本。本文就以dubbo较低版本2.6.2来写。

zookeeper服务注册中心

  • 下面包含了下载zk和启动zk
    1
    2
    3
    4
    5
    6
    7
    ## 服务地址可能变化，在zk官网上找就是
    wget https://dlcdn.apache.org/zookeeper/zookeeper-3.8.1/apache-zookeeper-3.8.1-bin.tar.gz
    tar xvf apache-zookeeper-3.8.1-bin.tar.gz
    cd apache-zookeeper-3.8.1-bin 
    cp conf/zoo_sample.cfg conf/zoo.cfg
    cd bin
    ./zkServer.sh start

服务提供者

  1. pom文件:

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    25
    26
    27
    28
    29
    30
    31
    32
    33
    34
    35
    36
    37
    38
    39
    40
    <?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">
        <modelVersion>4.0.0</modelVersion>
        <parent>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <version>2.6.14</version>
        </parent>

        <groupId>com.zw.dubbo</groupId>
        <artifactId>dubbo-provider</artifactId>
        <version>1.0-SNAPSHOT</version>

        <properties>
            <maven.compiler.source>8</maven.compiler.source>
            <maven.compiler.target>8</maven.compiler.target>
            <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
            <dubbo.version>2.6.2</dubbo.version>
        </properties>

        <dependencies>
            <dependency>
                <groupId>org.apache.curator</groupId>
                <artifactId>curator-framework</artifactId>
                <version>2.12.0</version>
            </dependency>
            <dependency>
                <groupId>com.alibaba</groupId>
                <artifactId>dubbo</artifactId>
                <version>${dubbo.version}</version>
            </dependency>
            <dependency>
                <groupId>ch.qos.logback</groupId>
                <artifactId>logback-classic</artifactId>
                <version>1.2.3</version>
            </dependency>
        </dependencies>
    </project>

  2. resources下服务提供者配置文件:dubbo-provider.xml

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    <?xml version="1.0" encoding="UTF-8"?>
    <beans xmlns="http://www.springframework.org/schema/beans"
           xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
           xmlns:dubbo="http://dubbo.apache.org/schema/dubbo"
           xsi:schemaLocation="http://www.springframework.org/schema/beans        http://www.springframework.org/schema/beans/spring-beans-4.3.xsd        http://dubbo.apache.org/schema/dubbo        http://dubbo.apache.org/schema/dubbo/dubbo.xsd">

        <!-- 提供方应用信息，用于计算依赖关系 -->
        <dubbo:application name="dubbo-provider"  />

        <!-- 使用multicast广播注册中心暴露服务地址 -->
        <dubbo:registry protocol="zookeeper" address="127.0.0.1:2181"/>

        <!-- 用dubbo协议在20880端口暴露服务 -->
        <dubbo:protocol name="dubbo" port="20880" />

        <!-- 声明需要暴露的服务接口 -->
        <dubbo:service interface="com.zw.dubbo.service.DemoService" ref="demoService" />

        <!-- 和本地bean一样实现服务 -->
        <bean id="demoService" class="com.zw.dubbo.service.DemoServiceImpl" />
    </beans>

  3. 接口定义文件

    1
    2
    3
    4
    5
    6
    7
    package com.zw.dubbo.service;

    public interface DemoService {

        String sayHello(String name);

    }

  4. 接口实现

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    package com.zw.dubbo.service;

    public class DemoServiceImpl implements DemoService {

        @Override
        public String sayHello(String name) {
            return name + " hello, welcome to dubbo!";
        }

    }

  5. 服务启动类

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    package com.zw.dubbo;

    import org.springframework.context.support.ClassPathXmlApplicationContext;

    import java.io.IOException;

    public class Provider {

        public static void main(String[] args) throws IOException {
            ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("classpath:/dubbo-provider.xml");
            context.start();
            System.in.read();
            // 按任意键退出
        }

    }

服务消费者

  1. pom文件

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    25
    26
    27
    28
    29
    30
    31
    32
    33
    34
    35
    36
    37
    38
    39
    40
    <?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">
        <modelVersion>4.0.0</modelVersion>
        <parent>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <version>2.6.14</version>
        </parent>

        <groupId>com.zw.dubbo</groupId>
        <artifactId>dubbo-consumer</artifactId>
        <version>1.0-SNAPSHOT</version>

        <properties>
            <maven.compiler.source>8</maven.compiler.source>
            <maven.compiler.target>8</maven.compiler.target>
            <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
            <dubbo.version>2.6.2</dubbo.version>
        </properties>

        <dependencies>
            <dependency>
                <groupId>org.apache.curator</groupId>
                <artifactId>curator-framework</artifactId>
                <version>2.12.0</version>
            </dependency>
            <dependency>
                <groupId>com.alibaba</groupId>
                <artifactId>dubbo</artifactId>
                <version>${dubbo.version}</version>
            </dependency>
            <dependency>
                <groupId>ch.qos.logback</groupId>
                <artifactId>logback-classic</artifactId>
                <version>1.2.3</version>
            </dependency>
        </dependencies>
    </project>

  2. 消费者dubbo配置文件

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    <?xml version="1.0" encoding="UTF-8"?>
    <beans xmlns="http://www.springframework.org/schema/beans"
           xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
           xmlns:dubbo="http://dubbo.apache.org/schema/dubbo"
           xsi:schemaLocation="http://www.springframework.org/schema/beans        http://www.springframework.org/schema/beans/spring-beans-4.3.xsd        http://dubbo.apache.org/schema/dubbo        http://dubbo.apache.org/schema/dubbo/dubbo.xsd">

        <!-- 消费方应用名，用于计算依赖关系，不是匹配条件，不要与提供方一样 -->
        <dubbo:application name="dubbo-consumer" />

        <!-- 使用multicast广播注册中心暴露发现服务地址 -->
        <dubbo:registry protocol="zookeeper" address="127.0.0.1:2181"/>

        <!-- 生成远程服务代理，可以和本地bean一样使用demoService -->
        <dubbo:reference id="demoService" interface="com.zw.dubbo.service.DemoService" />
    </beans>

  3. 接口定义类

    1
    2
    3
    4
    5
    6
    7
    package com.zw.dubbo.service;

    public interface DemoService {

        String sayHello(String name);

    }

  4. 服务启动调用类

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    package com.zw.dubbo;

    import com.zw.dubbo.service.DemoService;
    import org.springframework.context.support.ClassPathXmlApplicationContext;

    public class Consumer {

        public static void main(String[] args) {
            ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(new String[] {"classpath:consumer.xml"});
            context.start();
            DemoService demoService = (DemoService)context.getBean("demoService"); // 获取远程服务代理
            String hello = demoService.sayHello("你大爷"); // 执行远程方法
            System.out.println( hello ); // 显示调用结果
        }
    }

上面贴上了所有代码，但是需要注意一点文件目录并没有描述，可以从package代码可以看到