dubbo使用记录

缺乏、安全感 2022-07-12 14:38 117阅读 0赞

### 使用场景 ###

Dubbo缺省协议采用单一长连接和NIO异步通讯，适合于小数据量高并发的服务调用，以及服务消费者机器数远大于服务提供者机器数的情况。架构图如下：![Center][]

Dubbo缺省协议不适合传送大数据量的服务，比如传文件，传视频等，除非请求量很低。

项目一开始决定使用dubbo时完全是陌生的，所以为了尽快实现功能，dubbo服务接口采用了xml配置方式来暴露，随着项目的进展，需要配置的接口越来越多，这样势必会造成维护的不方便。于是决定改为注解方式，分为两部分：

### 注解方式 ###

provider

import com.alibaba.dubbo.config.annotation.Service;
    
    @Service(version = "${demo.service.version}",group = "${demo.service.group}")
    public class DefaultService implements DemoService {
        
    }

启动

import com.alibaba.dubbo.config.spring.context.annotation.EnableDubbo;
    
    @EnableDubbo(scanBasePackages = "com.alibaba.dubbo.demo.service")
    @PropertySource(value = "classpath:/provider-config.properties")
    public class DemoServiceProviderBootstrap {
    
        public static void main(String[] args) throws IOException {
            AnnotationConfigApplicationContext context = new AnnotationConfigApplicationContext();
            context.register(DemoServiceProviderBootstrap.class);
            context.refresh();
            System.out.println("DemoService provider is starting...");
            System.in.read();
        }
    }

consumer

消费端需要做的就是能够发现服务即可。首先在Action文件里，引入服务需要使用@Reference，一定要注意的是：服务的全路径一定要与提供者保持一致

@EnableDubbo
    @PropertySource(value = "classpath:/consumer-config.properties")
    public class DemoServiceConsumerBootstrap {
    
        @Reference(version = "${demo.service.version}" ,group = "${demo.service.group}")
        private DemoService demoService;
    
        public static void main(String[] args) throws IOException {
            AnnotationConfigApplicationContext context = new AnnotationConfigApplicationContext();
            context.register(DemoServiceConsumerBootstrap.class);
            context.refresh();
            System.in.read();
            context.close();
        }
    }

### dubbo-admin ###

dubbo旧版控制台已经不再维护，今天试了下新版，做个记录

导出源码：[https://github.com/apache/incubator-dubbo-admin][https_github.com_apache_incubator-dubbo-admin]

新版本采用前后端分离，有两种部署方式，可以参考文档[dubbo管控台说明文档][dubbo]

打开文件application.properties修改注册中心和配置中心地址

maven方式安装，执行

mvn clean package

到dubbo-admin-distribution/target下执行

java -jar dubbo-admin-0.1.jar

访问localhost:8080

dubbo+nocas组合使用

[https://github.com/changhf/dubbo-registry-nacos.git][https_github.com_changhf_dubbo-registry-nacos.git]

启动nacos注册中心，服务发现如下

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoYW5nX2xp_size_16_color_FFFFFF_t_70][]

[Center]: /images/20220709/02be4ac3fe384e19a27910e073e6e4f1.png
[https_github.com_apache_incubator-dubbo-admin]: https://github.com/apache/incubator-dubbo-admin
[dubbo]: http://dubbo.apache.org/zh-cn/docs/admin/introduction.html
[https_github.com_changhf_dubbo-registry-nacos.git]: https://github.com/changhf/dubbo-registry-nacos.git
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoYW5nX2xp_size_16_color_FFFFFF_t_70]: /images/20220709/4c693bb05175494ba1b47e5853bea3a7.png