dubbo入门

1.dubbo快速入门

2.dubbo常规配置

一 、dubbo快速入门

---

dubbo是什么

dubbo是由阿里开源的SPA服务治理框架，更为贴切的说法是RPC远程过程调用框架，支持多种传输及序列化的方案。

引入依赖

<dependency>
    <groupId>com.alibaba</groupId>
    <artifactId>dubbo</artifactId>
    <version>2.6.2</version>
</dependency>

模块结构说明

模块.png

dubbo-client 是消费端模块，dubbo-server是服务提供端模块，server-SDK是作为组件，供dubbo-client与dubbo-server依赖,提供了功能接口与pojo类，目的是屏蔽掉服务提供端的接口实现类的业务逻辑，针对server-SDK的作用，相信阅读并coding完本文内容之后就可以理解了。

服务提供端代码(先引入API层面如何实现)

public class DubboServer {
    public void buildService(int port){
        ServiceConfig<UserService> serviceConfig  = new ServiceConfig();
        //设置注册中心,暂时没有引入注册中心
        serviceConfig.setRegistry(new RegistryConfig(RegistryConfig.NO_AVAILABLE));
        //设置传输过程中通信协议及端口号
        serviceConfig.setProtocol(new ProtocolConfig("dubbo",port));
        // 设置应用名
        serviceConfig.setApplication(new ApplicationConfig("dubbo-server"));
        //设置暴露服务的接口
        serviceConfig.setInterface(UserService.class);
        UserService userService = new UserServiceImpl();
        //设置暴露服务的实现类
        serviceConfig.setRef(userService);
        //对外暴漏userService服务
        serviceConfig.export();
        int realPort = serviceConfig.getExportedUrls().get(0).getPort();
        ((UserServiceImpl) userService).setPort(realPort);
        System.out.println("dubbo服务已开启："+realPort);
    }
    public static void main(String[] args) throws IOException {
        new DubboServer().buildService(-1);
        System.in.read();
    }
}

服务消费端代码(先引入API层面如何实现)

public class DubboClient {
    private String remoteUrl = "dubbo://169.254.103.163:20880/com.ckd.dubbo.server.UserService"
    public UserService getUser(){
        ReferenceConfig<UserService> referenceConfig = new ReferenceConfig();
        referenceConfig.setInterface(UserService.class);
        referenceConfig.setApplication(new ApplicationConfig("dubbo-client"));
        referenceConfig.setUrl(remoteUrl);
        UserService userService = referenceConfig.get();
        return userService;
    }
    public static void main(String[] args) {
        UserService user = new DubboClient().getUser();
        System.out.println(user.getUser(1));
    }
}

服务端集群

试想一下,上面代码中需要服务消费端知道服务端地址才可以实现通信,此时可以将地址配置在消费端，但是随着服务端访问量变大时，需要增加节点时，消费端需要人工维护地址，并自己实现负载策略以决定调用那个节点。不利于动态扩容。

集群

因此需要引入注册中心，以实现动态扩容，监控服务的上下线。

注册中心

修改服务端与消费端API

服务提供端
serviceConfig.setRegistry(new RegistryConfig("multicast://224.5.6.7:1234"));

服务消费端
referenceConfig.setRegistry(new RegistryConfig("multicast://224.5.6.7:1234"));

集成spring

服务提供端

<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:dubbo="http://dubbo.apache.org/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-4.3.xsd
       http://dubbo.apache.org/schema/dubbo http://dubbo.apache.org/schema/dubbo/dubbo.xsd">
    <!--provider应用名-->
    <dubbo:application name="dubbo-provider"/>
    <!--用dubbo协议从20800端口开始暴漏服务-->
    <dubbo:protocol name="dubbo" port="-1"/>
    <!--<dubbo:registry address="zookeeper://localhost:2181"/>-->
    <!--用multicast广播注册中心暴漏服务地址-->
    <dubbo:registry address="multicast://224.5.6.7:1234"/>
    <!--dubbo:provider 提供了默认配置
    protocol="dubbo" port="-1" 可以不用<dubbo:protocol>标签
    application 可以代替<dubbo:application>标签
    timeout,retries....可以应用在<dubbo:service>标签里，避免配置多个<dubbo:service>时重复配置
    -->
    <dubbo:provider protocol="dubbo" port="-1" application="dubbo-provider" retries="2"
    timeout="5000"  loadbalance="roundrobin" threadpool="fixed" />
    <dubbo:service loadbalance="roundrobin" interface="com.ckd.dubbo.server.UserService" ref="userService"/>
    <bean id="userService" class="com.ckd.dubbo.server.impl.UserServiceImpl"/>
</beans>