通过Dubbo注解实现RPC调用

向右看齐 2022-05-18 06:52 212阅读 0赞

### pom.xml相关依赖 ###

<dependency>
                    <groupId>com.alibaba</groupId>
                    <artifactId>dubbo</artifactId>
                    <version>${dubbo.version}</version>
                </dependency>
    
                
                <dependency>
                    <groupId>org.apache.zookeeper</groupId>
                    <artifactId>zookeeper</artifactId>
                    <version>${zookeeper.version}</version>
                    <exclusions>
                        <exclusion>
                            <groupId>org.slf4j</groupId>
                            <artifactId>slf4j-log4j12</artifactId>
                        </exclusion>
                        <exclusion>
                            <groupId>log4j</groupId>
                            <artifactId>log4j</artifactId>
                        </exclusion>
                        <exclusion>
                            <groupId>io.netty</groupId>
                            <artifactId>netty</artifactId>
                        </exclusion>
                    </exclusions>
                </dependency>
                <dependency>
                    <groupId>org.apache.curator</groupId>
                    <artifactId>curator-framework</artifactId>
                    <version>${curator.version}</version>
                </dependency>
                <dependency>
                    <groupId>org.apache.curator</groupId>
                    <artifactId>curator-recipes</artifactId>
                    <version>${curator.version}</version>
                </dependency>
    
    
       <properties>
            <dubbo.version>2.6.2</dubbo.version>
            <zookeeper.version>3.4.13</zookeeper.version>
            <curator.version>4.0.1</curator.version>
        </properties>

## ##

### 启动Dubbo服务有2个方式，1是通过xml配置，2是通过注解来实现，这点和Spring相似。 ###

采用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:context="http://www.springframework.org/schema/context"
    	   xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx"
    	   xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
    	   xsi:schemaLocation="http://www.springframework.org/schema/beans
                http://www.springframework.org/schema/beans/spring-beans-4.0.xsd
                http://www.springframework.org/schema/context
                http://www.springframework.org/schema/context/spring-context-4.0.xsd
                http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-4.0.xsd
                http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.0.xsd
    			 http://code.alibabatech.com/schema/dubbo
        		 http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
    	<description>dubbo-provider配置</description>
    
    	
    	<dubbo:application name="dubbo_provider"  />
    
    	
    	
    	
    	<dubbo:registry address="zookeeper://192.168.2.2:2181" check="false" subscribe="false"/>
    
    	
    	<dubbo:protocol name="dubbo" port="20880" />
    
    	
    	<dubbo:service interface="com.custom.dubbo.api.service.DemoService" ref="demoService" />
    
    	
    	<bean id="demoService" class="com.custom.dubbo.provider.service.DemoServiceImpl" />
    
    </beans>

上面代码是通过dubbo:service interface标签把接口暴露出去,在程序启动的时候会自动注册到zookeeper。

通过下面方式启动服务

import org.springframework.context.support.ClassPathXmlApplicationContext;
    
    
    public class DubboProvider {
        public static void main(String[] args) throws Exception {
            ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(new String[] { "dubbo-provider.xml" });
            context.start();
            System.in.read(); // 为保证服务一直开着，利用输入流的阻塞来模拟
        }
    }

消费端调用方式配置如下：

<?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:context="http://www.springframework.org/schema/context"
    	   xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx"
    	   xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
    	   xsi:schemaLocation="http://www.springframework.org/schema/beans
                http://www.springframework.org/schema/beans/spring-beans-4.0.xsd
                http://www.springframework.org/schema/context
                http://www.springframework.org/schema/context/spring-context-4.0.xsd
                http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-4.0.xsd
                http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.0.xsd
    			 http://code.alibabatech.com/schema/dubbo
        		 http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
    	<description>dubbo-provider配置</description>
    
    	
    	<dubbo:application name="dubbo_consumer" />
    
    	
    	
    	<dubbo:registry address="zookeeper://192.168.2.2:2181" check="false"></dubbo:registry>
    
    	
    	<dubbo:reference interface="com.custom.dubbo.api.service.DemoService" id="demoService"></dubbo:reference>
    
    </beans>

applicationContext-consumer.xml配置如下：

然后我们可以像spring一样调用本地服务,代码如下：

import com.custom.dubbo.consumer.service.DubboConsumerService;
    import org.springframework.context.support.ClassPathXmlApplicationContext;
    
    
    public class DubboConsumer {
        public static void main(String[] args) throws Exception {
            ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(new String[] { "applicationContext-consumer.xml" });
            context.start();
            DubboConsumerService dubboConsumerService = (DubboConsumerService) context.getBean("dubboConsumerService");
            dubboConsumerService.print();
            System.in.read(); // 为保证服务一直开着，利用输入流的阻塞来模拟
        }
    }

