A. 调用bbo服务时事务配置在哪
bbo实现了分布式远程调用框架，多运行节点既能提高可靠性，又能提升负载能力。bbo配置主要有注册中心（推荐zookeeper或redis）、提供者provider、消费者consumer，注册中心是第三方实现，所以主要配置好服务提供者和消费者就可以了。实际上服务接口和实现都是需要我们自己设计和实现的，bbo做的事情就是将服务实现发布到注册中心，然后消费者从注册中心订阅服务接口，之后对接口的调用就由bbo调度提供者去执行并返回结果。以下配置都有源码，见右侧“免费资源”。提供者provider的配置：提供者是独立运行的节点，可以多实例运行，将服务注册到注册中心必须要有application name，注册中心配置zookeeper，协议bbo，超时6秒失败不重试，提供者加载repository和service层bean，然后发布接口service。<bbo:application name="ite-provider" /><bbo:registry address="zookeeper://127.0.0.1:2181"/><bbo:protocol name="bbo" port="20880" /><bbo:provider timeout="6000" retries="0"/><import resource="classpath:cache.xml"/><import resource="classpath:ite-repository.xml"/><import resource="classpath:ite-service.xml"/><import resource="classpath:ite-provider.xml"/>ite-provider.xml，ref引用的bean是ite-service.xml已经定义好的接口实现，bbo:service就是把接口实现发布到注册中心<bbo:service ref="codeListService" interface="com.itecheast.ite.domain.service.CodeListService" /><bbo:service ref="idService" interface="com.itecheast.ite.domain.service.IdService" /><bbo:service ref="passwordService" interface="com.itecheast.ite.domain.service.PasswordService" /><bbo:service ref="rolePermissionService" interface="com.itecheast.ite.domain.service.RolePermissionService" />provider是可以独立运行的，bbo.jar里面有assembly目录，运行mvn assembly:directory就可以生成能直接运行的provider目录assembly.xml内容，可以切换dir或tar.gz两种格式<assembly> <id>assembly</id> <formats> <!– <format>tar.gz</format> –> <format>dir</format> </formats> <includeBaseDirectory>true</includeBaseDirectory> <fileSets> <fileSet> <directory>src/main/assembly/bin</directory> <outputDirectory>bin</outputDirectory> <fileMode>0755</fileMode> </fileSet> <fileSet> <directory>src/main/assembly/conf</directory> <outputDirectory>conf</outputDirectory> <fileMode>0644</fileMode> </fileSet> <fileSet> <directory>src/test/resources</directory> <outputDirectory>conf</outputDirectory> <fileMode>0644</fileMode> </fileSet> </fileSets> <dependencySets> <dependencySet> <outputDirectory>lib</outputDirectory> </dependencySet> </dependencySets></assembly>bbo.properties，运行start.bat或start.sh时，将从属性文件读取bbo配置信息，provider节点可以多处复制并运行。bbo.container=log4j,springbbo.application.name=ite-providerbbo.registry.address=zookeeper://127.0.0.1:2181bbo.monitor.protocol=registrybbo.protocol.name=bbobbo.protocol.port=20880bbo.spring.config=provider.xmlbbo.log4j.file=logs/ite-provider.logbbo.log4j.level=WARN消费者consumer的配置，使用bbo:reference订阅注册中心里的服务即可，然后就可以@Autowired注入服务接口了。<bbo:application name="ite-consumer" /><bbo:registry address="zookeeper://127.0.0.1:2181"/><bbo:reference id="codeListService" interface="com.itecheast.ite.domain.service.CodeListService" /><bbo:reference id="idService" interface="com.itecheast.ite.domain.service.IdService" /><bbo:reference id="passwordService" interface="com.itecheast.ite.domain.service.PasswordService" /><bbo:reference id="rolePermissionService" interface="com.itecheast.ite.domain.service.RolePermissionService" />如果前端项目是一个消费者，就可以在web.xml里直接加载consumer.xml订阅服务了。<listener><listener-class>org.springframework.web.context.ContextLoaderListener</listener-class></listener><context-param> <param-name>contextConfigLocation</param-name> <param-value>classpath:consumer.xml,classpath:cache.xml,classpath:shiro.xml,classpath:front.xml</param-value></context-param>实际上本地调试开发时，可以不必启用分布式配置，只需要更改web.xml即可，所有的服务都已经是配置好了的。<listener><listener-class>org.springframework.web.context.ContextLoaderListener</listener-class></listener><context-param> <param-name>contextConfigLocation</param-name> <param-value>classpath:ite-repository.xml,classpath:ite-service.xml,classpath:cache.xml,classpath:shiro.xml,classpath:front.xml</param-value></context-param>zookeeper的配置很简单，wget http://tool.xlongwei.com/softwares/zookeeper-3.4.6.tar.gztar -zxvf zookeeper-3.4.6.tar.gzcd zookeeper-3.4.6/confcp zoo_sample.cfg zoo.cfgvi zoo.cfg #配置zookeeper参数单机配置（集群配置待研究）tickTime=2000initLimit=10syncLimit=5dataDir=/home/bbo/zookeeper-3.3.3/dataclientPort=2181运行或停止zookeepersh zkServer.sh start | stop
B. Dubbo简介
Dubbo是Alibaba开源的分布式服务框架，它按照分层的方式来架构，使用这种方式可以使各层解耦。 Dubbo在调用远程的服务的时候再本地有一个接口，就想调用本地方法一样去调用，底层实现好参数传输和远程服务运行结果传回之后的返回。 Dubbo的特点： （1）它主要使用高效的网络框架和序列化框架，让分布式服务之间调用效率更高。 （2）采用注册中心管理众多的服务接口地址，当你想调用服务的时候只需要跟注册中心询问即可，不像使用WebService一样每个服务都得记录好接口调用方式。 （3）监控中心时实现服务方和调用方之间运行状态的监控，还能控制服务的优先级、权限、权重、上下线等，让整个庞大的分布式服务系统的维护和治理比较方便。 （4）高可用，如果有服务挂了，注册中心就会从服务列表去掉该节点，客户端会像注册中心请求另一台可用的服务节点重新调用。同时注册中心也能实现高可用（ZooKeeper）。 （5）负载均衡，采用软负载均衡算法实现对多个相同服务的节点的请求负载均衡。 Dubbo需要四大基本组件：Rigistry,Monitor,Provider,Consumer。1、监控中心的配置文件-bbo.properties文件 （1）容器，监控中心是在jetty和spring环境下运行，依赖于注册中心，日志系统是log4j bbo.container = log4j,spring,registry,jetty （2）监控服务的名称，监控系统对整个Dubbo服务系统来说也是一个服务 bbo.application.name = simple-monitor （3）服务的所有者，这是Dubbbo的服务的功能，可以指定服务的负责人 bbo.application.owner = coselding （4）注册中心的地址，配置后监控中心就能通过注册中心获取当前可用的服务列表及其状态，在页面向你汇报Dubbo中的服务运行情况。 bbo.registr.address = multicast://{ip}:{port} //广播 bbo.registr.address = zookeeper://{ip}:{port} //zookeper bbo.registr.address = redis://{ip}:{port} //redis bbo.registr.address = bbo://{ip}:{port} //bbo （5）bbo协议端口号 bbo.protocol.port = 7070 （6）jetty工作端口号 bbo.jetty.port = 8082 （7）工作目录，用于存放监控中心的数据 bbo.jetty.directory = ${user.home}/monitor （8）监控中心报表存放目录 bbo.charts.directory=${bbo.jetty.directory}/charts （9）监控中心数据资料目录 bbo.statistics.directory=${user.home}/monitor/statistics （10）监控中心日志文件路径 bbo.log4j.file=logs/bbo-monitor-simple.log （11）监控中心日志记录级别 bbo.log4j.level=WARN 2、Dubbo提供负载均衡方式 （1）Random，随机，按权重配置随机概率，调用量越大分布越均匀，默认方式。 （2）RounRobin，轮询，按权重设置轮询比例，如果存在比较慢的机器容易在这台机器上请求阻塞较多。 （3）LeastActive，最少活跃调用数，不支持权重，只能根据自动识别的活跃数分配，不能灵活调配。 （4）ConsistenHash，一致性hash，对相同参数的请求路由到一个服务提供者上，如果有类似灰度发布需求可采用。 3、Dubbo过滤器 Dubbo初始化过程加载ClassPath下的META-INF/bbo/internal/，META-INF/bbo/，META-INF/services/三个路径下的com.alibaba.bbo.rpc.Filter文件。文件内容： Name = FullClassName,这些类必须实现Filter接口。自定义Filter类： 配置文件在配置过滤器，consumer.xml中：Dubbo对过滤器的加载过程： 先加载三个路径下的com.alibaba.bbo.rpc.Filter文件里面的键值对，key为过滤器名称，value为过滤器的类的全限定名(这个类必须实现Dubbo中的Filter接口)。 自定义的类中@Active注解是过滤器设定的全局基本属性。 Spring在加载consumer.xml文件时，通过 <bbo:consumer filter="xxx" id = "xxx" retrries = "0">这个配置指定消费者端要加载的过滤器，通过filter属性指定过滤器名称。 @Activate注解-自动激活，group属性是表示匹配了对应的角色才被加载，value表示表明过滤条件，不写则表示所有条件都会被加载，写了则只有bbo URL中包含该参数名且参数值不为空才被加载，这个参数会以bbo协议的一个参数K-V对传到Provider。 4、Dubbo的Provider配置 5、Dubbo的Consumer配置 1、Dubbo是什么？ Dubbo是阿里巴巴开源的基于Java的高性能RPC分布式框架。 2、为什么使用Dubbo？ 很多公司都在使用，经过很多线上的考验，内部使用了Netty，Zookeeper，保证了高性能可用性。 使用Dubbo可以将核心业务抽取出来，作为独立的服务，逐渐形成稳定的服务中心，可以提高业务复用灵活性扩展，使前端应用能快速的响应对边的市场需求。分布式架构可以承受更大规模的并发流量。 Dubbo的服务治理图： 3、Dubbo和Spring Cloud的区别 两个没有关联，但是非要说区别，有如下几点： （1）通信方式不同，Dubbo使用RPC通信，Spring Cloud使用HTTP Restful方式 （2）组成部分不同4、Dubbo支持的协议 bbo:// （推荐）；rmi:// ；hessian:// ；http:// ；webservice:// ；thrift:// ；memcached:// ；redis:// ；rest:// 。 5、Dubbo需要容器吗？ 不需要，如果硬要容器的话，会增加复杂性，同时也浪费资源。 6、Dubbo内置的服务容器 Spring Container；Jetty Container；Log4j Container。 7、Dubbo中节点角色 Register，Monitor，Provider，Consumer，Container(服务运行的容器)。 8、Dubbo的服务注册和发现的流程图 9、Dubbo的注册中心 默认使用Zookeper作为注册中心，还有Redis，Multicast，bbo注册中心。 10、Dubbo的配置方式 Spring配置方式和Java API配置方式 11、Dubbo的核心配置 （1）bbo:service 服务配置 （2）bbo:referece 引用配置 （3）bbo:protocol 协议配置 （4）bbo:application 应用配置 （5）bbo:registry 注册中心配置 （6）bbo:monitor 监控中心配置 （7）bbo:provider 提供方配置 （8）bbo:consumer 消费方配置 （9）bbo:method 方法配置 （10）bbo:argument 参数配置 12、在Provider 节点上可以配置Consumer端的属性有哪些？ （1）timeout：方法调用超时 （2）retries：失败重试次数，默认是2次 （3）loadbalance：负载均衡算法，默认随机 （4）actives消费者端，最大并发调用控制 13、Dubbo启动时如果依赖的服务不可用会怎样 Dubbo缺省会在启动时检查依赖的服务是否可用，不可用时会抛出异常，阻止Spring初始化完成。默认check ="true"。 14、Dubbo序列化框架 推荐使用Hessian序列化，还有Dubbo，FastJson，Java自带序列化。 15、Dubbo的通信框架 默认使用Netty框架，另外也提供了Mina，Grizzly。 16、Dubbo集群容错方案 （1）Failover Cluster，失败自动切换，自动重试其他服务器。 （2）Failfast Cluster，快速失败，立即报错，只发起一次调用。 （3）Failsafe Cluster，失败安全，出现异常时，直接忽略。 （4）Failback Cluster，失败自动恢复，记录失败请求，定时重发。 （5）Forking Cluster，并行调用多个服务器，只要一个返回成功即可。 （6）Broadcast Cluster，广播逐个调用所有提供者，任意一个报错则报错。 17、Dubbo的负载均衡策略 （1）Random LoadBalance，随机，按权重设置随机概率，默认。 （2）RoundRobin LoadBalace，轮询，按公约后的权重设置轮训比例。 （3）LeastActive LoadBalace，最少活跃调用数，相同活跃数的随机。 （4）ConsistenHash LoadBalance，一致性hash，相同参数的请求总是发到用一个服务器。 18、指定某一个服务 可以配置环境点对点直连，绕过注册中心，将以服务接口为单位，忽略注册中心的提供者列表。 <bbo:reference interface="com.weidian.bbo.IMyDemo" version="1.0" id="myDemo" url="bbo://127.0.0.1:20880/"></bbo:reference> 19、Dubbo多协议 Dubbo允许配置多协议，在不同服务器上支持不同协议，或者同一服务支持多种协议。 20、当一个服务有多种实现时怎么做？ 当一个接口有多种是现实，可以用group属性来分组，服务提供方和消费方都指定同一个group即可。 21、兼容旧版本 使用版本号过度，多个不同版本的服务注册到注册中心，版本号不同的服务相互间不引用。 22、Dubbo可以缓存吗？ Dubbo提供声明式缓存，用于加速热门数据的访问速度，以减少用户加缓存的工作量。 23、Dubbo服务之间的调用时阻塞的吗？ 默认是同步等待结果阻塞的，支持异步调用。Dubbo是基于NIO的非阻塞实现并行调用的，客户端不需要启动多线程即可完成并行调用多个远程服务，相对多线程开销较小，异步调用会返回一个Future对象。 24、Dubbo不支持分布式事务 25、Dubbo必须依赖的包 Dubbo必须依赖JDK，其他为可选。 26、Dubbo使用过程中的问题 Dubbo的设计目的是为了满足高并发小数据量的rpc请求，在大数据量下性能表现不是很好，建议使用rmi或http协议。 27、Dubbo的管理控制台的作用 路由规则，动态配置，服务降级，访问控制，权重调整，负载均衡。 28、Spring boot整合Dubbo （1）添加依赖 <!– https://mvnrepository.com/artifact/com.alibaba.boot/bbo-spring-boot-project –> <dependency> <groupId>com.alibaba.boot</groupId> <artifactId>bbo-spring-boot-starter</artifactId> <version>0.1.0</version> </dependency> <!– https://mvnrepository.com/artifact/com.101tec/zkclient –> <dependency> <groupId>com.101tec</groupId> <artifactId>zkclient</artifactId> <version>0.10</version> </dependency>（2）配置bbo ## Dubbo 服务提供者配置 spring.bbo.application.name=provider spring.bbo.registry.address=zookeeper://127.0.0.1:2181 spring.bbo.protocol.name=bbo spring.bbo.protocol.port=20880 spring.bbo.scan=org.spring.springboot.bbo ## Dubbo 服务消费者配置 spring.bbo.application.name=consumer spring.bbo.registry.address=zookeeper://127.0.0.1:2181 spring.bbo.scan=org.spring.springboot.bbo
C. bbo是如何启动的
已知，在项目启动过程中，我们会将bbo的配置文件写到spring的配置文件里，如下xml文件：
<bbo:application name="anyname_provider" /><!– 使用zookeeper注册中心暴露服务地址 –><bbo:registry address="zookeeper://127.0.0.1:2181" /><!– 用bbo协议在20880端口暴露服务 –><bbo:protocol name="bbo" port="20880" /><!– 声明需要暴露的服务接口 –><bbo:service interface="com.shxz130.provider.Provider"ref="demoService" />
从官方文档中，我们能看到如下：
启动过程.png
也就是说spring启动过程中，随着Spring在初始化过程中，碰到bbo命名的标签，如（<bbo:service>,<bbo:registry>）等标签，会由DubboNamespaceHandler类处理，具体原理见链接Spring自定义标签
DubboBeanDefinitionParser代码如下：
public class DubboNamespaceHandler extends NamespaceHandlerSupport { static {Version.checkDuplicate(DubboNamespaceHandler.class);} public void init() {registerBeanDefinitionParser("application", new DubboBeanDefinitionParser(ApplicationConfig.class, true));registerBeanDefinitionParser("mole", new DubboBeanDefinitionParser(MoleConfig.class, true));registerBeanDefinitionParser("registry", new DubboBeanDefinitionParser(RegistryConfig.class, true));registerBeanDefinitionParser("monitor", new DubboBeanDefinitionParser(MonitorConfig.class, true));registerBeanDefinitionParser("provider", new DubboBeanDefinitionParser(ProviderConfig.class, true));registerBeanDefinitionParser("consumer", new DubboBeanDefinitionParser(ConsumerConfig.class, true));registerBeanDefinitionParser("protocol", new DubboBeanDefinitionParser(ProtocolConfig.class, true));registerBeanDefinitionParser("service", new DubboBeanDefinitionParser(ServiceBean.class, true));registerBeanDefinitionParser("reference", new DubboBeanDefinitionParser(ReferenceBean.class, false));registerBeanDefinitionParser("annotation", new ());}}
遇到不同的标签，会由不同的Parser处理，这里重点看服务发布，这行代码：
registerBeanDefinitionParser("service", new DubboBeanDefinitionParser(ServiceBean.class, true));
也就是说，当Spring容器处理完<bbo:service>标签后，会在Spring容器中生成一个ServiceBean ，服务的发布也会在ServiceBean中完成。不妨看一下ServiceBean的定义：
public class ServiceBean<T> extends ServiceConfig<T> implements InitializingBean, DisposableBean, ApplicationContextAware, ApplicationListener<ContextRefreshedEvent>, BeanNameAware {}
该Bean实现了很多接口，关于InitializingBean，DisposableBean，ApplicationContextAware，BeanNameAware,这些接口的使用介绍如下链接：
InitializingBean&DisposableBean
BeanNameAware& ApplicationContextAware
而在Spring初始化完成Bean的组装，会调用InitializingBean的afterPropertiesSet方法，在Spring容器加载完成，会接收到事件ContextRefreshedEvent，调用ApplicationListener的onApplicationEvent方法。
在afterPropertiesSet中，和onApplicationEvent中，会调用export()，在export()中，会暴露bbo服务，具体区别在于是否配置了delay属性，是否延迟暴露，如果delay不为null，或者不为-1时，会在afterPropertiesSet中调用export()暴露bbo服务，如果为null,或者为-1时，会在Spring容器初始化完成，接收到ContextRefreshedEvent事件，调用onApplicationEvent，暴露bbo服务。
部分ServiceBean的代码如下：
public class ServiceBean<T> extends ServiceConfig<T> implements InitializingBean, DisposableBean, ApplicationContextAware, ApplicationListener<ContextRefreshedEvent>, BeanNameAware { //Spring容器初始化完成，调用public void onApplicationEvent(ContextRefreshedEvent event) { if (isDelay() && !isExported() && !isUnexported()) { if (logger.isInfoEnabled()) { logger.info("The service ready on spring started. service: " + getInterface()); } //暴露服务 export(); } } //判断是否延迟发布private boolean isDelay() { Integer delay = getDelay(); ProviderConfig provider = getProvider(); if (delay == null && provider != null) { delay = provider.getDelay(); } return supportedApplicationListener && (delay == null || delay == -1); } //当bean初始化完成调用public void afterPropertiesSet() throws Exception { //……此处省略10000行代码 if (!isDelay()) { //暴露服务 export(); } }}
在export()，暴露服务过程中，如果发现有delay属性，则延迟delay时间，暴露服务，如果没有，则直接暴露服务。
public synchronized void export() { //忽略若干行代码 if (delay != null && delay > 0) { //当delay不为null，且大于0时，延迟delay时间，暴露服务 delayExportExecutor.schele(new Runnable() { public void run() { //暴露服务 doExport(); } }, delay, TimeUnit.MILLISECONDS); } else { //直接暴露服务 doExport(); } }
而在doExport()中，验证参数，按照不同的Protocol，比如(bbo,injvm)暴露服务，在不同的zookeeper集群节点上注册自己的服务。
protected synchronized void doExport() { //忽略10000行代码 doExportUrls(); //忽略10000行代码 } private void doExportUrls() { List<URL> registryURLs = loadRegistries(true); for (ProtocolConfig protocolConfig : protocols) { //按照不同的Protocal暴露服务 doExportUrlsFor1Protocol(protocolConfig, registryURLs); } }
作者：一滴水的坚持链接：https://www.jianshu.com/p/7f3871492c71来源：简书简书著作权归作者所有，任何形式的转载都请联系作者获得授权并注明出处。
