??斗地主捕鱼电竞提现秒到 广告位招租 - 15元/月全站展示
??支付宝搜索579087183领大额红包 ??伍彩集团官网直营彩票
??好待遇→招代理 ??伍彩集团官网直营彩票
??络茄网 广告位招租 - 15元/月全站展示
使用dubbo+zookeeper+spring boot构建服务的方法详解

转载   2018-05-14   浏览量:369


前言

  互联网的发展,网站应用的规模不断扩大,常规的垂直应用架构已无法应对,分布式服务架构以及流动计算架构势在必行,Dubbo是一个分布式服务框架,在这种情况下诞生的。现在核心业务抽取出来,作为独立的服务,使前端应用能更快速和稳定的响应。

  Dubbo是什么

  Dubbo是Alibaba开源的分布式服务框架,它最大的特点是按照分层的方式来架构,使用这种方式可以使各个层之间解耦合(或者最大限度地松耦合)。从服务模型的角度来看,Dubbo采用的是一种非常简单的模型,要么是提供方提供服务,要么是消费方消费服务,所以基于这一点可以抽象出服务提供方(Provider)和服务消费方(Consumer)两个角色。关于注册中心、协议支持、服务监控等内容

  Dubbo能做什么

  当网站变大后,不可避免的需要拆分应用进行服务化(微服务),以提高开发效率,调优性能,节省关键竞争资源等。
当服务越来越多时,服务的URL地址信息就会爆炸式增长,配置管理变得非常困难,F5硬件负载均衡器的单点压力也越来越大。

  当进一步发展,服务间依赖关系变得错踪复杂,甚至分不清哪个应用要在哪个应用之前启动,架构师都不能完整的描述应用的架构关系。

  接着,服务的调用量越来越大,服务的容量问题就暴露出来,这个服务需要多少机器支撑?什么时候该加机器?等等……

在遇到这些问题时,都可以用Dubbo来解决。

  本次和大家分享的是dubbo框架应用的初略配置和zookeeper注册中心的使用;说到注册中心现在我使用过的只有两种:zookeeper和Eureka,zk我结合dubbo来使用,而Eureka结合springcloud使用,因此后面将和大家分享一些关于微服务的一些篇章,希望对你有好的帮助。

  安装注册中心zookeeper

  dubbo框架之provider和consumer

  dubbo-admin部署

安装注册中心zookeeper

  首先,我们需要在网上搜索下zookeeper下载地址,我这里是linux系统,所以下载了zookeeper-3.3.6.tar.gz包,通过 tar -zxvf zookeeper-3.3.6.tar.gz 解压出来,需要注意的是一般的包里面配置文件都是默认的sample版本,zookeeper默认配置文件名只zoo.cfg,为了不每次指定文件名来运行,因此需要我们自己在conf目录下创建一个名称为zoo.cfg的配置文件,文件内容可以从zoo_sample.cfg拷贝或者把这个文件重命名都行,内容如下 vim zoo.cfg :

# The number of milliseconds of each tick
tickTime=2000 #心跳频率
# The number of ticks that the initial 
# synchronization phase can take
initLimit=10 #限制连接
# The number of ticks that can pass between 
# sending a request and getting an acknowledgement
syncLimit=5
# the directory where the snapshot is stored.
dataDir=/tmp/zookeeper #数据存储文件夹
# the port at which the clients will connect
clientPort=2081 #zookeeper对外的端口

  这里就不修改参数信息了,采用默认;简单介绍下linux下怎么编辑文件内容的常用的几个命令:

  vim zoo.cfg:查看文件内容

  insert:执行插入命令

  esc:取消命令,再接着按:q:退出,:wq:保存并退出

  当有了zoo.cfg后,我们只需要进入她的bin目录里面查找zkServer.sh文件,通过执行: ./zkServer.sh start 命令启动zookeeper注册中心,正常启动提示如:

  

  通常情况是zookeeper作为注册中心在单独的一台服务器上,而程序(这里指我本地)需要调用另外注册中心需要检查zookeeper开放的端口是否能通,我本地是window10因此可以不需要通过zookeeper客户端去验证端口,只需要通过 telnet ip 2081 就能检测出是否端口开放;

dubbo框架之provider和consumer

  首先为了方便,我们需要定义一个统一的接口,该接口就是业务抽出来的公用接口,我们单独对这种接口包装成一个module,我这里是dubbo_api,我们在这个module中定义如下的接口:

 public interface UserService {
 
 List<MoUser> getUsers();
 }

  然后,创建一个provider???,这个??槿ヒ览礵ubbo_api???,并且实现UserService接口,代码如:

public class UserServiceImpl implements UserService {

 @Value("${server.port}")
 private int port;

 /**
 * @return
 */
 @Override
 public List<MoUser> getUsers() {

 List<MoUser> list = new ArrayList<>();
 for (int i = 0; i < 5; i++) {
  MoUser user = new MoUser();
  user.setUserName("shenniu" + i);
  user.setUserPwd("端口:" + port);
  list.add(user);
 }
 return list;
 }
}

  作为服务提供者,要使用dubbo框架就需要先引入dubbo,然后再做一些配置,首先我们需要在dubbo_provider??橥ü齧aven引入dubbo依赖,注册中心用的zookeeper所以也需要通过maven引入相应的依赖:

<dependency>
  <groupId>org.apache.zookeeper</groupId>
  <artifactId>zookeeper</artifactId>
  <version>3.4.8</version>
 </dependency>
 <dependency>
  <groupId>com.101tec</groupId>
  <artifactId>zkclient</artifactId>
  <version>0.3</version>
 </dependency>
 <dependency>
  <groupId>com.alibaba</groupId>
  <artifactId>dubbo</artifactId>
  <version>2.5.3</version>
  <exclusions>
  <exclusion>
   <groupId>org.springframework</groupId>
   <artifactId>spring</artifactId>
  </exclusion>
  </exclusions>
 </dependency>
 <dependency>
  <groupId>com.example</groupId>
  <artifactId>dubbo_api</artifactId>
  <version>0.0.1-SNAPSHOT</version>
 </dependency>

  完成依赖后,剩下的就是对dubbo的provider的配置了,创建resources/dubbo-conf/server.xml的配置文件,文件内容:

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

 <!-- 提供者名称 -->
 <dubbo:application name="demo-provider" />

 <!-- zookeeper注册中心的服务地址 -->
 <dubbo:registry protocol="zookeeper" address="192.168.168.168:2081" />

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

 <!-- 用户服务接口 -->
 <dubbo:service interface="service.UserService" ref="userService" />

 <!-- 用户服务接口实现 -->
 <bean id="userService" class="com.example.demo.service.UserServiceImpl"/>
</beans>

  在DubboProviderApplication入口增加资源导入 @ImportResource("classpath:dubbo-conf/*.xml") ,到这里我们的服务提供端就完成了,查看下启动日志:

  

  服务提供者启动暂无异常,再来看调用方创建一个dubbo_consumer的moduel,同样去引入dubbo_api公共接口的??橐览?,然后创建一个UserController,并暴露一个get的user接口:

@RestController
public class UserController {
 @Autowired
 private UserService userService;
 @GetMapping("/users")
 public List<MoUser> getUsers(){
 return userService.getUsers();
 }
}

  这里的UserService是公共接口的注入;编码完成后剩下的就是consumer端引入dubbo和zookeeper依赖了:

<dependency>
  <groupId>org.apache.zookeeper</groupId>
  <artifactId>zookeeper</artifactId>
  <version>3.4.8</version>
 </dependency>
 <dependency>
  <groupId>com.101tec</groupId>
  <artifactId>zkclient</artifactId>
  <version>0.3</version>
 </dependency>
 <dependency>
  <groupId>com.alibaba</groupId>
  <artifactId>dubbo</artifactId>
  <version>2.5.3</version>
  <exclusions>
  <exclusion>
   <groupId>org.springframework</groupId>
   <artifactId>spring</artifactId>
  </exclusion>
  </exclusions>
 </dependency>

  我们同样创建名称resources/dubbo-conf/client.xml的配置文件,并在application入口引入这个资源:

@ImportResource("classpath:dubbo-conf/*.xml")
@SpringBootApplication
public class DubboConsumerApplication {
 public static void main(String[] args) {
  SpringApplication.run(DubboConsumerApplication.class, args);
 }
}

  client.xml的配置内容如:

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="//www.springframework.org/schema/beans"
  xmlns:xsi="//www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="//code.alibabatech.com/schema/dubbo"  xsi:schemaLocation="//www.springframework.org/schema/beans   //www.springframework.org/schema/beans/spring-beans.xsd
   //code.alibabatech.com/schema/dubbo
   //code.alibabatech.com/schema/dubbo/dubbo.xsd">
 <!-- 服务名 -->
 <dubbo:application name="demo-consumer" />
 <!-- zookeeper注册中心暴露服务地址 -->
 <dubbo:registry protocol="zookeeper" address="192.168.168.168:2081" />
 <!-- 用户服务接口 -->
 <dubbo:reference id="userService" interface="service.UserService" />
