Dubbo系列四：基本使用

￡神魔★判官ぃ 2022-02-13 10:11 218阅读 0赞

一、引入依赖

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

二、创建服务提供者service-provider  
1、创建实体UserAddress

/**用户地址*/
    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();
    	}
        
    	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;
    	}
    	
    	public Integer getId() {
    		return id;
    	}
    	public void setId(Integer id) {
    		this.id = id;
    	}
    	public String getUserAddress() {
    		return userAddress;
    	}
    	public void setUserAddress(String userAddress) {
    		this.userAddress = userAddress;
    	}
    	public String getUserId() {
    		return userId;
    	}
    	public void setUserId(String userId) {
    		this.userId = userId;
    	}
    	public String getConsignee() {
    		return consignee;
    	}
    	public void setConsignee(String consignee) {
    		this.consignee = consignee;
    	}
    	public String getPhoneNum() {
    		return phoneNum;
    	}
    	public void setPhoneNum(String phoneNum) {
    		this.phoneNum = phoneNum;
    	}
    	public String getIsDefault() {
    		return isDefault;
    	}
    	public void setIsDefault(String isDefault) {
    		this.isDefault = isDefault;
    	}
    
    }

2、创建接口UserService

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

3、创建UserService接口的实现类UserServiceImpl

public class UserServiceImpl implements UserService {
    
    	public List<UserAddress> getUserAddressList(String userId) {
    		UserAddress address1 = new UserAddress(1, "北京市昌平区宏福科技园综合楼3层", "1", "李老师", "010-56253825", "Y");
    		UserAddress address2 = new UserAddress(2, "深圳市宝安区西部硅谷大厦B座3层（深圳分校）", "1", "王老师", "010-56253825", "N");
    		try {
    			Thread.sleep(10); //测试超时属性
    		} catch (InterruptedException e) {
    			e.printStackTrace();
    		}
    		return Arrays.asList(address1,address2);
    	}
    }

4、创建配置文件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">
    
    	
    	<dubbo:application name="service-provider"></dubbo:application>
    	
    	
    	<dubbo:registry protocol="zookeeper" address="127.0.0.1:2181"></dubbo:registry>
    	
    	
    	
    	<dubbo:protocol name="dubbo" port="20881"></dubbo:protocol>
    	
    	
    	
    	<dubbo:service interface="com.atguigu.gmall.service.UserService"
    				   ref="userServiceImpl" timeout="1000">
    		
    		<dubbo:method name="getUserAddressList" timeout="1000"></dubbo:method>
    	</dubbo:service>
    
    	
    	<dubbo:provider timeout="1000"></dubbo:provider>
    
    	
    	<bean id="userServiceImpl" class="com.atguigu.gmall.service.impl.UserServiceImpl"></bean>
    
    	
    	<dubbo:monitor protocol="registry"></dubbo:monitor>
    	
    </beans>

5、将服务提供者注册进zookeeper

/**启动ioc容器将服务提供者注册进zookeeper注册中心中*/
    public static void main(String[] args) throws IOException {
    	ClassPathXmlApplicationContext ioc = new ClassPathXmlApplicationContext("provider.xml");
    	ioc.start();
    	
    	System.in.read();
    }

三、创建服务消费者service-consumer  
1、创建接口OrderService

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

2、创建接口OrderService 的实现类OrderServiceImpl

/**
     * 1、将服务提供者注册到注册中心
     *    1）、导入dubbo依赖（2.6.2）、操作zookeeper的客户端(curator)
     *    2）、配置服务提供者
     * 2、让服务消费者去注册中心订阅服务提供者的服务地址
     */
    @Service
    public class OrderServiceImpl implements OrderService {
    
        @Autowired
        UserService userService;
    
        public List<UserAddress> initOrder(String userId) {
            System.out.println("用户id："+userId);
            //1、查询用户的收货地址
            List<UserAddress> userAddressList = userService.getUserAddressList(userId);
            for (UserAddress userAddress : userAddressList){
                System.out.println(userAddress.getUserAddress());
            }
            return null;
        }
    }

3、编写配置文件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.atguigu.gmall.service.impl"></context:component-scan>
    
        
    	<dubbo:application name="service-consumer"></dubbo:application>
    
        
        <dubbo:registry protocol="zookeeper" address="127.0.0.1:2181"></dubbo:registry>
        
    
    	
    	
    	
    	
    	<dubbo:reference interface="com.atguigu.gmall.service.UserService"
    					 id="userService" timeout="5000" retries="3" stub="com.atguigu.gmall.service.impl.UserServiceStub">
    		
    		<dubbo:method name="getUserAddressList" timeout="1000"></dubbo:method>
    	</dubbo:reference>
    
    	
    	<dubbo:consumer check="false" timeout="5000"></dubbo:consumer>
    
        
        <dubbo:monitor protocol="registry"></dubbo:monitor>
        
    </beans>

4、测试远程调用提供者

@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();
    }

![在这里插入图片描述][20190427182004662.png]

[20190427182004662.png]: /images/20220213/c9132582412f4eb7b2cc7d8f79ec1280.png