Dubbo + Zookeeper入门初探(转载)
- 一、搭建java和tomcat环境
- 二、搭建zookeeper
- 三、搭建dubbo监控中心
- 四、配置项目
- 4.1 服务提供方代码
- 4.2 服务使用方代码
- 五、测试
2018年2月15日,阿里巴巴的dubbo进入了Apache孵化器,社区的加入,希望dubbo能变得更好…
最近在学习一个分布式项目,使用到了dubbo
,之前没有使用过,体验一下,分布式项目地址:点击这里
使用dubbo官网的一张图来介绍下dubbo
(本人才开始学习,如有错误,欢迎指正):
Registry:注册中心,相当于房产中介,服务提供者和使用者都需要在这里注册/使用服务,我使用
zookeeper
实现。Monitor:监控中心,相当于房产局,它可以统计服务提供者和服务使用者的一些信息,及他们之间的关系,我使用
dubbo admin
实现。Provider:服务提供者,相当于房东,提供服务。
Consumer:服务消费者,想当于租户,使用服务。
下面我通俗的解释下dubbo的整个流程,我将服务比喻成房子:
start:dubbo一启动,房东想好自己准备要租出去的房子
register:房东将房子拿到房产中介那边进行登记,并留下自己的联系方式
subscribe:租户告诉房产中介自己想租一个什么样的房子
notify:房产中介回复给租户符合条件的房子的房东的联系方式
invoke:租户拿着联系方式去找房东租房子
count:房产局全程监控着房东和租户之间的交易
其中:
start、register、subscribe在dubbo服务一启动就完成了
notify、count是异步执行的
invoke是同步执行的
一、搭建java和tomcat环境
这一步比较简单,直接跳过,不会的可以看下这篇文章:Linux搭建JavaWeb开发环境(Java、Tomcat、MySQL)
二、搭建zookeeper
我使用的是zookeeper-3.5.2-alpha
,点我下载。
下载后将其解压:
wxs@ubuntu:~$ sudo tar zxf zookeeper-3.5.2-alpha.tar.gz
wxs@ubuntu:~$ sudo mv zookeeper-3.5.2-alpha /usr
wxs@ubuntu:~$ cd /usr/zookeeper-3.5.2-alpha
wxs@ubuntu:/usr/zookeeper-3.5.2-alpha$ ls
bin ivysettings.xml recipes
build.xml ivy.xml src
CHANGES.txt lib zookeeper-3.5.2-alpha.jar
conf LICENSE.txt zookeeper-3.5.2-alpha.jar.asc
contrib NOTICE.txt zookeeper-3.5.2-alpha.jar.md5
dist-maven README_packaging.txt zookeeper-3.5.2-alpha.jar.sha1
docs
在zookper文件夹下建立logs
文件夹和data
文件夹用于存放日志和数据:
wxs@ubuntu:/usr/zookeeper-3.5.2-alpha$ sudo mkdir data
wxs@ubuntu:/usr/zookeeper-3.5.2-alpha$ sudo mkdir logs
进入conf
目录,复制一份zoo_sample.cfg
为zoo.cfg
,对其进行修改:
wxs@ubuntu:/usr/zookeeper-3.5.2-alpha$ cd conf/
wxs@ubuntu:/usr/zookeeper-3.5.2-alpha/conf$ cp zoo_sample.cfg zoo.cfg
wxs@ubuntu:/usr/zookeeper-3.5.2-alpha/conf$ vim zoo.cfg
配置下dataDir
和dataLogDir
的路径,为之前创建的两个文件夹的路径,clientPort
使用默认的2181端口即可:
我使用的时单机模式,没有配集群,这样就可以了。
进入到bin
目录,启动服务即可:
wxs@ubuntu:/usr/zookeeper-3.5.2-alpha/bin$ ./zkServer.sh start
ZooKeeper JMX enabled by default
Using config: /usr/zookeeper-3.5.2-alpha/bin/../conf/zoo.cfg
Starting zookeeper ... STARTED
wxs@ubuntu:/usr/zookeeper-3.5.2-alpha/bin$ ./zkServer.sh status
ZooKeeper JMX enabled by default
Using config: /usr/zookeeper-3.5.2-alpha/bin/../conf/zoo.cfg
Client port found: 2181. Client address: localhost.
Mode: standalone
小心踩坑:
执行./zkServer.sh start
时不要加sudo
,如果root用户配置文件没有配JAVA_HOME
会出现找不到JAVA_HOME
!
wxs@ubuntu:/usr/zookeeper-3.5.2-alpha/bin$ sudo ./zkServer.sh start
Error: JAVA_HOME is not set and java could not be found in PATH.
相关命令:
启动服务:start 停止服务: stop 重启服务; restart 查看状态:status
三、搭建dubbo监控中心
版本要求:
请使用dubbo-admin-2.5.6.war
及以上版本,否则会不支持JDK1.8!
下载链接:点击这里
小心踩坑:
如果你的zookeeper
和dubbo-admin
在一台服务器上,dubbo-admin
不用修改任何内容!
如果不在一台服务器上,将war包解压后,修改项目/WEF-INF/dubbo.properties
文件,将zookeeper地址改为其所在服务器的地址(这里同时能修改root用户和guest用户的密码)。
四、配置项目
这里牵扯到项目代码,如果看不懂,可以下载文章开头的项目源码,或者直接使用官方提供的dubbo-demo
,更为简单。
首先给服务提供方和服务使用方导入依赖包:
<properties><dubbo.version>2.6.1</dubbo.version><zookeeper.version>3.5.2-alpha</zookeeper.version><curator.version>4.0.1</curator.version>
</properties><!-- dubbo包 -->
<dependency><groupId>com.alibaba</groupId><artifactId>dubbo</artifactId><!-- 排除dubbo自带的spring和netty,使用项目的,如果本身项目没有,无需排除 --><exclusions><exclusion><groupId>org.springframework</groupId><artifactId>spring</artifactId></exclusion><exclusion><groupId>org.jboss.netty</groupId><artifactId>netty</artifactId></exclusion></exclusions>
</dependency>
<!-- zookeeper包 -->
<dependency><groupId>org.apache.zookeeper</groupId><artifactId>zookeeper</artifactId><type>pom</type>
</dependency>
<!-- curator(zookeeper的客户端)包 -->
<dependency><groupId>org.apache.curator</groupId><artifactId>curator-client</artifactId>
</dependency>
<dependency><groupId>org.apache.curator</groupId><artifactId>curator-framework</artifactId>
</dependency>
还需要在相关配置文件加上dubbo
的bean
的头部约束,将下面的添加到bean头部即可:
xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"http://code.alibabatech.com/schema/dubbo
http://code.alibabatech.com/schema/dubbo/dubbo.xsd
4.1 服务提供方代码
对于服务提供方,如果我们想要TbItemService
对外提供服务:
package jit.wxs.service.impl;import jit.wxs.pojo.TbItem;
import jit.wxs.mapper.TbItemMapper;
import jit.wxs.service.TbItemService;
import com.baomidou.mybatisplus.service.impl.ServiceImpl;
import org.springframework.stereotype.Service;/*** <p>* 商品表 服务实现类* </p>** @author jitwxs* @since 2018-03-21*/
@Service
public class TbItemServiceImpl extends ServiceImpl<TbItemMapper, TbItem> implements TbItemService {}
需要修改spring关于service的配置文件,加入dubbo
的配置信息:
<?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"xmlns:context="http://www.springframework.org/schema/context"xsi:schemaLocation="http://www.springframework.org/schema/beanshttp://www.springframework.org/schema/beans/spring-beans.xsdhttp://code.alibabatech.com/schema/dubbohttp://code.alibabatech.com/schema/dubbo/dubbo.xsdhttp://www.springframework.org/schema/contexthttp://www.springframework.org/schema/context/spring-context.xsd"><!-- 扫描service层注解 --><context:component-scan base-package="jit.wxs.service"/><!-- dubbo发布服务 --><!-- 提供方应用信息,用于计算依赖关系 --><dubbo:application name="e3-manager" /><!-- 配置zookeeper的地址,集群地址用逗号隔开 --><dubbo:registry protocol="zookeeper" address="192.168.30.145:2181" /><!-- 用dubbo协议在20880端口暴露服务 --><dubbo:protocol name="dubbo" port="20880" /><!-- 声明需要暴露的服务接口ref:为注入的对应接口的beantimneout:超时时间,单位ms,开发模式可以设长一点方便debug--><dubbo:service interface="jit.wxs.service.TbItemService" ref="tbItemServiceImpl" timeout="600000"/>
</beans>
dubbo:application
:提供方的应用名dubbo:registry
:注册中心的类型和地址dubbo:protocol
:这个服务要暴露在哪个端口上(使用方根据这个端口使用服务)dubbo:service
:设置暴露的服务的接口,ref为该接口的bean,timeout为超时时间
4.2 服务使用方代码
服务使用方,我使用Spring MVC
来实现,修改Spring MVC的配置文件,加入dubbo的配置:
<?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"xmlns:context="http://www.springframework.org/schema/context"xmlns:mvc="http://www.springframework.org/schema/mvc"xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.0.xsdhttp://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc-4.0.xsdhttp://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.0.xsdhttp://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd"><!-- 扫描组件 --><context:component-scan base-package="jit.wxs.web"/><!-- 注解驱动 --><mvc:annotation-driven /><!-- 全局异常类 --><!--<bean class="cn.edu.jit.exception.GlobalExceptionResolver"/>--><!-- 视图解析器 --><bean class="org.springframework.web.servlet.view.InternalResourceViewResolver"><property name="prefix" value="/WEB-INF/jsp/" /><property name="suffix" value=".jsp" /></bean><!-- 引用dubbo服务 --><!-- 使用方应用信息,用于计算依赖关系 --><dubbo:application name="e3-manager-web"/><!-- 指定zookeeper的地址,集群用逗号分隔 --><dubbo:registry protocol="zookeeper" address="192.168.30.145:2181"/><!-- 申明要访问的接口,并创建代理对象,注入bean,名为id的值 --><dubbo:reference interface="jit.wxs.service.TbItemService" id="tbItemService" />
</beans>
dubbo:application
: 使用方的应用名dubbo:registry
:注册中心的类型和地址dubbo:reference
:要使用的服务的接口,并将返回的注入bean,名称为id设的值
如果配置没有问题的话,现在使用方已经能够使用提供方提供的服务了,直接将tbItemService
注入进来即可:
package jit.wxs.web;import jit.wxs.pojo.TbItem;
import jit.wxs.service.TbItemService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;/*** <p>* 商品表 前端控制器* </p>** @author jitwxs* @since 2018-03-21*/
@RestController
@RequestMapping("/items")
public class TbItemController {@Autowiredprivate TbItemService tbItemService;@GetMapping("/{id}")public TbItem getItemById(@PathVariable Long id) {TbItem item = null;if(id != null) {item = tbItemService.selectById(id);}return item;}
}
五、测试
服务器上分别启动zookper
和tomcat
:
wxs@ubuntu:/usr/zookeeper-3.5.2-alpha/bin$ ./zkServer.sh start
ZooKeeper JMX enabled by default
Using config: /usr/zookeeper-3.5.2-alpha/bin/../conf/zoo.cfg
Starting zookeeper ... STARTED
wxs@ubuntu:/usr/zookeeper-3.5.2-alpha/bin$ ./zkServer.sh status
ZooKeeper JMX enabled by default
Using config: /usr/zookeeper-3.5.2-alpha/bin/../conf/zoo.cfg
Client port found: 2181. Client address: localhost.
Mode: standalone
wxs@ubuntu:/usr/apache-tomcat-8.5.28/bin$ ./startup.sh
Using CATALINA_BASE: /usr/apache-tomcat-8.5.28
Using CATALINA_HOME: /usr/apache-tomcat-8.5.28
Using CATALINA_TMPDIR: /usr/apache-tomcat-8.5.28/temp
Using JRE_HOME: /usr/jdk1.8.0_161/jre
Using CLASSPATH: /usr/apache-tomcat-8.5.28/bin/bootstrap.jar:/usr/apache-tomcat-8.5.28/bin/tomcat-juli.jar
Tomcat started.
使用下面命令可以持续显示tomcat
的输出:
wxs@ubuntu:/usr/apache-tomcat-8.5.28/bin$ tail -f ../logs/catalina.out
分别启动服务提供方的项目和服务使用方的项目:
测试下/items/{id}
这个API:
成功!下面再访问下监控中心,因为监控中心和zookeeper
在一台服务器上,我的tomcat部署在8888端口,即访问192.168.30.145:8888/dubbo-admin
即可,用户名密码默认为root:
查看所有注册的服务:
查看包括消费者和提供者的所有应用名:
消费者、提供者详细信息:
Dubbo + Zookeeper入门初探(转载)相关推荐
- Dubbo + Zookeeper入门初探
2018年2月15日,阿里巴巴的dubbo进入了Apache孵化器,社区的加入,希望dubbo能变得更好-Registry:注册中心,相当于房产中介,服务提供者和使用者都需要在这里注册/使用服务, 我 ...
- Dubbo新手入门实例HelloWorld(zookeeper)
最近刚接触dubbo,新手入门遇到好多麻烦,网上搜来的入门demo也是各种问题,百般周折自己终于倒腾出来了,与大家共享~ 1.创建服务方项目dubbo-server,在pom.xml中构建项目依赖 & ...
- spring Boot环境下dubbo+zookeeper的一个基础讲解与示例
一,学习背景 1. 前言 对于我们不管工作还是生活中,需要或者想去学习一些东西的时候,大致都考虑几点: a) 我们为什么需要学习这个东西? b) 这个东西是什么? c) ...
- Dubbo+zookeeper使用方法以及注意事项
Dubbo+zookeeper使用方法以及注意事项 最近在一个项目中想做一个数据库查询的服务,目的是将数据库查询这块从程序中脱离出来,形成一个公共的服务平台,大家都可以调用,经过考虑决定选用Dubbo ...
- 【Zookeeper实战】Zookeeper入门到实战看这篇就够了
1. 前言 在上一篇[Zookeeper入门]相关概念总结 中已经完美的讲解了 Zookeeper入门 相关概念总结,接下来讲讲ZooKeeper 实战使用. 这篇文章简单给演示一下 ZooKeepe ...
- (五)springmvc+mybatis+dubbo+zookeeper分布式架构 整合 - maven构建根项目
上一篇我们介绍<springmvc+mybatis+dubbo+zookeeper分布式架构 整合 - maven模块规划>,从今天开始,我们将对代码的每一个构建做详细的记录,能够帮助大家 ...
- Springboot 整合 Dubbo/ZooKeeper 详解 SOA 案例
摘要: 原创出处:www.bysocket.com 泥瓦匠BYSocket 希望转载,保留摘要,谢谢! "看看星空,会觉得自己很渺小,可能我们在宇宙中从来就是一个偶然.所以,无论什么事情,仔 ...
- 分布式系统设计原理与方案Dubbo+Zookeeper+Spring整合
2019独角兽企业重金招聘Python工程师标准>>> 一直在思考分布式系统设计的问题,业务对象原封不动的情况下部署在客户端和服务器端,可以根据配置文件选择是连接服务器还是连接本地的 ...
- 精华【分布式、微服务、云架构dubbo+zookeeper+springmvc+mybatis+shiro+redis】分布式大型互联网企业架构!...
2019独角兽企业重金招聘Python工程师标准>>> 框架简介--主要定位于互联网企业架构,已内置企业信息化系统的基础功能和高效的代码生成工具,包括:系统权限组件.数据权限组件.数 ...
- dubbo+zookeeper+dubbo管理控制台实践demo
2019独角兽企业重金招聘Python工程师标准>>> 1,安装并启动zookeeper注册服务,这里使用的是3.4.6版本. 下载解压后,在zookeeper-3.4.6/conf ...
最新文章
- Springboot08-项目单元测试(接口测试)
- CentOS 6.5源码包安装MySQL
- Java 应用中的日志
- chapter 15 运算符详解
- Android之Handler探索
- 网页设计中HTML常范的五个错误
- Rockchip USB转485
- rabbitmq接口异常函数方法_分布式系统消息中间件——RabbitMQ的使用进阶篇
- 盲盒拓客小程序商家联盟红包分销裂变抽奖小程序源码
- 华为全新折叠屏方案曝光:让人眼前一亮!
- 95-140-124-源码-transform-算子fold
- gtk不是C语言的专属,c++也可以
- php访问父类的所有属性,php – 在父类中使用$this仅在子类中显示父类属性
- 单体内置对象_第五章 单体内置对象
- centos7 安装sogou输入法
- tftp命令怎么传输文件,5步掌握tftp命令的使用方法
- Vue项目上传图片后在ie浏览器卡死
- 洛谷【入门4】数组 P2141 [NOIP2014 普及组] 珠心算测验
- java魂斗罗zip_魂斗罗rom
- 06-数据类型的常用操作-字符串常用操作
热门文章
- java io 常用类库_JDK 中需要掌握的常用类库
- Harmony OS — RoundProgressBar圆形进度条
- 《Android 第1行代码》读后感—第11章【Android 特色开发——基于位置的服务】
- Android BroadcastReceiver(三)
- FJUT Home_W的gcd(乱搞)题解
- 2017-2018-1 20155220 《信息安全系统设计基础》第十四周学习总结
- 【转】从Chrome源码看JS Object的实现
- 怎样加入社区项目Karbor的Review?
- #VSTS日志# Xamarin构建支持和一大波更新
- PTA是什么?BT-WIFI共存 转帖