DubboConsumerServicee类如下：

import com.alibaba.fastjson.JSON;
    import com.custom.dubbo.api.service.DemoService;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Component;
    
    import java.util.List;
    
    
    @Component
    public class DubboConsumerService {
        @Autowired
        private DemoService demoService;
    
    
        public void print(){
            System.out.println("DemoService===============");
            String hello = demoService.sayHello("dubbo consumer");
            System.out.println(hello);
    
            List list = demoService.getUsers();
            if (list != null && list.size() > 0) {
                for (int i = 0; i < list.size(); i++) {
                    System.out.println(JSON.toJSON(list.get(i)));
                }
            }
           
        }
    }

上面的是采用xml方式配置dubbo，下面是通过注解配置dubbo。

通过注解方式配置的dubbo-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:context="http://www.springframework.org/schema/context"
    	   xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx"
    	   xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
    	   xsi:schemaLocation="http://www.springframework.org/schema/beans
                http://www.springframework.org/schema/beans/spring-beans-4.0.xsd
                http://www.springframework.org/schema/context
                http://www.springframework.org/schema/context/spring-context-4.0.xsd
                http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-4.0.xsd
                http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.0.xsd
    			 http://code.alibabatech.com/schema/dubbo
        		 http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
    	<description>dubbo-provider配置</description>
    
    	
    	<dubbo:application name="dubbo_provider"  />
    
    	
    	
    	
    	<dubbo:registry address="zookeeper://192.168.2.2:2181" check="false" subscribe="false"/>
    
    	
    	<dubbo:protocol name="dubbo" port="20880" />
    
    	
    	<dubbo:annotation package="com.custom.dubbo.provider.service" />
    </beans>

通过注解方式暴露的服务实现类如下

import com.alibaba.dubbo.config.annotation.Service;
    import com.custom.dubbo.api.service.TestService;
    import com.custom.dubbo.provider.model.User;
    
    import java.util.ArrayList;
    import java.util.List;
    
    
    @Service(version = "1.0.0", interfaceClass = TestService.class)
    public class TestServiceImpl implements TestService{
        @Override
        public String sayHello(String name) {
            return "Hello " + name;
        }
        @Override
        public List getUsers() {
            List list = new ArrayList();
            User u1 = new User();
            u1.setName("hejingyuan");
            u1.setAge(20);
            u1.setSex("f");
    
            User u2 = new User();
            u2.setName("xvshu");
            u2.setAge(21);
            u2.setSex("m");
    
    
            list.add(u1);
            list.add(u2);
    
            return list;
        }
    }

通过注解方式配置的dubbo-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:context="http://www.springframework.org/schema/context"
    	   xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx"
    	   xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
    	   xsi:schemaLocation="http://www.springframework.org/schema/beans
                http://www.springframework.org/schema/beans/spring-beans-4.0.xsd
                http://www.springframework.org/schema/context
                http://www.springframework.org/schema/context/spring-context-4.0.xsd
                http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-4.0.xsd
                http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.0.xsd
    			 http://code.alibabatech.com/schema/dubbo
        		 http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
    	<description>dubbo-provider配置</description>
    
    	
    	<dubbo:application name="dubbo_consumer" />
    
    	
    	
    	<dubbo:registry address="zookeeper://192.168.2.2:2181" check="false"></dubbo:registry>
    
    	
    	<dubbo:annotation package="com.custom.dubbo.api.service"/>
    </beans>

消费端注解方式调用类如下：

import com.alibaba.dubbo.config.annotation.Reference;
    import com.alibaba.fastjson.JSON;
    import com.custom.dubbo.api.service.TestNewService;
    import com.custom.dubbo.api.service.TestService;
    import org.springframework.stereotype.Component;
    
    import java.util.List;
    
    /**
     * Copyright (C), 2011-2018 {company}
     * FileName: com.custom.dubbo.consumer.service.DubboConsumer.java
     * Author: xxx
     * Email: xxx
     * Date: 2018/7/31 13:26
     * Description:
     * History:
     * <Author>      <Time>    <version>    <desc>
     * {xxx}   13:26    1.0          Create
     */
    @Component
    public class DubboConsumerService {
        @Reference
        private TestService testService;
    
    
        public void print(){
            String hello = testService.sayHello("dubbo consumer");
            System.out.println(hello);
    
            List list = testService.getUsers();
            if (list != null && list.size() > 0) {
                for (int i = 0; i < list.size(); i++) {
                    System.out.println(JSON.toJSON(list.get(i)));
                }
            }
    
        }
    }