springboot使用dubbo和zookeeper代码实例

 更新时间:2019年11月19日 09:25:26   作者:她的开呀  
这篇文章主要介绍了springboot使用dubbo和zookeeper代码实例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下

这篇文章主要介绍了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反序列化示例

    java序列化和java反序列化示例

    在web项目开发的时候,经常用到序列化和反序列化用来传递大流量的数据,类只有实现Serializable借口才能被序列化,下来是java序列化和反序列化演示
    2014-01-01
  • feign客户端设置超时时间操作

    feign客户端设置超时时间操作

    这篇文章主要介绍了feign客户端设置超时时间操作,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧
    2020-09-09
  • Mybatis查询返回Map<String,Object>类型实例详解

    Mybatis查询返回Map<String,Object>类型实例详解

    这篇文章主要给大家介绍了关于Mybatis查询返回Map<String,Object>类型的相关资料,平时没太注意怎么用,今天又遇到了总结记录一下,方便以后处理此类问题,需要的朋友可以参考下
    2022-07-07
  • Java实现按年月打印日历功能【基于Calendar】

    Java实现按年月打印日历功能【基于Calendar】

    这篇文章主要介绍了Java实现按年月打印日历功能,涉及java基于Calendar进行日期运算的相关操作技巧,需要的朋友可以参考下
    2018-03-03
  • JavaWeb实现多文件上传及zip打包下载

    JavaWeb实现多文件上传及zip打包下载

    这篇文章主要为大家详细介绍了JavaWeb实现多文件上传及zip打包下载,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2018-07-07
  • java商城项目实战之购物车功能实现

    java商城项目实战之购物车功能实现

    这篇文章主要为大家详细介绍了java商城项目实战之购物车功能实现,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2018-04-04
  • 线上dubbo线程池耗尽CyclicBarrier线程屏障异常解决记录

    线上dubbo线程池耗尽CyclicBarrier线程屏障异常解决记录

    系统相关使用人员反馈系统故障,这篇文章主要介绍了线上dubbo线程池耗尽CyclicBarrier线程屏障异常解决的记录,有需要的朋友可以借鉴参考下
    2022-03-03
  • SpringBoot深入探究@Conditional条件装配的使用

    SpringBoot深入探究@Conditional条件装配的使用

    这篇文章主要为大家介绍了SpringBoot底层注解@Conditional的使用分析,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2022-06-06
  • HelloSpringMVC注解版实现步骤解析

    HelloSpringMVC注解版实现步骤解析

    这篇文章主要介绍了HelloSpringMVC注解版实现步骤解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-09-09
  • JVM分析之类加载机制详解

    JVM分析之类加载机制详解

    JVM内部架构包含类加载器、内存区域、执行引擎等。日常开发中,我们编写的java文件被编译成class文件后,jvm会进行加载并运行使用类。本次将对JVM加载部分进行分析,便于大家了解并掌握加载机制
    2022-08-08

最新评论