SpringBoot2.x+Dubbo2.7.3+Zookeeper实现分布式项目开发

Dear 丶 2023-03-13 05:06 4阅读 0赞

### SpringBoot2.x+Dubbo2.7.3+Zookeeper实现分布式项目开发 ###

*   *   *   *  1.创建SpringBoot项目，引入dependency
             *  2.配置application.properties
             *  3.代码

#### 1.创建SpringBoot项目，引入dependency ####

Dubbo配置：

<dependency>
                <groupId>org.apache.dubbo</groupId>
                <artifactId>dubbo-spring-boot-starter</artifactId>
                <version>2.7.3</version>
            </dependency>

Zookeeper配置：

<dependency>
                <groupId>org.apache.zookeeper</groupId>
                <artifactId>zookeeper</artifactId>
                <version>3.6.0</version>
    
            </dependency>
            <dependency>
                <groupId>org.apache.curator</groupId>
                <artifactId>curator-recipes</artifactId>
                <version>2.11.1</version>
            </dependency>
            <dependency>
                <groupId>org.apache.curator</groupId>
                <artifactId>curator-framework</artifactId>
                <version>2.11.1</version>
            </dependency>

#### 2.配置application.properties ####

#dubbo服务名称
    dubbo.application.name=dubbo-ld-server
    #dubbo扫描的包路径
    dubbo.scan.base-packages=com.ld.service
    #注册中心id
    dubbo.registry.id=dubbo-registry-test
    #注册中心地址
    dubbo.registry.address=zookeeper://127.0.0.1:2181
    #元数据中心地址
    dubbo.metadata-report.address=zookeeper://127.0.0.1:2181
    #超时时间
    dubbo.provider.timeout=15000
    dubbo.protocol.name=dubbo
    dubbo.protocol.port=20880
    #dubbo.application.qos-enable=false

#### 3.代码 ####

接口

public interface DubboTestService { 
        public String aa(String name);
    }

实现

import com.ld.task.AsyncTask;
    import org.apache.dubbo.config.annotation.Service;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.http.ResponseEntity;
    import org.springframework.web.client.RestTemplate;
    
    import java.net.URI;
    import java.net.URISyntaxException;
    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.Future;
    
    @Service(version = "1.0.0")
    public class DubboTestServiceImpl implements DubboTestService { 
    
        @Autowired
        private RestTemplate restTemplate;
    
        @Autowired
        private AsyncTask asyncTask;
    
        @Override
        public String aa(String name) { 
            try { 
                URI uri = new URI("https://www.cnblogs.com/coderjinjian/ajax/GetViewCount.aspx?postId=9644923");
                ResponseEntity<String> responseEntity = restTemplate.getForEntity(uri,String.class);
                System.out.println(responseEntity.getBody());
            } catch (URISyntaxException e) { 
                e.printStackTrace();
            }
            return name;
        }
    }

test:

import com.ld.service.DubboTestService;
    import org.apache.dubbo.config.ApplicationConfig;
    import org.apache.dubbo.config.ReferenceConfig;
    import org.apache.dubbo.config.RegistryConfig;
    import org.apache.log4j.Logger;
    import org.junit.Test;
    
    //通过 API 方式使用泛化调用
    public class DubboTest { 
        private Logger logger = Logger.getLogger(DubboTest.class);
        @Test
        public void test(){ 
            ApplicationConfig application = new ApplicationConfig();
            application.setName("yyy");
    
    // 连接注册中心配置
            RegistryConfig registry = new RegistryConfig();
    // registry.setAddress("127.0.0.1:2182");
            registry.setAddress("zookeeper://127.0.0.1:2182?client=curator");
    // registry.setUsername("aaa");
    // registry.setPassword("bbb");
    
    // 注意：ReferenceConfig为重对象，内部封装了与注册中心的连接，以及与服务提供方的连接
    
    // 引用远程服务
            ReferenceConfig<DubboTestService> reference = new ReferenceConfig<>(); // 此实例很重，封装了与注册中心的连接以及与提供者的连接，请自行缓存，否则可能造成内存和连接泄漏
            reference.setApplication(application);
            reference.setRegistry(registry); // 多个注册中心可以用setRegistries()
            reference.setInterface(DubboTestService.class);
            reference.setVersion("1.0.0");
    
    // 和本地bean一样使用xxxService
            DubboTestService xxxService = reference.get();
            System.out.println(xxxService.aa("name"));
    
    }

注意：  
zk的dependency要和zk的版本相对应，如果不对应会启动时报。具体可以去官网看下说明。