Dubbo 简单的应用Dubbo+Zookeeper+Spring整合

刺骨的言语ヽ痛彻心扉 2024-02-18 15:19 48阅读 0赞

##### 一、Zookeeper是什么？为何使用Zookeeper？ #####

Zookeeper是一个分布式的服务框架，是树型的目录服务的数据存储，能做到集群管理数据 ，这里能很好的作为Dubbo服务的注册中心。

Dubbo能与Zookeeper做到集群部署，当提供者出现断电等异常停机时，Zookeeper注册中心能自动删除提供者信息，当提供者重启时，能自动恢复注册数据，以及订阅请求

二、创建MAVEN项目

主要分三大模块：   
dubbo-api1 : 存放公共接口； 最终会打为jar包，供consumer和provider1引用。  
dubbo-provider1 : 提供远程服务； 包含api1接口的实现类，提供服务的实现逻辑。

dubbo-consumer :　调用远程服务；

2.1 dubbo-api1 maven

![Center][]

项目只有一个文件，是一个接口，他定义了统一的接口让provider1和consumer来引用：

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

之后打包jar！

2.2 dubbo-provider1 maven

![Center 1][]

项目只有两个类，一个是服务实现类UserServiceImpl

package com.hlx.provider;
    
    import java.text.SimpleDateFormat;
    import java.util.Date;
    
    import com.alibaba.dubbo.rpc.RpcContext;
    import com.hlx.service.UserService;
    
    
    /**
     * 实现业务接口
     * @author Administrator
     *
     */
    public class UserServiceImpl implements UserService {
    
    	public String sayHello(String arg0) {
    		System.out.println("["
    				+ new SimpleDateFormat("HH:mm:ss").format(new Date())
    				+ "] Hello " + arg0 + ", request from consumer: "
    				+ RpcContext.getContext().getRemoteAddress());
    		return "Hello " + arg0 + ", response form provider: "
    				+ RpcContext.getContext().getLocalAddress();
    	}
    
    }

Main测试

package com.hlx.provider;
    
    /**
     * 该类是dubbo框架提供，作用是启动dubbo服务，dubbo会在启动服务时，
     * 读取classpath下一个名为dubbo.properties文件的属性值
     * 
     * @author Administrator
     * 
     */
    public class Main {
    	public static void main(String[] args) {
    		com.alibaba.dubbo.container.Main.main(args);
    	}
    }

dubbo.properties文件配置：

dubbo.container=spring
    dubbo.spring.config=classpath:dubbo-provider.xml
    dubbo.protocol.name=dubbo
    dubbo.protocol.port=20880

dubbo-provider1.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-provider" />
    
    	
    	<dubbo:registry protocol="zookeeper" address="127.0.0.1:2181" />
    
    	
    	<dubbo:protocol name="dubbo" port="20880" />
    
    	
    
    
    	
    	<bean id="userService" class="com.hlx.provider.UserServiceImpl" />
    
    	
    	<dubbo:service interface="com.hlx.service.UserService"
    		ref="userService" />
    
    </beans>

pom.xml文件

<dependencies>
    		
    		<dependency>
    			<groupId>com.alibaba</groupId>
    			<artifactId>dubbo</artifactId>
    			<version>2.5.5</version>
    		</dependency>
    
    		<dependency>
    			<groupId>org.apache.zookeeper</groupId>
    			<artifactId>zookeeper</artifactId>
    			<version>3.4.8</version>
    		</dependency>
    
    		
    		<dependency>
    			<groupId>io.netty</groupId>
    			<artifactId>netty</artifactId>
    			<version>3.7.0.Final</version>
    		</dependency>
    
    		
    		<dependency>
    			<groupId>jline</groupId>
    			<artifactId>jline</artifactId>
    			<version>0.9.94</version>
    		</dependency>
    
    
    
    		
    		<dependency>
    			<groupId>com.dubbo.demo</groupId>
    			<artifactId>dubbo-api1</artifactId>
    			<version>0.0.1-SNAPSHOT</version>
    		</dependency>
    
    
    		<dependency>
    			<groupId>com.github.sgroschupf</groupId>
    			<artifactId>zkclient</artifactId>
    			<version>0.1</version>
    		</dependency>
    
    	</dependencies>

