当前位置：网站首页 > 编程网 > 正文

dubbo整合zookeeper项目实战 dubbo zookeeper原理

yuyutoo 2024-10-26 16:08 2 浏览 0 评论

先来看下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的地址

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不支持这种日记显示");
}

接入效果图

contextloaderlistener

上一篇：SpringMVC源码解析(4):DispatcherServlet上下文初始化
下一篇：面试官:谈谈SpringSecurity是如何代理过滤器链的?三张图搞定

dubbo整合zookeeper项目实战 dubbo zookeeper原理

整体框架说明：

Zookeeper 原理图：

dubbo安装

一、服务端

二、客户端

cat 接入

相关推荐

取消回复欢迎你发表评论:

织梦(Dedecms)建站教程织梦建站详细步骤

【开源分享】2024在线客服系统PHP源码(安装教程+全新UI)

2024PHP在线客服系统源码+完全开源带详细搭建教程

2024php在线客服系统实时聊天系统源码

2024最新php在线客服系统源码(免费开源+全新UI+终身使用)

【开源分享】2024PHP在线客服系统源码(搭建教程+终身使用)

如何做一个搜索网站?如何做一个外贸网站?dedecms建站教程全集

网站建站基础第十二课(dedecms基础搭建教程)

dedecms网站如何logo设计和ico站标如何替换

SEO入门学习之安装Dede模板网站-耀途盛世

dubbo整合zookeeper项目实战 dubbo zookeeper原理

整体框架说明：

Zookeeper 原理图：

dubbo安装

一、服务端

二、客户端

cat 接入

相关推荐

取消回复欢迎 你 发表评论:

织梦(Dedecms)建站教程 织梦建站详细步骤

【开源分享】2024在线客服系统PHP源码(安装教程+全新UI)

2024PHP在线客服系统源码+完全开源 带详细搭建教程

2024php在线客服系统实时聊天系统源码

2024最新php在线客服系统源码(免费开源+全新UI+终身使用)

【开源分享】2024PHP在线客服系统源码(搭建教程+终身使用)

如何做一个搜索网站?如何做一个外贸网站?dedecms建站教程全集

网站建站基础第十二课(dedecms基础搭建教程)

dedecms网站如何logo设计和ico站标如何替换

SEO入门学习之安装Dede模板网站-耀途盛世

取消回复欢迎你发表评论:

织梦(Dedecms)建站教程织梦建站详细步骤

2024PHP在线客服系统源码+完全开源带详细搭建教程