Dubbo+ZooKeeper搭建的简单示例

一、简介

　　基于Dubbo + ZooKeeper实现的分布式架构，调用接口方法就像调用本地方法一样调用远程服务。

　　来自Dubbo官网的架构图：

            

　　节点角色说明
节点角色说明
Provider暴露服务的服务提供方
Consumer调用远程服务的服务消费方
Registry服务注册与发现的注册中心
Monitor统计服务的调用次数和调用时间的监控中心
Container服务运行容器
　　调用关系说明
  1. 服务容器负责启动，加载，运行服务提供者。
  2. 服务提供者在启动时，向注册中心注册自己提供的服务。
  3. 服务消费者在启动时，向注册中心订阅自己所需的服务。
  4. 注册中心返回服务提供者地址列表给消费者，如果有变更，注册中心将基于长连接推送变更数据给消费者。
  5. 服务消费者，从提供者地址列表中，基于软负载均衡算法，选一台提供者进行调用，如果调用失败，再选另一台调用。
  6. 服务消费者和提供者，在内存中累计调用次数和调用时间，定时每分钟发送一次统计数据到监控中心。

　　Dubbo 架构具有以下几个特点，分别是连通性、健壮性、伸缩性、以及向未来架构的升级性。

二、搭建Zookeeper注册中心详细步骤参考：

　　https://www.cnblogs.com/sun-flower1314/p/11341499.html

三、创建三个maven工程：接口工程；服务端工程；客户端工程。服务端和客户端去依赖接口工程。

　　接口工程的作用：定义服务接口，供消服务消费者和提供者使用

　　1. 创建接口工程的步骤：

　　　　1）创建一个maven项目，在创建后生成jar包的方式

　　　   

             

 　　　　2）创建完工程后，定义服务接口

package com.hxc.dubbo.demo;public interface DemoService {String sayHello(String name);
}

 

 　　2. 创建服务端工程的步骤：

 　　　　1）和创建接口工程相同，packaging项选择war包的形式

                

 　　　　2）以war包形式创建后，项目的pom.xml文件会报错：

　　　　　　web.xml is missing and <failOnMissingWebXml> is set to true，原因是没有web.xml文件。

　　　　　　解决错误的方法：

　　　　　　①右击项目，选择Properties ——> Project Facets ——> 将Dynamic Web Module选项去掉，然后选择Apply：

　　　　     

 　　　　　② 再次选中Dynamic Web Module，点击下方的Futher configuration available...进行配置web.xml，在弹出的界面中，在Content directory项填入：src/main/webapp，依次点击ok-> Apply -> Apply and close

                  

 　　　　

　　　　　3) 项目创建完成后，在pom.xml中依赖接口工程（即依赖由1创建的接口工程）

　　　　

　　　　或者直接自己手动敲：

　　　　<dependency><groupId>com.hxc.dubboInterfaceDemo</groupId><artifactId>dubboInterfaceDemo</artifactId><version>0.0.1-SNAPSHOT</version></dependency>

　　　4）添加相应的其他依赖jar包

　　 <dependency><groupId>cglib</groupId><artifactId>cglib</artifactId><version>2.2</version></dependency><dependency><groupId>org.aspectj</groupId><artifactId>aspectjweaver</artifactId><version>1.6.8</version></dependency><dependency><groupId>com.alibaba</groupId><artifactId>dubbo</artifactId><version>2.5.5</version></dependency><dependency><groupId>com.101tec</groupId><artifactId>zkclient</artifactId><version>0.10</version></dependency>

　　5）创建服务的接口实现类

package com.hxc.dubbo.demo.provider;import com.hxc.dubbo.demo.DemoService;public class DemoServiceImpl implements DemoService {public String sayHello(String name) {return " Hello " + name;}
}

 　　6）增加配置文件 provider.xml

<?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"><!-- 提供方应用信息，用于计算依赖关系 --><dubbo:application name="hello-world-app"  /><!-- 使用multicast广播注册中心暴露服务地址 方式为： <dubbo:registry address="multicast://224.5.6.7:1234" />--><!-- 采用zookeeper的方式 --><dubbo:registry address="192.168.202.132:2181" protocol="zookeeper" /><!-- 用dubbo协议在20880端口暴露服务 --><dubbo:protocol name="dubbo" port="20880" /><!-- 声明需要暴露的服务接口 --><dubbo:service interface="com.hxc.dubbo.demo.DemoService" ref="demoService" /><!-- 和本地bean一样实现服务 --><bean id="demoService" class="com.hxc.dubbo.demo.provider.DemoServiceImpl" />
</beans>

