【dubbo】1.简单spring-dubbo工程搭建

作者: 天还下着毛毛雨 | 来源:发表于2021-06-26 14:59 被阅读0次

工程目录结构：

dubbo-study ：父工程
    - dubbo-api : api接口工程
    - dubbo-c   : 服务消费者,依赖dubbo-api,用于获取api接口
    - duppo-p   : 服务提供者,依赖dubbo-api,实现api接口,并暴露给消费者

pom依赖

<dependencies>
    <!-- dubbo依赖 -->
    <dependency>
        <groupId>org.apache.dubbo</groupId>
        <artifactId>dubbo</artifactId>
        <version>2.7.0</version>
    </dependency>
    <!-- 添加zk客户端依赖 -->
    <dependency>
        <groupId>org.apache.zookeeper</groupId>
        <artifactId>zookeeper</artifactId>
        <version>3.6.0</version>
        <exclusions>
            <exclusion>
                <groupId>org.slf4j</groupId>
                <artifactId>slf4j-log4j12</artifactId>
            </exclusion>
            <exclusion>
                <groupId>log4j</groupId>
                <artifactId>log4j</artifactId>
            </exclusion>
        </exclusions>
    </dependency>
    <dependency>
        <groupId>org.apache.curator</groupId>
        <artifactId>curator-framework</artifactId>
        <version>5.1.0</version>
    </dependency>
    <dependency>
        <groupId>org.apache.curator</groupId>
        <artifactId>curator-recipes</artifactId>
        <version>5.1.0</version>
    </dependency>
    <!-- spring相关 -->
    <dependency>
        <groupId>javax.servlet</groupId>
        <artifactId>servlet-api</artifactId>
        <version>2.5</version>
        <scope>provided</scope>
    </dependency>
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-context</artifactId>
        <version>${spring.version}</version>
    </dependency>
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-webmvc</artifactId>
        <version>${spring.version}</version>
    </dependency>
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-test</artifactId>
        <version>${spring.version}</version>
    </dependency>
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-tx</artifactId>
        <version>${spring.version}</version>
    </dependency>
    <dependency>
        <groupId>com.fasterxml.jackson.core</groupId>
        <artifactId>jackson-core</artifactId>
        <version>2.0.0</version>
    </dependency>
    <dependency>
        <groupId>org.codehaus.jackson</groupId>
        <artifactId>jackson-mapper-asl</artifactId>
        <version>1.8.7</version>
    </dependency>
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-aop</artifactId>
        <version>${spring.version}</version>
    </dependency>
    <dependency>
        <groupId>junit</groupId>
        <artifactId>junit</artifactId>
        <version>4.13</version>
    </dependency>
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-test</artifactId>
        <version>3.2.10.RELEASE</version>
    </dependency>
    <!-- 日志相关依赖 -->
    <!-- https://mvnrepository.com/artifact/org.slf4j/slf4j-api -->
    <dependency>
        <groupId>org.slf4j</groupId>
        <artifactId>slf4j-api</artifactId>
        <version>1.7.25</version>
    </dependency>
    <dependency>
        <groupId>ch.qos.logback</groupId>
        <artifactId>logback-core</artifactId>
        <version>1.1.3</version>
    </dependency>
    <dependency>
        <groupId>ch.qos.logback</groupId>
        <artifactId>logback-access</artifactId>
        <version>1.1.3</version>
    </dependency>
    <dependency>
        <groupId>ch.qos.logback</groupId>
        <artifactId>logback-classic</artifactId>
        <version>1.1.3</version>
    </dependency>
    <!-- bubbo网络通信依赖 -->
    <dependency>
        <groupId>io.netty</groupId>
        <artifactId>netty-all</artifactId>
        <version>4.1.63.Final</version>
    </dependency>
    <!-- bubbo参数校验依赖 -->
    <dependency>
        <groupId>javax.validation</groupId>
        <artifactId>validation-api</artifactId>
        <version>1.0.0.GA</version>
    </dependency>
    <dependency>
        <groupId>org.hibernate</groupId>
        <artifactId>hibernate-validator</artifactId>
        <version>4.2.0.Final</version>
    </dependency>
</dependencies>

dubbo-api

只提供简单的服务接口
UserService接口：

public interface UserService {
    String getUser();
}

==如果是get开头的方法名,一定要有返回值,不然会报错==

dubbo-p 服务提供者

实现UserService接口

@Service
public class UserServiceImpl implements UserService {
    public String getUser() {
        return "我是服务的生产者";
    }
}

spring配置文件applicationProvider.xml:

