如何创建一个Dubbo的Demo

框架师

发布于 2019-09-19 17:49:47

1.1K0

发布于 2019-09-19 17:49:47

首先祝所有的小伙伴中秋快乐,今天让我们来写一个简单的Dubbo-Demo,Dubbo作为一个RPC框架，其最核心的功能就是要实现跨网络的远程调用。这个Demo就是要创建两个应用，一个作为服务的提供者，一个作为服务的消费者。通过Dubbo来实现服务消费者远程调用服务提供者的方法。

首先,要开启zookeeper注册中心,这里使用Windows版zookeeper注册中心

下载地址:http://mirror.bit.edu.cn/apache/zookeeper/

下载完成加压到自己想要安装的目录盘符即可,找到zookeeper/bin目录的zkServer.cmd双击启动;

出现以下界面就是启动成功了;

然后让我们先写一个dubbo的服务者:dubbodemo_provider

步骤如下

创建web项目: dubbodemo_provider
添加pom.xml依赖
编写web.xml
编写dubbo-provider.xml
编写服务接口
编写服务实现
启动tomcat，发布项目

创建maven-web项目,不知道怎么创建的小伙伴可以看我之前发表过的idea如何创建maven-web项目{IDEA配置Maven教程},里面有详细的介绍maven配置及如何创建一个web项目;

添加pom.xml依赖


<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.0modelVersion>  
  <groupId>com.mobaijungroupId>  
  <artifactId>dubbodemo_providerartifactId>  
  <version>1.0-SNAPSHOTversion>  
  <packaging>warpackaging>
  <properties> 
    <spring.version>5.0.2.RELEASEspring.version> 
  properties>  
  <dependencies> 
    <dependency> 
      <groupId>org.springframeworkgroupId>  
      <artifactId>spring-contextartifactId>  
      <version>${spring.version}version> 
    dependency>  
    <dependency> 
      <groupId>org.springframeworkgroupId>  
      <artifactId>spring-beansartifactId>  
      <version>${spring.version}version> 
    dependency>  
    <dependency> 
      <groupId>org.springframeworkgroupId>  
      <artifactId>spring-webmvcartifactId>  
      <version>${spring.version}version> 
    dependency>  
    <dependency> 
      <groupId>org.springframeworkgroupId>  
      <artifactId>spring-jdbcartifactId>  
      <version>${spring.version}version> 
    dependency>  
    <dependency> 
      <groupId>org.springframeworkgroupId>  
      <artifactId>spring-aspectsartifactId>  
      <version>${spring.version}version> 
    dependency>  
    <dependency> 
      <groupId>org.springframeworkgroupId>  
      <artifactId>spring-jmsartifactId>  
      <version>${spring.version}version> 
    dependency>  
    <dependency> 
      <groupId>org.springframeworkgroupId>  
      <artifactId>spring-context-supportartifactId>  
      <version>${spring.version}version> 
    dependency>  
      
    <dependency> 
      <groupId>com.alibabagroupId>  
      <artifactId>dubboartifactId>  
      <version>2.6.6version> 
    dependency>  
    <dependency> 
      <groupId>io.nettygroupId>  
      <artifactId>netty-allartifactId>  
      <version>4.1.32.Finalversion> 
    dependency>  
    <dependency> 
      <groupId>org.apache.curatorgroupId>  
      <artifactId>curator-frameworkartifactId>  
      <version>4.0.0version>  
      <exclusions> 
        <exclusion> 
          <groupId>org.apache.zookeepergroupId>  
          <artifactId>zookeeperartifactId> 
        exclusion> 
      exclusions> 
    dependency>  
    <dependency> 
      <groupId>org.apache.zookeepergroupId>  
      <artifactId>zookeeperartifactId>  
      <version>3.4.7version> 
    dependency>  
    <dependency> 
      <groupId>com.github.sgroschupfgroupId>  
      <artifactId>zkclientartifactId>  
      <version>0.1version> 
    dependency> 
  dependencies> 
