SpringBoot系列教程之dubbo和Zookeeper集成方法

（自动获取到最新的zookeeper版本）
docker pull zookeeper 

docker run --name zk01 -p 2181:2181 --restart always -d 6ad6cb039dfa
6ad6cb039dfa（镜像id）

    
    
      org.apache.dubbo
      dubbo-spring-boot-starter
      2.7.3
    

    
    
    
      com.github.sgroschupf
      zkclient
      0.1
    


    
    
      org.apache.curator
      curator-framework
      2.12.0
    
    
      org.apache.curator
      curator-recipes
      2.12.0
    

    
      org.apache.zookeeper
      zookeeper
      3.4.14
      
      
        
          org.slf4j
          slf4j-log4j12
        
      
    

public interface ITicketService {
  String saleTicket(String name);
}

package top.weidaboy.provider.service.Impl;
import org.apache.dubbo.config.annotation.Service;
import org.springframework.stereotype.Component;
import top.weidaboy.provider.service.ITicketService;
//zookeeper:服务注册与发现
@Service      //使用后被注入,项目已启动就自动注册到注册中心
@Component  //放到spring容器中去
//新版:import org.apache.dubbo.config.annotation.DubboService;
//@DubboService //将服务发布出去
public class TicketServiceImpl implements ITicketService {

  @Override
  public String saleTicket(String name) {
    return "确认买票： "+name;
  }
}

server.port=8081
#当前应用起名
dubbo.application.name=provider-server
#找到zookeeper注册中心地址
dubbo.registry.address=zookeeper://你的IP:2181
#扫描提供指定包下的服务
dubbo.scan.base-packages=top.weidaboy.provider.service

public interface IUserService {
  //买票
  String buyTicket(String name);
}

@Service//注入到容器中, 这个import org.springframework.stereotype.Service;
public class UserServiceImpl implements IUserService {

  @Reference
   //远程引用指定的服务,
  //该注解会按照全类名来进行匹配,看是哪个给注册中心注册了这个全类名
  ITicketService ticketService; //相同的接口名

  @Override
  public String buyTicket(String name) {
    return ticketService.saleTicket(name);
  }
}

public interface ITicketService {
  String saleTicket(String name);
}

server.port=8082 #需要不同端口
#给当前应用起名:
dubbo.application.name=consumer-server
#注册中心
dubbo.registry.address=zookeeper://你的IP:2181

@SpringBootTest
class WeidaboyApplicationTests {
  @Autowired
  IUserService userService;
  @Test
  void contextLoads() {
    System.out.println(userService.buyTicket("唐人街探案三"));
  }
}