Dubbo直连方式

一、简介

官网:http://dubbo.apache.org/zh-cn/

Dubbo是 [1]  阿里巴巴公司开源的一个高性能优秀的服务框架,使得应用可通过高性能的 RPC 实现服务的输出和输入功能,可以和 [2]  Spring框架无缝集成。

Dubbo是一款高性能、轻量级的开源Java RPC框架,它提供了三大核心能力:面向接口的远程方法调用,智能容错和负载均衡,以及服务自动注册和发现

二、Dubbo程序(直连式)

业务接口名即服务名称。无论是服务提供者向服务注册中心注册服务,还是服务消费者从注册中心索取服务,都是通过接口名称进行注册与查找的。即,提供者与消费者都依赖于业务接口。所以,一般情况下,会将业务接口专门定义为一个工程,让提供者与消费者依赖

三、创建业务接口工程00-api

(1)创建业务接口工程00-api


 

(2)创建业务接口

(3) 修改pom文件

<?xml version="1.0" encoding="UTF-8"?><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>00-api</groupId>    <artifactId>00-api</artifactId>    <version>1.0-SNAPSHOT</version>     <properties>        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>        <maven.compiler.source>1.8</maven.compiler.source>        <maven.compiler.target>1.8</maven.compiler.target>    </properties> </project>

四、创建提供者(自建Spring容器)00-api-provider

(1)创建工程

创建一个Maven的Java工程,并命名为00-api-provider

(2) 在pom中导入依赖

主要包含三类依赖:

业务接口依赖
Dubbo依赖(2.7.0版本)
Spring依赖(4.3.16版本)

<?xml version="1.0" encoding="UTF-8"?><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>00-api-provider</groupId>    <artifactId>00-api-provider</artifactId>    <version>1.0-SNAPSHOT</version>     <properties>        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>        <maven.compiler.source>1.8</maven.compiler.source>        <maven.compiler.target>1.8</maven.compiler.target>        <!-- 自定义版本号 -->        <spring-version>4.3.16.RELEASE</spring-version>    </properties>     <dependencies>        <!--业务接口工程依赖-->        <dependency>            <groupId>00-api</groupId>            <artifactId>00-api</artifactId>            <version>1.0-SNAPSHOT</version>        </dependency>         <!-- dubbo依赖 -->        <dependency>            <groupId>org.apache.dubbo</groupId>            <artifactId>dubbo</artifactId>            <version>2.7.2</version>        </dependency>         <!-- Spring依赖 -->        <dependency>            <groupId>org.springframework</groupId>            <artifactId>spring-beans</artifactId>            <version>${spring-version}</version>        </dependency>        <dependency>            <groupId>org.springframework</groupId>            <artifactId>spring-core</artifactId>            <version>${spring-version}</version>        </dependency>        <dependency>            <groupId>org.springframework</groupId>            <artifactId>spring-context</artifactId>            <version>${spring-version}</version>        </dependency>        <dependency>            <groupId>org.springframework</groupId>            <artifactId>spring-expression</artifactId>            <version>${spring-version}</version>        </dependency>        <dependency>            <groupId>org.springframework</groupId>            <artifactId>spring-aop</artifactId>            <version>${spring-version}</version>        </dependency>        <dependency>            <groupId>org.springframework</groupId>            <artifactId>spring-aspects</artifactId>            <version>${spring-version}</version>        </dependency>        <dependency>            <groupId>org.springframework</groupId>            <artifactId>spring-tx</artifactId>            <version>${spring-version}</version>        </dependency>        <dependency>            <groupId>org.springframework</groupId>            <artifactId>spring-jdbc</artifactId>            <version>${spring-version}</version>        </dependency>        <!-- commons-logging依赖 -->        <dependency>            <groupId>commons-logging</groupId>            <artifactId>commons-logging</artifactId>            <version>1.2</version>        </dependency>    </dependencies>  </project>

(3) 定义接口实现类

(4) 定义spring-provider配置文件

在src/main/resources下定义spring-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://dubbo.apache.org/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">     <!--指定当前工程在管控平台中的名称-->    <dubbo:application name="01-provider"/>     <!--指定注册中心:不使用注册中心-->    <dubbo:registry address="N/A"/>     <!--注册业务接口实现类,它是真正的服务提供者-->    <bean id="someService" class="com.dubbo.provider.SomeServiceImpl"/>     <!--服务暴露-->    <dubbo:service interface="com.dubbo.provider.SomeService" ref="someService"/></beans>

(5) 定义测试类

在/src/test/java中创建测试类RunProvider

五、创建提供者(Main启动) 01-api-provider

使用自建Spring容器方式是比较浪费资源的。容器的作用仅仅就是创建一个单例的提供者对象,其本身并不需要 Tomcat 或 JBoss 等 Web 容器的功能。如果硬要用 Web 容器去加载服务提供方,就增加了代码的复杂性,也浪费了资源。
Dubbo提供了一个Main.main()方法可以直接创建并启动Provider,其底层仅仅是加载了一个简单的用于暴露服务的Spring容器。该方式要求Spring配置文件必须要放到类路径下的META-INF/spring目录中,Spring配置文件名称无所谓

(1)工程创建

复制00-api-provider工程,并修改其工程名01-api-provider

(2) 创建目录并移动配置文件

在resources目录中创建META-INF/spring目录,并将spring-provider.xml配置文件拖入其中

(3) 修改启动类

六、创建消费者01-consumer

(1) 创建工程

创建一个Maven的Java工程,并命名为01-consumer

(2) 在pom中导入依赖

该工程的依赖与Provider中的完全相同,直接复制来就可以
(3) 定义spring-consumer配置文件

(4) 定义消费者类

七、效果

(1)启动提供者

(2)消费者消费

Published by

风君子

独自遨游何稽首 揭天掀地慰生平

发表回复

您的邮箱地址不会被公开。 必填项已用 * 标注