必威体育Betway必威体育官网
当前位置：首页 > IT技术

Dubbox、Zookepeer以及管理中心的使用（附Demo）

时间:2019-08-14 15:41:04来源:IT技术作者:seo实验室小编阅读:54次「手机版」
　

dubbox

dubbox：是一个分布式服务框架，其前身是阿里巴巴开源项目Dubbo，国内的电商以及互联网项目中使用较多，后期阿里巴巴停止了维护，当当网在此基础上进行了维护，并取名为Dubbox。Dubbox是一个分布式服务框架，致力于提高性能和透明化的 RPC 远程服务调用方案，以及SOA服务治理方案。

一、Dubbox架构图（如下图1-1所示）

                   图1-1：Dubbox架构图

1）、长连接：数据传输完了，保持TCP连接不断开，等待在同域名下继续用这个通道传输数据。需要双方检测包以维持连接，一般需要自己在线维持连接。

2）、短连接：指双方有数据交互时，就建立一次TCP连接，数据发送完成后就断开TCP连接。

3）、Provider：服务提供者。

4）、consumer：服务消费者。

5）、Registry：服务注册中心。

6）、monitor：监控中心，用于监控服务调用的次数和调用时间。

7）、Container：服务运行的容器。

调用关系说明：

①、0：容器负责启动、加载、运行服务提供者。

②、1：服务提供者启动时，向注册中心注册自己提供的服务。

③、2：服务消费者启动时，向服务中心订阅自己所需的服务。

④、3：注册中心推送消费者订阅的服务，并基于长连接进行连接，当地址变更时，推送新地址给订阅者。

⑤、4：服务消费者，基于软负载均衡算法，从服务提供者列表中，获取其中一台服务器进行调用。

⑥、5：监控调用次数和时间，可以定时发送统计数据到监控中心。

二、注册中心Zookeeper

注册中心负责服务地址的注册和查找，相当于目录结构，服务提供者和消费者只有在启动时与注册中心交互，注册中心不转发请求，压力较小。zk 将全量数据存储在内存，可谓是高性能，而且支持集群。同时支持变更推送，适合 Dubbo 服务的注册中心，工作强度较高，可用于生产环境。

1）、Zookeeper 在 linux 系统中的安装：

▶ 安装步骤：①、安装 JDK：https://www.cnblogs.com/Dylansuns/p/6974272.html

②、下载 zookeeper 压缩包：http://apache.org/dist/zookeeper/

   ③、将压缩包移至 Linux 中，解压：tar -zxvf zookeeper-3.4.10.tar.gz

④、可以修改目录名称 mv zookeeper-3.4.10 zookeeper

⑤、进入 zookeeper 目录创建 data 目录：mkdir data

⑥、进入 conf 目录：cd conf 将 zoo_simple.cfg 改名为 zoo.cfg：mv zoo_simple.cfg zoo.cfg

⑦、进入 zoo.cfg：vim zoo.cfg 修改 dataDir 属性 dataDir=/安装目录/zookeeper/data

     

⑧、启动：进入 /bin 目录 ./zkserver.sh start    启动服务、

                                     ./zkServer.sh status 查看状态、

                                     ./zkServer.sh stop    停服务。

              

三、Dubbox本地 Jar 包部署与安装

Dubbox 的 jar 包并没有部署到 Maven 的中央仓库中，需要手动将 Jar 包安装到我的本地仓库。先将 jar 包放到 d:/setup（位置随意），然后输入如下命令：

mvn install:install-file -Dfile=d:\setup\dubbo-2.8.4.jar -DgroupId=com.alibaba -DartifactId=dubbo -Dversion=2.8.4 -Dpackaging=jar

四、配置Dubbox的离线约束

1）、下载Dubbox.xsd文件 https://download.csdn.net/download/jesse_li_ma/10229527

2）、通过Eclipse导入xsd https://blog.csdn.net/54powerman/article/details/60956826 

3）、Key的值：http://code.alibaBATech.com/schema/dubbo/dubbo.xsd

五、Dubbox入门程序入门程序

1）、服务类

●  创建 maven 项目：Maven Project ——create  a simple ...——war 工程：整体 demo 结构如下：

    

