dubbo-springboot入门级demo

老梁

发布于 2019-09-10 18:36:15

3510

发布于 2019-09-10 18:36:15

文章被收录于专栏：Java工程师成长之路Java工程师成长之路

1. dubbo-springboot入门级demo

1.1. 前言

最后一个做运维的朋友和我提起，他们公司想做个dubbo灰度发布的功能，而这个功能落到了他头上。在我的印象里，dubbo应该可以通过扩展代码来实现特定用户路由到特定服务器，来实现这方面的灰度功能，但完全由运维去做，可能就需要脚本了吧，dubbo是否支持脚本我还不清楚，趁着这个进一步熟悉dubbo的过程，我来系统的学一下dubbo的基本功能，由于现在基本都用springboot来开发了，所以直接从springboot入门级dubbo应用开始

1.2. 生产者

1.2.1. 服务方法和接口

public interface GreetingService {
    String sayHello(String name);
}

import com.tzxylao.dubbo.service.GreetingService;
import org.apache.dubbo.config.annotation.Service;
import org.springframework.beans.factory.annotation.Value;

@Service(version = "1.0.0")
public class GreetingServiceImpl implements GreetingService {

    @Value("${dubbo.application.name}")
    private String serviceName;
    @Value("${dubbo.protocol.port:0}")
    private int port;

    @Override
    public String sayHello(String name) {
        return String.format("[%s][%s] : Hello, %s", serviceName,port, name);
    }
}

1.2.2. 配置文件application.properties

server.port=8082

dubbo.application.name=first-dubbo-provider
dubbo.scan.base-packages=com.tzxylao.dubbo.service

dubbo.protocol.name=dubbo
dubbo.protocol.port=20884
dubbo.registry.address=zookeeper://127.0.0.1:2181

1.2.3. pom

<properties>
        <java.version>1.8</java.version>
        <spring-boot.version>2.1.1.RELEASE</spring-boot.version>
        <dubbo.version>2.7.1</dubbo.version>
        <curator.version>2.8.0</curator.version>
        <zookeeper.version>3.4.6</zookeeper.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>


        <!-- Dubbo Spring Boot Starter -->
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>2.7.1</version>
        </dependency>

        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo</artifactId>
        </dependency>


        <!-- zookeeper -->
        <dependency>
            <groupId>org.apache.zookeeper</groupId>
            <artifactId>zookeeper</artifactId>
            <version>${zookeeper.version}</version>
            <exclusions>
                <exclusion>
                    <groupId>org.slf4j</groupId>
                    <artifactId>slf4j-log4j12</artifactId>
                </exclusion>
                <exclusion>
                    <groupId>log4j</groupId>
                    <artifactId>log4j</artifactId>
                </exclusion>
                <exclusion>
                    <groupId>io.netty</groupId>
                    <artifactId>netty</artifactId>
                </exclusion>
            </exclusions>
        </dependency>

        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-framework</artifactId>
            <version>${curator.version}</version>
        </dependency>
        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-recipes</artifactId>
            <version>${curator.version}</version>
        </dependency>
    </dependencies>
    <repositories>
        <repository>
            <id>apache.snapshots.https</id>
            <name>Apache Development Snapshot Repository</name>
            <url>https://repository.apache.org/content/repositories/snapshots</url>
            <releases>
                <enabled>false</enabled>
            </releases>
            <snapshots>
                <enabled>true</enabled>
            </snapshots>
        </repository>
    </repositories>

1.2.4. 启动方法

@EnableAutoConfiguration
public class DubboApplication {

    public static void main(String[] args) {
        SpringApplication.run(DubboApplication.class, args);
    }

}

1.3. 消费者

1.3.1. 接口同上

1.3.2. pom同上

1.3.3. 配置文件

server.port=8081

spring.application.name=first-dubbo-consumer
dubbo.registry.address=zookeeper://127.0.0.1:2181

1.3.4. 启动方法

@EnableAutoConfiguration
public class DubboConsumerApplication {

    @Reference(version = "1.0.0")
    private GreetingService greetingService;

    public static void main(String[] args) throws InterruptedException {
        SpringApplication.run(DubboConsumerApplication.class, args);
    }

    @Bean
    public ApplicationRunner runner(){
        int count = 0;
        while (true) {
            System.out.println(greetingService.sayHello("World "));
            try {
                TimeUnit.SECONDS.sleep(3);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            count++;
            if (count == 100) {
                break;
            }
        }
        return s -> {
            System.out.println(greetingService.sayHello("World"));
        };
    }

}

1.4. 运行结果

...
[first-dubbo-provider][20884] : Hello, World
[first-dubbo-provider][20884] : Hello, World
...

1.5. 总结

这里需要注意的几个核心点就是扫描包路劲别搞错
@Refernece注解用的是dubbo包里的，@Service也是dubbo包里的

Github地址：https://github.com/tzxylao/learn-demo

本文参与腾讯云自媒体分享计划，分享自作者个人站点/博客。

原始发表：2019-04-19 ，如有侵权请联系 cloudcommunity@tencent.com 删除

dubbo

运维

maven

本文分享自作者个人站点/博客前往查看

如有侵权，请联系 cloudcommunity@tencent.com 删除。

本文参与腾讯云自媒体分享计划，欢迎热爱写作的你一起参与！

dubbo

运维

maven

登录后参与评论

0 条评论

热度

dubbo-springboot入门级demo

dubbo-springboot入门级demo

1. dubbo-springboot入门级demo

1.1. 前言

1.2. 生产者

1.2.1. 服务方法和接口

1.2.2. 配置文件application.properties

1.2.3. pom

1.2.4. 启动方法

1.3. 消费者

1.3.1. 接口同上

1.3.2. pom同上

1.3.3. 配置文件

1.3.4. 启动方法

1.4. 运行结果

1.5. 总结

社区

活动

资源

关于

腾讯云开发者

热门产品

热门推荐

更多推荐