二、分布式服务框架-Dubbo

 

1、简介:Dubbo是阿里巴巴开源的一个高性能分布式服务框架,使得应用可以通过高性能的RPC实现服务的输出和输入功能,可以和Spring实现无缝集成。

2、原理:在分布式需求下,通常服务提供方被称为:Service Provider,服务需求方被称为:Service Consumer,另外还会使用一个注册中心,官方推荐使用Zookeeper。

二、分布式服务框架-Dubbo

Registry:注册中心;

Provider:服务提供方;

Consumer:服务消费方;

Monitor:监控中心

1.服务提供方需要在注册中心注册自己提供的服务;2.服务消费方需要向注册中心订阅自己需要的服务;

3.注册中心会将服务提供方的地址发送给消费方;4.服务消费方获取到地址列表后,基于软负载均衡算法,挑选一台合适的服务提供方并调用服务,如果失败,很快切换到另一台服务提供方;

5.服务提供方和服务消费方会将调用次数、调用时间等信息定时发送给监控中心,由监控中心统计。

这一系列过程就好比我们找房屋中介租房子,首先房东如果有需要出租的房子,则会先到房屋中介登记房屋信息;当有人需要租房子时,会到房屋中介去了解房源信息,并把自己的需求告诉中介,比如房子面积、需要几居室的、月租多少钱等。中介会根据需求查询已登记的房源,并把合适房源告诉给租房者,可能是一套房源,也可能是多套房源,租房者会在其中挑选一套最合适的房源,并和房东面议价格、签订合同等,达成协议则拎包入住,中介会把这个过程记录下来备案。

其中,Service-Provider就好比房东,Service-Consumer就好比租房者,Registry、Monitor就好比中介,在分布式服务中,ZooKeeper扮演的就是中介的角色:

3、安装部署,首先安装ZooKeeper,直译为动物园管理员,是Apache Hadoop下的子项目。

首先安装Zookeeper:

通过WinSCP上传到指定的linux服务器的/usr/local/src目录下,解压安装包:

二、分布式服务框架-Dubbo

cd到安装目录:cd /urs/local/src

解压缩:tar -zxvf zookeeper-3.4.6.tar.gz

解压缩会有一个同名文件夹:

二、分布式服务框架-Dubbo

cd进入zookeeper-3.4.6文件夹:

 cd zookeerer-3.4.6,找到conf文件夹:

二、分布式服务框架-Dubbo

在conf下有三个文件,找到zoo_sample.cfg:

二、分布式服务框架-Dubbo

将配置文件复制一份:

cp zoo_sample.cfg zoo.cfg

重新cd 到bin目录下,启动Zookeeper:./zkServer.sh start

二、分布式服务框架-Dubbo

二、分布式服务框架-Dubbo

显示已启动。

然后配置Dubbo:

新建Maven工程,在工程下新建四个子工程,分别是:

父工程:parent-demo

子工程:shopping-common    通用类,jar包

    shopping-interface    接口类,jar包

    shopping-service-product 商品服务,war包

    shopping-web-console   后台,war包

在parent-demo中设置统一控制版本、统一依赖管理,且不强制依赖,在shopping-common中设置依赖管理。

依赖关系是shopping-service-product、shopping-web-console都依赖shopping-common,shopping-service-product依赖shopping-interface,shopping-web-console依赖shopping-service-product。

二、分布式服务框架-Dubbo

接下来就是配置服务提供方和服务消费方了,引入必要的依赖包后,在shopping-interface下新建接口类:DubboTestService.java

二、分布式服务框架-Dubbo二、分布式服务框架-Dubbo

在shopping-service-product下新建接口实现类:DubboTestServiceImpl.java

二、分布式服务框架-Dubbo二、分布式服务框架-Dubbo

使用@Service注解将id设置为dubboTestService。

在resources下新建spring配置文件和dubbo配置文件。

<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:mvc="http://www.springframework.org/schema/mvc"
    xmlns:context="http://www.springframework.org/schema/context"
    xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx"
    xmlns:task="http://www.springframework.org/schema/task" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
    xsi:schemaLocation="http://www.springframework.org/schema/beans 
        http://www.springframework.org/schema/beans/spring-beans-4.0.xsd 
        http://www.springframework.org/schema/mvc 
        http://www.springframework.org/schema/mvc/spring-mvc-4.0.xsd 
        http://www.springframework.org/schema/context 
        http://www.springframework.org/schema/context/spring-context-4.0.xsd 
        http://www.springframework.org/schema/aop 
        http://www.springframework.org/schema/aop/spring-aop-4.0.xsd 
        http://www.springframework.org/schema/tx 
        http://www.springframework.org/schema/tx/spring-tx-4.0.xsd
        http://www.springframework.org/schema/task
           http://www.springframework.org/schema/task/spring-task-4.0.xsd
        http://code.alibabatech.com/schema/dubbo        
        http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
    <context:component-scan base-package="com.xx" />
    <import resource="config/*.xml"/>
