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

创建服务接口模块

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

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

在接口中引入依赖包

<dependency> <groupId>org.projectlombok</groupId> <artifactId>lombok</artifactId> <optional>true</optional> </dependency>

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

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

创建接口

public interface UserService { List<User> getAll(); List<User> getAll2();}

创建服务提供者

引入依赖

<!--引入创建的接口服务--> <dependency> <groupId>com.yls</groupId> <artifactId>common-api</artifactId> <version>1.0-SNAPSHOT</version> </dependency> <!--由于服务提供者不是web项目 ，只需引入spring-boot-starter，不用引入spring-boot-starter-web--> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter</artifactId> </dependency> <!--dubbo--> <dependency> <groupId>com.alibaba.boot</groupId> <artifactId>dubbo-spring-boot-starter</artifactId> <version>0.2.0</version> </dependency>

修改配置文件

#服务名称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<User> getAll() { User user1 = new User("张三"); User user2 = new User("lisi"); List<User> 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); }}

创建消费者

引入依赖

<!--消费者是web项目--> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <!--dubbo--> <dependency> <groupId>com.alibaba.boot</groupId> <artifactId>dubbo-spring-boot-starter</artifactId> <version>0.2.0</version> </dependency> <!--引入创建的接口服务--> <dependency> <groupId>com.yls</groupId> <artifactId>common-api</artifactId> <version>1.0-SNAPSHOT</version> </dependency>

修改配置文件

#注册中心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<User> init() { List<User> 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<User> 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;

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