zookeeper和dubbo简单使用

阅读数: 次 2021-01-20

1. 在docker中安装和启动zookeeper
1. 卖票和买票的例子
1. 总结

dubbo和zookeeper

Dubbo是一款高性能、轻量级的开源Java RPC框架，它提供了三大核心能力：面向接口的远程方法调用，智能容错和负载均衡，以及服务自动注册和发现。
ZooKeeper是一个分布式的，开放源码的分布式应用程序协调服务，是Google的Chubby一个开源的实现，是Hadoop和Hbase的重要组件。它是一个为分布式应用提供一致性服务的软件，提供的功能包括：配置维护、域名服务、分布式同步、组服务等。

dubbo实现各模块的rpc调用，而zookeeper相当于一个管理员。各模块需要先在zookeeper中注册，如果A模块想使用B模块的服务，先要到zookeeper中找到B的地址，然后使用rpc调用。

1. 在docker中安装和启动zookeeper

1 2	docker pull docker.io/zookeeper docker run -d --name ZK01 -p 2181:2181 --restart always 28ffb774bc32

2. 卖票和买票的例子

在idea中创建两个模块，买票模块和卖票模块
在两个模块的pom文件中加入dubbo和zkclient的依赖

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

<!--zookeeper的客户端依赖-->
<dependency>
    <groupId>com.github.sgroschupf</groupId>
    <artifactId>zkclient</artifactId>
    <version>0.1</version>
</dependency>

在卖票模块的配置文件中配置注册中心的地址，要扫描的包（要注册的服务）

dubbo.application.name=provider.ticket

dubbo.registry.address=zookeeper://192.168.124.6:2181

dubbo.scan.base-packages=com.hjznb.provider.service

在买票模块中编写服务代码，在要发布的类上加上dubbo的service注解，会将该服务发布出去

package com.hjznb.provider.service;

import com.alibaba.dubbo.config.annotation.Service;
import org.springframework.stereotype.Component;

@Component
@Service    //将服务发布出去，dubbo的注解
public class TicketServiceImpl implements TicketService {
    @Override
    public String getTicket() {
        return "《泰坦尼克号》";
    }
}

在买票模块中创建所要使用的卖票模块中的类（全类名要一致）

package com.hjznb.provider.service;

public interface TicketService {

    String getTicket();
}

在买票代码中使用该服务，需要用@Reference注解来标明要引用的类，duboo会从zookeeper中引用该类。

import com.alibaba.dubbo.config.annotation.Reference;
import com.hjznb.provider.service.TicketService;
import org.springframework.stereotype.Service;

@Service	//spring框架的service注解，将其注入到容器中
public class UserService {

    @Reference
    TicketService ticketService;

    public void hello(){
        String ticket = ticketService.getTicket();
        System.out.println("买到了"+ticket);
    }
}

先启动卖票模块，再到买票模块中进行测试，控制台输出：买到了《泰坦尼克号》

@SpringBootTest
@RunWith(SpringRunner.class)
class ConsumerApplicationTests {

    @Autowired
    UserService userService;

    @Test
    void contextLoads() {
        userService.hello();
    }
// 买到了《泰坦尼克号》