zoukankan      html  css  js  c++  java
  • dubbo 搭建开发环境

    本文是基于maven的,预先使用,先装maven。

    dubbo是一个分布式服务框架,提供一个SOA的解决方案。简单的说,dubbo就像在生产者和消费者中间架起了一座桥梁,使之能透明交互。

    本文旨在搭建一个可供使用和测试dubbo环境,使用了spring框架;使用了zookeeper和dubbo服务。

    准备:

    zookeeper:直接去官方网站下载即可,下载后解压,不需要改任何配置即可使用。

    dubbo:直接去阿里巴巴下载即可,下载后解压并放到tomcat的webapps目录下,修改WEB-INF/dubbo.properties中属性如下:

    #zookeeper的地址和端口

    dubbo.registry.address=zookeeper://127.0.0.1:2181

    #登录dubbo管理页面时的root用户和guest用户的密码

    dubbo.admin.root.password=root

    dubbo.admin.guest.password=guest

     

    代码:

    如果你清楚生产者-消费者模型,那么将会很容易理解dubbo的使用步骤。

    一个生产者-消费者模型的代码实现需要3部分:生产者代码,消费者代码,中间接口。

    中间接口:创建一个mavan项目,然后添加一个接口如下:

    publicinterface ITest {

    public voidsayHello(String message);

    }

    生产者代码

    创建一个mavan项目,并引入spring依赖、中间接口依赖、zookeeper依赖及dubbo依赖如下

    <dependency>

    <groupId>org.springframework</groupId>

    <artifactId>spring-context</artifactId>

    <version>4.1.6.RELEASE</version>

    </dependency>

    <!-- 中间接口,根据你的情况进行修改 -->

    <dependency>

    <groupId>com.dubbo.demo</groupId>

    <artifactId>DubboIServiceDemo</artifactId>

    <version>0.0.1</version>

    </dependency>

    <dependency>

    <groupId>org.apache.zookeeper</groupId>

    <artifactId>zookeeper</artifactId>

    <version>3.4.6</version>

    </dependency>

    <dependency>

    <groupId>com.alibaba</groupId>

    <artifactId>dubbo</artifactId>

    <version>2.5.3</version>

    </dependency>

    <!-- 连接zookeeper的客户端 -->

    <dependency>

    <groupId>com.github.sgroschupf</groupId>

    <artifactId>zkclient</artifactId>

    <version>0.1</version>

    </dependency>

    编写中间接口的实现,代码如下,注意这里通过注解的方式将此类标记为了spring服务

    @Service("springservice")

    public class Test implements ITest {

    /*

     * @authorShixy

     *@date  2016年1月5日

     * @seecom.dubbo.iservice.ITest#sayHello(Java.lang.String)

     */

    @Override

    public void sayHello(String message) {

    System.out.println("service say:" +message);

    }

    }

     

    编写spring配置文件,注意需要引入dubbo的schema:

    <?xml version="1.0"encoding="UTF-8"?>

    <beansxmlns="http://www.springframework.org/schema/beans"

    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xmlns:jee="http://www.springframework.org/schema/jee"

    xmlns:tx="http://www.springframework.org/schema/tx"xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"

    xmlns:context="http://www.springframework.org/schema/context"

    xsi:schemaLocation="http://www.springframework.org/schema/beans

    http://www.springframework.org/schema/beans/spring-beans-3.1.xsd

    http://www.springframework.org/schema/tx

    http://www.springframework.org/schema/tx/spring-tx-3.1.xsd

    http://www.springframework.org/schema/jee

    http://www.springframework.org/schema/jee/spring-jee-3.1.xsd

    http://code.alibabatech.com/schema/dubbo

    http://code.alibabatech.com/schema/dubbo/dubbo.xsd

    http://www.springframework.org/schema/context

    http://www.springframework.org/schema/context/spring-context-3.1.xsd"

    default-lazy-init="false">

     

    <bean id="springservice"class="com.dubbo.iservice.impl.Test">

    </bean>

    <!--提供方应用名称信息,这个相当于起一个名字,我们dubbo管理页面比较清晰是哪个应用暴露出来的 -->

    <dubbo:applicationname="dubbo_provider"></dubbo:application>

    <!--使用zookeeper注册中心暴露服务地址 -->

    <dubbo:registry address="zookeeper://127.0.0.1:2181"  check="false"subscribe="false" register=""></dubbo:registry>

    <!--要暴露的服务接口 -->

    <dubbo:serviceinterface="com.dubbo.iservice.ITest" ref="springservice"/>

    </beans>

     

     

    编写测试类:

    public class Demo {

    public static void main(String[] args) {

    //这里注意spring配置文件的名字和路径

    ApplicationContext applicationContext = newClassPathXmlApplicationContext(new String[] {"classpath*:config/applicationContext-commons.xml" });

    while(true);

    }

    }

    消费者代码

    创建一个mavan项目,并引入spring依赖、中间接口依赖、zookeeper依赖及dubbo依赖,这里和生产者是完全相同的。

    编写spring配置文件,注意需要引入dubbo的schema:

    <?xml version="1.0"encoding="UTF-8"?>

    <beansxmlns="http://www.springframework.org/schema/beans"

    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xmlns:jee="http://www.springframework.org/schema/jee"

    xmlns:tx="http://www.springframework.org/schema/tx"xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"

    xmlns:context="http://www.springframework.org/schema/context"

    xsi:schemaLocation="http://www.springframework.org/schema/beans

    http://www.springframework.org/schema/beans/spring-beans-3.1.xsd

    http://www.springframework.org/schema/tx

    http://www.springframework.org/schema/tx/spring-tx-3.1.xsd

    http://www.springframework.org/schema/jee

    http://www.springframework.org/schema/jee/spring-jee-3.1.xsd

    http://code.alibabatech.com/schema/dubbo

    http://code.alibabatech.com/schema/dubbo/dubbo.xsd

    http://www.springframework.org/schema/context

    http://www.springframework.org/schema/context/spring-context-3.1.xsd"

    default-lazy-init="false">

    <dubbo:applicationname="dubbo_consumer"></dubbo:application>

    <!--使用zookeeper注册中心暴露服务地址 -->

    <dubbo:registryaddress="zookeeper://127.0.0.1:2181"

    check="false"></dubbo:registry>

    <!--要引用的服务 -->

    <dubbo:referenceinterface="com.dubbo.iservice.ITest"

    id="springservice" ></dubbo:reference>

    </beans>

     

    编写测试类:

    public class ClientDemo {

    public static void main(String[] args) {

    //这里注意spring配置文件的名字和路径

    ApplicationContext applicationContext = newClassPathXmlApplicationContext(new String[] {"classpath*:config/applicationContext-commons.xml" });

    ITest        test = (ITest) applicationContext.getBean("springservice");

    test.sayHello("abcdefg");

    while(true);

    }

    }

     

    开始测试:

    1.启动zookeeper。执行zookeeper目录下:bin/zkServer.cmd启动服务

    2.启动dubbo服务。启动dubbo所在tomcat(详见本文开头),dubbo启动后,可通过http://127.0.0.1:8080/dubbo-admin来查看dubbo服务状态

    3.启动生产者服务。运行生产者测试类Client.Java

    4.启动消费者服务。运行消费者服务代码ClientDemo.java,此时可以在生产者的控制台看到服务被调用了。

     

    此时整个dubbo测试已经完成。同时我们可以在dubbo的web端看到生产者、消费者的状态以及各个服务的调用情况。

    为了方便大家,本测试用例以及需要的工具都可以在这里下载:

    zookeeper下载:http://download.csdn.net/detail/sxyandapp/9425428

    dubbo下载(配置文件已修改,可直接解压后放到tomcat中使用):http://download.csdn.net/detail/sxyandapp/9425438

    实例代码下载(包含接口、生产者、消费者):http://download.csdn.net/detail/sxyandapp/9425445

  • 相关阅读:
    Jinja2模板引擎简介
    单元测试
    Blueprint属性
    状态保持中的cookie
    异常捕获abort方法
    数据库迁移
    Flask-SQLAlchemy中 ORM 一对多的模型关系定义步骤
    request请求的常用属性
    搜索引擎
    Mark
  • 原文地址:https://www.cnblogs.com/zuolun2017/p/6434884.html
Copyright © 2011-2022 走看看