spring整合dubbo服务消费和发现入门示例

文章目录

• ​​准备​​
• ​​公共接口部分​​
• ​​服务提供​​
• ​​服务消费​​

准备

1.启动zookeeper

目录

其中interface包下是公共接口
测试预期结果：
订单服务web模块在A服务器，用户服务模块在B服务器，A可以远程调用B的功能。

公共接口部分

public class UserAddress implements Serializable {
    
    private Integer id;
    private String userAddress; //用户地址
    private String userId; //用户id
    private String consignee; //收货人
    private String phoneNum; //电话号码
    private String isDefault; //是否为默认地址    Y-是     N-否
    
    public UserAddress() {
        super();
        // TODO Auto-generated constructor stub
    }
    
    public UserAddress(Integer id, String userAddress, String userId, String consignee, String phoneNum,
            String isDefault) {
        super();
        this.id = id;
        this.userAddress = userAddress;
        this.userId = userId;
        this.consignee = consignee;
        this.phoneNum = phoneNum;
        this.isDefault = isDefault;
    }
    //省略get set方法
    }

public interface OrderService {
  
  /**
   * 初始化订单
   * @param userId
   */
  public List<UserAddress> initOrder(String userId);

}

public interface UserService {
  
  /**
   * 按照用户id返回所有的收货地址
   * @param userId
   * @return
   */
  public List<UserAddress> getUserAddressList(String userId);

}

然后mvn package进行打包，可以看到target目录下生成的jar包：

服务提供

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://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">

  <!-- 1、指定当前服务/应用的名字（同样的服务名字相同，不要和别的服务同名） -->
  <dubbo:application name="user-service-provider"></dubbo:application>
  
  <!-- 2、指定注册中心的位置 -->
  <!-- <dubbo:registry address="zookeeper://127.0.0.1:2181"></dubbo:registry> -->
  <dubbo:registry protocol="zookeeper" address="127.0.0.1:2181"></dubbo:registry>
  
  <!-- 3、指定通信规则（通信协议？通信端口） -->
  <dubbo:protocol name="dubbo" port="20882"></dubbo:protocol>
  
  <!-- 4、暴露服务   ref：指向服务的真正的实现对象 -->
  <dubbo:service interface="com.dubbo.service.UserService"
    ref="userServiceImpl01" timeout="1000" version="1.0.0">
    <dubbo:method name="getUserAddressList" timeout="1000"></dubbo:method>
  </dubbo:service>
  
  <!--统一设置服务提供方的规则  -->
  <dubbo:provider timeout="1000"></dubbo:provider>
  
  
  <!-- 服务的实现 -->
  <bean id="userServiceImpl01" class="com.dubbo.bean.service.impl.UserServiceImpl"></bean>
  
  
  <dubbo:service interface="com.dubbo.service.UserService"
    ref="userServiceImpl02" timeout="1000" version="2.0.0">
    <dubbo:method name="getUserAddressList" timeout="1000"></dubbo:method>
  </dubbo:service>
  <bean id="userServiceImpl02" class="com.dubbo.bean.service.impl.UserServiceImpl2"></bean>
  
  <!-- 连接监控中心 -->
  <dubbo:monitor protocol="registry"></dubbo:monitor>
  
</beans>

public class UserServiceImpl implements UserService {

  @Override
  public List<UserAddress> getUserAddressList(String userId) {
    System.out.println("UserServiceImpl.....old...");
    // TODO Auto-generated method stub
    UserAddress address1 = new UserAddress(1, "北京市昌平区宏福科技园综合楼3层", "1", "李老师", "010-56253825", "Y");
    UserAddress address2 = new UserAddress(2, "深圳市宝安区西部硅谷大厦B座3层（深圳分校）", "1", "王老师", "010-56253825", "N");
    /*try {
      Thread.sleep(4000);
    } catch (InterruptedException e) {
      // TODO Auto-generated catch block
      e.printStackTrace();
    }*/
    return Arrays.asList(address1,address2);
  }

}

