dubbo+zookeeper简单环境搭建

dubbo+zoopeeper例子

目录

• dubbo+zoopeeper例子
  • dubbo
    • dubbo相关

标签（空格分隔）： 分布式

---

dubbo

dubbo相关

dubbo是目前国内比较流行的一种分布式服务治理方案。还有一种就是esb了。一般采用的是基于Apache servicemix 和 Apache Camel和activemq这种方式。这里先介绍一下dubbo的相关。
dubbo工程一般分为3个module.一个服务者，一个消费者，一个接口。其中服务者和消费者都依赖于接口文件。工程图类似如下

+wordspace
    |-接口
    |-服务者
    |-消费者

新建三个maven项目，其中接口/服务者为普通java项目，以后打成jar包，采用java -jar命令运行。

• 接口的很简单就一个接口文件：

public interface OrderInterface {
    void add(String message);
    void add(Object o);
    void orderHasCase();
}

• 服务者也比较简单，就是实现了接口文件。暂时不添加数据库方面的支持。后面会有一个示例项目来做一个比较全的示例。

public class OrderServiceImpl implements OrderInterface {
    public void add(String s) {
        System.out.println(s);
    }
    public void orderHasCase() {

    }
    public void add(Object o) {
        System.out.println("objcect:" + o);
    }
}

在服务者里添加spring的配置文件，及ip信息等。

<?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"
       xsi:schemaLocation="http://www.springframework.org/schema/beans
        http://www.springframework.org/schema/beans/spring-beans.xsd
        http://code.alibabatech.com/schema/dubbo
        http://code.alibabatech.com/schema/dubbo/dubbo.xsd
        ">
    <!-- 具体的实现bean -->
    <bean id="orderService"
          class="com.yks.service.OrderServiceImpl"/>
    <!-- 提供方应用信息，用于计算依赖关系 -->
    <dubbo:application name="oms_provider"/>
    <!-- 使用multicast广播注册中心暴露服务地址
     -->
    <!--<dubbo:registry address="multicast://224.1.1.1:1234" />-->
    <!-- 使用zookeeper注册中心暴露服务地址 -->
    <dubbo:registry address="zookeeper://192.168.3.15:2181"/>
    <!-- 用dubbo协议在20880端口暴露服务 -->
    <dubbo:protocol name="dubbo" port="20880"/>
    <!-- 声明需要暴露的服务接口 -->
    <dubbo:service interface="com.yks.oms.OrderInterface"
                   ref="orderService"/>
</beans>

• 消费者测试程序，消费者可以是web也可以是jar形式的，这里为了方便测试，只是用了一个main方法。

public class TestMain {
    public static void main(String[] args) {
        ClassPathXmlApplicationContext classPathXmlApplicationContext = new ClassPathXmlApplicationContext("customer.xml");
        classPathXmlApplicationContext.start();
        OrderInterface orderService = (OrderInterface) classPathXmlApplicationContext.getBean("orderService");
        String message = "test";
        orderService.add(message);
    }
}

消费者配置文

<?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"
       xsi:schemaLocation="http://www.springframework.org/schema/beans
        http://www.springframework.org/schema/beans/spring-beans.xsd
        http://code.alibabatech.com/schema/dubbo
        http://code.alibabatech.com/schema/dubbo/dubbo.xsd
        ">
    <!-- consumer application name -->
    <dubbo:application name="consumer-of-helloworld-app"/>
    <!-- registry address, used for consumer to discover services -->
    <!--<dubbo:registry address="multicast://224.1.1.1:1234" />-->
    <dubbo:registry address="zookeeper://192.168.3.15:2181"/>
    <dubbo:consumer timeout="5000"/>
    <!-- which service to consume? -->
    <dubbo:reference id="orderService"
                     interface="com.yks.oms.OrderInterface"/>
</beans>

• zookeeper 我这里采用的是使用zookeeper管理的。所以要安装zookeepker.
  1.下载zookeeper.tar.gz解压
  2.zk启动时会读取zoo.cfg配置文件，我们复制一下zookeeper文件夹下conf/zoo_sample.cfg 改名为zoo.cfg,zoo.cfg里面配置文件很简单，就是配置一些目录时间端口等信息。
  3.启动zk:sh bin/zkServer.sh start

启动zk            sh bin/zkServer.sh start
查看ZK服务状态:   sh bin/zkServer.sh status
停止ZK服务:       sh bin/zkServer.sh stop
重启ZK服务:       sh bin/zkServer.sh restart 

• 安装dubbo-admin
  去github上下载dubbo项目。按照dubbo文档的提示去执行编译dubbo-admin。会生成dubbo-admin.war
  把war解压到tomcat ROOT目录下。然后修改WEB-INF下dubbo.properties里面的ip地址，还可以修改密码等信息
  修改完毕后启动tomcat.然后访问ip:8080看看有没有界面。如果出现登录则没问题。如果没反映就是jdk版本的问题。dubbo-admin一般运行1.5-1.7之间，你有可能用了jdk1.8，这里在重新修改一下dubbo的pom然后重新打包就可以。具体修改方法请看github-issus.如果还不可以请下载我下面给的地址里的war包。

• 启动
  启动服务者，在dubboadmin就可以看到相应的服务对象。至此一个简单的dubbo就搭建起来了。
  代码（dubbo-admin）都在github上了。
  github地址:https://github.com/wongloong/aboutDubbo.git