Dubbo学习笔记

/**
 * 订单服务相关接口
 */
public interfaceOrderService {
    
    /**
     * 初始化订单
     * @param userId
     */List<User>initOrder(String userId);

}


public interfaceUserService {

    /**
     * 获取用户信息
     * @param userId
     * @return
     */List<User>getUserList(String userId);
    List<User>getUserAddressList(String userId);
}


user-service-provider
     <dependency>
            <groupId>com.darling.dubboDemo</groupId>
            <artifactId>pub-interfence</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>

            <!-- 引入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>



packagecom.provider.userserviceprovider.service;

importcom.pubinter.pubinterface.dao.UserService;
importcom.pubinter.pubinterface.pojo.User;

importjava.util.ArrayList;
importjava.util.List;

public class UserServiceImpl implementsUserService {


    public List<User>getUserAddressList(String userId) {
        List<User> list = newArrayList();
        list.add(new User(3,"韦德",36,"迈阿密"));
        list.add(new User(23,"詹姆斯",34,"洛杉矶"));
        list.add(new User(24,"科比",39,"洛杉矶"));
        returnlist;
    }

    @Override
    public List<User>getUserList(String userId) {
        return null;
    }
}


<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xmlns:dubbo="http://dubbo.apache.org/schema/dubbo"xmlns="http://www.springframework.org/schema/beans"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="user-service-provider"/>

    <!-- 注册中心的地址 这里注册中心用的是zookeeper -->
    <dubbo:registry protocol="zookeeper" address="148.70.4.44:2181"/>

    <!-- 指定通信规则（通信协议？通信端口） -->
    <dubbo:protocol name="dubbo" port="20883"></dubbo:protocol>

    <!-- 需要暴露的服务 -->
    <dubbo:service interface="com.pubinter.pubinterface.dao.UserService" ref="userService" version="1.0.0"/>

    <!-- 需要暴露的服务的实现类 -->
    <bean    />

    <!-- 监控中心协议，如果为protocol="registry"，表示从注册中心发现监控中心地址，否则直连监控中心 -->
    <dubbo:monitor protocol="registry"></dubbo:monitor>

    <!--timeout：超时时间配置
        retries：重试次数配置(超时报错后重试连接的次数,不含第一次调用,如果目标服务有多个重试的时候会自动切换别的服务)
     -->
    <dubbo:provider timeout="2000" retries="6"></dubbo:provider>
</beans>


public classTestProviderDemo {

    public static void main(String[] args) throwsIOException {
        // 加载配置文件
        ClassPathXmlApplicationContext applicationContext = new ClassPathXmlApplicationContext("provider.xml");
        // 容器启动
applicationContext.start();
        // 使程序阻塞(由于是单元测试,如果程序跑完了我们再dubbo控制台看不到效果)
System.in.read();
    }
}


不启用spring boot 主类，因为没必要，只启动了这个一个配置文件
order-service-consumer

      <!-- 引入公共接口层的依赖 -->
        <dependency>
            <groupId>com.darling.dubboDemo</groupId>
            <artifactId>pub-interfence</artifactId>
            <version>1.0-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>


    /**
 *   @author 董琳琳
 *   @date 2018/9/14 11:50
 *   @description   订单服务的实现类
 */@Service
public class OrderServiceImpl implementsOrderService {

    @Autowired
    UserService userService;

    /**
     * 初始化订单并调用用户服务的接口
     * @param userId
     * @return
     */@Override
    public List<User>initOrder(String userId) {
        returnuserService.getUserAddressList(userId);
    }
}


<?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">
    <!-- 开启springmvc的包扫描 -->
    <context:component-scan base-package="com.order.orderserviceconsumer"></context:component-scan>
    <!-- 当前服务的名称 -->
    <dubbo:application name="order-service-consumer"/>

    <!-- 注册中心的地址 这里注册中心用的是zookeeper -->
    <dubbo:registry protocol="zookeeper" address="148.70.4.44:2181"/>

    <!-- 声明需要调用的远程服务的接口；生成远程服务代理 -->
    <dubbo:reference   check="false" interface="com.pubinter.pubinterface.dao.UserService" version="*"/>

    <!-- 监控中心协议，如果为protocol="registry"，表示从注册中心发现监控中心地址，否则直连监控中心 -->
    <dubbo:monitor protocol="registry"></dubbo:monitor>
</beans>user必须实现serializable接口


必须要加扫描路径，不然会出错，找不到类
    <context:component-scan base-package="com.darling.order"></context:component-scan>

/**
 *   @author 董琳琳
 *   @date 2018/9/14 15:57
 *   @description 测试服务调用者是否成功从注册中心订阅服务
 */
public classTestConsumerDemo {
    public static void main(String[] args) throwsIOException {
        ClassPathXmlApplicationContext applicationContext = new ClassPathXmlApplicationContext("consumer.xml");
        OrderService service = applicationContext.getBean(OrderService.class);
        List<User> list = service.initOrder("1");
        for(User user:list) {
            System.out.println(user.toString());
        }
        System.in.read();
    }
}


importjava.io.Serializable;

public class User implementsSerializable {
    private static final long serialVersionUID = -2844400681715908324L;
    private intage;
    privateString name;
    privateString address;
    private intnumber;
    User(){};
    public User(int age,String name,intnumber,String address){
        this.address=address;
        this.age=age;
        this.number=number;
        this.name=name;
    }

    public intgetAge() {
        returnage;
    }

    public void setAge(intage) {
        this.age =age;
    }

    publicString getName() {
        returnname;
    }

    public voidsetName(String name) {
        this.name =name;
    }

    publicString getAddress() {
        returnaddress;
    }

    public voidsetAddress(String address) {
        this.address =address;
    }

    public intgetNumber() {
        returnnumber;
    }

    public void setNumber(intnumber) {
        this.number =number;
    }
}