脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 软件编程 → java → springboot dubbo

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中解密微信加密数据工具类

    最近小编一直在开发微信公众号、小程序项目，微信返回给我们的数据都是加密的，我们需要使用sessionkey配合解密，才能看到我们想要的数据，基于代码怎么实现呢，下面小编给大家带来了Java中解密微信加密数据工具类的完整代码，一起看看吧
    2021-06-06
  • 深度理解SpringMVC中的HandlerMapping

    深度理解SpringMVC中的HandlerMapping

    这篇文章主要介绍了深度理解SpringMVC中的HandlerMapping,HandlerMapping的作用根据request找到对应的处理器Handler,在HandlerMapping接口中有一个唯一的方法getHanler,需要的朋友可以参考下
    2023-09-09
  • SpringBoot Webflux创建TCP/UDP server并使用handler解析数据

    SpringBoot Webflux创建TCP/UDP server并使用handler解析数据

    这篇文章主要介绍了SpringBoot Webflux创建TCP/UDP server并使用handler解析数据，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
    2022-02-02
  • java编程实现两个大数相加代码示例

    java编程实现两个大数相加代码示例

    这篇文章主要介绍了java编程实现两个大数相加代码示例，具有一定参考价值，需要的朋友可以了解下。
    2017-12-12
  • Spring事务的传播行为解析

    Spring事务的传播行为解析

    这篇文章主要介绍了Spring事务的传播行为解析,事务传播行为(propagation behavior)指的就是当一个事务方法被另一个事务方法调用时,这个事务方法应该如何运行,需要的朋友可以参考下
    2023-10-10
  • Java中防止数据重复提交超简单的6种方法

    Java中防止数据重复提交超简单的6种方法

    在平时开发中,如果网速比较慢的情况下,用户提交表单后,发现服务器半天都没有响应,那么用户可能会以为是自己没有提交表单,就会再点击提交按钮重复提交表单,这篇文章主要给大家介绍了关于Java中防止数据重复提交超简单的6种方法,需要的朋友可以参考下
    2021-11-11
  • Java设计模式之策略模式详细解析

    Java设计模式之策略模式详细解析

    这篇文章主要介绍了Java设计模式之策略模式详细解析,策略模式中,定义算法族,分别封装起来,让他们之间可以相互转化,此模式让算法的变化独立于使用算法的客户,需要的朋友可以参考下
    2023-11-11
  • spring security 自定义Provider 如何实现多种认证

    spring security 自定义Provider 如何实现多种认证

    这篇文章主要介绍了spring security 自定义Provider实现多种认证方式，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
    2021-12-12
  • Mybatis下的SQL注入漏洞原理及防护方法解析

    Mybatis下的SQL注入漏洞原理及防护方法解析

    SQL 注入是发生在 Web 程序中数据库层的安全漏洞，是网站存在最多也是最简单的漏洞，在实际项目中，即使使用了 Mybatis 框架，但仍然有可能因为编码人员安全意识不足而导致 SQL 注入问题，这篇文章主要介绍了Mybatis下的SQL注入漏洞原理及防护方法 ,需要的朋友可以参考下
    2022-11-11
  • 解决@Around对静态方法不生效的问题

    解决@Around对静态方法不生效的问题

    这篇文章主要介绍了解决@Around对静态方法不生效的问题，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧
    2021-02-02

最新评论