dubbo与zookeeper怎么在springboot中使用-创新互联

今天就跟大家聊聊有关dubbo与zookeeper怎么在springboot中使用，可能很多人都不太了解，为了让大家更加了解，小编给大家总结了以下内容，希望大家根据这篇文章可以有所收获。

创建服务接口模块

接口工程只提供接口，不提供实现，在后面的提供者和消费者中使用

在使用接口的模块中只需要写具体实现类，避免了在每个模块中重复编写接口

在接口中引入依赖包

      org.projectlombok
      lombok
      true
    

创建一个实体类,一定要实现Serializable接口，否则dubbo协议之间无法传输

@Data
@AllArgsConstructor
public class User implements Serializable {
  private String name;
}

创建接口

public interface UserService {
  List getAll();
  List getAll2();
}

创建服务提供者

引入依赖

    
      com.yls
      common-api
      1.0-SNAPSHOT
    
    
    
      org.springframework.boot
      spring-boot-starter
    

    
    
      com.alibaba.boot
      dubbo-spring-boot-starter
      0.2.0
    

修改配置文件

#服务名称
dubbo.application.name=provider1
#注册中心地址
dubbo.registry.address=39.97.234.52:2181,39.97.234.52:2182,39.97.234.52:2183
#注册中心类型
dubbo.registry.protocol=zookeeper

#版本号
dubbo.application.version=3
# Dubbo Protocol
#协议名称
dubbo.protocol.name=dubbo
#服务暴露端口
dubbo.protocol.port=20880

实现服务接口

//暴露服务
//这里的@Service是Dubbo提供的，不是spring中的
//version必填
@Service(version = "${dubbo.application.version}")
@Component
public class UserImpl implements UserService {
  @Override
  public List getAll() {
    User user1 = new User("张三");
    User user2 = new User("lisi");
    List list = Arrays.asList(user1, user2);
    return list;
  }
}

启动服务

//@EnableDubbo等价于在配置文件中配置dubbo.scan.base-packages
//扫描实现类所在的包，注册Bean
@EnableDubbo
@SpringBootApplication
public class ProviderApplication {

  public static void main(String[] args) {

    SpringApplication.run(ProviderApplication.class,args);
  }
}

创建消费者

引入依赖

    
      org.springframework.boot
      spring-boot-starter-web
    

    
    
      com.alibaba.boot
      dubbo-spring-boot-starter
      0.2.0
    

    
    
      com.yls
      common-api
      1.0-SNAPSHOT
    

修改配置文件

#注册中心
dubbo.registry.address=39.97.234.52:2181,39.97.234.52:2182,39.97.234.52:2183
dubbo.registry.protocol=zookeeper
#dubbo应用名称
dubbo.application.name=consumer1

实现消费接口

//服务消费者的Service是spring的
@Service
public class OrderImpl implements OrderService {

  //使用dubbo提供的@Reference访问远程服务
  //version对应服务提供者的version
  @Reference(version = "3")
  private UserService userService;

  @Override
  public List init() {
    List list = userService.getAll();
    list.forEach(item -> System.out.println(item.getName()));
    return list;
  }
}

创建controller

@Controller
public class OrderController {

  @Autowired
  private OrderService orderService;

  @ResponseBody
  @RequestMapping("/init")
  public List init() {
    return orderService.init();
  }
}

启动服务消费者

@EnableDubbo
@SpringBootApplication
public class ConsumerApplication {
  public static void main(String[] args) {
    SpringApplication.run(ConsumerApplication.class, args);
  }
}

dubbo相关补充

dubbo使用本地缓存方式，如果注册中心全部宕机，dubbo也能正常工作，就算没有注册中心，dubbo也能通过dubbo直连通信

//使用dubbo提供的@Reference访问远程服务
  //version对应服务提供者的version
  //url:如果没有注册中心，可以通过url配置服务提供者的dubbo协议端口，进行dubbo直连
  @Reference(version = "3",url ="127.0.0.1:20880" )
  private UserService userService;

看完上述内容，你们对dubbo与zookeeper怎么在springboot中使用有进一步的了解吗？如果还想了解更多知识或者相关内容，请关注创新互联网站建设公司行业资讯频道，感谢大家的支持。

另外有需要云服务器可以了解下创新互联建站www.cdcxhl.com，海内外云服务器15元起步，三天无理由+7*72小时售后在线，公司持有idc许可证，提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案，具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势，专为企业上云打造定制，能够满足用户丰富、多元化的应用场景需求。