Dubbox与zookeeper

时间 2019-11-16

标签 dubbox zookeeper 栏目 Zookeeper 繁體版

原文原文链接

1.Dubbox框架java

SOA(Service-Oriented Architecture)是一种面向服务的架构。它将应用程序的不一样功能单元（称为服务）进行拆分，并经过这些服务之间定义良好的接口和契约联系起来.linux

Dubbox 是一个分布式服务框架，若是没有分布式的需求，实际上是不须要用的，只有在分布式的时候，才有dubbox这样的分布式服务框架的需求git

2.注册中心Zookeepergithub

注册中心负责服务地址的注册与查找，至关于目录服务，服务提供者和消费者只在启动时与注册中心交互，注册中心不转发请求，压力较小web

3.在linux上安装zookeeperspring

1）安装jdkapache

2）把 zookeeper 的压缩包上传到 linux 系统浏览器

3）解压spring-mvc

tar -zxvf zookeeper-3.4.6.tar.gz -C /usr/local

4）进入 zookeeper-3.4.6 目录，建立 data 文件夹。tomcat

cd zookeeper-3.4.6
mkdir data

5）进入conf目录，把 zoo_sample.cfg 更名为 zoo.cfg

cd conf
mv zoo_sample.cfg zoo.cfg

6）打开zoo.cfg , 修改 data 属性：

dataDir=/usr/local/zookeeper-3.4.6/data

7）进入bin目录，启动zookeeper服务

cd bin
./zkServer.sh start

输出以上内容表示启动成功

关闭服务：

./zkServer.sh stop

查看状态：

./zkServer.sh statu

若是启动状态，提示

若是未启动状态，提示

4.入门小案例

服务消费者开发

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

（2）在webapps目录下建立WEB-INF 目录，建立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"
    version="2.5">    
   <!-- 解决post乱码 -->
    <filter>
        <filter-name>CharacterEncodingFilter</filter-name>       