</beans>
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:mvc="http://www.springframework.org/schema/mvc"
    xmlns:context="http://www.springframework.org/schema/context"
    xmlns:aop="http://www.springframework.org/schema/aop" 
    xmlns:tx="http://www.springframework.org/schema/tx"
    xmlns:task="http://www.springframework.org/schema/task"
    xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
    xsi:schemaLocation="http://www.springframework.org/schema/beans 
        http://www.springframework.org/schema/beans/spring-beans-4.0.xsd 
        http://www.springframework.org/schema/mvc 
        http://www.springframework.org/schema/mvc/spring-mvc-4.0.xsd 
        http://www.springframework.org/schema/context 
        http://www.springframework.org/schema/context/spring-context-4.0.xsd 
        http://www.springframework.org/schema/aop 
        http://www.springframework.org/schema/aop/spring-aop-4.0.xsd 
        http://www.springframework.org/schema/tx 
        http://www.springframework.org/schema/tx/spring-tx-4.0.xsd
        http://www.springframework.org/schema/task
           http://www.springframework.org/schema/task/spring-task-4.0.xsd
        http://code.alibabatech.com/schema/dubbo        
        http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
        
    <!-- 配置dubbo提供方名称 -->
    <dubbo:application name="shopping-service-product" />
    <!-- 配置注册中心地址 -->
    <dubbo:registry address="172.16.30.51:2181" protocol="zookeeper" />
    <!-- 定义dubbo协议端口 -->
    <dubbo:protocol port="20880" name="dubbo" />
    <!-- 提供方暴露实现类 -->
    <dubbo:service interface="com.xx.shopping.service.DubboTestService" ref="dubboTestService" />
</beans>

这里ref就是前面@Service注解里定义的id:dubboTestService,两者必须一样,interface就是接口所在包名。

接着编写服务消费方:shopping-web-console

二、分布式服务框架-Dubbo

配置springmvc和Controller,并在WEB-INF下新建一个index.jsp页面:

二、分布式服务框架-Dubbo二、分布式服务框架-Dubbo

 

<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:mvc="http://www.springframework.org/schema/mvc"
    xmlns:context="http://www.springframework.org/schema/context"
    xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx"
    xmlns:task="http://www.springframework.org/schema/task" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
    xsi:schemaLocation="http://www.springframework.org/schema/beans 
        http://www.springframework.org/schema/beans/spring-beans-4.0.xsd 
        http://www.springframework.org/schema/mvc 
        http://www.springframework.org/schema/mvc/spring-mvc-4.0.xsd 
        http://www.springframework.org/schema/context 
        http://www.springframework.org/schema/context/spring-context-4.0.xsd 
        http://www.springframework.org/schema/aop 
        http://www.springframework.org/schema/aop/spring-aop-4.0.xsd 
        http://www.springframework.org/schema/tx 
        http://www.springframework.org/schema/tx/spring-tx-4.0.xsd
        http://www.springframework.org/schema/task
           http://www.springframework.org/schema/task/spring-task-4.0.xsd
        http://code.alibabatech.com/schema/dubbo        
        http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
    <context:component-scan base-package="com.xx"></context:component-scan>
    <mvc:annotation-driven></mvc:annotation-driven>
    <bean id="jspViewResolver"
        class="org.springframework.web.servlet.view.InternalResourceViewResolver">
        <property name="prefix" value="/WEB-INF/console/" />
        <property name="suffix" value=".jsp" />
    </bean>
    <!-- <import resource="dubbo-consumer.xml"/>  -->
</beans>
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:mvc="http://www.springframework.org/schema/mvc"
    xmlns:context="http://www.springframework.org/schema/context"
    xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx"
    xmlns:task="http://www.springframework.org/schema/task" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
    xsi:schemaLocation="http://www.springframework.org/schema/beans 
        http://www.springframework.org/schema/beans/spring-beans-4.0.xsd 
        http://www.springframework.org/schema/mvc 
        http://www.springframework.org/schema/mvc/spring-mvc-4.0.xsd 
        http://www.springframework.org/schema/context 
        http://www.springframework.org/schema/context/spring-context-4.0.xsd 
        http://www.springframework.org/schema/aop 
        http://www.springframework.org/schema/aop/spring-aop-4.0.xsd 
        http://www.springframework.org/schema/tx 
        http://www.springframework.org/schema/tx/spring-tx-4.0.xsd
        http://www.springframework.org/schema/task
           http://www.springframework.org/schema/task/spring-task-4.0.xsd
        http://code.alibabatech.com/schema/dubbo        
        http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
    
    <!-- 配置dubbo消费方 -->
    <dubbo:application name="shopping-web-console"/>
    <!-- 配置注册中心地址 -->
    <dubbo:registry address="172.16.30.51:2181" protocol="zookeeper" check="false"/>
    <!-- 消费方调用实现类 -->
    <dubbo:reference interface="com.xx.shopping.service.DubboTestService" id="dubboTestService"/>
    
    
</beans>

 index.jsp:

<%@ page language="java" contentType="text/html; charset=UTF-8"
    pageEncoding="UTF-8"%>
<!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
<html>
<head>
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">
<title>Insert title here</title>
</head>
<body>
    Hello,World!
    <input id="inputOne" name="inputOne" type="text"/> 
</body>
<script>
</script>
</html>

最后测试一下dubbo是否成功,启动zookeeper,将shopping-service-product和shopping-web-console部署到tomcat容器,先启动服务提供方shopping-service-product,再启动服务消费方shopping-web-console,在浏览器输入地址:

http://localhost:8081/shopping/test/index.do

可以看到如下页面:

二、分布式服务框架-Dubbo

说明dubbo测试成功!

上一篇:python – 乘以两个词典(价格,股票)的值,然后求和


下一篇:Codeforces 1139F Dish Shopping 树状数组套平衡树 || 平衡树