doubbo+zookeeper服务注册发现

鱼找水需要时间

发布于 2023-02-16 15:17:54

2450

发布于 2023-02-16 15:17:54

文章被收录于专栏：SpringBoot教程

IDEA创建一个空项目；
创建一个模块，实现服务提供者：provider-server ，选择web依赖即可

Pom依赖：

  <!-- Dubbo Spring Boot Starter -->
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>2.7.3</version>
        </dependency>
        <dependency>
            <groupId>com.github.sgroschupf</groupId>
            <artifactId>zkclient</artifactId>
            <version>0.1</version>
        </dependency>
        <!-- 引入zookeeper -->
        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-framework</artifactId>
            <version>2.12.0</version>
        </dependency>
        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-recipes</artifactId>
            <version>2.12.0</version>
        </dependency>
        <dependency>
            <groupId>org.apache.zookeeper</groupId>
            <artifactId>zookeeper</artifactId>
            <version>3.4.14</version>
            <!--排除这个slf4j-log4j12-->
            <exclusions>
                <exclusion>
                    <groupId>org.slf4j</groupId>
                    <artifactId>slf4j-log4j12</artifactId>
                </exclusion>
            </exclusions>
        </dependency>

#当前应用名字
dubbo.application.name=provider-server
#注册中心地址
dubbo.registry.address=zookeeper://127.0.0.1:2181
#扫描指定包下服务
dubbo.scan.base-packages=com.example.service.impl

编写服务：TicketServiceImpl.java

@Service //将服务发布出去，这里一定要用 dubbo包下的
//亲测 @Component 无用，不会启动客户端的 zookeeper
public class TicketServiceImpl implements ITicketService {
    @Override
    public String getTicket() {
        return "一张票";
    }
}

启动测试服务提供者是否正常

开启zookeeper
打开dubbo-admin实现监控（可略过，只是方便查看）
开启服务者这步测试了好久，刚开始是service层没有用@Service，改完了还不行又换版本，最后清里idea的缓存重新运行就好了

消费服务

创建一个模块，实现服务提供者：consumer-server ，选择web依赖即可
引入pom依赖，同上

server.port=8002
# 谁消费了服务
dubbo.application.name=cunsumer-server
# 注册中心地址
dubbo.registry.address=zookeeper://127.0.0.1:2181

UserServiceImpl.java 将provider-server下 ITicketService 拷贝至consumer-server下（interface的目录一定要对应）

@Service  //这里是spring下的
public class UserServiceImpl implements IUserService {
    @Reference   // dubbo包下，Pom坐标，可以定义路径相同的接口名
    ITicketService ticketService;
    
    @Override
    public void buyTicket() {
       String string = ticketService.getTicket();
        System.out.println("买到了" + string);
    }
}

测试

@SpringBootTest
class ConsumerServerApplicationTests {
    @Autowired
    IUserService userService;

    @Test
    void contextLoads() {
        userService.buyTicket();
    }
}

结果：