Dubbo-04 20190317
SpringBoot使用dubbo
1. idea没问题可以直接创建 如果使用eclipse 需要安装spring插件
1 )查看eclipse版本 Help->About Eclipse IDE
2 )找插件地址 4.9与eclispe匹配
https://spring.io/tools3/sts/all
3 )Eclipse安装
Help->Install New SoftWare
**2. 创建SpringBoot项目 provider **
1 )pom文件 需要引入jar包 和之前的userService接口
<?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.1.3.RELEASE</version><relativePath /> <!-- lookup parent from repository --></parent><groupId>com.test</groupId><artifactId>boot-user-service-provider</artifactId><version>0.0.1-SNAPSHOT</version><name>boot-user-service-provider</name><description>Demo project for Spring Boot</description><properties><java.version>1.8</java.version><spring-boot.version>2.1.1.RELEASE</spring-boot.version><dubbo.version>2.7.0</dubbo.version></properties><dependencies><dependency><!--common的pom.xml 开头就是这个配置 直接复制过来groupId artifactId version --><groupId>com.test.mall</groupId><artifactId>mall-common</artifactId><version>0.0.1-SNAPSHOT</version></dependency><!-- springboot--><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId></dependency><!-- Dubbo Spring Boot Starter --><dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo-spring-boot-starter</artifactId><version>2.7.0</version></dependency><dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo</artifactId><version>${dubbo.version}</version></dependency><!-- Zookeeper --><dependency><groupId>org.apache.zookeeper</groupId><artifactId>zookeeper</artifactId><version>3.4.6</version></dependency><dependency><groupId>org.apache.curator</groupId><artifactId>curator-framework</artifactId><version>2.12.0</version></dependency><dependency><groupId>org.apache.curator</groupId><artifactId>curator-recipes</artifactId><version>2.12.0</version></dependency></dependencies><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId></plugin></plugins></build></project>
2 ) Service
package com.test.mall.service.impl;
import java.util.Arrays;
import java.util.List;
import org.apache.dubbo.config.annotation.Service;
import org.springframework.stereotype.Component;import com.test.mall.bean.UserAddress;
import com.test.mall.service.UserService;
/*** 接口的实现类 负责提供所需数据* * @author LM**/
@Service // 为了暴露服务 这个service不是spring的 是dubbo家的
@Component
public class UserServiceImpl implements UserService {public List<UserAddress> getUserAddressList(String userId) {UserAddress address1 = new UserAddress(1, "沙河高教園", "1", "李老师", "010-88888888", "Y");UserAddress address2 = new UserAddress(2, "沙河", "1", "王老师", "010-66666666", "N");return Arrays.asList(address1, address2);}
}
3 )配置文件
#名称
dubbo.application.name=user-service-provider
#注册中心
dubbo.registry.address=127.0.0.1:2181
dubbo.registry.protocol=zookeeper
#通信协议
dubbo.protocol.name=dubbo
dubbo.protocol.port=20880
#监控中心
dubbo.monitor.protocol=registry
dubbo.scan.base-packages=com.test.mall.service.impl
4 )启动 我用的是dubbo2.7 这个启动类里边不需要开启EnableDubbo注解 在配置文件写dubbo.scan.base-packages=com.test.mall.service.impl
package com.test.mall;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;//@EnableDubbo
@SpringBootApplication
public class BootUserServiceProviderApplication {public static void main(String[] args) {SpringApplication.run(BootUserServiceProviderApplication.class, args);}}
5 ) 启动 查看dubbo admin 管理页
2. 创建SpringBoot项目 consumer web项目
1 )
2 )pom 文件
<?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.1.3.RELEASE</version><relativePath /> <!-- lookup parent from repository --></parent><groupId>com.test</groupId><artifactId>boot-user-service-consumer</artifactId><version>0.0.1-SNAPSHOT</version><name>boot-user-service-consumer</name><description>Demo project for Spring Boot</description><properties><java.version>1.8</java.version><dubbo.version>2.7.0</dubbo.version></properties><dependencies><dependency><!--common的pom.xml 开头就是这个配置 直接复制过来groupId artifactId version --><groupId>com.test.mall</groupId><artifactId>mall-common</artifactId><version>0.0.1-SNAPSHOT</version></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></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.0</version></dependency><dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo</artifactId><version>${dubbo.version}</version></dependency><!-- Zookeeper --><dependency><groupId>org.apache.zookeeper</groupId><artifactId>zookeeper</artifactId><version>3.4.6</version></dependency><dependency><groupId>org.apache.curator</groupId><artifactId>curator-framework</artifactId><version>2.12.0</version></dependency><dependency><groupId>org.apache.curator</groupId><artifactId>curator-recipes</artifactId><version>2.12.0</version></dependency></dependencies><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId></plugin></plugins></build></project>
3 ) 编写service类 和 controller类
controller:
package com.test.mall.controller;import java.util.List;import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.ResponseBody;import com.test.mall.bean.UserAddress;
import com.test.mall.service.OrderService;@Controller
public class OrderController {@AutowiredOrderService OrderService;@ResponseBody@RequestMapping("/initOrder")public List<UserAddress> initOrder(@RequestParam("uid") String userId) {return OrderService.initOrder(userId);}
}
service: 使用dubbo的Reference注解
package com.test.mall.service.impl;import java.util.List;import org.apache.dubbo.config.annotation.Reference;
import org.springframework.stereotype.Service;import com.test.mall.bean.UserAddress;
import com.test.mall.service.OrderService;
import com.test.mall.service.UserService;@Service
public class OrderServiceImpl implements OrderService {// @Autowired@ReferenceUserService userService;public List<UserAddress> initOrder(String userId) {// 查询用户收货地址List<UserAddress> addList = userService.getUserAddressList(userId);for(UserAddress ua:addList) {System.out.println(ua.getUserAddress());}return addList;}}
main:
package com.test.mall;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;@SpringBootApplication
public class BootUserServiceConsumerApplication {public static void main(String[] args) {SpringApplication.run(BootUserServiceConsumerApplication.class, args);}}
4 ) 配置文件
#应用名字
dubbo.application.name=user-service-consumer#注册中心
dubbo.registry.address=zookeeper://127.0.0.1:2181
#监控中心 去注册中心找
dubbo.monitor.protocol=registryserver.port=8082
5 )访问页面
3. dubbo属性加载顺序
从上到下 优先级降低
-D 是虚拟机参数 启动项目的时候后边跟的参数
xml就相当于springboot中的application.properties
dubbo.propertie主要配置一些公共配置 如果其他地方不配合的话 他就会起作用
以 timeout 为例(默认超时是1000毫秒),下图显示了配置的查找顺序,其它 retries, loadbalance, actives 等类似:
- 方法级优先,接口级次之,全局配置再次之。!!!
- 如果级别一样,则消费方优先,提供方次之。!
其中,服务提供方配置,通过 URL 经由注册中心传递给消费方。
从上到下 优先级逐渐降低
这里有一个方法级别的配置 方法优先
(建议由服务提供方设置超时,因为一个方法需要执行多长时间,服务提供方更清楚,如果一个消费方同时引用多个服务,就不需要关心每个服务的超时设置)。
4. dubbo 启动检查
http://dubbo.apache.org/zh-cn/docs/user/demos/preflight-check.html
Dubbo 缺省会在启动时检查依赖的服务是否可用,不可用时会抛出异常,阻止 Spring 初始化完成,以便上线时,能及早发现问题**,默认 check=“true”。**
可以通过 **check="false"** 关闭检查,比如,测试时,有些服务不关心,或者出现了循环依赖,必须有一方先启动。另外,如果你的 Spring 容器是懒加载的,或者通过 API 编程延迟引用服务,请关闭 check,否则服务临时不可用时,会抛出异常,拿到 null 引用,如果 check="false",总是会返回引用,当服务恢复时,能自动连上。
单个设置 关闭某个服务的启动时检查 (没有提供者时报错):
<dubbo:reference interface="com.foo.BarService" check="false" />
统一设置 关闭所有服务的启动时检查 (没有提供者时报错):
<dubbo:consumer check="false" />
关闭注册中心启动时检查 (注册订阅失败时报错):
<dubbo:registry check="false" />
通过 dubbo.properties
dubbo.reference.com.foo.BarService.check=false
dubbo.reference.check=false
dubbo.consumer.check=false
dubbo.registry.check=false
通过 -D 参数
java -Ddubbo.reference.com.foo.BarService.check=false
java -Ddubbo.reference.check=false
java -Ddubbo.consumer.check=false
java -Ddubbo.registry.check=false配置的含义
dubbo.reference.check=false,强制改变所有 reference 的 check 值,就算配置中有声明,也会被覆盖。dubbo.consumer.check=false,是设置 check 的缺省值,如果配置中有显式的声明,如:<dubbo:reference check="true"/>,不会受影响。dubbo.registry.check=false,前面两个都是指订阅成功,但提供者列表是否为空是否报错,如果注册订阅失败时,也允许启动,需使用此选项,将在后台定时重试。
这些配置参考手册:
http://dubbo.apache.org/zh-cn/docs/user/quick-start.html
知识点:
timeout :
方法调用超时时间(毫秒) 调优的时候使用 默认1000毫秒
retries:
远程服务调用重试次数,不包括第一次调用,不需要重试请设为0 配合timeout使用 也是性能调优的时候使用 如果调用provider1是吧 可能会再去尝试连接provider2 provider3 等 这与loadbalance 负载均衡策略有关系
注意:这个重试次数 要在服务符合幂等性的情况下才能使用多次 幂等性就是你操作1次和操作2次的结果是一样的 比如查询/修改/删除 数据 查询一次 和查询2次 结果都是一样的(当然不能考虑中间有数据新增的情况 没这个必要) 但是修改或者新增就不一样了,你新增第一次更新了某些字段,然后服务端由于某些原因超时了,但是这些新增已经起作用了,客户端傻呀,它不知道你已经新增完成了,它只知道你没有按时返回,他就又去调用你,你又进行新增 这就不对了 ~~ 这就不是幂等了
loadbalance:
负载均衡策略,可选值:random,roundrobin,leastactive,分别表示:随机,轮询,最少活跃调用
随机就是那个随机 不一定下一个是谁
轮训就是1 2 3 1 2 3 这样
最少活跃调用就是谁被用的少就去用谁
5. dubbo 多版本 灰度发布
当一个接口实现,出现不兼容升级时,可以用版本号过渡,版本号不同的服务相互间不引用。
可以按照以下的步骤进行版本迁移:
1 ) 在低压力时间段,先升级一半提供者为新版本
2 )再将所有消费者升级为新版本
3 )然后将剩下的一半提供者升级为新版本
老版本服务提供者配置:
<dubbo:service interface="com.foo.BarService" version="1.0.0" />
新版本服务提供者配置:
<dubbo:service interface="com.foo.BarService" version="2.0.0" />
老版本服务消费者配置:
<dubbo:reference id="barService" interface="com.foo.BarService" version="1.0.0" />
新版本服务消费者配置:
<dubbo:reference id="barService" interface="com.foo.BarService" version="2.0.0" />
如果不需要区分版本,可以按照以下的方式配置 [1]:
<dubbo:reference id="barService" interface="com.foo.BarService" version="*" />
6. dubbo 本地存根
http://dubbo.apache.org/zh-cn/docs/user/demos/local-stub.html
远程服务后,客户端通常只剩下接口,而实现全在服务器端,但提供方有些时候想在客户端也执行部分逻辑,比如:做 ThreadLocal 缓存,提前验证参数,调用失败后伪造容错数据等等,此时就需要在 API 中带上 Stub,客户端生成 Proxy 实例,会把 Proxy 通过构造函数传给 Stub [1],然后把 Stub 暴露给用户,Stub 可以决定要不要去调 Proxy。
在 spring 配置文件中按以下方式配置:
<dubbo:service interface="com.foo.BarService" stub="true" />
或
<dubbo:service interface="com.foo.BarService" stub="com.foo.BarServiceStub" />
//提供 Stub 的实现 [2]:package com.foo;
public class BarServiceStub implements BarService { private final BarService barService;// 构造函数传入真正的远程代理对象public (BarService barService) {this.barService = barService;}public String sayHello(String name) {// 此代码在客户端执行, 你可以在客户端做ThreadLocal本地缓存,或预先验证参数是否合法,等等try {return barService.sayHello(name);} catch (Exception e) {// 你可以容错,可以做任何AOP拦截事项return "容错数据";}}
}
**6. dubbo 与SpringBoot **
一些属性比如timeout retries 之类的 直接在Service/Refrence 注解里边配置属性就行了
@Service(timeout=3000 ,retries= 10) // 为了暴露服务 这个service不是spring的 是dubbo家的@Componentpublic class UserServiceImpl implements UserService {public List<UserAddress> getUserAddressList(String userId) {UserAddress address1 = new UserAddress(1, "沙河高教園", "1", "李老师", "010-88888888", "Y");UserAddress address2 = new UserAddress(2, "沙河", "1", "王老师", "010-66666666", "N");return Arrays.asList(address1, address2);}}
注解没办法作用到method上 :
方法级别配置1:
保留buddo的配置文件 然后导入配置 也就不用注解什么的了
@ImportResource("classpath:provider.xml")
@SpringBootApplication
public class BootUserServiceProviderApplication {public static void main(String[] args) {SpringApplication.run(BootUserServiceProviderApplication.class, args);}}
方法级别配置2:
使用注解API方式 自定义confuguration 每一个标签都有对应的config
package com.test.mall.config;import java.util.ArrayList;
import java.util.List;import org.apache.dubbo.config.ApplicationConfig;
import org.apache.dubbo.config.MethodConfig;
import org.apache.dubbo.config.ProtocolConfig;
import org.apache.dubbo.config.RegistryConfig;
import org.apache.dubbo.config.ServiceConfig;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;import com.test.mall.service.UserService;@Configuration
public class MyDubboConfig {//dubbo.application.name=user-service-provider@Bean public ApplicationConfig applicationConfig() {ApplicationConfig applicationConfig = new ApplicationConfig();applicationConfig.setName("boot-user-service-provider");return applicationConfig;}//<dubbo:registry protocol="zookeeper" address="127.0.0.1:2181"></dubbo:registry>//dubbo.registry.address=127.0.0.1:2181 dubbo.registry.protocol=zookeeper@Beanpublic RegistryConfig registryConfig() {RegistryConfig registryConfig = new RegistryConfig();registryConfig.setProtocol("zookeeper");registryConfig.setAddress("127.0.0.1:2181");return registryConfig;}//<dubbo:protocol name="dubbo" port="20882"></dubbo:protocol>//dubbo.protocol.name=dubbo dubbo.protocol.port=20880@Beanpublic ProtocolConfig protocolConfig() {ProtocolConfig protocolConfig = new ProtocolConfig();protocolConfig.setName("dubbo");protocolConfig.setPort(20882);return protocolConfig;}/***<dubbo:service interface="com.test.mall.service.UserService" ref="userServiceImpl01" timeout="1000" version="1.0.0"><dubbo:method name="getUserAddressList" timeout="1000"></dubbo:method></dubbo:service>@Service注解*/@Beanpublic ServiceConfig<UserService> userServiceConfig(UserService userService){ServiceConfig<UserService> serviceConfig = new ServiceConfig<>();
// serviceConfig.setInterface("com.test.mall.service.UserService");serviceConfig.setInterface(UserService.class);serviceConfig.setRef(userService);serviceConfig.setVersion("1.0.0");//配置每一个method的信息 MethodConfig methodConfig = new MethodConfig();methodConfig.setName("getUserAddressList");methodConfig.setTimeout(1000);//将method的设置关联到service配置中List<MethodConfig> methods = new ArrayList<>();methods.add(methodConfig);serviceConfig.setMethods(methods);//ProviderConfig//MonitorConfigreturn serviceConfig;}
}
@EnableDubbo(scanBasePackages = "com.test.mall")
public class BootUserServiceProviderApplication {public static void main(String[] args) {SpringApplication.run(BootUserServiceProviderApplication.class, args);}
}
Dubbo-04 20190317相关推荐
- mtb9_Polygon_Great Circle Distance_Heatmap_Dual axes layering map_Swap sheet_COLLECT spatial shp WMS
When I conduct[kənˈdʌkt]进行,举办 Tableau classes and workshops for people who are using Tableau for the ...
- 【SpringCloudAlibaba学习 04】整合Dubbo(实现数据消费者服务调用数据生产者服务)
文章目录 引言 1.[数据生产者工程]创建service-api子工程 1.1.[数据生产者服务]创建user-service-api服务 目录结构 UserService服务接口 UserServi ...
- 100道 Dubbo面试题及答案(2021最新)
Redis面试题及答案[2021最新版]Dubbo面试题大全(2021版),发现网上很多Dubbo面试题都没有答案,所以花了很长时间搜集,小编觉得挺不错的,现在分享给大家,也给大家做个参考.一起跟随小 ...
- Dubbo常见面试题及答案汇总1000道(春招+秋招+社招)
Dubbo面试题以及答案整理[最新版]Dubbo高级面试题大全(2021版),发现网上很多Dubbo面试题都没有答案,所以花了很长时间搜集,本套Dubbo面试题大全,汇总了大量经典的Dubbo程序员面 ...
- 一次Dubbo拥堵的分析
点击上方"方志朋",选择"设为星标" 回复"666"获取新整理的面试文章 作者:nxlhero https://blog.51cto.com ...
- 突发流量引发的Dubbo拥堵,该怎么办?
点击上方蓝色"程序猿DD",选择"设为星标" 回复"资源"获取独家整理的学习资料! 作者 | nxlhero 来源 | https://bl ...
- php dubbo 接口测试工具,dubbo服务自动化测试搭建
java实现dubbo的消费者服务编写:ruby实现消费者服务的接口测试:通过消费者间接测试dubbo服务接口的逻辑 内容包括:dubbo服务本地调用环境搭建,dubbo服务启动,消费者部署,脚本编写 ...
- Dubbo入门介绍---搭建一个最简单的Demo框架
Dubbo入门---搭建一个最简单的Demo框架 置顶 2017年04月17日 19:10:44 是Guava不是瓜娃 阅读数:320947 标签: dubbo zookeeper 更多 个人分类: ...
- dubbo consumer 端口_基于Springboot+Dubbo+Nacos 注解方式实现微服务调用
今天跟大家分享基于Springboot+Dubbo+Nacos 注解方式实现微服务调用的知识. 1 项目结构 |-- spring-boot-dubbo-demo (父级工程) |-- spring- ...
- dubbo-go 白话文 | 从零搭建 dubbogo 和 dubbo 的简单用例
作者 | 铁城 dubbo-go 社区 committer 来源|阿里巴巴云原生公众号 本文将手把手教你使用 dubbogo 调用 dubbogo 或 dubbo 提供的服务提供方. 前言 本文基于 ...
最新文章
- 贪心 ---- Educational Codeforces Round 90 (Rated for Div. 2)E. Sum of Digits[数位贡献+思维题+贪心]
- Cisco/H3C交换机配置与管理完全手册(第2版)卓越网正式到货
- HDU-1170的解题报告
- 配置tomcat的环境变量
- python re match groups_【原创】如何治疗使用python中re模块group、groups与findall分组匹配后产生的“眩晕反应”...
- 《数据库原理与应用》(第三版)第13章 安全管理 基础 习题参考答案
- MC新手入门(十三)------ 添加游戏角色
- html菜鸟ruby,ruby的基础语法
- Java 8实战-Stream 查找替换 VS 归约reduce
- H3C AP当无线路由器静态IP上网配置
- java十二星座 (快来测试你是什么星座吧)
- 硬件工程师岗位应聘为什么都要求精通CC++呢,这其中有什么说法吗
- linux三种用户界面,Linux的图形用户界面-你会选择哪个?
- 10015---SpringMVC--自定义视图
- STM32开发_利用SPI协议读写SD卡、介绍SD卡SPI时序
- DisGeNET的初步认识
- Oceanbase和TiDB粗浅对比之 - 执行计划
- 太酷了,手把手教你用 Python 绘制桑基图
- 【C语言】两个变量值的交换——指针
- 名果黑的Mac装机必备
热门文章
- spring redis executePipelined
- C语言基础:折半查找
- HDU 1808 Halloween treats (鸽巢原理)(数学)
- 过去 10 年,阿里在开源圈做了什么?
- 自适应控制---模型参考自适应控制(一)基于局部参数最优化的设计方法(MIT方案)
- matlab怎么开始使用方法,matlab怎么使用,matlab基本使用方法
- 人工智能开源项目推荐
- docker容器虚拟技术
- html标签的下一级遍历,jquery属性,遍历,HTML操作方法详解
- 侯捷C++视频笔记——C++面向对象高级编程(上)