源码网商城,靠谱的源码在线交易网站 我的订单 购物车 帮助

源码网商城

Springboot 整合 Dubbo/ZooKeeper 实现 SOA 案例解析

  • 时间:2022-10-29 05:15 编辑: 来源: 阅读:
  • 扫一扫,手机访问
摘要:Springboot 整合 Dubbo/ZooKeeper 实现 SOA 案例解析
[b]一、为啥整合 Dubbo 实现 SOA[/b] Dubbo 不单单只是高性能的 RPC 调用框架,更是 SOA 服务治理的一种方案。 核心: 远程通信,向本地调用一样调用远程方法。 集群容错 服务自动发现和注册,可平滑添加或者删除服务提供者。 我们常常使用 Springboot 暴露 HTTP 服务,并走 JSON 模式。但慢慢量大了,一种 SOA 的治理方案。这样可以暴露出 Dubbo 服务接口,提供给 Dubbo 消费者进行 RPC 调用。下面我们详解下如何集成 Dubbo。 [b]二、运行 springboot-dubbo-server 和 springboot-dubbo-client 工程[/b] 运行环境:JDK 7 或 8,Maven 3.0+ 技术栈:SpringBoot 1.5+、Dubbo 2.5+、ZooKeeper 3.3+ [b]1.ZooKeeper 服务注册中心[/b] ZooKeeper 是一个分布式的,开放源码的分布式应用程序协调服务。它是一个为分布式应用提供一致性服务的软件,提供的功能包括:配置维护、域名服务、分布式同步、组服务等。 下载 ZooKeeper ,地址 git@github.com:JeffLi1993/springboot-learning-example.git 然后,Maven 编译安装这个工程:
cd springboot-learning-example
mvn clean install
[b]3.运行 springboot-dubbo-server Dubbo 服务提供者工程[/b] 右键运行 springboot-dubbo-server 工程 ServerApplication 应用启动类的 main 函数。Console 中出现如下表示项目启动成功。这里表示 Dubbo 服务已经启动成功,并注册到 ZK (ZooKeeper)中。 [b]4.运行 springboot-dubbo-client Dubbo 服务消费者工程[/b] 右键运行 springboot-dubbo-client 工程 ClientApplication 应用启动类的 main 函数。Console 中出现如下:
...
2017-03-01 16:31:38.473 INFO 9896 --- [      main] o.s.j.e.a.AnnotationMBeanExporter    : Registering beans for JMX exposure on startup
2017-03-01 16:31:38.538 INFO 9896 --- [      main] s.b.c.e.t.TomcatEmbeddedServletContainer : Tomcat started on port(s): 8081 (http)
2017-03-01 16:31:38.547 INFO 9896 --- [      main] org.spring.springboot.ClientApplication : Started ClientApplication in 6.055 seconds (JVM running for 7.026)
City{id=1, provinceId=2, cityName='温岭', description='是我的故乡'}
最后打印的城市信息,就是通过 Dubbo 服务接口调用获取的。顺利运行成功,下面详解下各个代码及配置。 [b]三、springboot-dubbo-server 和 springboot-dubbo-client 工程配置详解[/b] 代码都在 GitHub 上, [url=https://github.com/JeffLi1993/springboot-learning-example]https://github.com/JeffLi1993/springboot-learning-example[/url]。 [b]1.详解 springboot-dubbo-server Dubbo 服务提供者工程[/b] springboot-dubbo-server 工程目录结构
├── pom.xml
└── src
  └── main
    ├── java
    │  └── org
    │    └── spring
    │      └── springboot
    │        ├── ServerApplication.java
    │        ├── domain
    │        │  └── City.java
    │        └── dubbo
    │          ├── CityDubboService.java
    │          └── impl
    │            └── CityDubboServiceImpl.java
    └── resources
      └── application.properties
a.pom.xml 配置 pom.xml 中依赖了 spring-boot-starter-dubbo 工程,该项目地址是 [url=https://github.com/teaey/spring-boot-starter-dubbo]https://github.com/teaey/spring-boot-starter-dubbo[/url]。 pom.xml 配置如下
4.0.0  springboot  springboot-dubbo-server  0.0.1-SNAPSHOT  springboot-dubbo 服务端:: 整合 Dubbo/ZooKeeper 详解 SOA 案例  
      org.springframework.boot    spring-boot-starter-parent    1.5.1.RELEASE        1.0.0        
          io.dubbo.springboot      spring-boot-starter-dubbo      ${dubbo-spring-boot}        
          org.springframework.boot      spring-boot-starter-web        
          org.springframework.boot      spring-boot-starter-test      test        
          junit      junit      4.12
b.application.properties 配置
## Dubbo 服务提供者配置
spring.dubbo.application.name=provider
spring.dubbo.registry.address=zookeeper://127.0.0.1:2181
spring.dubbo.protocol.name=dubbo
spring.dubbo.protocol.port=20880
spring.dubbo.scan=org.spring.springboot.dubbo
这里 ZK 配置的地址和端口,就是上面本机搭建的 ZK 。如果有自己的 ZK 可以修改下面的配置。配置解释如下:
spring.dubbo.application.name 应用名称
spring.dubbo.registry.address 注册中心地址
spring.dubbo.protocol.name 协议名称
spring.dubbo.protocol.port 协议端口
spring.dubbo.scan dubbo 服务类包目录
c.CityDubboServiceImpl.java 城市业务 Dubbo 服务层实现层类
// 注册为 Dubbo 服务
@Service(version = "1.0.0")
public class CityDubboServiceImpl implements CityDubboService {
  public City findCityByName(String cityName) {
    return new City(1L,2L,"温岭","是我的故乡");
  }
}
@Service 注解标识为 Dubbo 服务,并通过 version 指定了版本号。
d.City.java 城市实体类 实体类通过 Dubbo 服务之间 RPC 调用,则需要实现序列化接口。最好指定下 serialVersionUID 值。 [b]2.详解 springboot-dubbo-client Dubbo 服务消费者工程[/b]
springboot-dubbo-client 工程目录结构
├── pom.xml
└── src
  └── main
    ├── java
    │  └── org
    │    └── spring
    │      └── springboot
    │        ├── ClientApplication.java
    │        ├── domain
    │        │  └── City.java
    │        └── dubbo
    │          ├── CityDubboConsumerService.java
    │          └── CityDubboService.java
    └── resources
      └── application.properties
pom.xml 、 CityDubboService.java、City.java 没有改动。Dubbo 消费者通过引入接口实现 Dubbo 接口的调用。 a.application.properties 配置
## 避免和 server 工程端口冲突
server.port=8081
## Dubbo 服务消费者配置
spring.dubbo.application.name=consumer
spring.dubbo.registry.address=zookeeper://127.0.0.1:2181
spring.dubbo.scan=org.spring.springboot.dubbo
因为 springboot-dubbo-server 工程启动占用了 8080 端口,所以这边设置端口为 8081。 b.CityDubboConsumerService.java 城市 Dubbo 服务消费者
@Component
public class CityDubboConsumerService {
  @Reference(version = "1.0.0")
  CityDubboService cityDubboService;
  public void printCity() {
    String cityName="温岭";
    City city = cityDubboService.findCityByName(cityName);
    System.out.println(city.toString());
  }
}
@Reference(version = “1.0.0”) 通过该注解,订阅该接口版本为 1.0.0 的 Dubbo 服务。 这里将 CityDubboConsumerService 注入 Spring 容器,是为了更方便的获取该 Bean,然后验证这个 Dubbo 调用是否成功。 c.ClientApplication.java 客户端启动类
@SpringBootApplication
public class ClientApplication {
  public static void main(String[] args) {
    // 程序启动入口
    // 启动嵌入式的 Tomcat 并初始化 Spring 环境及其各 Spring 组件
    ConfigurableApplicationContext run = SpringApplication.run(ClientApplication.class, args);
    CityDubboConsumerService cityService = run.getBean(CityDubboConsumerService.class);
    cityService.printCity();
  }
}
解释下这段逻辑,就是启动后从 Bean 容器中获取城市 Dubbo 服务消费者 Bean。然后调用该 Bean 方法去验证 Dubbo 调用是否成功。 [b]四、小结[/b] 还有涉及到服务的监控,治理。这本质上和 SpringBoot 无关,这边不做一一介绍。 总结 以上所述是小编给大家介绍的Springboot 整合 Dubbo/ZooKeeper 实现 SOA 案例解析,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对编程素材网网站的支持!
  • 全部评论(0)
联系客服
客服电话:
400-000-3129
微信版

扫一扫进微信版
返回顶部