dubbo框架的使用

ゝ一世哀愁。 2023-06-13 08:56 36阅读 0赞

# 一：什么是dubbo框架 #

Dubbo是一个分布式服务的框架，致力于提供高性能和透明化PRC远程服务调用方案，以及SOA服务治理方案。一句话来说dubbo就是远程服务调用的分布式框架

--------------------

# 二：dubbo作用： #

1.透明化的远程方法调用，就像调用本地方法一样调用远程方法，只需简单配置，没有任何API侵入。        
2.软负载均衡及容错机制，可在内网替代F5等硬件负载均衡器，降低成本，减少单点。  
3. 服务自动注册与发现，不再需要写死服务提供方地址，注册中心基于接口名查询服务提供者的IP地址，并且能够平滑添加或删除服务提供者。  
  
Dubbo采用全[spring][]配置方式，透明化接入应用，对应用没有任何API侵入，只需用Spring加载Dubbo的配置即可，Dubbo基于Spring的Schema扩展进行加载。

--------------------

# 三：dubbo的架构： #

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxNTgxMTU0_size_16_color_FFFFFF_t_70][]

1：provider：暴露服务的提供方。

2：服务注册与发现的注册中心。

3：Consumer服务发现，调用远程服务的服务消费方

4：Monitor: 统计服务的调用次调和调用时间的监控中心。

5：Container：服务运行的容器。

## 状态观测: ##

调用关系说明：

0 服务容器负责启动，加载，运行服务提供者。

1. 服务提供者在启动时，向注册中心注册自己提供的服务。

2. 服务消费者在启动时，向注册中心订阅自己所需的服务。

3. 注册中心返回服务提供者地址列表给消费者，如果有变更，注册中心将基于长连接推送变更数据给消费者。

4. 服务消费者，从提供者地址列表中，基于软负载均衡算法，选一台提供者进行调用，如果调用失败，再选另一台调用。

5. 服务消费者和提供者，在内存中累计调用次数和调用时间，定时每分钟发送一次统计数据到监控中心。

--------------------

# 案例（情景一：项目A远程调用项目B的ServiceImpl方法） #

### 一：项目发布端： ###

![20191115095410464.png][]

添加pom依赖（添加dubbo依赖、添加zkclient依赖--封装了zookeeper插件）

<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>
    	<groupId>dubbo-provider</groupId>
    	<artifactId>dubbo-provider</artifactId>
    	<version>0.0.1-SNAPSHOT</version>
    	<dependencies>
    		
    		<dependency>
    			<groupId>com.alibaba</groupId>
    			<artifactId>dubbo</artifactId>
    			<version>2.6.5</version>
    		</dependency>
    		
    		
    
    	
    	<dependency>
    	    <groupId>com.github.sgroschupf</groupId>
    	    <artifactId>zkclient</artifactId>
    	    <version>0.1</version>
    	</dependency>
    
    
    	</dependencies>
    </project>

配置applicion-dubbo.xml文件：

<?xml version="1.0" encoding="UTF-8"?>
    <beans xmlns="http://www.springframework.org/schema/beans"
    	xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
    	xmlns:context="http://www.springframework.org/schema/context"
    	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    	xsi:schemaLocation="                                               
                http://www.springframework.org/schema/beans    
                http://www.springframework.org/schema/beans/spring-beans.xsd 
                http://www.springframework.org/schema/context    
                http://www.springframework.org/schema/context/spring-context.xsd
                http://code.alibabatech.com/schema/dubbo
                http://code.alibabatech.com/schema/dubbo/dubbo.xsd      
              ">
    	
    	<context:component-scan base-package="com.bjsxt.service.impl"></context:component-scan>
    	
    	
    	<dubbo:application name="dubbo-provider"></dubbo:application>
    	
    	<dubbo:registry protocol="zookeeper" 
    		address="192.168.220.10:2181,192.168.220.10:2182,192.168.220.10:2183"
    		client="zkclient"></dubbo:registry>
    	
    	<dubbo:protocol name="dubbo" port="20880"></dubbo:protocol>
    	
    	<dubbo:service interface="com.bjsxt.service.UserService" ref="userServiceImpl"></dubbo:service>
    </beans>

serviceImpl实现类:

package com.bjsxt.service.impl;
    
    import org.springframework.stereotype.Service;
    
    import com.bjsxt.service.UserService;
    @Service
    public class UserServiceImpl implements UserService {
    
    	@Override
    	public String showName(String name) {
    		return "hi~" +name;
    	}
    
    }

Service接口：

package com.bjsxt.service;
    
    public interface UserService {
    	
    	public String showName(String name);
    }

服务发布：

package com.bjsxt.app;
    
    import java.io.IOException;
    
    import org.springframework.context.ApplicationContext;
    import org.springframework.context.support.ClassPathXmlApplicationContext;
    
    public class ProductorController {
    
    	public static void main(String[] args) {
    		ClassPathXmlApplicationContext applicationContext
    			=new ClassPathXmlApplicationContext("application-dubbo.xml");
    		applicationContext.start();
    		System.out.println("启动远程服务");
    		try {
    			System.in.read();
    		} catch (IOException e) {
    			// TODO Auto-generated catch block
    			e.printStackTrace();
    			
    		}
    
    	}
    
    }

### 服务发现端 ###

![20191115095907769.png][]

**添加pom依赖（dubbo依赖、zkclient依赖）**

<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>
    	<groupId>dubbo-cosumer</groupId>
    	<artifactId>dubbo-cosumer</artifactId>
    	<version>0.0.1-SNAPSHOT</version>
    
    	<dependencies>
    		
    		<dependency>
    			<groupId>com.alibaba</groupId>
    			<artifactId>dubbo</artifactId>
    			<version>2.6.5</version>
    		</dependency>
    
    		
    		
    		
    		<dependency>
    			<groupId>com.github.sgroschupf</groupId>
    			<artifactId>zkclient</artifactId>
    			<version>0.1</version>
    		</dependency>
    	</dependencies>
    </project>

配置application-cosumer.xml文件

<?xml version="1.0" encoding="UTF-8"?>
    <beans xmlns="http://www.springframework.org/schema/beans"
    	xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
    	xmlns:context="http://www.springframework.org/schema/context"
    	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    	xsi:schemaLocation="                                               
                http://www.springframework.org/schema/beans    
                http://www.springframework.org/schema/beans/spring-beans.xsd 
                http://www.springframework.org/schema/context    
                http://www.springframework.org/schema/context/spring-context.xsd
                http://code.alibabatech.com/schema/dubbo
                http://code.alibabatech.com/schema/dubbo/dubbo.xsd      
              ">
    	<dubbo:application name="dubbo-cosumer"></dubbo:application>
    
    	<dubbo:registry protocol="zookeeper" 
    		address="192.168.220.10:2181,192.168.220.10:2182,192.168.220.10:2183"
    		client="zkclient"></dubbo:registry>
    	
    	<dubbo:reference interface="com.bjsxt.service.UserService" id="userServiceProxy"/>
    </beans>

Service接口（与服务注册端接口保持一致）

package com.bjsxt.service;
    
    public interface UserService {
    	
    	public String showName(String name);
    }

服务发现：

package com.bjsxt.app;
    
    import java.io.IOException;
    
    import org.springframework.context.support.ClassPathXmlApplicationContext;
    
    import com.bjsxt.service.UserService;
    
    public class App {
    	public static void main(String[] args) {
    		ClassPathXmlApplicationContext as = new ClassPathXmlApplicationContext(
    				"application-cosumer.xml");
    		//启动容器
    		as.start();
    		UserService userService
    			=(UserService)as.getBean("userServiceProxy");
    		System.out.println(userService.showName("fucking"));;
    		try {
    			System.in.read();
    		} catch (IOException e) {
    			// TODO Auto-generated catch block
    			e.printStackTrace();
    		}
    		
    	}
    }

**结果:服务发现端会调用接口，然后通过dubbo注册与发现中心，产生一个代理类，会调用服务发布端的service接口的实现类（服务发布端暴露的类），就可以使用其中的方法。**

[spring]: http://lib.csdn.net/base/javaee
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxNTgxMTU0_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20191115093225680.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxNTgxMTU0,size_16,color_FFFFFF,t_70
[20191115095410464.png]: https://img-blog.csdnimg.cn/20191115095410464.png
[20191115095907769.png]: https://img-blog.csdnimg.cn/20191115095907769.png