分布式框架RPC框架Dubbo

2024-02-18 17:26:52

文章目录

一.Dubbo概述
- 1.1 简介
- 1.2 Dubbo架构
二.服务注册中心ZooKeeper
- 2.1 ZooKeeper介绍
三.Dubbo快速入门
- 3.1 服务提供方
- 3.2 服务消费方
四.Dubbo相关配置
五.解决Dubbo无法发布被事务代理的Service问题

一.Dubbo概述

1.1 简介

Apache Dubbo是一款高性能的Java RPC框架。其前身是阿里巴巴公司开源的、轻量级的开源Java RPC框架，可以和Spring框架无缝集成。

1.2 Dubbo架构

节点角色说明：
provider:服务提供方
consumer:服务消费方
registry:服务注册中心
monitor:服务调用次数和调用时间监控中心
container:服务运行容器

调用关系说明：

服务容器负责启动，加载，运行服务提供者。

服务提供者在启动时，向注册中心注册自己提供的服务。

服务消费者在启动时，向注册中心订阅自己所需的服务。

注册中心返回服务提供者地址列表给消费者，如果有变更，注册中心将基于长连接推送变更数据给
消费者。

服务消费者，从提供者地址列表中，基于软负载均衡算法，选一台提供者进行调用，如果调用失
败，再选另一台调用。

服务消费者和提供者，在内存中累计调用次数和调用时间，定时每分钟发送一次统计数据到监控中心。

二.服务注册中心ZooKeeper

2.1 ZooKeeper介绍

Zookeeper是Apache Hadoop 的子项目，是一个树型的目录服务，支持变更推送，适合作为 Dubbo服务的注册中心。

流程说明：

服务提供者(Provider)启动时: 向 /dubbo/com.foo.BarService/providers 目录下写入自己的
URL 地址

服务消费者(Consumer)启动时: 订阅 /dubbo/com.foo.BarService/providers 目录下的提供者URL 地址。并向 /dubbo/com.foo.BarService/consumers 目录下写入自己的 URL 地址

监控中心(Monitor)启动时: 订阅 /dubbo/com.foo.BarService 目录下的所有提供者和消费者URL 地址。

三.Dubbo快速入门

Dubbo作为一个RPC框架，核心功能就是实现跨网络远程调用，但本案例只使用一台计算机，不同端口模拟两台机器的互联。

3.1 服务提供方

创建maven工程，打为war包，命名：dubbodemo_provider，导入依赖。

<properties>
	<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
	<maven.compiler.source>1.8</maven.compiler.source>
	<maven.compiler.target>1.8</maven.compiler.target>
	<spring.version>5.0.5.RELEASE</spring.version>
</properties>
<dependencies>
	<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.6.0</version>
	</dependency>
	<dependency>
		<groupId>org.apache.zookeeper</groupId>
		<artifactId>zookeeper</artifactId>
		<version>3.4.7</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.12.1.GA</version>
	</dependency>
	<dependency>
		<groupId>com.alibaba</groupId>
		<artifactId>fastjson</artifactId>
		<version>1.2.47</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>

web.xml文件

<web-app>
	<display-name>Archetype Created Web Application</display-name>
	<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.lxs.service;
public interface HelloService {
	public String sayHello(String name);
}

接口实现类

package com.lxs.service.impl;
import com.alibaba.dubbo.config.annotation.Service;
import com.lxs.service.HelloService;
@Service
public class HelloServiceImpl implements HelloService {
	public String sayHello(String name) {
		return "hello " + name;
	}
}

注意：@Service注解选择Dubbo提供的，用于对外发布服务。

创建applicationContext-service.xml

和Spring Cloud方式一样，需要应用名，应用端口，注册中心地址，这里只是多了一个协议。

这里需要更改的就是zookeeper的地址，我是装在虚拟机，如果是本地，可以写成localhost。

<?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="dubbodemo_provider" />
		<!-- 连接服务注册中心zookeeper ip为zookeeper所在服务器的ip地址-->
		<dubbo:registry address="zookeeper://192.168.134.129:2181"/>
		<!-- 注册 协议和port -->
		<dubbo:protocol name="dubbo" port="20881"></dubbo:protocol>
		<!-- 扫描指定包，加入@Service注解的类会被发布为服务 -->
		<dubbo:annotation package="com.lxs.service.impl" />

启动服务
tomcat7:run

3.2 服务消费方

创建maven项目，dubbodemo_consumer，导入相同的依赖，将tomcat的端口改为8082.
配置web.xml

<web-app>
	<display-name>Archetype Created Web Application</display-name>
	<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>
		<load-on-startup>1</load-on-startup>
	</servlet>
	<servlet-mapping>
		<servlet-name>springmvc</servlet-name>
		<url-pattern>*.do</url-pattern>
	</servlet-mapping>
</web-app>

将服务提供者工程中的HelloService接口复制到当前工程
Controller

@Controller使用的是Dubbo提供的注解

@Controller
@RequestMapping("/demo")
public class HelloController {
	@Reference
	private HelloService helloService;
	
