Dubbo+zookeeper实现分布式服务框架
什么是Dubbo??
Dubbo也是一套微服务框架,他与SpringCloud的区别就是,他支持多种协议,而SpringCloud只支持Http协议。如果没有分布式,那么他是不存在的。
Dubbo底层架构图 Dubbo底层
首先Provider生成服务将服务注册到zookeeper(具体实现下面有代码),然后zookeeper接收到过后底层会触发zookeeper监听事件(不懂请看前一节),然后告诉Consumer可以消费了,但是Provider关闭过后zookeeper不会删除节点,因为是存储的持久化节点,不是临时节点。然后会有一个专门的模块来监听服务的调用,统计模块调用次数和反馈信息。
Dubbo有哪些作用
①:Dubbo有服务治理的能力:透明化的远程方法调用,就像调用本地方法一样调用远程方法,只需简单 配置,没有任何API侵入。 ②:集群容错:软负载均衡及容错机制,可在内网替代F5等硬件负鞭均衡器,降低成本,减少单点。 ③:自动发现:服务自动注册与发现,不再需要写死服务提供方地址,注册中心基于接口名查询服务提供者的IP地址,并且能够平滑添加或删除服务提供者。 另外:Dubbo采用全Spring 配置方式,功明化接入应用,对应用没有任何API侵只需用Spring加载Dubbo的配置即可,Dubbo基FSpring的Schema扩入,展进行加载。
搭建模拟环境
首先我们搭建一个Dubbo服务类(该类主要是写接口供生产者和消费者引用并继承。主要原因是为了避免消费者和生产者都去写一次相同的接口类)
创建项目名称:dubbo-common
在per.lx.service包下新建UserService接口
public interface UserService { String getUser(Integer id); }
如果需要更多的服务的话,都在dubbo-common包下进行新建,然后在生产者中去实现它的内部方法并注册到zookeeper
下面创建服务提供者和消费者,都需要引入相同的依赖pom.xml:
<dependencies> <dependency> <groupId>com.alibaba</groupId> <artifactId>dubbo</artifactId> <version>2.5.6</version> </dependency> <!-- 添加zk客户端依赖 --> <dependency> <groupId>com.github.sgroschupf</groupId> <artifactId>zkclient</artifactId> <version>0.1</version> </dependency> <!-- 添加对dubbo-common的依赖,使用UserService --> <dependency> <groupId>per.lx</groupId> <artifactId>dubbo-common</artifactId> <version>0.0.1-SNAPSHOT</version> </dependency> </dependencies>
创建项目名称服务提供者:dubbo-producer
新建一个UserServiceImpl去实现dubbo-common中的UserService接口
public class UserServiceImpl implements UserService{ @Override public String getUser(Integer id) { System.out.println("进入到getUser服务实现内 id:"+id); if(id==1){ return "Hello,LLL丶禾羊,id:"+id; } if(id==2){ return "Hello,OSC,id:"+id; } if(id==3){ return "Hello,开源中国!,id:"+id; } return null; } }
并且在resources下面新建配置文件provider.xml
<?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="provider" /> <!-- 使用zookeeper注册中心暴露服务地址 --> <dubbo:registry address="zookeeper://127.0.0.1:2181" /> <!-- 用dubbo协议在29014端口暴露服务 --> <dubbo:protocol name="dubbo" port="29014" /> <!-- 声明需要暴露的服务接口 --> <dubbo:service interface="per.lx.service.UserService" ref="userService" /> <!-- 具体的实现bean --> <bean id="userService" class="per.lx.service.impl.UserServiceImpl" /> </beans>
最后新建一个启动类StartProducer
public class StartProducer { public static void main(String[] args) throws IOException { ClassPathXmlApplicationContext app = new ClassPathXmlApplicationContext("provider.xml"); app.start(); System.out.println("服务发布成功..."); System.in.read();//让程序阻塞。 } }
这里直接启动主函数,可以直接在控制台看到服务发布成功。之后打开zookeeper查看工具可以查看到服务信息(如下图,工具是ZooInspector.jar,开源的,百度可下载)。
写完生产者,消费者更加简单。
新建消费者项目dubbo-consumer
在resources中新建consumer.xml
<?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="consumer" /> <!-- 使用multicast广播注册中心暴露发现服务地址 --> <dubbo:registry protocol="zookeeper" address="zookeeper://127.0.0.1:2181" /> <!-- 生成远程服务代理,可以和本地bean一样使用demoService --> <dubbo:reference id="userService" interface="per.lx.service.UserService" /> </beans>
然后直接新建启动类StartConsumer
public class StartConsumer { public static void main(String[] args) throws IOException{ ClassPathXmlApplicationContext app = new ClassPathXmlApplicationContext("consumer.xml"); app.start(); UserService userService = (UserService) app.getBean("userService"); String name = userService.getUser(1); System.out.println("消费端从生产者获取到 name:" + name); System.in.read();//让程序阻塞。 } }
启动之后可以发现从控制台打印输出图中内容,表示发布成功。
欢迎工作一到五年的Java工程师朋友们加入Java架构开发:468947140
点击链接加入群聊【Java-BATJ企业级资深架构】:https://jq.qq.com/?_wv=1027&k=5zMN6JB
本群提供免费的学习指导 架构资料 以及免费的解答
不懂得问题都可以在本群提出来 之后还会有职业生涯规划以及面试指导
低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。
持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。
转载内容版权归作者及来源网站所有,本站原创内容转载请注明来源。
- 上一篇
浅谈前端响应式设计(一)
现实世界有很多是以响应式的方式运作的,例如我们会在收到他人的提问,然后做出响应,给出相应的回答。在开发过程中笔者也应用了大量的响应式设计,积累了一些经验,希望能抛砖引玉。 响应式编程(Reactive Programming)和普通的编程思路的主要区别在于,响应式以推(push)的方式运作,而非响应式的编程思路以拉(pull)的方式运作。例如,事件就是一个很常见的响应式编程,我们通常会这么做: button.on('click', () => { // ... }) 而非响应式方式下,就会变成这样: while (true) { if (button.clicked) { // ... } } 显然,无论是代码的优雅度还是执行效率上,非响应式的方式都不如响应式的设计。 Event Emitter Event Emitter是大多数人都很熟悉的事件实现,它很简单也很实用,我们可以利用Event Emitter实现简单的响应式设计,例如下面这个异步搜索: class Input extends Component { state = { value: '' } onChange = ...
- 下一篇
17.移动架构手写数据库增删改查框架
待续。。。
相关文章
文章评论
共有0条评论来说两句吧...
文章二维码
点击排行
推荐阅读
最新文章
- Docker使用Oracle官方镜像安装(12C,18C,19C)
- CentOS6,CentOS7官方镜像安装Oracle11G
- SpringBoot2初体验,简单认识spring boot2并且搭建基础工程
- Hadoop3单机部署,实现最简伪集群
- CentOS6,7,8上安装Nginx,支持https2.0的开启
- CentOS关闭SELinux安全模块
- SpringBoot2编写第一个Controller,响应你的http请求并返回结果
- Windows10,CentOS7,CentOS8安装MongoDB4.0.16
- SpringBoot2整合Thymeleaf,官方推荐html解决方案
- Springboot2将连接池hikari替换为druid,体验最强大的数据库连接池