Dubbo

2018-12-30 | 阅读：次

Dubbo

为什么使用Dubbo——RPC远程调用

RPC远程调用框架：
1、HttpClient 内部转发 缺点：没有服务治理，没有负载均衡、容错机制、熔断机制
2、Dubbo
3、Dubbox
4、springCloud主流框架 eureka注册中心（fegin、rest客户端调用工具、zull、分布式配置中心、ribbon、hystriy redis）
5、zookeeper

网站架构的演变过程

单点系统（MVC）：控制层controller、业务逻辑层service、数据库访问层dao，几百个程序员同时开发一个项目会产生：代码冲突，适用于小团队开发

互联网公司开发：人多，所以需要满足高并发、高可用、敏捷开发。

分布式开发：讲一个系统拆分成多个子项目，分了各种各样的系统，合并时各自暴露自己的接口，采用RPC远程调用进行访问，项目互不影响。（WebService）Http+xml。SOA

演变过程到微服务架构请见springcloud博客

Dubbo架构

Dubbo能做什么

服务的URL管理非常困难(rmi://、http:*、)、F5负载均衡器的单点压力(硬件成本)

各个服务之间依赖管理非常复杂

各个服务之间如何进行监控

1.透明化的远程方法调用，就像调用本地方法一样调用远程方法，只需简单配置，没有任何API侵入。 2.软负载均衡及容错机制，可在内网替代F5等硬件负鞭均衡器，降低成本，减少单点。 3.服务自动注册与发现，不再需要写死服务提供方地址，注册中心基于楼口名查询服务提供者的IP地址，并且能够平滑添加或删除服务提供者。 4.Dubbo采用全Spring 配置方式，功明化接入应用，对应用没有任何API侵只需用Spring加载Dubbo的配置即可，Dubbo基FSpring的Schema扩入，展进行加载。

Dubbo环境搭建

启动zookeeper

使用zookeeper 作为服务注册中心

创建ripper-interface工程提供会员接口

//会员服务接口
public interface UserService {
	//使用userid查询 用户信息
	public String getUser(Long userId);
}

创建ripper-member-provider工程生产者

	<dependencies>
		<dependency>
			<groupId>com.ripper</groupId>
			<artifactId>ripper-interface</artifactId>
			<version>0.0.1-SNAPSHOT</version>
		</dependency>
		<dependency>
			<groupId>com.alibaba</groupId>
			<artifactId>dubbo</artifactId>
			<version>2.5.6</version>
		</dependency>
		<!-- 添加zk客户端依赖 -->
		<dependency>
			<groupId>com.github.sgroschupf</groupId>
			<artifactId>zkclient</artifactId>
			<version>0.1</version>
		</dependency>
	</dependencies>

定义一个Service实现服务接口

public class UserServiceImpl implements UserService {
	public String getUser(Long userId) {
		System.out.println("###会员服务接受参数开始userId:" + userId);
		if (userId == 1) {
			return "ripper";
		}
		if (userId == 2) {
			return "张杰";
		}
		System.out.println("###会员服务接受参数结束###");
		return "未找到用户...";
	}
}

新建配置文件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="provider" />
	<!-- 使用zookeeper注册中心暴露服务地址 -->
	<dubbo:registry address="zookeeper://127.0.0.1:2181" />
	<!-- 用dubbo协议在29014端口暴露服务 -->
	<dubbo:protocol name="dubbo" port="29014" />
	<!-- 声明需要暴露的服务接口 -->
	<dubbo:service interface="com.hxy.service.UserService"
		ref="userService" />
	<!-- 具体的实现bean -->
	<bean id="userService" class="com.hxy.member.service.impl.UserServiceImpl" />
</beans>

启动Dubbo服务

// 启动会员服务
public class MemberServer {

	public static void main(String[] args) throws IOException {
		ClassPathXmlApplicationContext applicationContext = new ClassPathXmlApplicationContext("provider.xml");
		applicationContext.start();
		System.out.println("会员服务启动成功...");
		System.in.read();
	}
}

创建ripper-order-consumer工程消费者

Maven依赖参数

  <dependencies>
		<dependency>
			<groupId>com.ripper</groupId>
			<artifactId>ripper-interface</artifactId>
			<version>0.0.1-SNAPSHOT</version>
		</dependency>
		<dependency>
			<groupId>com.alibaba</groupId>
			<artifactId>dubbo</artifactId>
			<version>2.5.6</version>
		</dependency>
		<!-- 添加zk客户端依赖 -->
		<dependency>
			<groupId>com.github.sgroschupf</groupId>
			<artifactId>zkclient</artifactId>
			<version>0.1</version>
		</dependency>
	</dependencies>

消费会员服务接口

public class OrderService {
	public static void addOrder() {
		ClassPathXmlApplicationContext applicationContext = new ClassPathXmlApplicationContext("consumer.xml");
		applicationContext.start();
		System.out.println("###order服務,开始调用会员服务");
		UserService userService=(UserService) applicationContext.getBean("userService");
		String userName = userService.getUser(1l);
		System.out.println("###order服務,结束调用会员服务,userName:" + userName);
	}
	public static void main(String[] args) {
		addOrder();
	}
}

配置

<?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" />
	<!-- 使用multicast广播注册中心暴露发现服务地址 -->
	<dubbo:registry protocol="zookeeper" address="zookeeper://127.0.0.1:2181" />
	<!-- 生成远程服务代理，可以和本地bean一样使用demoService -->
	<dubbo:reference id="userService" interface="com.ripper.service.UserService" />
</beans>

Dubbo支持哪些协议？

Dubbo协议

　 Dubbo缺省协议采用单一长连接和NIO异步通讯，适合于小数据量大并发的服务调用，以及服务消费者机器数远大于服务提供者机器数的情况。Dubbo缺省协议不适合传送大数据量的服务，比如传文件，传视频等，除非请求量很低。

Hessian协议

Hessian协议用于集成Hessian的服务，Hessian底层采用Http通讯，采用Servlet暴露服务，Dubbo缺省内嵌Jetty作为服务器实现。Hessian是Caucho开源的一个RPC框架：http://hessian.caucho.com，其通讯效率高于WebService和Java自带的序列化。

基于Hessian的远程调用协议:

连接个数：多连接

连接方式：短连接

传输协议：HTTP

传输方式：同步传输

序列化：Hessian二进制序列化

适用范围：传入传出参数数据包较大，提供者比消费者个数多，提供者压力较大，可传文件。

适用场景：页面传输，文件传输，或与原生hessian服务互操作

HTTP协议

此协议采用spring 的HttpInvoker的功能实现，

连接个数：多个

连接方式：长连接

连接协议：http

传输方式：同步传输

序列化：表单序列化

适用范围：传入传出参数数据包大小混合，提供者比消费者个数多，可用浏览器查看，可用表单或URL传入参数，暂不支持传文件。

适用场景：需同时给应用程序和浏览器JS使用的服务。

RMI协议

采用JDK标准的java.rmi.*实现，采用阻塞式短连接和JDK标准序列化方式

Java标准的远程调用协议：　　

连接个数：多连接

连接方式：短连接

传输协议：TCP

传输方式：同步传输

序列化：Java标准二进制序列化

适用范围：传入传出参数数据包大小混合，消费者与提供者个数差不多，可传文件。

适用场景：常规远程服务方法调用，与原生RMI服务互操作

Dubbo-admin管理平台搭建

步骤:

将dubbo-admin.zip 解压到webapps目录下

修改dubbo.properties zk注册中心连接地址连接信息

启动tomcat即可

服务治理：管理服务、统计、日志管理、容错机制、服务降级、负载均衡、路由策略、权限、权重、注册发现

常见Dubbo面试题

什么是Dubbo？

Duubbo是一个RPC远程调用框架，分布式服务治理框架

什么是Dubbo服务治理？

服务与服务之间会有很多个Url、依赖关系、负载均衡、容错、自动注册服务。

Dubbo有哪些协议？

默认用的dubbo协议、Http、RMI、Hessian

Dubbo整个架构流程

分为四大模块

生产者、消费者、注册中心、监控中心

生产者：提供服务

消费者: 调用服务

注册中心:注册信息(redis、zk)

监控中心:调用次数、关系依赖等。

首先生产者将服务注册到注册中心（zk），使用zk持久节点进行存储，消费订阅zk节点，一旦有节点变更，zk通过事件通知传递给消费者，消费可以调用生产者服务。

服务与服务之间进行调用，都会在监控中心中，存储一个记录。

Dubbox与Dubbo区别？

Dubox使用http协议+rest风格传入json或者xml格式进行远程调用。

Dubbo使用Dubbo协议。

RPC远程调用框架

SpringCloud、dubbo、Dubbox、thint、Hessian

Rpc其实就是远程调用，服务与服务之间相互进行通讯。

目前主流用http+json

SpringCloud与Dubbo区别？

相同点:

dubbo与springcloud都可以实现RPC远程调用。

dubbo与springcloud都可以使用分布式、微服务场景下。

区别:

dubbo有比较强的背景,在国内有一定影响力。

dubbo使用zk或redis作为作为注册中心

springcloud使用eureka作为注册中心

dubbo支持多种协议，默认使用dubbo协议。

dubbo里面是没有网关的，springcloud有zuul网关

Springcloud只能支持http协议。

Springcloud是一套完整的微服务解决方案。

Dubbo目前已经停止更新,SpringCloud更新速度快。

常见错误

在启动dubbo-admin时我们会先启动zookeeper,如果项目跑到zkclient.ZkEventThread - Starting ZkClient event thread.就不走了，那么就是zookeeper没有跑起来，如果你在zookeeper的目录下运行了./zookeeper-3.3.6/bin/zkServer.sh start 还是这样的话，那么请执行/zookeeper-3.3.6/bin/zkServer.sh status命令看看zookeeper是否跑起来了，如果没跑起来很可能是因为你zookeeper下的conf目录没有zoo.cfg

解决办法：把conf目录下的zoo_sample.cfg复制一份为zoo.cfg.