project>

编写web.xml


<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_2_5.xsd"
         version="2.5">

    
    <context-param>
        <param-name>contextConfigLocationparam-name>
        <param-value>classpath*:dubbo-provider.xmlparam-value>
    context-param>
    <listener>
        <listener-class>org.springframework.web.context.ContextLoaderListenerlistener-class>
    listener>

web-app>

编写dubbo-provider.xml,添加日志配置文件

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="dubbodemo_provider"/>

    <!--配置注册中心地址
        IP:这里的IP地址配置zookeeper注册中心的IP地址 
        -->
    <dubbo:registry address="zookeeper://192.168.0.0:2181"/>
    <!--
     配置请求协议            
            name 指定的是传输协议的名称,
                 值列表范围如：dubbo rmi hessian webservice http
            port：服务提供者的真实请求端口
    -->
    <dubbo:protocol name="dubbo" port="20881"/>

    <!--配置dubbo服务提供者的包扫描-->
    <dubbo:annotation package="com.mobaijun.service"/>

</beans>

编写服务接口HelloDubboService.java

package com.mobaijun.service;

/**
 * @author Auser·杰
 */
public interface HelloDubboService {

    String DubboHello(String name);
}

编写服务实现。注意这里的@Service引入的包是阿里巴巴的。

package com.mobaijun.service.impl;

import com.alibaba.dubbo.config.annotation.Service;
import com.mobaijun.service.HelloDubboService;


/**
 * @Author：Auser·杰
 * @DATE：2019/9/12 15:18
 */
@Service
public class HelloDubboServiceImpl implements HelloDubboService {
    @Override
    public String DubboHello(String name) {
        return  "hello :" + name;
    }
}

部署tomcat,启动项目dubbodemo_provider

二:添加Dubbo的服务消费者:dubbodemo_consumer

步骤如下

创建web项目: dubbodemo_consumer
添加依赖
编写web.xml
编写dubbo-consumer.xml
编写服务接口（客户端接口要与服务端接口一样：包类方法参数返回值）
编写控制器，调用服务
启动tomcat，测试，观察服务是否调用成功。

创建web项目: dubbodemo_consumer,添加pom.xml依赖

添加项目依赖



<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.0modelVersion>  
  <groupId>com.mobaijungroupId>  
  <artifactId>dubbodemo_consumerartifactId>  
  <version>1.0-SNAPSHOTversion>  
  <packaging>warpackaging>
  <properties> 
    <spring.version>5.0.2.RELEASEspring.version> 
  properties>  
  <dependencies> 
    <dependency> 
      <groupId>org.springframeworkgroupId>  
      <artifactId>spring-contextartifactId>  
      <version>${spring.version}version> 
    dependency>  
    <dependency> 
      <groupId>org.springframeworkgroupId>  
      <artifactId>spring-beansartifactId>  
      <version>${spring.version}version> 
    dependency>  
    <dependency> 
      <groupId>org.springframeworkgroupId>  
      <artifactId>spring-webmvcartifactId>  
      <version>${spring.version}version> 
    dependency>  
    <dependency> 
      <groupId>org.springframeworkgroupId>  
      <artifactId>spring-jdbcartifactId>  
      <version>${spring.version}version> 
    dependency>  
    <dependency> 
      <groupId>org.springframeworkgroupId>  
      <artifactId>spring-aspectsartifactId>  
      <version>${spring.version}version> 
    dependency>  
    <dependency> 
      <groupId>org.springframeworkgroupId>  
      <artifactId>spring-jmsartifactId>  
      <version>${spring.version}version> 
    dependency>  
    <dependency> 
      <groupId>org.springframeworkgroupId>  
      <artifactId>spring-context-supportartifactId>  
      <version>${spring.version}version> 
    dependency>  
      
    <dependency> 
      <groupId>com.alibabagroupId>  
      <artifactId>dubboartifactId>  
      <version>2.6.6version>  
      <exclusions> 
        <exclusion> 
          <groupId>org.springframeworkgroupId>  
          <artifactId>spring-webartifactId> 
        exclusion>  
        <exclusion> 
          <groupId>org.springframeworkgroupId>  
          <artifactId>spring-beansartifactId> 
        exclusion>  
        <exclusion> 
          <groupId>org.springframeworkgroupId>  
          <artifactId>spring-contextartifactId> 
        exclusion> 
      exclusions> 
    dependency>  
    <dependency> 
      <groupId>io.nettygroupId>  
      <artifactId>netty-allartifactId>  
      <version>4.1.32.Finalversion> 
    dependency>  
    <dependency> 
      <groupId>org.apache.curatorgroupId>  
      <artifactId>curator-frameworkartifactId>  
      <version>4.0.0version>  
      <exclusions> 
        <exclusion> 
          <groupId>org.apache.zookeepergroupId>  
          <artifactId>zookeeperartifactId> 
        exclusion> 
      exclusions> 
    dependency>  
    <dependency> 
      <groupId>org.apache.zookeepergroupId>  
      <artifactId>zookeeperartifactId>  
      <version>3.4.7version> 
    dependency>  
    <dependency> 
      <groupId>com.github.sgroschupfgroupId>  
      <artifactId>zkclientartifactId>  
      <version>0.1version> 
    dependency>
    <dependency>
      <groupId>javax.servletgroupId>
      <artifactId>servlet-apiartifactId>
      <version>2.5version>
    dependency>
  dependencies> 
