先来看下dubbo整合zookeeper的交互流程图

整体框架说明：

服务方

①、服务方加载配置中心，启动服务。

②、服务方向注册中心注册服务。

消费方

③、消费方加载配置中心，启动服务。

④、向注册中心订阅已注册的服务

⑤、注册中心监控到服务方注册有变更，通知消费方。

服务调用过程

⑥、消费方向服务方调用远程接口。

⑦、服务方接口调用完成后，向Dubbo接口日志服务异步发送日志。

⑧、消费方接口调用完成后，向Dubbo接口日志服务异步发送日志。

⑨、Dubbo接口日志服务向CAT监控中心发送统计源数据。

服务监控中心

⑩、Dubbo服务监控中心

Zookeeper 原理图：

流程说明：

• 服务提供者启动时向/dubbo/com.foo.BarService/providers目录下写入自己的URL地址。

• 服务消费者启动时订阅/dubbo/com.foo.BarService/providers目录下的提供者URL地址。

• 并向/dubbo/com.foo.BarService/consumers目录下写入自己的URL地址。

• 监控中心启动时订阅/dubbo/com.foo.BarService目录下的所有提供者和消费者URL地址。

Zookeeper单机配置:

<dubbo:registry address="zookeeper://10.20.153.10:2181" />

Or:

<dubbo:registry protocol="zookeeper" address="10.20.153.10:2181" />

Zookeeper集群配置:

<dubbo:registry address="zookeeper://10.20.153.10:2181?backup=10.20.153.11:2181,10.20.153.12:2181" />

Or:

<dubbo:registry protocol="zookeeper" address="10.20.153.10:2181,10.20.153.11:2181,10.20.153.12:2181" />

同一Zookeeper，分成多组注册中心:

<dubbo:registry id="chinaRegistry" protocol="zookeeper" address="10.20.153.10:2181" group="china" />

<dubbo:registry id="intlRegistry" protocol="zookeeper" address="10.20.153.10:2181" group="intl" />

dubbo安装

下载地址：http://download.csdn.net/detail/qq780825111/8750491

官方地址：http://code.alibabatech.com/mvn/releases/com/alibaba/dubbo-admin/2.4.1/dubbo-admin-2.4.1.war

将 dubbo-admin-2.4.1.war文件放在Tomcat E:\apache-tomcat-8.0.32\webapps目录下

unzip dubbo-admin-2.4.1.war -d /opt/apache-tomcat-6.0.37/webapps/ROOT

2、配置:

( windows 环境 解压的war包中自带有dubbo.properties 文件，直接修改就可以； linux上的话将dubbo.properties放在当前用户目录下，)修改zookeeper的地址

1. vim webapps/ROOT/WEB-INF/dubbo.properties

3、配置信息如下：

dubbo.registry.address=zookeeper://10.0.65.3:2181
dubbo.admin.root.password=root
dubbo.admin.guest.password=guest

这边使用的是zookeeper的注册中心（关于zookeeper的配置 之前的内容中记录过）。

启动tomcat：

说明：确定zookeeper启动后再去启动tomcat。

访问：http://localhost：8088 （这是我的tomcat的访问路径）

出现以下界面说明安装配置成功，登录密码为root/root

登录成功界面：（我的注册中心有1个提供者 2个消费者 都已经显示出来）

下面是我查看消费者信息的页面 还有一些功能 可以去尝试下

集成Spring实例：

一、服务端

1. web.xml

< !DOCTYPE web-app PUBLIC

 "-//Sun Microsystems, Inc.//DTD Web Application 2.3//EN"

 "http://java.sun.com/dtd/web-app_2_3.dtd" >

<web-app>
  <display-name>Archetype Created Web Application</display-name>
  <context-param>

<param-name>contextConfigLocation</param-name>
<param-value>classpath*:config/spring/appcontext-*.xml
<param-value>
<context-param>


<listener>
<listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
</listener>
</web-app>

2. appcontext-dubbo-provider.xml

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

<</span>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  ">  


    <dubbo:application name="zjh_provider"  />  

    <dubbo:registry address="zookeeper://127.0.0.1:4180" />   
  
    <dubbo:protocol name="dubbo" port="20880" />  
   
    <dubbo:service interface="com.dubbo.demo.service.DemoService" ref="demoService" />        

</beans>  

3. applicationcontext-beans.xml

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

<</span>beans xmlns="http://www.springframework.org/schema/beans"

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

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

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

xsi:schemaLocation="

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

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

     http://www.springframework.org/schema/jdbc http://www.springframework.org/schema/jdbc/spring-jdbc-3.2.xsd

     http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.0.xsd

     http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.2.xsd">

