dubbo（4）：配置与测试

迈不过友情╰ 2022-10-20 05:24 158阅读 0赞

# 一、服务提供者配置与测试 #

##     （1）在服务提供者中引入依赖 ##

<dependency>
                <groupId>com.alibaba</groupId>
                <artifactId>dubbo</artifactId>
                <version>2.6.8</version>
            </dependency>
    
            <dependency>
                <groupId>org.apache.curator</groupId>
                <artifactId>curator-framework</artifactId>
                <version>5.1.0</version>
            </dependency>

## （2）配置服务提供者 ##

创建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="user-service-provider"></dubbo:application>
    
        <dubbo:registry address="zookeeper://127.0.0.1:2181"></dubbo:registry>
    
        <dubbo:protocol name="dubbo" port="20080"></dubbo:protocol>
    
        <dubbo:service interface="com.buba.service.UserService" ref="UserServiceImpl"></dubbo:service>
    
        <bean id="UserServiceImpl" class="com.buba.service.impl.UserServiceImpl"></bean>
    </beans>

## （3）测试 ##

编写测试代码：

package com.buba;
    
    import org.springframework.context.support.ClassPathXmlApplicationContext;
    
    public class Provider {
        public static void main(String[] args) throws Exception {
            ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(new String[]{"provider.xml"});
            context.start();
            System.in.read(); // 按任意键退出
        }
    }

启动zookeeper服务，然后启动zookeeper客户端，最后执行测试代码。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMjk4MzUx_size_16_color_FFFFFF_t_70][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMjk4MzUx_size_16_color_FFFFFF_t_70 1][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMjk4MzUx_size_16_color_FFFFFF_t_70 2][]

登录监控中心查看：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMjk4MzUx_size_16_color_FFFFFF_t_70 3][]

# 二、服务消费者配置与测试 #

## （1）引入依赖 ##

## （2）消费者配置文件 ##

<?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="order-service-consumer"></dubbo:application>
        
        <dubbo:registry address="zookeeper://127.0.0.1:2181"></dubbo:registry>
        
        <dubbo:reference interface="com.buba.service.UserService" id="userService"></dubbo:reference>
    
        <bean class="com.buba.service.impl.OrderServiceImpl" id="orderServiceImpl">
            <property name="userService" ref="userService"></property>
        </bean>
    </beans>

## （3）补全业务层的实现 ##

package com.buba.service.impl;
    
    import com.buba.pojo.UserAddress;
    import com.buba.service.OrderService;
    import com.buba.service.UserService;
    import org.springframework.beans.factory.annotation.Autowired;
    
    import java.util.List;
    
    public class OrderServiceImpl implements OrderService {
    
        private UserService userService;
    
        @Override
        public void initOrder(String userId) {
            List<UserAddress> userAddressList = userService.getUserAddressList("1");
            userAddressList.forEach(System.out::println);
        }
    
        public void setUserService(UserService userService) {
            this.userService = userService;
        }
    }

## （4）编写测试类执行测试 ##

package com.buba.controller;
    
    import com.buba.service.OrderService;
    import org.springframework.context.support.ClassPathXmlApplicationContext;
    
    import java.io.IOException;
    
    public class Test {
        public static void main(String[] args) throws IOException {
            ClassPathXmlApplicationContext classPathXmlApplicationContext = new ClassPathXmlApplicationContext("consumer.xml");
            OrderService bean = classPathXmlApplicationContext.getBean(OrderService.class);
            bean.initOrder("1");
            System.in.read();
        }
    }

![20210517211958590.png][]

在监控中心可以看到服务关系。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMjk4MzUx_size_16_color_FFFFFF_t_70 4][]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMjk4MzUx_size_16_color_FFFFFF_t_70]: /images/20221020/e4510a6b3b6348cf96bcae8a17d114b8.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMjk4MzUx_size_16_color_FFFFFF_t_70 1]: /images/20221020/8a52a1283f554ebd9e469a3572982fba.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMjk4MzUx_size_16_color_FFFFFF_t_70 2]: /images/20221020/8c992cfe6bf54f678336684e7fccab7b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMjk4MzUx_size_16_color_FFFFFF_t_70 3]: /images/20221020/d7d5c1c557764920bf31327979ebad26.png
[20210517211958590.png]: /images/20221020/bd23031321f64019bfb344822e154ea2.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMjk4MzUx_size_16_color_FFFFFF_t_70 4]: /images/20221020/d871d7815ad34870b5db2e38524c121c.png