實戰Dubbo與Zookeeper、SpringMVC整合使用

時間 2019-11-13

標籤實戰 dubbo zookeeper springmvc 整合使用欄目 Dubbo 简体版

原文原文鏈接

爲何用Dubbo：

Dubbo是阿里開源的開源的一個高性能優秀的服務框架,詳見https://www.oschina.net/question/tag/dubbo，Dubbo撐起阿里的不少業務，能夠理解爲業務的橋樑，一個消費者須要知道哪裏有這麼一個服務，dubbo告訴他，而後他本身去調用。它的原理和優勢詳見https://www.oschina.net/p/dubbo。java

環境：

dubbo-admin-2.5.3.warlinux

CentOS 6.5git

zookeeper-3.4.6.tar.gzgithub

jdk-7u25-linux-x64.gzweb

Dubbo與Zookeeper、SpringMVC整合使用

一、zookeeper集羣搭建

關於zookeeper集羣搭建，能夠參考我以前寫的博客。spring

連接地址：https://my.oschina.net/u/2489417/blog/778600apache

二、配置dubbo-admin的管理頁面

（1）：複製local文件夾dubbo-admin-2.5.3.war包，放在tomcat的webapps/ROOT下，而後進行解壓：api

拷貝：瀏覽器

[root@wbx1 local]# cp /usr/local/dubbo-admin-2.5.3.war /usr/local/apache-tomcat-7.0.68/webapps/ROOT/
spring-mvc

解壓：

jar -xvf dubbo-admin-2.5.3.war

（2）:而後到webapps/ROOT/WEB-INF下，有一個dubbo.properties文件，裏面指向Zookeeper ，使用的是Zookeeper 的註冊中心，如圖所示：

（3）而後啓動tomcat服務，用戶名和密碼：root,並訪問服務，顯示登錄頁面，說明dubbo-admin部署成功，如圖所示：

3：SpringMVC與Dubbo的整合

（1）Maven構建的多模塊項目

這裏不介紹了，你們能夠參考我以前博客 https://my.oschina.net/u/2489417/blog/777443

（2）咱們先開發服務註冊的，就是提供服務，項目結構如圖所示：

a:SDK項目里加入一個服務接口，代碼以下：

b:Service項目裏在pom.xml加入Dubbo和Zookeeper的jar包代碼以下：

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>com.wangbx</groupId>
<artifactId>project-parent</artifactId>
<version>0.0.1-SNAPSHOT</version>
</parent>
<artifactId>project-service</artifactId>
<packaging>jar</packaging>
<name>project-service</name>
<dependencies>
       <dependency>
           <groupId>com.wangbx</groupId>
           <artifactId>project-SDK</artifactId>
           <version>${project.parent.version}</version>
       </dependency>
       <dependency>
           <groupId>com.wangbx</groupId>
           <artifactId>project-mybatis</artifactId>
           <version>${project.parent.version}</version>
       </dependency>

       <dependency>
   <groupId>org.springframework</groupId>
   <artifactId>spring-webmvc</artifactId>
   <version>4.3.3.RELEASE</version>
</dependency>
       <dependency>
           <groupId>org.apache.zookeeper</groupId>
           <artifactId>zookeeper</artifactId>
           <version>3.4.6</version>
       </dependency>
       <dependency>
           <groupId>com.github.sgroschupf</groupId>
           <artifactId>zkclient</artifactId>
           <version>0.1</version>
       </dependency>
       <dependency>
           <groupId>com.alibaba</groupId>
           <artifactId>dubbo</artifactId>
           <version>2.5.3</version>
           <exclusions>
               <exclusion>
                   <artifactId>spring</artifactId>
                   <groupId>org.springframework</groupId>
               </exclusion>
           </exclusions>
       </dependency>
   </dependencies>
</project>

c:service項目實現具體的服務，代碼以下：

package com.wbx.project.service.information;

import org.springframework.stereotype.Service;

import com.wbx.project.dto.RealNameRegDto;
import com.wbx.project.interfaces.information.TestRegistryService;

@Service("testRegistryService")
public class TestRegistryServiceImpl implements TestRegistryService{

   public String userBind(RealNameRegDto realNameRegDto) {
       // TODO Auto-generated method stub
       return "hello"+realNameRegDto.getFullName();
   }

}
d:咱們服務以及實現好了，這時要暴露服務，代碼以下：

dubbo-tfs-provider.xml

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

   <bean id="propertyConfigurer"
   class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
   <property name="locations">
   <list>
   <value>classpath:application.properties</value>
   </list>
   </property>
   </bean>
   <dubbo:application name="${dubbo.application.name}" owner="${dubbo.application.owner}" />
   <dubbo:registry protocol="${dubbo.monitor.protocol}" address="${dubbo.registry.address}" />
   <dubbo:protocol name="${dubbo.protocol.name}" port="${dubbo.protocol.port}" />

<dubbo:service interface="com.wbx.project.interfaces.information.TestRegistryService" ref="testRegistryService" timeout="100000" owner="${dubbo.application.owner}" group="${dubbo.service.group}"/>

</beans>

applicationContext.xml

xsi:schemaLocation="
   http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
   http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd
   http://www.springframework.org/schema/cache http://www.springframework.org/schema/cache/spring-cache.xsd
   http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd
   http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd
   http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task.xsd
   http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util.xsd
   http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc.xsd"
   default-lazy-init="true">
   <context:property-placeholder ignore-resource-not-found="true" ignore-unresolvable="true"
       location="classpath*:/application.properties" />

   
   <context:component-scan base-package="com.wbx.project">
   </context:component-scan>

</beans>

e:編寫服務啓動類DemoProvider

f:啓動項目，而後咱們在Dubbo管理頁面上顯示，已經暴露的服務，但顯示尚未消費者，由於咱們還沒實現消費者服務，如圖所示：

第二：咱們在開發服務消費者，就是調用服務,咱們看一會兒項目project-SpringMVC,消費者項目結構如圖所示：

a:一樣在project-SpringMVC添加下依賴的jar,有Dubbo和Zookeeper的jar包，同時依賴子項目project-SDK,代碼以下：

pom.xml

<?xml version="1.0"?>
<project xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd" xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>com.wangbx</groupId>
<artifactId>project-parent</artifactId>
<version>0.0.1-SNAPSHOT</version>
</parent>
<groupId>com.wangbx</groupId>
<artifactId>project-SpringMVC</artifactId>
<version>0.0.1-SNAPSHOT</version>
<packaging>war</packaging>
<name>project-SpringMVC Maven Webapp</name>
<url>http://maven.apache.org</url>
<dependencies>
<dependency>
           <groupId>com.wangbx</groupId>
           <artifactId>project-SDK</artifactId>
           <version>${project.parent.version}</version>
       </dependency>
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>3.8.1</version>
<scope>test</scope>
</dependency>
<dependency>
   <groupId>servletapi</groupId>
   <artifactId>servlet-api</artifactId>
   <version>2.4</version>
</dependency>
<dependency>
   <groupId>org.springframework</groupId>
   <artifactId>spring-webmvc</artifactId>
   <version>4.3.3.RELEASE</version>
</dependency>
<dependency>
           <groupId>org.apache.zookeeper</groupId>
           <artifactId>zookeeper</artifactId>
           <version>3.4.6</version>
       </dependency>
       <dependency>
           <groupId>com.github.sgroschupf</groupId>
           <artifactId>zkclient</artifactId>
           <version>0.1</version>
       </dependency>
       <dependency>
           <groupId>com.alibaba</groupId>
           <artifactId>dubbo</artifactId>
           <version>2.5.3</version>
           <exclusions>
               <exclusion>
                   <artifactId>spring</artifactId>
                   <groupId>org.springframework</groupId>
               </exclusion>
           </exclusions>
       </dependency>
</dependencies>
<build>
<finalName>project-SpringMVC</finalName>
</build>
</project>

b:咱們建立消費的dubbo.properties文件來配置dubbo,代碼以下：

dubbo.properties

# dubbo config
dubbo.application.name=project-Consumer
dubbo.application.owner=wangbx
dubbo.registry.address=zookeeper://192.168.102.136:2181?backup=192.168.102.137:2181,192.168.102.132:2181
dubbo.monitor.protocol=registry
dubbo.protocol.name=dubbo
dubbo.protocol.serialization=dubbo
dubbo.protocol.port=20881
dubbo.protocol.accesslog=true
dubbo.service.group=wangbx

# logback
dubbo.container=spring,logback
dubbo.application.logger=slf4j
dubbo.logback.file=logs/biz-qa-manage.logback.log
dubbo.logback.level=INFO
dubbo.logback.maxhistory=10

c:咱們再建立配置文件applicationContext-dubbo-service.xml，用來讀取dubbo配置屬性，同時生成遠程服務代理，可供消費方調用引用服務，代碼以下：

applicationContext-dubbo-service.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-4.0.xsd
http://code.alibabatech.com/schema/dubbo
   http://code.alibabatech.com/schema/dubbo/dubbo.xsd ">
       <bean id="propertyConfigurer"
   class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
   <property name="locations">
   <list>
   <value>classpath:dubbo/dubbo.properties</value>
   </list>
   </property>
   </bean>

<dubbo:application name="${dubbo.application.name}" owner="${dubbo.application.owner}" />

       <dubbo:registry protocol="${dubbo.monitor.protocol}" address="${dubbo.registry.address}" />

<dubbo:protocol name="${dubbo.protocol.name}" port="${dubbo.protocol.port}" />


<dubbo:reference id="testRegistryService" interface="com.wbx.project.interfaces.information.TestRegistryService" check="false" timeout="100000" owner="${dubbo.application.owner}" group="${dubbo.service.group}"/>

</beans>

d:controller層實現注入服務TestRegistryService，調用服務的具體實現代碼以下：

HelloController

package com.springmvc.controller;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.RequestMapping;
import com.wbx.project.dto.RealNameRegDto;
import com.wbx.project.interfaces.information.TestRegistryService;

@Controller
public class HelloController {

   @Autowired
   private TestRegistryService testRegistryService;

   @RequestMapping(value="/Hello")
   public String HelloWorld(Model model){

       RealNameRegDto realNameRegDto = new RealNameRegDto();
       realNameRegDto.setFullName("*****dubbo+SpringMVC");
       String str = testRegistryService.userBind(realNameRegDto);
       model.addAttribute("message","Hello World!!!"+str);
       return "Helloworld";
   }

}

e:web.xml咱們完善下，代碼以下

<web-app xmlns="http://java.sun.com/xml/ns/javaee"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_3_0.xsd"
version="3.0">

   <servlet>
       <servlet-name>spring-mvc</servlet-name>
       <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>
   </servlet>


   <servlet-mapping>
       <servlet-name>spring-mvc</servlet-name>
       <url-pattern>/</url-pattern>
   </servlet-mapping>

   <context-param>
       <param-name>contextConfigLocation</param-name>
       <param-value>
           classpath*:/applicationContext-dubbo-service.xml
       </param-value>
   </context-param>
   <context-param>
       <param-name>spring.profiles.default</param-name>
       <param-value>production</param-value>
   </context-param>

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