●  环境搭建：pom.xml 中的内容如下（客户端搭建时，pom.xm l文件内容相同）：

	<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.7</source>  
	              <target>1.7</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>

●  在 webAPP 目录下创建 WEB-INF/ web.xml 文件（添加 spring 配置文件的路径 ）。

<?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>

● 创建接口

package com.yintong.service;
/*
 *@description:接口文档
 */
public interface UserDemo {
	public String getName();
}

● 创建实现类（注意：@Service 注解需要使用 dubbo 提供的注解，负责项目不能对外发布成功）

package com.yintong.service.impl;

import com.alibaba.dubbo.config.annotation.Service;
import com.yintong.service.UserDemo;

@Service
public class UserDemoImp implements UserDemo {

	@Override
	public String getName() {
		return "Dubbox";
	}

}

●  applicationContext-service.xml（最主要的文件，配置了服务在 zookeeper 上的注册）

<?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服务的名称 ,一般跟工程名一样，可以不一样-->
	<dubbo:application name="applicationContext-service"/>
	<!-- 配置zookeeper的地址 -->
	<dubbo:registry address="zookeeper://192.168.159.129:2181"/>
	<!-- 包扫描 接口的实现类-->
	<dubbo:annotation package="com.yintong.service.impl"/>
</beans>

● 服务启动：run as ——>Maven build...——>Golas 中输入：tomcat7:run

2）、消费者

● 配置 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:springmvc.xml</param-value>
		</init-param>
	</servlet>

	<servlet-mapping>
		<servlet-name>springmvc</servlet-name>
		<url-pattern>*.do</url-pattern>
	</servlet-mapping>
</web-app>

● 拷贝服务端的接口类

package com.yintong.service;
/*
 *@description:接口文档
 */
public interface UserDemo {
	public String getName();
}

● 完成 controller 类，需要引入接口类，调用远程方法，使用 @reference 注解

package com.yintong.controller;

import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.requestMapping;
import org.springframework.web.bind.annotation.responseBody;

import com.alibaba.dubbo.config.annotation.Reference;
import com.yintong.service.UserDemo;

@Controller
@RequestMapping("/usr")
public class UserController {
	@Reference
	private UserDemo userdemo;
	
	@RequestMapping("/getName")
	@ResponseBody
	public String getName() {
		return userdemo.getName();
	}
}

● 配置 springmvc.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" />
	<!-- 配置zookeeper的地址 -->
	<dubbo:registry
		address="zookeeper://192.168.159.129:2181" />
	<!-- 包扫描 -->
	<dubbo:annotation package="com.yintong.controller" />
</beans>

3）、测试

六、管理中心的部署

开发时，我们需要通过图形化界面查看注册的提供者和消费者时，可以通过部署一个管理中心来实现。可以直接下载 dubbo-admin.war 包，也可以通过 dubbo-admin 源码通过命令 mvn package -Dmaven.skip.test=true 打 war 包。

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

  如果你部署在 zookeeper 同一台主机并且端口是默认的 2181，则无需修改任何配置。如果不是在一台主机上或端口被修改，需要修改 WEB-INF 下的 dubbo.properties  ，修改如下配置：dubbo.registry.address=zookeeper://127.0.0.1:2181，修改后重新启动 tomcat。

七、管理器使用

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

2）启动服务提供者工程，即可在服务治理-提供者查看到该服务，或者消费者，也可以查看详细等自己研究。

相关阅读

Dubbox框架简介

Dubbox是一个分布式服务框架，其前身是阿里巴巴开源项目Dubbo，被国内电商及互联网项目中使用，后期阿里巴巴停止了该项目的维护，当当网

Dubbox 和Dubbo 为何选择

1. 前言 随着现在互联网行业的发展，越来越多的框架、中间件、容器等开源技术不断地涌现，更好地来服务于业务，解决实现业务的问题。然

Dubbox 环境搭建

第一章：Dubbox简介Dubbox是一个开源的RPC(Remote ProcedureCall Protocol)远程调用框架，是由dangdang对阿里的Dubbo的升级，可以被视

赞()
分享到:

猜你喜欢

栏目导航

推荐阅读

热门阅读

seo实验室提供seo优化服务，有网站优化、网站建设、运营推广等需求请联系我们!
Copyright © 2001-2017 .seo实验室 版权所有 网站地图