　　　　 <filter-class>org.springframework.web.filter.CharacterEncodingFilter</filter-class>
        <init-param>
            <param-name>encoding</param-name>
            <param-value>utf-8</param-value>
        </init-param>
        <init-param>  
            <param-name>forceEncoding</param-name>  
            <param-value>true</param-value>  
        </init-param>  
    </filter>
    <filter-mapping>
        <filter-name>CharacterEncodingFilter</filter-name>
        <url-pattern>/*</url-pattern>
    </filter-mapping>        
  <servlet>
      <servlet-name>springmvc</servlet-name>      <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>
      <!-- 指定加载的配置文件 ，经过参数contextConfigLocation加载-->
      <init-param>
          <param-name>contextConfigLocation</param-name>
          <param-value>classpath:applicationContext-web.xml</param-value>
      </init-param>
  </servlet>  
  <servlet-mapping>
      <servlet-name>springmvc</servlet-name>
      <url-pattern>*.do</url-pattern>
  </servlet-mapping>
</web-app>

（3）拷贝业务接口

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

（4）编写Controller

package com.gh.dubboxdemo.controller;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import com.gh.dubbodemo.service.UserService;
@Controller
@RequestMapping("/user")
public class UserController {
    @Reference
    private UserService userService;    
    @RequestMapping("/showName")
    @ResponseBody
    public String showName(){
        return userService.getName();
    }        
}

（5）编写spring配置文件

在src/main/resources下建立applicationContext-web.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:p="http://www.springframework.org/schema/p"
    xmlns:context="http://www.springframework.org/schema/context"
    xmlns:dubbo="http://code.alibabatech.com/schema/dubbo" 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
        http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc.xsd
        http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd
        http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">

    <mvc:annotation-driven >
        <mvc:message-converters register-defaults="false">
            <bean class="org.springframework.http.converter.StringHttpMessageConverter">  
                <constructor-arg value="UTF-8" />
            </bean>  
        </mvc:message-converters>    
    </mvc:annotation-driven>
    <!-- 引用dubbo 服务 -->
    <dubbo:application name="dubboxdemo-web" />
    <dubbo:registry address="zookeeper://192.168.25.132:2181"/>
     <dubbo:annotation package="com.gh.dubboxdemo.controller" />
</beans>

（6）测试运行

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

服务提供者开发

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

<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>
  <groupId>com.gh.dubboxdemo</groupId>
  <artifactId>dubboxdemo-service</artifactId>
  <version>0.0.1-SNAPSHOT</version>
  <packaging>war</packaging>  
   <properties>        
        <spring.version>4.2.4.RELEASE</spring.version>
   </properties>    
    <dependencies>
        <!-- Spring -->
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-context</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-beans</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-webmvc</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-jdbc</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-aspects</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-jms</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-context-support</artifactId>
            <version>${spring.version}</version>
        </dependency>    
        <!-- dubbo相关 -->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>dubbo</artifactId>
            <version>2.8.4</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>javassist</groupId>
            <artifactId>javassist</artifactId>
            <version>3.11.0.GA</version>
        </dependency>        
    </dependencies>
   <build>  
      <plugins>
          <plugin>  
              <groupId>org.apache.maven.plugins</groupId>  
              <artifactId>maven-compiler-plugin</artifactId>  
              <version>2.3.2</version>  
              <configuration>  
                  <source>1.8</source>  
                  <target>1.8</target>  
              </configuration>  
          </plugin>  
          <plugin>
                <groupId>org.apache.tomcat.maven</groupId>
                <artifactId>tomcat7-maven-plugin</artifactId>
                <configuration>
                    <!-- 指定端口 -->
                    <port>8081</port>
                    <!-- 请求路径 -->
                    <path>/</path>
                </configuration>
            </plugin>
      </plugins>  
    </build>
</project>

（2）在工程的webapps下建立WEB-INF文件夹，建立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"
    version="2.5">    
    <!-- 加载spring容器 -->
    <context-param>
        <param-name>contextConfigLocation</param-name>
        <param-value>classpath:applicationContext*.xml</param-value>
    </context-param>
    <listener>        <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
    </listener>    
</web-app>

（3）建立业务接口

建立包com.gh.dubbodemo.service，用于存放业务接口，建立接口

package com.gh.dubbodemo.service;

public interface UserService {    
    public String getName();    
}

（4）建立业务实现类

建立包com.gh.dubbodemo.service.impl ，用于存放业务实现类。建立业务实现类：

package com.gh.dubbodemo.service.impl;
import com.alibaba.dubbo.config.annotation.Service;
import com.gh.dubbodemo.service.UserService;
@Service
public class UserServiceImpl implements UserService {
    public String getName() {        
        return "success";
    }
}

注意：Service注解与原来不一样，须要引入com.alibaba包下的

（5）编写配置文件

在src/main/resources下建立applicationContext-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:p="http://www.springframework.org/schema/p"
    xmlns:context="http://www.springframework.org/schema/context"
    xmlns:dubbo="http://code.alibabatech.com/schema/dubbo" 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
        http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc.xsd
        http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd
        http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">
     
    <dubbo:application name="dubboxdemo-service"/>  
<dubbo:registry address="zookeeper://192.168.25.132:2181"/> 
<dubbo:annotation package="com.gh.dubboxdemo.service" /> 
</beans>

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

（6）测试运行

tomcat7:run，注意，先运行服务提供者，再运行服务消费者。

3.6.1管理端安装

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

从网上下载个dubbox-master.zip 的资源包，这个是dubbox的源码，咱们可使用maven命令编译源码获得“管理端”的war包，将此压缩包解压，在命令符下进入dubbo-admin目录，输入maven命令

mvn package -Dmaven.skip.test=true

若是你看到以下信息，就说明成功了

（2）进入target文件夹，你会看到一个dubbo-admin-2.8.4.war ，在linux服务器上安装tomcat, 将此war包上传到linux服务器的tomcat的webapps下。

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

dubbo.registry.address=zookeeper://127.0.0.1:2181

修改后从新启动tomcat

3.6.2管理端使用

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

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

点击其中一条数据后能够查看详情。

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