Dubbo创建提供者、消费者项目(dubbo怎么使用)

需要先开启zookeeper和dubbo

 

spring版本

Dubbo服务提供消费者接口搭建

创建Maven项目=> gmail-interface 用于存放共同的服务接口(存放实体bean和接口interface

创建Maven项目=> user-service-provider 服务提供者(提供接口实现类)接口的实现类impl)

创建Maven项目=> order-service-consumer 服务消费者(使用到提供者的接口的实现类)接口的实现类impl

 

接口项目中有自己的引用格式(pom.xml)(可以在其他maven项目中使用接口)(用于在消费者提供者引用)

<groupId>com.atguigu.gmall</groupId>
<artifactId>gmall-interface</artifactId>
<version>0.0.1-SNAPSHOT</version>

 

 

在消费者和提供者 pom.xml 中引用dubbo,接口项目,zookeeper客户端(也可使用其他的注册中心,可在dubbo官网查询)

Dubbo创建提供者、消费者项目(dubbo怎么使用)
    <!-- 引入接口项目的接口 -->
    <dependency>
        <groupId>com.atguigu.gmall</groupId>
        <artifactId>gmall-interface</artifactId>
        <version>0.0.1-SNAPSHOT</version>
    </dependency>
    <!-- 引入dubbo -->
    <!-- https://mvnrepository.com/artifact/com.alibaba/dubbo -->
    <dependency>
        <groupId>com.alibaba</groupId>
        <artifactId>dubbo</artifactId>
        <version>2.6.2</version>
    </dependency>
    <!-- 注册中心使用的是zookeeper,引入操作zookeeper的客户端 -->
    <dependency>
        <groupId>org.apache.curator</groupId>
        <artifactId>curator-framework</artifactId>
        <version>2.12.0</version>
    </dependency>
View Code

 

在消费者(consumer.xml)和提供者(provider.xml)的resources下分别创建两个xml(使用的是spring配置方式配置dubbo和zookeeper)(xml名字随便取,之后使其ioc生效修改名字就行)

Dubbo创建提供者、消费者项目(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://dubbo.apache.org/schema/dubbo http://dubbo.apache.org/schema/dubbo/dubbo.xsd
        http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">

    <!-- 1、指定当前服务/应用的名字(同样的服务名字相同,不要和别的服务同名) -->
    <dubbo:application name="user-service-provider"></dubbo:application>
    
    <!-- 2、指定注册中心的位置 -->
    <!-- <dubbo:registry address="zookeeper://127.0.0.1:2181"></dubbo:registry> -->
    <dubbo:registry protocol="zookeeper" address="127.0.0.1:2181"></dubbo:registry>
    
    <!-- 3、指定通信规则(通信协议?通信端口) -->
    <dubbo:protocol name="dubbo" port="20882"></dubbo:protocol>
    
    <!-- 4、暴露服务   ref:指向服务的真正的实现对象 -->
    <dubbo:service interface="com.atguigu.gmall.service.UserService" 
        ref="userServiceImpl01" timeout="1000" version="1.0.0">
        <dubbo:method name="getUserAddressList" timeout="1000"></dubbo:method>
    </dubbo:service>
    
    <!--统一设置服务提供方的规则  -->
    <dubbo:provider timeout="1000"></dubbo:provider>
    
    
    <!-- 服务的实现 -->
    <bean id="userServiceImpl01" class="com.atguigu.gmall.service.impl.UserServiceImpl"></bean>
    
    
    <dubbo:service interface="com.atguigu.gmall.service.UserService" 
        ref="userServiceImpl02" timeout="1000" version="2.0.0">
        <dubbo:method name="getUserAddressList" timeout="1000"></dubbo:method>
    </dubbo:service>
    <bean id="userServiceImpl02" class="com.atguigu.gmall.service.impl.UserServiceImpl2"></bean>
    
    <!-- 连接监控中心 -->
    <dubbo:monitor protocol="registry"></dubbo:monitor>
    
</beans>
provider.xml
Dubbo创建提供者、消费者项目(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://dubbo.apache.org/schema/dubbo"
    xmlns:context="http://www.springframework.org/schema/context"
    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-4.3.xsd
        http://dubbo.apache.org/schema/dubbo http://dubbo.apache.org/schema/dubbo/dubbo.xsd
        http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
    <context:component-scan base-package="com.atguigu.gmall.service.impl"></context:component-scan>


    <dubbo:application name="order-service-consumer"></dubbo:application>
    
    <dubbo:registry address="zookeeper://127.0.0.1:2181"></dubbo:registry>
    
    <!--  配置本地存根-->
    
    <!--声明需要调用的远程服务的接口;生成远程服务代理  -->
    <!-- 
        1)、精确优先 (方法级优先,接口级次之,全局配置再次之)
        2)、消费者设置优先(如果级别一样,则消费方优先,提供方次之)
    -->
    <!-- timeout="0" 默认是1000ms-->
    <!-- retries="":重试次数,不包含第一次调用,0代表不重试-->
    <!-- 幂等(设置重试次数)【查询、删除、修改】、非幂等(不能设置重试次数)【新增】 -->
    <dubbo:reference interface="com.atguigu.gmall.service.UserService" 
        id="userService" timeout="5000" retries="3" version="*">
        <!-- <dubbo:method name="getUserAddressList" timeout="1000"></dubbo:method> -->
    </dubbo:reference>
        
    <!-- 配置当前消费者的统一规则:所有的服务都不检查 -->
    <dubbo:consumer check="false" timeout="5000"></dubbo:consumer>

    <dubbo:monitor protocol="registry"></dubbo:monitor>
    <!-- <dubbo:monitor address="127.0.0.1:7070"></dubbo:monitor> -->
    
