您可以捐助,支持我们的公益事业。

1元 10元 50元





认证码:  验证码,看不清楚?请点击刷新验证码 必填



  求知 文章 文库 Lib 视频 iPerson 课程 认证 咨询 工具 讲座 Model Center   Code  
会员   
   
 
     
   
 订阅
  捐助
dubbo+zookeeper 实战Demo
 
作者:我叫了了
  54  次浏览      2
 2021-9-15
 
编辑推荐:
本篇文章主要讲解一下当前流行的分布式开发所用到分布式服务框架dubbo和zookeepe,希望对您的学习有所帮助。
来自于简书,由火龙果软件Alice编辑、推荐。

先来一张,企业级大型网站的架构图

其中红色部分就是我们这次要讲解的,随着网站的规模不断扩大,业务逻辑不断复杂,负载逐渐增加,企业级的架构将各个业务模块拆分成多个应用,部署到不同的服务器,然后使用RPC或者其他的远程调用方式实现各个服务器的远程调用,以及用dubbo或者nigx实现负载均衡。

下面我们用dubbo+zookeeper实现,一个简单地分布式的java应用集群,在集群间实现远程调用。

看图

这次一共有三个项目

DubboPro:生产者(发布远程服务,供别人调用)

DubboCus:消费者(就是调用别人发布的远程服务)

DubboInterface:接口项目

#######PS:生产者和消费正可以同时存在于一个java应用,这里便于学习,我们将他们分开

DubboInterface 接口项目

里面定义的是 我们要提供的服务 所依赖的接口,因为dubbo所提供的远程调用时基于代理实现的,所以提供服务的应用必须要继承接口才能实现。还有一个是Person实体类,这是我们一会要用到的,这里要注意,远程调用要传输java的对象(实体),必须是可序列换的。下面,请看代码!

package com.zhongcheng.dubbo.interf;

import com.zhongcheng.dubbo.model.Person;

/**
* Hello world!
*
*/
public interface GetPerson {

String speak(Person person);
}


package com.zhongcheng.dubbo.interf;

import com.zhongcheng.dubbo.model.Person;

public interface GrowAge {

Person growPersonAge(Person person);

}


package com.zhongcheng.dubbo.model;

import java.io.Serializable;

public class Person implements Serializable {

/**
*
*/
private static final long serialVersionUID = -7408906574534643319L;

private String age;

private String name;

public String getAge() {
return age;
}

public void setAge(String age) {
this.age = age;
}

public String getName() {
return name;
}

public void setName(String name) {
this.name = name;
}

}
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>

<groupId>com.zhongcheng</groupId>
<artifactId>DubboInterface</artifactId>
<version>0.0.1-SNAPSHOT</version>
<packaging>jar</packaging>

<name>DubboInterface</name>
<url>http://maven.apache.org</url>

<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>

<dependencies>
</dependencies>
</project>

到这,这个工程就结束了,使用 mvn install打包到本地,我们一会在其他两个项目中会用到

mvn install

DubboPro:生产者

生产者在dubbo负责生,提供远程调用的服务,

先看下项目结构,其中有一个接口的实现类,和一个spring的配置文件(dubbo是依赖spring的),

package com.zhongcheng.dubbo.pro;

import com.zhongcheng.dubbo.interf.GetPerson;
import com.zhongcheng.dubbo.model.Person;

public class GetPersonImpl implements GetPerson {

public String speak(Person person) {
String s="Hello Dubbo!,My name is "+person.getName();
return s;
}

}

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://code.alibabatech.com/schema/dubbo
http://code.alibabatech.com/schema/dubbo/dubbo.xsd">

<!-- 提供方应用信息,用于计算依赖关系 ,一个应用只有一个 -->
<dubbo:application name="dubbo-hello-pro" />

<dubbo:provider registry="zk1" protocol="mydubbo" />

<!-- 使用multicast广播注册中心暴露服务地址 -->
<!-- <dubbo:registry address="multicast://224.5.6.7:1234" /> -->

<!-- 使用zookeeper注册中心暴露服务地址 -->
<dubbo:registry id="zk1" address="zookeeper://127.0.0.1:2181" />

<!-- 用dubbo协议在20880端口暴露服务 -->
<dubbo:protocol id="mydubbo" name="dubbo" port="20880" />

<!-- 声明需要暴露的服务接口 -->
<dubbo:service interface="com.zhongcheng.dubbo.interf.GetPerson" ref="getPerson" />

<!-- 和本地bean一样实现服务 -->
<bean id="getPerson" class="com.zhongcheng.dubbo.pro.GetPersonImpl" />
</beans>


<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>

<groupId>com.zhongcheng</groupId>
<artifactId>DubboPro</artifactId>
<version>0.0.1-SNAPSHOT</version>
<packaging>jar</packaging>

<name>DubboPro</name>
<url>http://maven.apache.org</url>

<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>

<dependencies>

<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>3.8.1</version>
<scope>test</scope>
</dependency>


<dependency>
<groupId>com.zhongcheng</groupId>
<artifactId>DubboInterface</artifactId>
<version>0.0.1-SNAPSHOT</version>
</dependency>

<dependency>
<groupId>com.alibaba</groupId>
<artifactId>dubbo</artifactId>
<version>2.4.10</version>
</dependency>

