1.表现层和服务层是如何实现通信的

  上一篇博客我们讲到分布式架构将一个程序分成了两个程序:表现层和服务层工程,就像两个单独的计算机,大家都知道两个单独的计算机不提供任何外界条件如网络环境,这两台计算机是无法同信的,那么回归到项目中,表现层和服务层两个单独的工程是如何通信的那,;实现远程通信的方法有:
  1、Webservice:效率不高基于soap协议。项目中不推荐使用。
  2、使用restful形式的服务:http+json。很多项目中应用。如果服务太多,服务之间调用关系混乱,需要治疗服务。
  3、使用dubbo:使用rpc协议进行远程调用,直接使用socket通信。传输效率高,并且可以统计出系统之间的调用关系、调用次数


2.什么是dubbo

  Dubbo是一个分布式服务框架,致力于提供高性能和透明化的RPC远程服务调用方案,以及SOA服务治理方案。简单的说,dubbo就是个服务框架,如果没有分布式的需求,其实是不需要用的,只有在分布式的时候,才有dubbo这样的分布式服务框架的需求,并且本质上是个服务要调用的东西


3.dubbo的作用

  1. 透明化的远程方法调用,就像调用本地方法一样调用远程方法,只需简单配置,没有任何API侵入
  2. 软负载均衡及容错机制,可在内网替代F5等硬件负载均衡器,降低成本,减少单点。
  3. 服务自动注册与发现,不再需要写死服务提供方地址,注册中心基于接口名查询服务提供者的IP地址,并且能够平滑添加或删除服务提供者
  Dubbo就是资源调度和治理中心的管理工具


4.dubbo框架

 4.1 节点角色说明:

   Provider: 暴露服务的服务提供方。
   Consumer: 调用远程服务的服务消费方。
   Registry: 服务注册与发现的注册中心。
   Monitor: 统计服务的调用次调和调用时间的监控中心。(dubbo监控中心)
   Container: 服务运行容器。(在此就是spring容器了)

 4.2 调用关系说明:

   1. 服务容器负责启动,加载,运行服务提供者。
   2. 服务提供者在启动时,向注册中心注册自己提供的服务。
   3. 服务消费者在启动时,向注册中心订阅自己所需的服务。
   4. 注册中心返回服务提供者地址列表给消费者,如果有变更,注册中心将基于长连接推送变更数据给消费者。
   5. 服务消费者,从提供者地址列表中,基于软负载均衡算法,选一台提供者进行调用,如果调用失败,再选另一台调用。
   6. 服务消费者和提供者,在内存中累计调用次数和调用时间,定时每分钟发送一次统计数据到监控中心


5.dubbo在工程中的配置,即发布服务

 5.1 服务的提供者端配置

  1. 在servoce工程的pom.xml中添加dubbo依赖的jar包

<!-- dubbo相关 -->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>dubbo</artifactId>
            <exclusions>
                <exclusion>
                    <groupId>org.springframework</groupId>
                    <artifactId>spring</artifactId>
                </exclusion>
                <exclusion>
                    <groupId>org.jboss.netty</groupId>
                    <artifactId>netty</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
        <dependency>
            <groupId>org.apache.zookeeper</groupId>
            <artifactId>zookeeper</artifactId>
        </dependency>
        <dependency>
            <groupId>com.github.sgroschupf</groupId>
            <artifactId>zkclient</artifactId>
        </dependency>

  2.在servoce工程的spring的配置文件中添加dubbo的约束,然后使用dubbo:service发布服务

<!-- 可以使用dubbo标签了 -->
xmlns:dubbo="http://code.alibabatech.com/schema/dubbo" 
<!-- 指定dubbo的xsd规范文件,这样你在进行下面具体配置的时候就会根据这些xsd规范文件给出相应的提示 -->
http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd

<!-- 使用dubbo发布服务 -->
    <!-- 提供方应用信息,用于计算依赖关系,即-->
    <dubbo:application name="e3-manager" />
    <dubbo:registry protocol="zookeeper" address="zookeeper所在服务器ip地址:2181" />
    <!-- 用dubbo协议在20880端口暴露服务 -->
    <dubbo:protocol name="dubbo" port="20880" />
    <!-- 声明需要暴露的服务接口 -->
    <!-- ref就是实现接口的类名,首字母小写 -->
    <dubbo:service interface="cn.e3mall.service.ItemService" ref="itemServiceImpl" timeout="600000"/>

  这样就创建了serv接口的代理对象,注入到spring的容器中了

  3. 这样要在web的pom.xml添加对server接口的引用

        <dependency>
            <groupId>cn.e3mall</groupId>
            <artifactId>e3-manager-interface</artifactId>
            <version>0.0.1-SNAPSHOT</version>
        </dependency>

  4. 在controler中就可以使用service服务了

@Controller
public class ItemController {

    @Autowired
    private ItemService itemService;

