今天就跟大家聊聊有关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中使用有进一步的了解吗？如果还想了解更多知识或者相关内容，请关注创新互联行业资讯频道，感谢大家的支持。