springboot怎么使用dubbo和zookeeper

小编给大家分享一下springboot怎么使用dubbo和zookeeper，希望大家阅读完这篇文章之后都有所收获，下面让我们一起去探讨吧！

创建服务接口模块

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

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

在接口中引入依赖包

org.projectlombok lombok true

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

@Data@AllArgsConstructorpublic 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}")@Componentpublic 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@SpringBootApplicationpublic 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:2183dubbo.registry.protocol=zookeeper#dubbo应用名称dubbo.application.name=consumer1

实现消费接口

//服务消费者的Service是spring的@Servicepublic 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

@Controllerpublic class OrderController { @Autowired private OrderService orderService; @ResponseBody @RequestMapping("/init") public List init() { return orderService.init(); }}

启动服务消费者

@EnableDubbo@SpringBootApplicationpublic 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;

看完了这篇文章，相信你对"springboot怎么使用dubbo和zookeeper"有了一定的了解，如果想了解更多相关知识，欢迎关注行业资讯频道，感谢各位的阅读！