public class UserServiceImpl2 implements UserService {

  @Override
  public List<UserAddress> getUserAddressList(String userId) {
    System.out.println("UserServiceImpl.....new...");
    // TODO Auto-generated method stub
    UserAddress address1 = new UserAddress(1, "北京市昌平区宏福科技园综合楼3层", "1", "李老师", "010-56253825", "Y");
    UserAddress address2 = new UserAddress(2, "深圳市宝安区西部硅谷大厦B座3层（深圳分校）", "1", "王老师", "010-56253825", "N");
    
    return Arrays.asList(address1,address2);
  }

}

主启动类：

public class MainApplication {
  
  public static void main(String[] args) throws IOException {
    ClassPathXmlApplicationContext ioc = new ClassPathXmlApplicationContext("provider.xml");
    ioc.start();
    
    System.in.read();
  }

}

服务消费

consumer.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"
  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">
  <context:component-scan base-package="com.dubbo.bean.service.impl"></context:component-scan>


  <dubbo:application name="order-service-consumer"></dubbo:application>
  
  <dubbo:registry address="zookeeper://127.0.0.1:2181"></dubbo:registry>
  
  <!--  配置本地存根-->
  
  <!--声明需要调用的远程服务的接口；生成远程服务代理  -->
  <!-- 
    1）、精确优先 (方法级优先，接口级次之，全局配置再次之)
    2）、消费者设置优先(如果级别一样，则消费方优先，提供方次之)
  -->
  <!-- timeout="0" 默认是1000ms-->
  <!-- retries="":重试次数，不包含第一次调用，0代表不重试-->
  <!-- 幂等（设置重试次数）【查询、删除、修改】、非幂等（不能设置重试次数）【新增】 -->
  <dubbo:reference interface="com.dubbo.service.UserService"
    id="userService" timeout="5000" retries="3" version="*">
    <!-- <dubbo:method name="getUserAddressList" timeout="1000"></dubbo:method> -->
  </dubbo:reference>
    
  <!-- 配置当前消费者的统一规则：所有的服务都不检查 -->
  <dubbo:consumer check="false" timeout="5000"></dubbo:consumer>

  <dubbo:monitor protocol="registry"></dubbo:monitor>
  <!-- <dubbo:monitor address="127.0.0.1:7070"></dubbo:monitor> -->
  
</beans>

/**
 * 1、将服务提供者注册到注册中心（暴露服务）
 *    1）、导入dubbo依赖（2.6.2）\操作zookeeper的客户端(curator)
 *    2）、配置服务提供者
 * 
 * 2、让服务消费者去注册中心订阅服务提供者的服务地址
 * @author lfy
 *
 */
@Service
public class OrderServiceImpl implements OrderService {

  @Autowired
  UserService userService;
  @Override
  public List<UserAddress> initOrder(String userId) {
    // TODO Auto-generated method stub
    System.out.println("用户id："+userId);
    //1、查询用户的收货地址
    List<UserAddress> addressList = userService.getUserAddressList(userId);
    for (UserAddress userAddress : addressList) {
      System.out.println(userAddress.getUserAddress());
    }
    return addressList;
  }
  
  

}

这里 @Autowired导入的UserService 是公共接口中的UserService

主启动类

public class MainApplication {
  
  @SuppressWarnings("resource")
  public static void main(String[] args) throws IOException {
    ClassPathXmlApplicationContext applicationContext = new ClassPathXmlApplicationContext("consumer.xml");
    
    OrderService orderService = applicationContext.getBean(OrderService.class);
    
    orderService.initOrder("1");
    System.out.println("调用完成....");
    System.in.read();
  }

}

启动服务提供者再启动服务消费者结果：

访问initOrder请求，会调用UserService获取用户地址；

调用成功。说明我们order已经可以调用远程的UserService了；