	@RequestMapping("/hello")
	@ResponseBody
	public String getName(String name){
	//远程调用
	String result = helloService.sayHello(name);
	System.out.println(result);
	return result;
	}
}

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">
	<!-- 当前应用名称，用于注册中心计算应用间依赖关系，注意：消费者和提供者应用名不要一样 -->
	<dubbo:application name="dubbodemo-consumer" />
	<!-- 连接服务注册中心zookeeper ip为zookeeper所在服务器的ip地址-->
	<dubbo:registry address="zookeeper://192.168.134.129:2181"/>
	<!-- 扫描的方式暴露接口 -->
	<dubbo:annotation package="com.lxs.controller" />
</beans>

运行测试

tomcat7:run
访问：localhost:8082/demo/hello.do?name=Jack,查看结果。

思考

Q1: 上述案例中我们将服务提供方的接口复制一份到服务消费者，是否有更好的方法？
A1:单独创建一个maven工程，将此接口创建在maven工程中，需要依赖此接口的工程只需要在自己工程的pom.xml文件中引入maven坐标。

Q2：在服务消费方只是引用了接口，并没有提供实现类，Dubbo是如何做到远程调用的？
A2：Dubbo底层是基于代理技术，为该接口创建代理对象，远程调用是通过该对象完成的。此外，Dubbo实现网络传输底层是基于Netty框架完成的。

四.Dubbo相关配置

4.1 包扫描

	<dubbo:annotation package="com.lxs.service" />

服务提供者和服务消费者都需要配置,作用是扫描指定包(包括子包)下的类

如果不使用包扫描，可以使用bean创建对象，再进行引用，如：

<!--服务提供者-->
<bean id="helloService" class="com.lxs.service.impl.HelloServiceImpl" />
<dubbo:service interface="com.lxs.api.HelloService" ref="helloService" />
<!--服务消费者-->
<dubbo:reference id="helloService" interface="com.lxs.api.HelloService" />

4.2 协议

<dubbo:protocol name="dubbo" port="20880"/>

一般在服务提供者一方配置，可以指定使用的协议名称和端口号。

其中Dubbo支持的协议有：dubbo、rmi、hessian、http、webservice、rest、redis等。推荐使用的是dubbo协议。

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

也可以在同一个工程中配置多个协议，如：

<!-- 多协议配置 -->
<dubbo:protocol name="dubbo" port="20880" />
<dubbo:protocol name="rmi" port="1099" />
<!-- 使用dubbo协议暴露服务 -->
<dubbo:service interface="com.lxs.api.HelloService" ref="helloService" protocol="dubbo" />
<!-- 使用rmi协议暴露服务 -->
<dubbo:service interface="com.lxs.api.DemoService" ref="demoService" protocol="rmi" />

4.3 负载均衡

负载均衡的概念在Spring Cloud已经提及，这里主要讲解如何配置Dubbo中的。

可以再服务提供方配置，也可以在服务消费方配置。

@Controller
@RequestMapping("/demo")
public class HelloController {
	//在服务消费者一方配置负载均衡策略
	@Reference(check = false,loadbalance = "random")
	private HelloService helloService;
	
	@RequestMapping("/hello")
	@ResponseBody
	public String getName(String name){
		//远程调用
		String result = helloService.sayHello(name);
		System.out.println(result);
		return result;
	}
}

//在服务提供者一方配置负载均衡
@Service(loadbalance = "random")
public class HelloServiceImpl implements HelloService {
	public String sayHello(String name) {
		return "hello " + name;
	}
}

可以通过启动多个服务提供者来观察Dubbo负载均衡效果。

注意：因为我们是在一台机器上启动多个服务提供者，所以需要修改tomcat的端口号和Dubbo服务的
端口号来防止端口冲突。
在实际生产环境中，多个服务提供者是分别部署在不同的机器上，所以不存在端口冲突问题。

五.解决Dubbo无法发布被事务代理的Service问题

5.2 背景

通过上面的学习，已经完成了Dubbo的入门案例，但是我们如果在服务提供者类上加入@Transactional事务控制注解后，服务就发布不成功了。

5.2 原因

添加事务注解后，事务注解会为服务提供者类创建代理对象，而默认情况下Spring是基于JDK方式创建对象，因此创建出来的完整类名是com.sun.proxy.$Proxy42(后面两个数字不固定）,很明显，该类名与我们自定义的dubbo包扫描路径不同（<dubbo:annotation package="com.lxs.service" />）

5.3 方案

将Spring创建对象的方式改为Cglib代理。

5.4 步骤

开启cglib代理

!--开启事务控制的注解支持-->
<tx:annotation-driven transaction-manager="transactionManager" proxy-target-
class="true"/>

然而依旧无法将服务发布成功，因为Cglib创建对象后，会将服务的接口名改成默认的SpringProxy，但是我们有自己的服务接口名：HelloService，所以还需要在 @Servcie接口 中指定服务接口名。

指定服务接口名

@Service(interfaceClass = HelloService.class)
@Transactional
public class HelloServiceImpl implements HelloService {
	public String sayHello(String name) {
		return "hello " + name;
	}
}

码农公寓

文章目录

一.Dubbo概述

1.1 简介

1.2 Dubbo架构

二.服务注册中心ZooKeeper

2.1 ZooKeeper介绍

三.Dubbo快速入门

3.1 服务提供方

3.2 服务消费方

四.Dubbo相关配置

4.1 包扫描

4.2 协议

4.3 负载均衡

五.解决Dubbo无法发布被事务代理的Service问题

5.2 背景

5.2 原因

5.3 方案

5.4 步骤

相关文章