　　7) 测试提供服务的是否能连接通

　　测试方式一：写测试代码

package com.hxc.demo.test;import java.io.IOException;import org.springframework.context.support.ClassPathXmlApplicationContext;public class ProviderTest {public static void main(String[] args) throws IOException {ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("provider.xml");context.start();System.in.read(); // 按任意键退出
    }
}

　　测试方式二：在web.xml中增加 加载配置文件的 provider.xml 的参数，再将项目添加至tomcat跑起来，查看zookeeper服务中是否已经注册

　　在web.xml中：

<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://java.sun.com/xml/ns/javaee" xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd" id="WebApp_ID" version="2.5"><!-- needed for ContextLoaderListener --><context-param><param-name>contextConfigLocation</param-name><param-value>classpath:provider.xml</param-value></context-param><!-- Bootstraps the root web application context before servlet initialization --><listener><listener-class>org.springframework.web.context.ContextLoaderListener</listener-class></listener>
</web-app>

　　测试通过后，在zookeeper端可以查看服务注册是否成功，若看到下图对应的值，则说明联接成功：

       

　3. 创建客户端工程的步骤：

 　  1）创建客户端工程和创建服务端工程的步骤相同（1-3步骤）

　　2）创建完成后，添加依赖jar包

      <dependency><groupId>cglib</groupId><artifactId>cglib</artifactId><version>2.2</version></dependency><dependency><groupId>org.aspectj</groupId><artifactId>aspectjweaver</artifactId><version>1.6.8</version></dependency><dependency><groupId>com.alibaba</groupId><artifactId>dubbo</artifactId><version>2.5.5</version></dependency><dependency><groupId>com.101tec</groupId><artifactId>zkclient</artifactId><version>0.10</version></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-webmvc</artifactId><version>4.3.10.RELEASE</version><scope>compile</scope></dependency><dependency><groupId>javax.servlet</groupId><artifactId>servlet-api</artifactId><version>2.5</version><scope>provided</scope></dependency><dependency><groupId>javax.servlet</groupId><artifactId>jsp-api</artifactId><version>2.0</version><scope>provided</scope></dependency>

　　3）增加配置文件，consumer.xml

<?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"><!-- 消费方应用名，用于计算依赖关系，不是匹配条件，不要与提供方一样 --><dubbo:application name="consumer-of-helloworld-app"  /><!-- 使用multicast广播注册中心暴露发现服务地址 <dubbo:registry address="multicast://224.5.6.7:1234" /> --><!-- 采用zookeeper的方式 --><dubbo:registry address="192.168.202.132:2181" protocol="zookeeper" /><!-- 生成远程服务代理，可以和本地bean一样使用demoService --><dubbo:reference id="demoService" interface="com.hxc.dubbo.demo.DemoService" />
</beans>

 

　　4) 测试客户端

　　注：测试时，一定要先启动服务端在zookeeper上注册完接口，然后再测试客户端

　　测试方式一：直接写测试代码，运行后在控制台能够看到   Hello world

package com.hxc.dubbo.demo.test;import org.springframework.context.support.ClassPathXmlApplicationContext;import com.hxc.dubbo.demo.DemoService;public class ConsumerTest {public static void main(String[] args) throws Exception {ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("consumer.xml");context.start();DemoService demoService = (DemoService)context.getBean("demoService"); // 获取远程服务代理String hello = demoService.sayHello("world"); // 执行远程方法System.out.println( hello ); // 显示调用结果
    }
}

 

　　测试方式二：在web.xml中增加 加载配置文件的 consumer.xml 的参数，再将项目添加至tomcat跑起来，查看zookeeper服务中是否已经注册

　　在web.xml中：

<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xmlns="http://java.sun.com/xml/ns/javaee"xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd"id="WebApp_ID" version="2.5" ><servlet><servlet-name>springDispatcherServlet</servlet-name><servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class><init-param><param-name>contextConfigLocation</param-name><param-value>classpath:demo-service-consumer.xml</param-value></init-param><load-on-startup>1</load-on-startup></servlet><servlet-mapping><servlet-name>springDispatcherServlet</servlet-name><url-pattern>/</url-pattern></servlet-mapping></web-app>

 

 　　5）再zookeeper服务中心查看结果：

             

 