注册服务实现类bean到spring
声明暴露的服务,并指定bean
指定服务名称,可以有同名的服务，用来做负载均衡
注册服务到zokeeper注册中心
指定netty端口(默认为20880),通信协议为dubbo/rmi(默认为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://code.alibabatech.com/schema/dubbo
        http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
    <!-- 注册UserServiceImpl类的实例到Spring容器 -->
    <bean id="userServiceImpl" class="com.lb.dubbo_api.service.impl.UserServiceImpl"/>
    
    <!-- 注册服务,声明服务类型为UserService，指定spring容器的beanId为上面的userServiceImpl -->
    <dubbo:service interface="com.lb.dubbo_api.service.UserService" ref="userServiceImpl"/>
    
    <!-- 暴露服务的服务名,如果部署了同名称的多个服务实例,服务提供方被调用时,会负载均衡 -->
    <dubbo:application name="dubbo-p"/>
    
    <!-- 指定zookeeper作为服务的注册中心,并声明zookeeper的ip和端口 -->
    <dubbo:registry check="false" address="zookeeper://192.168.31.211:2181"/>
    
    <!-- 指定通信协议为dubbo,并指定netty通信端口为22184 -->
    <dubbo:protocol name="dubbo" port="22184"/>
</beans>

启动spring容器,并阻塞线程

public class DubboProviderApplication {

    public static void main(String[] args) throws IOException {
        // 加载applicationProvider.xml
        new ClassPathXmlApplicationContext("applicationProvider.xml");
        // 阻塞线程
        System.in.read();
    }

}

zookeeper会创建dubbo节点

dubbo
-   com.lb.dubbo_api.service.UserService:注册的服务接口名
    -   configurators
    -   consumers : 该服务的消费者列表
    -   providers : 该服务的提供者列表
    -   routers

comsumers和providers 数组元素实际为一串dubbo协议,包含服务ip地址,服务接口名,服务实例名等信息

image

dubbo-c 服务消费者

spring配置文件applicationConsumer.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-c"/>
    <!-- 注册中心配置 -->
    <dubbo:registry check="false" address="zookeeper://192.168.31.211:2181"/>
    <dubbo:consumer check="false"/>

    <!-- 要调用的服务接口名-->
    <dubbo:reference interface="com.lb.dubbo_api.service.UserService"/>
</beans>

启动实例

public static void main(String[] arghrows IOException {
    // 加载配置文件
    ClassPathXmlApplicationContelassPathXmlApplicationContext = nlassPathXmlApplicationContext("apptionConsumer.xml");
    // 从bean获取服务提供方的实例
    UserService userServiceImplUserServiclassPathXmlApplicationContext.getB"userServiceImpl");
    // 调用方法
    System.out.println(userServiceImpl.ser());
    System.in.read();
}

rpc调用成功,控制台打印

image

zookeeper的dubbo节点会在服务接口下注册该消费者信息

image

注解版本

dubbo-p 服务提供者

服务实现类添加dubbo的@Service注解

import org.apache.dubbo.config.annotation.Service;

/**
 * @author liuben
 * @date 2021/6/23 10:05 下午
 **/
@Service
public class UserServiceImpl implements UserService {
    public String getUser() {
        return "我是服务的生产者";
    }
}

dobbo.properties ：

## 服务名称
dubbo.application.name=dubbo-p
## 注册地址
dubbo.registry.address=zookeeper://192.168.31.211:2181
dubbo.registry.check=false

AnnoBean类：

import org.apache.dubbo.config.spring.context.annotation.EnableDubbo;
import org.springframework.context.annotation.PropertySource;

/**
 * @author liuben
 * @date 2021/6/26 1:06 下午
 **/
 //该注册用于扫描包下含有@Service的服务实现
@EnableDubbo(scanBasePackages = "com.lb.dubbo_api.service")
// 指定加载的配置文件
@PropertySource("dobbo.properties")
public class AnnoBean {

}

启动的时候加载AnnoBean类。

public static void main(String[] args) throws IOException {
 new AnnotationConfigApplicationContext(AnnoBean.class);
 System.in.read();
}

dubbo-c 服务提供者

dobbo.properties：

dubbo.application.name=dubbo-c
dubbo.registry.address=zookeeper://192.168.31.211:2181

AnnoBean类

@EnableDubbo
@PropertySource("dobbo.properties")
public class AnnoBean {

}

测试类：
用@Reference注入服务提供方的bean，并调用其方法

@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(classes = {AnnoBean.class})
public class DubboTest {

    @Reference
    UserService userService;

    @Test
    public void test() throws IOException {
        System.out.println(userService.getUser());
        System.in.read();
    }

}

【dubbo】1.简单spring-dubbo工程搭建

dubbo-api

dubbo-p 服务提供者

dubbo-c 服务消费者

注解版本

dubbo-p 服务提供者

dubbo-c 服务提供者

相关文章

网友评论

延伸阅读

深度阅读

栏目导航

热点阅读