基于SpringBoot的dubbo+zookeeper搭建分布式

迷南。 2022-05-20 08:54 311阅读 0赞

使用docker安装zookeeper

docker pull zookeeper
    docker run --name zk01 -p 2181:2181 --restart always -d 镜像id

写一个提供者

在pom.xml中添加依赖

<dependency>
                <groupId>com.github.sgroschupf</groupId>
                <artifactId>zkclient</artifactId>
                <version>0.1</version>
            </dependency>
            <dependency>
                <groupId>com.alibaba.boot</groupId>
                <artifactId>dubbo-spring-boot-starter</artifactId>
                <version>0.1.0</version>
            </dependency>

接着配置application,properties,  
配置其在dubbo注册中心的名字,  
配置注册中心的zookeeper的address  
配置扫描的包,这点与spring包扫描类似

dubbo.application.name=provider
    dubbo.registry.address=zookeeper://xxx.xxx.xxx.xxx:2181
    dubbo.scan.base-packages=com.lhc.service

写一个接口

package com.lhc.service;
    
    public interface TicketService {
    
        public String getTicket();
    }

写一个实现类,注意,@Service为dubbo的注解

package com.lhc.service.imp;
    
    import com.alibaba.dubbo.config.annotation.Service;
    import com.lhc.service.TicketService;
    import org.springframework.stereotype.Component;
    
    @Component
    @Service
    public class TicketServiceImp implements TicketService { 
        @Override
        public String getTicket() {
            return "get a ticket";
        }
    }

接着写一个消费者  
同样的,在pom.xml中添加dubbo和zookeeper的依赖

接着在application,properties中配置  
配置在注册中心的名字和注册中心zookeeper的address

dubbo.application.name=consumer
    dubbo.registry.address=zookeeper://xxx.xxx.xxx.xxx:2181

同样依赖之前的接口,因此,接口应该独立为一个maven的jar工程,加入provider和consumer的依赖中

package com.lhc.service;
    
    public interface TicketService {
    
        public String getTicket();
    }

接着调用provider的实现类,这里我们使用dubbo的@Reference的注解

package com.lhc.service;
    
    import com.alibaba.dubbo.config.annotation.Reference;
    import org.springframework.stereotype.Service;
    
    @Service
    public class UserService {
    
        @Reference
        TicketService ticketService;
    
        public void testdubbo(){
            System.out.println(ticketService.getTicket());
        }
    }

启动上一个provider的工程  
在consumer中做如下测试

package com.lhc;
    
    import com.lhc.service.UserService;
    import org.junit.Test;
    import org.junit.runner.RunWith;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.boot.test.context.SpringBootTest;
    import org.springframework.test.context.junit4.SpringRunner;
    
    @RunWith(SpringRunner.class)
    @SpringBootTest
    public class Dubbo02ApplicationTests {
    
    
    
        @Autowired
        UserService userService;
    
        @Test
        public void contextLoads() {
            userService.testdubbo();
        }
    
    }

可以看到打印出了get a ticket 说明整合完毕