前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >Dubbo实战(二) - 环境搭建

Dubbo实战(二) - 环境搭建

作者头像
JavaEdge
发布2021-02-23 14:59:55
2560
发布2021-02-23 14:59:55
举报
文章被收录于专栏:JavaEdgeJavaEdge

Dubbo 采用全 Spring 配置方式,透明化接入应用,对应用没有任何 API 侵入,只需用 Spring 加载 Dubbo 的配置即可,Dubbo 基于 Spring 的 Schema 扩展 进行加载。

如果不想使用 Spring 配置,可以通过 API 的方式 进行调用。

1 Provider

1.1 定义服务接口

  • DemoService.java (该接口需单独打包,在服务提供方和消费方共享)
代码语言:javascript
复制
package org.apache.dubbo.demo;

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

1.2 在服务提供方实现接口

  • DemoServiceImpl.java (对服务消费方隐藏实现)
代码语言:javascript
复制
package org.apache.dubbo.demo.provider;
 
import org.apache.dubbo.demo.DemoService;
 
public class DemoServiceImpl implements DemoService {
    public String sayHello(String name) {
        return "Hello " + name;
    }
}

1.3 用 Spring 配置声明暴露服务

  • provider.xml:
代码语言:javascript
复制

1.4 加载 Spring 配置

  • Provider.java:
代码语言:javascript
复制
import org.springframework.context.support.ClassPathXmlApplicationContext;
 
public class Provider {
    public static void main(String[] args) throws Exception {
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(new String[] {"http://10.20.160.198/wiki/display/dubbo/provider.xml"});
        context.start();
        System.in.read(); // 按任意键退出
    }
}

2 Consumer

2.1 通过 Spring 配置引用远程服务

  • consumer.xml:
代码语言:javascript
复制

2.2 加载Spring配置,并调用远程服务

  • Consumer.java (也可以使用 IoC 注入)
代码语言:javascript
复制
import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.apache.dubbo.demo.DemoService;
 
public class Consumer {
    public static void main(String[] args) throws Exception {
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(new String[] {"http://10.20.160.198/wiki/display/dubbo/consumer.xml"});
        context.start();
        DemoService demoService = (DemoService)context.getBean("demoService"); // 获取远程服务代理
        String hello = demoService.sayHello("world"); // 执行远程方法
        System.out.println( hello ); // 显示调用结果
    }
}

3 SpringBoot搭建

3.1 生成者

  • 启动类
  • 服务类
  • 接口
  • 配置

3.2 消费者

  • 启动类
  • 服务类
  • 配置

3.3 文件结构

其实上面的操作都是直连提供者的具体实现

4 直连提供者

4.0 概念

消费端知道服务提供者的地址,直接进行连接

限制了分布式的易扩展性

一般只在测试环境中使用,绕过注册中心,只测试指定的服务提供者,这时候可能需要

  • 点对点直连方式 以服务接口为单位,忽略注册中心的提供者列表,A 接口配置点对点,不影响 B 接口从注册中心获取列表

4.1 通过 XML 配置

如果是线上需求需要点对点,可在 中配置 url 指向提供者,将绕过注册中心,多个地址用分号隔开,配置如下(≥1.0.6 版本)

代码语言:javascript
复制

4.2 通过 -D 参数指定

在 JVM 启动参数中加入-D参数映射服务地址

key 为服务名,value 为服务提供者 url,此配置优先级最高,1.0.15 及以上版本支持

代码语言:javascript
复制
java -Dcom.alibaba.xxx.XxxService=dubbo://localhost:20890

4.3 通过文件映射

如果服务比较多,也可以用文件映射,用 -Ddubbo.resolve.file 指定映射文件路径,此配置优先级高于 dubbo:reference 中的配置

1.0.15 及以上版本支持,2.0 以上版本自动加载 ${user.home}/dubbo-resolve.properties文件,不需要配置

代码语言:javascript
复制
java -Ddubbo.resolve.file=xxx.properties

然后在映射文件 xxx.properties 中加入配置,其中 key 为服务名,value 为服务提供者 URL:

代码语言:javascript
复制
com.alibaba.xxx.XxxService=dubbo://localhost:20890

注意 为了避免复杂化线上环境,不要在线上使用这个功能,只应在测试阶段使用。

5 启动ZooKeeper

6 SpringBoot配置注册中心

修改配置文件,现在有注册中心了,不再是直连模式!

6.1 再配置Provider

  • 添加zookeeper客户端依赖
  • 添加zookeeper配置

6.2 再配置Consumer

  • 添加zookeeper客户端依赖
  • 添加zookeeper配置
  • 修改消费服务类

参考

Dubbo官方文档

本文参与 腾讯云自媒体分享计划,分享自作者个人站点/博客。
原始发表:2019-09-01 ,如有侵权请联系 cloudcommunity@tencent.com 删除

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

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

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

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • 1 Provider
    • 1.1 定义服务接口
      • 1.2 在服务提供方实现接口
        • 1.3 用 Spring 配置声明暴露服务
          • 1.4 加载 Spring 配置
          • 2 Consumer
            • 2.1 通过 Spring 配置引用远程服务
              • 2.2 加载Spring配置,并调用远程服务
              • 3 SpringBoot搭建
                • 3.1 生成者
                  • 3.2 消费者
                    • 3.3 文件结构
                    • 4 直连提供者
                      • 4.0 概念
                        • 4.1 通过 XML 配置
                          • 4.2 通过 -D 参数指定
                            • 4.3 通过文件映射
                            • 5 启动ZooKeeper
                            • 6 SpringBoot配置注册中心
                              • 6.1 再配置Provider
                                • 6.2 再配置Consumer
                                • 参考
                                相关产品与服务
                                微服务引擎 TSE
                                微服务引擎(Tencent Cloud Service Engine)提供开箱即用的云上全场景微服务解决方案。支持开源增强的云原生注册配置中心(Zookeeper、Nacos 和 Apollo),北极星网格(腾讯自研并开源的 PolarisMesh)、云原生 API 网关(Kong)以及微服务应用托管的弹性微服务平台。微服务引擎完全兼容开源版本的使用方式,在功能、可用性和可运维性等多个方面进行增强。
                                领券
                                问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档