project>

编写web.xml


<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_2_5.xsd"
         version="2.5">
    <servlet>
        <servlet-name>springmvcservlet-name>
        <servlet-class>org.springframework.web.servlet.DispatcherServletservlet-class>
        <init-param>
            <param-name>contextConfigLocationparam-name>
            <param-value>classpath:dubbo-consumer.xmlparam-value>
        init-param>
        <load-on-startup>1load-on-startup>
    servlet>
    <servlet-mapping>
        <servlet-name>springmvcservlet-name>
        <url-pattern>*.dourl-pattern>
    servlet-mapping>
web-app>

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:dubbo="http://code.alibabatech.com/schema/dubbo"
       xmlns:context="http://www.springframework.org/schema/context"
       xmlns:mvc="http://www.springframework.org/schema/mvc"
       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 http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc.xsd">

    <!--开启SpringMVC注解扫描，扫描@Controller注解-->
    <context:component-scan base-package="com.mobaijun.controller"/>
    <!--SpringMVC注解驱动-->
    <mvc:annotation-driven/>
    <!-- 消费方应用名，用于计算依赖关系，不是匹配条件，不要与提供方一样 -->
    <dubbo:application name="dubbodemo_consumer">
        <dubbo:parameter key="qos.enable" value="false"/>
    </dubbo:application>

    <!--配置注册中心地址-->
    <dubbo:registry address="zookeeper://192.168.0.0:2181"/>

    <!--开启dubbo注解扫描(@Reference注解)-->
    <dubbo:annotation package="com.mobaijun.web"/>
</beans>

编写服务接口。注意：这里的接口类名称要与服务端接口名称一致；路径也要一致。

package com.mobaijun.service;

/**
 * @Author：Auser·杰
 * @DATE：2019/9/13 15:31
 */
public interface HelloDubboService {
    String DubboHello(String name);
}

编写控制器，调用服务HelloDubboController

package com.mobaijun.controlle;
import com.alibaba.dubbo.config.annotation.Reference;
import com.mobaijun.service.HelloService;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
/**
 * @Author：Auser·杰
 * @DATE：2019/9/12 15:32
 */
@Controller
public class HelloDubboController {
    @Reference
    private HelloDubboService helloDubboService;
    @RequestMapping("hello")
    @ResponseBody
    public String hello(){
        String str  = helloDubboService.DubboHello("lisi");
        System.out.println(str);
        return str;
    }
}

启动tomcat，测试，观察服务是否调用成功。