Dubbox框架与Zookeeper入门之DEMO

Love The Way You Lie 2022-11-20 01:48 120阅读 0赞

## **入门小Demo** ##

### **服务提供者开发** ###

开发步骤：

**（1）创建Maven工程（WAR）dubboxdemo-service  ，在pom.xml中引入依赖**

<table> 
 <tbody> 
 <tr> 
 <td>&lt;project&nbsp;xmlns="http://maven.apache.org/POM/4.0.0"&nbsp;xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"&nbsp;xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"&gt;&nbsp;&nbsp;&lt;modelVersion&gt;4.0.0&lt;/modelVersion&gt;&nbsp;&nbsp;&lt;groupId&gt;cn.itcast.dubboxdemo&lt;/groupId&gt;&nbsp;&nbsp;&lt;artifactId&gt;dubboxdemo-service&lt;/artifactId&gt;&nbsp;&nbsp;&lt;version&gt;0.0.1-SNAPSHOT&lt;/version&gt;&nbsp;&nbsp;&lt;packaging&gt;war&lt;/packaging&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;properties&gt;&lt;spring.version&gt;4.2.4.RELEASE&lt;/spring.version&gt;&nbsp;&nbsp;&nbsp;&lt;/properties&gt;&nbsp;&nbsp;&nbsp;&nbsp;&lt;dependencies&gt;&lt;!-- Spring --&gt;&lt;dependency&gt;&lt;groupId&gt;org.springframework&lt;/groupId&gt;&lt;artifactId&gt;spring-context&lt;/artifactId&gt;&lt;version&gt;${spring.version}&lt;/version&gt;&lt;/dependency&gt;&lt;dependency&gt;&lt;groupId&gt;org.springframework&lt;/groupId&gt;&lt;artifactId&gt;spring-beans&lt;/artifactId&gt;&lt;version&gt;${spring.version}&lt;/version&gt;&lt;/dependency&gt;&lt;dependency&gt;&lt;groupId&gt;org.springframework&lt;/groupId&gt;&lt;artifactId&gt;spring-webmvc&lt;/artifactId&gt;&lt;version&gt;${spring.version}&lt;/version&gt;&lt;/dependency&gt;&lt;dependency&gt;&lt;groupId&gt;org.springframework&lt;/groupId&gt;&lt;artifactId&gt;spring-jdbc&lt;/artifactId&gt;&lt;version&gt;${spring.version}&lt;/version&gt;&lt;/dependency&gt;&lt;dependency&gt;&lt;groupId&gt;org.springframework&lt;/groupId&gt;&lt;artifactId&gt;spring-aspects&lt;/artifactId&gt;&lt;version&gt;${spring.version}&lt;/version&gt;&lt;/dependency&gt;&lt;dependency&gt;&lt;groupId&gt;org.springframework&lt;/groupId&gt;&lt;artifactId&gt;spring-jms&lt;/artifactId&gt;&lt;version&gt;${spring.version}&lt;/version&gt;&lt;/dependency&gt;&lt;dependency&gt;&lt;groupId&gt;org.springframework&lt;/groupId&gt;&lt;artifactId&gt;spring-context-support&lt;/artifactId&gt;&lt;version&gt;${spring.version}&lt;/version&gt;&lt;/dependency&gt;&lt;!-- dubbo相关 --&gt;&lt;dependency&gt;&lt;groupId&gt;com.alibaba&lt;/groupId&gt;&lt;artifactId&gt;dubbo&lt;/artifactId&gt;&lt;version&gt;2.8.4&lt;/version&gt;&lt;/dependency&gt;&lt;dependency&gt;&lt;groupId&gt;org.apache.zookeeper&lt;/groupId&gt;&lt;artifactId&gt;zookeeper&lt;/artifactId&gt;&lt;version&gt;3.4.6&lt;/version&gt;&lt;/dependency&gt;&lt;dependency&gt;&lt;groupId&gt;com.github.sgroschupf&lt;/groupId&gt;&lt;artifactId&gt;zkclient&lt;/artifactId&gt;&lt;version&gt;0.1&lt;/version&gt;&lt;/dependency&gt;&lt;dependency&gt;&lt;groupId&gt;javassist&lt;/groupId&gt;&lt;artifactId&gt;javassist&lt;/artifactId&gt;&lt;version&gt;3.11.0.GA&lt;/version&gt;&lt;/dependency&gt;&lt;/dependencies&gt;&nbsp;&nbsp;&nbsp;&lt;build&gt;&nbsp;&nbsp;&nbsp;&nbsp;&lt;plugins&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;plugin&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;groupId&gt;org.apache.maven.plugins&lt;/groupId&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;artifactId&gt;maven-compiler-plugin&lt;/artifactId&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;version&gt;2.3.2&lt;/version&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;configuration&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;source&gt;1.7&lt;/source&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;target&gt;1.7&lt;/target&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;/configuration&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;/plugin&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;plugin&gt;&lt;groupId&gt;org.apache.tomcat.maven&lt;/groupId&gt;&lt;artifactId&gt;tomcat7-maven-plugin&lt;/artifactId&gt;&lt;configuration&gt;&lt;!-- 指定端口 --&gt;&lt;port&gt;8081&lt;/port&gt;&lt;!-- 请求路径 --&gt;&lt;path&gt;/&lt;/path&gt;&lt;/configuration&gt;&nbsp;&nbsp;&nbsp;&nbsp;&lt;/plugin&gt;&nbsp;&nbsp;&lt;/plugins&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;/build&gt;&lt;/project&gt;</td> 
 </tr> 
 </tbody> 
