dubbo学习

本是古典何须时尚 2022-05-08 02:46 176阅读 0赞

dubbo文档[http://dubbo.apache.org/zh-cn/docs/user/quick-start.html][http_dubbo.apache.org_zh-cn_docs_user_quick-start.html]

项目结构

![70][]

# api接口模块 #

![70 1][]

### 实体类 ###

package com.study.dubbo.bean;
    
    
    import java.io.Serializable;
    
    /**
     * 用户地址
     * @author lfy
     *
     */
    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方法省略...
    }

### 接口 ###

package com.study.dubbo.service;
    
    import com.study.dubbo.bean.UserAddress;
    
    import java.util.List;
    
    
    public interface OrderService {
    	
    	/**
    	 * 初始化订单
    	 * @param userId
    	 */
    	public List<UserAddress> initOrder(String userId);
    
    }

# 服务提供者 #

### 结构 ###

![70 2][]

### pom.xml ###

<?xml version="1.0" encoding="UTF-8"?>
    <project xmlns="http://maven.apache.org/POM/4.0.0"
             xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
             xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
        <parent>
            <artifactId>dubbo-project</artifactId>
            <groupId>com.study.dubbo</groupId>
            <version>1.0-SNAPSHOT</version>
        </parent>
        <modelVersion>4.0.0</modelVersion>
    
        <artifactId>user-service-provider</artifactId>
    
        <dependencies>
            <dependency>
            <groupId>com.study.dubbo</groupId>
            <artifactId>user-serice-api</artifactId>
        </dependency>
            
            
            <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>
            <dependency>
                <groupId>com.study.dubbo</groupId>
                <artifactId>user-serice-api</artifactId>
                <version>1.0-SNAPSHOT</version>
            </dependency>
            <dependency>
                <groupId>com.study.dubbo</groupId>
                <artifactId>user-serice-api</artifactId>
                <version>1.0-SNAPSHOT</version>
            </dependency>
        </dependencies>
    
    </project>

### 接口实现 ###

package com.study.dubbo.service.impl;
    
    import com.study.dubbo.bean.UserAddress;
    import com.study.dubbo.service.UserService;
    
    import java.util.Arrays;
    import java.util.List;
    
    
    
    public class UserServiceImpl implements UserService {
    
    	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);
    	}
    
    }

package com.study.dubbo.service.impl;
    
    import com.study.dubbo.bean.UserAddress;
    import com.study.dubbo.service.UserService;
    
    import java.util.Arrays;
    import java.util.List;
    
    
    
    public class UserServiceImpl2 implements UserService {
    
    	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);
    	}
    
    }

package com.study.dubbo.service.impl;
    
    import com.study.dubbo.bean.UserAddress;
    import com.study.dubbo.service.UserService;
    import org.springframework.util.StringUtils;
    
    import java.util.List;
    
    
    public class UserServiceStub implements UserService {
    	
    	private final UserService userService;
    	
    
    	/**
    	 * 传入的是userService远程的代理对象
    	 * @param userService
    	 */
    	public UserServiceStub(UserService userService) {
    		super();
    		this.userService = userService;
    	}
    
    
    	public List<UserAddress> getUserAddressList(String userId) {
    		// TODO Auto-generated method stub
    		System.out.println("UserServiceStub.....");
    		if(!StringUtils.isEmpty(userId)) {
    			return userService.getUserAddressList(userId);
    		}
    		return null;
    	}
    }

## 服务提供者配置 ##

<?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="user-service-provider"></dubbo:application>
    	
    	
    	
    	<dubbo:registry protocol="zookeeper" address="127.0.0.1:2181"></dubbo:registry>
    	
    	
    	<dubbo:protocol name="dubbo" port="20882"></dubbo:protocol>
    	
    	
    	<dubbo:service interface="com.study.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.study.dubbo.service.impl.UserServiceImpl"></bean>
    	
    	
    	<dubbo:service interface="com.study.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.study.dubbo.service.impl.UserServiceImpl2"></bean>
    	
    	
    	<dubbo:monitor protocol="registry"></dubbo:monitor>
    	
    </beans>

### 提供者注册 ###

