Dubbo--集成SpringBoot

电玩女神 2021-08-27 02:51 495阅读 0赞

#### 创建Maven 工程 (dubbo\_test) ####

引入依赖：

<dependencies>
            
            <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>
        </dependencies>

创建子模块：（myinterface）

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NvbGRfX19wbGF5_size_16_color_FFFFFF_t_70]

实体类：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();
    		// 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;
    	}
    	
    	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;
    	}
    
    
    	@Override
    	public String toString() { 
    		return "UserAddress{" +
    				"id=" + id +
    				", userAddress='" + userAddress + '\'' +
    				", userId='" + userId + '\'' +
    				", consignee='" + consignee + '\'' +
    				", phoneNum='" + phoneNum + '\'' +
    				", isDefault='" + isDefault + '\'' +
    				'}';
    	}
    }

UserService

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

OrderService

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

创建用户子模块：(user-service)  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NvbGRfX19wbGF5_size_16_color_FFFFFF_t_70 1]

引入依赖：

<?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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
        <modelVersion>4.0.0</modelVersion>
        <parent>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <version>2.2.4.RELEASE</version>
            <relativePath/> 
        </parent>
        <groupId>pers.zhang</groupId>
        <artifactId>user-service</artifactId>
        <version>0.0.1-SNAPSHOT</version>
        <name>user-service</name>
        <description>Demo project for Spring Boot</description>
    
        <properties>
            <java.version>1.8</java.version>
        </properties>
    
        <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter</artifactId>
            </dependency>
    
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
                <exclusions>
                    <exclusion>
                        <groupId>org.junit.vintage</groupId>
                        <artifactId>junit-vintage-engine</artifactId>
                    </exclusion>
                </exclusions>
            </dependency>
            <dependency>
                <groupId>pers.zhang</groupId>
                <artifactId>myinterface</artifactId>
                <version>1.0-SNAPSHOT</version>
            </dependency>
    
            
            <dependency>
                <groupId>com.alibaba.boot</groupId>
                <artifactId>dubbo-spring-boot-starter</artifactId>
                <version>0.2.0</version>
            </dependency>
        </dependencies>
    
        <build>
            <plugins>
                <plugin>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-maven-plugin</artifactId>
                </plugin>
            </plugins>
        </build>
    
    </project>

实现UserService：

@com.alibaba.dubbo.config.annotation.Service //暴露服务
    @Component
    public class UserServiceImpl implements UserService { 
    
        public List<UserAddress> getUserAddressList(String userId) { 
            UserAddress address1 = new UserAddress(1, "北京市昌平区宏福科技园综合楼3层","1","李老师","101-56253825", "Y");
            UserAddress address2 = new UserAddress(2, "深圳市宝安区西部硅谷大厦B座3层","1","王老师", "010-562531", "N");
            return Arrays.asList(address1, address2);
        }
    }

配置Dubbo（application.properties）

dubbo.application.name=user-service
    dubbo.registry.address=127.0.0.1:2181
    dubbo.registry.protocol=zookeeper
    dubbo.protocol.name=dubbo
    dubbo.protocol.port=20880
    dubbo.monitor.protocol=registry
    
            
    spring.http.encoding.force=true
    spring.http.encoding.charset=UTF-8
    spring.http.encoding.enabled=true
    server.tomcat.uri-encoding=UTF-8

启动类：

@EnableDubbo //开启基于注解的dubbo配置
    @SpringBootApplication
    public class UserServiceApplication { 
    
        public static void main(String[] args) { 
            SpringApplication.run(UserServiceApplication.class, args);
        }
    
    }

创建Order子模块：(order-service)  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NvbGRfX19wbGF5_size_16_color_FFFFFF_t_70 2]

引入依赖：

<?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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
        <modelVersion>4.0.0</modelVersion>
        <parent>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <version>2.2.4.RELEASE</version>
            <relativePath/> 
        </parent>
        <groupId>pers.zhang</groupId>
        <artifactId>order-service</artifactId>
        <version>0.0.1-SNAPSHOT</version>
        <name>order-service</name>
        <description>Demo project for Spring Boot</description>
    
        <properties>
            <java.version>1.8</java.version>
        </properties>
    
        <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter</artifactId>
            </dependency>
    
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
                <exclusions>
                    <exclusion>
                        <groupId>org.junit.vintage</groupId>
                        <artifactId>junit-vintage-engine</artifactId>
                    </exclusion>
                </exclusions>
            </dependency>
            <dependency>
                <groupId>pers.zhang</groupId>
                <artifactId>myinterface</artifactId>
                <version>1.0-SNAPSHOT</version>
            </dependency>
    
            
            <dependency>
                <groupId>com.alibaba.boot</groupId>
                <artifactId>dubbo-spring-boot-starter</artifactId>
                <version>0.2.0</version>
            </dependency>
    
        </dependencies>
    
        <build>
            <plugins>
                <plugin>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-maven-plugin</artifactId>
                </plugin>
            </plugins>
        </build>
    
    </project>

实现OrderService：

@Service
    public class OrderServiceImpl implements OrderService { 
    
        @Reference //Bubbo提供，自动发现已注册的服务，远程引用
        UserService userService;
    
        public List<UserAddress> initOrder(String userId) { 
            System.out.println(userId);
            //调用UserService查询用户收货地址
            List<UserAddress> userAddressList = userService.getUserAddressList(userId);
            return userAddressList;
        }
    }

Controller：

@Controller
    public class OrderController { 
    
        @Autowired
        OrderService orderService;
    
        @ResponseBody
        @RequestMapping("/initOrder")
        public List<UserAddress> initOrder(@RequestParam("uid") String userId){ 
            return orderService.initOrder(userId);
        }
    }

配置Dubbo（application.properties）

server.port=8081
    
    dubbo.application.name=order-service
    dubbo.registry.address=zookeeper://127.0.0.1:2181
    dubbo.monitor.protocol=registry
    
    
    spring.http.encoding.force=true
    spring.http.encoding.charset=UTF-8
    spring.http.encoding.enabled=true
    server.tomcat.uri-encoding=UTF-8

启动类：

@EnableDubbo
    @SpringBootApplication
    public class OrderServiceApplication { 
    
        public static void main(String[] args) { 
            SpringApplication.run(OrderServiceApplication.class, args);
        }
    
    }

### 测试 ###

启动zookeepter  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NvbGRfX19wbGF5_size_16_color_FFFFFF_t_70 3]

启动user模块，启动order模块。

访问localhost:8081/initOrder?uid=1

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NvbGRfX19wbGF5_size_16_color_FFFFFF_t_70 4]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NvbGRfX19wbGF5_size_16_color_FFFFFF_t_70]: /images/20210813/990494385a0f4a87abf2b9ed0aaed10e.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NvbGRfX19wbGF5_size_16_color_FFFFFF_t_70 1]: /images/20210813/fba0cd56c83f40c6ae9027fcf05cafe7.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NvbGRfX19wbGF5_size_16_color_FFFFFF_t_70 2]: /images/20210813/5141a2614f96456fbd8df0937df9899d.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NvbGRfX19wbGF5_size_16_color_FFFFFF_t_70 3]: /images/20210813/32c180e735d84a73b8784898830fb990.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NvbGRfX19wbGF5_size_16_color_FFFFFF_t_70 4]: /images/20210813/14121e4a16b04970988101858656faf3.png