    @RequestMapping("/item/{itemId}")
    @ResponseBody
    public TbItem getItemById(@PathVariable Long itemId){
        TbItem tbItem = itemService.getItemById(itemId);
        return tbItem;
    }
}

  至此就完美的表现层和服务层两个独立工程的远程调用了

 5.2 服务的消费者端配置

  1. 在web工程的pom.xml中添加dubbo依赖的jar包

<!-- dubbo相关 -->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>dubbo</artifactId>
            <exclusions>
                <exclusion>
                    <groupId>org.springframework</groupId>
                    <artifactId>spring</artifactId>
                </exclusion>
                <exclusion>
                    <groupId>org.jboss.netty</groupId>
                    <artifactId>netty</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
        <!-- https://mvnrepository.com/artifact/org.apache.zookeeper/zookeeper -->
        <dependency>
            <groupId>org.apache.zookeeper</groupId>
            <artifactId>zookeeper</artifactId>
            <version>3.4.11</version>
            <type>pom</type>
        </dependency>
        <dependency>
            <groupId>com.github.sgroschupf</groupId>
            <artifactId>zkclient</artifactId>
        </dependency>
        <dependency>
            <groupId>log4j</groupId>
            <artifactId>log4j</artifactId>
            <version>1.2.17</version>
        </dependency>

  2.在web工程的spring的配置文件中添加dubbo的约束,然后使用dubbo:reference 添加服务的引用

<!-- 可以使用dubbo标签了 -->
xmlns:dubbo="http://code.alibabatech.com/schema/dubbo" 
<!-- 指定dubbo的xsd规范文件,这样你在进行下面具体配置的时候就会根据这些xsd规范文件给出相应的提示 -->
http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd

<!-- 引用dubbo服务 -->
    <!-- 该工程名,即消费者的名称 -->
    <dubbo:application name="e3-manager-web"/>
    <dubbo:registry protocol="zookeeper" address="192.168.20.216:2181"/>    
    <dubbo:reference interface="cn.e3mall.service.ItemService" id="itemService" />

  服务的提供用dubbo:service;引用服务是用 dubbo:reference


6.dubbo监控中心的安装

  1.在要dubbo监控中心的服务器上部署安装tomcat(因为dubbo监控要安装在tomcat上,其实就是一个打包成war的一个java程序)
  2.部署监控中心:[root@localhost ~]# cp dubbo-admin-2.5.4.war apache-tomcat-7.0.47/webapps/dubbo-admin.war
  3.启动tomcat:bin/server.sh
  4.访问dubbo监控中心:http://dubbo监控中心所在服务器ip地址:8080/dubbo-admin/,默认用户名和密码都是root,可通过/root/apache-tomcat-7.0.47/webapps/dubbo-admin/WEB-INF/dubbo.properties查看

注:
  1. 如果监控中心和注册中心在同一台服务器上,可以不需要任何配置。
  2. 如果不在同一台服务器,需要修改配置文件:

/root/apache-tomcat-7.0.47/webapps/dubbo-admin/WEB-INF/dubbo.properties

7. 什么是zookeeper

  1. 先说什么是注册中心:注册中心负责服务地址的注册与查找,相当于目录服务,服务提供者和消费者只在启动时与注册中心交互,注册中心不转发请求,压力较小
  2. Zookeeper是Apacahe Hadoop的子项目,是一个树型的目录服务,支持变更推送,是个服务注册中心


8.zookeeper的作用

  作为Dubbo服务的注册中心,工业强度较高,可用于生产环境


9.zookeeper的安装

  Zookeeper是java开发的可以运行在windows、linux环境。需要先安装jdk。
  安装步骤:
    第一步:安装jdk
    第二步:把zookeeper的压缩包上传到linux系统。
    第三步:解压缩压缩包
        tar -zxvf zookeeper-3.4.6.tar.gz
    第四步:进入zookeeper-3.4.6目录,创建data文件夹。
    第五步:把zoo_sample.cfg改名为zoo.cfg
        [root@localhost conf]# mv zoo_sample.cfg zoo.cfg
    第六步:修改data属性:dataDir=/root/zookeeper-3.4.6/data
    第七步:启动zookeeper
        [root@localhost bin]# ./zkServer.sh start
    关闭:[root@localhost bin]# ./zkServer.sh stop
    查看状态:[root@localhost bin]# ./zkServer.sh status
  一定要关闭防火墙,本人开始忘了关闭防火墙,zookeeper连不上,解决了好久


10. 总结

  个人理解:dubbo提供服务,zookeeper是注册服务,现在表现层工程和服务层工程现在只是单纯的代码,要写实现远程的调用,必须把它们封装为或赋予服务这个属相,才能注册到zookeeper上,zookeeper只识别服务,不识别单纯的代码:就如卖房子,提供者要将房子的信息(dubbo服务,具体服务是工程代码实现的)注册的中介,不能说把砖块(服务层工程)提供给中介,当找房的人(消费者)需要买A型房时,就去 中介找有没有A型的房

Logo

权威|前沿|技术|干货|国内首个API全生命周期开发者社区

更多推荐