</beans>
consumer.xml

 

 启动检查

Dubbo创建提供者、消费者项目(dubbo怎么使用)

 

 

 

 

 

 springboot版本

导入依赖(接口依赖,dubbo-spring-boot-starter依赖)(包含了dubbo,zookeeper)

        <dependency>
            <groupId>com.atguigu.gmall</groupId>
            <artifactId>gmall-interface</artifactId>
            <version>0.0.1-SNAPSHOT</version>
        </dependency>
        <dependency>
            <groupId>com.alibaba.boot</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>0.2.0</version>
        </dependency>

 

 

在application.properties中配置dubbo

Dubbo创建提供者、消费者项目(dubbo怎么使用)
dubbo.application.name=user-service-provider
dubbo.registry.address=127.0.0.1:2181
dubbo.registry.protocol=zookeeper

dubbo.protocol.name=dubbo
dubbo.protocol.port=20881

dubbo.monitor.protocol=registry
dubbo.scan.base-packages=com.atguigu.gmall
View Code

 

提供者:

在springboot的主运行方法下开启dubbo的注解功能(@EnableDubbo

将提供者的   spring包下的注解@service换为@Component

并使用dubbo包下注解@service(将接口暴露到dubbo中,能给其他应用提供接口)

Dubbo创建提供者、消费者项目(dubbo怎么使用)

 

Dubbo创建提供者、消费者项目(dubbo怎么使用)

 

 这样就不需要大量的在springboot中配置了

Dubbo创建提供者、消费者项目(dubbo怎么使用)

 

 

消费者

开启springboot主运行方法中的dubbo注解(@EnableDubbo)

在dubbo中远程引用其他应用的接口

将@Autowired改为@Reference

Dubbo创建提供者、消费者项目(dubbo怎么使用)

 

Dubbo创建提供者、消费者项目(dubbo怎么使用)

 

application.xml(因为监控中心使用的是8080端口,所以应用我们使用8081端口)

Dubbo创建提供者、消费者项目(dubbo怎么使用)
server.port=8081

dubbo.application.name=boot-order-service-consumer
dubbo.registry.address=zookeeper://127.0.0.1:2181
dubbo.monitor.protocol=registry
View Code

 

Dubbo创建提供者、消费者项目(dubbo怎么使用)

上一篇:jmeter--性能监控之nmon使用方法


下一篇:leetcode 73 矩阵置零