2.3 dubbo-consumer maven

![Center 2][]

UserController类就是控制器，使用requestMapping注解提供http接口服务

@RestController
    public class UserController {
    
    	@Autowired
    	private UserService userService;
    
    	@RequestMapping("/hello")
    	@ResponseBody
    	public String hello(String name) throws Exception {
                     System.out.println("controol==>");
    		return userService.sayHello(name);
    
    	}
    
    }

dubbo-consumer.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:p="http://www.springframework.org/schema/p"
    	xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
    	xsi:schemaLocation="http://www.springframework.org/schema/beans 
    	http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
    	http://code.alibabatech.com/schema/dubbo
        http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
    
    	
    	<dubbo:application name="dubbo-consumer" />
    
    	
    	<dubbo:registry address="zookeeper://127.0.0.1:2181" />
    
       
        
        <dubbo:reference id="userService" check="false" interface="com.hlx.service.UserService"/>
    
    </beans>

spring-config.xml文件配置

spring-mvc.xml 文件配置

![Center 3][]  
web.xml配置文件

<context-param>
            <param-name>contextConfigLocation</param-name>
            <param-value>
                classpath*:spring-config.xml
            </param-value>
        </context-param>
        
        <listener>
            <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
        </listener>
    
        <servlet>
            <servlet-name>dispatcher</servlet-name>
            <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>
            <init-param>
                <param-name>contextConfigLocation</param-name>
                <param-value>classpath*:spring-mvc.xml</param-value>
            </init-param>
            <load-on-startup>1</load-on-startup>
        </servlet>
        <servlet-mapping>
            <servlet-name>dispatcher</servlet-name>
            <url-pattern>*.action</url-pattern>
        </servlet-mapping>

配置pom.xml文件

<dependencies>
       	
    		<dependency>
    			<groupId>com.alibaba</groupId>
    			<artifactId>dubbo</artifactId>
    			<version>2.5.5</version>
    		</dependency>
    
    		<dependency>
    			<groupId>org.apache.zookeeper</groupId>
    			<artifactId>zookeeper</artifactId>
    			<version>3.4.8</version>
    		</dependency>
    
    		
    		 <dependency>
    			<groupId>com.dubbo.demo</groupId>
    			<artifactId>dubbo-api1</artifactId>
    			<version>0.0.1-SNAPSHOT</version>
    		</dependency> 
    
    		<dependency>
    			<groupId>com.github.sgroschupf</groupId>
    			<artifactId>zkclient</artifactId>
    			<version>0.1</version>
    		</dependency>
    		
    		
    		<dependency>
    			<groupId>org.springframework</groupId>
    			<artifactId>spring-webmvc</artifactId>
    			<version>4.3.10.RELEASE</version>
    		</dependency>
    		
    		  <dependency>
                <groupId>org.springframework</groupId>
                <artifactId>spring-context-support</artifactId>
                <version>4.3.10.RELEASE</version>
            </dependency>
            
            <dependency>
    			<groupId>org.springframework</groupId>
    			<artifactId>spring-tx</artifactId>
    			<version>4.3.10.RELEASE</version>
    		</dependency>
      </dependencies>

**注意：provider1与consumer必须导入公共api1包哦！**

***(1)zookeeper服务启动起来。***

***(2)dubbo-provider1 服务器运行起来；***

***(3)dubbo-consumer 部署到Tomcat上！运行起来；***

**显示效果：**

IE : http://localhost:8888/dubbo-consumer/hello.action?name=Mike

**![Center 4][]**

[Center]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/e8524a23cb0c4f94b662973755cf679d.png
[Center 1]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/4c912a8b9dfa469086bc575ebc42cce1.png
[Center 2]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/b9b839a21e4f482499d344ceb6df27b2.png
[Center 3]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/eef7974fa22a4e59927678fddb818b16.png
[Center 4]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/85616cf808d94f348d23fede3b7c0880.png