springboot使用dubbo和zookeeper代码实例
这篇文章主要介绍了springboot使用dubbo和zookeeper代码实例,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
创建服务接口模块
接口工程只提供接口，不提供实现，在后面的提供者和消费者中使用
在使用接口的模块中只需要写具体实现类，避免了在每个模块中重复编写接口
在接口中引入依赖包
org.projectlombok lombok true
创建一个实体类,一定要实现Serializable接口，否则dubbo协议之间无法传输
@Data
@AllArgsConstructor
publicclassUserimplementsSerializable{
privateStringname;
}
创建接口
publicinterfaceUserService{
ListgetAll();
ListgetAll2();
}
创建服务提供者
引入依赖
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 #DubboProtocol #协议名称 dubbo.protocol.name=dubbo #服务暴露端口 dubbo.protocol.port=20880
实现服务接口
//暴露服务
//这里的@Service是Dubbo提供的，不是spring中的
//version必填
@Service(version="${dubbo.application.version}")
@Component
publicclassUserImplimplementsUserService{
@Override
publicListgetAll(){
Useruser1=newUser("张三");
Useruser2=newUser("lisi");
Listlist=Arrays.asList(user1,user2);
returnlist;
}
}
启动服务
//@EnableDubbo等价于在配置文件中配置dubbo.scan.base-packages
//扫描实现类所在的包，注册Bean
@EnableDubbo
@SpringBootApplication
publicclassProviderApplication{
publicstaticvoidmain(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
publicclassOrderImplimplementsOrderService{
//使用dubbo提供的@Reference访问远程服务
//version对应服务提供者的version
@Reference(version="3")
privateUserServiceuserService;
@Override
publicListinit(){
Listlist=userService.getAll();
list.forEach(item->System.out.println(item.getName()));
returnlist;
}
}
创建controller
@Controller
publicclassOrderController{
@Autowired
privateOrderServiceorderService;
@ResponseBody
@RequestMapping("/init")
publicListinit(){
returnorderService.init();
}
}
启动服务消费者
@EnableDubbo
@SpringBootApplication
publicclassConsumerApplication{
publicstaticvoidmain(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") privateUserServiceuserService;
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。
声明：本文内容来源于网络，版权归原作者所有，内容由互联网用户自发贡献自行上传，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任。如果您发现有涉嫌版权的内容，欢迎发送邮件至：czq8825#qq.com（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。