Dubbo管控台安装 2020-04-08 阅读次数：

一、api

根据dubbo官网服务化最佳实践，建议将服务接口、服务模型、服务异常等均放在 API 包中。

我这里在api项目定义了服务接口

public interface UserService {
    public String getUsername(int uid);
}

public interface OrderService {
    public void initOrder(int uid);
}

二、provider

项目依赖如下,包括对公共接口、dubbo、以及注册中心zookeeper的依赖。

  <dependencies>
    <dependency>
      <groupId>tech.lazyrabbit.dubbotest</groupId>
      <artifactId>z-dubbo-interface</artifactId>
      <version>0.0.1-SNAPSHOT</version>
    </dependency>
    <!-- https://mvnrepository.com/artifact/com.alibaba/dubbo -->
    <dependency>
      <groupId>com.alibaba</groupId>
      <artifactId>dubbo</artifactId>
      <version>2.6.5</version>
    </dependency>
    <!-- https://mvnrepository.com/artifact/org.apache.curator/curator-recipes -->
    <dependency>
      <groupId>org.apache.curator</groupId>
      <artifactId>curator-recipes</artifactId>
      <version>2.12.0</version>
    </dependency>
  </dependencies>

在提供者项目中提供了一个UserService的实现类

public class UserServiceImpl implements UserService {

    @Override
    public String getUsername(int uid) {
        // TODO Auto-generated method stub
        return uid + "_lazyrabbit";
    }

}

利用spring配置来声明暴露服务

<?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-4.3.xsd        http://dubbo.apache.org/schema/dubbo        http://dubbo.apache.org/schema/dubbo/dubbo.xsd">
 
    <!-- 提供方应用信息，用于计算依赖关系 -->
    <dubbo:application name="z-dubbo-user-service-provider" />

    <!-- 使用multicast广播注册中心暴露服务地址 -->
    <dubbo:registry address="zookeeper://127.0.0.1:2181" ></dubbo:registry>

    <!-- 用dubbo协议在20880端口暴露服务 -->
    <dubbo:protocol name="dubbo" port="20880" />

    <!-- 声明需要暴露的服务接口 -->
    <dubbo:service interface="tech.lazyrabbit.dubbotest.service.UserService"
        ref="userServiceImpl" />

    <!-- 和本地bean一样实现服务 -->
    <bean id="userServiceImpl" class="tech.lazyrabbit.dubbotest.service.impl.UserServiceImpl" />
</beans>

加载 Spring 配置，测试提供者

    public static void main(String[] args) {
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("provider.xml");
        context.start();
        try {
            System.in.read();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }

三、consummer

pom.xml配置见提供者中配置

在消费者项目中实现了OrderService，并通过dubbo远程调用userService。

@Service
public class OrderServiceImpl implements OrderService {

    @Autowired
    UserService userService;

    @Override
    public void initOrder(int uid) {
        // TODO Auto-generated method stub
        System.out.println(userService.getUsername(uid));
    }

}

通过 Spring 配置引用远程服务

<?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/context        http://www.springframework.org/schema/context/spring-context-4.3.xsd        http://www.springframework.org/schema/beans        http://www.springframework.org/schema/beans/spring-beans-4.3.xsd        http://dubbo.apache.org/schema/dubbo        http://dubbo.apache.org/schema/dubbo/dubbo.xsd">

    <context:component-scan base-package="tech.lazyrabbit"/>
    
    <!-- 消费方应用名，用于计算依赖关系，不是匹配条件，不要与提供方一样 -->
    <dubbo:application name="z-dubbo-order-service-consumer" />

    <!-- 使用multicast广播注册中心暴露发现服务地址 -->
    <dubbo:registry address="zookeeper://127.0.0.1:2181" />

    <!-- 生成远程服务代理，可以和本地bean一样使用demoService -->
    <dubbo:reference id="userService"
        interface="tech.lazyrabbit.dubbotest.service.UserService" />
</beans>

加载Spring配置，并调用远程服务

    public static void main(String[] args) {
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("consumer.xml");
        OrderService orderService = context.getBean(OrderService.class);
        orderService.initOrder(1);
        System.out.println("第1次调用完成！");
        try {
            System.in.read();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }