当前位置:  首页  >  PHP资讯  >  业界资讯

springboot使用dubbo和zookeeper代码实例

这篇文章主要介绍了springboot使用dubbo和zookeeper代码实例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下

这篇文章主要介绍了springboot使用dubbo和zookeeper代码实例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下

创建服务接口模块

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

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

在接口中引入依赖包

  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;

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。

内容推荐:免费高清PNG素材下载
吐了个 "CAO" !
扫码关注 PHP1 官方微信号
PHP1.CN | 中国最专业的PHP中文社区 | PNG素材下载 | DevBox开发工具箱 | json解析格式化 |PHP资讯 | PHP教程 | 数据库技术 | 服务器技术 | 前端开发技术 | PHP框架 | 开发工具 | 在线工具
Copyright © 1998 - 2020 PHP1.CN. All Rights Reserved PHP1.CN 第一PHP社区 版权所有 京ICP备19059560号-4