springboot怎么使用dubbo和zookeeper

小编给大家分享一下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;

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