<!-- https://mvnrepository.com/artifact/com.101tec/zkclient -->
<dependency>
<groupId>com.101tec</groupId>
<artifactId>zkclient</artifactId>
<version>0.5</version>
</dependency>

<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-core</artifactId>
<version>3.2.8.RELEASE</version>
</dependency>


<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-beans</artifactId>
<version>3.2.8.RELEASE</version>
</dependency>

</dependencies>
</project>

这样完成了,主要的工作都在配置文件中,接口实现类只负责业务的逻辑,这时,我们就可以启动了,当然这时一个javaApplcation程序,需要主函数,我们需要配置一下,看图

执行应用,这时我们就可以去zookeeper看下,我们的在dubbo中注册的服务是否已经被存放到节点中

在zcClient中使用ls和get命令

ls /

图中可以看到,我们发布的接口已经到zookeeper的/dubbo节点中了,下面我们就可以使用消费者调用了

DubboCus:消费者

消费者我服调用远程服务,先看下项目的结构

这里只有一个测试类和spring的配置文件,直接看代码

package com.zhongcheng.dubbo.pro;

import com.zhongcheng.dubbo.interf.GetPerson;
import com.zhongcheng.dubbo.model.Person;

public class GetPersonImpl implements GetPerson {

public String speak(Person person) {
String s="Hello Dubbo!,My name is "+person.getName();
return s;
}

}
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://code.alibabatech.com/schema/dubbo
http://code.alibabatech.com/schema/dubbo/dubbo.xsd">

<!-- 提供方应用信息,用于计算依赖关系 ,一个应用只有一个 -->
<dubbo:application name="dubbo-hello-pro" />

<dubbo:provider registry="zk1" protocol="mydubbo" />

<!-- 使用multicast广播注册中心暴露服务地址 -->
<!-- <dubbo:registry address="multicast://224.5.6.7:1234" /> -->

<!-- 使用zookeeper注册中心暴露服务地址 -->
<dubbo:registry id="zk1" address="zookeeper://127.0.0.1:2181" />

<!-- 用dubbo协议在20880端口暴露服务 -->
<dubbo:protocol id="mydubbo" name="dubbo" port="20880" />

<!-- 声明需要暴露的服务接口 -->
<dubbo:service interface="com.zhongcheng.dubbo.interf.GetPerson" ref="getPerson" />

<!-- 和本地bean一样实现服务 -->
<bean id="getPerson" class="com.zhongcheng.dubbo.pro.GetPersonImpl" />
</beans>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>

<groupId>com.zhongcheng</groupId>
<artifactId>DubboPro</artifactId>
<version>0.0.1-SNAPSHOT</version>
<packaging>jar</packaging>

<name>DubboPro</name>
<url>http://maven.apache.org</url>

<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>

<dependencies>

<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>3.8.1</version>
<scope>test</scope>
</dependency>


<dependency>
<groupId>com.zhongcheng</groupId>
<artifactId>DubboInterface</artifactId>
<version>0.0.1-SNAPSHOT</version>
</dependency>

<dependency>
<groupId>com.alibaba</groupId>
<artifactId>dubbo</artifactId>
<version>2.4.10</version>
</dependency>

<!-- https://mvnrepository.com/artifact/com.101tec/zkclient -->
<dependency>
<groupId>com.101tec</groupId>
<artifactId>zkclient</artifactId>
<version>0.5</version>
</dependency>

<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-core</artifactId>
<version>3.2.8.RELEASE</version>
</dependency>


<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-beans</artifactId>
<version>3.2.8.RELEASE</version>
</dependency>

</dependencies>
</project>

成功了!!!!

写的太粗略了,就当学习笔记吧,

原文链接:https://www.jianshu.com/p/0096bbe7e846

 

   
54 次浏览       2
相关文章

企业架构、TOGAF与ArchiMate概览
架构师之路-如何做好业务建模?
大型网站电商网站架构案例和技术架构的示例
完整的Archimate视点指南(包括示例)
相关文档

数据中台技术架构方法论与实践
适用ArchiMate、EA 和 iSpace进行企业架构建模
Zachman企业架构框架简介
企业架构让SOA落地
相关课程

云平台与微服务架构设计
中台战略、中台建设与数字商业
亿级用户高并发、高可用系统架构
高可用分布式架构设计与实践

最新活动计划
软件架构设计方法、案例与实践 9-22[北京]
云计算、微服务与分布式架构 9-22[北京]
人工智能、机器学习& TensorFlow+Keras 9-24[北京]
配置管理方法、实践、工具与应用 9-26[北京]
MBSE(基于模型的系统工程)9-28[北京]
Python 核心编程与可视化技术实战 9-16[上海]
 
最新文章
架构设计-谈谈架构
实现SaaS(软件及服务)架构三大技术挑战
到底什么是数据中台?
响应式架构简介
业务架构、应用架构与云基础架构
最新课程
软件架构设计方法、案例与实践
从大型电商架构演进看互联网高可用架构设计
大型互联网高可用架构设计实践
企业架构师 (TOGAF官方认证)
嵌入式软件架构设计—高级实践
更多...   
成功案例
某新能源电力企业 软件架构设计方法、案例与实践
中航工业某研究所 嵌入式软件开发指南
某轨道交通行业 嵌入式软件高级设计实践
北京 航天科工某子公司 软件测试架构师
北京某领先数字地图 架构师(设计案例)
更多...