<context:component-scan base-package="com.dubbo.demo" />

</beans>

4. User对象

@Data
public class User implements Serializable{

private String name;

private int age;

private String sex;


@Override

public String toString() {

return "User [name=" + name + ", age=" + age + ", sex=" + sex + "]";

}


}

5. DemoService

public interface DemoService {    

    String sayHello(String name);  

  
    public List  getUsers();  


}  

6. DemoServiceImpl

@Service("demoService")
public class DemoServiceImpl implements DemoService{  

@PostConstruct
public void init(){

System.out.println("@@@@@DemoServiceImpl init");

}

    

    public String sayHello(String name) {  
           return "Hello " + name;  

    }  

    public List getUsers() {  
        List  list = new ArrayList ();  

        User u1 = new User();  

        u1.setName("jack");  

        u1.setAge(20);  

        u1.setSex("男");  

          

        User u2 = new User();  

        u2.setName("tom");  

        u2.setAge(21);  

        u2.setSex("女");  

          

        User u3 = new User();  

        u3.setName("rose");  

        u3.setAge(19);  

        u3.setSex("女");  

          

        list.add(u1);  

        list.add(u2);  

        list.add(u3);  

        return list;  

    }  

}  

二、客户端

1. web.xml

< !DOCTYPE web-app PUBLIC

 "-//Sun Microsystems, Inc.//DTD Web Application 2.3//EN"

 "http://java.sun.com/dtd/web-app_2_3.dtd" >

<web-app>

  <display-name>Archetype Created Web Application</display-name>

  <context-param>

<param-name>contextConfigLocation</param-name>

<param-value>classpath*:config/spring/appcontext-*.xml

</param-value>

</context-param>


<listener>
<listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
</listener>

<servlet>

<servlet-name>ClientServlet</servlet-name>
<display-name>ClientServlet</display-name>
<description></description>
<servlet-class>com.dubbo.demo.client.servlet.ClientServlet</servlet-class>
</servlet>
<servlet-mapping>
<servlet-name>ClientServlet</servlet-name>
<url-pattern>/ClientServlet</url-pattern>
</servlet-mapping>

</web-app>

2. appcontext-dubbo-consumer.xml

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

<</span>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  

        ">  

    dubbo:application name="zjh_consumer" />  

    <dubbo:registry address="zookeeper://127.0.0.1:4180" />   

    <dubbo:reference id="demoService"  interface="com.dubbo.demo.service.DemoService" /> 
  
</beans>  

3. DemoService和User

可以服务端提供jar包，测试时可以自己在客户端的工程创建一样的类文件即可

4. ClientServlet

public class ClientServlet extends HttpServlet {

private static final long serialVersionUID = 1L;

private static DemoService demoService;


    public ClientServlet() {

    }

@Override

public void init() throws ServletException {

super.init();

 

ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(  

                new String[] { "config/spring/appcontext-dubbo-consumer.xml" });  

        context.start();    

        demoService = (DemoService) context.getBean("demoService");

}


protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {

System.out.println("servlet start..."); 

        String hello = demoService.sayHello("tom");   

        System.out.println(hello);         

        List list = demoService.getUsers();  

        if (list != null && list.size() > 0) {  

            for (int i = 0; i < list.size(); i++) {  

                System.out.println(list.get(i));  

            }  

        }   

System.out.println("servlet end");

}


protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {

// TODO Auto-generated method stub

}

}

验证

访问：http://localhost:8080/dubbo-client/ClientServlet

dubbo管理页面：

应用页面：

提供者页面:

消费者页面：

服务页面：

cat 接入

1. pom.xml文件中添加包依赖

    <dependency>
        <groupId>com.dianping.cat</groupId>
        <artifactId>cat-client</artifactId>
        <version>1.4.2-SNAPSHOT</version>
    </dependency> 

2. error信息接入

• log4j配置

文件中，添加appender配置

<appender name="catAppender" class="com.dianping.cat.log4j.CatAppender"> 
  <param name="Threshold" value="ERROR"></param> 
</appender>

在root中添加

<appender-ref ref="catAppender" />

如：

<root> 
   <level value="ERROR" /> 
   <appender-ref ref="CONSOLE" /> 
   <appender-ref ref="catAppender" /> 
  </root>

注：catAppender展现的是log记录的error信息，项目中必须使用log正确地记录error信息，Cat才会正常呈现。正确记录是指发生Exception时，按以下方式记录

try {
    // TODO:业务逻辑
} catch (Exception e) {
    logger.error("支持显示的错误信息" , e);

    logger.error("目前版本Cat不支持这种日记显示");
} 

• 接入效果图