</table>

**（2）在工程的webapps下创建WEB-INF文件夹，创建web.xml**

**（3）创建业务接口**

创建包cn.itcast.dubbodemo.service，用于存放业务接口，创建接口

<table> 
 <tbody> 
 <tr> 
 <td>package&nbsp;cn.itcast.dubbodemo.service;/**&nbsp;* 业务接口&nbsp;* @author&nbsp;Administrator&nbsp;*&nbsp;*/public&nbsp;interface&nbsp;UserService { public&nbsp;String getName();}</td> 
 </tr> 
 </tbody> 
</table>

**（4）创建业务实现类**

创建包cn.itcast.dubbodemo.service.impl ，用于存放业务实现类。创建业务实现类：

<table> 
 <tbody> 
 <tr> 
 <td>package&nbsp;cn.itcast.dubbodemo.service.impl;import com.alibaba.dubbo.config.annotation.Service;import&nbsp;cn.itcast.dubbodemo.service.UserService;@Servicepublic&nbsp;class&nbsp;UserServiceImpl implements&nbsp;UserService { public&nbsp;String getName() { return&nbsp;"itcast";}}</td> 
 </tr> 
 </tbody> 
</table>

注意：Service注解与原来不同，需要引入com.alibaba包下的

**（5）编写配置文件**

在src/main/resources下创建applicationContext-service.xml ,内容如下：

注意：dubbo:annotation用于扫描@Service注解。

**（6）测试运行**

tomcat7:run

### **服务消费者开发** ###

开发步骤：

**（1）创建Maven工程（WAR）dubboxdemo-web** ，在pom.xml引入依赖 ，同“dubboxdemo-service”工程。区别就是把tomcat插件的运行端口改为8082 。

**（2）在webapps目录下创建WEB-INF 目录**，并创建web.xml

<table> 
 <tbody> 
 <tr> 
 <td>&lt;?xml&nbsp;version="1.0"&nbsp;encoding="UTF-8"?&gt;&lt;web-app&nbsp;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"version="2.5"&gt;&nbsp;&nbsp;&nbsp;&lt;!-- 解决post乱码 --&gt;&lt;filter&gt;&lt;filter-name&gt;CharacterEncodingFilter&lt;/filter-name&gt;&lt;filter-class&gt;org.springframework.web.filter.CharacterEncodingFilter&lt;/filter-class&gt;&lt;init-param&gt;&lt;param-name&gt;encoding&lt;/param-name&gt;&lt;param-value&gt;utf-8&lt;/param-value&gt;&lt;/init-param&gt;&lt;init-param&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;param-name&gt;forceEncoding&lt;/param-name&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;param-value&gt;true&lt;/param-value&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;/init-param&gt;&nbsp;&nbsp;&lt;/filter&gt;&lt;filter-mapping&gt;&lt;filter-name&gt;CharacterEncodingFilter&lt;/filter-name&gt;&lt;url-pattern&gt;/*&lt;/url-pattern&gt;&lt;/filter-mapping&gt;&nbsp;&nbsp;&lt;servlet&gt;&nbsp;&nbsp;&lt;servlet-name&gt;springmvc&lt;/servlet-name&gt;&nbsp;&nbsp;&lt;servlet-class&gt;org.springframework.web.servlet.DispatcherServlet&lt;/servlet-class&gt;&nbsp;&nbsp;&lt;!-- 指定加载的配置文件 ，通过参数contextConfigLocation加载--&gt;&nbsp;&nbsp;&lt;init-param&gt;&nbsp;&nbsp;&lt;param-name&gt;contextConfigLocation&lt;/param-name&gt;&nbsp;&nbsp;&lt;param-value&gt;classpath:applicationContext-web.xml&lt;/param-value&gt;&nbsp;&nbsp;&lt;/init-param&gt;&nbsp;&nbsp;&lt;/servlet&gt;&nbsp;&nbsp;&nbsp;&nbsp;&lt;servlet-mapping&gt;&nbsp;&nbsp;&lt;servlet-name&gt;springmvc&lt;/servlet-name&gt;&nbsp;&nbsp;&lt;url-pattern&gt;*.do&lt;/url-pattern&gt;&nbsp;&nbsp;&lt;/servlet-mapping&gt;&lt;/web-app&gt;</td> 
 </tr> 
 </tbody> 
</table>

**（3）拷贝业务接口**

将“dubboxdemo-service”工程的cn.itcast.dubboxdemo.service 包以及下面的接口拷贝至此工程。

（4）编写Controller