到此就基本完成了整个服务的搭建，至于dubbo更加详细的API，请参考dubbo官方文档。

关于Dubbo的官方API：https://dubbo.gitbooks.io/dubbo-user-book/  非常全面详细的教程

 

记得点个赞哦 谢谢

 

转载于:https://www.cnblogs.com/sun-flower1314/p/11344896.html

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/549676.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

tftpd32

tftpd32

tftpd32
阅读更多...
uni-calendar更改打点颜色实现签到和缺勤不同打点颜色效果

uni-calendar更改打点颜色实现签到和缺勤不同打点颜色效果

1.公司要实现打卡功能&#xff0c;发现uni-calendar插件不支持不同打点颜色的效果&#xff0c;所以就自己改一下源码 下图是公司ui设计师给的图 2.我们打开调试&#xff0c;可以看到红色打点的样式是.uni-calendar-item__weeks-box-circle 3.我们复制下来这个class名&#xff…
阅读更多...
C++_练习—面积

C++_练习—面积

面积 代码示例&#xff1a; 1 #include <iostream>2 3 using namespace std;4 5 class circle {6 7 public:8 void set_r(int rr);9 double c_circle(); 10 double s_circle(); 11 12 private: 13 int r; 14 }; 15 16 17 void circle::set_r(int rr) …
阅读更多...
C++_练习—函数指针与函数重载

C++_练习—函数指针与函数重载

函数指针与函数重载 成员函数与普通函数区别&#xff1a; 定义一个对象时&#xff0c;系统只为数据成员分配空间。那么对于类的成员函数而言&#xff0c;它如何知道函数中提到的数据成员是哪个对象的数据成员呢&#xff1f;……实际上&#xff0c;C为每个成员函数设置了一个隐藏…
阅读更多...
反编译工具jad的使用

反编译工具jad的使用

from:http://www.javaresearch.org/article/55024.htm这是jad的readme文件jad -sjava example1.classjad的主页是&#xff1a;http://www.geocities.com/SiliconValley/Bridge/8617/jad.htmlCopyright 2000 Pavel Kouznetsov (kpdusyahoo.com).1. 请先读jad主页的否认声明文件2…
阅读更多...
[转载]Redis 持久化之RDB和AOF

[转载]Redis 持久化之RDB和AOF

原文链接&#xff1a;https://www.cnblogs.com/itdragon/p/7906481.html 温馨提示 在正式数据&#xff08;当然是非生产环境啦&#xff09;练习以下操作时&#xff0c;一定一定一定记得备份dump.rdb文件。 我给自己的服务器添加了aof持久化配置&#xff0c;重启后&#xff0c;发…
阅读更多...
C++_练习—构造与析构

C++_练习—构造与析构

构造与析构 1 #include <iostream>2 3 using namespace std;4 5 class info {6 public:7 info(int a);8 info(int a, int b);9 info(int a,int b,int c); 10 11 ~info(); // 无类型无返无参 12 13 private: 14 int age; 15 int *temp; 16 }; …
阅读更多...
分布式 dynamips+dyangen （更新于07.3.30）

分布式 dynamips+dyangen （更新于07.3.30）

更新内容&#xff1a;很多网友都反映用此文方法行不通&#xff0c;现象为&#xff1a;分布在各计算机上的路由器能起来&#xff0c;但互联的端口是Down的&#xff0c;以至于ping 不通。在此特别感谢 flyxj 网友QQ联系到我才引起我的高度注视使问题得到解决&#xff0c;不会再给…
阅读更多...
vs 运行的时候产生伴随cmd窗口

vs 运行的时候产生伴随cmd窗口

简介 很多程序运行的时候&#xff0c;需要输出调试信息。如果没有伴随cmd窗口的话&#xff0c;输出的信息很难被看到 参考链接 https://blog.csdn.net/weixin_39278265/article/details/81865362 转载于:https://www.cnblogs.com/eat-too-much/p/11357709.html
阅读更多...
tcl学习---windows下安装及运行环境

tcl学习---windows下安装及运行环境

以前一直用tcl&#xff0c;但是面试的时候发现很多基本的概念竟然又忘记了。有什么好说的&#xff0c;从头到尾再实践一遍吧~~~~1&#xff1a;下载windows版本不方便UNIX/LINUX,所以直接下载windows版本&#xff0c;现在版本已经到8.5了&#xff1b;下载链接&#xff1a;[url]h…
阅读更多...
OCP-052考试题库汇总（33）-CUUG内部解答版

