springboot、springMVC整合dubbo服务

谁借莪１个温暖的怀抱￠ 2022-02-17 09:13 301阅读 0赞

## 项目 ##

新建一个项目，里面建三个Module分别代表暴露接口、服务提供者、消费者  
![在这里插入图片描述][20190419164411547.jpg]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2gyNzM5Nzk1ODY_size_16_color_FFFFFF_t_70]

## 引用依赖 ##

*  springboot  
    在consumer提供者项目引用pom依赖

<dependency>
    			<groupId>com.alibaba.boot</groupId>
    			<artifactId>dubbo-spring-boot-starter</artifactId>
    			<version>0.2.0</version>
    	</dependency>

*  springmvc

<dependency>
                <groupId>com.alibaba</groupId>
                <artifactId>dubbo</artifactId>
                <version>2.6.4</version>
            </dependency>
            <dependency>
                <groupId>org.apache.zookeeper</groupId>
                <artifactId>zookeeper</artifactId>
                <version>3.4.10</version>
            </dependency>
            <dependency>
                <groupId>com.101tec</groupId>
                <artifactId>zkclient</artifactId>
                <version>0.10</version>
            </dependency>

## 生产者 ##

在interface中写几个接口，并有consumer项目实现这个接口

实现类需要注入@service（使用dubbo的包）和@component实现类代码如下：

import com.alibaba.dubbo.config.annotation.Service;
    import com.zang.gmall.bean.UserAddress;
    import com.zang.gmall.service.UserService;
    import org.springframework.stereotype.Component;
    
    import java.util.Arrays;
    import java.util.List;
    
    @Service   //属于Dubbo的@Service注解，非Spring 作用：暴露服务
    @Component
    public class UserServiceImpl implements UserService { 
    
        @Override
        public List<UserAddress> getUserAddressList(String userId) { 
        	//省略
    	}
    }

## 生产者配置application.properties ##

## dubbo
    #当前服务/应用的名字
    dubbo.application.name=user-service-provider
    #注册中心的协议和地址
    dubbo.registry.protocol=zookeeper
    dubbo.registry.address=IP:2181
    #通信规则（通信协议和接口）
    dubbo.protocol.name=dubbo
    dubbo.protocol.port=20880
    #连接监控中心
    dubbo.monitor.protocol=registry

*  如果是mvc项目需要一个xml文件

<?xml version="1.0" encoding="UTF-8"?>
    <beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/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.xsd http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd ">
    
        
        <dubbo:application name="authorizationManagement-web"/>
    
        <dubbo:protocol name="dubbo" port="20870"/>
        
        
        <dubbo:registry protocol="zookeeper" address="IP:2181" register="true"/>
        
        
        
    	
        <dubbo:service interface="暴露接口包路径" ref="helloService"/>
    
        <bean id="helloService" class="暴露实现包接口路径"/>    
    
        <dubbo:provider timeout="300000" group="local"/>
        <dubbo:consumer check="false" timeout="300000" group="local"/>
        
    </beans>

并在启动类上加@EnableDubbo注解  
![在这里插入图片描述][20190419170436531.jpg]

## 消费者配置文件 ##

和提供者引用的引用pom一样

#避免和监控中心端口冲突，设为8081端口访问
    server.port=8081  
    
    dubbo.application.name=order-service-consumer
    dubbo.registry.address=zookeeper://IP:2181
    dubbo.monitor.protocol=registry

*  如果是mvc项目需要一个xml文件

<?xml version="1.0" encoding="UTF-8"?>
    <beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/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.xsd http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd ">
    
        
        <dubbo:application name="dubbo-client"/>
    
        <dubbo:protocol name="dubbo" port="20870"/>
        
    	
        
        
        
    	
        <dubbo:reference id="helloService" interface="引用服务提供者暴露接口包路径"/>
    
    	
        
    
    
    </beans>

需要引用dubbo服务采用注入方式。

import com.alibaba.dubbo.config.annotation.Reference;
    import com.zang.gmall.bean.UserAddress;
    import com.zang.gmall.service.OrderService;
    import com.zang.gmall.service.UserService;
    import org.springframework.stereotype.Service;
    
    import java.util.List;
    
    @Service
    public class OrderServiceImpl implements OrderService { 
    
        @Reference
        UserService userService;
    
        @Override
        public List<UserAddress> initOrder(String userId) { 
    　　//代码省略
       }
    }

在启动类添加@EnableDubbo注解  
![在这里插入图片描述][20190419172030406.jpg]

[20190419164411547.jpg]: /images/20220217/4cf054e181f9410c82c9d8303c5331d9.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2gyNzM5Nzk1ODY_size_16_color_FFFFFF_t_70]: /images/20220217/f99f9a3cfc6a46dd902f407886d2cadd.png
[20190419170436531.jpg]: /images/20220217/89c413f584d84dd0b84ea40177e4cb9d.png
[20190419172030406.jpg]: /images/20220217/280c58312b87485a9550a93deebdcff3.png