dubbo系列（一）——dubbo简介和dubbo+spring+zookeeper配置整合

喜欢ヅ旅行 2022-06-17 13:00 244阅读 0赞

## 简介 ##

Dubbo是一个分布式服务框架，可以在java项目中整合使用，dubbo推荐的注册中心是wookeeper。

在dubbo流行之前，分布式框架实现是通过RMI或Hessian等工具，简单的暴露和引用远程服务，通过配置服务的URL地址进行调用，通过F5等硬件进行负载均衡。

### 架构 ###

![Center][]

节点角色说明：

*  **Provider:** 暴露服务的服务提供方。
 *  **Consumer:** 调用远程服务的服务消费方。
 *  **Registry:** 服务注册与发现的注册中心。
 *  **Monitor:** 统计服务的调用次调和调用时间的监控中心。
 *  **Container:** 服务运行容器。

调用关系说明：

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

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

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

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

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

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

## dubbo、spring、zookeeper整合 ##

### 普通方式 ###

#### Provider(提供者) ####

1.      新建一个dynamic web项目sdz，作为dubbo的provider提供者。

项目结构

![Center 1][]

项目jar包

![Center 2][]

2.      提供者代码IDemoProvider.java和DemoProviderImpl.java。

IDemoProvider.java

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

DemoProviderImpl.java

public class DemoProviderImpl implements IDemoProvider {
    	public String sayHello(String name) {
    		return "hello " + name;
    	}
    }

3.  dubbo配置文件dubbo-provider.xml

<?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="hello-world-app" />
        
        
        <dubbo:registry protocol="zookeeper" address="127.0.0.1:2181,127.0.0.1:2182,127.0.0.1:2183"
         file="/ouput/dubbo.cache" check="false" />
        
        
        <dubbo:protocol name="dubbo" port="20880" />
        
        
        <dubbo:service interface="com.lc.provider.IDemoProvider" ref="demoProvider" />
        
        <bean id="demoProvider" class="com.lc.service.DemoProviderImpl"/>
    </beans>

4.      web.xml配置

<?xml version="1.0" encoding="UTF-8"?>
    <web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://java.sun.com/xml/ns/javaee" xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_3_0.xsd" id="WebApp_ID" version="3.0">
      <display-name>spring、dubbo、zookeeper框架整合</display-name>
      
      <context-param>
      	<param-name>contextConfigLocation</param-name>
      	<param-value>WEB-INF/dubbo-provider.xml</param-value>
      </context-param>
      
      <listener>
      	<listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
      </listener>
      
      
      <filter>
      	<filter-name>CharacterEncodingFilter</filter-name>
      	<filter-class>org.springframework.web.filter.CharacterEncodingFilter</filter-class>
      	<init-param>
      		<param-name>encoding</param-name>
      		<param-value>UTF-8</param-value>
      	</init-param>
      	<init-param>
      		<param-name>forceEncoding</param-name>
      		<param-value>true</param-value>
      	</init-param>
      </filter>
      <filter-mapping>
      	<filter-name>CharacterEncodingFilter</filter-name>
      	<url-pattern>/*</url-pattern>
      </filter-mapping>
      <welcome-file-list>
        <welcome-file>index.jsp</welcome-file>
      </welcome-file-list>
    </web-app>

#### Consumer(消费者) ####

1.      将IDemoProvider.class接口打成jar包，可以使用jar cvf provider.jar com，也可以使用eclpse的打包功能，右击包名，点击export。包名provider.jar。

2.      新建项目（web、普通都可以）sdz-web，导入provider.jar，导入dubbo提供方所有的jar包。

![Center 3][]

3.      dubbo消费方配置文件dubbo-custom.xml

<?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-service-consumer" />
    
        
        <dubbo:registry protocol="zookeeper" address="127.0.0.1:2181,127.0.0.1:2182,127.0.0.1:2183"
    		check="false" file="${dubbo.cache.dir}/dubbo.cache" />	
        
        <dubbo:reference id="demoService" interface="com.lc.provider.IDemoProvider"/>
    </beans>

4.      web.xml配置

5.      消费者代码。

DemoService.java

public class DemoService {
    	private IDemoProvider iDemoProvider;
    	public DemoService(IDemoProvider iDemoProvider) {
    		this.iDemoProvider = iDemoProvider;
    	}
    	public String sayHello(String name) {
    		return iDemoProvider.sayHello(name);
    	}
    }

TestProvider.java

public class TestProvider {
    	public static void main(String[] args) {
    		ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("file:F:/workspace1.8/sdz-web/WebContent/WEB-INF/dubbo-custom.xml");
    		context.start();
    		IDemoProvider provider = (IDemoProvider)context.getBean("demoService"); 
    		DemoService service = new DemoService(provider);
    		System.out.println(service.sayHello("张三"));
    	}
    }

运行结果：

![Center 4][]

参考资料

\[1\].dubbo.io

[Center]: /images/20220617/8095ada4b7dd4020885832513a721731.png
[Center 1]: /images/20220617/401248526f804c67a79b72b01dd4b4c9.png
[Center 2]: /images/20220617/d465bde244f94e4a87a9f7b7455ce324.png
[Center 3]: /images/20220617/dfebe21ec3a748b3963039a012787266.png
[Center 4]: /images/20220617/f24898905e784a92aa4b0f87035c3a98.png