OCP-052考试题库汇总（33）-CUUG内部解答版

Which two can be exported by a non-administrative account by using Data Pump? A)directory objects B)tables C)tablespaces D)schemas E)database Answer: BD 赵&#xff1a; EXP 和 IMP 是客户端工具程序&#xff0c;它们既可以在客户端使用&#xff0c;也可以在服务端…
阅读更多...
linux mesg 命令详解

linux mesg 命令详解

linux mesg 命令详解功能说明&#xff1a;设置终端机的写入权限。语　　法&#xff1a;mesg [ny]补充说明&#xff1a;将mesg设置y时&#xff0c;其他用户可利用write指令将信息直接显示在您的屏幕上。参　　数&#xff1a;n 不允许气筒用户将信息直接显示在你的屏幕上。y 允许…
阅读更多...
OCP-052考试题库汇总（34）-CUUG内部解答版

OCP-052考试题库汇总（34）-CUUG内部解答版

Where is an expdp operation tracked? A)dump files B)control file C)log files D)Automatic Diagnostic Repository(ADR) E)master table (MT) Answer: E 赵&#xff1a; 题译&#xff1a;哪里有一个 Exdp 操作跟踪? Master table 是一个临时 table&#xff0c;专门为 imp…
阅读更多...
C++_练习—元友三友

C++_练习—元友三友

元友三友 元友函数&#xff1a; 全局函数作为友元函数&#xff1a; 1 #include <iostream>2 3 using namespace std;4 5 class info {6 public:7 void init(int a);8 friend void yuan_fun(info a); // 注意元友函数的参数&#xff01;&#xff01;9 10 private…
阅读更多...
关于《详解》第12.1节按键驱动的进一步阐述

关于《详解》第12.1节按键驱动的进一步阐述

《详解》12.1的按键驱动&#xff0c;是本书的最大失误&#xff0c;应大家的要求&#xff0c;我们很有必要对其进行再次阐述。注意标题是“按键”驱动而非“键盘”驱动&#xff0c;按键往往是一个按钮直接对应于一个可中断的GPIO&#xff0c;而键盘则有一个行列矩阵&#xff0c;…
阅读更多...
几件欣慰的事，关于.Net的培训和嵌入式开发效率

几件欣慰的事，关于.Net的培训和嵌入式开发效率

到软件园这边已经好几个月了&#xff0c;以前.Net的相关的一些东西都慢慢的没怎么接触了。而我去一直在关心相关的东西。以前订阅的一些东西还是很有用的&#xff0c;收集一些相关的资料&#xff0c;也了解一些相关的培训信息。值得欣慰的是&#xff0c;很多培训都是在软件园这…
阅读更多...
C++_练习—继承_公有继承

C++_练习—继承_公有继承

公有继承 公有继承 public&#xff1a; 当类的继承方式为公有继承时,基类的公有和保护成员的访问属性在派生类中 不变,而基类的私有成员不可访问。 即基类的公有成员和保护成员被继承到派生类中仍作为派生类的公有成员和保护成员。派生类的其他成员可以直接访问它们。无 论派…
阅读更多...
MYSQLMANAGER实例管理器总结

MYSQLMANAGER实例管理器总结

好久没有写文章了&#xff0c;今天来看看MYSQL的实例管理器&#xff08;MYSQLMANAGER&#xff09;。一、简单介绍&#xff1a;1、MySQL实例管理器(IM)是通过TCP/IP端口运行的后台程序&#xff0c;用来监视和管理MySQL数据库服务器实例。&#xff08;如果你之前用过MYSQLD_MULTI…
阅读更多...
C++_练习—继承_保护继承

C++_练习—继承_保护继承

保护继承 protected&#xff1a;保护继承 保护继承&#xff1a;当保护继承时&#xff0c;基类的公有和保护成员变成派生类的保护成员,私有成员不可直接访问&#xff01; 1 #include <iostream>2 3 using namespace std;4 5 class info {6 public:7 void setter(int a…
阅读更多...
C++_练习—继承_私有继承

C++_练习—继承_私有继承

私有继承 私有继承&#xff1a;当私有继承时&#xff0c;基类的公有和保护成员变成派生类的私有成员&#xff0c;私有成员不可直接访问 1 #include <iostream>2 3 using namespace std;4 5 class info {6 public:7 void setter(int a, int b) {8 num a;9 …
阅读更多...
最新文章

Copyright @ 2022~2023