springboot使用dubbo和zookeeper代码实例

更新时间：2019年11月19日 09:25:26 作者：她的开呀

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

创建服务接口模块

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

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

在接口中引入依赖包

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

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

@Data
@AllArgsConstructor
public 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}")
@Component
public 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
@SpringBootApplication
public 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: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<User> init() {
    List<User> 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<User> 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;

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

您可能感兴趣的文章:

java序列化和java反序列化示例
在web项目开发的时候，经常用到序列化和反序列化用来传递大流量的数据,类只有实现Serializable借口才能被序列化,下来是java序列化和反序列化演示
2014-01-01
feign客户端设置超时时间操作
这篇文章主要介绍了feign客户端设置超时时间操作，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧
2020-09-09
Mybatis查询返回Map<String,Object>类型实例详解
这篇文章主要给大家介绍了关于Mybatis查询返回Map<String,Object>类型的相关资料,平时没太注意怎么用,今天又遇到了总结记录一下,方便以后处理此类问题,需要的朋友可以参考下
2022-07-07
Java实现按年月打印日历功能【基于Calendar】
这篇文章主要介绍了Java实现按年月打印日历功能,涉及java基于Calendar进行日期运算的相关操作技巧,需要的朋友可以参考下
2018-03-03
JavaWeb实现多文件上传及zip打包下载
这篇文章主要为大家详细介绍了JavaWeb实现多文件上传及zip打包下载，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2018-07-07
java商城项目实战之购物车功能实现
这篇文章主要为大家详细介绍了java商城项目实战之购物车功能实现，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2018-04-04
线上dubbo线程池耗尽CyclicBarrier线程屏障异常解决记录
系统相关使用人员反馈系统故障，这篇文章主要介绍了线上dubbo线程池耗尽CyclicBarrier线程屏障异常解决的记录，有需要的朋友可以借鉴参考下
2022-03-03
SpringBoot深入探究@Conditional条件装配的使用
这篇文章主要为大家介绍了SpringBoot底层注解@Conditional的使用分析，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪
2022-06-06
HelloSpringMVC注解版实现步骤解析
这篇文章主要介绍了HelloSpringMVC注解版实现步骤解析,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
2020-09-09
JVM分析之类加载机制详解
JVM内部架构包含类加载器、内存区域、执行引擎等。日常开发中，我们编写的java文件被编译成class文件后，jvm会进行加载并运行使用类。本次将对JVM加载部分进行分析，便于大家了解并掌握加载机制
2022-08-08