package com.study.dubbo;
    
    import java.io.IOException;
    
    import org.springframework.context.ApplicationContext;
    import org.springframework.context.support.ClassPathXmlApplicationContext;
    
    public class MainApplication {
    	
    	public static void main(String[] args) throws IOException {
    		ClassPathXmlApplicationContext ioc = new ClassPathXmlApplicationContext("provider.xml");
    		ioc.start();
    		
    		System.in.read();
    	}
    
    }

# 服务消费者模块 #

### 结构 ###

![70 3][]

### pom.xml ###

<?xml version="1.0" encoding="UTF-8"?>
    <project xmlns="http://maven.apache.org/POM/4.0.0"
             xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
             xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
        <parent>
            <artifactId>dubbo-project</artifactId>
            <groupId>com.study.dubbo</groupId>
            <version>1.0-SNAPSHOT</version>
        </parent>
        <modelVersion>4.0.0</modelVersion>
    
        <artifactId>order-service-consumer</artifactId>
    
        <dependencies>
            <dependency>
                <groupId>com.study.dubbo</groupId>
                <artifactId>user-serice-api</artifactId>
            </dependency>
    
            
            
            <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>
            <dependency>
                <groupId>com.study.dubbo</groupId>
                <artifactId>user-serice-api</artifactId>
                <version>1.0-SNAPSHOT</version>
            </dependency>
        </dependencies>
    
    </project>

### 服务引用 ###

package com.study.dubbo.service.impl;
    
    import java.util.List;
    
    import com.study.dubbo.bean.UserAddress;
    import com.study.dubbo.service.OrderService;
    import com.study.dubbo.service.UserService;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Service;
    
    
    /**
     * 1、将服务提供者注册到注册中心（暴露服务）
     * 		1）、导入dubbo依赖（2.6.2）\操作zookeeper的客户端(curator)
     * 		2）、配置服务提供者
     * 
     * 2、让服务消费者去注册中心订阅服务提供者的服务地址
     * @author lfy
     *
     */
    @Service
    public class OrderServiceImpl implements OrderService {
    
    	@Autowired
    	UserService userService;
    
    	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;
    	}
    	
    	
    
    }
    package com.study.dubbo.service.impl;
    
    import java.util.List;
    
    import com.study.dubbo.bean.UserAddress;
    import com.study.dubbo.service.OrderService;
    import com.study.dubbo.service.UserService;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Service;
    
    
    /**
     * 1、将服务提供者注册到注册中心（暴露服务）
     * 		1）、导入dubbo依赖（2.6.2）\操作zookeeper的客户端(curator)
     * 		2）、配置服务提供者
     * 
     * 2、让服务消费者去注册中心订阅服务提供者的服务地址
     * @author lfy
     *
     */
    @Service
    public class OrderServiceImpl implements OrderService {
    
    	@Autowired
    	UserService userService;
    
    	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;
    	}
    }

### 消费者配置 ###

<?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.study.dubbo.service.impl"></context:component-scan>
    
    
    	<dubbo:application name="order-service-consumer"></dubbo:application>
    	
    	<dubbo:registry address="zookeeper://127.0.0.1:2181"></dubbo:registry>
    	
    	
    	
    	
    	
    	
    	
    	
    	<dubbo:reference interface="com.study.dubbo.service.UserService"
    		id="userService" timeout="5000" retries="3" version="*">
    		
    	</dubbo:reference>
    		
    	
    	<dubbo:consumer check="false" timeout="5000"></dubbo:consumer>
    
    	<dubbo:monitor protocol="registry"></dubbo:monitor>
    	
    	
    </beans>

### 消费者启动 ###

package com.study.dubbo;
    
    import java.io.IOException;
    
    import com.study.dubbo.service.OrderService;
    import org.springframework.context.support.ClassPathXmlApplicationContext;
    
    
    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();
    	}
    
    }

[http_dubbo.apache.org_zh-cn_docs_user_quick-start.html]: http://dubbo.apache.org/zh-cn/docs/user/quick-start.html
[70]: /images/20220508/0de26a4d5d9b43698a445bc7676f6c0b.png
[70 1]: /images/20220508/afbaba67e9df454da37ff4bf398ca5ee.png
[70 2]: /images/20220508/b401108c6f3f41be8fea5cfe87a2bcf8.png
[70 3]: /images/20220508/c346b6ea94da4eaab0da8d1192756214.png