</beans>

  这个时候一个简单的服务提供者,服务调用者配置和编码都完成了,3个module如下:

  

  然后分别启动provider,consumer;再通过consumer暴露的controller接口请求接口,我这里的地址是 //localhost:8082/users :

  

  效果是Consumer通过注入的UserService接口依赖调用getUsers()拿到了Provider返回的结果,也表示此次dubbo框架的简单使用算成功了。

dubbo-admin部署

  作为一个流行的rpc框架dubbo有这一个开源的监控工具dubbo-admin,不得不说现在网上现成的dubbo-admin.war包要么现在下来不能用要么就是下载需要csdn积分,版本多种多样有点坑啊,果断去git拉源码自己打包,git地址: https://github.com/apache/incubator-dubbo-ops ,拉下来后我们只需要关注dubbo-admin工程,其他的暂可忽略;打开项目后,我们需要改的地方只有如下截图配置(也可以对打包后的配置文件修改):

  

#zookeeper配置地址和端口
dubbo.registry.address=zookeeper://127.0.0.1:2081
#后台登录密码
dubbo.admin.root.password=root
dubbo.admin.guest.password=guest

  执行打包后,能得到名称:dubbo-admin-2.0.0.war包,然后放在tomcat中,再通过浏览器浏览,账号和密码:都是root;登录后能看到我们之前的启动的provider和consumer在里面,这就是dubbo-admin监控注册中心服务的界面,能够直接对这些服务做点击操作,其他的不多说自行尝试吧?!?/p>

git地址: https://github.com/shenniubuxing3    nuget发布包:https://www.nuget.org/profiles/shenniubuxing3


转载自://www.jb51.net/article/140058.htm

招聘 不方便扫码就复制添加关注:程序员招聘谷,微信号:jobs1024



微服务理念以及dobbo+zookeeper入门微服务架构
微服务理念以及dobbo+zookeeper入门微服务架构。微服务架构成了当下的技术热点,实现微服务是要付出很大成本的,但也许是因为微服务的优点太过于吸引人,以至于大部分开发者都将它当成未来的发展趋势。
ZooKeeper是按照CP原则构建的,不适合做Service服务发现
ZooKeeper是按照CP原则构建的,不适合做Service服务发现。
Zookeeper ACL 使用node-zookeeper-client
再分布式系统中,ACL(AccessControl)十分重要;Zookeeper也提供了十分好用的ACL接口,下面我记录一下在nodejs下如何实现zookeeper的访问控制。Zookeeper的ACL通常表示为:Scheme:Id:Permission,即S
zookeeper环境搭建与启动
解压[[email protected]]#tarzxvfzookeeper-3.4.6.tar.gz[[email protected]]#pwd/home/zookeeper/zookeeper-3.4.6[[email protected]]#新建目录:[[email protected]]#mk
Hbase和Zookeeper分开管理
Hbase和Zookeeper分开管理,第一步:编辑confhbase-envsh,找到HBASE_MANAGES_ZK,加入如下一行:exportHBASE_MANAGES_ZK=false,HBase,不自动维护Zookeeper。
CentOS7下配置Hadoop集群和Zookeeper集群
1.版本centos764位,VM虚拟机12.0,jdk1.8.0hadoop2.9.0zookeeper3.4.62.Hadoop集群的配置0.下载解压安装文件解压命令tar-xzvf压缩文件名文件夹路径1.修改hadoop-env.sh添加jdk环境exportJAVA_HOME=/usr/java/jdk1.8.0_144文...
docker overlay network 使用ZooKeeper
docker通常情况下使用的是bridge网络,这种无法进行跨主机通讯,即,一台主机上的docker容器是不能直接访问另一台主机上的容器的内部IP。如果我们想要通DNS
SpringCloud用Zookeeper搭建配置中心的方法
本篇文章主要介绍了SpringCloud用Zookeeper搭建配置中心的方法,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧
ZookeeperJavaAPI 二 zk节点内容的操作和节点的删除
ZookeeperJavaAPI(二)zk节点内容的操作和节点的删除。