<table> 
 <tbody> 
 <tr> 
 <td>package&nbsp;cn.itcast.dubboxdemo.controller;import&nbsp;org.springframework.beans.factory.annotation.Autowired;import&nbsp;org.springframework.stereotype.Controller;import&nbsp;org.springframework.web.bind.annotation.RequestMapping;import&nbsp;org.springframework.web.bind.annotation.ResponseBody;import&nbsp;cn.itcast.dubbodemo.service.UserService;@Controller@RequestMapping("/user")public&nbsp;class&nbsp;UserController { @Referenceprivate&nbsp;UserService userService;@RequestMapping("/showName")@ResponseBodypublic&nbsp;String showName(){ return&nbsp;userService.getName();}}</td> 
 </tr> 
 </tbody> 
</table>

**（5）编写spring配置文件**

在src/main/resources下创建applicationContext-web.xml

<table> 
 <tbody> 
 <tr> 
 <td>&lt;?xml&nbsp;version="1.0"&nbsp;encoding="UTF-8"?&gt;&lt;beans&nbsp;xmlns="http://www.springframework.org/schema/beans"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"&nbsp;xmlns:p="http://www.springframework.org/schema/p"xmlns:context="http://www.springframework.org/schema/context"xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"&nbsp;xmlns:mvc="http://www.springframework.org/schema/mvc"xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc.xsd&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;http://www.springframework.org/schema/context " &gt;http://www.springframework.org/schema/context/spring-context.xsd"&gt;&nbsp;&lt;mvc:annotation-driven &gt;&lt;mvc:message-converters register-defaults="false"&gt;&lt;bean class="org.springframework.http.converter.StringHttpMessageConverter"&gt; &nbsp;&lt;constructor-arg value="UTF-8" /&gt;&lt;/bean&gt; &nbsp;&lt;/mvc:message-converters&gt;&lt;/mvc:annotation-driven&gt;&lt;!-- 引用dubbo&nbsp;服务 --&gt;&lt;dubbo:application name="dubboxdemo-web"&nbsp;/&gt;&lt;dubbo:registry address="zookeeper://192.168.25.132:2181"/&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;dubbo:annotation package="cn.itcast.dubboxdemo.controller"&nbsp;/&gt;&lt;/beans&gt;</td> 
 </tr> 
 </tbody> 
</table>

**（6）测试运行**

tomcat7:run

在浏览器输入http://localhost:8082/user/showName.do，查看浏览器输出结果

## **管理中心的部署** ##

我们在开发时，需要知道注册中心都注册了哪些服务，以便我们开发和测试。我们可以通过部署一个管理中心来实现。其实管理中心就是一个web应用，部署到tomcat即可。

### **管理端安装** ###

（1）编译源码，得到war包

给大家下发的资源中有个dubbox-master.zip  ，这个是dubbox的源码，我们可以使用maven命令编译源码得到“管理端”的war包

将此压缩包解压，在命令符下进入dubbo-admin目录 ，输入maven命令

<table> 
 <tbody> 
 <tr> 
 <td>mvn package -Dmaven.skip.test=true</td> 
 </tr> 
 </tbody> 
</table>

如果你看到如下信息，就说明成功了

![format_png][]

（2）进入target文件夹，你会看到一个dubbo-admin-2.8.4.war ， 在linux服务器上安装tomcat,  将此war包上传到linux服务器的tomcat的webapps下。为了访问方便，你可以把版本号去掉。 启动tomcat后自动解压。

（3）如果你部署在zookeeper同一台主机并且端口是默认的2181，则无需修改任何配置。如果不是在一台主机上或端口被修改，需要修改WEB-INF下的dubbo.properties  ，修改如下配置：

<table> 
 <tbody> 
 <tr> 
 <td>dubbo.registry.address=zookeeper://127.0.0.1:2181</td> 
 </tr> 
 </tbody> 
</table>

修改后重新启动tomcat

### **管理端使用** ###

（1）打开浏览器，输入http://192.168.25.132:8080/dubbo-admin/ ,登录用户名和密码均为root 进入首页。 (192.168.25.132:)是我部署的linux主机地址。

![Image 1][]

（2）启动服务提供者工程，即可在服务治理-提供者查看到该服务。

![Image 1][]

点击其中一条数据后可以查看详情。

![format_png 1][]

（3）启动服务消费者工程，运行页面，观察“消费者”列表

![format_png 2][]

![format_png 3][]

长按图片识别二维码关注

![format_png 4][]

CSDN博客地址

一个喜欢分享最新开发技术的公众号，是我个人的公众号，强烈推荐关注。

关注后回复1001，领取一整套JAVA和大数据相关学习资源以及精品教程

[format_png]: /images/20221120/181984e1445f4a98a45b82196810705f.png
[Image 1]: https://imgconvert.csdnimg.cn/
[format_png 1]: /images/20221120/422a7a58b3904c30bb5f183b71b31a1b.png
[format_png 2]: /images/20221120/2a708dc06a2147f3839b8705f8ed499a.png
[format_png 3]: /images/20221120/f991b009e4c9437a956fae2f77230580.png
[format_png 4]: /images/20221120/68764063f198465681a87bb17ffefaed.png