dubbo的使用（二）

节点说明：

Provider：暴露服务的服务提供方
Container：服务运行容器
Registry：服务注册于发现的注册中心
Consumer：调用注册于发现的注册中心
Monitor：统计服务的调用次数和调用的监控中心

关系说明：

0：服务容器负责启动，加载，运行服务提供者
1：服务提供者在启动的时候，向注册中心注册自己提供的服务
2：服务消费者在启动的时候，想注册中心订阅自己所需要的服务
3：注册中心返回服务提供者的地址列表给消费者，如果有变更，注册中心将基于长连接推送变更的数据给消费者
4：服务消费方，从提供者地址列表中，基于软负载的均衡算法，选一台提供者进行调用，如果调用失败，再选另一台调用
5：服务消费者和提供者，在呢哦村中累计调用次数和调用的时间，定时每分钟发送一个统计数据到监控中心

连通性：

注册中心负责服务地址的注册于查找，相当于目录服务，服务提供者和消费者只在启动的时候于注册中心交互，注册中心不转发请求，压力较小。

监控中心负责统计各服务调用的次数，调用的时间等，统计先在内存汇总后每分钟发送一次到监控中心服务器，并以报表展示

服务提供者想注册中心注册其提供的服务，并汇报调用时间到监控中心，此时间不包含网络开销

服务消费方在注册中心获取服务提供者地址列表，并根据负载短发直接调用服务提供者，同时汇报调用时间到监控中心，此时间包含网络开销的时间

注册中心，服务提供者，服务消费者三者之间均属于长连接，监控中心除外

注册中心通过长连接感知服务提供者的存在，服务提供者宕机，注册中心将立即推送事件通知消费者

注册中心和监控中心全部宕机，不影响已运行的提供者和消费者，消费者在本地缓存了提供者列表

注册中心和监控中心都是可选的，服务消费者可以直姐连接到服务提供者

健壮性：

监控中心宕机后不影响使用，只是丢失部分采样数据
数据库宕机后，注册中心仍能通过缓存提供服务列表查询，但不能注册新的服务
注册中心对等集群，任意一台宕机后，将自动切换到另一台
注册中心全部宕机后，服务提供者和服务消费者仍能通过本地缓存通信
服务提供者无状态，任意一台宕机后，不影响使用
服务提供者全部宕机后，服务消费者应用将无法使用，并无限次重连等待服务提供者恢复（可以设置重试连接的次数）

伸缩性：

注册中心为对等集群，可动态增加机器部署实例，所有客户端将自动发现新的注册中心
服务提供者无状态，可动态增加机器部署的实例，注册中心将推送新的服务信息给消费者

当zookeeper宕机后，dubbo的消费者也可以访问生产者，因为项目在启动的时候，回去主动拉取生产者的地址端口等数据，每次消费者应用访问的时候首先是从本地址的缓存中读取。

服务方配置：可以引入服务和发布服务

流程：首先服务名称- --- >服务发布的地址--- > 服务的端口 ---> 使用的协议 --- > 提供的服务的版本号，协议 -- > 依赖的版本号，连接的次数，超时的时间，-- > 引入的服务(可选) -- > 提供的服务（可选）

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
    xsi:schemaLocation="http://www.springframework.org/schema/beans
        http://www.springframework.org/schema/beans/spring-beans.xsd
        http://code.alibabatech.com/schema/dubbo
        http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
        
    <dubbo:application name="${dubbo.name}" />
	<dubbo:registry protocol="zookeeper" address="${dubbo.url}" />
	
	<dubbo:protocol name="dubbo" port="-1" />
	<!-- rest协议 -->
    <dubbo:protocol name="rest" server="servlet" port="${rest.port}" contextpath="${rest.contextpath}"/>
    <!-- 该标签为<dubbo:service>和<dubbo:protocol>标签的缺省值设置
      retries               ==> 服务调用超时时自动重试的次数
      timeout               = => 服务超时时间（单位：毫秒）
    -->
    <dubbo:provider retries="0" timeout="20000" protocol="dubbo" version="${dubbo.version1}" />
   	<!-- 该标签为<dubbo:reference>标签的缺省值设置
      retries               ==> 服务调用超时时自动重试的次数
      timeout               ==> 服务超时时间（单位：毫秒）
    -->
    <dubbo:consumer retries="0" timeout="10000" version="${dubbo.version}" />
	
	
	
	<dubbo:reference id="cbService" interface="com.strongit.nj.czyd.sim.service.inter.shipinfo.ICbService" />

</beans>

对外提供的服务

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
	xsi:schemaLocation="http://www.springframework.org/schema/beans
        http://www.springframework.org/schema/beans/spring-beans.xsd
        http://code.alibabatech.com/schema/dubbo
        http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
	
	<dubbo:service interface="com.strongit.nj.wjcz.ais.service.inter.BindingTransactionalService" protocol="dubbo" ref="bindingTransactionalServiceImpl" timeout="10000" />
		
	<dubbo:service interface="com.strongit.nj.wjcz.ais.service.inter.BindingQueryService" protocol="dubbo" ref="bindingQueryServiceImpl" timeout="10000" />
	
	<dubbo:service interface="com.strongit.nj.wjcz.rest.ILocationInfoService" protocol="rest" ref="locationInfoServiceImpl" timeout="5000" />
</beans>

消费方：消费不能自己提供服务，但是可以引入服务

流程：发布到注册中心的名称 ---> 注册中心的地址 ----- > 引入服务的地址 ---- > 引入相关的接口

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
    xsi:schemaLocation="http://www.springframework.org/schema/beans
        http://www.springframework.org/schema/beans/spring-beans.xsd
        http://code.alibabatech.com/schema/dubbo
        http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
	
	<!-- 提供方应用信息，用于计算依赖关系 -->
    <dubbo:application name="${appname}" />
	<!-- 注册中心地址 -->
    <dubbo:registry protocol="zookeeper" address="${dubbo.address}" timeout="300000"/>
	
    <!-- 该标签为<dubbo:reference>标签的缺省值设置
      retries               ==> 服务调用超时时自动重试的次数
      timeout               ==> 服务超时时间（单位：毫秒）
    -->
    <dubbo:consumer retries="0" timeout="100000" version="${dubbo.version}" />
    
		
	<dubbo:reference id="organiseService" interface="com.strongit.nj.czyd.bim.service.inter.organise.IOrgService" />

	<dubbo:reference id="yhService" interface="com.strongit.nj.czyd.bim.service.inter.user.IYhService" />

	<dubbo:reference id="permissionService" interface="com.strongit.nj.czyd.bim.service.inter.permission.IPermissionService" />

	<dubbo:reference id="uploadFileService"
					 interface="com.strongit.nj.czyd.bim.service.inter.uploadFile.IUploadFileService"/>
</beans>

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
    xsi:schemaLocation="http://www.springframework.org/schema/beans
        http://www.springframework.org/schema/beans/spring-beans.xsd
        http://code.alibabatech.com/schema/dubbo
        http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
        
	
	<dubbo:reference id="cbService" interface="com.strongit.nj.czyd.sim.service.inter.shipinfo.ICbService" />
	
	<dubbo:reference id="bindingTransactionalService" interface="com.strongit.nj.wjcz.ais.service.inter.BindingTransactionalService" />
		
	<dubbo:reference id="bindingQueryService" interface="com.strongit.nj.wjcz.ais.service.inter.BindingQueryService" />

	<dubbo:reference id="qyfxService" interface="com.strongit.nj.wjcz.qyfx.service.inter.IQyfxService" />
</beans>

dubbo的使用（二）

猜你喜欢